From 32b593115da09714624f3803fc43a6add07da391 Mon Sep 17 00:00:00 2001
From: Junjie <540245094@qq.com>
Date: 星期四, 22 五月 2025 16:20:14 +0800
Subject: [PATCH] #系统异常监视
---
src/main/java/com/zy/common/utils/News.java | 25 +++++++++++++++++++++++++
1 files changed, 25 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/zy/common/utils/News.java b/src/main/java/com/zy/common/utils/News.java
index 63c8762..3937246 100644
--- a/src/main/java/com/zy/common/utils/News.java
+++ b/src/main/java/com/zy/common/utils/News.java
@@ -1,5 +1,7 @@
package com.zy.common.utils;
+import com.core.common.SpringUtils;
+import com.zy.common.service.WatchService;
import lombok.extern.slf4j.Slf4j;
import java.lang.reflect.Array;
@@ -109,6 +111,21 @@
offer(NewsLevel.ERROR, format, arguments);
}
+ public static void watchInfo(String key, String format, Object... arguments) {
+ info(format, arguments);
+ watchOffer(key, replace(format, arguments));
+ }
+
+ public static void watchWarn(String key, String format, Object... arguments) {
+ warn(format, arguments);
+ watchOffer(key, replace(format, arguments));
+ }
+
+ public static void watchError(String key, String format, Object... arguments) {
+ error(format, arguments);
+ watchOffer(key, replace(format, arguments));
+ }
+
public static void infoNoLog(String format, Object... arguments) {
offer(NewsLevel.INFO, format, arguments);
}
@@ -155,6 +172,14 @@
return NEWS_QUEUE.offer(new NewsDomain(level, replace(msg, args), (new SimpleDateFormat("yyyy-MM-dd HH:mm:ss")).format(new Date())));
}
+ private static boolean watchOffer(String key, String msg) {
+ WatchService watchService = SpringUtils.getBean(WatchService.class);
+ if(watchService != null) {
+ return watchService.push(key, msg);
+ }
+ return false;
+ }
+
private static String replace(String str, Object[] objs){
if (null == objs || objs.length == 0 || null == str || "".equals(str.trim())) {
return str;
--
Gitblit v1.9.1