Merge branch 'master' of http://47.97.1.152:5880/r/zy-wcs-master

lsh

2026-04-21 720e0926fa1c94b952c26e111206c5d6e1ed5ba2

 src/main/java/com/zy/core/move/StationMoveSessionRegistry.java

@@ -4,6 +4,7 @@
import com.alibaba.fastjson.serializer.SerializerFeature;
import com.zy.common.utils.RedisUtil;
import com.zy.core.enums.RedisKeyType;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@@ -11,6 +12,7 @@
import java.util.List;
import java.util.Objects;

@Slf4j
@Component
public class StationMoveSessionRegistry {

@@ -65,11 +67,27 @@

    public synchronized boolean canDispatchRoute(Integer taskNo, Integer routeVersion) {
        StationMoveSession session = load(taskNo);
        if (session == null || routeVersion == null || !Objects.equals(routeVersion, session.getRouteVersion())) {
        if (session == null) {
            log.warn("canDispatchRoute rejected: session=null, taskNo={}, routeVersion={}", taskNo, routeVersion);
            return false;
        }
        return StationMoveSession.STATUS_WAITING.equals(session.getStatus())
        if (routeVersion == null) {
            log.warn("canDispatchRoute rejected: routeVersion=null, taskNo={}, session.routeVersion={}, session.status={}",
                    taskNo, session.getRouteVersion(), session.getStatus());
            return false;
        }
        if (!Objects.equals(routeVersion, session.getRouteVersion())) {
            log.warn("canDispatchRoute rejected: routeVersion mismatch, taskNo={}, cmdRouteVersion={}, sessionRouteVersion={}, session.status={}, session.cancelReason={}",
                    taskNo, routeVersion, session.getRouteVersion(), session.getStatus(), session.getCancelReason());
            return false;
        }
        boolean dispatchable = StationMoveSession.STATUS_WAITING.equals(session.getStatus())
                || StationMoveSession.STATUS_RUNNING.equals(session.getStatus());
        if (!dispatchable) {
            log.warn("canDispatchRoute rejected: status not dispatchable, taskNo={}, routeVersion={}, session.status={}, session.cancelReason={}",
                    taskNo, routeVersion, session.getStatus(), session.getCancelReason());
        }
        return dispatchable;
    }

    public synchronized boolean shouldSkipOutOrderDecision(Integer taskNo, Integer currentStationId) {