Junjie
8 小时以前 9a8571484d907978247aa6ac62f7ef6c4b49072b
#预调度堆垛机
1个文件已修改
10 ■■■■■ 已修改文件
src/main/java/com/zy/asrs/task/InboundCrnMoveDispatchScheduler.java 10 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/zy/asrs/task/InboundCrnMoveDispatchScheduler.java
@@ -180,6 +180,7 @@
        return pendingOutboundTasks.stream()
                .filter(this::isBatchTaskWithSeq)
                .filter(this::isCrnMoveBlockingOutboundTask)
                .anyMatch(task -> Objects.equals(activeBatch, task.getBatch()));
    }
@@ -206,6 +207,15 @@
                && wrkMast.getBatchSeq() != null;
    }
    private boolean isCrnMoveBlockingOutboundTask(WrkMast wrkMast) {
        if (wrkMast == null || wrkMast.getWrkSts() == null) {
            return false;
        }
        return Objects.equals(wrkMast.getWrkSts(), WrkStsType.NEW_OUTBOUND.sts)
                || Objects.equals(wrkMast.getWrkSts(), WrkStsType.OUTBOUND_RUN.sts)
                || Objects.equals(wrkMast.getWrkSts(), WrkStsType.OUTBOUND_MANUAL.sts);
    }
    private boolean isInboundCrnMoveDispatchWindow(WrkMast wrkMast, StationMoveSession session) {
        if (wrkMast == null || session == null || !session.isActive() || wrkMast.getStaNo() == null) {
            return false;