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:11:38 +08:00
parent 4dce76070f
commit d8de627199
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -256,7 +256,9 @@ public class NodeMessageServiceImpl extends TextWebSocketHandler implements Node
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));
} }
adminRedisTemplate.mSet(keyValueMap); if (jsonNode.get("isStore") != null && jsonNode.get("isStore").asBoolean()) {
archiveValues = values;
}
Iterator<String> archiveKeys = archiveValues.fieldNames(); Iterator<String> archiveKeys = archiveValues.fieldNames();
while (archiveKeys.hasNext()) { while (archiveKeys.hasNext()) {
String fieldName = keysHigh.next(); String fieldName = keysHigh.next();
@ -283,6 +285,7 @@ public class NodeMessageServiceImpl extends TextWebSocketHandler implements Node
tdEngineService.updateYCLowValues(lowSpeedData,modelCode); tdEngineService.updateYCLowValues(lowSpeedData,modelCode);
} }
} }
adminRedisTemplate.mSet(keyValueMap);
} }
@Override @Override