From 7c36a39a0a2abf561d6c529f4918323f2c44945c Mon Sep 17 00:00:00 2001
From: pang.jiabao <pang_jiabao@163.com>
Date: 星期三, 26 二月 2025 08:58:26 +0800
Subject: [PATCH] agv站点修改

---
 src/main/java/com/zy/common/web/WcsController.java |   76 +++++++++++++++++++++++++++-----------
 1 files changed, 54 insertions(+), 22 deletions(-)

diff --git a/src/main/java/com/zy/common/web/WcsController.java b/src/main/java/com/zy/common/web/WcsController.java
index 5e3124c..2eab1e8 100644
--- a/src/main/java/com/zy/common/web/WcsController.java
+++ b/src/main/java/com/zy/common/web/WcsController.java
@@ -21,7 +21,6 @@
 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.*;
@@ -57,6 +56,8 @@
     private StaDescService staDescService;
     @Autowired
     private WebSocketServer webSocketServer;
+    @Autowired
+    private OrderDetlService orderDetlService;
 
 
     @PostMapping("/led/getTask")
@@ -66,7 +67,7 @@
         String sta = param.get("sta");
         // 鍛戒护闆嗗悎
         List<LedCommand> commands = new ArrayList<>();
-        if ("0".equals(sta)) {
+        if (!"0".equals(taskNo)) {
 
             // 宸ヤ綔妗i泦鍚�
             List<WrkMast> wrkMasts = new ArrayList<>();
@@ -121,14 +122,28 @@
                     } else {
                         total = locDetl.getAnfme();
                     }
-                    if (wrkMast.getIoType() == 101 || wrkMast.getIoType() == 1) {
-                        ledCommand.getMatDtos().add(new MatDto(wrkDetl.getMatnr(), wrkDetl.getMaktx(), wrkDetl.getBatch(), wrkDetl.getSpecs(), wrkDetl.getManu(), wrkDetl.getMemo(), wrkDetl.getAnfme(),total));
-                    }
-                    if (wrkMast.getIoType() == 103 && (null == wrkDetl.getInspect() || 0 == wrkDetl.getInspect())) {
-                        ledCommand.getMatDtos().add(new MatDto(wrkDetl.getMatnr(), wrkDetl.getMaktx(), wrkDetl.getBatch(), wrkDetl.getSpecs(), wrkDetl.getManu(), wrkDetl.getMemo(), wrkDetl.getAnfme(),total));
-                    }
-                    if (wrkMast.getIoType() == 107 || wrkMast.getIoType() == 104) {
-                        ledCommand.getMatDtos().add(new MatDto(wrkDetl.getMatnr(), wrkDetl.getMaktx(), wrkDetl.getBatch(), wrkDetl.getSpecs(), wrkDetl.getManu(), wrkDetl.getMemo(), wrkDetl.getAnfme(),total));
+                    if (!Cools.isEmpty(wrkDetl.getOrderNo())){
+                        OrderDetl orderDetl = orderDetlService.selectOne(new EntityWrapper<OrderDetl>().eq("order_no", wrkDetl.getOrderNo())
+                                .eq("matnr", wrkDetl.getMatnr()).eq("batch", wrkDetl.getBatch()));
+                        if (wrkMast.getIoType() == 101 || wrkMast.getIoType() == 1) {
+                            ledCommand.getMatDtos().add(new MatDto(wrkDetl.getMatnr(), wrkDetl.getMaktx(), wrkDetl.getBatch(), wrkDetl.getSpecs(), wrkDetl.getManu(), wrkDetl.getMemo(), wrkDetl.getAnfme(),total,orderDetl.getSuppCode(),orderDetl.getSku()));
+                        }
+                        if (wrkMast.getIoType() == 103 && (null == wrkDetl.getInspect() || 0 == wrkDetl.getInspect())) {
+                            ledCommand.getMatDtos().add(new MatDto(wrkDetl.getMatnr(), wrkDetl.getMaktx(), wrkDetl.getBatch(), wrkDetl.getSpecs(), wrkDetl.getManu(), wrkDetl.getMemo(), wrkDetl.getAnfme(),total,orderDetl.getSuppCode(),orderDetl.getSku()));
+                        }
+                        if (wrkMast.getIoType() == 107 || wrkMast.getIoType() == 104) {
+                            ledCommand.getMatDtos().add(new MatDto(wrkDetl.getMatnr(), wrkDetl.getMaktx(), wrkDetl.getBatch(), wrkDetl.getSpecs(), wrkDetl.getManu(), wrkDetl.getMemo(), wrkDetl.getAnfme(),total,orderDetl.getSuppCode(),orderDetl.getSku()));
+                        }
+                    }else {
+                        if (wrkMast.getIoType() == 101 || wrkMast.getIoType() == 1) {
+                            ledCommand.getMatDtos().add(new MatDto(wrkDetl.getMatnr(), wrkDetl.getMaktx(), wrkDetl.getBatch(), wrkDetl.getSpecs(), wrkDetl.getManu(), wrkDetl.getMemo(), wrkDetl.getAnfme(),total));
+                        }
+                        if (wrkMast.getIoType() == 103 && (null == wrkDetl.getInspect() || 0 == wrkDetl.getInspect())) {
+                            ledCommand.getMatDtos().add(new MatDto(wrkDetl.getMatnr(), wrkDetl.getMaktx(), wrkDetl.getBatch(), wrkDetl.getSpecs(), wrkDetl.getManu(), wrkDetl.getMemo(), wrkDetl.getAnfme(),total));
+                        }
+                        if (wrkMast.getIoType() == 107 || wrkMast.getIoType() == 104) {
+                            ledCommand.getMatDtos().add(new MatDto(wrkDetl.getMatnr(), wrkDetl.getMaktx(), wrkDetl.getBatch(), wrkDetl.getSpecs(), wrkDetl.getManu(), wrkDetl.getMemo(), wrkDetl.getAnfme(),total));
+                        }
                     }
                 });
             }
