yuyang/XH-Power-Cloud
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

终端心跳状态

Browse Source
This commit is contained in:
ZZ 2022-02-25 13:16:32 +08:00
parent 5e92204b66
commit bb92694576
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/logic/HBLogic.java
View File

@ -20,7 +20,7 @@ import static com.xhpc.common.data.redis.StaticBeanUtil.seqHex;
@Component("HBLogic")
public class HBLogic implements ServiceLogic {
private static Logger log = LoggerFactory.getLogger(HBLogic.class);
private static final Logger log = LoggerFactory.getLogger(HBLogic.class);
public static final String[] stable = {"空闲", "故障"};
@ -30,12 +30,14 @@ public class HBLogic implements ServiceLogic {
Map<String, Object> req = sp.getParameters();
String pileNo = (String) req.get("pileNo");
String gunId = (String) req.get("gunId");
String gunStatus = (String) req.get("gunStatus");
Long gunStatusInt = Long.parseLong(gunStatus);
Integer gunStatus = (Integer) req.get("gunStatus");
String gunkey = "gun:".concat(pileNo).concat(gunId);
Map<String, Object> cacheGun = REDIS.getCacheMap(gunkey);
cacheGun.put("statusInt", gunStatusInt);
cacheGun.put("hbtime", Calendar.getInstance().getTimeInMillis());
String status = (String) cacheGun.get("status");
if ("离线".equals(status) || "故障".equals(status)) {
cacheGun.put("status", stable[gunStatus]);
}
REDIS.setCacheMap(gunkey, cacheGun);
String skey = gunkey.concat(".seqhex");
String seq = seqHex(skey);