修改离线消息

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

@@ -10,6 +10,7 @@ import com.mortals.framework.model.ErrorLogPdu;
 import com.mortals.framework.service.ICacheService;
 import com.mortals.framework.service.IMessageProduceService;
 import com.mortals.xhx.common.code.*;
+import com.mortals.xhx.common.key.RedisKey;
 import com.mortals.xhx.common.pdu.RespData;
 import com.mortals.xhx.common.pdu.sms.SmsSetPdu;
 import com.mortals.xhx.feign.sms.ISmsSetFeign;
@@ -83,7 +84,7 @@ public class CustomerKeyExpirationListener implements MessageListener {
                 DeviceEntity deviceEntity = deviceService.getExtCache(subStr);
                 if (!ObjectUtils.isEmpty(deviceEntity)) {
                     if (deviceEntity.getDeviceStatus() == DeviceStatusEnum.在线.getValue()) {
-                        deviceEntity.setOfflineTime(new Date());
+            /*            deviceEntity.setOfflineTime(new Date());
                         deviceEntity.setDeviceStatus(DeviceStatusEnum.离线.getValue());
 
                         DeviceEntity entity = new DeviceEntity();
@@ -93,7 +94,15 @@ public class CustomerKeyExpirationListener implements MessageListener {
                         DeviceEntity condition = new DeviceEntity();
                         condition.setId(deviceEntity.getId());
                         deviceService.getDeviceDao().update(entity, condition);
-                        deviceService.putCache(deviceEntity.getId().toString(), deviceEntity);
+                        deviceService.putCache(deviceEntity.getId().toString(), deviceEntity);*/
+
+                        DeviceEntity condition = new DeviceEntity();
+                        condition.setId(deviceEntity.getId());
+                        condition.setOfflineTime(new Date());
+                        condition.setDeviceStatus(DeviceStatusEnum.离线.getValue());
+
+                        cacheService.lpush(RedisKey.KEY_DEVICE_UPDATE_QUEUE,condition);
+
                         log.info("deviceCode:{}，deviceName:{}==>离线", deviceEntity.getDeviceCode(), deviceEntity.getDeviceName());
                         // deviceService.update(deviceEntity);
                         PlatformEntity platformEntity = platformService.getCache(deviceEntity.getPlatformId().toString());