1

zhang

1 天以前 6831504a0ece1c073b65873757905936b533f2d9

 zy-asc-conveyor/src/main/java/com/zy/acs/conveyor/core/ConveyorBackgroundService.java

@@ -1,5 +1,6 @@
package com.zy.acs.conveyor.core;

import com.zy.acs.common.utils.News;
import com.zy.acs.conveyor.core.properties.CtuOperationConfig;
import com.zy.acs.conveyor.core.properties.CtuServiceProperties;
import com.zy.acs.conveyor.core.properties.SystemProperties;
@@ -32,6 +33,11 @@

    private final AtomicBoolean running = new AtomicBoolean(false);

    private long lastDbUpdateTime = 0;


    private static final int LOG_INTERVAL_MS = 30000;

    @PostConstruct
    public void init() {
        // 初始化线程池
@@ -57,15 +63,16 @@
            log.debug("系统未运行或服务已停止，跳过输送线任务处理");
            return;
        }

        long currentTime = System.currentTimeMillis();
        if (currentTime - lastDbUpdateTime > LOG_INTERVAL_MS) {
            News.info("执行输送线操作");
            lastDbUpdateTime = currentTime;
        }
        try {
            // 执行配置的操作序列
            for (CtuOperationConfig config : properties.getOperations()) {
                //log.info("执行输送线操作: {}", config.getType());
                operationExecutor.execute(config);
            }

            //log.info("输送线任务处理完成");
        } catch (Exception e) {
            log.error("输送线任务处理异常", e);
        }