From 847a7773ef1a8ad418c6934d35b5f205a97c04d0 Mon Sep 17 00:00:00 2001
From: wlzboy <66905212@qq.com>
Date: 星期六, 06 十二月 2025 17:03:24 +0800
Subject: [PATCH] fix:在任务状态更新时，需要更新日志到旧系统
---
ruoyi-system/src/main/java/com/ruoyi/system/mapper/SysTaskEmergencyMapper.java | 51 +++++++++++++++++++++++++++++++++++++++++++++++++--
1 files changed, 49 insertions(+), 2 deletions(-)
diff --git a/ruoyi-system/src/main/java/com/ruoyi/system/mapper/SysTaskEmergencyMapper.java b/ruoyi-system/src/main/java/com/ruoyi/system/mapper/SysTaskEmergencyMapper.java
index 49fc98f..b27cb02 100644
--- a/ruoyi-system/src/main/java/com/ruoyi/system/mapper/SysTaskEmergencyMapper.java
+++ b/ruoyi-system/src/main/java/com/ruoyi/system/mapper/SysTaskEmergencyMapper.java
@@ -1,6 +1,10 @@
package com.ruoyi.system.mapper;
import java.util.List;
+
+import com.ruoyi.common.annotation.DataSource;
+import com.ruoyi.common.enums.DataSourceType;
+import org.apache.ibatis.annotations.Param;
import com.ruoyi.system.domain.SysTaskEmergency;
/**
@@ -9,6 +13,7 @@
* @author ruoyi
* @date 2024-01-16
*/
+@DataSource(DataSourceType.MASTER)
public interface SysTaskEmergencyMapper {
/**
@@ -61,15 +66,57 @@
/**
* 鏌ヨ寰呭悓姝ョ殑鎬ユ晳杞繍浠诲姟鍒楄〃锛堝悓姝ョ姸鎬佷负0鎴�3鐨勪换鍔★級
+ * 鏀寔鍒嗛〉鏌ヨ锛岃繃婊ゅ凡瀹屾垚/宸插彇娑堢殑浠诲姟
*
+ * @param offset 鍋忕Щ閲忥紙浠庣鍑犳潯寮�濮嬶級
+ * @param limit 姣忛〉鏁伴噺
* @return 鎬ユ晳杞繍浠诲姟鍒楄〃
*/
- public List<SysTaskEmergency> selectPendingSyncTasks();
+ public List<SysTaskEmergency> selectPendingSyncTasks(@Param("offset") Integer offset, @Param("limit") Integer limit);
/**
* 鏌ヨ寰呭悓姝ヨ皟搴﹀崟鐨勪换鍔″垪琛紙宸插悓姝ユ湇鍔″崟浣嗘湭鍚屾璋冨害鍗曪級
+ * 鏀寔鍒嗛〉鏌ヨ锛岃繃婊ゅ凡瀹屾垚/宸插彇娑堢殑浠诲姟
*
+ * @param offset 鍋忕Щ閲忥紙浠庣鍑犳潯寮�濮嬶級
+ * @param limit 姣忛〉鏁伴噺
* @return 鎬ユ晳杞繍浠诲姟鍒楄〃
*/
- public List<SysTaskEmergency> selectPendingDispatchSyncTasks();
+ public List<SysTaskEmergency> selectPendingDispatchSyncTasks(@Param("offset") Integer offset, @Param("limit") Integer limit);
+
+ /**
+ * 鏌ヨ宸插悓姝ヨ皟搴﹀崟涓旂姸鎬佹湭瀹屾垚鐨勪换鍔″垪琛紙鐢ㄤ簬鐘舵�佸悓姝ワ級
+ * 鏀寔鍒嗛〉鏌ヨ
+ *
+ * @param offset 鍋忕Щ閲忥紙浠庣鍑犳潯寮�濮嬶級
+ * @param limit 姣忛〉鏁伴噺
+ * @return 鎬ユ晳杞繍浠诲姟鍒楄〃
+ */
+ public List<SysTaskEmergency> selectSyncedTasksForStatusUpdate(@Param("offset") Integer offset, @Param("limit") Integer limit);
+
+ /**
+ * 鏍规嵁鏃х郴缁熸湇鍔″崟ID鏌ヨ鎬ユ晳杞繍浠诲姟鎵╁睍淇℃伅
+ *
+ * @param legacyServiceOrdId 鏃х郴缁熸湇鍔″崟ID
+ * @return 鎬ユ晳杞繍浠诲姟鎵╁睍淇℃伅
+ */
+ public SysTaskEmergency selectByLegacyServiceOrdId(@Param("legacyServiceOrdId") Long legacyServiceOrdId);
+
+ /**
+ * 鏍规嵁鏃х郴缁熻皟搴﹀崟ID鏌ヨ鎬ユ晳杞繍浠诲姟鎵╁睍淇℃伅
+ *
+ * @param legacyDispatchOrdId 鏃х郴缁熻皟搴﹀崟ID
+ * @return 鎬ユ晳杞繍浠诲姟鎵╁睍淇℃伅
+ */
+ public SysTaskEmergency selectByLegacyDispatchOrdId(@Param("legacyDispatchOrdId") Long legacyDispatchOrdId);
+
+ /**
+ * 鏌ヨ闇�瑕侀噸鏂板悓姝ョ殑浠诲姟鍒楄〃锛堣溅杈嗘垨浜哄憳鍙樻洿锛�
+ * 鏀寔鍒嗛〉鏌ヨ锛岃繃婊ゅ凡瀹屾垚/宸插彇娑堢殑浠诲姟
+ *
+ * @param offset 鍋忕Щ閲忥紙浠庣鍑犳潯寮�濮嬶級
+ * @param limit 姣忛〉鏁伴噺
+ * @return 鎬ユ晳杞繍浠诲姟鍒楄〃
+ */
+ public List<SysTaskEmergency> selectNeedResyncTasks(@Param("offset") Integer offset, @Param("limit") Integer limit);
}
--
Gitblit v1.9.1