From 014ac34ff2baf657c3236f41fdbf11c9d7d414b4 Mon Sep 17 00:00:00 2001
From: yangys <y_ys79@sina.com>
Date: 星期四, 09 五月 2024 18:02:27 +0800
Subject: [PATCH] 大批注释改造
---
smart-man-boot/src/main/java/com/qianwen/smartman/modules/cps/utils/TelemetryDataUtils.java | 35 +++++++++++++++++++++++++++--------
1 files changed, 27 insertions(+), 8 deletions(-)
diff --git a/smart-man-boot/src/main/java/com/qianwen/smartman/modules/cps/utils/TelemetryDataUtils.java b/smart-man-boot/src/main/java/com/qianwen/smartman/modules/cps/utils/TelemetryDataUtils.java
index 17f066c..32fdbea 100644
--- a/smart-man-boot/src/main/java/com/qianwen/smartman/modules/cps/utils/TelemetryDataUtils.java
+++ b/smart-man-boot/src/main/java/com/qianwen/smartman/modules/cps/utils/TelemetryDataUtils.java
@@ -13,7 +13,6 @@
import java.util.stream.Collectors;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import com.qianwen.smartman.common.cache.RegionCache;
import com.qianwen.smartman.common.cache.cps.WorkstationCache;
import com.qianwen.smartman.common.constant.CommonConstant;
import com.qianwen.smartman.common.enums.WorkstationParamStateEnum;
@@ -25,7 +24,10 @@
import com.qianwen.smartman.modules.cps.message.dto.TelemetryDataResponseDTO;
import com.qianwen.smartman.modules.cps.message.event.TelemetryDataMessage;
-/* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/cps/utils/TelemetryDataUtils.class */
+
+/**
+ * 閬ユ祴鏁版嵁util
+ */
public class TelemetryDataUtils {
private static final Logger log = LoggerFactory.getLogger(TelemetryDataUtils.class);
@@ -94,17 +96,20 @@
if (!checkResult.booleanValue()) {
return null;
}
- switch (AnonymousClass1.$SwitchMap$org$springblade$common$enums$WorkstationParamTypeEnum[WorkstationParamTypeEnum.of(workstationParam.getType(), WorkstationParamTypeEnum.OTHER).ordinal()]) {
- case 1:
+ switch (WorkstationParamTypeEnum.of(workstationParam.getType(), WorkstationParamTypeEnum.OTHER)) {
+ case STATE:
handlerStatusUpdateValue(telemetryDataMessage, workstationParam);
break;
- case 3:
- case 4:
+ case ALARM:
+ case ALARM_NO:
packWorkStationAlarmMessageInfo(telemetryDataMessage, workstationParam.getWorkstationId());
break;
- case RegionCache.VILLAGE_LEVEL /* 5 */:
+ case ALARM_MSG:
telemetryDataMessage = null;
break;
+ default:
+ break;
+
}
return telemetryDataMessage;
}
@@ -167,7 +172,20 @@
}
private static List<AlarmInfoDTO> handlerRepeatAlarmInfo(List<AlarmInfoDTO> alarmInfoDTOS) {
- ArrayList arrayList = new ArrayList(CommonConstant.ALARM_MAX_COUNT.intValue());
+ ArrayList<AlarmInfoDTO> arrayList = new ArrayList<>(CommonConstant.ALARM_MAX_COUNT.intValue());
+ List<AlarmInfoDTO> alarmList = alarmInfoDTOS.stream().collect(
+ Collectors.collectingAndThen(
+ Collectors.toCollection(() -> new TreeSet<AlarmInfoDTO>(Comparator.comparing(
+ alarm -> {
+ return alarm.getCode() + ";" + alarm.getMsg();
+ })//end of comparing
+ )//end new treeset
+ )//end toCollection
+ , ArrayList::new)//collectingAndThen
+ );
+
+ alarmList = alarmList.stream().sorted(Comparator.comparing(AlarmInfoDTO::getTimestamp).reversed()).collect(Collectors.toList());
+ /*
List<AlarmInfoDTO> alarmList = (List) ((List) alarmInfoDTOS.stream().collect(Collectors.collectingAndThen(Collectors.toCollection(() -> {
return new TreeSet(Comparator.comparing(alarm -> {
return alarm.getCode() + ";" + alarm.getMsg();
@@ -177,6 +195,7 @@
}))).stream().sorted(Comparator.comparing((v0) -> {
return v0.getTimestamp();
}).reversed()).collect(Collectors.toList());
+ */
for (int i = 0; i < alarmList.size() && arrayList.size() < CommonConstant.ALARM_MAX_COUNT.intValue(); i++) {
arrayList.add(alarmList.get(i));
}
--
Gitblit v1.9.3