提交 c41d4048 authored 作者: 杨凯's avatar 杨凯

feat:新增告警接收接口

上级 774c4838
......@@ -37,26 +37,25 @@ public class AlarmServiceImpl implements AlarmService {
@Override
public String receive(List<AlarmMessage> alarmMessages) {
for (AlarmMessage alarmMessage : alarmMessages) {
String name = alarmMessage.getName();
String message = alarmMessage.getAlarmMessage();
// 获取服务名称
String serviceNme = name.substring(name.indexOf("byh"), name.length());
// 云端通知人员
if (projProperties.getCloudBaseService().contains(serviceNme)) {
// message += "<at user_id=\\\"ou_6cb2f35f9bf8e7d7e977483801ab13de\\\">杨凯</at>";
message += "<at user_id=\\\"" + projProperties.getCloudBaseNotifyName() + "\\\"></at>";
alarmMessage.setAlarmMessage(message);
}
String sendMessage = "{\"msg_type\":\"text\",\"content\":{\"text\":\"Apache SkyWalking Alarm: \\n %s.\"}}";
String requestBody = getRequestBody(sendMessage, alarmMessage);
try {
HttpKit.jsonPost(webHookUrl, requestBody);
} catch (Exception e) {
return "fail";
}
}
// for (AlarmMessage alarmMessage : alarmMessages) {
// String name = alarmMessage.getName();
// String message = alarmMessage.getAlarmMessage();
// // 获取服务名称
// String serviceNme = name.substring(name.indexOf("byh"), name.length());
// // 云端通知人员
// if (projProperties.getCloudBaseService().contains(serviceNme)) {
// // message += "<at user_id=\\\"ou_6cb2f35f9bf8e7d7e977483801ab13de\\\">杨凯</at>";
// message += "<at user_id=\\\"" + projProperties.getCloudBaseNotifyName() + "\\\"></at>";
// alarmMessage.setAlarmMessage(message);
// }
// String sendMessage = "{\"msg_type\":\"text\",\"content\":{\"text\":\"Apache SkyWalking Alarm: \\n %s.\"}}";
// String requestBody = getRequestBody(sendMessage, alarmMessage);
// try {
// HttpKit.jsonPost(webHookUrl, requestBody);
// } catch (Exception e) {
// return "fail";
// }
// }
return "success";
}
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论