添加告警统计信息

device-manager/src/main/java/com/mortals/xhx/busiz/web/DeviceApiController.java

@@ -233,7 +233,11 @@ public class DeviceApiController {
             deviceEntity.setDeviceStatus(DeviceStatusEnum.在线.getValue());
             deviceEntity.setDeviceVersion(req.getDeviceVersion() == null ? "" : req.getDeviceVersion());
             //todo 延迟队列更新 此时进入redis 队列
-            Long lpush = cacheService.lpush(RedisKey.KEY_DEVICE_ONLINE_QUEUE, deviceEntity);
+            DeviceEntity entity = new DeviceEntity();
+            entity.setId(deviceEntity.getId());
+            entity.setOnlineTime(new Date());
+            entity.setDeviceStatus(DeviceStatusEnum.在线.getValue());
+            Long lpush = cacheService.lpush(RedisKey.KEY_DEVICE_ONLINE_QUEUE, entity);
             log.info("lpush:{}",lpush);
 
             //deviceService.getDeviceDao().update(deviceEntity);

device-manager/src/main/java/com/mortals/xhx/daemon/task/DeviceStatTaskImpl.java

@@ -45,8 +45,8 @@ public class DeviceStatTaskImpl implements ITaskExcuteService {
         List<DeviceEntity> waitDeviceInfos = new ArrayList<>();
         while (true) {
             DeviceEntity deviceEntity = cacheService.lpop(RedisKey.KEY_DEVICE_ONLINE_QUEUE, DeviceEntity.class);
+            log.info("deviceEntity:{}",deviceEntity==null);
             if (ObjectUtils.isEmpty(deviceEntity)) {
-                log.info("等待更新队列为空!");
                 break;
             } else {
                 waitDeviceInfos.add(deviceEntity);