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

feiyu02

2025-05-29 4d065a305b997bfb66f41b33a31d59de63b1958d

 src/main/kotlin/com/flightfeather/uav/biz/sourcetrace/exceptiontype/RealTimeExceptionValueMutation.kt

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

import com.flightfeather.uav.biz.FactorFilter
import com.flightfeather.uav.biz.dataanalysis.model.ExceptionTag
import com.flightfeather.uav.biz.dataanalysis.model.ExceptionType
import com.flightfeather.uav.biz.sourcetrace.RealTimeAnalysisConfig
import com.flightfeather.uav.common.utils.MapUtil
@@ -15,11 +15,12 @@
 * @date 2025/5/13
 * @author feiyu02
 */
class RealTimeExceptionValueMutation : RealTimeExceptionContinuous {
@Deprecated("2025.5.29, 逻辑与业务不匹配，后续删除")
class RealTimeExceptionValueMutation : BaseRealTimeException<ExceptionTag> {

    constructor(config: RealTimeAnalysisConfig) : super(config)
    constructor(config: RealTimeAnalysisConfig) : super(config, ExceptionTag::class.java)

    constructor(config: RealTimeAnalysisConfig, callback: NewExceptionCallback) : super(config, callback)
    constructor(config: RealTimeAnalysisConfig, callback: NewExceptionCallback) : super(config, callback, ExceptionTag::class.java)

    /**
     * 本异常的连续发生次数会根据异常的程度变化
@@ -52,18 +53,16 @@
        return res
    }

    override fun judgeExceptionCount(tag: Tag): Boolean {
        // 首个数据没有前一个数据参照，不算异常值，最后一个数据是判断结束的正常值，因此异常数据个数的计算下标为sIndex和eIndex
        val sIndex = tag.sIndex
        val eIndex = tag.eIndex - 1
    override fun judgeExceptionCount(tag: ExceptionTag): Boolean {
        val count = tag.exceptionData.size

        val b1 = special && (eIndex - sIndex) >= (config.mutationNum / 2)
        val b2 = (eIndex - sIndex) >= config.mutationNum
        val b1 = special && count >= (config.mutationNum / 2)
        val b2 = count >= config.mutationNum
        special = false
        return b1 || b2
    }

    override fun needCut(tag: Tag): Boolean {
    override fun needCut(tag: ExceptionTag, hasException: Boolean?): Boolean {
        // 按照时长和距离限制将异常截取
        if (tag.exceptionData.isEmpty()) return false