github/JeecgBoot
1
0
Fork 0
mirror of https://github.com/jeecgboot/JeecgBoot.git synced 2026-02-14 04:53:53 +00:00
Code Issues Packages Projects Releases Wiki Activity

当需要租户隔离时才添加多租户插件

Browse Source
This commit is contained in:
sunzhiri 2026-02-10 21:32:27 +08:00
parent 04a26cdd6d
commit 0859784c3b
1 changed files with 34 additions and 31 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

65
jeecg-boot/jeecg-boot-base-core/src/main/java/org/jeecg/config/mybatis/MybatisPlusSaasConfig.java
View File

@ -93,40 +93,43 @@ public class MybatisPlusSaasConfig {
public MybatisPlusInterceptor mybatisPlusInterceptor() { public MybatisPlusInterceptor mybatisPlusInterceptor() {
MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor(); MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
// 先 add TenantLineInnerInterceptor 再 add PaginationInnerInterceptor // 先 add TenantLineInnerInterceptor 再 add PaginationInnerInterceptor
interceptor.addInnerInterceptor(new TenantLineInnerInterceptor(new TenantLineHandler() { // 条件注册租户拦截器：当需要租户隔离时才添加
@Override if (OPEN_SYSTEM_TENANT_CONTROL) {
public Expression getTenantId() { interceptor.addInnerInterceptor(new TenantLineInnerInterceptor(new TenantLineHandler() {
String tenantId = TenantContext.getTenant(); @Override
//如果通过线程获取租户ID为空，则通过当前请求的request获取租户（shiro排除拦截器的请求会获取不到租户ID） public Expression getTenantId() {
if(oConvertUtils.isEmpty(tenantId)){ String tenantId = TenantContext.getTenant();
try { //如果通过线程获取租户ID为空，则通过当前请求的request获取租户（shiro排除拦截器的请求会获取不到租户ID）
tenantId = TokenUtils.getTenantIdByRequest(SpringContextUtils.getHttpServletRequest()); if (oConvertUtils.isEmpty(tenantId)) {
} catch (Exception e) { try {
//e.printStackTrace(); tenantId = TokenUtils.getTenantIdByRequest(SpringContextUtils.getHttpServletRequest());
} catch (Exception e) {
//e.printStackTrace();
}
} }
} if (oConvertUtils.isEmpty(tenantId)) {
if(oConvertUtils.isEmpty(tenantId)){ tenantId = "0";
tenantId = "0";
}
return new LongValue(tenantId);
}
@Override
public String getTenantIdColumn(){
return TenantConstant.TENANT_ID_TABLE;
}
// 返回 true 表示不走租户逻辑
@Override
public boolean ignoreTable(String tableName) {
for(String temp: TENANT_TABLE){
if(temp.equalsIgnoreCase(tableName)){
return false;
} }
return new LongValue(tenantId);
} }
return true;
} @Override
})); public String getTenantIdColumn() {
return TenantConstant.TENANT_ID_TABLE;
}
// 返回 true 表示不走租户逻辑
@Override
public boolean ignoreTable(String tableName) {
for (String temp : TENANT_TABLE) {
if (temp.equalsIgnoreCase(tableName)) {
return false;
}
}
return true;
}
}));
}
//update-begin-author:zyf date:20220425 for:【VUEN-606】注入动态表名适配拦截器解决多表名问题 //update-begin-author:zyf date:20220425 for:【VUEN-606】注入动态表名适配拦截器解决多表名问题
interceptor.addInnerInterceptor(dynamicTableNameInnerInterceptor()); interceptor.addInnerInterceptor(dynamicTableNameInnerInterceptor());
//update-end-author:zyf date:20220425 for:【VUEN-606】注入动态表名适配拦截器解决多表名问题 //update-end-author:zyf date:20220425 for:【VUEN-606】注入动态表名适配拦截器解决多表名问题