From 207823b94f5627fae49d29b51b5ce7186a70c8e0 Mon Sep 17 00:00:00 2001
From: whycq <913841844@qq.com>
Date: 星期六, 04 一月 2025 09:59:48 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/task/handler/WorkMastHandler.java |  126 +++++++++++++++++++++++++++++++++++++----
 1 files changed, 113 insertions(+), 13 deletions(-)

diff --git a/src/main/java/com/zy/asrs/task/handler/WorkMastHandler.java b/src/main/java/com/zy/asrs/task/handler/WorkMastHandler.java
index 9182407..2527b59 100644
--- a/src/main/java/com/zy/asrs/task/handler/WorkMastHandler.java
+++ b/src/main/java/com/zy/asrs/task/handler/WorkMastHandler.java
@@ -37,6 +37,8 @@
     private OrderDetlService orderDetlService;
     @Autowired
     private OrderService orderService;
+    @Autowired
+    private ManPakOutService manPakOutService;
 
     public ReturnT<String> start(WrkMast wrkMast) {
         // 4.鍏ュ簱瀹屾垚
@@ -111,6 +113,7 @@
                             locDetl.setAppeTime(now);
                             locDetl.setOwner(wrkDetl.getOwner());
                             locDetl.setPayment(wrkDetl.getPayment());
+                            locDetl.setWeight(wrkDetl.getWeight());
                             if (!locDetlService.insert(locDetl)) {
 //                                exceptionHandle("鍏ㄦ澘鍏ュ簱 ===>> 娣诲姞搴撳瓨鏄庣粏澶辫触锛沎workNo={0}],[locNo={1}]", wrkMast.getWrkNo(), wrkMast.getLocNo());
                                 TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
@@ -180,6 +183,21 @@
                             }
                         } catch (Exception ignore){}
 
+                        //鏇存柊鎷h揣鍗曞畬鎴愭暟閲�
+                        EntityWrapper<ManPakOut> manPakOutEntityWrapper = new EntityWrapper<>();
+                        manPakOutEntityWrapper.eq("doc_num",wrkDetl.getOrderNo());
+                        manPakOutEntityWrapper.eq("matnr",wrkDetl.getMatnr());
+                        ManPakOut manPakOut = manPakOutService.selectOne(manPakOutEntityWrapper);
+                        if (!Cools.isEmpty(manPakOut)){
+                            if (manPakOut.getCount() + wrkDetl.getAnfme() >= manPakOut.getAnfme()){
+                                manPakOut.setStatus(1);
+                            }
+                            manPakOut.setCount(manPakOut.getCount() + wrkDetl.getAnfme());
+                            if (!manPakOutService.update(manPakOut,manPakOutEntityWrapper)){
+                                return FAIL.setMsg("鏇存柊鎷h揣鍗曞畬鎴愭暟閲忓け璐�");
+                            }
+                        }
+
                     }
                     // 淇敼搴撲綅鐘舵�� Q ====>> F
                     if (locMast.getLocSts().equals("Q")) {
@@ -195,6 +213,45 @@
                     }
                     break;
                 // 骞舵澘鍏ュ簱
