package com.flightfeather.uav.biz.sourcetrace.exceptiontype
|
|
import com.flightfeather.uav.biz.FactorFilter
|
import com.flightfeather.uav.biz.dataanalysis.BaseExceptionContinuous
|
import com.flightfeather.uav.biz.dataanalysis.model.ExceptionTag
|
import com.flightfeather.uav.biz.sourcetrace.RealTimeAnalysisConfig
|
import com.flightfeather.uav.biz.sourcetrace.model.RealTimeExceptionResult
|
import com.flightfeather.uav.domain.entity.BaseRealTimeData
|
import com.flightfeather.uav.lightshare.eunm.ExceptionStatusType
|
|
// 异常数据生成回调类
|
typealias NewExceptionCallback = (ex: RealTimeExceptionResult) -> Unit
|
/**
|
* 走航动态溯源异常判断
|
* 相比于其父类，修改了异常分组的逻辑，不再考虑异常需要连续出现，而是只通过数据采样时间是否连续以及是否需要主动截取分组来决定
|
* 另外新增了异常实时播报的逻辑
|
* @date 2025/5/13
|
* @author feiyu02
|
*/
|
abstract class BaseRealTimeException<T : ExceptionTag>(config: RealTimeAnalysisConfig, tagClz: Class<T>) :
|
BaseExceptionContinuous<T, RealTimeAnalysisConfig, RealTimeExceptionResult>(config, tagClz) {
|
|
constructor(config: RealTimeAnalysisConfig, callback: NewExceptionCallback, tagClz: Class<T>) : this(config, tagClz){
|
this.callback = callback
|
}
|
|
var callback: NewExceptionCallback? = null
|
|
override fun onNextData(data: BaseRealTimeData) {
|
val isContinue = isContinuous(lastData, data)
|
val hasException = judgeException(lastData, data)
|
config.factorFilter.selectedList.forEach { s ->
|
val f = s.main
|
tagMap[f]?.let {
|
it.eIndex++
|
// 起始数据
|
it.endData = data
|
if (it.startData == null) {
|
it.refreshWithNextException(data)
|
}
|
// 判断相邻数据是否连续或者是否满足自定义截取条件
|
if (!isContinue || needCut(it)) {
|
// 记录异常，结束异常的实时状态播报
|
recordException(s, it, data)
|
} else {
|
// 移除了父类原有逻辑，改为当满足异常条件时，需要实时推送播报异常的状态变化，但不截取异常
|
if (hasException[f] == true) {
|
it.addExceptionData(data)
|
checkResult(s)
|
}
|
}
|
}
|
}
|
lastData = data
|
}
|
|
override fun newResult(
|
start: BaseRealTimeData,
|
end: BaseRealTimeData?,
|
factor: FactorFilter.SelectedFactor,
|
exceptionData: List<BaseRealTimeData>,
|
): RealTimeExceptionResult {
|
val eType = getExceptionType()
|
return RealTimeExceptionResult(start, end, factor, exceptionData, eType)
|
}
|
|
override fun onNewException(tag: T, factor: FactorFilter.SelectedFactor, exceptionStatus: ExceptionStatusType) {
|
super.onNewException(tag, factor, exceptionStatus)
|
callback?.let { func ->
|
val exc = tag.exceptionResult.last()
|
func.invoke(exc as RealTimeExceptionResult)
|
}
|
}
|
}
|
