服务中管家人数

src/main/java/com/care/bms/mqtt/MqttInit.java

@@ -6,6 +6,7 @@ package com.care.bms.mqtt;
 import com.care.bms.service.BmsEventOrderService;
 
 import com.care.common.service.*;
+import com.care.common.util.CommonConfUtil;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -34,9 +35,12 @@ public class MqttInit implements CommandLineRunner {
 
     @Override
     public void run(String... args) throws Exception {
-        logger.info("初始化MQTTstart ...........................");
-        MqttTool.init(careDeviceService,bmsEventOrderService,careEventOrderService,careHouseService,careOrganizationService,careStationService);
-        logger.info("初始化MQTTend ...........................");
+        String mqttOn = CommonConfUtil.getConf("mqtt.on");
+        if ("1".equals(mqttOn)){
+            logger.info("初始化MQTTstart ...........................");
+            MqttTool.init(careDeviceService,bmsEventOrderService,careEventOrderService,careHouseService,careOrganizationService,careStationService);
+            logger.info("初始化MQTTend ...........................");
+        }
     }
 
 }