健康诊断告警,稳压泵单小时“启动”次数超过15次生成预警，不是启停次数

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

@@ -1166,9 +1166,8 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
                         // 处理每站消防储水量不少于4000m³ 预警问题
                         doWaterStationWarning(equipmentSpecificIndex.getBizOrgCode(), equipmentSpecificIndex.getBizOrgName());
                     }
-                    //稳压泵启停次数大于15次触发预警
-                    if (iotDataVO.getKey().equalsIgnoreCase(FHS_PressurePump_Start) ||
-                            iotDataVO.getKey().equalsIgnoreCase(FHS_PressurePump_Stop)) {
+                    //稳压泵启动次数大于15次触发预警
+                    if (iotDataVO.getKey().equalsIgnoreCase(FHS_PressurePump_Start)) {
                         doPressurePumInfo(topicEntity, equipmentSpecificIndex);
                     }
                     // 遥测数据生成告警事件、日志处理
@@ -1557,7 +1556,7 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
         String startDate = DateUtil.format(DateUtil.offsetHour(new Date(), -1), DatePattern.NORM_DATETIME_PATTERN);
         String prefix = topicEntity.getIotCode().substring(0, 8);
         String suffix = topicEntity.getIotCode().substring(8);
-        ResponseModel<Map<String, Integer>> mapResponseModel = iotFeign.queryIotDataNumByIndex(startDate, endDate, prefix, suffix, FHS_PressurePump_Start + "," + FHS_PressurePump_Stop, "true");
+        ResponseModel<Map<String, Integer>> mapResponseModel = iotFeign.queryIotDataNumByIndex(startDate, endDate, prefix, suffix, FHS_PressurePump_Start, "true");
         if (200 == mapResponseModel.getStatus()) {
             Map<String, Integer> result = mapResponseModel.getResult();
             Integer totalNum = result.get("num");