From bb7dd1f513149ecd2887895c807861fdd06a43f6 Mon Sep 17 00:00:00 2001
From: chen.lin <1442464845@qq.com>
Date: 星期三, 11 二月 2026 15:29:27 +0800
Subject: [PATCH] 展示库存明细

---
 rsf-server/src/main/java/com/vincent/rsf/server/manager/utils/LocManageUtil.java |   40 +++++++++++++++++++++++++++++++++++-----
 1 files changed, 35 insertions(+), 5 deletions(-)

diff --git a/rsf-server/src/main/java/com/vincent/rsf/server/manager/utils/LocManageUtil.java b/rsf-server/src/main/java/com/vincent/rsf/server/manager/utils/LocManageUtil.java
index f16250a..ac3d112 100644
--- a/rsf-server/src/main/java/com/vincent/rsf/server/manager/utils/LocManageUtil.java
+++ b/rsf-server/src/main/java/com/vincent/rsf/server/manager/utils/LocManageUtil.java
@@ -16,7 +16,6 @@
 
 import org.apache.commons.lang3.StringUtils;
 
-import javax.swing.*;
 import java.math.BigDecimal;
 import java.util.*;
 import java.util.stream.Collectors;
@@ -97,7 +96,10 @@
     public static List<LocItem> getEfficiencyFirstItemList(String matnrCode, String splrBatch, Double anfme) {
         LambdaQueryWrapper<LocItem> locItemQueryWrapper = new LambdaQueryWrapper<>();
         locItemQueryWrapper.eq(LocItem::getMatnrCode, matnrCode);
-        locItemQueryWrapper.eq(StringUtils.isNotBlank(splrBatch), LocItem::getBatch, splrBatch);
+        // 鏈夋壒娆℃椂锛氬尮閰嶅簱浣嶆壒娆�=璁㈠崟鎵规 鎴� 搴撲綅鎵规涓虹┖锛堟棤鎵规搴撳瓨鍙弬涓庡垎閰嶏紝閬垮厤璇垽搴撳瓨涓嶈冻锛�
+        if (StringUtils.isNotBlank(splrBatch)) {
+            locItemQueryWrapper.and(w -> w.eq(LocItem::getBatch, splrBatch).or().isNull(LocItem::getBatch));
+        }
         String applySql = String.format(
                 "EXISTS (SELECT 1 FROM man_loc ml " +
                         "WHERE ml.use_status = '%s'" +
@@ -128,8 +130,16 @@
     public static List<LocItem> getFirstInFirstOutItemList(String matnrCode, String splrBatch, Double anfme) {
         LambdaQueryWrapper<LocItem> locItemQueryWrapper = new LambdaQueryWrapper<>();
         locItemQueryWrapper.eq(LocItem::getMatnrCode, matnrCode);
-        locItemQueryWrapper.eq(StringUtils.isNotEmpty(splrBatch), LocItem::getBatch, splrBatch);
-        locItemQueryWrapper.orderByAsc(LocItem::getCreateTime);
+        // 鏈夋壒娆℃椂锛氬尮閰嶅簱浣嶆壒娆�=璁㈠崟鎵规 鎴� 搴撲綅鎵规涓虹┖锛堟棤鎵规搴撳瓨鍙弬涓庡垎閰嶏紝閬垮厤璇垽搴撳瓨涓嶈冻锛�
+        if (StringUtils.isNotBlank(splrBatch)) {
+            locItemQueryWrapper.and(w -> w.eq(LocItem::getBatch, splrBatch).or().isNull(LocItem::getBatch));
+        }
+        //濡傛灉鎵规涓嶄负绌猴紝鎸夋壒娆″厛鍚庡嚭搴�
+        if (StringUtils.isNotBlank(splrBatch)) {
+            locItemQueryWrapper.orderByAsc(LocItem::getBatch);
+        } else {
+            locItemQueryWrapper.orderByAsc(LocItem::getCreateTime);
+        }
         String applySql = String.format(
                 "EXISTS (SELECT 1 FROM man_loc ml " +
                         "WHERE ml.use_status = '%s'" +
@@ -209,12 +219,18 @@
                                 orderOutItemDto.setStaNos(maps);
                                 //鑾峰彇婊¤冻鏉′欢绔欑偣
                                 Set<String> stationSet = deviceSites.stream().map(DeviceSite::getSite).collect(Collectors.toSet());
+                                String sType = "H";
+                                //鑾峰彇楂樹綆绔欑偣绫诲瀷
+                                if (startsWithTwoChars(loc.getBarcode(), "31")) {
+                                    sType = "L";
+                                }
                                 //宸蹭娇鐢ㄧ珯鐐�
                                 Set<String> stas = stations.stream().map(BasStation::getStationName).collect(Collectors.toSet());
                                 BasStationService basStationService = SpringUtils.getBean(BasStationService.class);
                                 BasStation basStation = basStationService.getOne(new LambdaQueryWrapper<BasStation>()
                                         .eq(BasStation::getUseStatus, LocStsType.LOC_STS_TYPE_O.type)
                                         .in(BasStation::getStationName, stationSet)
+//                                        .eq(BasStation::getSType, sType)
                                         .notIn(!stas.isEmpty(), BasStation::getStationName, stas)
                                         .last("LIMIT 1"));
                                 stations.add(basStation);
@@ -225,7 +241,6 @@
                                 orderOutItemDto.setSitesNo(basStation.getStationName());
                             }
                         }
-
 
                         list.add(orderOutItemDto);
 
@@ -252,4 +267,19 @@
         return list;
     }
 
+    /**
+     * 妫�鏌ュ瓧绗︿覆鍓嶄袱涓瓧绗︽槸鍚﹀寘鍚寚瀹氬唴瀹�
+     *
+     * @param str    瑕佹鏌ョ殑瀛楃涓�
+     * @param target 鐩爣瀛楃涓诧紙闀垮害搴斾负2锛�
+     * @return 鏄惁鍖呭惈
+     */
+    public static boolean startsWithTwoChars(String str, String target) {
+        if (str == null || target == null || target.length() != 2) {
+            return false;
+        }
+        return str.length() >= 2 && str.substring(0, 2).equals(target);
+    }
+
+
 }

--
Gitblit v1.9.1