From 9ac70efe81c1909d63b89f9b18c4f367c0584ceb Mon Sep 17 00:00:00 2001
From: 野心家 <1051256694@qq.com>
Date: 星期一, 28 四月 2025 16:04:00 +0800
Subject: [PATCH] 初始化

---
 src/main/java/com/zy/common/web/WcsController.java |   83 ++++++++++++++++++++++++++++++++---------
 1 files changed, 65 insertions(+), 18 deletions(-)

diff --git a/src/main/java/com/zy/common/web/WcsController.java b/src/main/java/com/zy/common/web/WcsController.java
index b00ca42..3d85ce9 100644
--- a/src/main/java/com/zy/common/web/WcsController.java
+++ b/src/main/java/com/zy/common/web/WcsController.java
@@ -47,11 +47,15 @@
     private WaitPakinService waitPakinService;
     @Autowired
     private  LocDetlService locDetlService;
+    @Autowired
+    private  TestMastService testMastService;
+    @Autowired
+    private  MatService matService;
 
-    @Value("mes.url")
+    @Value("${mes.url}")
     private String mesUrl;
 
-    @Value("mes.inPath")
+    @Value("${mes.inPath}")
     private String inpath;
 
     @PostMapping("/pakin/loc/v1")
@@ -64,16 +68,18 @@
         if (Cools.isEmpty(param.getSourceStaNo())) {
             return R.error("婧愮珯缂栧彿涓嶈兘涓虹┖");
         }
+
+        Date now = new Date();
         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)) {
+            if (Cools.isEmpty(waitPakins) || waitPakins.size() !=1) {
                 WrkMast wrkMast = wrkMastService.selectByBarcode(param.getBarcode());
-                if (wrkMast != null && wrkMast.getIoType() == 103) {
-                    return R.parse(CodeRes.PICK_600);
+                if (wrkMast != null || waitPakins.size() !=1) {
+                    return R.parse("600-閲嶅缁勬墭");
                 }
                 return R.parse(CodeRes.NO_COMB_700);
             }
@@ -93,8 +99,7 @@
 
         // 婧愮珯鐐圭姸鎬佹娴�
         BasDevp sourceStaNo = basDevpService.checkSiteStatus(param.getSourceStaNo(), false);
-//        sourceStaNo.setLocType1(param.getLocType1());
-        sourceStaNo.setLocType1((short)1);
+        sourceStaNo.setLocType1(param.getLocType1());
         LocTypeDto locTypeDto = new LocTypeDto(sourceStaNo);
 
         StartupDto dto = null;
@@ -114,7 +119,7 @@
     }
 
     /**
-     * 鍏ㄦ澘鍏ュ簱
+         * 鍏ㄦ澘鍏ュ簱
      */
     @Transactional
     public StartupDto startupFullPutStore(Integer devpNo, String barcode, LocTypeDto locTypeDto, List<WaitPakin> waitPakins) {
@@ -150,8 +155,11 @@
         if (!res) {
             throw new CoolException("淇濆瓨宸ヤ綔妗eけ璐�");
         }
+        // 鐩爣搴撲綅
+        LocMast locMast = locMastService.selectById(dto.getLocNo());
+
         // 鐢熸垚宸ヤ綔妗f槑缁�
-        waitPakins.forEach(waitPakin -> {
+        for (WaitPakin waitPakin: waitPakins) {
             WrkDetl wrkDetl = new WrkDetl();
             wrkDetl.sync(waitPakin);
             wrkDetl.setWrkNo(wrkMast.getWrkNo());
@@ -162,7 +170,42 @@
             if (!wrkDetlService.insert(wrkDetl)) {
                 throw new CoolException("淇濆瓨宸ヤ綔鏄庣粏澶辫触");
             }
-        });
+
+                TestMast testMast = testMastService.selectOne(new EntityWrapper<TestMast>()
+                        .eq("barcode", wrkDetl.getMatnr())
+                        .eq("user_id",wrkDetl.getZpallet()));//pack鐮�
+                if (Cools.isEmpty(testMast)){
+                    //鐢熸垚娴嬭瘯妗�
+                    testMast=new TestMast();
+                    //鍏ュ緟娴嬪簱浣嶉�氶亾璁句负0
+                    if(locMast.getChannel()==null) {
+                        testMast.setChannel(0);//閫氶亾璁句负0
+                    }else{
+                        testMast.setChannel(locMast.getChannel());
+                    }
+                    testMast.setUserId(wrkMast.getBarcode());//鎵樼洏鐮�
+                    testMast.setStatus(1);
+                    testMast.setBarcode(wrkDetl.getMatnr());
+                    testMast.setLocNo(locMast.getLocNo());
+                    testMast.setModiTime(now);
+                    testMast.setAppeTime(now);
+                    if (!testMastService.insert(testMast)){
+                        throw new CoolException(wrkDetl.getMatnr()+"鐢熸垚娴嬭瘯妗eけ璐�");
+                    }
+                }else {
+                    testMast.setBarcode(wrkDetl.getMatnr());
+                    testMast.setChannel(locMast.getChannel());
+                    testMast.setLocNo(locMast.getLocNo());
+                    testMast.setStatus(1);
+                    testMast.setUserId(wrkMast.getBarcode());//鎵樼洏鐮�
+                    testMast.setAppeTime(now);
+                    if(!testMastService.update(testMast,new EntityWrapper<TestMast>().eq("barcode", wrkDetl.getMatnr()))){
+                        throw new CoolException(wrkDetl.getMatnr()+"鏇存柊娴嬭瘯妗eけ璐�");
+                    }
+                }
+
+
+        }
         // 鏇存柊鍏ュ簱閫氱煡妗� ioStatus ===>> Y
         Wrapper<WaitPakin> wrapper = new EntityWrapper<WaitPakin>()
                 .eq("zpallet", barcode);
@@ -180,24 +223,28 @@
             throw new CoolException("鏇存柊婧愮珯澶辫触");
         }
         // 鏇存柊鐩爣搴撲綅鐘舵��
-        LocMast locMast = locMastService.selectById(dto.getLocNo());
         if (locMast.getLocSts().equals("O")){
             locMast.setLocSts("S"); // S.鍏ュ簱棰勭害
             locMast.setModiTime(now);
             if (!locMastService.updateById(locMast)){
                 throw new CoolException("鏀瑰彉搴撲綅鐘舵�佸け璐�");
             }else{
-                //1.鎵爜涓婃姤
-                CombParam combParam = new CombParam();
-                combParam.setPackNo(locMast.getBarcode());
-                combParam.setLocNo(locMast.getLocNo());
-                combParam.setPackSts(1);
-                combParam.setRequestTime(DateUtils.convert(new Date()));
-                new PostMesDataUtils().postMesData("MES绯荤粺",mesUrl,inpath,combParam);
+                if (locMast.getRow1()<2){
+                    //1.鎵爜涓婃姤
+                    CombParam combParam = new CombParam();
+                    combParam.setPackNo(waitPakins.get(0).getMatnr());
+                    combParam.setBarcode(wrkMast.getBarcode());
+                    combParam.setLocNo(wrkMast.getLocNo());
+                    combParam.setPackSts(0);
+                    combParam.setStepSts(1);
+                    combParam.setRequestTime(DateUtils.convert(now));
+//                    new PostMesDataUtils().postMesData("MES绯荤粺",mesUrl,inpath,combParam);
+                }
             }
         } else {
             throw new CoolException(dto.getLocNo()+"鐩爣搴撲綅宸茶鍗犵敤");
         }
+
         return dto;
     }
 

--
Gitblit v1.9.1