#

Administrator

2026-04-27 007ee7bc1b63aa381b3a414952bbf41aeebed60e

 src/main/java/com/zy/core/utils/DualCrnOperateProcessUtils.java

@@ -751,6 +751,20 @@
    }

    public void submitDualCrnIoTasks(MainProcessLane lane, long minIntervalMs) {
        mainProcessTaskSubmitter.submitSerialTask(
                MainProcessLane.DUAL_CRN_SCAN,
                "submitDualCrnIoTasks",
                minIntervalMs,
                new Runnable() {
                    @Override
                    public void run() {
                        submitDualCrnIoTasksInternal(lane, minIntervalMs);
                    }
                }
        );
    }

    private void submitDualCrnIoTasksInternal(MainProcessLane lane, long minIntervalMs) {
        List<BasDualCrnp> basDualCrnps = basDualCrnpService.selectList(new EntityWrapper<>());
        for (final BasDualCrnp basDualCrnp : basDualCrnps) {
            Integer crnNo = basDualCrnp == null ? null : basDualCrnp.getCrnNo();
@@ -777,6 +791,20 @@
    }

    public void submitDualCrnIoExecuteFinishTasks(MainProcessLane lane, long minIntervalMs) {
        mainProcessTaskSubmitter.submitSerialTask(
                MainProcessLane.DUAL_CRN_SCAN,
                "submitDualCrnIoExecuteFinishTasks",
                minIntervalMs,
                new Runnable() {
                    @Override
                    public void run() {
                        submitDualCrnIoExecuteFinishTasksInternal(lane, minIntervalMs);
                    }
                }
        );
    }

    private void submitDualCrnIoExecuteFinishTasksInternal(MainProcessLane lane, long minIntervalMs) {
        List<BasDualCrnp> basDualCrnps = basDualCrnpService.selectList(new EntityWrapper<>());
        for (final BasDualCrnp basDualCrnp : basDualCrnps) {
            Integer crnNo = basDualCrnp == null ? null : basDualCrnp.getCrnNo();