From a1d108d95ac087c16557a11c58098cf76d967cb2 Mon Sep 17 00:00:00 2001 From: Junjie <xjj@123> Date: 星期六, 13 四月 2024 10:36:10 +0800 Subject: [PATCH] # --- zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/rcs/model/protocol/ShuttleProtocol.java | 51 +++++++++++++++++++++++++-------------------------- 1 files changed, 25 insertions(+), 26 deletions(-) diff --git a/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/rcs/model/protocol/ShuttleProtocol.java b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/rcs/model/protocol/ShuttleProtocol.java index d9a3147..c3d506c 100644 --- a/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/rcs/model/protocol/ShuttleProtocol.java +++ b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/rcs/model/protocol/ShuttleProtocol.java @@ -16,6 +16,8 @@ import lombok.Data; import lombok.extern.slf4j.Slf4j; +import java.util.HashMap; + /** * 鍥涘悜绌挎杞� */ @@ -27,7 +29,7 @@ /** * 鍥涘悜绌挎杞﹀彿 */ - private String shuttleNo; + private Integer shuttleNo; /** * 浠诲姟鍙� @@ -87,6 +89,11 @@ * 鏄惁椤跺崌 */ private Boolean hasLift; + + /** + * 鏄惁鏈夋墭鐩� + */ + private Boolean hasPallet; /** * 琛岄┒鏂瑰悜 @@ -161,6 +168,11 @@ private Device device; /** + * 鎵╁睍瀛楁 + */ + private Object extend; + + /** * 璁剧疆灏忚溅鐘舵�� */ public void setProtocolStatus(Integer status) { @@ -195,37 +207,23 @@ return ""; } - /** - * 鑾峰彇灏忚溅绌洪棽鐘舵�� - */ - public Boolean getIdle() { - if (this.deviceStatus == null) { - return false; - } - - ShuttleDeviceStatusService shuttleDeviceStatusService = SpringUtils.getBean(ShuttleDeviceStatusService.class); - ShuttleDeviceStatus status = shuttleDeviceStatusService.getOne(new LambdaQueryWrapper<ShuttleDeviceStatus>() - .eq(ShuttleDeviceStatus::getHostId, this.device.getHostId()) - .eq(ShuttleDeviceStatus::getDevicePlc, this.device.getDevicePlc()) - .eq(ShuttleDeviceStatus::getStatus, 1) - .eq(ShuttleDeviceStatus::getDeviceStatus, this.deviceStatus)); - if (status != null) { - if (status.getFlag() != null && status.getFlag().equals(String.valueOf(ShuttleDeviceStatusType.IDLE))) { - return true;//绌洪棽涓� - } - } - return false;//榛樿涓嶇┖闂� - } - public Integer getTaskNo() { RedisUtil redisUtil = SpringUtils.getBean(RedisUtil.class); if (null != redisUtil) { - Object o = redisUtil.get(DeviceRedisConstant.SHUTTLE_FLAG + this.taskNo); + Object o = redisUtil.get(DeviceRedisConstant.SHUTTLE_FLAG + this.shuttleNo); if (!Cools.isEmpty(o)) { this.taskNo = Integer.parseInt(String.valueOf(o)); } } return this.taskNo == null ? 0 : this.taskNo; + } + + public void setTaskNo(Integer taskNo) { + RedisUtil redisUtil = SpringUtils.getBean(RedisUtil.class); + if (null != redisUtil) { + redisUtil.set(DeviceRedisConstant.SHUTTLE_FLAG + this.shuttleNo, taskNo); + this.taskNo = taskNo; + } } //閫氳繃褰撳墠浜岀淮鐮佽幏鍙栧綋鍓嶅簱浣嶅彿 @@ -239,9 +237,10 @@ } //婧愬簱浣�(灏忚溅褰撳墠浣嶇疆) - Loc currentLoc = locService.getOne(new LambdaQueryWrapper<Loc>() + LambdaQueryWrapper<Loc> wrapper = new LambdaQueryWrapper<Loc>() .eq(Loc::getCode, this.currentCode) - .eq(Loc::getHostId, this.device.getHostId())); + .eq(Loc::getHostId, this.device.getHostId()); + Loc currentLoc = locService.getOne(wrapper); if (currentLoc == null) { return null; } -- Gitblit v1.9.1