2025.8.5 1. 动态溯源模块添加延迟数据周期异常合并功能

feiyu02

2025-08-05 176d7d8283e66ccf63878c9ab823e900df94b748

 src/main/kotlin/com/flightfeather/uav/biz/dataanalysis/exceptiontype/ExceptionValueMutation.kt

@@ -1,6 +1,7 @@
package com.flightfeather.uav.biz.dataanalysis.exceptiontype

import com.flightfeather.uav.biz.dataanalysis.model.DataAnalysisConfig
import com.flightfeather.uav.biz.dataanalysis.model.ExceptionResult
import com.flightfeather.uav.biz.dataanalysis.model.ExceptionTag
import com.flightfeather.uav.biz.dataanalysis.model.ExceptionType
import com.flightfeather.uav.domain.entity.BaseRealTimeData
@@ -19,6 +20,8 @@
    private var special = false

    override fun getExceptionType(): ExceptionType = ExceptionType.TYPE4

    override var judgeMethod: JudgeMethod = JudgeMethod.M2

    override fun judgeException(p: BaseRealTimeData?, n: BaseRealTimeData): MutableMap<FactorType, Boolean> {
        val res = mutableMapOf<FactorType, Boolean>()
@@ -40,7 +43,7 @@
        return res
    }

    override fun judgeExceptionCount(tag: ExceptionTag): Boolean {
    override fun judgeExceptionCount(tag: ExceptionTag, factorType: FactorType?): Boolean {
        // 首个数据没有前一个数据参照，不算异常值，最后一个数据是判断结束的正常值，因此异常数据个数的计算下标为sIndex和eIndex
        val sIndex = tag.sIndex
        val eIndex = tag.eIndex - 1
@@ -51,4 +54,8 @@
//        println("sIndex: $sIndex --- eIndex: $eIndex --- special: $special")
        return b1 || b2
    }

    override fun onNewResult(result: List<ExceptionResult>) {
        TODO("Not yet implemented")
    }
}