From 54f683c3fd09dd88fd4520e014b14825f7479c2f Mon Sep 17 00:00:00 2001
From: yeg <1347747024@qq.com>
Date: 星期四, 03 九月 2026 22:21:51 +0800
Subject: [PATCH] 修正暂停停止后的设备异常展示
---
ruoyi-system/src/main/java/com/ruoyi/system/service/impl/TTestLiveServiceImpl.java | 13 +++++++------
1 files changed, 7 insertions(+), 6 deletions(-)
diff --git a/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/TTestLiveServiceImpl.java b/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/TTestLiveServiceImpl.java
index 1869330..d59699b 100644
--- a/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/TTestLiveServiceImpl.java
+++ b/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/TTestLiveServiceImpl.java
@@ -62,12 +62,13 @@
sources.add(snapshotFor(collectorSource(battery), receiving));
}
List<Map<String, Object>> exceptions = new ArrayList<>();
- exceptions.addAll(sources.stream().filter(source -> !"COLLECTOR".equals(source.sourceType())
- && !"ONLINE".equals(source.deviceStatus())
- && !"WORKING".equals(source.deviceStatus()) && !"PAUSED".equals(source.deviceStatus()))
- .map(source -> Map.<String, Object>of("sourceType", source.sourceType(), "sourceId", source.sourceId(),
- "batteryNo", source.batteryNo(), "status", source.deviceStatus(), "message", "数据来源当前不可观测"))
- .toList());
+ if (receiving)
+ exceptions.addAll(sources.stream().filter(source -> !"COLLECTOR".equals(source.sourceType())
+ && !"ONLINE".equals(source.deviceStatus())
+ && !"WORKING".equals(source.deviceStatus()) && !"PAUSED".equals(source.deviceStatus()))
+ .map(source -> Map.<String, Object>of("sourceType", source.sourceType(), "sourceId", source.sourceId(),
+ "batteryNo", source.batteryNo(), "status", source.deviceStatus(), "message", "数据来源当前不可观测"))
+ .toList());
if (mapper != null) {
mapper.selectWarningExceptions(testId, "OPEN").forEach(item -> exceptions.add(Map.of(
"exceptionId", item.getExceptionId(), "sourceType", item.getSourceType(),
--
Gitblit v1.7.1