#钉钉消息通知

lty

11 小时以前 9465ca0127101dfec793afce847b613dad80bce2

#钉钉消息通知

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

@@ -1,11 +1,16 @@
package com.zy.asrs.task;

import com.zy.asrs.task.core.ReturnT;
import com.zy.asrs.task.handler.ExceptionNoticeHandler;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import static org.reflections.Reflections.log;

@Component
public class ExceptionNoticeScheduler {
    @Autowired
    private ExceptionNoticeHandler exceptionNoticeHandler;
    @Scheduled(cron = "0/1 * * * * ? ")
    private void execute(){
        ReturnT<String> returnT = exceptionNoticeHandler.start();

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

@@ -29,13 +29,12 @@
            if (page.getRecords() != null && !page.getRecords().isEmpty()) {
                ApiLog item = page.getRecords().get(0);
                StringBuilder sb = new StringBuilder();
                sb.append("异常告警").append("\n");
                sb.append("异常告警-ERROR").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(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);

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

@@ -17,14 +17,6 @@
 */
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";