From 68e28880d085f1f42f64467e78fa13a973f04b39 Mon Sep 17 00:00:00 2001 From: xy <748613696@qq.com> Date: Fri, 11 Oct 2024 11:55:16 +0800 Subject: [PATCH] =?UTF-8?q?=E5=BE=AE=E8=B0=83?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../njcn/access/listener/RedisKeyExpirationListener.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) 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); } }