From 24bc9aa5888c7b98cf0a7d1bf05ec6c5624d3719 Mon Sep 17 00:00:00 2001
From: zhangc <zc@123>
Date: 星期一, 03 三月 2025 16:02:29 +0800
Subject: [PATCH] 四期

---
 src/main/java/com/zy/asrs/task/handler/AgvWrkMastHandler.java |   38 ++++++++++++++++++++++++++++++++------
 1 files changed, 32 insertions(+), 6 deletions(-)

diff --git a/src/main/java/com/zy/asrs/task/handler/AgvWrkMastHandler.java b/src/main/java/com/zy/asrs/task/handler/AgvWrkMastHandler.java
index d4694a5..762386d 100644
--- a/src/main/java/com/zy/asrs/task/handler/AgvWrkMastHandler.java
+++ b/src/main/java/com/zy/asrs/task/handler/AgvWrkMastHandler.java
@@ -7,6 +7,7 @@
 import com.core.common.Cools;
 import com.core.common.SnowflakeIdWorker;
 import com.core.exception.CoolException;
+import com.zy.asrs.constant.AsrsConstants;
 import com.zy.asrs.entity.*;
 import com.zy.asrs.entity.param.MesBuyPakinReportParam;
 import com.zy.asrs.entity.param.MesOrderReportParam;
@@ -15,6 +16,7 @@
 import com.zy.asrs.service.*;
 import com.zy.asrs.task.AbstractHandler;
 import com.zy.asrs.task.core.ReturnT;
+import com.zy.common.service.AgvCommonService;
 import lombok.Synchronized;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -115,6 +117,9 @@
     @Autowired
     private ReportDataService reportDataService;
 
+    @Autowired
+    private AgvCommonService agvCommonService;
+
 
     @Transactional
     public ReturnT<String> completedPutWayWrk(AgvWrkMast agvWrkMast) {
@@ -153,7 +158,7 @@
                 if (pltType != null) {
                     agvWrkMast.setPltType(pltType);
                 }
-                log.info("宸ヤ綔鍙�--{},浠撳簱缂栫爜锛歿}", agvWrkMast.getWrkNo(), agvWrkMast.getPltType());
+                //log.info("宸ヤ綔鍙�--{},浠撳簱缂栫爜锛歿}", agvWrkMast.getWrkNo(), agvWrkMast.getPltType());
             }
             agvWrkMast.setModiTime(new Date());
             //淇敼宸ヤ綔妗g姸鎬佷负207.搴撳瓨鏇存柊瀹屾垚
@@ -171,7 +176,7 @@
 
             switch (agvWrkMast.getIoType()) {
                 case 1:
-                    agvLocMastService.updateLocStsByLocNo(agvWrkMast.getLocNo(), "F", agvWrkMast.getBarcode(), agvWrkMast.getWhsType().shortValue());
+                    agvLocMastService.updateLocStsByLocNo(agvWrkMast.getLocNo(), "F", agvWrkMast.getBarcode(), agvWrkMast.getWhsType().shortValue(), agvWrkMast.getCtnNo());
                     //鏇存柊鐩爣搴撲綅鏄庣粏
                     log.info("鏇存柊鐩爣搴撲綅鏄庣粏 agvWrkMast.getLocNo(): " + agvWrkMast.getLocNo() + ", wrkNo: " + wrkNo);
                     agvLocDetlService.addLocDetlInfo(agvWrkMast.getLocNo(), wrkNo);
@@ -191,7 +196,7 @@
                     //鏇存柊搴撳瓨鏄庣粏
                     agvLocDetlService.updateStock(agvWrkMast.getSourceLocNo(), agvWrkMast.getLocNo());
                     //淇敼婧愬簱浣嶇姸鎬佷负O
-                    agvLocMastService.updateLocStsByLocNo(agvWrkMast.getSourceLocNo(), "O", "", null);
+                    agvLocMastService.updateLocStsByLocNo(agvWrkMast.getSourceLocNo(), "O", "", null, "");
                     break;
                 case 53:
                     //淇敼宸ヤ綔鍏氭槑缁�
@@ -254,7 +259,7 @@
                     });
                     // 鏇存柊绔欑偣 + 搴撲綅鐘舵��     婧愬簱浣嶆槸绔欑偣
                     agvBasDevpService.updateLocStsAndBarcodeByDevNo(agvWrkMast.getSourceLocNo(), "O", "", agvWrkMast.getWhsType().shortValue());
-                    agvLocMastService.updateLocStsByLocNo(agvWrkMast.getLocNo(), "F", agvWrkMast.getBarcode(), agvWrkMast.getWhsType().shortValue());
+                    agvLocMastService.updateLocStsByLocNo(agvWrkMast.getLocNo(), "F", agvWrkMast.getBarcode(), agvWrkMast.getWhsType().shortValue(), agvWrkMast.getCtnNo());
                     break;
                 case 58:
                     agvLocMastService.updateLocStsByLocNo(agvWrkMast.getLocNo(), "F", agvWrkMast.getBarcode(), agvWrkMast.getWhsType().shortValue());
@@ -421,10 +426,31 @@
                     wrkMast.setIoTime(now);
                     //浼樺厛绾�
                     wrkMast.setIoPri(300.0);
+
                     //婧愮珯鐐�
                     wrkMast.setSourceLocNo(agvWrkMast.getLocNo());
+
                     //鐩爣绔欑偣
-                    wrkMast.setLocNo(agvWrkMast.getSourceLocNo());
+                    if (agvWrkMast.getLocNo().startsWith("QO") && agvWrkMast.getLocNo().endsWith("F4") && Integer.valueOf(agvWrkMast.getBarcode().substring(0, 2)) == 30) {
+                        if (!agvWrkMast.getSourceLocNo().endsWith("02F1")) {
+                            AgvLocMast locByFloor = agvCommonService.getLocByLocRule(3, 1, AsrsConstants.ERCHANG,true);
+                            if (locByFloor != null) {
+                                AgvLocMast agvLocMast = agvLocMastService.selectById(agvWrkMast.getSourceLocNo());
+                                agvLocMast.setLocSts("O");
+                                agvLocMast.setModiTime(now);
+                                agvLocMastService.updateById(agvLocMast);
+                                wrkMast.setLocNo(locByFloor.getLocNo());
+                            } else {
+                                wrkMast.setLocNo(agvWrkMast.getSourceLocNo());
+                            }
+                        } else {
+                            wrkMast.setLocNo(agvWrkMast.getSourceLocNo());
+                        }
+                    } else {
+                        wrkMast.setLocNo(agvWrkMast.getSourceLocNo());
+                    }
+                    //wrkMast.setLocNo(agvWrkMast.getSourceLocNo());
+
                     //璐ф灦缂栫爜
                     wrkMast.setBarcode(agvWrkMast.getBarcode());
                     //璐ф灦绫诲瀷
@@ -439,7 +465,7 @@
                     if (!agvWrkMastService.insertByIncrease(wrkMast)) {
                         throw new CoolException("淇濆瓨宸ヤ綔妗eけ璐�");
                     }
-                    AgvLocMast agvLocMast = agvLocMastService.selectById(agvWrkMast.getSourceLocNo());
+                    AgvLocMast agvLocMast = agvLocMastService.selectById(wrkMast.getLocNo());
                     agvLocMast.setLocSts("S");
                     agvLocMast.setModiTime(now);
                     agvLocMastService.updateById(agvLocMast);

--
Gitblit v1.9.1