From 0c4b48edb964d47a6db0e2f6a6073fade51c3c4d Mon Sep 17 00:00:00 2001 From: whycq <10027870+whycq@user.noreply.gitee.com> Date: 星期四, 09 十一月 2023 09:27:54 +0800 Subject: [PATCH] # 显示器 --- src/main/java/com/zy/common/utils/ShuttleDispatchUtils.java | 67 ++++++++++++++++++++++++++++++--- 1 files changed, 60 insertions(+), 7 deletions(-) diff --git a/src/main/java/com/zy/common/utils/ShuttleDispatchUtils.java b/src/main/java/com/zy/common/utils/ShuttleDispatchUtils.java index 7396b7e..77e40a2 100644 --- a/src/main/java/com/zy/common/utils/ShuttleDispatchUtils.java +++ b/src/main/java/com/zy/common/utils/ShuttleDispatchUtils.java @@ -1,14 +1,17 @@ package com.zy.common.utils; +import com.alibaba.fastjson.JSON; import com.baomidou.mybatisplus.mapper.EntityWrapper; import com.core.common.SpringUtils; import com.core.exception.CoolException; import com.zy.asrs.entity.BasDevp; +import com.zy.asrs.entity.BasShuttle; import com.zy.asrs.entity.WrkCharge; import com.zy.asrs.entity.WrkMast; import com.zy.asrs.mapper.WrkChargeMapper; import com.zy.asrs.mapper.WrkMastMapper; import com.zy.asrs.service.BasDevpService; +import com.zy.asrs.service.BasShuttleService; import com.zy.asrs.service.WrkMastService; import com.zy.asrs.utils.Utils; import com.zy.common.model.NavigateNode; @@ -66,6 +69,18 @@ * 璋冨害杞﹁締 */ public boolean dispatchShuttle(Integer wrkNo, String locNo) { + //妫�娴嬬洰鏍囧簱浣嶇粍鏄惁瀛樺湪灏忚溅锛屽瀛樺湪灏忚溅鍒欑洿鎺ユ寚瀹氳杞� + WrkMast wrkMast = wrkMastMapper.selectByWorkNo(wrkNo); + if (wrkMast != null) { + String targetLocNo = wrkMast.getIoType() < 100 ? wrkMast.getLocNo() : wrkMast.getSourceLocNo(); + List<String> groupLoc = Utils.getGroupLoc(targetLocNo); + Integer groupShuttleNo = Utils.checkGroupLocHasShuttle(groupLoc); + if (groupShuttleNo != null) { + //瀛樺湪灏忚溅锛岀洿鎺ヨ皟搴﹁杞� + return shuttleMoveGenerate(wrkNo, locNo, groupShuttleNo); + } + } + ArrayList<NyShuttleThread> sameLev = new ArrayList<>();//鐩稿悓妤煎眰鐨勭┛姊溅 ArrayList<NyShuttleThread> diffLev = new ArrayList<>();//涓嶅悓妤煎眰鐨勭┛姊溅 @@ -115,7 +130,7 @@ //褰撳墠绌挎杞﹀簱浣嶅彿 String currentLocNo = shuttleThread.getShuttleProtocol().getCurrentLocNo(); //褰撳墠绌挎杞︾嚎绋嬪埌鐩爣鍦扮偣璺濈 - List<NavigateNode> currentShuttlePath = NavigateUtils.calc(currentLocNo, locNo, NavigationMapType.NORMAL.id, Utils.getShuttlePoints(shuttleThread.getSlave().getId(), Utils.getLev(currentLocNo)));//鎼滅储绌洪棽绌挎杞︼紝浣跨敤姝e父閫氶亾鍦板浘 + List<NavigateNode> currentShuttlePath = NavigateUtils.calc(currentLocNo, locNo, NavigationMapType.NORMAL.id, Utils.getShuttlePoints(shuttleThread.getSlave().getId(), Utils.getLev(currentLocNo)), null);//鎼滅储绌洪棽绌挎杞︼紝浣跨敤姝e父閫氶亾鍦板浘 if (currentShuttlePath == null) { continue; } @@ -134,7 +149,8 @@ WrkMast wrkMast1 = wrkMastMapper.selectByWorkNo(wrkNo); if (wrkMast1 != null) { - int lev = Utils.getLev(wrkMast1.getLocNo());//鐩爣妤煎眰 + String targetLoc = wrkMast1.getIoType() < 100 ? wrkMast1.getLocNo() : wrkMast1.getSourceLocNo(); + int lev = Utils.getLev(targetLoc);//鐩爣妤煎眰 //妫�娴嬬洰鏍囨ゼ灞傝溅鏁伴噺鏄惁灏忎簬鍏佽鐨勬渶澶ф暟閲� boolean checkDispatchMaxNum = checkDispatchMaxNum(lev); @@ -232,7 +248,7 @@ if (Utils.getLev(locNo) != shuttleProtocol.getPoint().getZ()) { //鐩爣搴撲綅鍜屽皬杞﹀簱浣嶅浜庝笉鍚屼竴妤煎眰锛岄渶瑕侀�氳繃鎻愬崌鏈鸿皟搴� //鑾峰彇绌挎杞︽渶杩戜笖绌洪棽鐨勬彁鍗囨満杈撻�佺珯鐐� - LiftStaProtocol liftSta = this.getRecentLiftSta(shuttleNo); + LiftStaProtocol liftSta = this.getRecentLiftSta(shuttleNo, Utils.getLev(locNo)); if (liftSta == null) { return false;//娌℃湁鍙敤涓旂┖闂茬殑杈撻�佺珯鐐� } @@ -281,6 +297,7 @@ * true: 灏忎簬鏈�澶ф暟閲� false: 澶т簬鎴栫瓑浜庢渶澶ф暟閲� */ public boolean checkDispatchMaxNum(Integer lev) { + BasShuttleService basShuttleService = SpringUtils.getBean(BasShuttleService.class); ConfigService configService = SpringUtils.getBean(ConfigService.class); EntityWrapper<Config> wrapper = new EntityWrapper<>(); wrapper.eq("code", "dispatchShuttleMaxNum"); @@ -298,14 +315,40 @@ continue; } + NyShuttleProtocol.NyShuttlePointClass point = null; if (shuttleProtocol.getPoint() == null) { - continue; + BasShuttle basShuttle = basShuttleService.selectById(shuttle.getId());//灏忚溅濡傛灉娌℃湁鏁版嵁锛屼粠鏁版嵁搴撳彇鏁版嵁 + if (basShuttle == null || basShuttle.getPoint() == null) { + continue; + } + point = JSON.parseObject(basShuttle.getPoint(), NyShuttleProtocol.NyShuttlePointClass.class); + }else { + point = shuttleProtocol.getPoint(); } - if (shuttleProtocol.getPoint().getZ().equals(lev)) { + if (point.getZ().equals(lev)) { levCount++;//鐩爣妤煎眰鏈夎溅锛屾暟閲忓鍔� } } + + //鎼滅储鏄惁瀛樺湪鍓嶅線鐩爣妤煎眰鐨勫皬杞︾Щ鍔ㄥ伐浣滄。 + for (WrkMast wrkMast : wrkMastMapper.selectShuttleMoveWrk()) { + if (wrkMast.getSourceLocNo() == null || wrkMast.getLocNo() == null) { + continue; + } + + int sourceLev = Utils.getLev(wrkMast.getSourceLocNo());//宸ヤ綔妗f簮妤煎眰 + int targetLev = Utils.getLev(wrkMast.getLocNo());//宸ヤ綔妗g洰鏍囨ゼ灞� + if (sourceLev == lev) { + continue;//宸ヤ綔妗fゼ灞傚拰鐩爣妤煎眰鐩稿悓锛岃烦杩� + } + + if (targetLev == lev) { + levCount++;//宸ヤ綔妗g洰鏍囨ゼ灞傚拰瀹為檯妤煎眰鐩稿悓锛屾暟閲忓鍔� + continue; + } + } + return levCount < Integer.parseInt(config.getValue()); } @@ -313,7 +356,7 @@ /** * 鑾峰彇绌挎杞︽渶杩戜笖绌洪棽鐨勬彁鍗囨満杈撻�佺珯鐐� */ - public LiftStaProtocol getRecentLiftSta(Integer shuttleNo) { + public LiftStaProtocol getRecentLiftSta(Integer shuttleNo, Integer targetLev) { //鑾峰彇鍥涘悜绌挎杞︾嚎绋� NyShuttleThread shuttleThread = (NyShuttleThread) SlaveConnection.get(SlaveType.Shuttle, shuttleNo); if (shuttleThread == null) { @@ -345,6 +388,16 @@ continue; } + //鍒ゆ柇鐩爣妤煎眰绔欑偣鏄惁鏃犳墭鐩� + LiftStaProtocol targetLiftStaProtocol = NyLiftUtils.getLiftStaByLev(slave.getId(), targetLev); + if (targetLiftStaProtocol == null) { + continue; + } + + if (targetLiftStaProtocol.getHasTray()) { + continue;//鏈夋墭鐩樿烦杩� + } + list.add(liftStaProtocol); } @@ -361,7 +414,7 @@ String locNo = liftStaProtocol.getLocNo();//绔欑偣搴撲綅鍙� //褰撳墠绌挎杞︾嚎绋嬪埌鐩爣鍦扮偣璺濈 - List<NavigateNode> currentShuttlePath = NavigateUtils.calc(currentLocNo, locNo, NavigationMapType.NORMAL.id, Utils.getShuttlePoints(shuttleNo, Utils.getLev(currentLocNo)));//浣跨敤姝e父閫氶亾鍦板浘 + List<NavigateNode> currentShuttlePath = NavigateUtils.calc(currentLocNo, locNo, NavigationMapType.NORMAL.id, Utils.getShuttlePoints(shuttleNo, Utils.getLev(currentLocNo)), null);//浣跨敤姝e父閫氶亾鍦板浘 if (currentShuttlePath == null) { continue; } -- Gitblit v1.9.1