mqtt

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

@@ -15,6 +15,7 @@ import com.care.common.entity.CareHouse;
 import com.care.common.enums.OrderStatusEnum;
 import com.care.common.enums.OrderTypeEnum;
 import com.care.common.service.*;
+import com.care.common.util.CommonConfUtil;
 import org.eclipse.paho.client.mqttv3.IMqttMessageListener;
 import org.eclipse.paho.client.mqttv3.MqttMessage;
 
@@ -93,7 +94,10 @@ public class MqttMessageListener implements IMqttMessageListener {
 
         String mqttMessageStr = mqttMessage.toString();
         System.out.println("mqttMessageStr == " + mqttMessageStr);
-
+        String saveDatabase = CommonConfUtil.getConf("mqtt.save.database");
+        if(!"1".equals(saveDatabase)){
+            return;
+        }
         if(mqttMessageStr == null || !mqttMessageStr.startsWith("{")){
             return;
         }