From d47c91c7f2d55dde03d92ec67f350387945b33da Mon Sep 17 00:00:00 2001 From: lzx <1234> Date: Fri, 9 Jan 2026 15:49:28 +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 - 更新了数据库查询条件以匹配新的数据源标识 - 修正了数据同步功能的数据过滤逻辑 --- .../system/api/databus/DatabusUserProviderApiImpl.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 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 4e2f53e8..3157ad2c 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 @@ -103,8 +103,8 @@ public class DatabusUserProviderApiImpl implements DatabusUserProviderApi { Long total = null; if (reqDTO.isFirstPage()) { LambdaQueryWrapper countWrapper = new LambdaQueryWrapper<>(); - // ⚠️ 只统计 userSource = 2 的用户 - countWrapper.eq(AdminUserDO::getUserSource, 2); + // ⚠️ 只统计 userSource = 3 的用户 + countWrapper.eq(AdminUserDO::getUserSource, 3); if (reqDTO.getTenantId() != null) { countWrapper.eq(AdminUserDO::getTenantId, reqDTO.getTenantId()); } @@ -148,8 +148,8 @@ public class DatabusUserProviderApiImpl implements DatabusUserProviderApi { @Override public CommonResult count(Long tenantId) { LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>(); - // ⚠️ 只统计 userSource = 2 的用户 - queryWrapper.eq(AdminUserDO::getUserSource, 2); + // ⚠️ 只统计 userSource = 3 的用户 + queryWrapper.eq(AdminUserDO::getUserSource, 3); if (tenantId != null) { queryWrapper.eq(AdminUserDO::getTenantId, tenantId); }