From e345d48dc7fef3cfec20cc4156c7c45c6479c237 Mon Sep 17 00:00:00 2001
From: lzx <1234>
Date: Fri, 9 Jan 2026 16:59:48 +0800
Subject: [PATCH] =?UTF-8?q?feat(databus):=20=E9=99=90=E5=88=B6=E9=83=A8?=
 =?UTF-8?q?=E9=97=A8=E6=95=B0=E6=8D=AE=E6=9F=A5=E8=AF=A2=E5=8F=AA=E7=BB=9F?=
 =?UTF-8?q?=E8=AE=A1=E7=89=B9=E5=AE=9A=E6=9D=A5=E6=BA=90?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- 在游标分页查询中添加部门来源过滤条件
- 在总数统计查询中添加部门来源过滤条件
- 在部门计数接口中添加部门来源过滤条件
- 确保只统计部门来源为3的数据记录
---
 .../system/api/databus/DatabusDeptProviderApiImpl.java       | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/zt-module-system/zt-module-system-server/src/main/java/com/zt/plat/module/system/api/databus/DatabusDeptProviderApiImpl.java b/zt-module-system/zt-module-system-server/src/main/java/com/zt/plat/module/system/api/databus/DatabusDeptProviderApiImpl.java
index 909845dc..326d1d3d 100644
--- a/zt-module-system/zt-module-system-server/src/main/java/com/zt/plat/module/system/api/databus/DatabusDeptProviderApiImpl.java
+++ b/zt-module-system/zt-module-system-server/src/main/java/com/zt/plat/module/system/api/databus/DatabusDeptProviderApiImpl.java
@@ -41,7 +41,7 @@ public class DatabusDeptProviderApiImpl implements DatabusDeptProviderApi {
     public CommonResult<CursorPageResult<DatabusDeptData>> getPageByCursor(CursorPageReqDTO reqDTO) {
         // 构建游标查询条件
         LambdaQueryWrapper<DeptDO> queryWrapper = new LambdaQueryWrapper<>();
-
+        queryWrapper.eq(DeptDO::getDeptSource, 3);
         // 游标条件：create_time > cursorTime OR (create_time = cursorTime AND id > cursorId)
         if (!reqDTO.isFirstPage()) {
             queryWrapper.and(w -> w
@@ -105,6 +105,7 @@ public class DatabusDeptProviderApiImpl implements DatabusDeptProviderApi {
         Long total = null;
         if (reqDTO.isFirstPage()) {
             LambdaQueryWrapper<DeptDO> countWrapper = new LambdaQueryWrapper<>();
+            countWrapper.eq(DeptDO::getDeptSource, 3);
             if (reqDTO.getTenantId() != null) {
                 countWrapper.eq(DeptDO::getTenantId, reqDTO.getTenantId());
             }
@@ -175,6 +176,8 @@ public class DatabusDeptProviderApiImpl implements DatabusDeptProviderApi {
     @Override
     public CommonResult<Long> count(Long tenantId) {
         LambdaQueryWrapper<DeptDO> queryWrapper = new LambdaQueryWrapper<>();
+        // ⚠️ 只统计 userSource = 3 的用户
+        queryWrapper.eq(DeptDO::getDeptSource, 3);
         if (tenantId != null) {
             queryWrapper.eq(DeptDO::getTenantId, tenantId);
         }