From 216e61b1ed5561e20878c070d8a3c676067047f6 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=88=98=E6=B3=89=E4=BD=B3?= <1107186916@qq.com>
Date: Thu, 29 Oct 2026 15:21:18 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E6=94=B6=E6=AC=BE=E6=B5=81=E6=B0=B4?=
 =?UTF-8?q?=E5=90=8C=E6=AD=A5=E6=8C=89=E5=B9=B3=E5=8F=B0=E5=85=AC=E5=8F=B8?=
 =?UTF-8?q?=E9=87=91=E8=9D=B6=E7=BB=84=E7=BB=87=E7=BC=96=E7=A0=81=E8=BF=87?=
 =?UTF-8?q?=E6=BB=A4=E6=9F=A5=E8=AF=A2?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../transport/mapper/KingdeeReceiptFlowMapper.java   | 12 ++++++++++++
 .../service/impl/ReceiptFlowServiceImpl.java         |  7 +++++++
 2 files changed, 19 insertions(+)

diff --git a/blade-service/blade-transport/src/main/java/org/springblade/transport/mapper/KingdeeReceiptFlowMapper.java b/blade-service/blade-transport/src/main/java/org/springblade/transport/mapper/KingdeeReceiptFlowMapper.java
index 7d69772c..0e6b654d 100644
--- a/blade-service/blade-transport/src/main/java/org/springblade/transport/mapper/KingdeeReceiptFlowMapper.java
+++ b/blade-service/blade-transport/src/main/java/org/springblade/transport/mapper/KingdeeReceiptFlowMapper.java
@@ -27,8 +27,11 @@ package org.springblade.transport.mapper;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Select;
 import org.springblade.transport.pojo.entity.KingdeeReceiptFlow;
 
+import java.util.List;
+
 /**
  * 金蝶收款流水镜像 Mapper 接口
  *
@@ -36,4 +39,13 @@ import org.springblade.transport.pojo.entity.KingdeeReceiptFlow;
  */
 @Mapper
 public interface KingdeeReceiptFlowMapper extends BaseMapper<KingdeeReceiptFlow> {
+
+	/**
+	 * 组织管理（blade_dept）中的平台公司金蝶组织编码列表（是否平台公司=是 且 已维护金蝶编码）
+	 *
+	 * @return 平台公司金蝶组织编码
+	 */
+	@Select("SELECT kingdee_dept_code FROM blade_dept WHERE is_platform_company = 1 "
+		+ "AND kingdee_dept_code IS NOT NULL AND kingdee_dept_code != '' AND is_deleted = 0")
+	List<String> selectPlatformOrgNumbers();
 }
diff --git a/blade-service/blade-transport/src/main/java/org/springblade/transport/service/impl/ReceiptFlowServiceImpl.java b/blade-service/blade-transport/src/main/java/org/springblade/transport/service/impl/ReceiptFlowServiceImpl.java
index 040907c7..a55ca6de 100644
--- a/blade-service/blade-transport/src/main/java/org/springblade/transport/service/impl/ReceiptFlowServiceImpl.java
+++ b/blade-service/blade-transport/src/main/java/org/springblade/transport/service/impl/ReceiptFlowServiceImpl.java
@@ -466,6 +466,13 @@ public class ReceiptFlowServiceImpl extends BaseServiceImpl<KingdeeReceiptFlowMa
 		queryDTO.setBeginBizdate(beginBizdate);
 		queryDTO.setEndBizdate(endBizdate);
 		queryDTO.setPageSize(SYNC_PAGE_SIZE);
+		// 按组织过滤：组织管理（blade_dept）中平台公司（是否平台公司=是）且已维护金蝶编码的组织
+		List<String> orgNumbers = baseMapper.selectPlatformOrgNumbers();
+		if (Func.isEmpty(orgNumbers)) {
+			throw new ServiceException("组织管理中未维护平台公司金蝶编码，无法同步金蝶收款流水，请先检查组织数据");
+		}
+		queryDTO.setOrgNumber(orgNumbers);
+		log.info("收款流水同步按组织过滤，组织编码：{}", orgNumbers);
 		// 待入库缓冲：累计满 SYNC_BATCH_SIZE 即入库一批并清空
 		List<BfiRecBillRow> pending = new ArrayList<>();
 		Set<String> batchSerials = new HashSet<>();