@@ -139,7 +154,7 @@
             for (WrkMast wrkMast1 : wrkMasts) {
                 wrkMast1.setOveMk("Y");
                 wrkMast1.setModiTime(new Date());
-                if (wrkMastService.updateById(wrkMast1)) {
+                if (!wrkMastService.update(wrkMast1,new EntityWrapper<WrkMast>().eq("wrk_No",wrkMast1.getWrkNo()))) {
                     throw new CoolException("鏇存柊宸ヤ綔妗eけ璐�");
                 }
             }
@@ -160,7 +175,7 @@
     public synchronized R getledError(@RequestBody Map<String, String> param) {
         String sta = param.get("sta");
         String message = param.get("msg");
-        if (Cools.isEmpty(sta) || Cools.isEmpty(message)) {
+        if (Cools.isEmpty(sta) ) {
             return R.error();
         }
         Map<String,Object> map=new HashMap<String, Object>();
@@ -192,12 +207,12 @@
         if (Cools.isEmpty(staDesc)){
             throw new CoolException("鏈壘鍒扮珯鐐硅矾寰�");
         }
-        if (wrkMast.getWrkSts() == 14 && wrkMast.getIoType() == 103){
+        if (wrkMast.getWrkSts() == 14 && (wrkMast.getIoType() == 103 || wrkMast.getIoType() == 107 || wrkMast.getIoType() == 104)){
             try {
                 // 淇濆瓨宸ヤ綔鏄庣粏妗e巻鍙叉。
-                if (wrkMastService.saveWrkDetlLog(wrkMast.getWrkNo()) == 0) {
-                    throw new CoolException("淇濆瓨宸ヤ綔鏄庣粏妗e巻鍙叉。澶辫触");
-                }
+//                if (wrkMastService.saveWrkDetlLog(wrkMast.getWrkNo()) == 0) {
+//                    throw new CoolException("淇濆瓨宸ヤ綔鏄庣粏妗e巻鍙叉。澶辫触");
+//                }
                 // 淇濆瓨宸ヤ綔涓绘。鍘嗗彶妗�
                 if (wrkMastService.saveWrkMastLog(wrkMast.getWrkNo()) == 0) {
                     throw new CoolException("淇濆瓨宸ヤ綔涓绘。鍘嗗彶妗eけ璐�");
@@ -399,7 +414,7 @@
         }
         WrkMast wrkMastPakin = wrkMastService.selectOne(new EntityWrapper<WrkMast>()
                 .eq("barcode", param.getBarcode())
-                .in("io_type", 103,53)
+                .in("io_type", 103,53,107,57,104,54)
                 .eq("wrk_sts",14));
         if (!Cools.isEmpty(wrkMastPakin)){
             StartupDto locNo3 = getLocNo3(param);
@@ -419,9 +434,12 @@
                     return R.parse(CodeRes.NO_COMB_700);
                 }
                 int countLoc = locDetlService.selectCount(new EntityWrapper<LocDetl>().eq("zpallet",param.getBarcode()));
+                if (countLoc > 0 ) {
+                    return R.error(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 ( countWrk > 0) {
+                    return R.error(param.getBarcode()+"鏉$爜鍦ㄥ伐浣滄。涓凡瀛樺湪");
                 }
             }
             if (Cools.isEmpty(param.getLocType1())){
@@ -510,7 +528,21 @@
         // 妫�绱㈠簱浣�
         List<String> matnrs = waitPakins.stream().map(WaitPakin::getMatnr).distinct().collect(Collectors.toList());
         List<String> batchs = waitPakins.stream().map(WaitPakin::getBatch).distinct().collect(Collectors.toList());
-        StartupDto dto = commonService.getLocNo( 1, devpNo, matnrs.get(0),batchs.get(0),null, locTypeDto, matnrs.size() > 1);
+        boolean mixtrue =false;
+
+        if (matnrs.size() == 1 && batchs.size() == 1) {
+
+        }else if(matnrs.size() > 1 && batchs.size() == 1) {
+            mixtrue = true;
+        }else if(matnrs.size() == 1 && batchs.size() > 1) {
+            mixtrue = true;
+        }else if(matnrs.size() > 1 && batchs.size() > 1) {
+            mixtrue = true;
+        }
+        StartupDto dto = commonService.getLocNo( 1, devpNo, matnrs.get(0),batchs.get(0),null, locTypeDto, mixtrue);
+        if (Cools.isEmpty(dto)){
+            throw new CoolException("鏈壘鍒板簱浣嶄俊鎭�");
+        }
         int workNo = dto.getWorkNo();
         Date now = new Date();
         // 鐢熸垚宸ヤ綔妗�
@@ -519,7 +551,7 @@
         wrkMast.setIoTime(new Date());
         wrkMast.setWrkSts(2L); // 宸ヤ綔鐘舵�侊細鐢熸垚鍏ュ簱ID
         wrkMast.setIoType(1); // 鍏ュ嚭搴撶姸鎬侊細1.鍏ュ簱
-        wrkMast.setIoPri(13D); // 浼樺厛绾�
+        wrkMast.setIoPri(12D); // 浼樺厛绾�
         wrkMast.setCrnNo(dto.getCrnNo());
         wrkMast.setSourceStaNo(dto.getSourceStaNo());
         wrkMast.setStaNo(dto.getStaNo());
@@ -593,7 +625,7 @@
         wrkMast.setIoTime(new Date());
         wrkMast.setWrkSts(2L); // 宸ヤ綔鐘舵�侊細鐢熸垚鍏ュ簱ID
         wrkMast.setIoType(10); // 鍏ュ嚭搴撶姸鎬侊細10.绌烘澘鍏ュ簱
-        wrkMast.setIoPri(13D); // 浼樺厛绾�
+        wrkMast.setIoPri(12D); // 浼樺厛绾�
         wrkMast.setCrnNo(dto.getCrnNo());
         wrkMast.setSourceStaNo(dto.getSourceStaNo());
         wrkMast.setStaNo(dto.getStaNo());

--
Gitblit v1.9.1