From 03ef11b551dfd2c62e9f1a45676c44b1d18af150 Mon Sep 17 00:00:00 2001
From: 18516761980 <4761516tqsxp>
Date: 星期五, 20 八月 2021 18:06:41 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/task/handler/WorkMastHandler.java |   43 ++++++++++++++++++++++++++++++-------------
 1 files changed, 30 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 7261645..c34bd07 100644
--- a/src/main/java/com/zy/asrs/task/handler/WorkMastHandler.java
+++ b/src/main/java/com/zy/asrs/task/handler/WorkMastHandler.java
@@ -6,6 +6,8 @@
 import com.zy.asrs.task.AbstractHandler;
 import com.zy.asrs.task.core.ReturnT;
 import com.zy.asrs.utils.VersionUtils;
+import com.zy.ints.entity.WaitMatin;
+import com.zy.ints.service.WaitMatinService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.interceptor.TransactionAspectSupport;
@@ -29,6 +31,8 @@
     private LocDetlService locDetlService;
     @Autowired
     private WaitPakinService waitPakinService;
+    @Autowired
+    private WaitMatinService waitMatinService;
 
     public ReturnT<String> start(WrkMast wrkMast) {
         // 4.鍏ュ簱瀹屾垚
@@ -91,18 +95,31 @@
                                 exceptionHandle("鍏ㄦ澘鍏ュ簱 ===>> 娣诲姞搴撳瓨鏄庣粏澶辫触锛沎workNo={0}],[locNo={1}]", wrkMast.getWrkNo(), wrkMast.getLocNo());
                             }
                         }
-                        // 鏇存柊鍏ュ簱閫氱煡妗� ioStatus ===>> Y
-                        try {
-                            WaitPakin setParam = new WaitPakin();
-                            setParam.setIoStatus("Y");
-                            boolean updateRes = waitPakinService.update(setParam
-                                    , new EntityWrapper<WaitPakin>().eq("zpallet", wrkDetl.getZpallet())
-                                            .eq("mat_no", wrkDetl.getMatNo())
-                                            .eq("qty", wrkDetl.getQty()));
-                            if (!updateRes && updateRes) {
-                                exceptionHandle("鍏ㄦ澘鍏ュ簱 ===>> 鏇存柊鍏ュ簱閫氱煡妗eけ璐ワ紱[workNo={0}]", wrkMast.getWrkNo());
+                        // 鏇存柊鍏ュ簱閫氱煡妗� ioStatus ===>> 2
+                        if(!"0".equals(wrkDetl.getBillNo()) || !"0".equals(wrkDetl.getSeqNo())){
+                            WaitMatin waitMatin = waitMatinService.selectOne(new EntityWrapper<WaitMatin>().eq("bill_no",wrkDetl.getBillNo()).eq("seq_no",wrkDetl.getSeqNo()));
+                            if(null != waitMatin && waitMatin.getInQty() >= waitMatin.getQty()){
+                                waitMatin.setIoStatus(2);
+                                waitMatin.setModiTime(new Date());
+                                boolean res = waitMatinService.update(waitMatin, new EntityWrapper<WaitMatin>().eq("bill_no",wrkDetl.getBillNo()).eq("seq_no",wrkDetl.getSeqNo()));
+                                if(!res){
+                                    exceptionHandle("鍏ㄦ澘鍏ュ簱 ===>> 鏇存柊鍏ュ簱閫氱煡妗eけ璐ワ紱[workNo={0}],[billNo={1}]", wrkMast.getWrkNo(),wrkDetl.getBillNo());
+                                }
                             }
-                        } catch (Exception ignore){}
+                        }
+
+                        //todo:鎻掑叆鍥炴姤妗�
+//                        try {
+//                            WaitPakin setParam = new WaitPakin();
+//                            setParam.setIoStatus("Y");
+//                            boolean updateRes = waitPakinService.update(setParam
+//                                    , new EntityWrapper<WaitPakin>().eq("zpallet", wrkDetl.getZpallet())
+//                                            .eq("mat_no", wrkDetl.getMatNo())
+//                                            .eq("qty", wrkDetl.getQty()));
+//                            if (!updateRes && updateRes) {
+//                                exceptionHandle("鍏ㄦ澘鍏ュ簱 ===>> 鏇存柊鍏ュ簱閫氱煡妗eけ璐ワ紱[workNo={0}]", wrkMast.getWrkNo());
+//                            }
+//                        } catch (Exception ignore){}
 
                     }
                     // 淇敼搴撲綅鐘舵�� S ====>> F
@@ -130,7 +147,7 @@
                             if (!locDetlService.updateAnfme(locDetl.getQty() - wrkDetl.getQty(), locMast.getLocNo(), wrkDetl.getMatNo())) {
                                 exceptionHandle("鎷f枡鍏ュ簱 ===>> 淇敼搴撳瓨鏄庣粏鏁伴噺澶辫触锛沎workNo={0}],[locNo={1}]", wrkMast.getWrkNo(), wrkMast.getLocNo());
                             }
-                            // todo:luxiaotao 3)淇敼鍑哄簱閫氱煡妗� status ==> Y
+                            // todo:luxiaotao 3)淇敼鍑哄簱閫氱煡妗� iostatus ==> Y
                         }
                     }
                     // 淇敼搴撲綅鐘舵�� Q ====>> F
@@ -155,7 +172,7 @@
                     for (WrkDetl wrkDetl:wrkDetls54) {
                         LocDetl locDetl = locDetlService.selectOne(new EntityWrapper<LocDetl>().eq("loc_no", locMast.getLocNo()).eq("mat_no", wrkDetl.getMatNo()));
                         if (null != locDetl) {
-                            if (!locDetlService.updateAnfme(wrkDetl.getQty(), locMast.getLocNo(), wrkDetl.getMatNo())) {
+                            if (!locDetlService.updateAnfme(wrkDetl.getQty()+locDetl.getQty(), locMast.getLocNo(), wrkDetl.getMatNo())) {
                                 exceptionHandle("骞舵澘鍏ュ簱 ===>> 淇敼搴撳瓨鏄庣粏鏁伴噺澶辫触锛沎workNo={0}],[matNo={1}]", wrkMast.getWrkNo(), wrkDetl.getMatNo());
                             }
                         } else {

--
Gitblit v1.9.1