Microservice/iot
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

微调

Browse Source
This commit is contained in:
xy
2024-10-11 11:55:16 +08:00
parent dfa7ebe94f
commit 68e28880d0
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
iot-access/access-boot/src/main/java/com/njcn/access/listener/RedisKeyExpirationListener.java
View File

@@ -137,7 +137,7 @@ public class RedisKeyExpirationListener extends KeyExpirationEventMessageListene
Object object = redisUtil.getObjectByKey("online" + nDid); Object object = redisUtil.getObjectByKey("online" + nDid);
if (Objects.nonNull(object)) { if (Objects.nonNull(object)) {
scheduler.shutdown(); scheduler.shutdown();
logDto.setOperate("客户端在线重连成功"); logDto.setOperate(nDid + "客户端在线重连成功");
} else { } else {
//装置下线 //装置下线
csEquipmentDeliveryService.updateRunStatusBynDid(nDid, AccessEnum.OFFLINE.getCode()); csEquipmentDeliveryService.updateRunStatusBynDid(nDid, AccessEnum.OFFLINE.getCode());
@@ -153,7 +153,7 @@ public class RedisKeyExpirationListener extends KeyExpirationEventMessageListene
//装置下线 //装置下线
csEquipmentDeliveryService.updateRunStatusBynDid(nDid, AccessEnum.OFFLINE.getCode()); csEquipmentDeliveryService.updateRunStatusBynDid(nDid, AccessEnum.OFFLINE.getCode());
startScheduledTask(scheduler,nDid,version); startScheduledTask(scheduler,nDid,version);
logDto.setOperate("客户端离线进入定时任务"); logDto.setOperate(nDid + "客户端离线进入定时任务");
} }
csLogsFeignClient.addUserLog(logDto); csLogsFeignClient.addUserLog(logDto);
} }
@@ -212,7 +212,7 @@ public class RedisKeyExpirationListener extends KeyExpirationEventMessageListene
onlineLogsService.updateById(record); onlineLogsService.updateById(record);
} }
csLogsFeignClient.addUserLog(logDto); csLogsFeignClient.addUserLog(logDto);
}, 0, 10, TimeUnit.SECONDS); }, 0, 2, TimeUnit.MINUTES);
} }
} }