From f1a1915b575c435f7172fdb59d48e13726ff4ff0 Mon Sep 17 00:00:00 2001 From: whycq <913841844@qq.com> Date: 星期三, 29 五月 2024 16:29:07 +0800 Subject: [PATCH] # 调拨单同步锁 --- src/main/java/com/zy/asrs/controller/AgvMobileController.java | 13 +++++++++++++ 1 files changed, 13 insertions(+), 0 deletions(-) diff --git a/src/main/java/com/zy/asrs/controller/AgvMobileController.java b/src/main/java/com/zy/asrs/controller/AgvMobileController.java index 3d35a72..5f00b40 100644 --- a/src/main/java/com/zy/asrs/controller/AgvMobileController.java +++ b/src/main/java/com/zy/asrs/controller/AgvMobileController.java @@ -219,6 +219,7 @@ */ @PostMapping("/check/detl/v1") @ManagerAuth(memo = "搴撳瓨鐩樼偣") + @Synchronized public R checkLocDetl(@RequestBody HashMap<String,String> param){ String locNo = param.get("locNo"); @@ -247,6 +248,7 @@ */ @PostMapping("/update/detl/v1") @ManagerAuth(memo = "绾犳搴撲綅") + @Synchronized public R updateLocDetlLocNo(@RequestBody HashMap<String,String> param){ String locNo = param.get("locNo"); String containerCode = param.get("containerCode"); @@ -369,6 +371,7 @@ @PostMapping("/agv/v1/locMove") @Transactional @ManagerAuth(memo = "璋冩嫧鍗曚换鍔′笅鍙�") + @Synchronized public R agvLocMove(@RequestBody HashMap<String,Object> params){ String fl = String.valueOf(params.get("floor")); short floor =(short)Integer.parseInt(fl.substring(0, 1)); @@ -405,6 +408,7 @@ @PostMapping("/agv/v2/locMove") @Transactional @ManagerAuth(memo = "璋冩嫧鍗曚换鍔′笅鍙�") + @Synchronized public R agvLocMove2(@RequestBody HashMap<String,Object> params){ Date now = new Date(); String fl = String.valueOf(params.get("floor")); @@ -424,6 +428,10 @@ for (HashMap<String, String> map : dbList) { String locNo = map.get("locNo"); String barcode = map.get("suppCode"); + AgvWrkMast source_loc_no = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>().eq("source_loc_no", locNo)); + if (!Cools.isEmpty(source_loc_no)) { + throw new CoolException("褰撳墠搴撲綅宸茬敓鎴愪换鍔★紒"); + } AgvWrkMast wrkMast = createWrkMast(ioType, 22L, locNo, "", barcode, now, getUserId(), 30,floor); // 鍚屾璋冩嫧鍗� List<AgvLocDetl> agvLocDetls = agvLocDetlService.selectList(new EntityWrapper<AgvLocDetl>().eq("loc_no", locNo)); @@ -458,6 +466,7 @@ @PostMapping("/hand/control/locMove") @Transactional @ManagerAuth(memo = "鎵嬪姩搴撲綅杞Щ") + @Synchronized public R handControlLocMove(@RequestBody LocMoveParam param){ agvMobileService.handControlLocMove(param, getUserId()); return R.ok(); @@ -466,6 +475,7 @@ @PostMapping("/hand/control/allocationOut") @Transactional @ManagerAuth(memo = "璋冩嫧绂诲満") + @Synchronized public R allocationOut(@RequestBody AgvMobileStartPakin param){ agvMobileService.allocationOut(param, getUserId()); return R.ok(); @@ -474,6 +484,7 @@ @PostMapping("/hand/control/allocationIn") @Transactional @ManagerAuth(memo = "璋冩嫧杩涘満") + @Synchronized public R allocationIn(@RequestBody AgvMobileStartPakin param){ agvMobileService.allocationIn(param, getUserId()); return R.ok(); @@ -482,6 +493,7 @@ @PostMapping("/hand/control/doBack") @Transactional @ManagerAuth(memo = "绔欑偣鍥為��") + @Synchronized public R doBack(@RequestBody AgvMobileStartPakin param){ agvMobileService.doBack(param, getUserId()); return R.ok(); @@ -490,6 +502,7 @@ @PostMapping("/hand/control/handBack") @Transactional @ManagerAuth(memo = "杞墜鍔ㄥ洖娴�") + @Synchronized public R handBack(@RequestBody AgvMobileStartPakin param){ agvMobileService.handBack(param, getUserId()); return R.ok(); -- Gitblit v1.9.1