修改设备更新线程实现逻辑

device-manager/src/main/java/com/mortals/xhx/thread/DeviceDownMsgThread.java

@@ -57,7 +57,7 @@ public class DeviceDownMsgThread extends AbstractThread {
 
     @Override
     protected void process() {
-        log.info("update device thread process");
+        log.info("DeviceDownMsgThread process");
         DeviceMsgReq deviceMsgReq = cacheService.blpop(KEY_DEVICE_DOWN_MSG_QUEUE, 10, DeviceMsgReq.class);
         if (!ObjectUtils.isEmpty(deviceMsgReq)) {
             log.info("下发消息:{}", deviceMsgReq.getDeviceCode());

device-manager/src/main/java/com/mortals/xhx/thread/DeviceUpdateComsumerThread.java

@@ -38,7 +38,7 @@ public class DeviceUpdateComsumerThread extends AbstractThread {
 
     @Override
     protected void process()  {
-        log.info("update device thread process");
+        log.info("DeviceUpdateComsumerThread process");
         List<DeviceEntity> waitUpdateDeviceList = new ArrayList<>();
         while (true) {
             DeviceEntity deviceEntity = cacheService.lpop(RedisKey.KEY_DEVICE_UPDATE_QUEUE, DeviceEntity.class);