+                case 55:
+                    // 鏍规嵁宸ヤ綔鍙凤紝鏌ヨ宸ヤ綔鏄庣粏妗�
+                    List<WrkDetl> wrkDetls55 = wrkDetlService.selectList(new EntityWrapper<WrkDetl>().eq("wrk_no", wrkMast.getWrkNo()));
+                    if (wrkDetls55.isEmpty()) {
+//                        exceptionHandle("骞舵澘鍏ュ簱 ===>> 宸ヤ綔鏄庣粏妗d负绌猴紱[workNo={0}]", wrkMast.getWrkNo());
+                        TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
+                        return FAIL.setMsg("骞舵澘鍏ュ簱 ===>> 宸ヤ綔鏄庣粏妗d负绌�; [workNo=" + wrkMast.getWrkNo() + "],[locNo=" + wrkMast.getLocNo() + "]");
+                    }
+                    // 淇敼搴撳瓨鏄庣粏鏁伴噺锛屽鏃犲簱瀛橈紝鏇炬柊澧�
+                    for (WrkDetl wrkDetl:wrkDetls55) {
+
+                        LocDetl locDetl = locDetlService.selectOne(new EntityWrapper<LocDetl>().eq("loc_no", locMast.getLocNo()));
+                        locDetlService.delete(new EntityWrapper<LocDetl>().eq("loc_no", locDetl.getLocNo()));
+                        locDetl = new LocDetl();
+                        locDetl.sync(wrkDetl);
+                        locDetl.setLocNo(wrkMast.getLocNo()); // 搴撲綅鍙�
+                        locDetl.setAnfme(wrkDetl.getAnfme()); // 鏁伴噺
+                        locDetl.setZpallet(wrkDetl.getZpallet()); // 鎵樼洏鏉$爜
+                        locDetl.setModiTime(now);
+                        locDetl.setAppeTime(now);
+                        if (!locDetlService.insert(locDetl)) {
+//                                exceptionHandle("骞舵澘鍏ュ簱 ===>> 鏂板搴撳瓨鏄庣粏澶辫触锛沎workNo={0}],[matnr={1}]", wrkMast.getWrkNo(), wrkDetl.getMatnr());
+                            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
+                            return FAIL.setMsg("骞舵澘鍏ュ簱 ===>> 鏂板搴撳瓨鏄庣粏澶辫触; [workNo=" + wrkMast.getWrkNo() + "],[locNo=" + wrkMast.getLocNo() + "]");
+                        }
+                    }
+                    // 淇敼搴撲綅鐘舵�� Q ====>> F
+                    if (locMast.getLocSts().equals("Q")) {
+                        locMast.setLocSts("F");
+                        locMast.setBarcode(wrkMast.getBarcode());
+                        locMast.setIoTime(now);
+                        locMast.setModiTime(now);
+                        if (!locMastService.updateById(locMast)) {
+//                            exceptionHandle("骞舵澘鍏ュ簱 ===>> 淇敼搴撲綅鐘舵�佸け璐ワ紱[workNo={0}],[locNo={1}]", wrkMast.getWrkNo(), wrkMast.getLocNo());
+                            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
+                            return FAIL.setMsg("骞舵澘鍏ュ簱 ===>> 淇敼搴撲綅鐘舵�佸け璐�; [workNo=" + wrkMast.getWrkNo() + "],[locNo=" + wrkMast.getLocNo() + "]");
+                        }
+                    }
+                    break;
                 case 54:
                     // 鏍规嵁宸ヤ綔鍙凤紝鏌ヨ宸ヤ綔鏄庣粏妗�
                     List<WrkDetl> wrkDetls54 = wrkDetlService.selectList(new EntityWrapper<WrkDetl>().eq("wrk_no", wrkMast.getWrkNo()));
@@ -241,6 +298,7 @@
                         }
                     }
                     break;
+
                 // 鐩樼偣鍏ュ簱
                 case 57:
                     // 鏍规嵁宸ヤ綔鍙凤紝鏌ヨ宸ヤ綔鏄庣粏妗�
