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-11-20 17:11:23 +08:00
parent c100cf5ada
commit f2390dc021
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

@ -247,6 +247,9 @@ 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(fieldName.toLowerCase().equals("iwindspeed")){
log.info("风速更新redis数据key：{}，value：{}",key,values.get(fieldName));
}
if (highKey.contains(fieldName)){ if (highKey.contains(fieldName)){
highSpeedValueMap.put(fieldName,values.get(fieldName)); highSpeedValueMap.put(fieldName,values.get(fieldName));
} }