From 14a5c0a9532de99081a58779633aa5001bdd989c Mon Sep 17 00:00:00 2001
From: gt-fuwuqi <3272660260@qq.com>
Date: 星期六, 09 十一月 2024 15:29:36 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/common/web/WcsController.java |  151 ++++++++++++++++++++++++++++++++++++++------------
 1 files changed, 114 insertions(+), 37 deletions(-)

diff --git a/src/main/java/com/zy/common/web/WcsController.java b/src/main/java/com/zy/common/web/WcsController.java
index 0166615..2690163 100644
--- a/src/main/java/com/zy/common/web/WcsController.java
+++ b/src/main/java/com/zy/common/web/WcsController.java
@@ -17,6 +17,7 @@
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.transaction.annotation.Transactional;
+import org.springframework.transaction.interceptor.TransactionAspectSupport;
 import org.springframework.web.bind.annotation.*;
 
 import java.util.ArrayList;
@@ -52,6 +53,71 @@
     private WorkService workService;
     @Autowired
     private StaDescService staDescService;
+
+
+    @Transactional
+    public synchronized StartupDto getLocNo3(@RequestBody SearchLocParam param){
+        log.info("鏀跺埌WCS鎷f枡鍏ュ簱鎺ュ彛璇锋眰====>>鍏ュ弬:{}", param);
+        WrkMast wrkMast = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("barcode", param.getBarcode()));
+        if (Cools.isEmpty(wrkMast)){
+            throw new CoolException("鏈壘鍒颁换鍔�");
+        }
+        StartupDto dto = new StartupDto();
+        // 鑾峰彇鐩爣绔�
+        Wrapper<StaDesc> wrapper = new EntityWrapper<StaDesc>()
+                .eq("type_no", wrkMast.getIoType() - 50)
+                .eq("stn_no", 31002) // 浣滀笟绔欑偣 = 鎷f枡鍑哄簱鐨勭洰鏍囩珯
+                .eq("crn_no", wrkMast.getCrnNo()); // 鍫嗗灈鏈哄彿
+        StaDesc staDesc = staDescService.selectOne(wrapper);
+        if (Cools.isEmpty(staDesc)){
+            throw new CoolException("鏈壘鍒扮珯鐐硅矾寰�");
+        }
+        if (wrkMast.getWrkSts() == 14 && wrkMast.getIoType() == 103){
+            try {
+                // 淇濆瓨宸ヤ綔鏄庣粏妗e巻鍙叉。
+                if (wrkMastService.saveWrkDetlLog(wrkMast.getWrkNo()) == 0) {
+                    throw new CoolException("淇濆瓨宸ヤ綔鏄庣粏妗e巻鍙叉。澶辫触");
+                }
+                // 淇濆瓨宸ヤ綔涓绘。鍘嗗彶妗�
+                if (wrkMastService.saveWrkMastLog(wrkMast.getWrkNo()) == 0) {
+                    throw new CoolException("淇濆瓨宸ヤ綔涓绘。鍘嗗彶妗eけ璐�");
+                }
+
+                Date now = new Date();
+                // 鍫嗗灈鏈虹珯鐐�(鐩爣绔�)
+                Integer staNo = staDesc.getCrnStn();
+                // 鏇存柊宸ヤ綔妗f暟鎹姸鎬�
+                wrkMast.setIoTime(now);
+                wrkMast.setIoType(wrkMast.getIoType() - 50); // 鍏ュ嚭搴撶被鍨�: 103->53,104->54,107->57
+                wrkMast.setWrkSts(2L); // 宸ヤ綔鐘舵��: 2.璁惧涓婅蛋
+                wrkMast.setSourceStaNo(wrkMast.getStaNo()); // 婧愮珯
+                wrkMast.setStaNo(staNo); // 鐩爣绔�
+                wrkMast.setLocNo(wrkMast.getSourceLocNo()); // 鐩爣搴撲綅 = 鍑哄簱鏃剁殑婧愬簱浣�
+                wrkMast.setSourceLocNo(""); // 婧愬簱浣嶆竻绌�
+                wrkMast.setModiTime(now);
+                if (!wrkMastService.updateById(wrkMast)) {
+                    throw new CoolException("鏇存柊宸ヤ綔妗f暟鎹姸鎬佸け璐�");
+                }
+                // 鏇存柊鏄庣粏妗o_time (鍘嗗彶妗e叧鑱斾娇鐢級
+                wrkDetlService.updateIoTime(wrkMast.getWrkNo(), now);
+                // 淇敼搴撲綅鐘舵�� Q.鎷f枡/鐩樼偣/骞舵澘鍐嶅叆搴�
+                LocMast locMast = locMastService.selectById(wrkMast.getLocNo());
+                locMast.setLocSts("Q");
+                locMast.setModiTime(new Date());
+                if (!locMastService.updateById(locMast)) {
+                    throw new CoolException("淇敼搴撲綅鐘舵�佸け璐�");
+                }
+                dto.setWorkNo(wrkMast.getWrkNo());
+                dto.setLocNo(wrkMast.getLocNo());
+                return dto;
+            } catch (Exception e) {
+                throw new CoolException("鍑洪敊");
+            }
+        }else {
+
+        }
+        return dto;
+    }
 
     @PostMapping("/pakin2/loc/v1")
     @ResponseBody
@@ -211,48 +277,59 @@
         if (Cools.isEmpty(param.getSourceStaNo())) {
             return R.error("婧愮珯缂栧彿涓嶈兘涓虹┖");
         }
