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

链路心跳新增modbus和ftp状态

Browse Source
This commit is contained in:
谷成伟 2024-12-30 11:08:51 +08:00
parent 39f4d50fca
commit d3d7937947
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
das/src/main/java/com/das/modules/node/command/HeartbeatCommand.java
View File

@ -46,11 +46,11 @@ public class HeartbeatCommand implements BaseCommand{
for (JsonNode linkNode : links) { for (JsonNode linkNode : links) {
String linkId = linkNode.get("linkId").asText(); String linkId = linkNode.get("linkId").asText();
boolean online = linkNode.get("online").asBoolean(); boolean online = linkNode.get("online").asBoolean();
JsonNode modbusNode = linkNode.get("modbus"); JsonNode realNode = linkNode.get("real");
if (modbusNode != null){ if (realNode != null){
boolean modbus = modbusNode.asBoolean(); boolean real = realNode.asBoolean();
String key = String.format("link:%s:modbus", linkId); String key = String.format("link:%s:modbus", linkId);
ops.set(key, modbus, HEARTBEAT_TTL, TimeUnit.SECONDS); ops.set(key, real, HEARTBEAT_TTL, TimeUnit.SECONDS);
} }
JsonNode ftpNode = linkNode.get("ftp"); JsonNode ftpNode = linkNode.get("ftp");
if (ftpNode != null){ if (ftpNode != null){