From 410ae0faceda3c5f0dd3593f6c781e79f4714849 Mon Sep 17 00:00:00 2001
From: 野心家 <1051256694@qq.com>
Date: 星期一, 04 九月 2023 19:06:26 +0800
Subject: [PATCH] 电视机显示

---
 src/main/java/com/zy/asrs/task/handler/WorkMastHandler.java |   99 +++++++++++++++++++++++++++++++++++++++++++------
 1 files changed, 87 insertions(+), 12 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 3741792..f2f97af 100644
--- a/src/main/java/com/zy/asrs/task/handler/WorkMastHandler.java
+++ b/src/main/java/com/zy/asrs/task/handler/WorkMastHandler.java
@@ -8,6 +8,7 @@
 import com.core.exception.CoolException;
 import com.zy.asrs.entity.*;
 import com.zy.asrs.entity.param.CombParam;
+import com.zy.asrs.mapper.ReportQueryMapper;
 import com.zy.asrs.service.*;
 import com.zy.asrs.task.AbstractHandler;
 import com.zy.asrs.task.core.ReturnT;
@@ -52,6 +53,11 @@
 
     @Value("${mes.inPath}")
     private String inpath;
+
+    @Autowired
+    private PackQualifiedService packQualifiedService;
+    @Autowired
+    private ReportQueryMapper reportQueryMapper;
 
     public ReturnT<String> start(WrkMast wrkMast) {
         // 4.鍏ュ簱瀹屾垚
@@ -161,21 +167,25 @@
                                 locMast.setPackStatus(0);
                             }
                         }else {
+                            WrkDetl wrkDetl1 = wrkDetlService.selectOne(new EntityWrapper<WrkDetl>().eq("zpallet",locMast.getBarcode()));
                             locMast.setPackStatus(5);
                             TestMast testMast = testMastService.selectOne(new EntityWrapper<TestMast>()
-                                    .eq("barcode",locMast.getBarcode())
+                                    .eq("barcode",wrkDetl1.getMatnr())
                                     .eq("status",4)
                             );
                             testMast.setStatus(5);
                             testMast.setModiTime(new Date());
-                            if (!testMastService.update(testMast,new EntityWrapper<TestMast>().eq("barcode",locMast.getBarcode()).eq("status",4))){
+                            if (!testMastService.update(testMast,new EntityWrapper<TestMast>().eq("barcode",wrkDetl1.getMatnr()).eq("status",4))){
                                 throw new CoolException("鏇存敼娴嬭瘯鐘舵�佸け璐�");
                             }
                         }
+                        //鍏ュ簱鏍囪
+                        packQualifiedService.insertPackQualified(true,new Date(),wrkDetls.get(0).getMatnr());
                         //2.鍏ュ簱瀹屾垚涓婃姤
                         CombParam combParam = new CombParam();
-                        combParam.setPackNo(wrkMast.getBarcode());
+                        combParam.setPackNo(wrkDetls.get(0).getMatnr());
                         combParam.setLocNo(wrkMast.getLocNo());
+                        combParam.setBarcode(wrkMast.getBarcode());
                         if (locMast.getCrnNo()==1){
                             combParam.setPackSts(0);
                             combParam.setStepSts(2);
@@ -332,7 +342,6 @@
                         sourceLoc.setLocSts("O");
                         sourceLoc.setModiTime(now);
                         sourceLoc.setIoTime(now);
-                        sourceLoc.setFireStatus(0);
                         sourceLoc.setPackStatus(0);
                         if (!locMastService.updateById(sourceLoc)) {
 //                            exceptionHandle("搴撲綅绉昏浆 ===>> 淇敼婧愬簱浣嶇姸鎬佸け璐ワ紱[workNo={0}],[sourceLoc={1}]", wrkMast.getWrkNo(), wrkMast.getSourceLocNo());
@@ -345,42 +354,78 @@
                     locMast.setBarcode(wrkMast.getBarcode());
                     locMast.setIoTime(now);
                     locMast.setModiTime(now);
-                    locMast.setFireStatus(0);
+                    LocDetl locDetl = locDetlService.selectOne(new EntityWrapper<LocDetl>().eq("loc_no", locMast.getLocNo()));
+
 
                     boolean sign =false;
                     if (locMast.getLocType1().equals(sourceLoc.getLocType1())){
                         locMast.setPackStatus(packStatus);
+
+                        //寰呮祴搴撲綅杞祴璇曞簱浣�
                     }else if (locMast.getLocType1().equals((short)1) && sourceLoc.getLocType1().equals((short)3)){
                         locMast.setPackStatus(1);
+                        TestMast testMast = testMastService.selectOne(new EntityWrapper<TestMast>()
+                                .eq("loc_no",sourceLoc.getLocNo())
+                                .eq("user_id",locMast.getBarcode())
+                                .eq("barcode",locDetl.getMatnr())
+                        );
+                        if(!Cools.isEmpty(testMast)){
+                            testMast.setChannel(locMast.getChannel());
+                            testMast.setLocNo(wrkMast.getLocNo());
+                            testMast.setModiTime(new Date());
+                            testMast.setBarcode(locDetl.getMatnr());
+                            if (!testMastService.update(testMast,new EntityWrapper<TestMast>()
+                                    .eq("loc_no",sourceLoc.getLocNo())
+                                    .eq("user_id",locMast.getBarcode())
+                                    .eq("barcode",locDetl.getMatnr()))){
+                                throw new CoolException("鏇存敼娴嬭瘯鐘舵�佸け璐�");
+                            }
+                        }else {
+                            throw new CoolException("寰呮祴搴撲綅鏃犵墿");
+                        }
+
                     }else {
+                        //娴嬭瘯搴撲綅杞潤缃簱浣嶅拰NG搴撲綅
                         if (locMast.getLocType1().equals((short)4)){
                             locMast.setPackStatus(4); //4:NG
+                            //鍏ュ簱鏍囪
+                            packQualifiedService.insertPackQualified(true,new Date(),locDetl.getMatnr());
+                            //鍑哄簱鏍囪
+                            packQualifiedService.insertPackQualified(false,new Date(),locDetl.getMatnr());
                         }else {
                             locMast.setPackStatus(5); //5:闈欑疆涓�
+                            //鍏ュ簱鏍囪
+                            packQualifiedService.insertPackQualified(true,new Date(),locDetl.getMatnr());
+                            //鍑哄簱鏍囪
+                            packQualifiedService.insertPackQualified(false,new Date(),locDetl.getMatnr());
                         }
                         sign=true;
-                        if (locMast.getLocType1()==1 && sourceLoc.getLocType1()==2){
                             TestMast testMast = testMastService.selectOne(new EntityWrapper<TestMast>()
                                     .eq("loc_no",sourceLoc.getLocNo())
-                                    .eq("barcode",locMast.getBarcode())
+                                    .eq("barcode",locDetl.getMatnr())
                                     .eq("status",4)
                             );
                             testMast.setStatus(5);
+                            testMast.setLocNo(locMast.getLocNo());
                             testMast.setModiTime(new Date());
-                            if (!testMastService.update(testMast,new EntityWrapper<TestMast>().eq("loc_no",sourceLoc.getLocNo()).eq("barcode",locMast.getBarcode()).eq("status",4))){
+                            if (!testMastService.update(testMast,new EntityWrapper<TestMast>()
+                                    .eq("loc_no",sourceLoc.getLocNo())
+                                    .eq("barcode",locDetl.getMatnr())
+                                    .eq("status",4))){
                                 throw new CoolException("鏇存敼娴嬭瘯鐘舵�佸け璐�");
                             }
-                        }
+
                     }
                     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() + "]");
                     }
+
                     if (locMast.getCrnNo()==1 && sign){
                         //5.闈欑疆搴撲綅鍏ュ簱瀹屾垚涓婃姤
                         CombParam combParam = new CombParam();
-                        combParam.setPackNo(wrkMast.getBarcode());
+                        combParam.setPackNo(locDetl.getMatnr());
                         combParam.setLocNo(wrkMast.getLocNo());
                         if (locMast.getPackStatus()==4){
                             combParam.setPackSts(2);
@@ -465,12 +510,43 @@
                         locMast.setBarcode("");
                         locMast.setModiTime(now);
                         locMast.setIoTime(now);
-                        locMast.setFireStatus(0);
                         locMast.setPackStatus(0);
                         if (!locMastService.updateById(locMast)) {
 //                            exceptionHandle("鍏ㄦ澘鍑哄簱 ===>> 淇敼婧愬簱浣嶇姸鎬佸け璐ワ紱[workNo={0}],[sourceLocNo={1}]", wrkMast.getWrkNo(), wrkMast.getSourceLocNo());
                             TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
                             return FAIL.setMsg("鍏ㄦ澘鍑哄簱 ===>> 淇敼婧愬簱浣嶇姸鎬佸け璐�; [workNo=" + wrkMast.getWrkNo() + "],[locNo=" + wrkMast.getSourceLocNo() + "]");
+                        }else{
+                            //鍑哄簱鏍囪
+                            packQualifiedService.insertPackQualified(false,new Date(),wrkDetls101.get(0).getMatnr());
+                            //2.鍑哄簱瀹屾垚涓婃姤
+                           CombParam combParam = new CombParam();
+                            combParam.setPackNo(wrkDetls101.get(0).getMatnr());
+                            combParam.setLocNo(wrkMast.getLocNo());
+                            combParam.setBarcode(wrkMast.getBarcode());
+                            //鐩爣绔�206鍑哄簱
+                            if(wrkMast.getStaNo()==206){
+                                combParam.setPackSts(1);//OK
+                                combParam.setStepSts(7);//娴嬭瘯搴撳嚭搴撳畬鎴�
+                            }else if(wrkMast.getStaNo()==204){//NG 鍑哄簱
+                                //NG鍑哄簱淇敼娴嬭瘯妗g殑鐘舵�佷负5.宸茬Щ搴�
+                                TestMast testMast=testMastService.selectOne(new EntityWrapper<TestMast>()
+                                        .eq("user_id",wrkMast.getBarcode())
+                                        .eq("barcode",wrkDetls101.get(0).getMatnr()));
+                                combParam.setPackSts(2);//NG
+                                combParam.setStepSts(8);//NG鍑哄簱瀹屾垚
+                                testMast.setStatus(5);
+                                if(!testMastService.update(testMast,new EntityWrapper<TestMast>()
+                                        .eq("user_id",wrkMast.getBarcode())
+                                        .eq("barcode",wrkDetls101.get(0).getMatnr()))){
+                                    TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
+                                    return FAIL.setMsg("鍏ㄦ澘鍑哄簱 ===>> 淇敼娴嬭瘯琛ㄧ姸鎬佷负5澶辫触; [workNo=" + wrkMast.getWrkNo() + "],[locNo=" + wrkMast.getSourceLocNo() + "]");
+                                }
+                            }else if(wrkMast.getStaNo()==103){//鐩爣绔�103鍑哄簱
+                                combParam.setPackSts(1);//OK
+                                combParam.setStepSts(6);//闈欑疆搴撳嚭搴撳畬鎴�
+                            }
+                            combParam.setRequestTime(DateUtils.convert(now));
+                            new PostMesDataUtils().postMesData("MES绯荤粺",mesUrl,inpath,combParam);
                         }
                     }
                     break;
@@ -482,7 +558,6 @@
                         locMast.setBarcode("");
                         locMast.setModiTime(now);
                         locMast.setIoTime(now);
-                        locMast.setFireStatus(0);
                         locMast.setPackStatus(0);
                         if (!locMastService.updateById(locMast)) {
 //                            exceptionHandle("绌烘澘鍑哄簱 ===>> 淇敼婧愬簱浣嶇姸鎬佸け璐ワ紱[workNo={0}],[sourceLocNo={1}]", wrkMast.getWrkNo(), wrkMast.getSourceLocNo());

--
Gitblit v1.9.1