From 594de76ed51fd49fb79b912212bb0052a63e7671 Mon Sep 17 00:00:00 2001
From: feiyu02 <risaku@163.com>
Date: 星期四, 09 四月 2026 16:10:45 +0800
Subject: [PATCH] 2026.4.9
---
src/main/kotlin/com/flightfeather/uav/domain/repository/impl/AirDataRepImpl.kt | 18 +++++++++---------
1 files changed, 9 insertions(+), 9 deletions(-)
diff --git a/src/main/kotlin/com/flightfeather/uav/domain/repository/impl/AirDataRepImpl.kt b/src/main/kotlin/com/flightfeather/uav/domain/repository/impl/AirDataRepImpl.kt
index 2931e5b..59e2d87 100644
--- a/src/main/kotlin/com/flightfeather/uav/domain/repository/impl/AirDataRepImpl.kt
+++ b/src/main/kotlin/com/flightfeather/uav/domain/repository/impl/AirDataRepImpl.kt
@@ -35,11 +35,11 @@
private val tmpVehicleDataList = mutableListOf<BaseRealTimeData>()
// 璧拌埅鐩戞祴鏍″噯绯绘暟
- private val calibrationMap = mutableMapOf<String, MutableMap<Int, Float>>()
+ private val calibrationMap = mutableMapOf<String?, MutableMap<Int, Float>>()
// 璧拌埅鐩戞祴鏍″噯绯绘暟鏇存柊鏃堕棿
private var cUpdateTime = LocalDateTime.now()
// 璧拌埅鐩戞祴鏍″噯绯绘暟鏇存柊鏃堕棿闂撮殧锛堝垎閽燂級
- private val cInterval = 5L
+ private val cInterval = 1L
override fun saveAirData(dataPackage: AirDataPackage): Int {
val data = RealTimeData().apply {
@@ -135,7 +135,7 @@
val d = vo.toBaseRealTimeData(RealTimeDataVehicle::class.java)
/***************************************************************************************************/
// FIXME: 2021/10/27 杞﹁浇鐩戞祴閮ㄥ垎鍥犲瓙閲忕骇璋冩暣
- calibration(d, UWDeviceType.VEHICLE)
+ calibration(d, d.deviceCode)
/***************************************************************************************************/
realTimeDataVehicleMapper.insert(d)
res.add(d)
@@ -267,20 +267,20 @@
}
}
- private fun calibration(data: BaseRealTimeData, type: UWDeviceType) {
+ private fun calibration(data: BaseRealTimeData, deviceCode: String?) {
//1. 鏍″噯绯绘暟鎸夌収涓�瀹氭椂闂撮棿闅旇繘琛屽埛鏂�
val now = LocalDateTime.now()
- if (calibrationMap.isEmpty() || now.minusMinutes(cInterval).isAfter(cUpdateTime)) {
+ if (calibrationMap[deviceCode].isNullOrEmpty() || now.minusMinutes(cInterval).isAfter(cUpdateTime)) {
cUpdateTime = now
- calibrationMap[type.value] = mutableMapOf()
+ calibrationMap[deviceCode] = mutableMapOf()
factorCalibrationMapper.selectByExample(Example(FactorCalibration::class.java).apply {
- createCriteria().andEqualTo("deviceType", type.value)
+ createCriteria().andEqualTo("deviceType", deviceCode)
}).forEach {
- calibrationMap[type.value]?.put(it.factorId, it.factorScale)
+ calibrationMap[deviceCode]?.put(it.factorId, it.factorScale)
}
}
//2. 鏍规嵁鏍″噯绯绘暟璁＄畻
- calibrationMap[type.value]?.let{
+ calibrationMap[deviceCode]?.let {
data.voc = data.voc?.times(it[FactorType.VOC.value] ?: 1f)
data.co = data.co?.times(it[FactorType.CO.value] ?: 1f)
data.pm25 = data.pm25?.times(it[FactorType.PM25.value] ?: 1f)
--
Gitblit v1.9.3