更新下发消息为线程池发送

device-manager/src/main/java/com/mortals/xhx/daemon/applicationservice/DeviceMsgComsumerStartedService.java

@@ -177,7 +177,7 @@ public class DeviceMsgComsumerStartedService implements IApplicationStartedServi
                                 condition.setOnlineTime(new Date());
                                 condition.setDeviceStatus(DeviceStatusEnum.在线.getValue());
 
-                                cacheService.lpush(RedisKey.KEY_DEVICE_UPDATE_QUEUE,deviceEntity);
+                                cacheService.lpush(RedisKey.KEY_DEVICE_UPDATE_QUEUE,condition);
                                 //  deviceService.update(deviceEntity);
 
                                 PlatformEntity platformEntity = platformService.getCache(deviceEntity.getPlatformId().toString());

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

@@ -78,9 +78,11 @@ public class DeviceStatTaskImpl implements ITaskExcuteService {
             if (ObjectUtils.isEmpty(item.getDeviceCode())) return null;
             boolean exists = cacheService.exists(RedisKey.KEY_DEVICE_ONLINE_CACHE + item.getDeviceCode());
             if (!exists) {
-                item.setDeviceStatus(DeviceStatusEnum.离线.getValue());
-                item.setOfflineTime(new Date());
-                return item;
+                DeviceEntity condition = new DeviceEntity();
+                condition.setId(item.getId());
+                condition.setDeviceStatus(DeviceStatusEnum.离线.getValue());
+                condition.setOfflineTime(new Date());
+                return condition;
             }
             return null;
         }).filter(f -> f != null).collect(Collectors.toList());