update

springboot-summarizing/pom.xml

@@ -197,13 +197,16 @@
 		<!-- springmvc 版本 -->
 		<!-- <dependency> <groupId>com.baomidou</groupId> <artifactId>mybatis-plus</artifactId> 
 			<version>3.0.5</version> </dependency> -->
-
+		<dependency>
+			<groupId>cn.hutool</groupId>
+			<artifactId>hutool-all</artifactId>
+			<version>5.3.7</version>
+		</dependency>
 	</dependencies>
 
 
 	<build>
 		<defaultGoal>compile</defaultGoal>
-		<sourceDirectory>src</sourceDirectory>
 		<finalName>springboot-summarizing</finalName>
 		<plugins>
 			<plugin>

springboot-summarizing/src/main/java/com/pancm/web/AlertController.java

@@ -0,0 +1,90 @@
+package com.pancm.web;
+
+import cn.hutool.core.date.DateUtil;
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.http.HttpEntity;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.MediaType;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.client.RestTemplate;
+
+import java.util.HashMap;
+import java.util.Map;
+
+
+/**
+ * @Author pancm
+ * @Description Grafana和飞书webhook中转服务的代码
+ * @Date  2023/9/8
+ * @Param
+ * @return
+ **/
+@RestController
+@RequestMapping("alert")
+@Slf4j
+public class AlertController {
+
+    @Value("${feishu.webhook-url:https://open.feishu.cn/open-apis/bot/v2/hook/07f75330-f57b-40dd-8236-30092b0f4cc2}")
+    private String webhookUrl;
+
+    @Autowired
+    private  RestTemplate restTemplate;
+
+
+    private String msg = "告警标题：%s\n告警描述：%s\n面板URL：%s\n发生时间：%s";
+
+
+    @RequestMapping("/webhook/receive")
+    public void receive(@RequestBody String message) {
+        log.info("获取的Grafana的告警数据:{}",message);
+        Map<String, Object> m = createMessage(getText(message));
+        HttpHeaders headers = new HttpHeaders();
+        headers.setContentType(MediaType.APPLICATION_JSON);
+        restTemplate.postForEntity(webhookUrl, new HttpEntity<>(m, headers), Void.class);
+    }
+
+    /**
+     * 构建通知报文
+     * @param content
+     * @return
+     */
+    protected Map<String, Object> createMessage(String content) {
+        Map<String, Object> messageJson = new HashMap<>();
+        messageJson.put("msg_type", "text");
+
+        Map<String, Object> text = new HashMap<>();
+        text.put("text", content);
+        messageJson.put("content", text);
+        Long timestamp = System.currentTimeMillis() / 1000;
+        messageJson.put("timestamp", timestamp);
+
+        return messageJson;
+    }
+    /**
+     * 构建文本内容
+     * @param body
+     * @return
+     */
+    private String getText(String body) {
+        JSONObject json = JSON.parseObject(body);
+        Map<String, Object> root = new HashMap<>();
+        root.put("title", json.getString("title"));
+        root.put("description", json.getJSONObject("commonAnnotations").getString("description"));
+        JSONObject alertObject = json.getJSONArray("alerts").getJSONObject(0);
+        root.put("panelUrl", alertObject.getString("panelURL"));
+        root.put("startTime",DateUtil.now());
+        String senMsg = String.format(msg,
+                json.getString("title"),
+                json.getJSONObject("commonAnnotations").getString("description"),
+                alertObject.getString("panelURL"),
+                DateUtil.now()
+                );
+        return senMsg;
+    }
+}