#

Administrator

2026-04-25 d300a0ef052579d73d27daa9cd1acf35fa00ed0a

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

@@ -852,6 +852,15 @@
    }

    public void submitCrnIoTasks(MainProcessLane lane, long minIntervalMs) {
        mainProcessTaskSubmitter.submitSerialTask(
                MainProcessLane.CRN_SCAN,
                "submitCrnIoTasks",
                minIntervalMs,
                () -> submitCrnIoTasksInternal(lane, minIntervalMs)
        );
    }

    private void submitCrnIoTasksInternal(MainProcessLane lane, long minIntervalMs) {
        List<BasCrnp> basCrnps = basCrnpService.selectList(new EntityWrapper<>());
        for (BasCrnp basCrnp : basCrnps) {
            if (basCrnp == null || basCrnp.getCrnNo() == null) {
@@ -873,6 +882,15 @@
    }

    public void submitCrnIoExecuteFinishTasks(MainProcessLane lane, long minIntervalMs) {
        mainProcessTaskSubmitter.submitSerialTask(
                MainProcessLane.CRN_SCAN,
                "submitCrnIoExecuteFinishTasks",
                minIntervalMs,
                () -> submitCrnIoExecuteFinishTasksInternal(lane, minIntervalMs)
        );
    }

    private void submitCrnIoExecuteFinishTasksInternal(MainProcessLane lane, long minIntervalMs) {
        List<BasCrnp> basCrnps = basCrnpService.selectList(new EntityWrapper<>());
        for (BasCrnp basCrnp : basCrnps) {
            if (basCrnp == null || basCrnp.getCrnNo() == null) {