@@ -322,10 +380,10 @@
     }
 
     private ReturnT<String> doOut(WrkMast wrkMast){
-        Date now = new Date();
-        LocMast locMast = locMastService.selectById(wrkMast.getSourceLocNo());
+        Date now = new Date(); //鑾峰彇褰撳墠鐨勬椂闂�
+        LocMast locMast = locMastService.selectById(wrkMast.getSourceLocNo()); //鑾峰彇宸ヤ綔妗�
         try {
-            if (null == locMast) {
+            if (null == locMast) { //濡傛灉宸ヤ綔妗d负绌猴紝鎶涘嚭寮傚父
 //                exceptionHandle("宸ヤ綔妗workNo={0}]搴撲綅鍙烽敊璇痆locNo={1}]", wrkMast.getWrkNo(), wrkMast.getLocNo());
                 TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
                 return FAIL.setMsg("宸ヤ綔妗e簱浣嶅彿閿欒; [workNo=" + wrkMast.getWrkNo() + "],[locNo=" + wrkMast.getLocNo() + "]");
@@ -346,17 +404,7 @@
                         return FAIL.setMsg("鍏ㄦ澘鍑哄簱 ===>> 宸ヤ綔鏄庣粏妗d负绌�; [workNo=" + wrkMast.getWrkNo() + "],[locNo=" + wrkMast.getSourceLocNo() + "]");
                     }
 
-                    Boolean finsihed = orderDetlService.checkAllDetlFinish(wrkDetls101.get(0).getOrderNo());
-                    if (finsihed) {
-                        Boolean mastFinished = wrkMastService.checkFinishByOrder(wrkDetls101.get(0).getOrderNo());
-                        if (mastFinished) {
-                            Order order = orderService.selectByNo(wrkDetls101.get(0).getOrderNo());
-                            if (!Cools.isEmpty(order)) {
-                                orderService.updateSettle(order.getId(),4L,1L);
 
-                            }
-                        }
-                    }
 
                     // 鍒犻櫎宸ヤ綔妗f簮搴撲綅鐨勫簱瀛樻槑缁�
                     if (!locDetlService.delete(new EntityWrapper<LocDetl>().eq("loc_no", wrkMast.getSourceLocNo()))) {
@@ -376,6 +424,58 @@
                             return FAIL.setMsg("鍏ㄦ澘鍑哄簱 ===>> 淇敼婧愬簱浣嶇姸鎬佸け璐�; [workNo=" + wrkMast.getWrkNo() + "],[locNo=" + wrkMast.getSourceLocNo() + "]");
                         }
                     }
+
+                    for (WrkDetl wrkDetl: wrkDetls101) {
+                        if(Cools.isEmpty(wrkDetl)){
+                            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
+                            return FAIL.setMsg("鍏ㄦ澘鍑哄簱 ===>> 浠诲姟鏄庣粏涓虹┖; [workNo=" + wrkMast.getWrkNo() + "],[locNo=" + wrkMast.getSourceLocNo() + "]");
+                        }
+                        if (!wrkDetl.getOrderNo().isEmpty()){
+                            //鏇存柊璁㈠崟瀹屾垚鏁伴噺
+                            EntityWrapper<OrderDetl> orderDetlEntityWrapper = new EntityWrapper<>();
+                            orderDetlEntityWrapper.eq("order_no",wrkDetl.getOrderNo());
+                            orderDetlEntityWrapper.eq("matnr",wrkDetl.getMatnr());
+
+                            OrderDetl orderDetl = orderDetlService.selectOne(orderDetlEntityWrapper);
+
+                            OrderDetl orderDetl1 = new OrderDetl();
+                            orderDetl1.setQty(orderDetl.getQty() + wrkDetl.getAnfme());
+                            orderDetl1.setUpdateTime(now);
+                            if (!orderDetlService.update(orderDetl1,orderDetlEntityWrapper)){
+                                return FAIL.setMsg("鏇存柊璁㈠崟瀹屾垚鏁伴噺澶辫触");
+                            }
+                            //鏇存柊绔嬪簱鎷h揣鍗曞畬鎴愭暟閲�
+                            EntityWrapper<ManPakOut> manPakOutEntityWrapper = new EntityWrapper<>();
+                            manPakOutEntityWrapper.eq("doc_num",wrkDetl.getOrderNo());
+                            manPakOutEntityWrapper.eq("matnr",wrkDetl.getMatnr());
+                            manPakOutEntityWrapper.eq("loc_no","绔嬪簱");
+                            ManPakOut manPakOut = manPakOutService.selectOne(manPakOutEntityWrapper);
+                            if (manPakOut.getCount() + wrkDetl.getAnfme() >= manPakOut.getAnfme()){
+                                manPakOut.setStatus(1);
+                            }
+                            manPakOut.setCount(manPakOut.getCount() + wrkDetl.getAnfme());
+                            if (!manPakOutService.update(manPakOut,manPakOutEntityWrapper)){
+                                return FAIL.setMsg("鏇存柊鎷h揣鍗曞畬鎴愭暟閲忓け璐�");
+                            }
+                        }
+                    }
+
+
+
+
+                    Boolean finsihed = orderDetlService.checkAllDetlFinish(wrkDetls101.get(0).getOrderNo());
+                    if (finsihed) {
+                        Boolean mastFinished = wrkMastService.checkFinishByOrder(wrkDetls101.get(0).getOrderNo());
+                        if (mastFinished) {
+                            Order order = orderService.selectByNo(wrkDetls101.get(0).getOrderNo());
+                            if (!Cools.isEmpty(order)) {
+                                orderService.updateSettle(order.getId(),4L,1L);
+
+                            }
+                        }
+                    }
+
+
                     break;
                 // 绌烘澘鍑哄簱
                 case 110:

--
Gitblit v1.9.1