修改redis 过期事件通知

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

@@ -75,7 +75,11 @@ public class DeviceMsgComsumerStartedService implements IApplicationStartedServi
         TbQueueConsumer<TbQueueMsg> mainConsumer = consumerService.getMainConsumer();
         if (!ObjectUtils.isEmpty(mainConsumer)) {
             //订阅所有已激活设备
-            Set<TopicPartitionInfo> topicPartitionInfoSet = deviceService.find(new DeviceQuery().active(ActiveEnum.已激活.getValue()).status(StatusEnum.启用.getValue())).stream()
+            Set<TopicPartitionInfo> topicPartitionInfoSet = deviceService.find(new DeviceQuery()
+                    .active(ActiveEnum.已激活.getValue())
+                    //.status(StatusEnum.启用.getValue())
+                     )
+                    .stream()
                     .filter(f -> !ObjectUtils.isEmpty(platformService.get(f.getPlatformId())))
                     .filter(f -> !ObjectUtils.isEmpty(productService.get(f.getProductId())))
                     .map(item -> {

device-manager/src/test/java/com/mortals/httpclient/device/DeviceController.http

@@ -90,9 +90,9 @@ Authorization: {{authToken}}
 Content-Type: application/json
 
 {
-  "receiveMethod": 1,
+  "receiveMethod": 3,
   "deviceName": "测试接口创建设备3",
-  "deviceCode": "b12345678",
+  "deviceCode": "a12345678",
   "siteId": 123,
   "siteCode": "adfasfdasfdasf",
   "siteName": "测试站点",