#

Junjie

2025-03-29 d51e29f60353ba3941489aed453997ee423c7bd5

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

@@ -1,12 +1,13 @@
package com.zy.core;

import com.core.common.SpringUtils;
import com.zy.asrs.entity.WrkMast;
import com.zy.asrs.service.WrkMastService;
import lombok.extern.slf4j.Slf4j;

import java.lang.reflect.Array;
import java.text.SimpleDateFormat;
import java.util.Arrays;
import java.util.Date;
import java.util.List;
import java.util.*;

/**
 * news stories for zoneyung
@@ -111,7 +112,22 @@
        offer(NewsLevel.ERROR, format, arguments);
    }

    public static String print() {
    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() {
        StringBuilder sb = new StringBuilder("[");
        List<NewsDomain> domains = NEWS_QUEUE.data();
        for (int i = 0; i < domains.size(); i++) {
@@ -129,11 +145,42 @@
        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.level.idx);
            map.put("v", datum.content);
            map.put("t", datum.date);
            res.add(map);
        }
        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 {