1. 新增动态污染溯源新的判定逻辑（待完成）

feiyu02

2025-05-29 4d065a305b997bfb66f41b33a31d59de63b1958d

 src/main/kotlin/com/flightfeather/uav/biz/dataanalysis/BaseExceptionContinuous.kt

@@ -19,42 +19,6 @@
        private const val OFFSET = 10
    }

    inner class Tag {
        // 起始数据下标
        var sIndex = 0

        // 起始数据对象
        var startData: BaseRealTimeData? = null

        // 末尾数据下标
        var eIndex = -1

        // 末尾数据对象
        var endData: BaseRealTimeData? = null

        // 异常数据段
        var exceptionData = mutableListOf<BaseRealTimeData>()

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

        // 异常结果是否创建
        var exceptionCreated = false

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

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

    protected val tagMap = mutableMapOf<FactorType, T>()

    // 起始数据与末尾数据间隔
@@ -62,6 +26,20 @@

    // 末尾数据对象
    protected var lastData: BaseRealTimeData? = null

    /**
     * 后置判断：当相邻数据时间不连续时，或者满足自定义条件时，对之前已有的异常进行记录
     */
    open fun afterExcCheck(isContinue: Boolean, tag: T, hasException: Boolean?): Boolean {
        return !isContinue || needCut(tag, hasException)
    }

    /**
     * 立即判断：当出现异常时，缓存异常数据的同时，立即对已有异常进行判断是否满足异常结果要求
     */
    open fun immeExcCheck(tag: T): Boolean {
        return false
    }

    /**
     * 判断相邻数据是否连续
@@ -75,7 +53,7 @@
    }

    /**
     * 判断是否满足异常条件
     * 判断前后数据是否满足异常条件
     */
    abstract fun judgeException(p: BaseRealTimeData?, n: BaseRealTimeData): MutableMap<FactorType, Boolean>

@@ -87,11 +65,11 @@

    /**
     * 异常数据的截取判断
     * 是否需要限制一组异常数据的长度
     * @return 默认不需要截取
     */
    open fun needCut(tag: T): Boolean {
        return false
    open fun needCut(tag: T, hasException: Boolean?): Boolean {
        // 默认判断条件为 当异常不再重复出现时，形成异常结果
        return tag.exceptionExisted && hasException == false
    }

    override fun init() {
@@ -115,15 +93,19 @@
                if (it.startData == null) {
                    it.refreshWithNextException(data)
                }
                // 判断相邻数据是否连续并且是否满足异常判断
                if (!isContinue || needCut(it)) {
                    // 数据不连续时，记录异常情况

                // 对于异常的生成分别执行后置判断、和立即判断
                // 1. 后置判断：当相邻数据时间不连续时，或者满足自定义条件时，对之前已有的异常进行记录，形成异常结果
                if (afterExcCheck(isContinue, it, hasException[f])) {
                    // 数据不连续时或者满足主动截断条件时，记录异常情况
                    recordException(s, it, data)
                } else {
                    if (hasException[f] == true) {
                        it.addExceptionData(data)
                    } else {
                        // 异常不再重复出现时，记录异常情况
                }
                // 2. 立即判断：当出现异常时，缓存异常数据的同时，立即对已有异常进行判断是否满足异常结果要求
                else if (hasException[f] == true) {
                    // 有异常出现时，记录异常数据
                    it.addExceptionData(data)
                    // 当立即判断通过时，形成异常结果
                    if (immeExcCheck(it)) {
                        recordException(s, it, data)
                    }
                }
@@ -138,12 +120,11 @@

    /**
     * 异常结束，记录异常
     * 判断已有的异常数据是否满足异常条件，满足则记录，不满足则略过
     */
    fun recordException(factor: FactorFilter.SelectedFactor, tag: T, data: BaseRealTimeData) {
        checkResult(factor, ExceptionStatusType.Ended)
//        if (tag.eIndex - tag.sIndex >= durationCount) {
        tag.refreshWithNextException(data)
//        }
    }

    /**