From 9465ca0127101dfec793afce847b613dad80bce2 Mon Sep 17 00:00:00 2001
From: lty <876263681@qq.com>
Date: 星期六, 07 三月 2026 13:17:00 +0800
Subject: [PATCH] #钉钉消息通知
---
src/main/java/com/zy/asrs/task/handler/ExceptionNoticeHandler.java | 5 ++---
src/main/java/com/zy/asrs/task/ExceptionNoticeScheduler.java | 7 ++++++-
src/main/java/com/zy/common/utils/DingDingPush.java | 8 --------
3 files changed, 8 insertions(+), 12 deletions(-)
diff --git a/src/main/java/com/zy/asrs/task/ExceptionNoticeScheduler.java b/src/main/java/com/zy/asrs/task/ExceptionNoticeScheduler.java
index 06a973e..6400efa 100644
--- a/src/main/java/com/zy/asrs/task/ExceptionNoticeScheduler.java
+++ b/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();
diff --git a/src/main/java/com/zy/asrs/task/handler/ExceptionNoticeHandler.java b/src/main/java/com/zy/asrs/task/handler/ExceptionNoticeHandler.java
index 92ab9b3..3d55188 100644
--- a/src/main/java/com/zy/asrs/task/handler/ExceptionNoticeHandler.java
+++ b/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);
diff --git a/src/main/java/com/zy/common/utils/DingDingPush.java b/src/main/java/com/zy/common/utils/DingDingPush.java
index f2115fd..f87c480 100644
--- a/src/main/java/com/zy/common/utils/DingDingPush.java
+++ b/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){
//娴嬭瘯鏈哄櫒浜簁ey
String dingKey ="https://oapi.dingtalk.com/robot/send?access_token=a7b0a0e96f4b19810e545b0518740e16ad934679c42ffb0a4d545cf4fd129887";
--
Gitblit v1.9.1