feat:新增告警接收接口

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

@@ -42,47 +42,47 @@ 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 scope = alarmMessage.getScope();
-            // 过滤一下不发送服务通知逻辑
-            if (SERVICE.equals(scope)) {
-                if (Objects.nonNull(projProperties.getNotNotifyService()) && projProperties.getNotNotifyService().contains(name)) {
-                    return "success";
-                }
-            }
-            // 过滤一下不发送服务通知接口逻辑
-            if (ENDPOINT_RELATION.equalsIgnoreCase(scope)) {
-                // 获取路径地址
-                String tempName = name.substring(name.indexOf("/"), name.length());
-                String pathUrl = tempName.substring(0, tempName.indexOf(" "));
-                if (Objects.nonNull(projProperties.getNotNotifyService()) && projProperties.getNotNotifyUrl().contains(pathUrl)) {
-                    return "success";
-                }
-            }
-
-            // 获取服务名称
-            String serviceNme = name.substring(name.indexOf("byh"), name.length());
-            List<ServiceInfo> serviceInfos = projProperties.getServiceInfo();
-            for (ServiceInfo serviceInfo : serviceInfos) {
-                // 相应的服务通知对应人员
-                if (serviceInfo.getServiceNames().contains(serviceNme)) {
-                    //  message += "<at user_id=\\\"ou_6cb2f35f9bf8e7d7e977483801ab13de\\\">杨凯</at>";
-                    message += "<at user_id=\\\"" + serviceInfo.getServiceNotifyName() + "\\\"></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 scope = alarmMessage.getScope();
+//            // 过滤一下不发送服务通知逻辑
+//            if (SERVICE.equals(scope)) {
+//                if (Objects.nonNull(projProperties.getNotNotifyService()) && projProperties.getNotNotifyService().contains(name)) {
+//                    return "success";
+//                }
+//            }
+//            // 过滤一下不发送服务通知接口逻辑
+//            if (ENDPOINT_RELATION.equalsIgnoreCase(scope)) {
+//                // 获取路径地址
+//                String tempName = name.substring(name.indexOf("/"), name.length());
+//                String pathUrl = tempName.substring(0, tempName.indexOf(" "));
+//                if (Objects.nonNull(projProperties.getNotNotifyService()) && projProperties.getNotNotifyUrl().contains(pathUrl)) {
+//                    return "success";
+//                }
+//            }
+//
+//            // 获取服务名称
+//            String serviceNme = name.substring(name.indexOf("byh"), name.length());
+//            List<ServiceInfo> serviceInfos = projProperties.getServiceInfo();
+//            for (ServiceInfo serviceInfo : serviceInfos) {
+//                // 相应的服务通知对应人员
+//                if (serviceInfo.getServiceNames().contains(serviceNme)) {
+//                    //  message += "<at user_id=\\\"ou_6cb2f35f9bf8e7d7e977483801ab13de\\\">杨凯</at>";
+//                    message += "<at user_id=\\\"" + serviceInfo.getServiceNotifyName() + "\\\"></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";
     }