Commit c0db5acd by fudahua

Merge branch 'feature-918' into developer

parents cc876e3d e3f9b956
...@@ -134,19 +134,20 @@ public class CheckQywxSettingApiServiceImpl implements CheckQywxSettingApiServic ...@@ -134,19 +134,20 @@ public class CheckQywxSettingApiServiceImpl implements CheckQywxSettingApiServic
if (null == messageDTO) { if (null == messageDTO) {
return; return;
} }
boolean alertFlag = false;
if (messageDTO.getAlertType().equals(AlertTypeEnum.ES_BID_PAGE.getType())) { if (messageDTO.getAlertType().equals(AlertTypeEnum.ES_BID_PAGE.getType())) {
Object limit = RedisUtil.getCache("es_bid_page_limit"); Object limit = RedisUtil.getCache("es_bid_page_limit");
if (null != limit) { if (null != limit) {
Integer begin = Integer.valueOf(messageDTO.getContentMap().get("begin").toString()); Integer begin = Integer.valueOf(messageDTO.getContentMap().get("begin").toString());
if (begin.intValue() < Integer.valueOf(limit.toString())) { if (begin.intValue() < Integer.valueOf(limit.toString())) {
logger.info("没到阈值,无需告警"); logger.info("没到阈值,无需告警");
return; alertFlag = true;
} }
} }
} }
//告警是否拦截重复告警 防止批量触发 //告警是否拦截重复告警 防止批量触发
if (StringUtils.isNotBlank(messageDTO.getKey())) { if (StringUtils.isNotBlank(messageDTO.getKey())) {
String key = messageDTO.getKey() + messageDTO.getAlertType(); String key = messageDTO.getKey() + messageDTO.getAlertType() + alertFlag;
RBucket<Object> bucket = RedisUtil.getRedisClient().getBucket(key); RBucket<Object> bucket = RedisUtil.getRedisClient().getBucket(key);
boolean b = bucket.trySet(1, 60L, TimeUnit.SECONDS); boolean b = bucket.trySet(1, 60L, TimeUnit.SECONDS);
if (!b) { if (!b) {
...@@ -168,6 +169,9 @@ public class CheckQywxSettingApiServiceImpl implements CheckQywxSettingApiServic ...@@ -168,6 +169,9 @@ public class CheckQywxSettingApiServiceImpl implements CheckQywxSettingApiServic
if (anEnum.getDingUrl() != null) { if (anEnum.getDingUrl() != null) {
dingUrl = anEnum.getDingUrl(); dingUrl = anEnum.getDingUrl();
} }
if (alertFlag) {
dingUrl = ALERT_URL;
}
} else { } else {
markdownMap.put("title", messageDTO.getAlertTitle()); markdownMap.put("title", messageDTO.getAlertTitle());
text += "标题:" + messageDTO.getAlertTitle() + "\n\r"; text += "标题:" + messageDTO.getAlertTitle() + "\n\r";
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment