From d283d92a4e7449ab5d0e0d44c4ecc716c60869ea Mon Sep 17 00:00:00 2001
From: lzx <1234>
Date: Fri, 9 Jan 2026 15:02:54 +0800
Subject: [PATCH] =?UTF-8?q?fix(sync):=20=E4=BF=AE=E6=94=B9=E7=94=A8?=
 =?UTF-8?q?=E6=88=B7=E6=95=B0=E6=8D=AE=E5=90=8C=E6=AD=A5=E7=9A=84=E6=95=B0?=
 =?UTF-8?q?=E6=8D=AE=E6=BA=90=E8=BF=87=E6=BB=A4=E6=9D=A1=E4=BB=B6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- 将用户同步的数据源从 userSource = 2 修改为 userSource = 3
- 更新了数据库查询条件以匹配新的数据源标识
- 修正了数据同步功能的数据过滤逻辑
---
 .../module/system/api/databus/DatabusUserProviderApiImpl.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/zt-module-system/zt-module-system-server/src/main/java/com/zt/plat/module/system/api/databus/DatabusUserProviderApiImpl.java b/zt-module-system/zt-module-system-server/src/main/java/com/zt/plat/module/system/api/databus/DatabusUserProviderApiImpl.java
index f6b9050a..4e2f53e8 100644
--- a/zt-module-system/zt-module-system-server/src/main/java/com/zt/plat/module/system/api/databus/DatabusUserProviderApiImpl.java
+++ b/zt-module-system/zt-module-system-server/src/main/java/com/zt/plat/module/system/api/databus/DatabusUserProviderApiImpl.java
@@ -54,8 +54,8 @@ public class DatabusUserProviderApiImpl implements DatabusUserProviderApi {
         // 构建游标查询条件
         LambdaQueryWrapper<AdminUserDO> queryWrapper = new LambdaQueryWrapper<>();
 
-        // ⚠️ 只同步 userSource = 2 的用户
-        queryWrapper.eq(AdminUserDO::getUserSource, 2);
+        // ⚠️ 只同步 userSource = 3 的用户
+        queryWrapper.eq(AdminUserDO::getUserSource, 3);
 
         // 游标条件：create_time > cursorTime OR (create_time = cursorTime AND id > cursorId)
         if (!reqDTO.isFirstPage()) {