src/main/kotlin/com/flightfeather/uav/biz/sourcetrace/SourceTraceController.kt
@@ -102,6 +102,16 @@ dealOnTimeout() } fun addDataList(dataList: List<BaseRealTimeData>) { // 计算异常 dataList.forEach { data -> taskList.forEach { it.onNextData(data) } pollutedSummary.refreshLatestMonitorData(data) } // 限定时间内没有新数据传入,则结束当前的计算 dealOnTimeout() } /** * 超时处理,较长时间没有新数据进入,进行初始化操作 */