修改优化

huimv-env-platform/huimv-env-manage/src/main/java/com/huimv/env/manage/saas/mqtt/subscribe/ConsumerMQTT.java

@@ -47,6 +47,7 @@ public class ConsumerMQTT {
     }
 
     public void disConnect(String topic) {
+        System.out.println("主题名称：" + topic);
         try {
             client.unsubscribe(topic);
         } catch (MqttException e) {

huimv-env-platform/huimv-env-manage/src/main/java/com/huimv/env/manage/saas/mqtt/uplod/UploadMqtt.java

@@ -47,7 +47,7 @@ public class UploadMqtt extends Thread {
             options.setKeepAliveInterval(30);
 
             //设置断开后重新连接
-            options.setAutomaticReconnect(false);
+            options.setAutomaticReconnect(true);
 
             // 设置回调
             client.setCallback(new PushCallback());
@@ -69,7 +69,7 @@ public class UploadMqtt extends Thread {
 
     public static void test(List<String> topics) {
         try {
-            // host为主机名，clientid即连接MQTT的客户端ID，一般以唯一标识符表示，MemoryPersistence设置clientid的保存形式，默认为以内存保存
+/*            // host为主机名，clientid即连接MQTT的客户端ID，一般以唯一标识符表示，MemoryPersistence设置clientid的保存形式，默认为以内存保存
             client = new MqttClient(HOST, "subscribe", new MemoryPersistence());
             // MQTT的连接设置
             options = new MqttConnectOptions();
@@ -85,7 +85,7 @@ public class UploadMqtt extends Thread {
             options.setKeepAliveInterval(30);
 
             //设置断开后重新连接
-            options.setAutomaticReconnect(true);
+            options.setAutomaticReconnect(true);*/
 
             // 设置回调
             client.setCallback(new PushCallback());

huimv-env-platform/huimv-env-manage/src/main/java/com/huimv/env/manage/service/impl/EnvDeviceRegisterServiceImpl.java

@@ -141,7 +141,7 @@ public class EnvDeviceRegisterServiceImpl extends ServiceImpl<EnvDeviceRegisterM
     @Transactional
     public Result unbindingBaseDeviceCofig(Map<String, String> map, HttpServletRequest request) {
         String deviceCode = map.get("deviceCode");
-
+        System.out.println("解绑的设备编码"+deviceCode);
         EnvDeviceRegister envDeviceRegister = envDeviceRegisterMapper.selectOne(new QueryWrapper<EnvDeviceRegister>().eq("device_code", deviceCode));
         EnvDeviceRegister deviceRegister = new EnvDeviceRegister();
         deviceRegister.setUnitId("0");
@@ -154,8 +154,9 @@ public class EnvDeviceRegisterServiceImpl extends ServiceImpl<EnvDeviceRegisterM
         envDeviceEquipment.setUploadStart(0);
         envDeviceEquipment.setBinding(0);
         envDeviceEquipmentMapper.update(envDeviceEquipment,new UpdateWrapper<EnvDeviceEquipment>().eq("device_code",deviceCode));
+  /*      System.out.println("解绑的设备的主题名称"+envDeviceRegister.getChipId());
         ConsumerMQTT consumerMQTT = new ConsumerMQTT();
-        consumerMQTT.disConnect("huimv_up_"+envDeviceRegister.getChipId());
+        consumerMQTT.disConnect("huimv_up_"+envDeviceRegister.getChipId());*/
         return new Result(10000,"解绑成功",true);
     }