feat: 增加钉钉推送

xymanager_common/pom.xml

@@ -133,6 +133,11 @@
             <artifactId>easyexcel</artifactId>
         </dependency>
 
+        <dependency>
+            <groupId>com.aliyun</groupId>
+            <artifactId>alibaba-dingtalk-service-sdk</artifactId>
+            <version>2.0.0</version>
+        </dependency>
 
         <dependency>
             <groupId>io.jsonwebtoken</groupId>

xymanager_common/src/main/java/com/shxy/xymanager_common/util/DingTalkPushUtil.java

@@ -0,0 +1,53 @@
+package com.shxy.xymanager_common.util;
+
+import com.dingtalk.api.DefaultDingTalkClient;
+import com.dingtalk.api.DingTalkClient;
+import com.dingtalk.api.request.OapiRobotSendRequest;
+import com.dingtalk.api.response.OapiRobotSendResponse;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.codec.binary.Base64;
+
+import javax.crypto.Mac;
+import javax.crypto.spec.SecretKeySpec;
+import java.net.URLEncoder;
+
+/**
+ * 钉钉推送工具类
+ */
+@Slf4j
+public class DingTalkPushUtil {
+
+    public static final String CUSTOM_ROBOT_TOKEN = "e65e730cba22e320e16926fd4ff19ce787fa2162d065792bb6562c6d4a4cf328";
+    public static final String SECRET = "SEC72e5fb1b4ce7f9fed55386040d599035c50f8d2a181ad66bd1277549f0716124";
+    public static final String KEY_WORD = "运维告警: ";
+
+
+    public static void pushText(String content) {
+        try {
+            Long timestamp = System.currentTimeMillis();
+            String stringToSign = timestamp + "\n" + SECRET;
+            Mac mac = Mac.getInstance("HmacSHA256");
+            mac.init(new SecretKeySpec(SECRET.getBytes("UTF-8"), "HmacSHA256"));
+            byte[] signData = mac.doFinal(stringToSign.getBytes("UTF-8"));
+            String sign = URLEncoder.encode(new String(Base64.encodeBase64(signData)), "UTF-8");
+
+            //sign字段和timestamp字段必须拼接到请求URL上，否则会出现 310000 的错误信息
+            DingTalkClient client = new DefaultDingTalkClient("https://oapi.dingtalk.com/robot/send?sign=" + sign + "&timestamp=" + timestamp);
+            OapiRobotSendRequest req = new OapiRobotSendRequest();
+            /**
+             * 发送文本消息
+             */
+            //定义文本内容
+            OapiRobotSendRequest.Text text = new OapiRobotSendRequest.Text();
+            text.setContent(KEY_WORD + content);
+            //设置消息类型
+            req.setMsgtype("text");
+            req.setText(text);
+            OapiRobotSendResponse rsp = client.execute(req, CUSTOM_ROBOT_TOKEN);
+        } catch (Exception e) {
+            log.error("钉钉发送失败", e);
+        }
+    }
+
+}
+