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

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

@@ -80,6 +80,8 @@ public class DirectDynamicListener implements MessageListener {
             if (!ObjectUtils.isEmpty(deviceEntity)) {
                 cacheService.set(RedisKey.KEY_DEVICE_ONLINE_CACHE + deviceEntity.getDeviceCode(), "", GlobalSysInfo.getParamIntValue(Constant.HEARTBEAT_TIMEOUT, 180));
                 if (deviceEntity.getDeviceStatus() == DeviceStatusEnum.离线.getValue()) {
+                    DeviceEntity condition = new DeviceEntity();
+                    condition.setId(deviceEntity.getId());
                     deviceEntity.setOnlineTime(new Date());
                     deviceEntity.setDeviceStatus(DeviceStatusEnum.在线.getValue());
 //                    DeviceEntity entity = new DeviceEntity();
@@ -91,7 +93,7 @@ public class DirectDynamicListener implements MessageListener {
                     // deviceService.update(deviceEntity);
                      //deviceService.putCache(deviceEntity.getId().toString(),deviceEntity);
 
-                     cacheService.lpush(RedisKey.KEY_DEVICE_UPDATE_QUEUE,deviceEntity);
+                     cacheService.lpush(RedisKey.KEY_DEVICE_UPDATE_QUEUE,condition);
 
                     PlatformEntity platformEntity = platformService.getCache(deviceEntity.getPlatformId().toString());
                     ProductEntity productEntity = productService.get(deviceEntity.getProductId());