| | |
| | | package com.ruoyi.framework.aspectj; |
| | | |
| | | import cn.hutool.core.lang.Validator; |
| | | import com.baomidou.dynamic.datasource.toolkit.DynamicDataSourceContextHolder; |
| | | import com.ruoyi.common.annotation.DataSource; |
| | | import com.ruoyi.common.utils.StringUtils; |
| | | import org.aspectj.lang.ProceedingJoinPoint; |
| | | import org.aspectj.lang.annotation.Around; |
| | | import org.aspectj.lang.annotation.Aspect; |
| | | import org.aspectj.lang.annotation.Pointcut; |
| | | import org.aspectj.lang.reflect.MethodSignature; |
| | | import org.springframework.core.annotation.AnnotationUtils; |
| | | import org.springframework.core.annotation.Order; |
| | | import org.springframework.stereotype.Component; |
| | | |
| | | import java.util.Objects; |
| | | |
| | | /** |
| | | * 多数据源处理 |
| | | * |
| | | * @author ruoyi |
| | | * @author Lion Li |
| | | */ |
| | | @Aspect |
| | | @Order(1) |
| | | @Order(-500) |
| | | @Component |
| | | public class DataSourceAspect { |
| | | |
| | | @Pointcut("@annotation(com.ruoyi.common.annotation.DataSource)" |
| | | + "|| @within(com.ruoyi.common.annotation.DataSource)") |
| | | public void dsPointCut() { |
| | | } |
| | | |
| | | @Around("dsPointCut()") |
| | | public Object around(ProceedingJoinPoint point) throws Throwable { |
| | | DataSource dataSource = getDataSource(point); |
| | | |
| | | if (Validator.isNotNull(dataSource)) { |
| | | DynamicDataSourceContextHolder.push(dataSource.value().name()); |
| | | @Around("@annotation(dataSource) || @within(dataSource)") |
| | | public Object around(ProceedingJoinPoint point, DataSource dataSource) throws Throwable { |
| | | if (StringUtils.isNotNull(dataSource)) { |
| | | DynamicDataSourceContextHolder.poll(); |
| | | String source = dataSource.value().getSource(); |
| | | DynamicDataSourceContextHolder.push(source); |
| | | } |
| | | |
| | | try { |
| | |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 获取需要切换的数据源 |
| | | */ |
| | | public DataSource getDataSource(ProceedingJoinPoint point) { |
| | | MethodSignature signature = (MethodSignature) point.getSignature(); |
| | | DataSource dataSource = AnnotationUtils.findAnnotation(signature.getMethod(), DataSource.class); |
| | | if (Objects.nonNull(dataSource)) { |
| | | return dataSource; |
| | | } |
| | | |
| | | return AnnotationUtils.findAnnotation(signature.getDeclaringType(), DataSource.class); |
| | | } |
| | | } |