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

feiyu02

2025-05-28 19c90b219bd80f82bfcf799a7adfd03fd469c0b7

 src/main/kotlin/com/flightfeather/uav/socket/handler/UnderwayWebSocketServerHandler.kt

@@ -40,11 +40,15 @@

                // Test
                try {
                    val data = GsonUtils.parserJsonToArrayBeans(msgTxt, DataVo::class.java)
                    data.forEach {
                        realTimeExceptionAnalysisController.addOneData(
                            it.toBaseRealTimeData(BaseRealTimeData::class.java)
                        )
                    if (msgTxt == "start") {
                        realTimeExceptionAnalysisController.initTask()
                    } else {
                        val data = GsonUtils.parserJsonToArrayBeans(msgTxt, DataVo::class.java)
                        data.forEach {
                            realTimeExceptionAnalysisController.addOneData(
                                it.toBaseRealTimeData(BaseRealTimeData::class.java)
                            )
                        }
                    }
                } catch (e: Exception) {
//                    ctx?.channel()?.writeAndFlush(TextWebSocketFrame("当前为测试状态，传输的数据不是走航数据格式"))