跑马灯消息重复问题补充

amos-boot-module/amos-boot-module-biz/amos-boot-module-equip-biz/src/main/java/com/yeejoin/equipmanage/service/impl/MqttReceiveServiceImpl.java

@@ -264,9 +264,11 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
         if (ObjectUtils.isEmpty(iotDatalist)) {
             return;
         }
-        int count = equipmentSpecificAlarmMapper.selectCountByIotCode(iotCode, iotDatalist.get(0).getKey(), String.valueOf(iotDatalist.get(0).getValue()));
-        if (count > 0) {
-            return;
+        for (IotDataVO item : iotDatalist) {
+            int count = equipmentSpecificAlarmMapper.selectCountByIotCode(iotCode, item.getKey(), String.valueOf(item.getValue()));
+            if (count > 0) {
+                return;
+            }
         }
         log.info(String.format("收到mqtt消息：%s", message));
         realTimeDateProcessing(topicEntity, iotDatalist);