-        List<WaitPakin> waitPakins = null;
-        if (param.getIoType() == 1) {
-            if (Cools.isEmpty(param.getBarcode())) {
-                return R.error("鏉$爜涓嶈兘涓虹┖");
-            }
-            waitPakins = waitPakinService.selectList(new EntityWrapper<WaitPakin>().eq("zpallet", param.getBarcode()));
-            if (Cools.isEmpty(waitPakins)) {
-                WrkMast wrkMast = wrkMastService.selectByBarcode(param.getBarcode());
-                if (wrkMast != null && wrkMast.getIoType() == 103) {
-                    return R.parse(CodeRes.PICK_600);
+        WrkMast wrkMastPakin = wrkMastService.selectOne(new EntityWrapper<WrkMast>()
+                .eq("barcode", param.getBarcode())
+                .in("io_type", 103,53)
+                .eq("wrk_sts",14));
+        if (!Cools.isEmpty(wrkMastPakin)){
+            StartupDto locNo3 = getLocNo3(param);
+            return R.ok(locNo3);
+        }else {
+            List<WaitPakin> waitPakins = null;
+            if (param.getIoType() == 1) {
+                if (Cools.isEmpty(param.getBarcode())) {
+                    return R.error("鏉$爜涓嶈兘涓虹┖");
                 }
-                return R.parse(CodeRes.NO_COMB_700);
+                waitPakins = waitPakinService.selectList(new EntityWrapper<WaitPakin>().eq("zpallet", param.getBarcode()));
+                if (Cools.isEmpty(waitPakins)) {
+                    WrkMast wrkMast = wrkMastService.selectByBarcode(param.getBarcode());
+                    if (wrkMast != null && wrkMast.getIoType() == 103) {
+                        return R.parse(CodeRes.PICK_600);
+                    }
+                    return R.parse(CodeRes.NO_COMB_700);
+                }
+                int countLoc = locDetlService.selectCount(new EntityWrapper<LocDetl>().eq("zpallet",param.getBarcode()));
+                int countWrk = wrkDetlService.selectCount(new EntityWrapper<WrkDetl>().eq("zpallet",param.getBarcode()));
+                if (countLoc > 0 || countWrk > 0) {
+                    return R.error(CodeRes.EXIST_500);
+                }
             }
-            int countLoc = locDetlService.selectCount(new EntityWrapper<LocDetl>().eq("zpallet",param.getBarcode()));
-            int countWrk = wrkDetlService.selectCount(new EntityWrapper<WrkDetl>().eq("zpallet",param.getBarcode()));
-            if (countLoc > 0 || countWrk > 0) {
-                return R.error(CodeRes.EXIST_500);
+            if (Cools.isEmpty(param.getLocType1())){
+                return R.error("楂樹綆妫�娴嬩俊鍙蜂笉鑳戒负绌�");
             }
-        }
-        if (Cools.isEmpty(param.getLocType1())){
-            return R.error("楂樹綆妫�娴嬩俊鍙蜂笉鑳戒负绌�");
+
+            // 婧愮珯鐐圭姸鎬佹娴�
+            BasDevp sourceStaNo = basDevpService.checkSiteStatus(param.getSourceStaNo(), true);
+            sourceStaNo.setLocType1(param.getLocType1());
+            LocTypeDto locTypeDto = new LocTypeDto(sourceStaNo);
+
+            StartupDto dto = null;
+            switch (param.getIoType()) {
+                case 1://婊℃墭鐩樺叆搴�
+                    assert waitPakins != null;
+                    dto = startupFullPutStore(param.getSourceStaNo(), param.getBarcode(), locTypeDto, waitPakins);
+                    break;
+                case 10://绌烘墭鐩樺叆搴�
+                    dto = emptyPlateIn(param.getSourceStaNo(), locTypeDto, param.getBarcode());
+                    break;
+                default:
+                    break;
+            }
+            log.info("WCS鍏ュ簱鎺ュ彛杩斿弬:{},鎵樼洏鐮�:{}", dto, param.getBarcode());
+            return R.ok().add(dto);
         }
 
-        // 婧愮珯鐐圭姸鎬佹娴�
-        BasDevp sourceStaNo = basDevpService.checkSiteStatus(param.getSourceStaNo(), true);
-        sourceStaNo.setLocType1(param.getLocType1());
-        LocTypeDto locTypeDto = new LocTypeDto(sourceStaNo);
 
-        StartupDto dto = null;
-        switch (param.getIoType()) {
-            case 1://婊℃墭鐩樺叆搴�
-                assert waitPakins != null;
-                dto = startupFullPutStore(param.getSourceStaNo(), param.getBarcode(), locTypeDto, waitPakins);
-                break;
-            case 10://绌烘墭鐩樺叆搴�
-                dto = emptyPlateIn(param.getSourceStaNo(), locTypeDto, param.getBarcode());
-                break;
-            default:
-                break;
-        }
-        log.info("WCS鍏ュ簱鎺ュ彛杩斿弬:{},鎵樼洏鐮�:{}", dto, param.getBarcode());
-        return R.ok().add(dto);
     }
 
     @PostMapping("/auto/emptyIn/v1")
@@ -401,7 +478,7 @@
         wrkMast.setSourceStaNo(dto.getSourceStaNo());
         wrkMast.setStaNo(dto.getStaNo());
         wrkMast.setLocNo(dto.getLocNo());
-        wrkMast.setFullPlt("N"); // 婊℃澘
+        wrkMast.setFullPlt(dto.getSourceStaNo() == 1025?"Y":"N"); // 婊℃澘
         wrkMast.setPicking("N"); // 鎷f枡
         wrkMast.setExitMk("N"); // 閫�鍑�
         wrkMast.setEmptyMk("Y"); // 绌烘澘

--
Gitblit v1.9.1