OpenSource/hertzbeat
Public Access
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

[manager]fix 重复发送企业微信通知

Browse Source
This commit is contained in:
tomsun28
2022-02-22 10:10:30 +08:00
parent c1010da2fe
commit e54ba2b058
1 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
manager/src/main/java/com/usthe/manager/component/alerter/DispatchAlarm.java
View File

@@ -117,7 +117,6 @@ public class DispatchAlarm {
List<NoticeReceiver> receivers = matchReceiverByNoticeRules(alert); List<NoticeReceiver> receivers = matchReceiverByNoticeRules(alert);
// todo 发送通知这里暂时单线程 // todo 发送通知这里暂时单线程
for (NoticeReceiver receiver : receivers) { for (NoticeReceiver receiver : receivers) {
sendWeWorkRobotAlert(receiver, alert);
switch (receiver.getType()) { switch (receiver.getType()) {
// todo 短信通知 // todo 短信通知
case 0: break; case 0: break;
@@ -162,7 +161,7 @@ public class DispatchAlarm {
log.warn("Send weWork webHook: {} Failed: {}", webHookUrl, entity.getBody()); log.warn("Send weWork webHook: {} Failed: {}", webHookUrl, entity.getBody());
} }
} catch (ResourceAccessException e) { } catch (ResourceAccessException e) {
log.warn("Send WebHook: {} Failed: {}.", receiver.getHookUrl(), e.getMessage()); log.warn("Send WebHook: {} Failed: {}.", webHookUrl, e.getMessage());
} catch (Exception e) { } catch (Exception e) {
log.error(e.getMessage(), e); log.error(e.getMessage(), e);
} }