feat:新增告警接收接口

alarm-server/src/main/java/com/ebaiyihui/alarm/server/service/Impl/AlarmServiceImpl.java

@@ -37,25 +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";
     }