2025.7.13 动态溯源逻辑调整

Riku

2025-07-13 37d47c6a7ab0f454b948b68c987146b261117993

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

@@ -16,7 +16,7 @@


// 异常数据生成回调类
typealias NewPolluteClueCallback = (ex: PollutedClue) -> Unit
typealias NewPolluteClueCallback = (ex: List<PollutedClue>) -> Unit
/**
 * 不同风速下，数据突变异常基类
 * @date 2025/5/29
@@ -134,9 +134,23 @@
        exceptionStatus: ExceptionStatusType,
    ) {
        super.onNewException(tag, factor, exceptionStatus)
//        callback?.let { func ->
//            val exc = tag.exceptionResult.last()
//            func.invoke(exc as PollutedClue)
//        }
    }

    override fun mergeExceptionResult() {
        super.mergeExceptionResult()
        latestExceptionResult
        latestCombinedResult
        callback?.let { func ->
            val exc = tag.exceptionResult.last()
            func.invoke(exc as PollutedClue)
            latestExceptionResult.forEach {
                func.invoke(listOf(it as PollutedClue))
            }
            latestCombinedResult.forEach {
                func.invoke(it as List<PollutedClue>)
            }
        }
    }
}