1. 新增动态污染溯源的数据异常判断逻辑 2. 新增动态污染溯源websocket连接功能

feiyu02

2025-05-13 1571cd0f137ced4345fa8785e166a29dc31b6ad1

 src/main/kotlin/com/flightfeather/uav/domain/repository/impl/AirDataRepImpl.kt

@@ -127,8 +127,8 @@
        return count
    }

    override fun savePrepData2(dataList: List<DataVo>): Int {
        var count = 0
    override fun savePrepData2(dataList: List<DataVo>): List<BaseRealTimeData> {
        val res = mutableListOf<BaseRealTimeData>()
        dataList.forEach {vo ->
            when (UWDeviceType.getType(vo.deviceCode)) {
                UWDeviceType.VEHICLE -> {
@@ -139,7 +139,7 @@
                    calibration(d, UWDeviceType.VEHICLE)
                    /***************************************************************************************************/
                    realTimeDataVehicleMapper.insert(d)
                    count++
                    res.add(d)
                }
                UWDeviceType.UAV -> {
                    val d = RealTimeDataUav()
@@ -164,7 +164,7 @@
                    }
                    /***************************************************************************************************/
                    realTimeDataUavMapper.insert(d)
                    count++
                    res.add(d)
                }
                UWDeviceType.GRID -> {
                    val d = RealTimeDataGrid()
@@ -196,7 +196,7 @@
//                    d.h2s = d.h2s?.let { sqrt(it) * 2 }
                    /**************************************************************************/
                    realTimeDataGridMapper.insert(d)
                    count++
                    res.add(d)
                }
                UWDeviceType.BOAT -> {

@@ -204,7 +204,7 @@
                else -> Unit
            }
        }
        return count
        return res
    }

    private fun dataTransform(vo: RealTimeData, bean: BaseRealTimeData) {