From 13c2be4774f4afbb34fa70be97c96802f07b15ff Mon Sep 17 00:00:00 2001
From: zyx <zyx123456>
Date: 星期四, 04 七月 2024 15:35:02 +0800
Subject: [PATCH] #MES接口

---
 src/main/java/com/zy/asrs/controller/AgvMobileController.java |   55 +++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 55 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 488c19f..9f38872 100644
--- a/src/main/java/com/zy/asrs/controller/AgvMobileController.java
+++ b/src/main/java/com/zy/asrs/controller/AgvMobileController.java
@@ -12,6 +12,8 @@
 import com.zy.common.web.BaseController;
 import io.swagger.models.auth.In;
 import lombok.Synchronized;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.web.bind.annotation.*;
@@ -27,6 +29,8 @@
 @RequestMapping("agvMobile")
 public class AgvMobileController extends BaseController  {
 
+
+    private static final Logger log = LoggerFactory.getLogger(AgvMobileController.class);
     @Autowired
     private AgvMobileService agvMobileService;
     @Autowired
@@ -219,6 +223,7 @@
      */
     @PostMapping("/check/detl/v1")
     @ManagerAuth(memo = "搴撳瓨鐩樼偣")
+    @Synchronized
     public R checkLocDetl(@RequestBody HashMap<String,String> param){
 
         String locNo = param.get("locNo");
@@ -247,6 +252,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 +375,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 +412,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"));
@@ -417,6 +425,11 @@
         if (mT.equals("unAuto")) {
             moveType = "2";
             ioType = 111;
+            int count = agvWrkMastService.selectCount(new EntityWrapper<AgvWrkMast>().eq("io_type", ioType));
+            if (count>3){
+                log.equals("111浠诲姟鍫靛锛岀◢鍚庡啀璇曪紒锛侊紒褰撳墠闄愬埗鏁伴噺3鏉★紝闄愬埗鏉′欢锛歩o_type = 111");
+                throw new CoolException("111浠诲姟鍫靛锛岀◢鍚庡啀璇曪紒");
+            }
         } else {
             moveType = "1";
             ioType = 108;
@@ -424,6 +437,14 @@
         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("褰撳墠搴撲綅宸茬敓鎴愪换鍔★紒");
+            }
+            AgvLocMast locMastS = agvLocMastService.selectOne(new EntityWrapper<AgvLocMast>().eq("loc_no", locNo).eq("loc_sts","F"));
+            if (Cools.isEmpty(locMastS)) {
+                throw new CoolException("褰撳墠搴撲綅闈炲湪搴撶姸鎬侊紒搴撲綅鍙�="+locNo);
+            }
             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 +479,7 @@
     @PostMapping("/hand/control/locMove")
     @Transactional
     @ManagerAuth(memo = "鎵嬪姩搴撲綅杞Щ")
+    @Synchronized
     public R handControlLocMove(@RequestBody LocMoveParam param){
         agvMobileService.handControlLocMove(param, getUserId());
         return R.ok();
@@ -466,6 +488,7 @@
     @PostMapping("/hand/control/allocationOut")
     @Transactional
     @ManagerAuth(memo = "璋冩嫧绂诲満")
+    @Synchronized
     public R allocationOut(@RequestBody AgvMobileStartPakin param){
         agvMobileService.allocationOut(param, getUserId());
         return R.ok();
@@ -474,19 +497,51 @@
     @PostMapping("/hand/control/allocationIn")
     @Transactional
     @ManagerAuth(memo = "璋冩嫧杩涘満")
+    @Synchronized
     public R allocationIn(@RequestBody AgvMobileStartPakin param){
         agvMobileService.allocationIn(param, getUserId());
+        return R.ok();
+    }
+
+    @PostMapping("/hand/control/empOut")
+    @Transactional
+    @ManagerAuth(memo = "绌烘灦绂诲満")
+    @Synchronized
+    public R empOut(@RequestBody AgvMobileStartPakin param){
+        agvMobileService.empOut(param, getUserId());
+        return R.ok();
+    }
+
+    @PostMapping("/hand/control/empIn")
+    @Transactional
+    @ManagerAuth(memo = "绌烘灦杩涘満")
+    @Synchronized
+    public R empIn(@RequestBody AgvMobileStartPakin param){
+        agvMobileService.empIn(param, getUserId());
         return R.ok();
     }
 
     @PostMapping("/hand/control/doBack")
     @Transactional
     @ManagerAuth(memo = "绔欑偣鍥為��")
+    @Synchronized
     public R doBack(@RequestBody AgvMobileStartPakin param){
+        if (Cools.isEmpty(param)){
+            return R.error("鍙傛暟涓虹┖");
+        }
         agvMobileService.doBack(param, getUserId());
         return R.ok();
     }
 
+    @PostMapping("/hand/control/handBack")
+    @Transactional
+    @ManagerAuth(memo = "杞墜鍔ㄥ洖娴�")
+    @Synchronized
+    public R handBack(@RequestBody AgvMobileStartPakin param){
+        agvMobileService.handBack(param, getUserId());
+        return R.ok();
+    }
+
     public static void main(String[] args) {
         List<AgvLocDetl> agvLocDetls1 = new ArrayList<>();
         List<AgvLocDetl> agvLocDetls2 = new ArrayList<>();

--
Gitblit v1.9.1