sx/map
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

模拟数据上报修改

Browse Source
This commit is contained in:
huguanghan 2024-12-11 10:22:39 +08:00
parent 3eb790acdb
commit 8187ffe3a5
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
das/src/main/java/com/das/modules/node/service/impl/NodeMessageServiceImpl.java
View File

@ -238,6 +238,7 @@ public class NodeMessageServiceImpl extends TextWebSocketHandler implements Node
@Override
public void handleData(TerminalMessage data) {
JsonNode jsonNode = data.getData();
log.info("收到消息：{}",data.getData());
String deviceId = jsonNode.get("deviceId").asText();
JsonNode values = jsonNode.get("values");
JsonNode archiveValues = jsonNode.get("archiveValues");
@ -256,6 +257,7 @@ public class NodeMessageServiceImpl extends TextWebSocketHandler implements Node
String key = String.format("RT:%s:%s", deviceId, fieldName.toLowerCase());
keyValueMap.put(key, values.get(fieldName));
}
log.info("values解析成功");
Iterator<String> archiveKeys = archiveValues.fieldNames();
while (archiveKeys.hasNext()) {
String fieldName = archiveKeys.next();
@ -268,6 +270,7 @@ public class NodeMessageServiceImpl extends TextWebSocketHandler implements Node
lowSpeedValueMap.put(fieldName, values.get(fieldName));
}
}
log.info("archive解析成功");
//更新td
if (!highSpeedValueMap.isEmpty()) {
List<RTData> highSpeedData = new ArrayList<>();