过滤垃圾消息

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

@@ -124,6 +124,9 @@ public class MqttMsgRedisService {
         CareDevice careDevice = careDeviceService.getById(careMqttMsg.getDevId());
         CareEventOrder order = mqttMsgService.getNewOrder(careDevice);
         if(order == null){
+            careMqttMsg.setStatus(MqttMsgStatusEnum.HANDLED.getValue());
+            careMqttMsg.setModifyTime(new Date());
+            this.careMqttMsgService.updateById(careMqttMsg);
             return;
         }
         order.setCreateTime(careMqttMsg.getCreateTime());