From 829cf2318e2902279b7601cb8fd4c4bc0587ad60 Mon Sep 17 00:00:00 2001
From: zxc <1272811460@qq.com>
Date: Wed, 5 Aug 2020 15:01:11 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BB=A3=E7=A0=81=E5=AE=A1=E6=A0=B8=E6=9C=BA?=
 =?UTF-8?q?=E5=99=A8=E4=BA=BA?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../epmet-third/epmet-third-server/pom.xml    |  8 +++++
 .../service/impl/WarrantServiceImpl.java      | 36 +++++++++++++++++++
 2 files changed, 44 insertions(+)

diff --git a/epmet-module/epmet-third/epmet-third-server/pom.xml b/epmet-module/epmet-third/epmet-third-server/pom.xml
index 952e9f8fb9..75699d5c0c 100644
--- a/epmet-module/epmet-third/epmet-third-server/pom.xml
+++ b/epmet-module/epmet-third/epmet-third-server/pom.xml
@@ -147,6 +147,14 @@
             <version>5.1.12.RELEASE</version>
             <scope>compile</scope>
         </dependency>
+
+        <!-- 钉钉机器人 -->
+        <dependency>
+            <groupId>com.aliyun</groupId>
+            <artifactId>alibaba-dingtalk-service-sdk</artifactId>
+            <version>1.0.1</version>
+        </dependency>
+
     </dependencies>
 
     <build>
diff --git a/epmet-module/epmet-third/epmet-third-server/src/main/java/com/epmet/service/impl/WarrantServiceImpl.java b/epmet-module/epmet-third/epmet-third-server/src/main/java/com/epmet/service/impl/WarrantServiceImpl.java
index 85b4a9277b..7177625410 100644
--- a/epmet-module/epmet-third/epmet-third-server/src/main/java/com/epmet/service/impl/WarrantServiceImpl.java
+++ b/epmet-module/epmet-third/epmet-third-server/src/main/java/com/epmet/service/impl/WarrantServiceImpl.java
@@ -3,6 +3,10 @@ package com.epmet.service.impl;
 import cn.hutool.json.JSONObject;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.nacos.client.config.utils.IOUtils;
+import com.dingtalk.api.DefaultDingTalkClient;
+import com.dingtalk.api.DingTalkClient;
+import com.dingtalk.api.request.OapiRobotSendRequest;
+import com.dingtalk.api.response.OapiRobotSendResponse;
 import com.epmet.commons.tools.constant.NumConstant;
 import com.epmet.commons.tools.utils.ConvertUtils;
 import com.epmet.commons.tools.utils.HttpClientManager;
@@ -24,6 +28,7 @@ import com.epmet.wxapi.constant.WxMaCodeConstant;
 import com.fasterxml.jackson.core.JsonEncoding;
 import com.fasterxml.jackson.core.JsonGenerator;
 import com.fasterxml.jackson.databind.ObjectMapper;
+import com.taobao.api.ApiException;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
 import org.dom4j.DocumentException;
@@ -139,16 +144,20 @@ public class WarrantServiceImpl implements WarrantService {
                 codeAuditRecordDao.insertCodeAuditRecord(codeAuditRecord);
                 // 修改 code_audit_result 中的代码审核结果
 //                String event = codeAuditRecord.getEvent();
+                String reason = codeAuditRecord.getReason();
                 String codeResult = null;
                 switch (event) {
                     case ModuleConstant.WEAPP_AUDIT_SUCCESS:
                         codeResult = ModuleConstant.AUDIT_SUCCESS;
+                        this.dingDingRobot(reason,null);
                         break;
                     case ModuleConstant.WEAPP_AUDIT_FAIL:
                         codeResult = ModuleConstant.AUDIT_FAILED;
+                        this.dingDingRobot(reason,codeResult);
                         break;
                     case ModuleConstant.WEAPP_AUDIT_DELAY:
                         codeResult = ModuleConstant.DELAY;
+                        this.dingDingRobot(reason,codeResult);
                         break;
                 }
                 String codeCustomerId = codeCustomerDao.selectCodeCustomerId(codeAuditRecord);
@@ -190,6 +199,33 @@ public class WarrantServiceImpl implements WarrantService {
         return ModuleConstant.SUCCESS;
     }
 
+    public void dingDingRobot(String result,String event){
+        DingTalkClient client = new DefaultDingTalkClient("https://oapi.dingtalk.com/robot/send?access_token=5b48fcbc3fde24b8ba4696aa062b7f8146479a9d3467dbb1f9cf132ec36b955a");
+        OapiRobotSendRequest request = new OapiRobotSendRequest();
+        request.setMsgtype("text");
+        OapiRobotSendRequest.Text text = new OapiRobotSendRequest.Text();
+        switch (event){
+            case ModuleConstant.WEAPP_AUDIT_SUCCESS:
+                text.setContent("代码审核结果: 审核成功");
+                break;
+            case ModuleConstant.WEAPP_AUDIT_FAIL:
+                text.setContent("代码审核结果: 审核不通过，"+
+                        "不通过原因："+result);
+                break;
+            case ModuleConstant.WEAPP_AUDIT_DELAY:
+                text.setContent("代码审核结果: 审核延时，"+
+                        "延时原因："+result);
+                break;
+        }
+        request.setText(text);
+        try {
+            OapiRobotSendResponse response = client.execute(request);
+        } catch (ApiException e) {
+            log.error("机器人生病了......");
+            e.printStackTrace();
+        }
+    }
+
     /**
      * 方法描述: 类型为enevt的时候，拼接
      * @param request