fix error

pom.xml

@@ -116,6 +116,12 @@
             <version>4.4</version>
         </dependency>
 
+        <dependency>
+            <groupId>com.jayway.jsonpath</groupId>
+            <artifactId>json-path</artifactId>
+            <version>2.5.0</version>
+        </dependency>
+
     </dependencies>
 
     <build>

src/main/java/cn/qg/holmes/controller/jira/JiraWebhookController.java

 package cn.qg.holmes.controller.jira;
 
+import cn.qg.holmes.utils.JiraWebhookUtils;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
@@ -14,37 +15,19 @@ import java.io.BufferedReader;
 public class JiraWebhookController {
 
     @PostMapping("/webhook")
-    public Boolean jiraWebhook(HttpServletRequest request) {
-        log.info("已进入jira webhook！");
-//        BufferedReader br = null;
-//        String str, wholeStr = "";
-//        try {
-//            br = request.getReader();
-//            while ((str = br.readLine()) != null) {
-//                wholeStr += str;
-//            }
-//            log.info("jiraWebHook body: {}", wholeStr);
-//        } catch (Exception e) {
-//            log.error("jiraWebHook error", e);
-//        } finally {
-//            if (br != null) {
-//                try {
-//                    br.close();
-//                } catch (Exception e) {
-//                }
-//            }
-//        }
+    public void jiraWebhook(HttpServletRequest request) {
+        BufferedReader br = null;
+        StringBuilder jiraData = new StringBuilder();
         try {
-            BufferedReader br = request.getReader();
             String str = "";
-            StringBuilder requestData = new StringBuilder();
+            br = request.getReader();
             while((str = br.readLine()) != null){
-                requestData.append(str);
+                jiraData.append(str);
             }
             br.close();
         } catch (Exception e) {
             e.printStackTrace();
         }
-        return false;
+        JiraWebhookUtils.sendDingdingMsg(jiraData.toString());
     }
 }

src/main/java/cn/qg/holmes/entity/ding/LinkEntity.java

+package cn.qg.holmes.entity.ding;
+
+import com.alibaba.fastjson.JSONObject;
+import lombok.Data;
+
+@Data
+public class LinkEntity {
+
+    private String msgType;
+
+    // 显示标题
+    private String title;
+
+    // 显示内容
+    private String content;
+
+    // icon url
+    private String picUrl;
+
+    // 内容对链接
+    private String messageUrl;
+
+    public String getMsgType() {
+        return "link";
+    }
+
+    public String getJSONObjectString() {
+        // text类型
+        JSONObject linkContent = new JSONObject();
+        linkContent.put("title", this.getTitle());
+        linkContent.put("text", this.getContent());
+        linkContent.put("picUrl", this.getPicUrl());
+        linkContent.put("messageUrl", this.getMessageUrl());
+
+        JSONObject json = new JSONObject();
+        json.put("msgtype", this.getMsgType());
+        json.put("link", linkContent);
+        return json.toJSONString();
+    }
+
+}
+

src/main/java/cn/qg/holmes/utils/DingdingUtils.java

+package cn.qg.holmes.utils;
+
+import java.util.HashMap;
+import java.util.Map;
+
+public class DingdingUtils {
+
+    public static boolean sendToDingding(String jsonString, String webhook) {
+        Map<String, Object> headers = new HashMap<>();
+        Map<String, Object> params = new HashMap<>();
+        headers.put("content-type", "application/json; charset=utf-8");
+        HttpClientUtils.doPostJson(webhook, jsonString, headers);
+        return true;
+    }
+}

src/main/java/cn/qg/holmes/utils/JiraWebhookUtils.java

+package cn.qg.holmes.utils;
+
+import cn.qg.holmes.entity.ding.LinkEntity;
+import com.jayway.jsonpath.JsonPath;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
+
+@Slf4j
+public class JiraWebhookUtils {
+
+    public static void sendDingdingMsg(String jiraData) {
+        String url = "https://oapi.dingtalk.com/robot/send?access_token=835663338d638e40daaf3ab358af741ef0680a826a962c91bedc53b149d85ee1";
+
+        String webhookEvent = JsonPath.read(jiraData, "$.webhookEvent");
+        if (StringUtils.equals(webhookEvent, "jira:issue_created")) {
+            String creator = JsonPath.read(jiraData, "$.issue.fields.creator.displayName");
+            String assignee = JsonPath.read(jiraData, "$.issue.fields.assignee.displayName");
+            String key = JsonPath.read(jiraData, "$.issue.key");
+            String summary = JsonPath.read(jiraData, "$.issue.fields.summary");
+            LinkEntity linkEntity = new LinkEntity();
+            linkEntity.setTitle(creator + " 创建故障 " + key + "给@" + assignee + ", 请注意查看！");
+            linkEntity.setContent(summary);
+            linkEntity.setMessageUrl("http://jira2.quantgroup.cn/browse/" + key);
+            DingdingUtils.sendToDingding(linkEntity.getJSONObjectString(), url);
+        }
+    }
+}