From 85deecd28f589f280a3db19fb35fcb6d9081b781 Mon Sep 17 00:00:00 2001
From: wang..123 <brook_w@163.com>
Date: 星期五, 18 二月 2022 09:57:18 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/task/handler/WorkMastHandler.java |   83 ++++++++++++++++++++++++++++++++---------
 1 files changed, 65 insertions(+), 18 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 819eb95..d6605e3 100644
--- a/src/main/java/com/zy/asrs/task/handler/WorkMastHandler.java
+++ b/src/main/java/com/zy/asrs/task/handler/WorkMastHandler.java
@@ -1,14 +1,10 @@
 package com.zy.asrs.task.handler;
 
 import com.baomidou.mybatisplus.mapper.EntityWrapper;
-import com.zy.asrs.entity.LocDetl;
-import com.zy.asrs.entity.LocMast;
-import com.zy.asrs.entity.WrkDetl;
-import com.zy.asrs.entity.WrkMast;
-import com.zy.asrs.service.LocDetlService;
-import com.zy.asrs.service.LocMastService;
-import com.zy.asrs.service.WrkDetlService;
-import com.zy.asrs.service.WrkMastService;
+import com.baomidou.mybatisplus.mapper.Wrapper;
+import com.core.common.Cools;
+import com.zy.asrs.entity.*;
+import com.zy.asrs.service.*;
 import com.zy.asrs.task.AbstractHandler;
 import com.zy.asrs.task.core.ReturnT;
 import com.zy.asrs.utils.VersionUtils;
@@ -19,6 +15,7 @@
 import com.zy.ints.service.WaitMatinService;
 import com.zy.ints.service.WaitMatoutService;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.interceptor.TransactionAspectSupport;
 
@@ -45,6 +42,15 @@
     private WaitMatoutService waitMatoutService;
     @Autowired
     private IoCompleteService ioCompleteService;
