From 3738c51db53d1e6bac98785b22e953e106bd5485 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E7=BB=ABUmbrella?= <2539020564@qq.com>
Date: Wed, 1 Apr 2026 14:41:00 +0800
Subject: [PATCH 1/4] =?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

---
 .../logistics/service/impl/StorageMonitoringServiceImpl.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/StorageMonitoringServiceImpl.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/StorageMonitoringServiceImpl.java
index eeda28ed..76a0efee 100644
--- a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/StorageMonitoringServiceImpl.java
+++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/StorageMonitoringServiceImpl.java
@@ -100,7 +100,7 @@ public class StorageMonitoringServiceImpl implements IStorageMonitoringService {
 //                new LambdaQueryWrapper<Station>()
 //                        .eq(Station::getStationStatus, Station.STATUS_FREE) // 筛选条件：站点状态为空闲
 //        );
-        List<StationVO> stationList = stationService.getStatusStationList(Station.STATUS_FREE, true,null, null, false);
+        List<StationVO> stationList = stationService.getStatusStationList(Station.STATUS_FREE, true,null, Station.STATION_RECEIVE_ONLY, false);
         // 日志打印空闲站点数量，便于监控和问题排查
         log.info("【仓储监控】定时任务执行 - 查询到空闲站点数量：{}", stationList == null ? 0 : stationList.size());
 

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 2/4] =?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

From 3c75aeec355594f824c39e0a57dc6211d27d6148 Mon Sep 17 00:00:00 2001
From: pangyang <475446853@qq.com>
Date: Wed, 1 Apr 2026 16:26:08 +0800
Subject: [PATCH 3/4] =?UTF-8?q?=E8=B4=A8=E9=87=8F=E6=A3=80=E9=AA=8C?=
 =?UTF-8?q?=E7=AE=A1=E7=90=86=E5=BE=AA=E7=8E=AF=E4=BE=9D=E8=B5=96=E4=BF=AE?=
 =?UTF-8?q?=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/impl/InspectionTaskServiceImpl.java      | 12 ++++++++++--
 1 file changed, 10 insertions(+), 2 deletions(-)

diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/quality/service/impl/InspectionTaskServiceImpl.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/quality/service/impl/InspectionTaskServiceImpl.java
index 2f2bebc7..3b5768eb 100644
--- a/blade-service/blade-desk/src/main/java/org/springblade/desk/quality/service/impl/InspectionTaskServiceImpl.java
+++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/quality/service/impl/InspectionTaskServiceImpl.java
@@ -68,6 +68,8 @@ import org.springblade.system.feign.IDictClient;
 import org.springblade.system.feign.IUserClient;
 import org.springblade.system.pojo.entity.User;
 import org.springframework.beans.BeanUtils;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.ApplicationContextAware;
 import org.springframework.context.annotation.Lazy;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
@@ -91,7 +93,7 @@ import static com.fasterxml.jackson.databind.type.LogicalType.DateTime;
 @EqualsAndHashCode(callSuper = true)
 @Slf4j
 public class InspectionTaskServiceImpl extends BaseServiceImpl<InspectionTaskMapper, InspectionTask>
-        implements IInspectionTaskService {
+        implements IInspectionTaskService , ApplicationContextAware {
 
     @Resource
     private IInspectionItemService itemService;
@@ -1377,7 +1379,8 @@ public class InspectionTaskServiceImpl extends BaseServiceImpl<InspectionTaskMap
                 task.setCheckDate(LocalDateTime.now());
                 this.computeOrderQty(wp, wo, sumCheckQ, sumTestQty, sumLossQty, 0);
 //                this.qualified(wp, wc, wo);
-
+                IWorkOrderService workOrderService = context.getBean(IWorkOrderService.class);
+                workOrderService.qualified(wp,wo);
             } else if (countNA == itemList.size()) { // 全部item NA
                 checkResult = InspectionTaskConst.CHECK_RESULT_NA;
             } else if (countNO >= 0 && countNO <= itemList.size()) { // 不合格
@@ -1404,7 +1407,12 @@ public class InspectionTaskServiceImpl extends BaseServiceImpl<InspectionTaskMap
         return task;
     }
 
+    private ApplicationContext context;
 
+    @Override
+    public void setApplicationContext(ApplicationContext context) {
+        this.context = context;
+    }
     public void computeOrderQty(WorkPlan wp, WorkOrder wo, int checkQ, int testQty, int lossQty, int scrapQty) {
 
         if (wo != null) {

From fc4f0766c5f4ddbcde39a11515ef56bbb28fc4b2 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E7=BB=ABUmbrella?= <2539020564@qq.com>
Date: Wed, 1 Apr 2026 16:32:44 +0800
Subject: [PATCH 4/4] =?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/service/impl/IOrderBoxServiceImpl.java      | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/IOrderBoxServiceImpl.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/IOrderBoxServiceImpl.java
index 797a4b60..7f544e25 100644
--- a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/IOrderBoxServiceImpl.java
+++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/IOrderBoxServiceImpl.java
@@ -607,7 +607,7 @@ public class IOrderBoxServiceImpl implements IOrderBoxService {
             // 校验站点是否可以发送数据
             if (stationList.get(0).getStatus().equals(CONVEYOR_LINE_RECEIVE_ONLY) && agvSend) {
                 return R.fail("起始站点站码无法当开始站点编码");
-            } else if (!stationList.get(0).getStatus().equals(CONVEYOR_LINE_RECEIVE_ONLY) && !agvSend) {
+            } else if (!stationList.get(0).getStatus().equals(STATION_RECEIVE_ONLY) && !agvSend) {
                 return R.fail("起始站点站码无法当开始站点编码");
             }
             return R.data(startStationCode);
@@ -678,7 +678,6 @@ public class IOrderBoxServiceImpl implements IOrderBoxService {
         if (freeStationList != null && freeStationList.size() != 0) {
             //判断是不是镀后库作业中心
             if (DistinguishRegionsEnum.includeByWcName(wcName) && !agvSend) {
-                log.info("是读后库");
                 freeStationList = freeStationList.stream().filter(s -> s.getStationRegion().equals(task.getStationRegion())).toList();
             }