diff --git a/src/main/java/com/ifish7/mq/push/AliyunPushApi.java b/src/main/java/com/ifish7/mq/push/AliyunPushApi.java index 0797b90..0e1c3dd 100644 --- a/src/main/java/com/ifish7/mq/push/AliyunPushApi.java +++ b/src/main/java/com/ifish7/mq/push/AliyunPushApi.java @@ -100,18 +100,20 @@ public class AliyunPushApi { public void advancedPush(TblPushList pushList) { - //温度告警 0.0° 一天内只告警一次 + //温度告警 0.0° 屏蔽0.0 if (pushList.getPushType().equals("wendu_warn") && pushList.getPushContext().indexOf("达到0.0") > 0) { - try { - Long l = limitPushCaches.get(pushList.getDeviceId().toString()); - if (l != null && l > 0) { - log.info("24小时内已推送当前消息忽略 : " + JSONObject.toJSONString(pushList)); - return; - } - } catch (Exception e) { - log.error("check error", e); - } - limitPushCaches.put(pushList.getDeviceId().toString(), System.currentTimeMillis()); + log.info("0.0告警忽略 : " + JSONObject.toJSONString(pushList)); + return; +// try { +// Long l = limitPushCaches.get(pushList.getDeviceId().toString()); +// if (l != null && l > 0) { +// log.info("24小时内已推送当前消息忽略 : " + JSONObject.toJSONString(pushList)); +// return; +// } +// } catch (Exception e) { +// log.error("check error", e); +// } +// limitPushCaches.put(pushList.getDeviceId().toString(), System.currentTimeMillis()); } //根据Target来设定,多个值使用逗号分隔