#入库任务优化

Junjie

11 小时以前 61a792a8ba5532132bef32721f055c619057ab28

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

@@ -65,8 +65,8 @@
    public void run() {
        //检测入库站是否有任务生成，并启动入库
        checkInStationHasTask();
        //按站点拆分生成入库任务，避免单个站点阻塞整轮扫描
        submitGenerateStoreTasks();
        //请求生成入库任务，保留按站点 lane 串行提交
        generateStoreWrkFile();

        //堆垛机与输送站点都按单个任务提交到各自串行通道，逐个执行
        submitCrnTask("crnIoExecute", DISPATCH_INTERVAL_MS, crnOperateUtils::crnIoExecute);
@@ -173,6 +173,10 @@
        submitProcessTask(STATION_TASK_LANE, taskName, minIntervalMs, task);
    }

    private void generateStoreWrkFile() {
        submitGenerateStoreTasks();
    }

    private void submitGenerateStoreTasks() {
        List<BasDevp> basDevps = basDevpService.list(new QueryWrapper<>());
        for (BasDevp basDevp : basDevps) {