From 09e6dc3fb7266620fafb5e341808a8eb36e080a1 Mon Sep 17 00:00:00 2001
From: wlzboy <66905212@qq.com>
Date: 星期六, 13 十二月 2025 22:51:52 +0800
Subject: [PATCH] feat:增加企业微信消息提醒
---
ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/LegacySystemSyncTask.java | 115 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++-
1 files changed, 113 insertions(+), 2 deletions(-)
diff --git a/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/LegacySystemSyncTask.java b/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/LegacySystemSyncTask.java
index 6f28280..3c724a9 100644
--- a/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/LegacySystemSyncTask.java
+++ b/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/LegacySystemSyncTask.java
@@ -1,6 +1,8 @@
package com.ruoyi.quartz.task;
import com.ruoyi.system.service.ITaskAttachmentSyncService;
+import com.ruoyi.system.service.IPaymentSyncService;
+import com.ruoyi.system.service.IAdditionalFeeSyncService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
@@ -22,6 +24,8 @@
* 3. TaskStatusSyncService - 浠诲姟鐘舵�佸悓姝ワ紙浠庢棫绯荤粺鍒版柊绯荤粺锛�
* 4. TaskStatusPushService - 浠诲姟鐘舵�佹帹閫侊紙浠庢柊绯荤粺鍒版棫绯荤粺锛�
* 5. TaskAttachmentSyncService - 浠诲姟闄勪欢鍚屾锛堜粠鏂扮郴缁熷埌鏃х郴缁燂級
+ * 6. PaymentSyncService - 鏀粯淇℃伅鍚屾锛堝弻鍚戝悓姝ワ級
+ * 7. AdditionalFeeSyncService - 闄勫姞璐圭敤鍚屾锛堝弻鍚戝悓姝ワ級
*/
@Component("legacySystemSyncTask")
public class LegacySystemSyncTask {
@@ -39,6 +43,12 @@
@Autowired
private ITaskAttachmentSyncService taskAttachmentSyncService;
+
+ @Autowired
+ private IPaymentSyncService paymentSyncService;
+
+ @Autowired
+ private IAdditionalFeeSyncService additionalFeeSyncService;
@@ -158,12 +168,113 @@
* 3. 鏈夎皟搴﹀崟ID鍜屾湇鍔″崟ID
*/
public void syncPendingAttachments() {
- log.info("寮�濮嬫墽琛屼换鍔￠檮浠跺悓姝ュ畾鏃朵换鍔�");
+// log.info("寮�濮嬫墽琛屼换鍔￠檮浠跺悓姝ュ畾鏃朵换鍔�");
try {
int successCount = taskAttachmentSyncService.batchSyncPendingAttachments();
- log.info("浠诲姟闄勪欢鍚屾瀹屾垚锛屾垚鍔熷悓姝�: {} 涓檮浠�", successCount);
+// log.info("浠诲姟闄勪欢鍚屾瀹屾垚锛屾垚鍔熷悓姝�: {} 涓檮浠�", successCount);
} catch (Exception e) {
log.error("浠诲姟闄勪欢鍚屾寮傚父", e);
}
}
+
+ /**
+ * 鎵归噺鍚屾鏀粯淇℃伅鍒版棫绯荤粺PaidMoney琛�
+ *
+ * 浣跨敤绀轰緥:
+ * 鍦ㄧ郴缁熺鐞� -> 瀹氭椂浠诲姟涓坊鍔�:
+ * 浠诲姟鍚嶇О: 鏀粯淇℃伅鍚屾
+ * 浠诲姟缁勫悕: DEFAULT
+ * 璋冪敤鐩爣瀛楃涓�: legacySystemSyncTask.syncPaymentToLegacy()
+ * cron琛ㄨ揪寮�: 0 0/10 * * * ? (姣�10鍒嗛挓鎵ц涓�娆�)
+ */
+ public void syncPaymentToLegacy() {
+// log.info("寮�濮嬫墽琛屾敮浠樹俊鎭悓姝ュ畾鏃朵换鍔★紙鏂扮郴缁� -> 鏃х郴缁燂級");
+ try {
+ int successCount = paymentSyncService.batchSyncPaymentToLegacy();
+// log.info("鏀粯淇℃伅鍚屾瀹屾垚锛屾垚鍔熷悓姝�: {} 鏉¤褰�", successCount);
+ } catch (Exception e) {
+ log.error("鏀粯淇℃伅鍚屾寮傚父", e);
+ }
+ }
+
+ /**
+ * 鎵归噺鍚屾鏀粯淇℃伅浠庢棫绯荤粺鍒版柊绯荤粺
+ *
+ * 浣跨敤绀轰緥:
+ * 鍦ㄧ郴缁熺鐞� -> 瀹氭椂浠诲姟涓坊鍔�:
+ * 浠诲姟鍚嶇О: 鏀粯淇℃伅鍙嶅悜鍚屾
+ * 浠诲姟缁勫悕: DEFAULT
+ * 璋冪敤鐩爣瀛楃涓�: legacySystemSyncTask.syncPaymentFromLegacy()
+ * cron琛ㄨ揪寮�: 0 0/15 * * * ? (姣�15鍒嗛挓鎵ц涓�娆�)
+ */
+ public void syncPaymentFromLegacy() {
+// log.info("寮�濮嬫墽琛屾敮浠樹俊鎭悓姝ュ畾鏃朵换鍔★紙鏃х郴缁� -> 鏂扮郴缁燂級");
+ try {
+ int successCount = paymentSyncService.batchSyncPaymentFromLegacy();
+// log.info("鏀粯淇℃伅鍚屾瀹屾垚锛屾垚鍔熷悓姝�: {} 鏉¤褰�", successCount);
+ } catch (Exception e) {
+ log.error("鏀粯淇℃伅鍚屾寮傚父", e);
+ }
+ }
+
+ /**
+ * 鎵归噺鍚屾闄勫姞璐圭敤鍒版棫绯荤粺PaidMoney_Add琛�
+ *
+ * 浣跨敤绀轰緥:
+ * 鍦ㄧ郴缁熺鐞� -> 瀹氭椂浠诲姟涓坊鍔�:
+ * 浠诲姟鍚嶇О: 闄勫姞璐圭敤鍚屾
+ * 浠诲姟缁勫悕: DEFAULT
+ * 璋冪敤鐩爣瀛楃涓�: legacySystemSyncTask.syncAdditionalFeeToLegacy()
+ * cron琛ㄨ揪寮�: 0 0/10 * * * ? (姣�10鍒嗛挓鎵ц涓�娆�)
+ */
+ public void syncAdditionalFeeToLegacy() {
+// log.info("寮�濮嬫墽琛屾柊绯荤粺闄勫姞璐圭敤鍚屾瀹氭椂浠诲姟锛堟柊绯荤粺 -> 鏃х郴缁燂級");
+ try {
+ int successCount = additionalFeeSyncService.batchSyncAdditionalFeeToLegacy();
+// log.info("闄勫姞璐圭敤鍚屾瀹屾垚锛屾垚鍔熷悓姝�: {} 鏉¤褰�", successCount);
+ } catch (Exception e) {
+ log.error("闄勫姞璐圭敤鍚屾寮傚父", e);
+ }
+ }
+
+ /**
+ * 鎵归噺鍚屾闄勫姞璐圭敤浠庢棫绯荤粺鍒版柊绯荤粺
+ *
+ * 浣跨敤绀轰緥锛�
+ * 鍦ㄧ郴缁熺鐞� -> 瀹氭椂浠诲姟涓坊鍔狅細
+ * 浠诲姟鍚嶇О锛� 闄勫姞璐圭敤鍙嶅悜鍚屾
+ * 浠诲姟缁勫悕锛� DEFAULT
+ * 璋冪敤鐩爣瀛楃涓诧細 legacySystemSyncTask.syncAdditionalFeeFromLegacy()
+ * cron琛ㄨ揪寮忥細 0 0/15 * * * ? (姣�15鍒嗛挓鎵ц涓�娆�)
+ */
+ public void syncAdditionalFeeFromLegacy() {
+// log.info("寮�濮嬫墽琛屾棫绯荤粺闄勫姞璐圭敤鍚屾瀹氭椂浠诲姟锛堟棫绯荤粺 -> 鏂扮郴缁燂級");
+ try {
+ // 鍚屾鏈�杩�24灏忔椂鍐呯殑璁板綍
+ int successCount = additionalFeeSyncService.batchSyncAdditionalFeeFromLegacy(72);
+// log.info("鏃х郴缁熼檮鍔犺垂鐢ㄥ悓姝ュ畬鎴愶紝鎴愬姛鍚屾: {} 鏉¤褰�", successCount);
+ } catch (Exception e) {
+ log.error("闄勫姞璐圭敤鍚屾寮傚父", e);
+ }
+ }
+
+ /**
+ * 鎵归噺閲嶆柊鍚屾杞﹁締鍜屼汉鍛樺彉鏇寸殑浠诲姟
+ *
+ * 浣跨敤绀轰緥锛�
+ * 鍦ㄧ郴缁熺鐞� -> 瀹氭椂浠诲姟涓坊鍔狅細
+ * 浠诲姟鍚嶇О锛� 閲嶆柊鍚屾杞﹁締浜哄憳鍙樻洿
+ * 浠诲姟缁勫悕锛� DEFAULT
+ * 璋冪敤鐩爣瀛楃涓诧細 legacySystemSyncTask.resyncVehicleAndPersonnel()
+ * cron琛ㄨ揪寮忥細 0 0/5 * * * ? (姣�5鍒嗛挓鎵ц涓�娆�)
+ */
+ public void resyncVehicleAndPersonnel() {
+ log.info("寮�濮嬫墽琛岄噸鏂板悓姝ヨ溅杈嗗拰浜哄憳鍙樻洿鐨勪换鍔″畾鏃朵换鍔�");
+ try {
+ int successCount = legacySystemSyncService.batchResyncPendingDispatchOrders();
+ log.info("閲嶆柊鍚屾杞﹁締鍜屼汉鍛樺彉鏇村畬鎴愶紝鎴愬姛鍚屾: {} 涓换鍔�", successCount);
+ } catch (Exception e) {
+ log.error("閲嶆柊鍚屾杞﹁締鍜屼汉鍛樺彉鏇村紓甯�", e);
+ }
+ }
}
--
Gitblit v1.9.1