1. 网格细分逻辑（编写中）

feiyu02

2025-01-23 698f8f0f22af4c66581ce284407e986ca036aec6

 src/main/kotlin/com/flightfeather/uav/socket/processor/UnderwayProcessor.kt

@@ -1,7 +1,7 @@
package com.flightfeather.uav.socket.processor

import com.flightfeather.uav.model.epw.EPWDataPrep
import com.flightfeather.uav.repository.AirDataRepository
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
@@ -30,7 +30,7 @@
    }

    @Autowired
    lateinit var airDataRepository: AirDataRepository
    lateinit var airDataRep: AirDataRep

    private val airDataDecoder = AirDataDecoder.instance
    private val dataPackageDecoder = DataPackageDecoder()
@@ -66,7 +66,7 @@
        when (dataPackage.commandUnit) {
            AirCommandUnit.AirData.value -> {
                // 以json格式存储原始数据
                instance.airDataRepository.saveAirData(dataPackage)
                instance.airDataRep.saveAirData(dataPackage)
                // 进行预处理后，存储至对应数据表
                if (!dataProcessMap.containsKey(dataPackage.deviceCode)) {
                    // 每台设备有单独的数据预处理对象
@@ -74,7 +74,7 @@
                }
                dataProcessMap[dataPackage.deviceCode]?.run {
                    val list = this.mDataPrep2(dataPackage)// 数据平滑处理
                    instance.airDataRepository.savePrepData2(list)// 按照设备类型存储至对应数据表
                    instance.airDataRep.savePrepData2(list)// 按照设备类型存储至对应数据表
                }
            }
        }