From 8fc27dba6719041402e3e3c099e2f3e01d9d52c7 Mon Sep 17 00:00:00 2001
From: feiyu02 <risaku@163.com>
Date: 星期三, 16 七月 2025 17:30:56 +0800
Subject: [PATCH] 2025.7.16 1. 修改动态溯源异常判断逻辑
---
src/main/kotlin/com/flightfeather/uav/biz/sourcetrace/exceptiontype/BaseRTExcChangeRate.kt | 24 ++++++++++++++++--------
1 files changed, 16 insertions(+), 8 deletions(-)
diff --git a/src/main/kotlin/com/flightfeather/uav/biz/sourcetrace/exceptiontype/BaseRTExcChangeRate.kt b/src/main/kotlin/com/flightfeather/uav/biz/sourcetrace/exceptiontype/BaseRTExcChangeRate.kt
index c3ad456..c0c0cd3 100644
--- a/src/main/kotlin/com/flightfeather/uav/biz/sourcetrace/exceptiontype/BaseRTExcChangeRate.kt
+++ b/src/main/kotlin/com/flightfeather/uav/biz/sourcetrace/exceptiontype/BaseRTExcChangeRate.kt
@@ -110,7 +110,14 @@
}
override fun newResult(tag: ExceptionTag, factor: FactorFilter.SelectedFactor): PollutedClue {
- return PollutedClue(tag, factor, getExceptionType(), config, changeRate[factor.main])
+ return PollutedClue()
+ }
+
+ override fun newResult(exceptions: List<Pair<FactorFilter.SelectedFactor, ExceptionTag>>): PollutedClue {
+ return if (exceptions.isEmpty())
+ PollutedClue()
+ else
+ PollutedClue(exceptions, getExceptionType(), config, changeRate[exceptions[0].first.main])
}
override fun onNewException(
@@ -127,15 +134,16 @@
override fun mergeExceptionResult() {
super.mergeExceptionResult()
- latestExceptionResult
- latestCombinedResult
callback?.let { func ->
- latestExceptionResult.forEach {
- func.invoke(listOf(it as PollutedClue))
+ result.forEach {
+ func.invoke(it)
}
- latestCombinedResult.forEach {
- func.invoke(it as List<PollutedClue>)
- }
+// latestExceptions.forEach {
+// func.invoke(listOf(it as PollutedClue))
+// }
+// latestCombinedExc.forEach {
+// func.invoke(it as List<PollutedClue>)
+// }
}
}
}
\ No newline at end of file
--
Gitblit v1.9.3