2025.9.30 1. 新增走航任务统计功能

feiyu02

2025-09-30 94fee0b511279679b43e210878d3d36e5a14384b

 src/main/kotlin/com/flightfeather/uav/biz/dataanalysis/model/ExceptionTag.kt

@@ -2,13 +2,20 @@

import com.flightfeather.uav.biz.dataanalysis.BaseExceptionResult
import com.flightfeather.uav.domain.entity.BaseRealTimeData
import org.apache.commons.lang3.SerializationUtils
import org.springframework.beans.BeanUtils
import java.io.Serializable

/**
 * 异常数据标签
 * @date 2025/5/13
 * @author feiyu02
 */
open class ExceptionTag {
open class ExceptionTag : Serializable {
    companion object {
        const val MAX_HISTORY = 10
    }

    // 起始数据下标
    var sIndex = 0

@@ -24,6 +31,9 @@
    // 异常数据段
    var exceptionData = mutableListOf<BaseRealTimeData>()

    // 近段时间内的历史数据
    var historyData = mutableListOf<BaseRealTimeData>()

    // 是否存在异常
    var exceptionExisted = false

@@ -32,16 +42,53 @@

    var exceptionResult = mutableListOf<BaseExceptionResult>()

    fun addExceptionData(data: BaseRealTimeData){
    fun addHistoryData(data: BaseRealTimeData) {
        historyData.add(data)
        if (exceptionData.isNotEmpty()) {
            // 保证历史数据包含所有异常数据（异常数据可能不连续），并且在首个异常数据之前最多再保存10个数据
            val i = historyData.indexOf(exceptionData.first())
            if (i > MAX_HISTORY) {
                historyData = historyData.subList(i - MAX_HISTORY, historyData.size).toMutableList()
            }
        } else {
            if (historyData.size > MAX_HISTORY) {
                historyData = historyData.subList(historyData.size - MAX_HISTORY, historyData.size).toMutableList()
            }
        }
    }

    fun addExceptionData(data: BaseRealTimeData) {
        exceptionExisted = true
        exceptionData.add(data)
    }

    fun refreshWithNextException(data: BaseRealTimeData) {
    fun refreshWithNoException(data: BaseRealTimeData) {
        sIndex = eIndex
        startData = data
    }

    fun refreshWithNextException(data: BaseRealTimeData) {
        refreshWithNoException(data)
        exceptionData.clear()
        exceptionExisted = false
        exceptionCreated = false
    }

    fun clone(): ExceptionTag {
        val exceptionTag = SerializationUtils.clone(this)
//        val exceptionTag = ExceptionTag()
//        BeanUtils.copyProperties(this, exceptionTag)
//        exceptionTag.apply {
//            this.sIndex = this@ExceptionTag.sIndex
//            this.startData = this@ExceptionTag.startData
//            this.eIndex = this@ExceptionTag.eIndex
//            this.endData = this@ExceptionTag.endData
//            this.exceptionData = this@ExceptionTag.exceptionData
//            this.historyData = this@ExceptionTag.historyData
//            this.exceptionExisted = this@ExceptionTag.exceptionExisted
//            this.exceptionCreated = this@ExceptionTag.exceptionCreated
//            this.exceptionResult = this@ExceptionTag.exceptionResult
//        }
        return exceptionTag
    }
}