|
|
|
@ -1,6 +1,7 @@
|
|
|
|
|
package com.logpm.warehouse.config; |
|
|
|
|
|
|
|
|
|
import com.baomidou.dynamic.datasource.toolkit.DynamicDataSourceContextHolder; |
|
|
|
|
import com.baomidou.mybatisplus.core.toolkit.StringUtils; |
|
|
|
|
import lombok.extern.slf4j.Slf4j; |
|
|
|
|
import org.slf4j.MDC; |
|
|
|
|
import org.springblade.core.secure.utils.AuthUtil; |
|
|
|
@ -66,7 +67,17 @@ public class ExecutorConfig {
|
|
|
|
|
RequestContextHolder.setRequestAttributes(context); |
|
|
|
|
// 未当前的异步线程绑定租户ID 和切换数据源
|
|
|
|
|
log.info(">>>> 异步线程创建,绑定租户数据源 {}",tenantId); |
|
|
|
|
DynamicDataSourceContextHolder.push(tenantId); |
|
|
|
|
log.info(">>>> 异步线程创建,绑定租户数据源 {}",tenantId); |
|
|
|
|
if(StringUtils.isBlank(tenantId)){ |
|
|
|
|
//这里为null 存在问题
|
|
|
|
|
log.info(">>>> 异步线程创建,没有用户信息 {}",AuthUtil.getUserId()); |
|
|
|
|
log.info(">>>> 异步线程创建,没有用户信息 {}",AuthUtil.getUser()); |
|
|
|
|
log.info(">>>> 异步线程创建,没有用户信息 {}",context); |
|
|
|
|
DynamicDataSourceContextHolder.push("627683"); |
|
|
|
|
}else{ |
|
|
|
|
// 未当前的异步线程绑定租户ID 和切换数据源
|
|
|
|
|
DynamicDataSourceContextHolder.push(tenantId); |
|
|
|
|
} |
|
|
|
|
runnable.run(); |
|
|
|
|
} finally { |
|
|
|
|
RequestContextHolder.resetRequestAttributes(); |
|
|
|
|