diff --git a/iot-access/access-boot/src/main/java/com/njcn/access/listener/RedisKeyExpirationListener.java b/iot-access/access-boot/src/main/java/com/njcn/access/listener/RedisKeyExpirationListener.java index 35d7b88..078cebb 100644 --- a/iot-access/access-boot/src/main/java/com/njcn/access/listener/RedisKeyExpirationListener.java +++ b/iot-access/access-boot/src/main/java/com/njcn/access/listener/RedisKeyExpirationListener.java @@ -137,7 +137,7 @@ public class RedisKeyExpirationListener extends KeyExpirationEventMessageListene Object object = redisUtil.getObjectByKey("online" + nDid); if (Objects.nonNull(object)) { scheduler.shutdown(); - logDto.setOperate("客户端在线重连成功"); + logDto.setOperate(nDid + "客户端在线重连成功"); } else { //装置下线 csEquipmentDeliveryService.updateRunStatusBynDid(nDid, AccessEnum.OFFLINE.getCode()); @@ -153,7 +153,7 @@ public class RedisKeyExpirationListener extends KeyExpirationEventMessageListene //装置下线 csEquipmentDeliveryService.updateRunStatusBynDid(nDid, AccessEnum.OFFLINE.getCode()); startScheduledTask(scheduler,nDid,version); - logDto.setOperate("客户端离线进入定时任务"); + logDto.setOperate(nDid + "客户端离线进入定时任务"); } csLogsFeignClient.addUserLog(logDto); } @@ -212,7 +212,7 @@ public class RedisKeyExpirationListener extends KeyExpirationEventMessageListene onlineLogsService.updateById(record); } csLogsFeignClient.addUserLog(logDto); - }, 0, 10, TimeUnit.SECONDS); + }, 0, 2, TimeUnit.MINUTES); } }