fix(sync): 修改用户数据同步的数据源过滤条件

- 将用户同步的数据源从 userSource = 2 修改为 userSource = 3
- 更新了数据库查询条件以匹配新的数据源标识
- 修正了数据同步功能的数据过滤逻辑
This commit is contained in:
lzx
2026-01-09 15:02:54 +08:00
parent e338de722f
commit d283d92a4e

View File

@@ -54,8 +54,8 @@ public class DatabusUserProviderApiImpl implements DatabusUserProviderApi {
// 构建游标查询条件 // 构建游标查询条件
LambdaQueryWrapper<AdminUserDO> queryWrapper = new LambdaQueryWrapper<>(); LambdaQueryWrapper<AdminUserDO> queryWrapper = new LambdaQueryWrapper<>();
// ⚠️ 只同步 userSource = 2 的用户 // ⚠️ 只同步 userSource = 3 的用户
queryWrapper.eq(AdminUserDO::getUserSource, 2); queryWrapper.eq(AdminUserDO::getUserSource, 3);
// 游标条件create_time > cursorTime OR (create_time = cursorTime AND id > cursorId) // 游标条件create_time > cursorTime OR (create_time = cursorTime AND id > cursorId)
if (!reqDTO.isFirstPage()) { if (!reqDTO.isFirstPage()) {