From 3bb4fb15c664d29d179083698fdad35a661b1d7f Mon Sep 17 00:00:00 2001 From: riku <risaku@163.com> Date: 星期四, 28 八月 2025 14:57:40 +0800 Subject: [PATCH] 2025.8.28 1. 添加走航季度报告相关统计功能(待完成) --- src/main/kotlin/com/flightfeather/uav/socket/processor/UnderwayProcessor.kt | 20 +++++++------------- 1 files changed, 7 insertions(+), 13 deletions(-) diff --git a/src/main/kotlin/com/flightfeather/uav/socket/processor/UnderwayProcessor.kt b/src/main/kotlin/com/flightfeather/uav/socket/processor/UnderwayProcessor.kt index 6c5f374..8d7f42f 100644 --- a/src/main/kotlin/com/flightfeather/uav/socket/processor/UnderwayProcessor.kt +++ b/src/main/kotlin/com/flightfeather/uav/socket/processor/UnderwayProcessor.kt @@ -1,27 +1,20 @@ package com.flightfeather.uav.socket.processor -import com.flightfeather.uav.biz.FactorFilter -import com.flightfeather.uav.biz.sourcetrace.RealTimeExceptionAnalysisController -import com.flightfeather.uav.common.location.LocationRoadNearby +import com.flightfeather.uav.biz.sourcetrace.SourceTraceController import com.flightfeather.uav.domain.entity.BaseRealTimeData import com.flightfeather.uav.model.epw.EPWDataPrep import com.flightfeather.uav.domain.repository.AirDataRep -import com.flightfeather.uav.domain.repository.RealTimeDataRep import com.flightfeather.uav.domain.repository.SceneInfoRep -import com.flightfeather.uav.domain.repository.SegmentInfoRep +import com.flightfeather.uav.domain.repository.SourceTraceRep import com.flightfeather.uav.socket.bean.AirDataPackage import com.flightfeather.uav.socket.decoder.AirDataDecoder import com.flightfeather.uav.socket.decoder.DataPackageDecoder import com.flightfeather.uav.socket.eunm.AirCommandUnit -import com.flightfeather.uav.socket.eunm.FactorType import com.flightfeather.uav.socket.eunm.UWDeviceType -import com.flightfeather.uav.socket.handler.UnderwayWebSocketServerHandler import io.netty.channel.ChannelHandlerContext -import org.springframework.beans.factory.annotation.Autowired import org.springframework.stereotype.Component import java.text.SimpleDateFormat import java.util.* -import javax.annotation.PostConstruct /** * 澶勭悊socket鎺ユ敹鐨勬秷鎭� @@ -33,6 +26,7 @@ class UnderwayProcessor( private val airDataRep: AirDataRep, private val sceneInfoRep: SceneInfoRep, + private val sourceTraceRep: SourceTraceRep ) : BaseProcessor() { companion object { @@ -46,7 +40,7 @@ private val dataProcessMap = mutableMapOf<String?, EPWDataPrep>() // 瀹炴椂璧拌埅姹℃煋婧簮澶勭悊鍣� - private val realTimeExceptionAnalysisMap = mutableMapOf<String?, RealTimeExceptionAnalysisController>() + private val sourceTraceMap = mutableMapOf<String?, SourceTraceController>() override var tag: String = "璧拌埅鐩戞祴" @@ -60,11 +54,11 @@ saveToTxt(msg) saveToDataBase(packageData)?.takeIf { it.isNotEmpty() }?.get(0)?.let { // 姣忓彴璁惧鏈夊悇鑷崟鐙殑寮傚父鏁版嵁澶勭悊鍣� - if (!realTimeExceptionAnalysisMap.containsKey(it.deviceCode)) { - realTimeExceptionAnalysisMap[it.deviceCode] = RealTimeExceptionAnalysisController(sceneInfoRep) + if (!sourceTraceMap.containsKey(it.deviceCode)) { + sourceTraceMap[it.deviceCode] = SourceTraceController(sceneInfoRep, sourceTraceRep) } // 灏嗚蛋鑸暟鎹紶鍏ュ紓甯稿鐞嗗櫒 - realTimeExceptionAnalysisMap[it.deviceCode]?.addOneData(it) + sourceTraceMap[it.deviceCode]?.addOneData(it) } } else { -- Gitblit v1.9.3