过滤垃圾消息

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

@@ -60,6 +60,11 @@ public class MqttMsgInstallService {
             logger.error("不是正确格式的消息");
             return;
         }
+        if(!"CfgAreaAck".equals(type) && !"CfgDevicePositionAck".equals(type)
+                && !"CfgEntrancesAck".equals(type) && !"CfgRegionsAck".equals(type)){
+            logger.error("不是要处理的消息");
+            return;
+        }
         Map msg = (Map) map.get("msg");
         if(msg == null) {
             logger.error("不是正确格式的消息");

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

@@ -80,6 +80,11 @@ public class MqttMsgService {
                 logger.error("不是正确格式的消息");
                 return;
             }
+
+            if(!"BreathHeartRate".equals(type) && !"FallDown".equals(type) && !"StayTooLong".equals(type)){
+                logger.error("不是要处理的消息");
+                return;
+            }
             QueryWrapper<CareDevice> queryWrapper = new QueryWrapper<>();
             queryWrapper.lambda().eq(CareDevice::getTopic,topic);
             CareDevice careDevice = careDeviceService.getOne(queryWrapper);