From 7299282e6d9bfb7cf008477c2af888b3930bd716 Mon Sep 17 00:00:00 2001
From: zhangc <zc@123>
Date: 星期四, 20 二月 2025 10:46:49 +0800
Subject: [PATCH] 兼容四期

---
 src/main/java/com/zy/asrs/service/impl/AgvLocDetlServiceImpl.java |   60 ++++++++++++++++++++++++++++++++++++++++++++++++++++++------
 1 files changed, 54 insertions(+), 6 deletions(-)

diff --git a/src/main/java/com/zy/asrs/service/impl/AgvLocDetlServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/AgvLocDetlServiceImpl.java
index a9c2d01..f7791fb 100644
--- a/src/main/java/com/zy/asrs/service/impl/AgvLocDetlServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/AgvLocDetlServiceImpl.java
@@ -7,7 +7,11 @@
 import com.core.common.Cools;
 import com.core.common.SnowflakeIdWorker;
 import com.core.exception.CoolException;
-import com.zy.asrs.entity.*;
+import com.zy.asrs.constant.AsrsConstants;
+import com.zy.asrs.entity.AgvLocDetl;
+import com.zy.asrs.entity.AgvLocMast;
+import com.zy.asrs.entity.AgvWrkDetl;
+import com.zy.asrs.entity.OrderDetl;
 import com.zy.asrs.mapper.AgvLocDetlMapper;
 import com.zy.asrs.service.*;
 import com.zy.asrs.utils.Utils;
@@ -55,9 +59,10 @@
         long flowId = snowflakeIdWorker.nextId();
         agvWrkDetls.stream().map(agvWrkDetl -> {
             AgvLocDetl agvLocDetl = new AgvLocDetl();
-            log.info("agvWrkDetl: " + agvLocDetl.getBarcode());
+            //log.info("agvWrkDetl: " + agvLocDetl.getBarcode());
             BeanUtils.copyProperties(agvWrkDetl, agvLocDetl);
             agvLocDetl.setLocNo(locNo);
+            //log.info("zc娣诲姞搴撳瓨鏃ュ織:{}", JSON.toJSON(agvLocDetl));
             this.insert(agvLocDetl);
             // 娴佹按 -- 鏂板璁㈠崟鏄庣粏
             OrderDetl orderDetl = orderDetlService.selectItem(agvWrkDetl.getOrderNo(), agvWrkDetl.getMatnr(), agvWrkDetl.getBatch(), agvWrkDetl.getThreeCode());
@@ -95,17 +100,27 @@
         //鏍规嵁鐗╂枡鍙峰拰鎵规鎵惧埌瀵瑰簲鐨勫簱瀛橈紝骞朵笖鎸夌収淇敼鏃堕棿鎺掑簭
         Wrapper<AgvLocDetl> wrapper = new EntityWrapper<AgvLocDetl>().eq("matnr", matnr).orderBy("modi_time");
         if (type != null) {
-            wrapper.notLike("loc_no", "F1");
+            if (type.equals(AsrsConstants.ERCHANG)) {
+                wrapper.notLike("loc_no", "F3");
+            } else {
+                if (matnr.startsWith("401") || matnr.startsWith("402")) {
+                    //wrapper.notLike("loc_no", "F3");
+                } else {
+                    wrapper.notLike("loc_no", "F1");
+                }
+            }
         }
-        wapperSetCondition(wrapper, "batch", batch);
+        //涓�鐩存湁PE甯︽壒娆″瓧娈靛鑷达紝鏃犳硶鍑哄簱锛屽氨娉ㄩ噴鎺�
+        //wapperSetCondition(wrapper, "batch", batch);
         wapperSetCondition(wrapper, "three_code", csocode);
-        wapperSetCondition(wrapper, "dead_time", isoseq);
+        //wapperSetCondition(wrapper, "dead_time", isoseq);
 
         if ("JG".equals(orderNo.substring(0, 2))) {
             wapperSetCondition(wrapper, "process_sts", "1");
         }
 
         List<AgvLocDetl> agvLocDetls = this.selectList(wrapper);
+
 
         for (AgvLocDetl agvLocDetl : agvLocDetls) {
             //鍒ゆ柇褰撳墠搴撲綅璐х墿鏄惁F鍦ㄥ簱
@@ -131,7 +146,39 @@
                 //褰撳墠搴撲綅鎵�澶勬ゼ灞�
                 int floor = Integer.parseInt(agvLocDetl.getLocNo().split("F")[1]);
                 //locDto.setAgvStaNos(queryAgvStaNosByFloor(floor));
-                locDto.setAgvStaNos(agvBasDevpService.selectCacheShelvesStationCodeByLocType(agvLocMast.getLocType1(), floor));
+                //鍥涙湡
+                //locDto.setAgvStaNos(agvBasDevpService.selectCacheShelvesStationCodeByLocType(agvLocMast.getLocType1(), floor));
+
+                List<String> strings = agvBasDevpService.selectCacheShelvesStationCodeByLocType(agvLocMast.getLocType1());
+                List<String> agvStaNos = new ArrayList<>();
+                if (agvLocDetl.getLocNo().contains("01F1")) {
+                    for (String string : strings) {
+                        if (string.contains("F1") || string.contains("F4")) {
+                            agvStaNos.add(string);
+                        }
+                    }
+                } else if (agvLocDetl.getLocNo().contains("02F1")) {
+                    for (String string : strings) {
+                        if (string.contains("F1") || string.contains("F4")) {
+                            agvStaNos.add(string);
+                        }
+                    }
+                } else if (agvLocDetl.getLocNo().contains("F2")) {
+                    for (String string : strings) {
+                        if (string.contains("F2") || string.contains("F4")) {
+                            agvStaNos.add(string);
+                        }
+                    }
+                } else if (agvLocDetl.getLocNo().contains("F3")) {
+                    for (String string : strings) {
+                        if (string.contains("F3")) {
+                            agvStaNos.add(string);
+                        }
+                    }
+                } else {
+                    agvStaNos = strings;
+                }
+                locDto.setAgvStaNos(agvStaNos);
                 locDtoList.add(locDto);
 
                 issued -= anfme;
@@ -142,6 +189,7 @@
 
     }
 
+
     /*
     鏇存柊搴撳瓨鏄庣粏
      */

--
Gitblit v1.9.1