1. 添加了动态污染溯源相关功能逻辑

feiyu02

2025-05-08 9a9a27f185bc0cf9dc0001cfc6839e6d13dbccd9

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
package com.flightfeather.uav.biz.dataanalysis
 
import com.flightfeather.uav.biz.dataanalysis.exceptiontype.ExceptionSlideAverage
import com.flightfeather.uav.biz.dataanalysis.exceptiontype.ExceptionValueMutation
import com.flightfeather.uav.biz.dataanalysis.model.DataAnalysisConfig
import com.flightfeather.uav.common.location.LocationRoadNearby
import com.flightfeather.uav.domain.repository.RealTimeDataRep
import com.flightfeather.uav.domain.repository.SegmentInfoRep
 
/**
 *
 * @date 2025/5/8
 * @author feiyu02
 */
class RealTimeExceptionAnalysisController (
    private val realTimeDataRep: RealTimeDataRep,
    private val locationRoadNearby: LocationRoadNearby,
    private val segmentInfoRep: SegmentInfoRep,
){
 
    private val taskList = mutableListOf<BaseExceptionAnalysis>()
 
    private fun initTask(config: DataAnalysisConfig) {
        taskList.clear()
        taskList.apply {
            add(ExceptionValueMutation(config))
            add(ExceptionSlideAverage(config))
        }
    }
 
    // 计算历史任务
}