root
/
ifishMQ
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

0.0温度忽略

This commit is contained in:
yan.y 2026-03-26 15:08:53 +08:00
parent 44b3eb14f1
commit 493f56593f
1 changed files with 13 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
src/main/java/com/ifish7/mq/push/AliyunPushApi.java
View File

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