package com.flightfeather.uav.biz.dataanalysis
|
|
import com.flightfeather.uav.biz.dataanalysis.exceptiontype.ExceptionDataExceed
|
import com.flightfeather.uav.biz.dataanalysis.exceptiontype.ExceptionValueMutation
|
import com.flightfeather.uav.biz.dataanalysis.model.DataAnalysisConfig
|
import com.flightfeather.uav.biz.dataanalysis.model.ExceptionResult
|
import com.flightfeather.uav.biz.dataanalysis.model.ExceptionSetting
|
import com.flightfeather.uav.domain.entity.Mission
|
import com.flightfeather.uav.domain.repository.RealTimeDataRep
|
import org.springframework.stereotype.Component
|
|
/**
|
* 数据异常分析控制器
|
*/
|
@Component
|
class ExceptionAnalysisController(
|
private val realTimeDataRep: RealTimeDataRep,
|
) {
|
|
var running = false
|
|
private val taskList = mutableListOf<BaseExceptionAnalysis>()
|
|
private fun initTask(config: DataAnalysisConfig) {
|
taskList.clear()
|
taskList.apply {
|
add(ExceptionDataExceed(config))
|
add(ExceptionValueMutation(config))
|
}
|
}
|
|
fun run(mission: Mission): List<ExceptionResult> {
|
running = true
|
val config = DataAnalysisConfig(mission, ExceptionSetting(), 8)
|
initTask(config)
|
|
val result = mutableListOf<ExceptionResult>()
|
taskList.forEach { it.init() }
|
// 轮询数据，计算各个异常
|
realTimeDataRep.fetchData(mission.deviceCode, mission.startTime, mission.endTime).forEach { d ->
|
taskList.forEach { it.onNextData(d) }
|
}
|
// 各个异常分析分别结束
|
taskList.forEach { it.onDone() }
|
// 存储分析结果
|
taskList.forEach {
|
result.addAll(it.resultList)
|
}
|
running = false
|
return result
|
}
|
}
|
