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 | 71 ++++++++++++++++++++--------------- 1 files changed, 41 insertions(+), 30 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 8f77aea..2d5de68 100644 --- a/src/main/java/com/zy/asrs/service/impl/AgvWorkServiceImpl.java +++ b/src/main/java/com/zy/asrs/service/impl/AgvWorkServiceImpl.java @@ -352,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); } //鏇存柊鐩爣搴撲綅鐘舵�佸拰淇℃伅 @@ -396,7 +396,7 @@ updateAgvLocMast(agvLocMast,"R"); //淇敼绔欑偣鐘舵�� - updateAgvBasDevp(agvBasDevp,"S"); + updateAgvBasDevp(agvBasDevp,"S",(short)containerType,agvLocMast.getBarcode()); } @@ -492,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()); @@ -592,6 +593,32 @@ } } + 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 -> { + + 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); + } + + }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); agvWrkDetlLogService.save(wrkMast.getWrkNo()); @@ -601,33 +628,8 @@ throw new CoolException("鍒犻櫎澶辫触锛岃鑱旂郴绠$悊鍛�"); } - if(wrkMast.getIoType() == 1 || wrkMast.getIoType() == 10){ - return; - } - - //璁㈠崟鍥炴粴 - //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); - } - - }else { - OrderDetl orderDetl = orderDetlService.selectByOrderNoAndMatnr(agvWrkDetl.getOrderNo(),agvWrkDetl.getMatnr(),agvWrkDetl.getThreeCode(),agvWrkDetl.getDeadTime()); - orderDetl.setQty(orderDetl.getQty() - agvWrkDetl.getAnfme()); - orderDetlService.updateById(orderDetl); - } - } - }); + //璋冪敤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