过滤垃圾消息

src/main/java/com/care/mqtt/service/MqttMsgInstallService.java

@@ -62,7 +62,7 @@ public class MqttMsgInstallService {
         }
         if(!"CfgAreaAck".equals(type) && !"CfgDevicePositionAck".equals(type)
                 && !"CfgEntrancesAck".equals(type) && !"CfgRegionsAck".equals(type)){
-            logger.error("不是要处理的消息");
+            //logger.error("不是要处理的消息");
             return;
         }
         Map msg = (Map) map.get("msg");

src/main/java/com/care/mqtt/service/MqttMsgService.java

@@ -82,7 +82,7 @@ public class MqttMsgService {
             }
 
             if(!"BreathHeartRate".equals(type) && !"FallDown".equals(type) && !"StayTooLong".equals(type)){
-                logger.error("不是要处理的消息");
+               // logger.error("不是要处理的消息");
                 return;
             }
             QueryWrapper<CareDevice> queryWrapper = new QueryWrapper<>();

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

@@ -34,7 +34,7 @@ public class MqttMessageListener implements IMqttMessageListener {
 //        System.out.println(mqttMessage.isRetained());
 //        System.out.println(mqttMessage.isDuplicate());
         String mqttMessageStr = mqttMessage.toString();
-        logger.info("mqttMessageStr == " + mqttMessageStr);
+        //logger.info("mqttMessageStr == " + mqttMessageStr);
         if(mqttMessageStr == null || !mqttMessageStr.startsWith("{")){
             logger.error("不是正确格式的消息");
             return;