Junjie
2026-04-10 c18f8a5adb162791ef63f92ec457c8a34844e822
src/main/java/com/zy/core/plugin/GslProcess.java
@@ -130,6 +130,10 @@
                        && stationProtocol.getTaskNo() == 0
                        && stationProtocol.isEnableIn()
                ) {
                    if (stationProtocol.getIoMode() != 1) {
                        continue;//不属于入库模式
                    }
                    StationCommand command = stationThread.getCommand(StationCommandType.MOVE, commonService.getWorkNo(WrkIoType.ENABLE_IN.id), stationId, entity.getBarcodeStation().getStationId(), 0);
                    stationCommandDispatcher.dispatch(basDevp.getDevpNo(), command, "gsl-process", "enable-in");
                    if (entity.getBarcodeStation() != null && entity.getBarcodeStation().getStationId() != null) {
@@ -242,10 +246,7 @@
            return false;
        }
        Integer lockTaskNo = stationProtocol.getTaskNo();
        String lockKey = (lockTaskNo != null && lockTaskNo > 0)
                ? RedisKeyType.GENERATE_STATION_BACK_LIMIT.key + lockTaskNo
                : RedisKeyType.GENERATE_STATION_BACK_LIMIT.key + "station_" + stationProtocol.getStationId();
        String lockKey = RedisKeyType.GENERATE_STATION_BACK_LIMIT.key + stationProtocol.getStationId();
        Object lock = redisUtil.get(lockKey);
        if (lock != null) {
            return false;
@@ -260,8 +261,8 @@
            return false;
        }
        stationCommandDispatcher.dispatch(basDevp.getDevpNo(), command, "gsl-process", "station-back");
        News.taskInfo(stationProtocol.getTaskNo(), "扫码异常,已退回至{}", backStation.getStationId());
        redisUtil.set(lockKey, "lock", 10);
        News.info("{}扫码站异常,已退回至{},条码站状态:{}", stationProtocol.getTaskNo(), backStation.getStationId(), JSON.toJSONString(stationProtocol));
        redisUtil.set(lockKey, "lock", 15);
        return false;
    }