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

根据心跳更新风机通讯状态

Browse Source
This commit is contained in:
谷成伟 2024-12-05 14:31:45 +08:00
parent 68c15b469a
commit e0542740f9
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -56,13 +56,13 @@ public class HeartbeatCommand implements BaseCommand{
} }
//判断是不是风机 //判断是不是风机
String keyPLCDeviceStatus = String.format("RT:%d:iturbineoperationmode", deviceId); String keyPLCDeviceStatus = String.format("RT:%d:iturbineoperationmode", deviceId);
String keyDeviceStatus = String.format("RT:%d:commfaultstate"); String keyCommFaultState = String.format("RT:%d:commfaultstate");
Integer plcDeviceStatus = adminRedisTemplate.get(keyPLCDeviceStatus); Integer plcDeviceStatus = adminRedisTemplate.get(keyPLCDeviceStatus);
if (plcDeviceStatus == null){ if (plcDeviceStatus == null){
adminRedisTemplate.set(keyDeviceStatus, online ? 1 : 0); adminRedisTemplate.set(keyCommFaultState, online ? 0 : 1);
} }
else{ else{
adminRedisTemplate.set(keyDeviceStatus, online && plcDeviceStatus == 1 ? 1 : 0); adminRedisTemplate.set(keyCommFaultState, online && plcDeviceStatus != 0 ? 0 : 1);
} }
} }
} }