From 071f3021f4ba872c572a4c59dd8ce9ea2d3c9106 Mon Sep 17 00:00:00 2001 From: whycq <913841844@qq.com> Date: 星期二, 23 四月 2024 18:50:37 +0800 Subject: [PATCH] # --- src/main/java/com/zy/asrs/service/impl/AgvWorkServiceImpl.java | 79 ++++++++++++++++++++++----------------- 1 files changed, 45 insertions(+), 34 deletions(-) diff --git a/src/main/java/com/zy/asrs/service/impl/AgvWorkServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/AgvWorkServiceImpl.java index f49c996..2d5de68 100644 --- a/src/main/java/com/zy/asrs/service/impl/AgvWorkServiceImpl.java +++ b/src/main/java/com/zy/asrs/service/impl/AgvWorkServiceImpl.java @@ -316,27 +316,19 @@ 鍏ュ簱 */ @Transactional - public String emptyPlateIn(String station,String containerCode,Short containerType, Long userId) { + public String emptyPlateIn(String station,String containerCode,Short containerType, Long userId, boolean emptyAutoIn) { Date now = new Date(); - // 婧愮珯鐐圭姸鎬佹娴� - //AgvBasDevp agvBasDevp = agvBasDevpService.selectByDevNo(station); + AgvBasDevp agvBasDevp = agvBasDevpService.selectById(station); - //鍒濆瀹氫箟涓虹┖鏉垮叆搴撶被鍨� - int ioType = 10; - -// if(Cools.isEmpty(agvBasDevp.getBarcode())){ -// agvBasDevp.setBarcode(containerCode); -// } - - if(!Cools.eq(agvBasDevp.getBarcode(),containerCode) && !agvBasDevp.getLocSts().equals("O")){ + if(!Cools.eq(agvBasDevp.getBarcode(),containerCode) && !agvBasDevp.getLocSts().equals("O") && !emptyAutoIn){ throw new CoolException("褰撳墠宸ヤ綔浣嶇姸鎬佷负" + agvBasDevp.getLocSts()+",鏃犳硶杩涜绌烘澘鍏ュ簱"); } //鏌ヨ宸ヤ綔妗� AgvWrkMast agvWrkMast = agvWrkMastService.selectByContainerCode(containerCode); - if(!Cools.isEmpty(agvWrkMast)){ + if(!Cools.isEmpty(agvWrkMast) && !emptyAutoIn){ throw new CoolException("褰撳墠瀹瑰櫒宸叉湁鍏ュ簱浠诲姟锛屾棤娉曡繘琛屽叆搴�"); } @@ -360,12 +352,12 @@ //淇敼鍏ュ簱閫氱煡妗g姸鎬� agvWaitPakinService.updateIoStatus(containerCode,"Y"); //鏇存柊婧愮珯鐐圭姸鎬� - updateAgvBasDevp(agvBasDevp,"R"); + updateAgvBasDevp(agvBasDevp,"R",containerType); }else { // 鐢熸垚宸ヤ綔妗� 10.绌烘澘鍏ュ簱 createWrkMast(10,201L,agvBasDevp.getDevNo(),agvLocMast.getLocNo(),containerCode,now,userId,containerType); //鏇存柊婧愮珯鐐圭姸鎬� - updateAgvBasDevp(agvBasDevp,"R",containerType); + updateAgvBasDevp(agvBasDevp,"R",containerType,containerCode); } //鏇存柊鐩爣搴撲綅鐘舵�佸拰淇℃伅 @@ -388,6 +380,12 @@ //瀵绘壘鐩稿簲绫诲瀷鐨勭┖鎵樼洏 AgvLocMast agvLocMast = agvLocMastService.selectEmptyZpallet(containerType); + if(containerType == 0){ + //绌烘澘鑷姩鍑哄簱锛屾牴鎹珯鐐圭被鍨嬮�夋嫨 + agvLocMastService.selectEmptyZpalletByLocType1(agvBasDevp.getLocType1()); + + } + if (Cools.isEmpty(agvLocMast)) { throw new CoolException("鏆傛棤褰撳墠鍑哄簱绔欑偣绫诲瀷鐨勭┖鎵樼洏锛�"); } @@ -398,7 +396,7 @@ updateAgvLocMast(agvLocMast,"R"); //淇敼绔欑偣鐘舵�� - updateAgvBasDevp(agvBasDevp,"S"); + updateAgvBasDevp(agvBasDevp,"S",(short)containerType,agvLocMast.getBarcode()); } @@ -494,6 +492,7 @@ locDetl.setModiTime(now); locDetl.setAppeUser(userId); locDetl.setAppeTime(now); + locDetl.setOrderNo(adjust.getOrderNo()); locDetl.setThreeCode(adjust.getThreeCode()); locDetl.setDeadTime(adjust.getDeadTime()); locDetl.setSuppCode(adjust.getSuppCode()); @@ -594,31 +593,31 @@ } } + if(wrkMast.getIoType() != 1 && wrkMast.getIoType() != 10){ + //璁㈠崟鍥炴粴 + //List<AgvWrkDetl> agvWrkDetlList = agvWrkDetlService.selectByWrkNo(wrkMast.getWrkNo()); + List<AgvWrkDetl> agvWrkDetlList1 = agvWrkDetlService.selectList(new EntityWrapper<AgvWrkDetl>().eq("wrk_no", wrkMast.getWrkNo())); + agvWrkDetlList1.forEach(agvWrkDetl -> { - //璁㈠崟鍥炴粴 - //List<AgvWrkDetl> agvWrkDetlList = agvWrkDetlService.selectByWrkNo(wrkMast.getWrkNo()); - List<AgvWrkDetl> agvWrkDetlList1 = agvWrkDetlService.selectList(new EntityWrapper<AgvWrkDetl>().eq("wrk_no", wrkMast.getWrkNo())); - agvWrkDetlList1.forEach(agvWrkDetl -> { + if(!Cools.isEmpty(agvWrkDetl.getOrderNo())){ + String orderNo = agvWrkDetl.getOrderNo(); + if(orderNo.contains("{")){ + JSONArray orderArray = JSON.parseArray(orderNo); + for (Object o : orderArray){ + JSONObject jsonobject = (JSONObject) o; + OrderDetl orderDetl = orderDetlService.selectByOrderNoAndMatnr(jsonobject.get("orderNo").toString(),agvWrkDetl.getMatnr(),agvWrkDetl.getThreeCode(),agvWrkDetl.getDeadTime()); + orderDetl.setQty(orderDetl.getQty() - agvWrkDetl.getAnfme()); + orderDetlService.updateById(orderDetl); + } - if(!Cools.isEmpty(agvWrkDetl.getOrderNo())){ - String orderNo = agvWrkDetl.getOrderNo(); - if(orderNo.contains("{")){ - JSONArray orderArray = JSON.parseArray(orderNo); - for (Object o : orderArray){ - JSONObject jsonobject = (JSONObject) o; - OrderDetl orderDetl = orderDetlService.selectByOrderNoAndMatnr(jsonobject.get("orderNo").toString(),agvWrkDetl.getMatnr(),agvWrkDetl.getThreeCode(),agvWrkDetl.getDeadTime()); + }else { + OrderDetl orderDetl = orderDetlService.selectByOrderNoAndMatnr(agvWrkDetl.getOrderNo(),agvWrkDetl.getMatnr(),agvWrkDetl.getThreeCode(),agvWrkDetl.getDeadTime()); orderDetl.setQty(orderDetl.getQty() - agvWrkDetl.getAnfme()); orderDetlService.updateById(orderDetl); } - - }else { - OrderDetl orderDetl = orderDetlService.selectByOrderNoAndMatnr(agvWrkDetl.getOrderNo(),agvWrkDetl.getMatnr(),agvWrkDetl.getThreeCode(),agvWrkDetl.getDeadTime()); - orderDetl.setQty(orderDetl.getQty() - agvWrkDetl.getAnfme()); - orderDetlService.updateById(orderDetl); } - } - }); - + }); + } //淇濆瓨宸ヤ綔妗d互鍙婃槑缁� agvWrkMastLogService.save(wrkMast); @@ -628,6 +627,9 @@ if(!agvWrkMastService.deleteByWrkNo(wrkMast.getWrkNo()) || !agvWrkDetlService.deleteByWrkNo(wrkMast.getWrkNo())){ throw new CoolException("鍒犻櫎澶辫触锛岃鑱旂郴绠$悊鍛�"); } + + //璋冪敤agv鍙栨秷浠诲姟鎺ュ彛 + agvWrkMastService.callCancelTask(wrkMast.getWrkNo()); } @@ -669,6 +671,15 @@ } } + private void updateAgvBasDevp(AgvBasDevp agvBasDevp, String locSts, Short continerType, String containerCode){ + if(!Cools.isEmpty(agvBasDevp)){ + agvBasDevp.setLocSts(locSts); + agvBasDevp.setLocType2(continerType); + agvBasDevp.setBarcode(containerCode); + agvBasDevpService.updateById(agvBasDevp); + } + } + /* 鐢熸垚宸ヤ綔妗f槑缁� */ -- Gitblit v1.9.1