From f7bdafb7cddd049bbb1bbf265fa006683b4ac693 Mon Sep 17 00:00:00 2001
From: feiyu02 <risaku@163.com>
Date: 星期三, 11 六月 2025 17:08:35 +0800
Subject: [PATCH] 1. 新增动态污染溯源新的判定逻辑(待完成)

---
 src/main/kotlin/com/flightfeather/uav/biz/sourcetrace/SourceTraceController.kt |   21 +++++++++++----------
 1 files changed, 11 insertions(+), 10 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 cefe129..662cd6b 100644
--- a/src/main/kotlin/com/flightfeather/uav/biz/sourcetrace/SourceTraceController.kt
+++ b/src/main/kotlin/com/flightfeather/uav/biz/sourcetrace/SourceTraceController.kt
@@ -35,23 +35,23 @@
         else
             RTExcWindLevelConfig(
                 FactorFilter.builder()
-//                .withMain(FactorType.NO2)
-                    .withMain(FactorType.CO)
-//                .withMain(FactorType.H2S)
-//                .withMain(FactorType.SO2)
-//                .withMain(FactorType.O3)
+//                    .withMain(FactorType.NO2)
+//                    .withMain(FactorType.CO)
+//                    .withMain(FactorType.H2S)
+//                    .withMain(FactorType.SO2)
+//                    .withMain(FactorType.O3)
                     .withMain(FactorType.PM25)
                     .withMain(FactorType.PM10)
                     .withMain(FactorType.VOC)
                     .create()
             )
-        pollutedSummary = PollutedSummary(config){ summaryCallback(it)}
+        pollutedSummary = PollutedSummary(config) { summaryCallback(it) }
         newTask()
     }
 
     constructor(sceneInfoRep: SceneInfoRep) : this(sceneInfoRep, null)
 
-    private val pollutedSummary:PollutedSummary
+    private val pollutedSummary: PollutedSummary
 
     private val sceneInfoRep: SceneInfoRep
 
@@ -71,6 +71,7 @@
             add(RTExcWindLevel1_1(config) { exceptionCallback(it) }.also { it.init() })
             add(RTExcWindLevel4(config) { exceptionCallback(it) }.also { it.init() })
             add(RTExcWindLevel6(config) { exceptionCallback(it) }.also { it.init() })
+            add(RTExcChangeRate(config) { exceptionCallback(it) }.also { it.init() })
         }
     }
 
@@ -102,11 +103,11 @@
         // 婧簮姹℃煋婧愪俊鎭�
         ex.searchScenes(sceneInfoRep)
 
-        // 璁板綍姹℃煋绾跨储
-        pollutedSummary.addClue(ex)
-
         // 骞挎挱姹℃煋婧簮寮傚父缁撴灉
         UnderwayWebSocketSender.broadcast(MsgType.PolClue.value, ex)
+
+        // 璁板綍姹℃煋绾跨储
+        pollutedSummary.addClue(ex)
     }
 
     private fun summaryCallback(ex: PollutedSummary.AnalysisResult) {

--
Gitblit v1.9.3