From c6e38b6c66de5f5a8df5b8b2ab03a82c3b605db8 Mon Sep 17 00:00:00 2001
From: wlzboy <66905212@qq.com>
Date: 星期三, 03 十二月 2025 00:48:44 +0800
Subject: [PATCH] feat:优化同步
---
ruoyi-system/src/main/java/com/ruoyi/system/service/impl/SysTaskEmergencyServiceImpl.java | 26 ++++++++++++++++++++++++++
1 files changed, 26 insertions(+), 0 deletions(-)
diff --git a/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/SysTaskEmergencyServiceImpl.java b/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/SysTaskEmergencyServiceImpl.java
index a106835..c145c31 100644
--- a/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/SysTaskEmergencyServiceImpl.java
+++ b/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/SysTaskEmergencyServiceImpl.java
@@ -1,5 +1,7 @@
package com.ruoyi.system.service.impl;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import com.ruoyi.system.mapper.SysTaskEmergencyMapper;
@@ -121,4 +123,28 @@
public List<SysTaskEmergency> selectSyncedTasksForStatusUpdate(Integer offset, Integer limit) {
return sysTaskEmergencyMapper.selectSyncedTasksForStatusUpdate(offset, limit);
}
+
+ /**
+ * 鏍囪浠诲姟闇�瑕侀噸鏂板悓姝ワ紙杞﹁締鎴栦汉鍛樺彉鏇存椂璋冪敤锛�
+ */
+ @Override
+ public void markNeedResync(Long taskId) {
+ try {
+ SysTaskEmergency emergency = sysTaskEmergencyMapper.selectSysTaskEmergencyByTaskId(taskId);
+ if (emergency == null) {
+ return;
+ }
+
+ // 鍙湁宸茬粡鍚屾杩囪皟搴﹀崟鐨勪换鍔℃墠闇�瑕佹爣璁伴噸鏂板悓姝�
+ if (emergency.getDispatchSyncStatus() != null && emergency.getDispatchSyncStatus() == 2
+ && emergency.getLegacyDispatchOrdId() != null && emergency.getLegacyDispatchOrdId() > 0) {
+ emergency.setNeedResync(1);
+ sysTaskEmergencyMapper.updateSysTaskEmergency(emergency);
+ }
+ } catch (Exception e) {
+ // 鏍囪澶辫触涓嶅奖鍝嶄富娴佺▼锛屽彧璁板綍鏃ュ織
+ Logger log = LoggerFactory.getLogger(SysTaskEmergencyServiceImpl.class);
+ log.error("鏍囪浠诲姟闇�瑕侀噸鏂板悓姝ュけ璐ワ紝浠诲姟ID: {}", taskId, e);
+ }
+ }
}
--
Gitblit v1.9.1