From 82416a8117dd69be757380e8a42ecbac6e861e11 Mon Sep 17 00:00:00 2001
From: zhang <zc857179121@qq.com>
Date: 星期四, 19 三月 2026 11:12:36 +0800
Subject: [PATCH] Merge branch 'rcs_master' into jdxaj
---
zy-acs-common/src/main/java/com/zy/acs/common/utils/News.java | 184 ++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 184 insertions(+), 0 deletions(-)
diff --git a/zy-acs-common/src/main/java/com/zy/acs/common/utils/News.java b/zy-acs-common/src/main/java/com/zy/acs/common/utils/News.java
new file mode 100644
index 0000000..5729f35
--- /dev/null
+++ b/zy-acs-common/src/main/java/com/zy/acs/common/utils/News.java
@@ -0,0 +1,184 @@
+package com.zy.acs.common.utils;
+
+import lombok.Data;
+import lombok.extern.slf4j.Slf4j;
+import org.slf4j.helpers.FormattingTuple;
+import org.slf4j.helpers.MessageFormatter;
+
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * news stories for vincent
+ * Created by vincent on 2022/12/22
+ */
+@Slf4j
+public class News {
+
+ private static final int DEFAULT_CAPACITY = 1024;
+ private static final DateTimeFormatter DATE_FORMATTER = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
+ private static final NewsQueue<NewsDomain> NEWS_QUEUE = new NewsQueue<>(DEFAULT_CAPACITY);
+
+ public static void main(String[] args) {
+ News.info("info{}", 1);
+ News.warn("warn{}", 2);
+ News.error("error{}", 3);
+ System.out.println(News.print());
+ }
+
+ public static void info(String format, Object... arguments) {
+ log.info(format, arguments);
+ offer(NewsLevel.INFO, format, arguments);
+ }
+
+ public static void warn(String format, Object... arguments) {
+ log.warn(format, arguments);
+ offer(NewsLevel.WARN, format, arguments);
+ }
+
+ public static void error(String format, Object... arguments) {
+ log.error(format, arguments);
+ offer(NewsLevel.ERROR, format, arguments);
+ }
+
+ public static String printStr() {
+ StringBuilder sb = new StringBuilder("[");
+ List<NewsDomain> domains = NEWS_QUEUE.data();
+ for (int i = 0; i < domains.size(); i++) {
+ NewsDomain domain = domains.get(i);
+ sb.append("{");
+ sb.append("\"l\":").append(domain.getLevel().idx).append(",");
+ sb.append("\"v\":\"").append(escapeJson(domain.getContent())).append("\"").append(",");
+ sb.append("\"t\":\"").append(escapeJson(domain.getDate())).append("\"");
+ sb.append("}");
+ if (i < domains.size() - 1) {
+ sb.append(",");
+ }
+ }
+ sb.append("]");
+ return sb.toString();
+ }
+
+ public static List<Map<String, Object>> print() {
+ List<Map<String, Object>> res = new ArrayList<>();
+ for (NewsDomain datum : NEWS_QUEUE.data()) {
+ Map<String, Object> map = new HashMap<>();
+ map.put("l", datum.getLevel().idx);
+ map.put("v", datum.getContent());
+ map.put("t", datum.getDate());
+ res.add(map);
+ }
+ return res;
+ }
+
+ private static boolean offer(NewsLevel level, String msg, Object[] args) {
+ String template = msg == null ? "" : msg;
+ FormattingTuple tuple = MessageFormatter.arrayFormat(template, args);
+ String formatted = tuple.getMessage();
+ return NEWS_QUEUE.offer(new NewsDomain(level, formatted,
+ LocalDateTime.now().format(DATE_FORMATTER)));
+ }
+
+ private static String escapeJson(String value) {
+ if (value == null) {
+ return "";
+ }
+ StringBuilder sb = new StringBuilder(value.length());
+ for (char c : value.toCharArray()) {
+ switch (c) {
+ case '"':
+ sb.append("\\\"");
+ break;
+ case '\\':
+ sb.append("\\\\");
+ break;
+ case '\n':
+ sb.append("\\n");
+ break;
+ case '\r':
+ sb.append("\\r");
+ break;
+ case '\t':
+ sb.append("\\t");
+ break;
+ default:
+ if (c < 0x20) {
+ sb.append(String.format("\\u%04x", (int) c));
+ } else {
+ sb.append(c);
+ }
+ }
+ }
+ return sb.toString();
+ }
+
+ private static final class NewsQueue<T> {
+
+ private final Object[] arr;
+ private final int capacity;
+ private int head;
+ private int size;
+
+ private NewsQueue(int capacity) {
+ if (capacity <= 0) {
+ throw new IllegalArgumentException("capacity must be > 0");
+ }
+ this.arr = new Object[capacity];
+ this.capacity = capacity;
+ this.head = 0;
+ this.size = 0;
+ }
+
+ public synchronized boolean offer(T t) {
+ int writeIndex = (head + size) % capacity;
+ arr[writeIndex] = t;
+ if (size == capacity) {
+ head = (head + 1) % capacity;
+ } else {
+ size++;
+ }
+ return true;
+ }
+
+ public synchronized List<T> data() {
+ List<T> copy = new ArrayList<>(size);
+ for (int i = 0; i < size; i++) {
+ int idx = (head + i) % capacity;
+ @SuppressWarnings("unchecked")
+ T element = (T) arr[idx];
+ copy.add(element);
+ }
+ return copy;
+ }
+ }
+
+ @Data
+ static class NewsDomain {
+ private final NewsLevel level;
+ private final String content;
+ private final String date;
+
+ public NewsDomain(NewsLevel level, String content, String date) {
+ this.level = level;
+ this.content = content;
+ this.date = date;
+ }
+
+ }
+
+ enum NewsLevel {
+ INFO(1),
+ WARN(2),
+ ERROR(3),
+ ;
+ public final int idx;
+ NewsLevel(int idx) {
+ this.idx = idx;
+ }
+ }
+
+}
--
Gitblit v1.9.1