leniu-data-permission
适用于 leniu-tengyun-core 项目的多租户数据权限控制。
双库架构
leniu-tengyun-core 采用物理数据库隔离的多租户架构，每个租户拥有独立的业务数据库：
系统库 (system) ├── 租户配置表 ├── 系统字典表 └── ... 系统级配置
租户库 (tenant_1, tenant_2, ...) ├── 租户业务数据 └── ... 业务表（无 tenant_id 字段）
数据源切换
注解方式
注解 用途
@UseSystem
切换到系统库
@UseGlobalTs("dbName")
切换到全局时序库
import net.xnzn.framework.data.mybatis.datasource.UseSystem; import net.xnzn.framework.data.mybatis.datasource.UseGlobalTs;
@Service public class TenantConfigService {
// 操作系统库
@UseSystem
public TenantConfig getTenantConfig(Long tenantId) {
return tenantConfigMapper.selectById(tenantId);
}
// 操作全局时序库
@UseGlobalTs("ts_db_name")
public List<TimeSeriesData> getTimeSeries(String key) {
return timeSeriesMapper.selectList(...);
}
}
编程方式
import net.xnzn.framework.data.dataset.Executors;
// 在指定租户库中执行操作 Executors.doInTenant(tenantId, status -> { // 这里的操作会在 tenantId 对应的数据库中执行 businessDataMapper.insert(data); });
// 读取指定租户数据（不开启事务） List<Data> data = Executors.readInTenant(tenantId, () -> { return businessDataMapper.selectList(...); });
// 遍历所有租户执行任务 Executors.doInAllTenant(tenantId -> { // 对每个租户执行此操作 businessDataMapper.delete(...); });
// 遍历所有租户执行任务（出错继续） Executors.doInAllTenant(true, tenantId -> { // 某个租户出错不影响其他租户 businessDataMapper.update(...); });
// 在系统库中执行操作 Executors.doInSystem(status -> { // 这里的操作会在系统库中执行 systemConfigMapper.insert(config); });
// 读取系统库数据 SystemConfig config = Executors.readInSystem(() -> { return systemConfigMapper.selectById(1); });
// 在全局时序库中执行 Executors.doInGlobalTs("ts_db_name", false, () -> { timeSeriesMapper.insert(data); });
租户上下文
TenantContextHolder
import net.xnzn.framework.data.tenant.TenantContextHolder;
// 获取当前租户 ID（来自请求头） Long tenantId = TenantContextHolder.getTenantId();
// 设置租户 ID（一般由 Filter 自动设置） TenantContextHolder.setTenantId(123L);
// 清除租户上下文 TenantContextHolder.clear();
租户请求头
默认租户 ID 请求头名称为 MERCHANT-ID （可配置）：
GET /api/v2/users HTTP/1.1 MERCHANT-ID: 12345
数据源路由
RoutingRule
import net.xnzn.framework.data.dataset.rule.RoutingRule;
// 获取当前路由上下文 RoutingRule.Context context = RoutingRule.getContext();
// 重置路由规则 RoutingRule.reset();
// 使用系统库 RoutingRule.useSystem();
// 使用全局时序库 RoutingRule.useGlobalTs("ts_db_name");
路由规则加载
数据源规则从配置文件加载：
spring: dataset: system: master: jdbc-url: jdbc:mysql://localhost:3306/system_db username: root password: xxx slave: - jdbc-url: jdbc:mysql://slave1:3306/system_db - jdbc-url: jdbc:mysql://slave2:3306/system_db global-ts: master: jdbc-url: jdbc:mysql://localhost:3306/ts_db business: tenant_1: master: jdbc-url: jdbc:mysql://localhost:3306/tenant_1 slave: - jdbc-url: jdbc:mysql://slave1:3306/tenant_1 tenant_2: master: jdbc-url: jdbc:mysql://localhost:3306/tenant_2
典型场景
跨租户查询
@Service public class CrossTenantService {
// 查询多个租户的数据
public Map<Long, List<Order>> getOrdersByTenants(List<Long> tenantIds) {
Map<Long, List<Order>> result = new HashMap<>();
for (Long tenantId : tenantIds) {
List<Order> orders = Executors.readInTenant(tenantId, () ->
orderMapper.selectList(new QueryWrapper<>())
);
result.put(tenantId, orders);
}
return result;
}
}
系统配置读取
@Service public class SystemConfigService {
@UseSystem
public SystemConfig getConfig(String key) {
return systemConfigMapper.selectOne(
new QueryWrapper<SystemConfig>().eq("config_key", key)
);
}
}
租户数据初始化
@Service public class TenantInitService {
// 为新租户初始化数据
public void initTenant(Long tenantId) {
Executors.doInTenant(tenantId, status -> {
// 创建默认菜单
defaultMenuService.createDefaultMenus();
// 创建默认角色
defaultRoleService.createDefaultRoles();
});
}
}
TenantConfigProperties
@Setter @Getter @ConfigurationProperties(prefix = "leniu.tenant") public class TenantConfigProperties { // 请求头名称，默认 MERCHANT-ID private String carrierName = "MERCHANT-ID";
// MDC 键名
private String mdc = "tenantId";
}
与 RuoYi-Plus 的区别
特性 RuoYi-Plus leniu-tengyun-core
多租户方式 逻辑隔离（tenant_id 字段） 物理隔离（独立数据库）
租户切换 @TenantLine 注解 @UseSystem / Executors.doInTenant()
租户上下文 TenantLineHelper.tenantId()
TenantContextHolder.getTenantId()
数据权限 @DataColumn 注解 物理库隔离，无需字段
系统库操作 @TenantLine 指定 "000000" @UseSystem 或 Executors.doInSystem()
注意事项
-
leniu 采用物理库隔离，表中无 tenant_id 字段
-
默认操作租户库，需要访问系统库时必须明确切换
-
跨租户操作需要使用 Executors.doInTenant() 或 Executors.readInTenant()
-
事务会在方法执行结束后自动切回原来的数据源
-
TenantContextHolderFilter 自动从请求头解析租户 ID
报表场景下的数据权限使用
报表场景数据权限使用模式
在定制报表（leniu-yunshitang 仓库）中，数据权限通过以下三层协作实现：
- Service 层：获取权限参数
@Autowired private MgrAuthV2Api mgrAuthApi;
@Autowired private ReportDataPermissionService reportDataPermissionService;
// 在每个查询/导出方法中调用 MgrUserAuthPO authPO = mgrAuthApi.getUserAuthPO(); ReportDataPermissionParam dataPermission = reportDataPermissionService.getDataPermission(authPO);
- Mapper 接口：传递权限参数
List<XxxVO> listPage(@Param("param") XxxParam param, @Param("authPO") MgrUserAuthPO authPO, @Param("dataPermission") ReportDataPermissionParam dataPermission);
XxxVO getTotal(@Param("param") XxxParam param, @Param("authPO") MgrUserAuthPO authPO, @Param("dataPermission") ReportDataPermissionParam dataPermission);
- MyBatis XML：引入公共权限片段
<!-- 在 baseWhere 的 SQL 片段末尾加入 --> <sql id="baseWhere"> <!-- 业务过滤条件... --> <include refid="net.xnzn.core.report.statistics.common.mapper.ReportDataPermissionMapper.dataPermission"/> </sql>
完整调用链示例：
public ReportBaseTotalVO<DzMealDetailVO> pageWithTotal(DzMealDetailParam param) { // 获取权限 MgrUserAuthPO authPO = mgrAuthApi.getUserAuthPO(); ReportDataPermissionParam dataPermission = reportDataPermissionService.getDataPermission(authPO);
ReportBaseTotalVO<DzMealDetailVO> result = new ReportBaseTotalVO<>();
// 查询合计行
if (CollUtil.isEmpty(param.getExportCols())) {
DzMealDetailVO totalLine = mapper.getTotal(param, authPO, dataPermission);
result.setTotalLine(Optional.ofNullable(totalLine).orElse(new DzMealDetailVO()));
}
// 查询列表
if (param.getPage() != null) {
PageMethod.startPage(param.getPage());
}
List<DzMealDetailVO> list = mapper.listPage(param, authPO, dataPermission);
result.setResultPage(PageVO.of(list));
return result;
}
注意： 导出方法（exportXxx）中同样需要获取权限并传给 Mapper，不能省略。