From 10354e63eb3298beb9ebcc029dd9f48d8936a272 Mon Sep 17 00:00:00 2001
From: wlzboy <66905212@qq.com>
Date: 星期五, 19 十二月 2025 23:15:05 +0800
Subject: [PATCH] feat:优化同步
---
ruoyi-system/src/main/java/com/ruoyi/system/service/impl/SysTaskEmergencyServiceImpl.java | 29 +++++++++++++++++++++++++++++
1 files changed, 29 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..f6cd1a4 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,31 @@
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;
+ }
+ emergency.setNeedResync(1);
+ emergency.setUpdateTime(new java.util.Date());
+ sysTaskEmergencyMapper.updateSysTaskEmergency(emergency);
+
+//
+// // 鍙湁宸茬粡鍚屾杩囪皟搴﹀崟鐨勪换鍔℃墠闇�瑕佹爣璁伴噸鏂板悓姝�
+// if (emergency.getDispatchSyncStatus() != null && emergency.getDispatchSyncStatus() == 2
+// && emergency.getLegacyDispatchOrdId() != null && emergency.getLegacyDispatchOrdId() > 0) {
+//
+// }
+ } catch (Exception e) {
+ // 鏍囪澶辫触涓嶅奖鍝嶄富娴佺▼锛屽彧璁板綍鏃ュ織
+ Logger log = LoggerFactory.getLogger(SysTaskEmergencyServiceImpl.class);
+ log.error("鏍囪浠诲姟闇�瑕侀噸鏂板悓姝ュけ璐ワ紝浠诲姟ID: {}", taskId, e);
+ }
+ }
}
--
Gitblit v1.9.1