From 21d0e7ab9d5c7316225a3e9eecf465cd37c9bd85 Mon Sep 17 00:00:00 2001
From: zhang <zc857179121@qq.com>
Date: 星期四, 05 六月 2025 14:15:07 +0800
Subject: [PATCH] 123

---
 src/main/java/com/zy/common/web/WcsController.java |   69 ++++++++++++++++++++++++++--------
 1 files changed, 53 insertions(+), 16 deletions(-)

diff --git a/src/main/java/com/zy/common/web/WcsController.java b/src/main/java/com/zy/common/web/WcsController.java
index 5cd4bcd..cc7fa7a 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 org.springframework.transaction.annotation.Transactional;
 import org.springframework.web.bind.annotation.*;
 
+import java.util.ArrayList;
 import java.util.Date;
 import java.util.List;
 import java.util.stream.Collectors;
@@ -82,21 +83,37 @@
         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;
-            case 103:// 鎷f枡鍏ュ簱
-            case 104:// 骞舵澘鍏ュ簱
-            case 107:// 鐩樼偣鍏ュ簱
-                dto = pickWrkPlateIn(param.getWrkNo(), param.getIoType(), param.getSourceStaNo(), locTypeDto);
-                break;
-            default:
-                break;
+        try{
+            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;
+                case 103:// 鎷f枡鍏ュ簱
+                case 104:// 骞舵澘鍏ュ簱
+                case 107:// 鐩樼偣鍏ュ簱
+                    dto = pickWrkPlateIn(param.getWrkNo(), param.getIoType(), param.getSourceStaNo(), locTypeDto);
+                    break;
+                default:
+                    break;
+            }
+        } catch (Exception e){
+            String message = e.getMessage();
+            if (message.contains("--")){
+                String[] split = message.split("--");
+                if (!Cools.isEmpty(split) && split.length>=2){
+                    if (split[1].equals("1000")){
+                        return R.parse(CodeRes.NONE_DETL_1000);
+                    }
+                }
+            }
+            return R.error().add(e.getMessage());
+        }
+        if (!Cools.isEmpty(dto) && param.getIoType()<11 && dto.getCrnNo().equals(0) && dto.getWorkNo().equals(9999) && dto.getStaNo().equals(1000)){
+            return R.parse(CodeRes.NONE_DETL_1000);
         }
         log.info("/pakin/loc/v1:"+dto + "======鎵樼洏鐮�:"+param.getBarcode());
         return R.ok().add(dto);
@@ -112,7 +129,13 @@
         BasDevp sourceStaNo = basDevpService.checkSiteStatus(devpNo, true);
         // 妫�绱㈠簱浣�
         List<String> matNos = waitPakins.stream().map(WaitPakin::getMatnr).distinct().collect(Collectors.toList());
-        StartupDto dto = commonService.getLocNo(1, 1, devpNo, matNos, locTypeDto,0);
+        StartupDto dto = commonService.getLocNo(1, 1, devpNo, matNos, locTypeDto,waitPakins.get(0).getMatTypeIn());
+        if ((dto.getSourceStaNo().equals(103) && dto.getCrnNo().equals(3)) || (dto.getSourceStaNo().equals(203) && dto.getCrnNo().equals(1))){
+            dto.setWorkNo(9999);
+            dto.setStaNo(1000);
+            dto.setCrnNo(0);
+            return dto;
+        }
         int workNo = dto.getWorkNo();
         Date now = new Date();
         // 鐢熸垚宸ヤ綔妗�
@@ -138,18 +161,26 @@
         // 鎿嶄綔浜哄憳鏁版嵁
         wrkMast.setAppeTime(now);
         wrkMast.setModiTime(now);
+
+        if(waitPakins.size()>0) {
+            WaitPakin one = waitPakins.get(0);
+            wrkMast.setFrozen(one.getFrozen());
+            wrkMast.setMemo(one.getMemo());
+        }
         boolean res = wrkMastService.insert(wrkMast);
         if (!res) {
             throw new CoolException("淇濆瓨宸ヤ綔妗eけ璐�");
         }
         // 鐢熸垚宸ヤ綔妗f槑缁�
         waitPakins.forEach(waitPakin -> {
+//            waitPakin.setBatch("");
             WrkDetl wrkDetl = new WrkDetl();
             wrkDetl.sync(waitPakin);
             wrkDetl.setWrkNo(wrkMast.getWrkNo());
             wrkDetl.setIoTime(wrkMast.getIoTime());
             wrkDetl.setAppeTime(now);
             wrkDetl.setModiTime(now);
+            wrkDetl.setOrigin(waitPakin.getBatch());
             if (!wrkDetlService.insert(wrkDetl)) {
                 throw new CoolException("淇濆瓨宸ヤ綔鏄庣粏澶辫触");
             }
@@ -189,6 +220,12 @@
         BasDevp sourceStaNo = basDevpService.checkSiteStatus(devpNo, true);
         // 妫�绱㈠簱浣�
         StartupDto dto = commonService.getLocNo(1, 10, devpNo, null, locTypeDto,0);
+        if ((dto.getSourceStaNo().equals(103) && dto.getCrnNo().equals(3)) || (dto.getSourceStaNo().equals(203) && dto.getCrnNo().equals(1))){
+            dto.setWorkNo(9999);
+            dto.setStaNo(1000);
+            dto.setCrnNo(0);
+            return dto;
+        }
         int workNo = dto.getWorkNo();
         // 鐢熸垚宸ヤ綔妗�
         WrkMast wrkMast = new WrkMast();

--
Gitblit v1.9.1