server commit files

fyxc

2025-05-22 09fcc4ec56a1ce6c0fcb308348d8dd5e2c08d336

 src/main/java/com/zy/core/News.java

@@ -23,7 +23,9 @@
        System.out.println(News.print());
    }

    interface NewsSupport<T> { boolean execute(T t); }
    interface NewsSupport<T> {
        boolean execute(T t);
    }

    private static final NewsQueue<NewsDomain> NEWS_QUEUE = new NewsQueue<>(NewsDomain.class, 1024);

@@ -36,7 +38,10 @@
        private int head;
        private int tail;

        { this.head = 0; this.tail = 0; }
        {
            this.head = 0;
            this.tail = 0;
        }

        public NewsQueue(Class<T> cls, int capacity) {
            this.cls = cls;
@@ -50,7 +55,7 @@
            }
            this.reform();
            this.arr[this.tail] = t;
            this.tail ++;
            this.tail++;
            return true;
        }

@@ -61,7 +66,7 @@
                this.reform();
            }
            this.arr[this.tail] = t;
            this.tail ++;
            this.tail++;
            return true;
        }

@@ -70,14 +75,14 @@
                return null;
            }
            T t = this.arr[this.head];
            this.head ++;
            this.head++;
            this.reform();
            return t;
        }

        private void reform() {
            for (int i = this.head; i < this.tail; i++) {
                this.arr[i-this.head] = this.arr[i];
                this.arr[i - this.head] = this.arr[i];
            }
            this.tail -= this.head;
            this.head = 0;
@@ -168,7 +173,7 @@
            return false;
        }
        String systemMsg = replace(msg, args);
        if (systemMsg.equals(wrkMast.getSystemMsg())) {
        if (!systemMsg.equals(wrkMast.getSystemMsg())) {
            wrkMast.setSystemMsg(systemMsg);
            wrkMast.setModiTime(new Date());
            wrkMastService.updateById(wrkMast);
@@ -180,14 +185,16 @@
        return NEWS_QUEUE.offer(new NewsDomain(level, replace(msg, args), (new SimpleDateFormat("yyyy-MM-dd HH:mm:ss")).format(new Date())));
    }

    public 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 {
            StringBuilder sb = new StringBuilder(str);
            for (Object obj : objs) {
                int idx = sb.indexOf("{}");
                if (idx == -1) { break; }
                if (idx == -1) {
                    break;
                }
                sb.replace(idx, idx + 2, String.valueOf(obj));
            }
            return sb.toString();
@@ -212,6 +219,7 @@
        ERROR(3),
        ;
        public int idx;

        NewsLevel(int idx) {
            this.idx = idx;
        }