添加告警统计信息

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

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

device-manager/src/main/java/com/mortals/xhx/common/key/RedisKey.java

@@ -18,7 +18,7 @@ public class RedisKey {
     /**
      * 设备上线更新队列
      */
-    public static final String KEY_DEVICE_ONLINE_QUEUE = "device:online:queue";
+    public static final String KEY_DEVICE_ONLINE_QUEUE = "device:queue";
 
     public static final String KEY_SITE_CACHE = "siteDict";
 

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

@@ -46,6 +46,7 @@ public class DeviceStatTaskImpl implements ITaskExcuteService {
         while (true) {
             DeviceEntity deviceEntity = cacheService.lpop(RedisKey.KEY_DEVICE_ONLINE_QUEUE, DeviceEntity.class);
             if (ObjectUtils.isEmpty(deviceEntity)) {
+                log.info("等待更新队列为空");
                 break;
             } else {
                 waitDeviceInfos.add(deviceEntity);

device-manager/src/test/java/com/mortals/httpclient/device/DeviceController.http

@@ -98,7 +98,7 @@ POST {{baseUrl}}/api/register
 Content-Type: application/json
 
 {
-  "deviceCode": "0c-cf-89-09-d1-c8"
+  "deviceCode": "B8-13-32-86-3E-F4"
 }
 
 > {%