+    @Autowired
+    private PltBarcodeService pltBarcodeService;
+    @Autowired
+    private  MatCodeService matCodeService;
+    /**
+     * ERP鎺ュ彛鏄惁鍚敤
+     */
+    @Value("${erp.enabled}")
+    private Boolean erpEnabled;
 
     public ReturnT<String> start(WrkMast wrkMast) {
         // 4.鍏ュ簱瀹屾垚
@@ -69,6 +75,7 @@
                 case 10:
                     // 淇敼搴撲綅鐘舵��=D
                     if (locMast.getLocSts().equals("S") || locMast.getLocSts().equals("Q")) {
+                        locMast.setFullPlt(wrkMast.getFullPlt());
                         locMast.setLocSts("D");
                         locMast.setIoTime(now);
                         locMast.setModiTime(now);
@@ -91,25 +98,56 @@
                     }
                     // 閬嶅巻宸ヤ綔鏄庣粏锛屾洿鏂板簱瀛樻槑缁嗗拰鍏ュ簱閫氱煡妗�
                     for (WrkDetl wrkDetl : wrkDetls) {
-                        LocDetl locDetl = locDetlService.selectOne(new EntityWrapper<LocDetl>().eq("loc_no", wrkMast.getLocNo()).eq("mat_no", wrkDetl.getMatNo()));
+                        LocDetl locDetl = locDetlService.selectOne(new EntityWrapper<LocDetl>().eq("loc_no", wrkMast.getLocNo()).eq("mat_no", wrkDetl.getMatNo()).eq("supplier", wrkDetl.getSupplier()));
                         if (null != locDetl) {
-                            boolean res = locDetlService.updateAnfme(wrkDetl.getQty()+locDetl.getQty(), wrkMast.getLocNo(), wrkDetl.getMatNo());
+                            boolean res = locDetlService.updateAnfme(wrkDetl.getQty()+locDetl.getQty(), wrkMast.getLocNo(), wrkDetl.getMatNo(),wrkDetl.getSupplier());
+
+
                             if (!res) {
                                 exceptionHandle("鍏ㄦ澘鍏ュ簱 ===>> 鏇存柊搴撳瓨鏄庣粏澶辫触锛沎workNo={0}],[locNo={1}]", wrkMast.getWrkNo(), wrkMast.getLocNo());
                             }
                         } else {
+                            WrkDetl wrk_no = wrkDetlService.selectOne(new EntityWrapper<WrkDetl>()
+                                    .eq("wrk_no", wrkMast.getWrkNo()).eq("mat_no",wrkDetl.getMatNo()).eq("supplier",wrkDetl.getSupplier()));
+
+                            MatCode matCode = matCodeService.selectOne(new EntityWrapper<MatCode>().eq("mat_no", wrkDetl.getMatNo()));
                             locDetl = new LocDetl();
+                            
                             locDetl.setLocNo(wrkMast.getLocNo()); // 搴撲綅鍙�
+                            locDetl.setMemo(wrkMast.getMemo());
                             VersionUtils.setLocDetl(locDetl, wrkDetl); // 鐗堟湰鎺у埗
                             locDetl.setModiTime(now);
                             locDetl.setAppeTime(now);
+                            locDetl.setAllQty(wrk_no.getAllQty());
+                            locDetl.setAllWeight(wrk_no.getAllWeight());
+                            locDetl.setSource(wrk_no.getSource());
+                            locDetl.setVendor(wrk_no.getVendor());
+                            locDetl.setWeight(matCode.getWeight());
+                            locDetl.setQtyBox(matCode.getStr6());
+
+                            if (!Cools.isEmpty(wrk_no)){
+                                locDetl.setMemo(wrk_no.getMemo());
+                                locDetl.setSupplier(wrk_no.getSupplier());
+                            }
                             if (!locDetlService.insert(locDetl)) {
                                 exceptionHandle("鍏ㄦ澘鍏ュ簱 ===>> 娣诲姞搴撳瓨鏄庣粏澶辫触锛沎workNo={0}],[locNo={1}]", wrkMast.getWrkNo(), wrkMast.getLocNo());
                             }
                         }
 
-                        // 鏇存柊鍏ュ簱閫氱煡妗� ioStatus ====>> 2
-                        WaitMatin waitMatin = waitMatinService.selectOne(new EntityWrapper<WaitMatin>().eq("bill_no",wrkDetl.getBillNo()).eq("seq_no",wrkDetl.getSeqNo()));
+                    //鏇存柊缁勬墭鏁版嵁鐘舵�佷负鍏ュ簱瀹屾垚 IoStatus ====>> 2
+                    Wrapper<PltBarcode> wrapper = new EntityWrapper<PltBarcode>().eq("barcode", wrkDetl.getZpallet())
+                            .eq("bill_no", wrkDetl.getBillNo()).eq("seq_no", wrkDetl.getSeqNo()).eq("mat_no", wrkDetl.getMatNo());
+                    PltBarcode pltBarcode = pltBarcodeService.selectOne(wrapper);
+                    if(null != pltBarcode) {
+                        pltBarcode.setIoStatus(2);//鍏ュ簱瀹屾垚
+                        boolean res = pltBarcodeService.update(pltBarcode, wrapper);
+                        if(!res){
+//                                exceptionHandle("鍏ㄦ澘鍏ュ簱 ===>> 鏇存柊缁勬墭鏁版嵁澶辫触锛沎workNo={0}],[billNo={1}],[seqNo={2}]", wrkMast.getWrkNo(),wrkDetl.getBillNo(),wrkDetl.getSeqNo());
+                        }
+                    }
+
+                    // 鏇存柊鍏ュ簱閫氱煡妗� ioStatus ====>> 2
+                    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(now);
@@ -120,7 +158,7 @@
                         }
 
                         //鎻掑叆鍥炴姤妗� insert ====>> io_complete
-                        if("Y".equals(wrkMast.getLinkMis())){
+                        if(erpEnabled && "Y".equals(wrkMast.getLinkMis())){
                             IoComplete ioComplete = new IoComplete();
                             ioComplete.setBillNo(wrkDetl.getBillNo());
                             ioComplete.setSeqNo(wrkDetl.getSeqNo());
@@ -142,6 +180,7 @@
                     }
                     // 淇敼搴撲綅鐘舵�� S ====>> F
                     if (locMast.getLocSts().equals("S")) {
+                        locMast.setFullPlt(wrkMast.getFullPlt());
                         locMast.setLocSts("F");
                         locMast.setBarcode(wrkMast.getBarcode());
                         locMast.setIoTime(now);
@@ -162,7 +201,7 @@
                         // 淇敼搴撳瓨鏄庣粏鏁伴噺锛屽鏋滃伐浣滄槑缁嗘暟閲忎负0鏃讹紝鍒犻櫎搴撳瓨鏄庣粏
                         LocDetl locDetl = locDetlService.selectOne(new EntityWrapper<LocDetl>().eq("loc_no", locMast.getLocNo()).eq("mat_no", wrkDetl.getMatNo()));
                         if (null != locDetl) {
-                            if (!locDetlService.updateAnfme(locDetl.getQty() - wrkDetl.getQty(), locMast.getLocNo(), wrkDetl.getMatNo())) {
+                            if (!locDetlService.updateAnfme(locDetl.getQty() - wrkDetl.getQty(), locMast.getLocNo(), wrkDetl.getMatNo(),wrkDetl.getSupplier())) {
                                 exceptionHandle("鎷f枡鍏ュ簱 ===>> 淇敼搴撳瓨鏄庣粏鏁伴噺澶辫触锛沎workNo={0}],[locNo={1}]", wrkMast.getWrkNo(), wrkMast.getLocNo());
                             }
 
@@ -178,7 +217,7 @@
                             }
 
                             //鎻掑叆鍥炴姤妗� insert ====>> io_complete
-                            if("Y".equals(wrkMast.getLinkMis())){
+                            if(erpEnabled && "Y".equals(wrkMast.getLinkMis())){
                                 IoComplete ioComplete = new IoComplete();
                                 ioComplete.setBillNo(wrkDetl.getBillNo());
                                 ioComplete.setSeqNo(wrkDetl.getSeqNo());
@@ -200,6 +239,7 @@
                     }
                     // 淇敼搴撲綅鐘舵�� Q ====>> F
                     if (locMast.getLocSts().equals("Q")) {
+                        locMast.setFullPlt(wrkMast.getFullPlt());
                         locMast.setLocSts("F");
                         locMast.setBarcode(wrkMast.getBarcode());
                         locMast.setIoTime(now);
@@ -220,7 +260,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()+locDetl.getQty(), locMast.getLocNo(), wrkDetl.getMatNo())) {
+                            if (!locDetlService.updateAnfme(wrkDetl.getQty()+locDetl.getQty(), locMast.getLocNo(), wrkDetl.getMatNo(),wrkDetl.getSupplier())) {
                                 exceptionHandle("骞舵澘鍏ュ簱 ===>> 淇敼搴撳瓨鏄庣粏鏁伴噺澶辫触锛沎workNo={0}],[matNo={1}]", wrkMast.getWrkNo(), wrkDetl.getMatNo());
                             }
                         } else {
@@ -246,7 +286,7 @@
                         }
 
                         //鎻掑叆鍥炴姤妗� insert ====>> io_complete
-                        if("Y".equals(wrkMast.getLinkMis())){
+                        if(erpEnabled && "Y".equals(wrkMast.getLinkMis())){
                             IoComplete ioComplete = new IoComplete();
                             ioComplete.setBillNo(wrkDetl.getBillNo());
                             ioComplete.setSeqNo(wrkDetl.getSeqNo());
@@ -268,6 +308,7 @@
                     }
                     // 淇敼搴撲綅鐘舵�� Q ====>> F
                     if (locMast.getLocSts().equals("Q")) {
+                        locMast.setFullPlt(wrkMast.getFullPlt());
                         locMast.setLocSts("F");
                         locMast.setBarcode(wrkMast.getBarcode());
                         locMast.setIoTime(now);
@@ -286,6 +327,7 @@
                     }
                     // 淇敼搴撲綅鐘舵�� Q ====>> F
                     if (locMast.getLocSts().equals("Q")) {
+                        locMast.setFullPlt(wrkMast.getFullPlt());
                         locMast.setLocSts("F");
                         locMast.setBarcode(wrkMast.getBarcode());
                         locMast.setIoTime(now);
@@ -309,7 +351,9 @@
                     }
                     // 淇敼婧愬簱浣嶇姸鎬� ==> O
                     LocMast sourceLoc = locMastService.selectById(wrkMast.getSourceLocNo());
+                    String fullPlt = sourceLoc.getFullPlt();
                     if (null != sourceLoc) {
+                        sourceLoc.setFullPlt("N");
                         sourceLoc.setBarcode("");
                         sourceLoc.setLocSts("O");
                         sourceLoc.setModiTime(now);
@@ -319,6 +363,7 @@
                         }
                     }
                     // 淇敼鐩爣搴撲綅鐘舵�� ==> .locSts
+                    locMast.setFullPlt(fullPlt);
                     locMast.setLocSts(locSts);
                     locMast.setBarcode(wrkMast.getBarcode());
                     locMast.setIoTime(now);
@@ -371,7 +416,7 @@
                         }
 
                         //鎻掑叆鍥炴姤妗� insert ====>> io_complete
-                        if("Y".equals(wrkMast.getLinkMis())){
+                        if(erpEnabled && "Y".equals(wrkMast.getLinkMis())){
                             IoComplete ioComplete = new IoComplete();
                             ioComplete.setBillNo(wrkDetl.getBillNo());
                             ioComplete.setSeqNo(wrkDetl.getSeqNo());
@@ -396,6 +441,7 @@
                     }
                     // 淇敼婧愬簱浣嶇姸鎬� R ===>> O
                     if (locMast.getLocSts().equals("R")) {
+                        locMast.setFullPlt("N");
                         locMast.setLocSts("O");
                         locMast.setBarcode("");
                         locMast.setModiTime(now);
@@ -409,6 +455,7 @@
                 case 110:
                     // 淇敼搴撲綅鐘舵�� R ===>> O
                     if (locMast.getLocSts().equals("R")) {
+                        locMast.setFullPlt("N");
                         locMast.setLocSts("O");
                         locMast.setBarcode("");
                         locMast.setModiTime(now);

--
Gitblit v1.9.1