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-06 16:47:17 +08:00
parent 6bfe1d9282
commit edc2e6f69b
1 changed files with 3 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -240,7 +240,6 @@ public class NodeMessageServiceImpl extends TextWebSocketHandler implements Node
JsonNode jsonNode = data.getData(); JsonNode jsonNode = data.getData();
String deviceId = jsonNode.get("deviceId").asText(); String deviceId = jsonNode.get("deviceId").asText();
JsonNode values = jsonNode.get("values"); JsonNode values = jsonNode.get("values");
JsonNode archiveValues = jsonNode.get("archiveValues");
Long dataTime = jsonNode.get("dataTime").asLong(); Long dataTime = jsonNode.get("dataTime").asLong();
Map<String, Object> keyValueMap = new HashMap<>(); Map<String, Object> keyValueMap = new HashMap<>();
String modelCode = dataService.deviceModelMap.get(deviceId); String modelCode = dataService.deviceModelMap.get(deviceId);
@ -255,21 +254,15 @@ public class NodeMessageServiceImpl extends TextWebSocketHandler implements Node
String fieldName = keysHigh.next(); String fieldName = keysHigh.next();
String key = String.format("RT:%s:%s", deviceId, fieldName.toLowerCase()); String key = String.format("RT:%s:%s", deviceId, fieldName.toLowerCase());
keyValueMap.put(key, values.get(fieldName)); keyValueMap.put(key, values.get(fieldName));
}
if (jsonNode.get("isStore") != null && jsonNode.get("isStore").asBoolean()) {
archiveValues = values;
}
Iterator<String> archiveKeys = archiveValues.fieldNames();
while (archiveKeys.hasNext()) {
String fieldName = archiveKeys.next();
String key = String.format("RT:%s:%s", deviceId, fieldName.toLowerCase());
keyValueMap.put(key, values.get(fieldName));
if (highKey.contains(fieldName)){ if (highKey.contains(fieldName)){
highSpeedValueMap.put(fieldName,values.get(fieldName)); highSpeedValueMap.put(fieldName,values.get(fieldName));
} }
if (lowKey.contains(fieldName)){ if (lowKey.contains(fieldName)){
lowSpeedValueMap.put(fieldName,values.get(fieldName)); lowSpeedValueMap.put(fieldName,values.get(fieldName));
} }
}
adminRedisTemplate.mSet(keyValueMap);
if (jsonNode.get("isStore") != null && jsonNode.get("isStore").asBoolean()) {
//更新td //更新td
if (!highSpeedValueMap.isEmpty()){ if (!highSpeedValueMap.isEmpty()){
List<RTData> highSpeedData = new ArrayList<>(); List<RTData> highSpeedData = new ArrayList<>();
@ -285,7 +278,6 @@ public class NodeMessageServiceImpl extends TextWebSocketHandler implements Node
tdEngineService.updateYCLowValues(lowSpeedData,modelCode); tdEngineService.updateYCLowValues(lowSpeedData,modelCode);
} }
} }
adminRedisTemplate.mSet(keyValueMap);
} }
@Override @Override