#钉钉消息通知

lty

12 小时以前 9efecf90d32e39b2ecab8fd6c789300962fd5a97

#钉钉消息通知

 pom.xml

@@ -112,6 +112,18 @@
            <artifactId>truelicense-core</artifactId>
            <version>1.33</version>
        </dependency>
        <!-- 钉钉消息推送 -->
        <dependency>
            <groupId>com.aliyun</groupId>
            <artifactId>alibaba-dingtalk-service-sdk</artifactId>
            <version>1.0.1</version>
            <exclusions>
                <exclusion>
                    <groupId>log4j</groupId>
                    <artifactId>log4j</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <!-- WebClient -->
        <dependency>
            <groupId>org.springframework.boot</groupId>

 src/main/java/com/zy/asrs/task/ExceptionNoticeScheduler.java

New file
@@ -0,0 +1,16 @@
package com.zy.asrs.task;

import com.zy.asrs.task.core.ReturnT;
import org.springframework.scheduling.annotation.Scheduled;

import static org.reflections.Reflections.log;

public class ExceptionNoticeScheduler {
    @Scheduled(cron = "0/1 * * * * ? ")
    private void execute(){
        ReturnT<String> returnT = exceptionNoticeHandler.start();
        if (!returnT.isSuccess()) {
            log.error(returnT.getMsg());
        }
    }
}

 src/main/java/com/zy/asrs/task/handler/ExceptionNoticeHandler.java

New file
@@ -0,0 +1,61 @@
package com.zy.asrs.task.handler;

import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.baomidou.mybatisplus.plugins.Page;
import com.zy.asrs.entity.ApiLog;
import com.zy.asrs.service.ApiLogService;
import com.zy.asrs.task.AbstractHandler;
import com.zy.asrs.task.core.ReturnT;
import com.zy.common.utils.DingDingPush;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.transaction.interceptor.TransactionAspectSupport;


@Slf4j
@Service
@Transactional
public class ExceptionNoticeHandler extends AbstractHandler<String> {
    @Autowired
    private ApiLogService apiLogService;
    @Transactional
    public ReturnT<String> start() {
        try {
            EntityWrapper<ApiLog> wrapper = new EntityWrapper<>();
            wrapper.eq("result", 0).isNull("memo").orderBy("create_time", false);
            Page<ApiLog> page = apiLogService.selectPage(new Page<>(1, 1), wrapper);
            if (page.getRecords() != null && !page.getRecords().isEmpty()) {
                ApiLog item = page.getRecords().get(0);
                StringBuilder sb = new StringBuilder();
                sb.append("异常告警").append("\n");
                sb.append("时间: ").append(item.getCreateTime$()).append("\n");
                sb.append("接口: ").append(nvl(item.getNamespace())).append(" ").append(nvl(item.getUrl())).append("\n");
                sb.append("IP: ").append(nvl(item.getClientIp())).append("\n");
                sb.append("请求: ").append(cut(nvl(item.getRequest()), 500)).append("\n");
                sb.append("响应: ").append(cut(nvl(item.getResponse()), 500)).append("\n");
                sb.append("异常: ").append(cut(nvl(item.getErr()), 500));
                DingDingPush.send(sb.toString());
                item.setMemo("PUSHED");
                apiLogService.updateById(item);
            }
        } catch (Exception e) {
            e.printStackTrace();
            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
            return FAIL.setMsg(e.getMessage());
        }
        return SUCCESS;
    }

    private String nvl(String s) {
        return s == null ? "" : s;
    }

    private String cut(String s, int max) {
        if (s == null) {
            return "";
        }
        return s.length() > max ? s.substring(0, max) : s;
    }
}

 src/main/java/com/zy/common/utils/DingDingPush.java

New file
@@ -0,0 +1,117 @@
package com.zy.common.utils;

import com.alibaba.fastjson.JSON;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.URL;
import java.net.URLConnection;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;

/**
 * 钉钉消息发送
 */
public class DingDingPush {

    public static void main(String[] args) {
        StringBuffer pushSb = new StringBuffer();
        pushSb.append("【")
                .append(new Date()).append("】")
                .append("ERRORChina");
        DingDingPush.send(pushSb.toString());
    }

    public static String send(String content){
        //测试机器人key
        String dingKey ="https://oapi.dingtalk.com/robot/send?access_token=a7b0a0e96f4b19810e545b0518740e16ad934679c42ffb0a4d545cf4fd129887";
        // 请求的JSON数据，这里我用map在工具类里转成json格式
        Map<String,Object> json=new HashMap<>();
        Map<String,Object> text=new HashMap<>();
        json.put("msgtype","text");
        text.put("content",content);
        json.put("text",text);
        // 发送post请求
        String result = DingDingPush.sendPostByMap(dingKey, json);
        System.out.println("result sefsefsfsef " + result);
        return result;
    }

    /**
     * 发送POST请求，参数是Map, contentType=x-www-form-urlencoded
     *
     * @param url
     * @param mapParam
     * @return
     */
    public static String sendPostByMap(String url, Map<String, Object> mapParam) {
        Map<String, String> headParam = new HashMap<>();
        headParam.put("Content-type", "application/json;charset=UTF-8");
        return sendPost(url, mapParam, headParam);
    }

    /**
     * 向指定 URL 发送POST方法的请求
     *
     * @param url   发送请求的 URL
     * @param param 请求参数，
     * @return 所代表远程资源的响应结果
     */
    public static String sendPost(String url, Map<String, Object> param, Map<String, String> headParam) {
        PrintWriter out = null;
        BufferedReader in = null;
        String result = "";
        try {
            URL realUrl = new URL(url);
            // 打开和URL之间的连接
            URLConnection conn = realUrl.openConnection();
            // 设置通用的请求属性 请求头
            conn.setRequestProperty("accept", "*/*");
            conn.setRequestProperty("connection", "Keep-Alive");
            conn.setRequestProperty("user-agent",
                    "Fiddler");
            if (headParam != null) {
                for (Map.Entry<String, String> entry : headParam.entrySet()) {
                    conn.setRequestProperty(entry.getKey(), entry.getValue());
                }
            }
            // 发送POST请求必须设置如下两行
            conn.setDoOutput(true);
            conn.setDoInput(true);
            // 获取URLConnection对象对应的输出流
            out = new PrintWriter(conn.getOutputStream());
            // 发送请求参数
            out.print(JSON.toJSONString(param));
            // flush输出流的缓冲
            out.flush();
            // 定义BufferedReader输入流来读取URL的响应
            in = new BufferedReader(
                    new InputStreamReader(conn.getInputStream()));
            String line;
            while ((line = in.readLine()) != null) {
                result += line;
            }
            System.out.println("line=" +line);
        } catch (Exception e) {
            System.out.println("发送 POST 请求出现异常！" + e);
            e.printStackTrace();
        }
        //使用finally块来关闭输出流、输入流
        finally {
            try {
                if (out != null) {
                    out.close();
                }
                if (in != null) {
                    in.close();
                }
            } catch (IOException ex) {
                ex.printStackTrace();
            }
        }
        return result;
    }
}