From 9360e541fb38bca1ae9d1f981eb3ada729671c37 Mon Sep 17 00:00:00 2001 From: zjj <3272660260@qq.com> Date: 星期一, 15 九月 2025 14:46:50 +0800 Subject: [PATCH] # --- src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java | 45 +++++++++++++++++++++++++++++---------------- 1 files changed, 29 insertions(+), 16 deletions(-) diff --git a/src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java index 14ec5a9..4babf62 100644 --- a/src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java +++ b/src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java @@ -205,8 +205,12 @@ if (jsonObject.getInteger("code").equals(0)) { success = true; // 鍏ュ簱鏆傚瓨+1 - basDevp.setInQty(basDevp.getInQty() + 1); - basDevpMapper.updateById(basDevp); + if (!inSta.equals("1000") && !inSta.equals("1035")){ + basDevp.setInQty(basDevp.getInQty() + 1); + basDevpMapper.updateById(basDevp); + log.info("鍏ュ簱鍛煎彨锛�"+basDevp.getDevNo()+"+1"); + } + } else { message = jsonObject.getString("message"); log.error("鍏ュ簱鍛煎彨agv澶辫触锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}", ApiInterfaceConstant.AGV_IP + ApiInterfaceConstant.AGV_CALL_IN_PATH, body, response); @@ -284,12 +288,12 @@ return success ? R.ok("瑙g粦鎴愬姛") : R.parse(message); } - public boolean sendAgvTask(String org,String tar){ + public boolean sendAgvTask(String org,String tar,String type){ ForwardAGVTaskParam forwardAGVTaskParam = new ForwardAGVTaskParam(); forwardAGVTaskParam.setReqCode(UUID.randomUUID().toString().replace("-", "")); forwardAGVTaskParam.setClientCode("IWMS"); - forwardAGVTaskParam.setTaskTyp("GT3"); + forwardAGVTaskParam.setTaskTyp(type); forwardAGVTaskParam.setCtnrTyp("2"); forwardAGVTaskParam.setPriority("1"); List<ForwardAGVTaskParam.PositionCodePaths> positionCodePathsList = new ArrayList<>(); @@ -1366,28 +1370,37 @@ } AgvSite orgAgvSite = agvSiteService.selectOne(new EntityWrapper<AgvSite>().eq("name", orgSite)); - AgvSite tarAgvSite = agvSiteService.selectOne(new EntityWrapper<AgvSite>().eq("name", tarSite)); - if (Cools.isEmpty(orgAgvSite) || Cools.isEmpty(tarAgvSite)) { +// AgvSite tarAgvSite = agvSiteService.selectOne(new EntityWrapper<AgvSite>().eq("name", tarSite)); + if (Cools.isEmpty(orgAgvSite)) { return R.error("绔欑偣鏁版嵁閿欒"); } //鏇存柊tar绔欑偣鐘舵�� - tarAgvSite.setWorkNo(orgAgvSite.getWorkNo()); - tarAgvSite.setStatus(2); - if (!agvSiteService.updateById(tarAgvSite)){ - throw new CoolException("鍙枡绔欐洿鏂板け璐�"); +// tarAgvSite.setWorkNo(orgAgvSite.getWorkNo()); +// tarAgvSite.setStatus(2); +// if (!agvSiteService.updateById(tarAgvSite)){ +// throw new CoolException("鍙枡绔欐洿鏂板け璐�"); +// } + WrkMast wrkMast = wrkMastService.selectById(orgAgvSite.getWorkNo()); + if (!Cools.isEmpty(wrkMast)){ + wrkMast.setWrkSts(5L); + wrkMastService.updateById(wrkMast); } + //鏇存柊org绔欑偣鐘舵�� - orgAgvSite.setStatus(2); + orgAgvSite.setStatus(0); + orgAgvSite.setWorkNo(null); if (!agvSiteService.updateById(orgAgvSite)){ throw new CoolException("婧愮珯鏇存柊澶辫触"); } - //鍛煎彨agv -// boolean success = sendAgvTask(orgSite, tarSite); -// if (!success){ -// throw new CoolException("鍛煎彨agv澶辫触"); -// } + + +// 鍛煎彨agv + boolean success = sendAgvTask(orgSite, tarSite,"GT6"); + if (!success){ + throw new CoolException("鍛煎彨agv澶辫触"); + } return R.ok(); } -- Gitblit v1.9.1