From 5568f3df818971733006b5630ff46b81e04b9052 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E7=BB=ABUmbrella?= <2539020564@qq.com>
Date: Wed, 1 Apr 2026 15:35:09 +0800
Subject: [PATCH] =?UTF-8?q?=E7=89=A9=E6=B5=81=E6=94=B9=E5=86=99?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../desk/logistics/pojo/dto/OrderBindDto.java |  5 ++
 .../desk/logistics/mapper/OrderBindMapper.xml |  3 +
 .../desk/logistics/mapper/StationMapper.java  |  6 +-
 .../desk/logistics/mapper/StationMapper.xml   | 59 +++++++++----
 .../service/impl/StationServiceImpl.java      | 88 ++-----------------
 5 files changed, 64 insertions(+), 97 deletions(-)

diff --git a/blade-service-api/blade-desk-api/src/main/java/org/springblade/desk/logistics/pojo/dto/OrderBindDto.java b/blade-service-api/blade-desk-api/src/main/java/org/springblade/desk/logistics/pojo/dto/OrderBindDto.java
index e8863ccb..55ce993c 100644
--- a/blade-service-api/blade-desk-api/src/main/java/org/springblade/desk/logistics/pojo/dto/OrderBindDto.java
+++ b/blade-service-api/blade-desk-api/src/main/java/org/springblade/desk/logistics/pojo/dto/OrderBindDto.java
@@ -15,6 +15,11 @@ public class OrderBindDto {
      */
     @Schema(description = "箱条码")
     private String boxBarcode;
+    /**
+     * 流程卡号
+     */
+    @Schema(description = "流程卡号")
+    private String cardNo;
     /**
      * 开始时间
      */
diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/mapper/OrderBindMapper.xml b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/mapper/OrderBindMapper.xml
index d8b2b85a..5cc0eb23 100644
--- a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/mapper/OrderBindMapper.xml
+++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/mapper/OrderBindMapper.xml
@@ -14,6 +14,9 @@
         <if test="orderBindDto.boxBarcode != null and orderBindDto.boxBarcode != ''">
             AND O.BOX_BARCODE LIKE '%' || #{orderBindDto.boxBarcode} || '%'
         </if>
+        <if test="orderBindDto.cardNo != null and orderBindDto.cardNo != ''">
+            AND O.CARD_NO LIKE '%' || #{cardNo} || '%'
+        </if>
         <!-- 修复2：参数引用错误，补充 orderBindDto. 前缀 -->
         <if test="orderBindDto.bindingStatus != null and orderBindDto.bindingStatus != ''">
             AND O.BINDING_STATUS = #{orderBindDto.bindingStatus}
diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/mapper/StationMapper.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/mapper/StationMapper.java
index 147e6175..dae98b0c 100644
--- a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/mapper/StationMapper.java
+++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/mapper/StationMapper.java
@@ -16,5 +16,9 @@ public interface StationMapper extends BaseMapper<Station> {
 
     List<StationVO> selectStationList(IPage<StationVO> page, @Param("station") Station station);
 
-    List<StationVO> getStatusStationList(@Param("stationStatus")Integer stationStatus,@Param("stationStatusInclude") boolean stationStatusInclude, @Param("wcId")Long wcId, @Param("status")Integer status, @Param("include")boolean include);
+    long selectStationListCount(@Param("station") Station station);
+
+    List<StationVO> getStatusStationList(@Param("stationStatus")Integer stationStatus,
+                                         @Param("stationStatusInclude") boolean stationStatusInclude, @Param("wcId")Long wcId, @Param("status")Integer status,
+                                         @Param("include")boolean include);
 }
diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/mapper/StationMapper.xml b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/mapper/StationMapper.xml
index 040565d9..ca998b69 100644
--- a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/mapper/StationMapper.xml
+++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/mapper/StationMapper.xml
@@ -28,16 +28,43 @@
         l.create_dept,
         l.update_user,
         l.update_time,
-        l.is_deleted,
-        l.remark,
         l.station_position,
-        r.WC_ID as wcId
+        (select LISTAGG(w.wc_name, '、') WITHIN GROUP (ORDER BY w.wc_name)
+         from LM_STATION_CENTER r
+         left join BS_WORK_CENTER w on r.WC_ID = w.id
+         where r.STATION_ID = l.id) as wc_name
         from LM_STATION l
-        left join LM_STATION_CENTER r
-        on l.id = r.STATION_ID
+        where l.IS_DELETED = 0
+
+        <if test="station.stationName != null and station.stationName != ''">
+            and l.STATION_NAME like '%' || #{station.stationName} || '%'
+        </if>
+
+        <if test="station.stationCode != null and station.stationCode != ''">
+            and l.STATION_CODE like '%' || #{station.stationCode} || '%'
+        </if>
+
+        <if test="station.stationStatus != null">
+            and l.STATION_STATUS = #{station.stationStatus}
+        </if>
+
+        <if test="station.stationPosition != null and station.stationPosition != ''">
+            and l.STATION_POSITION = #{station.stationPosition}
+        </if>
+
         <if test="station.wcId != null">
-            and r.WC_ID = #{station.wcId}
+            and exists (
+                select 1 from LM_STATION_CENTER r2
+                where r2.STATION_ID = l.id and r2.WC_ID = #{station.wcId}
+            )
         </if>
+
+        order by l.create_time desc
+    </select>
+
+    <select id="selectStationListCount" resultType="long">
+        select count(*)
+        from LM_STATION l
         where l.IS_DELETED = 0
 
         <if test="station.stationName != null and station.stationName != ''">
@@ -55,16 +82,22 @@
         <if test="station.stationPosition != null and station.stationPosition != ''">
             and l.STATION_POSITION = #{station.stationPosition}
         </if>
-    </select>
 
+    </select>
 
     <select id="getStatusStationList" resultType="org.springblade.desk.logistics.pojo.vo.StationVO">
         select l.*, r.WC_ID as wcId
         from LM_STATION l
-        left join LM_STATION_CENTER r on l.id = r.STATION_ID
+        left join LM_STATION_CENTER r
+        on l.id = r.STATION_ID
+        <!-- wcId 条件放到 on 中，不破坏左连接 -->
+        <if test="wcId != null">
+            and r.WC_ID = #{wcId}
+        </if>
         where l.IS_DELETED = 0
 
-        <if test="stationStatus != null and stationStatus != ''">
+        <!-- 去掉 stationStatus 的空字符串判断 -->
+        <if test="stationStatus != null">
             <if test="stationStatusInclude">
                 and l.STATION_STATUS = #{stationStatus}
             </if>
@@ -73,12 +106,8 @@
             </if>
         </if>
 
-        <if test="wcId != null and wcId != ''">
-            and r.WC_ID = #{wcId}
-        </if>
-
-        <!-- 修正：不等于语法错误 + 格式规范 -->
-        <if test="status != null and status != ''">
+        <!-- 去掉 status 的空字符串判断 -->
+        <if test="status != null">
             <if test="include">
                 and l.STATUS = #{status}
             </if>
diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/StationServiceImpl.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/StationServiceImpl.java
index 92a1109e..755517f7 100644
--- a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/StationServiceImpl.java
+++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/StationServiceImpl.java
@@ -31,19 +31,13 @@ import lombok.extern.slf4j.Slf4j;
 import org.springblade.core.log.exception.ServiceException;
 import org.springblade.core.mp.base.BaseServiceImpl;
 import org.springblade.core.tool.api.R;
-import org.springblade.desk.basic.pojo.entity.WorkCenter;
-import org.springblade.desk.basic.service.IWorkCenterService;
 import org.springblade.desk.logistics.mapper.StationMapper;
 import org.springblade.desk.logistics.pojo.entity.Station;
 import org.springblade.desk.logistics.pojo.vo.StationVO;
 import org.springblade.desk.logistics.service.IStationService;
-import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
-import org.springframework.util.CollectionUtils;
-import org.springframework.util.StringUtils;
 
-import java.util.*;
-import java.util.stream.Collectors;
+import java.util.List;
 
 /**
  * 物流站点 服务类
@@ -55,10 +49,6 @@ import java.util.stream.Collectors;
 @Slf4j
 public class StationServiceImpl extends BaseServiceImpl<StationMapper, Station> implements IStationService {
 
-
-    @Autowired
-    IWorkCenterService workCenterService;
-
     @Override
     public List<Station> selectByWcId(Long wcId) {
         return baseMapper.selectByWcId(wcId);
@@ -83,77 +73,13 @@ public class StationServiceImpl extends BaseServiceImpl<StationMapper, Station>
 
     @Override
     public IPage<StationVO> getStationList(IPage<StationVO> page, Station station) {
-        List<StationVO> stationList = baseMapper.selectStationList(page, station);
-
-        if (CollectionUtils.isEmpty(stationList)) {
-            return page.setRecords(stationList);
-        }
-
-        // 填充工作中心名称
-        for (StationVO stationVO : stationList) {
-            if (null != stationVO && null != stationVO.getWcId()) {
-                WorkCenter workCenter = workCenterService.getById(stationVO.getWcId());
-                if (null != workCenter && !StringUtils.isEmpty(workCenter.getWcName())) {
-                    stationVO.setWcName(workCenter.getWcName());
-                }
-            }
-        }
-
-        // 合并数据：除wcId和wcName外其他字段相同的记录，wcName用顿号拼接
-        List<StationVO> mergedList = mergeStationList(stationList);
-
-        // 更新 total 为合并后的实际记录数
-        page.setTotal(mergedList.size());
-
-        return page.setRecords(mergedList);
-    }
-
-    /**
-     * 合并站点列表：除wcId和wcName外其他字段相同的记录，wcName用顿号拼接
-     */
-    private List<StationVO> mergeStationList(List<StationVO> stationList) {
-        // 使用Map分组，key为除wcId和wcName外的其他字段组合
-        Map<String, List<StationVO>> groupMap = new LinkedHashMap<>();
-
-        for (StationVO vo : stationList) {
-            String key = buildGroupKey(vo);
-            groupMap.computeIfAbsent(key, k -> new ArrayList<>()).add(vo);
-        }
-
-        List<StationVO> result = new ArrayList<>();
-        for (List<StationVO> group : groupMap.values()) {
-            if (group.size() == 1) {
-                result.add(group.get(0));
-            } else {
-                // 合并：保留第一条，wcName用顿号拼接（去重）
-                StationVO merged = group.get(0);
-                String mergedWcName = group.stream()
-                    .map(StationVO::getWcName)
-                    .filter(name -> !StringUtils.isEmpty(name))
-                    .distinct()
-                    .collect(Collectors.joining("、"));
-                merged.setWcName(mergedWcName);
-                result.add(merged);
-            }
-        }
-
-        return result;
-    }
+        // 先查询总数（使用自定义 count 避免拼接导致的不准确）
+        long total = baseMapper.selectStationListCount(station);
+        page.setTotal(total);
 
-    /**
-     * 构建分组key（排除wcId和wcName）
-     */
-    private String buildGroupKey(StationVO vo) {
-        // 使用站点核心字段构建分组key
-        return String.join("|",
-            String.valueOf(vo.getId()),
-            vo.getStationName(),
-            vo.getStationPosition(),
-            vo.getStationCode(),
-            String.valueOf(vo.getStationStatus()),
-            vo.getRemark(),
-            vo.getStationRegion()
-        );
+        // 再查询列表
+        List<StationVO> stationVOS = baseMapper.selectStationList(page, station);
+        return page.setRecords(stationVOS);
     }
 
     @Override