From 698f8f0f22af4c66581ce284407e986ca036aec6 Mon Sep 17 00:00:00 2001
From: feiyu02 <risaku@163.com>
Date: 星期四, 23 一月 2025 17:10:26 +0800
Subject: [PATCH] 1. 网格细分逻辑（编写中）
---
src/main/kotlin/com/flightfeather/uav/socket/processor/UnderwayProcessor.kt | 23 ++++++++++++++++++-----
1 files changed, 18 insertions(+), 5 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 7df1965..201bfe4 100644
--- a/src/main/kotlin/com/flightfeather/uav/socket/processor/UnderwayProcessor.kt
+++ b/src/main/kotlin/com/flightfeather/uav/socket/processor/UnderwayProcessor.kt
@@ -1,6 +1,7 @@
package com.flightfeather.uav.socket.processor
-import com.flightfeather.uav.repository.AirDataRepository
+import com.flightfeather.uav.model.epw.EPWDataPrep
+import com.flightfeather.uav.domain.repository.AirDataRep
import com.flightfeather.uav.socket.bean.AirDataPackage
import com.flightfeather.uav.socket.decoder.AirDataDecoder
import com.flightfeather.uav.socket.decoder.DataPackageDecoder
@@ -29,10 +30,13 @@
}
@Autowired
- lateinit var airDataRepository: AirDataRepository
+ lateinit var airDataRep: AirDataRep
- val airDataDecoder = AirDataDecoder.instance
- val dataPackageDecoder = DataPackageDecoder()
+ private val airDataDecoder = AirDataDecoder.instance
+ private val dataPackageDecoder = DataPackageDecoder()
+
+ // 鏁版嵁棰勫鐞嗗嚱鏁�
+ private val dataProcessMap = mutableMapOf<String?, EPWDataPrep>()
@PostConstruct
fun init() {
@@ -62,7 +66,16 @@
when (dataPackage.commandUnit) {
AirCommandUnit.AirData.value -> {
// 浠son鏍煎紡瀛樺偍鍘熷鏁版嵁
- instance.airDataRepository.saveAirData(dataPackage)
+ instance.airDataRep.saveAirData(dataPackage)
+ // 杩涜棰勫鐞嗗悗锛屽瓨鍌ㄨ嚦瀵瑰簲鏁版嵁琛�
+ if (!dataProcessMap.containsKey(dataPackage.deviceCode)) {
+ // 姣忓彴璁惧鏈夊崟鐙殑鏁版嵁棰勫鐞嗗璞�
+ dataProcessMap[dataPackage.deviceCode] = EPWDataPrep(UWDeviceType.getType(dataPackage.deviceCode))
+ }
+ dataProcessMap[dataPackage.deviceCode]?.run {
+ val list = this.mDataPrep2(dataPackage)// 鏁版嵁骞虫粦澶勭悊
+ instance.airDataRep.savePrepData2(list)// 鎸夌収璁惧绫诲瀷瀛樺偍鑷冲搴旀暟鎹〃
+ }
}
}
}
--
Gitblit v1.9.3