|
|
@ -4,6 +4,7 @@ import com.alibaba.fastjson2.JSON; |
|
|
|
import com.alibaba.fastjson2.JSONObject; |
|
|
|
import com.alibaba.fastjson2.JSONObject; |
|
|
|
import com.mh.user.dynamic.datasource.DataSourceContextHolder; |
|
|
|
import com.mh.user.dynamic.datasource.DataSourceContextHolder; |
|
|
|
import com.mh.user.service.SysUserService; |
|
|
|
import com.mh.user.service.SysUserService; |
|
|
|
|
|
|
|
import lombok.extern.slf4j.Slf4j; |
|
|
|
import org.springframework.beans.factory.annotation.Autowired; |
|
|
|
import org.springframework.beans.factory.annotation.Autowired; |
|
|
|
import org.springframework.stereotype.Component; |
|
|
|
import org.springframework.stereotype.Component; |
|
|
|
import org.springframework.web.servlet.HandlerInterceptor; |
|
|
|
import org.springframework.web.servlet.HandlerInterceptor; |
|
|
@ -16,6 +17,7 @@ import javax.servlet.http.HttpServletResponse; |
|
|
|
* @date 2020-09-03 08:44 |
|
|
|
* @date 2020-09-03 08:44 |
|
|
|
* @Description 请求拦截器 |
|
|
|
* @Description 请求拦截器 |
|
|
|
*/ |
|
|
|
*/ |
|
|
|
|
|
|
|
@Slf4j |
|
|
|
@Component |
|
|
|
@Component |
|
|
|
public class PrimessionInterceptor implements HandlerInterceptor { |
|
|
|
public class PrimessionInterceptor implements HandlerInterceptor { |
|
|
|
|
|
|
|
|
|
|
@ -36,20 +38,20 @@ public class PrimessionInterceptor implements HandlerInterceptor { |
|
|
|
String token = request.getHeader("token"); |
|
|
|
String token = request.getHeader("token"); |
|
|
|
if (token != null && token.contains("token")) { |
|
|
|
if (token != null && token.contains("token")) { |
|
|
|
JSONObject jsonObject = (JSONObject) JSON.parse(token); |
|
|
|
JSONObject jsonObject = (JSONObject) JSON.parse(token); |
|
|
|
System.out.println("header---->" + jsonObject.get("token")); |
|
|
|
log.info("header---->" + jsonObject.get("token")); |
|
|
|
if (jsonObject.get("token") !=null ) { |
|
|
|
if (jsonObject.get("token") !=null ) { |
|
|
|
token = jsonObject.get("token").toString(); |
|
|
|
token = jsonObject.get("token").toString(); |
|
|
|
} |
|
|
|
} |
|
|
|
System.out.println(" token==> " + token); |
|
|
|
log.info(" token==> " + token); |
|
|
|
} |
|
|
|
} |
|
|
|
String uri = request.getRequestURI(); |
|
|
|
String uri = request.getRequestURI(); |
|
|
|
System.out.println(uri); |
|
|
|
log.info(uri); |
|
|
|
DataSourceContextHolder.setDBType("default"); |
|
|
|
DataSourceContextHolder.setDBType("default"); |
|
|
|
// 除了中间库业务的请求都使用多数据源切换
|
|
|
|
// 除了中间库业务的请求都使用多数据源切换
|
|
|
|
// if(!(uri.contains("/sysUser") || uri.contains("/sysRole") || uri.contains("/sysMenu") )){
|
|
|
|
// if(!(uri.contains("/sysUser") || uri.contains("/sysRole") || uri.contains("/sysMenu") )){
|
|
|
|
// if(token != null){
|
|
|
|
// if(token != null){
|
|
|
|
// String userName = JwtTokenUtils.getUsernameFromToken(token);
|
|
|
|
// String userName = JwtTokenUtils.getUsernameFromToken(token);
|
|
|
|
// System.out.println(userName);
|
|
|
|
// log.info(userName);
|
|
|
|
// DBEntity dbEntity = sysUserService.queryDBInfo(userName);
|
|
|
|
// DBEntity dbEntity = sysUserService.queryDBInfo(userName);
|
|
|
|
// dbEntity.setDB_Pwd(AESUtil.AESdecrypt(dbEntity.getDB_Pwd()));
|
|
|
|
// dbEntity.setDB_Pwd(AESUtil.AESdecrypt(dbEntity.getDB_Pwd()));
|
|
|
|
// // 切换数据源
|
|
|
|
// // 切换数据源
|
|
|
|