From 0d04bc5d8080b82338302fba0a59fccff2eaedfc Mon Sep 17 00:00:00 2001 From: Junjie <fallin.jie@qq.com> Date: 星期日, 06 七月 2025 11:28:29 +0800 Subject: [PATCH] # --- zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/kernel/command/ShuttleCommandService.java | 26 +++++++++++++++++++++++++- 1 files changed, 25 insertions(+), 1 deletions(-) diff --git a/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/kernel/command/ShuttleCommandService.java b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/kernel/command/ShuttleCommandService.java index 8fafb60..c831984 100644 --- a/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/kernel/command/ShuttleCommandService.java +++ b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/kernel/command/ShuttleCommandService.java @@ -1,5 +1,6 @@ package com.zy.asrs.wcs.core.kernel.command; +import com.alibaba.fastjson.JSON; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.zy.asrs.framework.common.Cools; import com.zy.asrs.framework.exception.CoolException; @@ -18,6 +19,7 @@ import com.zy.asrs.wcs.rcs.News; import com.zy.asrs.wcs.rcs.cache.SlaveConnection; import com.zy.asrs.wcs.core.entity.Motion; +import com.zy.asrs.wcs.rcs.entity.Device; import com.zy.asrs.wcs.rcs.model.enums.ShuttleProtocolStatusType; import com.zy.asrs.wcs.rcs.model.enums.SlaveType; import com.zy.asrs.wcs.rcs.model.protocol.LiftProtocol; @@ -58,6 +60,8 @@ private LiftAction liftAction; @Autowired private LiftDispatcher liftDispatcher; + @Autowired + private ShuttleDispatcher shuttleDispatcher; // 璁$畻 public Boolean accept(Motion motion) { @@ -70,7 +74,7 @@ if (null == shuttleProtocol) { return false; } - + Device shuttleDevice = shuttleThread.getDevice(); if (!shuttleThread.isIdle(new ExecuteSupport() { @Override public Boolean judgement() { @@ -222,6 +226,21 @@ case SHUTTLE_UPDATE_LOCATION://灏忚溅鍧愭爣鏇存柊 shuttleTaskModeType = ShuttleTaskModeType.SHUTTLE_UPDATE_LOCATION; shuttleCommands.add(shuttleThread.getUpdateLocationCommand(motion.getTaskNo(), motion.getTarget())); + break; + case SHUTTLE_MOVE_STANDBY://绌挎杞︾Щ鍔ㄥ埌寰呮満浣� + shuttleTaskModeType = ShuttleTaskModeType.SHUTTLE_MOVE_LOC_NO; + + //鑾峰彇鍏ㄩ儴寰呮満浣� + List<String> standbyLocs = JSON.parseArray(motion.getTemp(), String.class); + //鑾峰彇鍙敤寰呮満浣� + String shuttleFromLiftStandbyLoc = shuttleDispatcher.searchAvailableLocNo(Integer.valueOf(shuttleDevice.getDeviceNo()), shuttleDevice.getHostId(), shuttleThread.getStatus().getCurrentLocNo(), standbyLocs); + shuttleCommands = this.shuttleAssignCommand(motion.getOrigin(), shuttleFromLiftStandbyLoc, NavigationMapType.NORMAL.id, assignCommand, shuttleThread); + + //鏇存柊鍔ㄤ綔鍙敤寰呮満浣� + motion.setTarget(shuttleFromLiftStandbyLoc); + motion.setUpdateTime(new Date()); + motionService.updateById(motion); + break; default: throw new CoolException(motion.getMotionCtgEl() + "娌℃湁鎸囧畾浠诲姟浣滀笟娴佺▼锛侊紒锛�"); @@ -396,6 +415,11 @@ return false; } break; + case SHUTTLE_MOVE_STANDBY://绌挎杞︾Щ鍔ㄥ埌寰呮満浣� + if (!shuttleProtocol.getCurrentLocNo().equals(motion.getTarget())) { + return false; + } + break; default: break; } -- Gitblit v1.9.1