| | |
|---|
| | | 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(), |
|---|
