#

Junjie

1 天以前 57273834cdf6dcac9b6dfe5e0fb15ee9b9f2bc2d

#

 src/main/java/com/zy/core/plugin/GslProcess.java

@@ -22,11 +22,9 @@
import com.zy.core.plugin.store.StoreInTaskContext;
import com.zy.core.plugin.store.StoreInTaskGenerationService;
import com.zy.core.plugin.store.StoreInTaskPolicy;
import com.zy.core.properties.SystemProperties;
import com.zy.core.thread.StationThread;
import com.zy.core.utils.CrnOperateProcessUtils;
import com.zy.core.utils.StationOperateProcessUtils;
import com.zy.system.entity.Config;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
@@ -53,39 +51,17 @@
    @Autowired
    private StationCommandDispatcher stationCommandDispatcher;

    private Thread crnRunThread = null;

    @Override
    public void run() {
        if (crnRunThread == null) {
            crnRunThread = new Thread(() -> {
                while (!Thread.currentThread().isInterrupted()) {
                    try {
                        //执行堆垛机任务
                        crnOperateUtils.crnIoExecute();
                        //堆垛机任务执行完成
                        crnOperateUtils.crnIoExecuteFinish();
                        // 间隔
                        Thread.sleep(50);
                    } catch (InterruptedException ie) {
                        Thread.currentThread().interrupt();
                        crnRunThread = null;
                        break;
                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                }
            });
            crnRunThread.setName("crnRunProcess");
            crnRunThread.setDaemon(true);
            crnRunThread.start();
        }

        //检测入库站是否有任务生成，并启动入库
        checkInStationHasTask();
        //请求生成入库任务
        generateStoreWrkFile();

        //执行堆垛机任务
        crnOperateUtils.crnIoExecute();
        //堆垛机任务执行完成
        crnOperateUtils.crnIoExecuteFinish();
        //执行输送站点入库任务
        stationOperateProcessUtils.stationInExecute();
        //执行输送站点出库任务