From 6e02d92c3b9c240fa78a343b67ddf0db12d840e6 Mon Sep 17 00:00:00 2001
From: Junjie <540245094@qq.com>
Date: 星期五, 22 八月 2025 17:00:56 +0800
Subject: [PATCH] #
---
src/main/java/com/zy/core/News.java | 122 ++++++++++++++++++++++++++++++++++++++++
1 files changed, 121 insertions(+), 1 deletions(-)
diff --git a/src/main/java/com/zy/core/News.java b/src/main/java/com/zy/core/News.java
index e5e069e..0b650b5 100644
--- a/src/main/java/com/zy/core/News.java
+++ b/src/main/java/com/zy/core/News.java
@@ -1,5 +1,13 @@
package com.zy.core;
+import com.baomidou.mybatisplus.mapper.EntityWrapper;
+import com.core.common.SpringUtils;
+import com.zy.asrs.entity.WrkMast;
+import com.zy.asrs.service.WrkMastService;
+import com.zy.common.utils.RedisUtil;
+import com.zy.core.enums.RedisKeyType;
+import com.zy.system.entity.Config;
+import com.zy.system.service.ConfigService;
import lombok.extern.slf4j.Slf4j;
import java.lang.reflect.Array;
@@ -95,18 +103,111 @@
}
public static void info(String format, Object... arguments) {
+ if (format.contains("[RCS Debug]")) {
+ ConfigService configService = SpringUtils.getBean(ConfigService.class);
+ if(configService != null) {
+ boolean show = true;
+ Config config = configService.selectOne(new EntityWrapper<Config>().eq("code", "rcsDebugShowLog"));
+ if(config != null) {
+ show = config.getValue().equals("true");
+ }
+
+ if (!show) {
+ return;
+ }
+ }
+ }
+ RedisUtil redisUtil = null;
+ try {
+ redisUtil = SpringUtils.getBean(RedisUtil.class);
+ if(redisUtil != null) {
+ Object object = redisUtil.get(RedisKeyType.LOG_LIMIT.key + format);
+ if (object != null) {
+ return;
+ }
+ redisUtil.set(RedisKeyType.LOG_LIMIT.key + format, "lock", 3);
+ }
+ }catch (Exception e) {}
+
log.info(format, arguments);
offer(NewsLevel.INFO, format, arguments);
}
public static void warn(String format, Object... arguments) {
+ if (format.contains("[RCS Debug]")) {
+ ConfigService configService = SpringUtils.getBean(ConfigService.class);
+ if(configService != null) {
+ boolean show = true;
+ Config config = configService.selectOne(new EntityWrapper<Config>().eq("code", "rcsDebugShowLog"));
+ if(config != null) {
+ show = config.getValue().equals("true");
+ }
+
+ if (!show) {
+ return;
+ }
+ }
+ }
+ RedisUtil redisUtil = null;
+ try {
+ redisUtil = SpringUtils.getBean(RedisUtil.class);
+ if(redisUtil != null) {
+ Object object = redisUtil.get(RedisKeyType.LOG_LIMIT.key + format);
+ if (object != null) {
+ return;
+ }
+ redisUtil.set(RedisKeyType.LOG_LIMIT.key + format, "lock", 3);
+ }
+ }catch (Exception e) {}
+
log.warn(format, arguments);
offer(NewsLevel.WARN, format, arguments);
}
public static void error(String format, Object... arguments) {
+ if (format.contains("[RCS Debug]")) {
+ ConfigService configService = SpringUtils.getBean(ConfigService.class);
+ if(configService != null) {
+ boolean show = true;
+ Config config = configService.selectOne(new EntityWrapper<Config>().eq("code", "rcsDebugShowLog"));
+ if(config != null) {
+ show = config.getValue().equals("true");
+ }
+
+ if (!show) {
+ return;
+ }
+ }
+ }
+ RedisUtil redisUtil = null;
+ try {
+ redisUtil = SpringUtils.getBean(RedisUtil.class);
+ if(redisUtil != null) {
+ Object object = redisUtil.get(RedisKeyType.LOG_LIMIT.key + format);
+ if (object != null) {
+ return;
+ }
+ redisUtil.set(RedisKeyType.LOG_LIMIT.key + format, "lock", 3);
+ }
+ }catch (Exception e) {}
+
log.error(format, arguments);
offer(NewsLevel.ERROR, format, arguments);
+ }
+
+ public static void taskInfo(Integer wrkNo, String format, Object... arguments) {
+ info(format, arguments);
+ offerTask(wrkNo, format, arguments);
+ }
+
+ public static void taskWarn(Integer wrkNo, String format, Object... arguments) {
+ warn(format, arguments);
+ offerTask(wrkNo, format, arguments);
+ }
+
+ public static void taskError(Integer wrkNo, String format, Object... arguments) {
+ error(format, arguments);
+ offerTask(wrkNo, format, arguments);
}
public static String printStr() {
@@ -139,11 +240,30 @@
return res;
}
+ private static boolean offerTask(Integer wrkNo, String msg, Object[] args) {
+ WrkMastService wrkMastService = SpringUtils.getBean(WrkMastService.class);
+ if (wrkMastService == null) {
+ return false;
+ }
+
+ WrkMast wrkMast = wrkMastService.selectByWorkNo(wrkNo);
+ if (wrkMast == null) {
+ return false;
+ }
+ String systemMsg = replace(msg, args);
+ if (!systemMsg.equals(wrkMast.getSystemMsg())) {
+ wrkMast.setSystemMsg(systemMsg);
+ wrkMast.setModiTime(new Date());
+ wrkMastService.updateById(wrkMast);
+ }
+ return true;
+ }
+
private static boolean offer(NewsLevel level, String msg, Object[] args) {
return NEWS_QUEUE.offer(new NewsDomain(level, replace(msg, args), (new SimpleDateFormat("yyyy-MM-dd HH:mm:ss")).format(new Date())));
}
- private static String replace(String str, Object[] objs){
+ public static String replace(String str, Object[] objs){
if (null == objs || objs.length == 0 || null == str || "".equals(str.trim())) {
return str;
} else {
--
Gitblit v1.9.1