From b10c22af595bd995e56946bff63b8f2f984b13e8 Mon Sep 17 00:00:00 2001 From: feiyu02 <risaku@163.com> Date: 星期四, 14 八月 2025 17:25:05 +0800 Subject: [PATCH] 2025.8.14 1. 动态溯源模块添加滑动平均异常计算(调试中) --- src/main/kotlin/com/flightfeather/uav/socket/handler/UnderwayWebSocketServerHandler.kt | 15 +++++++-------- 1 files changed, 7 insertions(+), 8 deletions(-) diff --git a/src/main/kotlin/com/flightfeather/uav/socket/handler/UnderwayWebSocketServerHandler.kt b/src/main/kotlin/com/flightfeather/uav/socket/handler/UnderwayWebSocketServerHandler.kt index fef4d1a..11f5696 100644 --- a/src/main/kotlin/com/flightfeather/uav/socket/handler/UnderwayWebSocketServerHandler.kt +++ b/src/main/kotlin/com/flightfeather/uav/socket/handler/UnderwayWebSocketServerHandler.kt @@ -1,25 +1,23 @@ package com.flightfeather.uav.socket.handler -import com.flightfeather.uav.biz.sourcetrace.RealTimeExceptionAnalysisController -import com.flightfeather.uav.common.api2word.utils.JsonUtils +import com.flightfeather.uav.biz.sourcetrace.SourceTraceController import com.flightfeather.uav.common.utils.GsonUtils import com.flightfeather.uav.domain.entity.BaseRealTimeData import com.flightfeather.uav.domain.repository.SceneInfoRep +import com.flightfeather.uav.domain.repository.SourceTraceRep import com.flightfeather.uav.lightshare.bean.DataVo import com.flightfeather.uav.socket.sender.UnderwayWebSocketSender -import com.google.gson.JsonSyntaxException import io.netty.channel.ChannelHandlerContext import io.netty.handler.codec.http.websocketx.TextWebSocketFrame -import org.springframework.stereotype.Component /** * * @date 2025/5/13 * @author feiyu02 */ -class UnderwayWebSocketServerHandler(sceneInfoRep: SceneInfoRep) : BaseHandler() { +class UnderwayWebSocketServerHandler(sceneInfoRep: SceneInfoRep, sourceTraceRep: SourceTraceRep) : BaseHandler() { - private val realTimeExceptionAnalysisController = RealTimeExceptionAnalysisController(sceneInfoRep) + private val sourceTraceController = SourceTraceController(sceneInfoRep, sourceTraceRep) override var tag: String = "UAV-WS" @@ -41,11 +39,11 @@ // Test try { if (msgTxt == "start") { - realTimeExceptionAnalysisController.initTask() + sourceTraceController.initTask() } else { val data = GsonUtils.parserJsonToArrayBeans(msgTxt, DataVo::class.java) data.forEach { - realTimeExceptionAnalysisController.addOneData( + sourceTraceController.addOneData( it.toBaseRealTimeData(BaseRealTimeData::class.java) ) } @@ -53,6 +51,7 @@ } catch (e: Exception) { // ctx?.channel()?.writeAndFlush(TextWebSocketFrame("褰撳墠涓烘祴璇曠姸鎬侊紝浼犺緭鐨勬暟鎹笉鏄蛋鑸暟鎹牸寮�")) println("褰撳墠涓烘祴璇曠姸鎬侊紝浼犺緭鐨勬暟鎹笉鏄蛋鑸暟鎹牸寮�") + e.printStackTrace() } } } -- Gitblit v1.9.3