添加智慧办公回调信息

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

@@ -47,8 +47,6 @@ public class DeviceComsumersRegisterService implements IApplicationStartedServic
         sendTaskThreadPool.init(20);
         log.info("服务端消息队列初始化服务开始..");
 
-
-
         deviceService.find(new DeviceEntity())
                 .stream()
                 .filter(f -> !ObjectUtils.isEmpty(platformService.get(f.getPlatformId())))

device-manager/src/main/java/com/mortals/xhx/module/device/service/impl/DeviceServiceImpl.java

@@ -103,6 +103,8 @@ public class DeviceServiceImpl extends AbstractCRUDCacheServiceImpl<DeviceDao, D
     @Autowired
     private SiteService siteService;
 
+
+
     public void refresh() {
         log.info("开始初始化系统参数...");
         try {
@@ -631,7 +633,9 @@ public class DeviceServiceImpl extends AbstractCRUDCacheServiceImpl<DeviceDao, D
                         };
                         messageProducer.queueDelete(Constant.UPLOAD_TOPIC + deviceEntity.getDeviceCode());
                         messageProducer.queueDelete(Constant.DOWN_TOPIC + deviceEntity.getDeviceCode());
-
+                        //删除监听器
+                        container.removeQueueNames(Constant.UPLOAD_TOPIC + deviceEntity.getDeviceCode());
+                        container.removeQueueNames(Constant.DOWN_TOPIC + deviceEntity.getDeviceCode());
                         //删除扩展extKey
                         this.removeCache(deviceEntity.getDeviceCode());
                         return id;

device-manager/src/test/java/com/mortals/httpclient/http-client.env.json

@@ -11,6 +11,11 @@
     "baseUrl": "http://192.168.0.98:11078/m",
     "baseLogin": "http://192.168.0.98:11078/base"
   },
+
+  "test1": {
+    "baseUrl": "http://8.136.255.30:11078/m",
+    "baseLogin": "http://192.168.0.98:11078/base"
+  },
   "portal": {
     "baseUrl": "http://192.168.0.98:11072/zwfw",
     "baseLogin": "http://192.168.0.98:11078/base"