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-08-12 09:28:02 +08:00
parent 7657269b33
commit c6213d06e5
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -88,8 +88,9 @@ public class RedisKeyExpirationListener extends KeyExpirationEventMessageListene
try { try {
String version = csTopicService.getVersion(nDid); String version = csTopicService.getVersion(nDid);
//装置没有心跳，则立马发起接入请求 //装置没有心跳，则立马发起接入请求
log.info("装置掉线3分钟发送接入请求");
csDeviceService.devAccess(nDid,version); csDeviceService.devAccess(nDid,version);
logDto.setOperate("装置掉线3分钟发送接入请求");
csLogsFeignClient.addUserLog(logDto);
Integer status = csEquipmentDeliveryService.queryEquipmentBynDid(nDid).getRunStatus(); Integer status = csEquipmentDeliveryService.queryEquipmentBynDid(nDid).getRunStatus();
if (Objects.equals(status,AccessEnum.ONLINE.getCode())){ if (Objects.equals(status,AccessEnum.ONLINE.getCode())){
throw new BusinessException(CommonResponseEnum.SUCCESS); throw new BusinessException(CommonResponseEnum.SUCCESS);
@@ -98,18 +99,18 @@ public class RedisKeyExpirationListener extends KeyExpirationEventMessageListene
for (int i = 1; i < 4; i++) { for (int i = 1; i < 4; i++) {
//接入再次失败，则定时发起接入请求 //接入再次失败，则定时发起接入请求
Thread.sleep(1000 * 60); Thread.sleep(1000 * 60);
log.info("装置定时1分钟发送接入请求，第" + i + "次尝试");
csDeviceService.devAccess(nDid,version); csDeviceService.devAccess(nDid,version);
status = csEquipmentDeliveryService.queryEquipmentBynDid(nDid).getRunStatus(); status = csEquipmentDeliveryService.queryEquipmentBynDid(nDid).getRunStatus();
if (Objects.equals(status,AccessEnum.ONLINE.getCode())){ if (Objects.equals(status,AccessEnum.ONLINE.getCode())){
break; break;
} }
logDto.setOperate("装置定时1分钟发送接入请求，第" + i + "次尝试");
csLogsFeignClient.addUserLog(logDto);
} }
if (!Objects.isNull(status) && Objects.equals(status,AccessEnum.OFFLINE.getCode())){ if (!Objects.isNull(status) && Objects.equals(status,AccessEnum.OFFLINE.getCode())){
final int[] mid = {2}; final int[] mid = {2};
ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(2); ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(2);
ScheduledFuture<?> runnableFuture = executor.scheduleAtFixedRate(() -> { ScheduledFuture<?> runnableFuture = executor.scheduleAtFixedRate(() -> {
log.info("装置10分钟定时发送接入请求...");
csDeviceService.devAccessMid(nDid,version, mid[0]); csDeviceService.devAccessMid(nDid,version, mid[0]);
Integer status2 = csEquipmentDeliveryService.queryEquipmentBynDid(nDid).getRunStatus(); Integer status2 = csEquipmentDeliveryService.queryEquipmentBynDid(nDid).getRunStatus();
if (Objects.equals(status2,AccessEnum.ONLINE.getCode())){ if (Objects.equals(status2,AccessEnum.ONLINE.getCode())){
@@ -118,7 +119,7 @@ public class RedisKeyExpirationListener extends KeyExpirationEventMessageListene
mid[0] = mid[0] + 1; mid[0] = mid[0] + 1;
} }
//记录日志 //记录日志
logDto.setOperate("装置掉线,定时发送接入请求，装置为:" + nDid + ",请求的时间戳为:" + System.currentTimeMillis()); logDto.setOperate("装置掉线,定时10分钟发送接入请求，装置为:" + nDid + ",请求的时间戳为:" + System.currentTimeMillis());
csLogsFeignClient.addUserLog(logDto); csLogsFeignClient.addUserLog(logDto);
}, 1, 600, TimeUnit.SECONDS); }, 1, 600, TimeUnit.SECONDS);
} }