From 37d47c6a7ab0f454b948b68c987146b261117993 Mon Sep 17 00:00:00 2001
From: Riku <risaku@163.com>
Date: 星期日, 13 七月 2025 22:47:21 +0800
Subject: [PATCH] 2025.7.13 动态溯源逻辑调整
---
src/main/kotlin/com/flightfeather/uav/biz/sourcetrace/SourceTraceController.kt | 26 +++++++++++++++-----------
1 files changed, 15 insertions(+), 11 deletions(-)
diff --git a/src/main/kotlin/com/flightfeather/uav/biz/sourcetrace/SourceTraceController.kt b/src/main/kotlin/com/flightfeather/uav/biz/sourcetrace/SourceTraceController.kt
index 65fc3a8..d721f59 100644
--- a/src/main/kotlin/com/flightfeather/uav/biz/sourcetrace/SourceTraceController.kt
+++ b/src/main/kotlin/com/flightfeather/uav/biz/sourcetrace/SourceTraceController.kt
@@ -110,28 +110,32 @@
}
// 鏁版嵁绐佸彉寮傚父鍥炶皟
- private fun exceptionCallback(ex: PollutedClue) {
- // 婧簮姹℃煋婧愪俊鎭�
- ex.searchScenes(sceneInfoRep)
- ex.msgType = MsgType.PolClue.value
+ private fun exceptionCallback(ex: List<PollutedClue>) {
+ ex.forEach {
+ // 婧簮姹℃煋婧愪俊鎭�
+ it.searchScenes(sceneInfoRep)
+ it.msgType = MsgType.PolClue.value
+ }
// 骞挎挱姹℃煋婧簮寮傚父缁撴灉
UnderwayWebSocketSender.broadcast(MsgType.PolClue.value, ex)
- sourceTraceRep.insert(MsgType.PolClue, ex)
+ sourceTraceRep.insertList(MsgType.PolClue, ex)
// 璁板綍姹℃煋绾跨储
- pollutedSummary.addClue(ex)
+ pollutedSummary.addClueList(ex)
}
// 鏁版嵁鍙樺寲鎻愰啋鍥炶皟
- private fun dataChangeCallback(ex: PollutedClue) {
- // 婧簮姹℃煋婧愪俊鎭�
- ex.searchScenes(sceneInfoRep)
- ex.msgType = MsgType.DataChange.value
+ private fun dataChangeCallback(ex: List<PollutedClue>) {
+ ex.forEach {
+ // 婧簮姹℃煋婧愪俊鎭�
+ it.searchScenes(sceneInfoRep)
+ it.msgType = MsgType.DataChange.value
+ }
// 骞挎挱鏁版嵁鍙樺寲鎻愰啋
UnderwayWebSocketSender.broadcast(MsgType.DataChange.value, ex)
- sourceTraceRep.insert(MsgType.DataChange, ex)
+ sourceTraceRep.insertList(MsgType.DataChange, ex)
}
private fun summaryCallback(ex: AnalysisResult) {
--
Gitblit v1.9.3