From 6c6f9a87948db32d67b8d147ceced0605837e770 Mon Sep 17 00:00:00 2001 From: "pref_mail@163.com" Date: Wed, 14 Aug 2024 15:00:18 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E4=BB=93=E5=BA=93=E6=A8=A1?= =?UTF-8?q?=E5=9D=97=E7=9A=84=E5=BC=82=E6=AD=A5=E7=BA=BF=E7=A8=8B=E7=BB=91?= =?UTF-8?q?=E5=AE=9A=E5=BD=93=E5=89=8D=E4=BC=9A=E8=AF=9D=20=E6=97=A0?= =?UTF-8?q?=E6=B3=95=E8=8E=B7=E5=8F=96token=E7=BB=91=E5=AE=9A=E7=A7=9F?= =?UTF-8?q?=E6=88=B7ID=E7=9A=84=E6=83=85=E5=86=B5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/logpm/warehouse/config/ExecutorConfig.java | 13 ++++++++++++- 1 file changed, 12 insertions(+), 1 deletion(-) diff --git a/blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/config/ExecutorConfig.java b/blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/config/ExecutorConfig.java index cb8d0f169..beffac986 100644 --- a/blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/config/ExecutorConfig.java +++ b/blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/config/ExecutorConfig.java @@ -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();