1.添加无人机多参数的数据接收解析函数 2.添加参数存储函数

riku

2020-06-11 585fb9b67dc81f9e14f2cbf59f1c3a02eb4fe98f

 src/main/kotlin/com/flightfeather/uav/socket/decoder/impl/DataUnitDecoderImpl.kt

@@ -1,12 +1,10 @@
package com.flightfeather.uav.socket.decoder.impl

import com.flightfeather.uav.socket.bean.*
import com.flightfeather.uav.socket.bean.AirData
import com.flightfeather.uav.socket.bean.AirTypeData
import com.flightfeather.uav.socket.decoder.DataUnitDecoder
import com.flightfeather.uav.socket.decoder.RealTimeDataDecoder
import com.flightfeather.uav.socket.eunm.ObdDataType
import com.flightfeather.uav.socket.eunm.FactorType
import org.slf4j.LoggerFactory
import java.lang.StringBuilder
import java.util.*

/**
 * @author riku
@@ -15,113 +13,34 @@
class DataUnitDecoderImpl : DataUnitDecoder {

    private val logger = LoggerFactory.getLogger(javaClass.name)
    private var realTimeDataDecoder: RealTimeDataDecoder = RealTimeDataDecoderImpl()

    override fun getCarRegisterData(b: List<String>): List<CarRegisterData> {
        val time = decodeDataTime(b)

        val serialNum = "${b[6]}${b[7]}".toInt(16)

        val simCode = StringBuilder()
        for (i in 10 until b.size) {
            simCode.append(b[i].toInt(16).toChar())
        }

        return mutableListOf(CarRegisterData(time, serialNum, simCode.toString()))
    }

    override fun getRealTimeData(b: List<String>): List<RealTimeData> {
        val time = decodeDataTime(b)

        //国标法: 起始字节为7 开始的2个字节表示 流水号
//        val serialNum = "${b[7]}${b[8]}".toInt(16)

        //上海法: 起始字节为6 开始的2个字节表示 流水号
        val serialNum = "${b[6]}${b[7]}".toInt(16)

        val dataList = mutableListOf<String>().apply { addAll(b) }
        //删去前6位时间
        for (i in 0..5) {
            if (dataList.isNotEmpty()) dataList.removeAt(0)
        }

        //fixme 2019.9.15 目前两种规则有冲突，并且只从数据内容无法区分。暂时使用 国标法
        /*
        * 删去流水号，得到信息标志与信息体的组合
        * (国标法：去除前6位时间后，起始字节为1 开始的2个字节表示 流水号)
        */
//        if (dataList.size >= 2) dataList.removeAt(1)
//        if (dataList.size >= 2) dataList.removeAt(1)

        /*
        * 删去流水号，得到信息标志与信息体的组合
        * (上海法：去除前6位时间后，起始字节为0 开始的2个字节表示 流水号)
        */
        if (dataList.isNotEmpty()) dataList.removeAt(0)
        if (dataList.isNotEmpty()) dataList.removeAt(0)

        val resultList = mutableListOf<RealTimeData>()

        /*
         * 最终得到的数据结构为 [ 信息类型标志, 信息体, ...... , 信息类型标志, 信息体 ]
         */
        while (dataList.isNotEmpty()) {
            //得到最前面的一组信息类型+信息体列表
            val data = realTimeDataDecoder.getDataListByDataType(dataList)
            if (data.isNotEmpty()) {
                val r = when (data[0].toInt(16)) {
                    ObdDataType.ObdData.value -> realTimeDataDecoder.getObdData(time, serialNum, data)
                    ObdDataType.EngineDataFlow.value -> realTimeDataDecoder.getEngineDataStream(time, serialNum, data)
                    ObdDataType.SupplementDataFlow.value -> realTimeDataDecoder.getSupplementDataStream(time, serialNum, data)
                    else -> null
                }

                if (r != null) {
                    resultList.add(r)
                }

                for (i in 0 until data.size) {
                    if (dataList.isNotEmpty()) dataList.removeAt(0)
                }
            }else if (dataList.isNotEmpty()) {
                //按照规则没有取到信息体，并且原数据不为空，表示原数据格式错误，退出循环
                logger.error("-------数据信息流或补充数据流格式错误")
                break
    override fun getAirConfirmData(b: List<String>): List<AirTypeData> {
        val resultList = mutableListOf<AirTypeData>()
        b.forEach {
            FactorType.getByIndex(it.toInt(16))?.let { f->
                resultList.add(AirTypeData(f))
            }
        }

        return resultList
    }

    override fun getReplacementData(b: List<String>): List<ReplacementData> = getRealTimeData(b)

    override fun getCarLogOutData(b: List<String>): List<CarLogOutData> {
        val time = decodeDataTime(b)

        val serialNum = "${b[6]}${b[7]}".toInt(16)

        return mutableListOf(CarLogOutData(time, serialNum))
    }

    override fun getTimeCalibrationData(b: List<String>): List<TimeCalibrationData> = emptyList()

    override fun decodeDataTime(b: List<String>): Date? {
        if (b.size < 6) {
            return null
    override fun getAirData(b: List<String>): List<AirData> {
        val resultList = mutableListOf<AirData>()
        var i = 0
        while (i < b.size - 3) {
            val a = "${b[i]}${b[i + 1]}".toInt(16)
            var b1 = b[i + 2].toInt(16).toDouble()
            while (b1 >= 1) {
                b1 /= 10
            }
            val data = a + b1
            resultList.add(AirData().apply {
                factorData = data
            })
            i += 3
        }

        val year = b[0].toInt(16) + 2000
        if (year < 2000 || year > 2099) return null
        val month = b[1].toInt(16)
        val day = b[2].toInt(16)
        val hour = b[3].toInt(16)
        val min = b[4].toInt(16)
        val sec = b[5].toInt(16)
        val cal  = Calendar.getInstance().apply {
            set(year, month - 1, day, hour, min, sec)
            set(Calendar.MILLISECOND, 0)
        }

        return cal.time
        return resultList
    }
}