1. 新增动态污染溯源新的判定逻辑（待完成）

feiyu02

2025-06-11 f7bdafb7cddd049bbb1bbf265fa006683b4ac693

 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) {