修改离线消息

device-manager/src/main/java/com/mortals/xhx/base/framework/listener/DirectDynamicListener.java

@@ -82,8 +82,8 @@ public class DirectDynamicListener implements MessageListener {
                 if (deviceEntity.getDeviceStatus() == DeviceStatusEnum.离线.getValue()) {
                     DeviceEntity condition = new DeviceEntity();
                     condition.setId(deviceEntity.getId());
-                    deviceEntity.setOnlineTime(new Date());
-                    deviceEntity.setDeviceStatus(DeviceStatusEnum.在线.getValue());
+                    condition.setOnlineTime(new Date());
+                    condition.setDeviceStatus(DeviceStatusEnum.在线.getValue());
 //                    DeviceEntity entity = new DeviceEntity();
 //                    entity.setOnlineTime(new Date());
 //                    entity.setDeviceStatus(DeviceStatusEnum.在线.getValue());

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

@@ -78,6 +78,11 @@ public class DeviceUpdateComsumerThread extends AbstractThread {
                 List<List<DeviceEntity>> partition = ListUtil.partition(sortUpdateList, 50);
                 for (List<DeviceEntity> deviceEntityList : partition) {
                     deviceService.update(deviceEntityList);
+                    try {
+                        Thread.sleep(1000);
+                    } catch (InterruptedException e) {
+                        throw new RuntimeException(e);
+                    }
                 }
             });
 /*