From 4d065a305b997bfb66f41b33a31d59de63b1958d Mon Sep 17 00:00:00 2001
From: feiyu02 <risaku@163.com>
Date: 星期四, 29 五月 2025 17:43:21 +0800
Subject: [PATCH] 1. 新增动态污染溯源新的判定逻辑（待完成）
---
src/main/kotlin/com/flightfeather/uav/biz/sourcetrace/exceptiontype/BaseRealTimeException.kt | 55 ++++++++++++++++++++++++++++---------------------------
1 files changed, 28 insertions(+), 27 deletions(-)
diff --git a/src/main/kotlin/com/flightfeather/uav/biz/sourcetrace/exceptiontype/BaseRealTimeException.kt b/src/main/kotlin/com/flightfeather/uav/biz/sourcetrace/exceptiontype/BaseRealTimeException.kt
index bfb6b9a..d4c0232 100644
--- a/src/main/kotlin/com/flightfeather/uav/biz/sourcetrace/exceptiontype/BaseRealTimeException.kt
+++ b/src/main/kotlin/com/flightfeather/uav/biz/sourcetrace/exceptiontype/BaseRealTimeException.kt
@@ -17,6 +17,7 @@
* @date 2025/5/13
* @author feiyu02
*/
+@Deprecated("2025.5.29, 閫昏緫涓庝笟鍔′笉鍖归厤锛屽悗缁垹闄�")
abstract class BaseRealTimeException<T : ExceptionTag>(config: RealTimeAnalysisConfig, tagClz: Class<T>) :
BaseExceptionContinuous<T, RealTimeAnalysisConfig, RealTimeExceptionResult>(config, tagClz) {
@@ -26,33 +27,33 @@
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 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,
--
Gitblit v1.9.3