java+SpringSecurity+用AOP使用注解实现统一数据隔离

1，实现”数据权限过滤注解“：
如下：
2，需要在下图实现代码”使其可以项目启动可以自动装配“:
如下：
3，最重要：实现数据过滤处理
代码如下：

package com.bd.common.datascope.aspect;

import com.bd.common.core.utils.StringUtils;
import com.bd.common.core.web.domain.BaseEntity;
import com.bd.common.datascope.annotation.WmsDataScope;
import com.bd.common.security.utils.SecurityUtils;
import com.bd.system.api.domain.SysUser;
import com.bd.system.api.model.LoginUser;
import org.aspectj.lang.JoinPoint;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Before;
import org.springframework.stereotype.Component;


@Aspect
@Component
public class WmsDataScopeAspect
{
    
    public static final String DATA_SCOPE = "dataScope";

    @Before("@annotation(controllerWmsDataScope)")
    public void doBefore(JoinPoint point, WmsDataScope controllerWmsDataScope) throws Throwable
    {
        clearDataScope(point);
        handleDataScope(point, controllerWmsDataScope);
    }

    protected void handleDataScope(final JoinPoint joinPoint, WmsDataScope controllerWmsDataScope)
    {
        // 获取当前的用户
        LoginUser loginUser = SecurityUtils.getLoginUser();
        if (StringUtils.isNotNull(loginUser))
        {
            SysUser currentUser = loginUser.getSysUser();
            //如果是超级管理员，则不过滤
            if (StringUtils.isNotNull(currentUser) && !currentUser.isAdmin()){
                dataScopeFilter(joinPoint, currentUser, controllerWmsDataScope.wmsDepotAlias());
            }
        }
    }

    
    public static void dataScopeFilter(JoinPoint joinPoint, SysUser user, String wmsDepotAlias)
    {
        StringBuilder sqlString = new StringBuilder();
        sqlString.append(StringUtils.format(
                " JOIN (这里是需要拼接的sql) SUD ON {}=SUD.(需要join的字段) ", user.getSitecode(),
                wmsDepotAlias));

        if (StringUtils.isNotBlank(sqlString.toString()))
        {
            Object params = joinPoint.getArgs()[0];
            if (StringUtils.isNotNull(params) && params instanceof BaseEntity)
            {
                BaseEntity baseEntity = (BaseEntity) params;
                baseEntity.getParams().put(DATA_SCOPE, sqlString);
            }
        }
    }

    
    private void clearDataScope(final JoinPoint joinPoint)
    {
        Object params = joinPoint.getArgs()[0];
        if (StringUtils.isNotNull(params) && params instanceof BaseEntity)
        {
            BaseEntity baseEntity = (BaseEntity) params;
            baseEntity.getParams().put(DATA_SCOPE, "");
        }
    }
}

4，用法：
4.1需要在impl中添加注解

4.2，在sql中添加：
${params.dataScope}
如下：
需要注意的是 上图的表和你所写的sql有一个字段可以join起来！！

然后，它就会在每一行需要隔离的sql自动拼接上你所写的sql！
end！