From a3686cfa49bf53fb91a2ceb960cf15b3ebdac641 Mon Sep 17 00:00:00 2001
From: yangys <y_ys79@sina.com>
Date: 星期四, 30 五月 2024 16:38:00 +0800
Subject: [PATCH] 测试代码
---
smart-man-boot/src/main/java/com/qianwen/smartman/modules/mdc/service/impl/SuperNewCollectServiceImpl.java | 7 ++++---
1 files changed, 4 insertions(+), 3 deletions(-)
diff --git a/smart-man-boot/src/main/java/com/qianwen/smartman/modules/mdc/service/impl/SuperNewCollectServiceImpl.java b/smart-man-boot/src/main/java/com/qianwen/smartman/modules/mdc/service/impl/SuperNewCollectServiceImpl.java
index f571767..4855bf6 100644
--- a/smart-man-boot/src/main/java/com/qianwen/smartman/modules/mdc/service/impl/SuperNewCollectServiceImpl.java
+++ b/smart-man-boot/src/main/java/com/qianwen/smartman/modules/mdc/service/impl/SuperNewCollectServiceImpl.java
@@ -23,7 +23,7 @@
public class SuperNewCollectServiceImpl implements ISuperNewCollectService {
private final SuperCollectJsonMapper collectJsonMapper;
private static final Logger log = LoggerFactory.getLogger(SuperNewCollectServiceImpl.class);
- private static final Map<Integer, String> PROCESS_PARAM_MAP = new HashMap();
+ private static final Map<Integer, String> PROCESS_PARAM_MAP = new HashMap<>();
static {
PROCESS_PARAM_MAP.put(1, "STATE");
@@ -39,16 +39,17 @@
this.collectJsonMapper = collectJsonMapper;
}
+
@Override
public void insertData(Set<String> workstationIds) {
List<NewParamSaveDTO> data = workstationIds.stream().map(workstationId -> {
- Map<String, Object> realTimeData = WorkstationCache.getWorkstationAllCollect(workstationId);
+ Map<String, Object> realTimeData = WorkstationCache.getWorkstationAllCollect(workstationId);//瀹炴椂鏁版嵁锛�
if (Func.isNotEmpty(realTimeData)) {
int size = realTimeData.size();
long time = DateUtil.now().getTime();
Map<String, String> valuesMap = new HashMap<>(size);
realTimeData.forEach((n, telemetry) -> {
- if (!n.toUpperCase().contains(CollectConstant.ALARM)) {
+ if (!n.toUpperCase().contains(CollectConstant.ALARM)) {//鍘婚櫎ALARM鏁版嵁
TelemetryDataResponseDTO dto = (TelemetryDataResponseDTO) telemetry;
String v = dto.getV();
if (Func.isNotEmpty(v) && v.length() <= CollectConstant.MAX_VALUE.intValue() && !v.contains("timestamp")) {
--
Gitblit v1.9.3