From 948571f0925c69edddf387a0edeb203711e76ac7 Mon Sep 17 00:00:00 2001 From: whycq <10027870+whycq@user.noreply.gitee.com> Date: 星期六, 25 五月 2024 08:20:34 +0800 Subject: [PATCH] # --- src/main/java/com/zy/asrs/controller/AgvBasDevpController.java | 123 +++++++++++++++-------------------------- 1 files changed, 45 insertions(+), 78 deletions(-) diff --git a/src/main/java/com/zy/asrs/controller/AgvBasDevpController.java b/src/main/java/com/zy/asrs/controller/AgvBasDevpController.java index 0667c0f..2dd57fc 100644 --- a/src/main/java/com/zy/asrs/controller/AgvBasDevpController.java +++ b/src/main/java/com/zy/asrs/controller/AgvBasDevpController.java @@ -19,7 +19,6 @@ import org.springframework.web.bind.annotation.*; import java.util.*; -import java.util.stream.Collectors; @RestController @RequestMapping("/agv") @@ -35,6 +34,8 @@ AgvWaitPakinService agvWaitPakinService; @Autowired AgvWorkService agvWorkService; + @Autowired + AgvLocDetlService agvLocDetlService; @RequestMapping(value = "/basDevp/list/auth") @ManagerAuth @@ -178,6 +179,15 @@ AgvWrkMast agvWrkMast = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>() .eq("loc_no", agvBasDevp.getDevNo()) .or().eq("source_loc_no",agvBasDevp.getDevNo())); + if (Cools.isEmpty(agvWrkMast)) { + Page<AgvLocDetl> agvLocDetlPage = agvLocDetlService.selectPage(new Page<>(curr, limit), new EntityWrapper<AgvLocDetl>() + .eq("supp_code", agvBasDevp.getBarcode())); + if (agvLocDetlPage.getRecords().size() > 0) { + return R.ok(agvLocDetlPage); + } else { + return R.error("褰撳墠璐ф灦鐮佸紓甯革紒"); + } + } Page<AgvWrkDetl> agvWrkDetlPage = agvWrkDetlService.selectPage(new Page<>(curr, limit), new EntityWrapper<AgvWrkDetl>() .eq("wrk_no", agvWrkMast.getWrkNo())); @@ -211,100 +221,57 @@ 浠诲姟瀹屾垚 */ @RequestMapping(value = "/basDevp/visualized/container/moveOut") + @ManagerAuth(memo = "纭鍑哄簱") public R visualiZedContainerMoveOut(@RequestBody Map<String,Object> map) { - List<String> devNos = new ArrayList<>(); - List<AgvWrkMast> agvWrkMastList = new ArrayList<>(); - try { - devNos = (List<String>) map.get("devNo"); - agvWrkMastList = devNos.stream().map(devNo -> { - AgvWrkMast agvWrkMast = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>().eq("loc_no", devNo).eq("wrk_sts",205L)); - if(agvWrkMast.getIoType() != 101 && agvWrkMast.getIoType() != 110){ - throw new CoolException("宸ヤ綔鍙蜂负" + agvWrkMast.getWrkNo() + "绫诲瀷涓嶄负101.鍑哄簱锛屾棤娉曟墽琛屽鍣ㄧ鍦轰换鍔★紝璇烽噸鏂伴�夋嫨绔欑偣銆�"); - } - return agvWrkMast; - }).collect(Collectors.toList()); - }catch (Exception e){ - String devNo = map.get("devNo").toString(); - AgvWrkMast agvWrkMast = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>().eq("loc_no", devNo)); - if(agvWrkMast.getIoType() != 101 && agvWrkMast.getIoType() != 110){ - throw new CoolException("宸ヤ綔鍙蜂负" + agvWrkMast.getWrkNo() + "绫诲瀷涓嶄负101.鍑哄簱锛屾棤娉曟墽琛屽鍣ㄧ鍦轰换鍔★紝璇烽噸鏂伴�夋嫨绔欑偣銆�"); - } - agvWrkMastList.add(agvWrkMast); + String barcode = map.get("barcode").toString(); + AgvWrkMast agvWrkMast = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>().eq("barcode", barcode).eq("wrk_sts",205L)); + if(agvWrkMast.getIoType() != 101 && agvWrkMast.getIoType() != 110){ + throw new CoolException("宸ヤ綔鍙蜂负" + agvWrkMast.getWrkNo() + "绫诲瀷涓嶄负101.鍑哄簱锛屾棤娉曟墽琛岃揣鏋剁鍦轰换鍔★紝璇烽噸鏂伴�夋嫨绔欑偣銆�"); } -// List<AgvWrkMast> agvWrkMastList = devNos.stream().map(devNo -> { -// AgvWrkMast agvWrkMast = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>().eq("loc_no", devNo)); -// if(agvWrkMast.getIoType() != 101 && agvWrkMast.getIoType() != 110){ -// throw new CoolException("宸ヤ綔鍙蜂负" + agvWrkMast.getWrkNo() + "绫诲瀷涓嶄负101.鍑哄簱锛屾棤娉曟墽琛屽鍣ㄧ鍦轰换鍔★紝璇烽噸鏂伴�夋嫨绔欑偣銆�"); -// } -// return agvWrkMast; -// }).collect(Collectors.toList()); + agvWrkMast.setWrkSts(206L); + agvWrkMastService.updateById(agvWrkMast); - agvWrkMastList.forEach(agvWrkMast -> { - agvWrkMast.setWrkSts(206L); - agvWrkMastService.updateById(agvWrkMast); - }); + return R.ok("璐ф灦绂诲満鎴愬姛"); + } -// try { -// int code = agvWrkMastService.containerMoveOut(agvWrkMastList); -// if(code == 0){ -// //灏嗗伐浣滃厷鐘舵�佹敼涓哄鍣ㄧ鍦� -// agvWrkMastList.forEach(agvWrkMast -> { -// agvWrkMast.setWrkSts(206L); -// agvWrkMastService.updateById(agvWrkMast); -// }); -// //淇敼绔欑偣鐘舵�� -//// devNos.forEach(devNo -> { -//// AgvBasDevp agvBasDevp = agvBasDevpService.selectById(devNo); -//// agvBasDevp.setBarcode(""); -//// agvBasDevp.setLocSts("O"); -//// agvBasDevpService.updateById(agvBasDevp); -//// }); -// } -// } catch (IOException e) { -// e.printStackTrace(); -// return R.error("瀹瑰櫒绂诲満澶辫触"); -// } + /* + 浠诲姟瀹屾垚 + */ + @RequestMapping(value = "/basDevp/visualized/container/moveOut2") + @ManagerAuth(memo = "纭鍑哄簱2") + public R visualiZedContainerMoveOut2(@RequestBody Map<String,Object> map) { - return R.ok("瀹瑰櫒绂诲満鎴愬姛"); + String barcode = map.get("barcode").toString(); + AgvWrkMast agvWrkMast = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>().eq("barcode", barcode).eq("wrk_sts",205L)); + if(agvWrkMast.getIoType() != 101 && agvWrkMast.getIoType() != 110){ + throw new CoolException("宸ヤ綔鍙蜂负" + agvWrkMast.getWrkNo() + "绫诲瀷涓嶄负101.鍑哄簱锛屾棤娉曟墽琛岃揣鏋剁鍦轰换鍔★紝璇烽噸鏂伴�夋嫨绔欑偣銆�"); + } + + agvWrkMast.setWrkSts(208L); + agvWrkMastService.updateById(agvWrkMast); + + return R.ok("璐ф灦绂诲満鎴愬姛"); } /* 鎷f枡/鐩樼偣鍏ュ簱 */ @RequestMapping(value = "/basDevp/visualized/container/pickIn") + @ManagerAuth(memo = "鍐嶆鎷f枡") public R visualiZedPickIn(@RequestBody Map<String,Object> map){ - List<String> devNos = new ArrayList<>(); List<AgvWrkMast> agvWrkMastList = new ArrayList<>(); - try { - devNos = (List<String>) map.get("devNo"); - agvWrkMastList = devNos.stream().map(devNo -> { - AgvWrkMast agvWrkMast = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>().eq("loc_no", devNo).eq("wrk_sts",205L)); - if(agvWrkMast.getIoType() == 101){ - throw new CoolException("宸ヤ綔鍙蜂负" + agvWrkMast.getWrkNo() + "绫诲瀷涓�101.鍑哄簱锛屾棤娉曟墽琛屾嫞鏂欏叆搴撲换鍔★紝璇烽噸鏂伴�夋嫨绔欑偣銆�"); - } - return agvWrkMast; - }).collect(Collectors.toList()); - }catch (Exception e){ - String devNo = map.get("devNo").toString(); - AgvWrkMast agvWrkMast = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>().eq("loc_no", devNo).eq("wrk_sts",205L)); - if (agvWrkMast != null) { - if(agvWrkMast.getIoType() == 101){ - throw new CoolException("宸ヤ綔鍙蜂负" + agvWrkMast.getWrkNo() + "绫诲瀷涓�101.鍑哄簱锛屾棤娉曟墽琛屾嫞鏂欏叆搴撲换鍔★紝璇烽噸鏂伴�夋嫨绔欑偣銆�"); - } - agvWrkMastList.add(agvWrkMast); + String devNo = map.get("devNo").toString(); + String barcode = map.get("barcode").toString(); + AgvWrkMast agvWrkMast = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>().eq("barcode", barcode).eq("wrk_sts",205L)); + if (agvWrkMast != null) { + if(agvWrkMast.getIoType() == 101){ + throw new CoolException("宸ヤ綔鍙蜂负" + agvWrkMast.getWrkNo() + "绫诲瀷涓�101.鍑哄簱锛屾棤娉曟墽琛屾嫞鏂欏叆搴撲换鍔★紝璇烽噸鏂伴�夋嫨绔欑偣銆�"); } + agvWrkMast.setLocNo(devNo); + agvWrkMastList.add(agvWrkMast); } - -// List<String> devNos = (List<String>) map.get("devNo"); -// List<AgvWrkMast> agvWrkMastList = devNos.stream().map(devNo -> { -// AgvWrkMast agvWrkMast = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>().eq("loc_no", devNo)); -// if(agvWrkMast.getIoType() == 101){ -// throw new CoolException("宸ヤ綔鍙蜂负" + agvWrkMast.getWrkNo() + "绫诲瀷涓�101.鍑哄簱锛屾棤娉曟墽琛屾嫞鏂欏叆搴撲换鍔★紝璇烽噸鏂伴�夋嫨绔欑偣銆�"); -// } -// return agvWrkMast; -// }).collect(Collectors.toList()); agvWorkService.pickIn(agvWrkMastList); -- Gitblit v1.9.1