RuoYi-Vue-Plus 项目详解：架构、原理与设计思想

/**
 * 数据权限注解
 */
@Target({ElementType.METHOD, ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface DataScope {
    /**
     * 表别名
     */
    String tableAlias() default "";
    
    /**
     * 部门ID字段名
     */
    String deptId() default "";
    
    /**
     * 用户ID字段名
     */
    String userId() default "";
}

spring:
  datasource:
    dynamic:
      primary: master #设置默认的数据源或者数据源组,默认值即为master
      strict: false #严格匹配数据源,默认false. true未匹配到指定数据源时抛异常,false使用默认数据源
      datasource:
        master:
          url: jdbc:mysql://localhost:3306/ry-vue
          username: root
          password: password
          driver-class-name: com.mysql.cj.jdbc.Driver
        slave:
          url: jdbc:mysql://localhost:3307/ry-vue
          username: root
          password: password
          driver-class-name: com.mysql.cj.jdbc.Driver

/**
 * 权限服务接口
 */
public interface PermissionService {
    /**
     * 获取角色数据权限
     *
     * @param roleId 角色ID
     * @return 数据权限范围
     */
    Set<Long> getRoleDataScope(Long roleId);
    
    /**
     * 获取菜单数据权限
     *
     * @param userId 用户ID
     * @return 菜单权限标识集合
     */
    Set<String> getMenuPermission(Long userId);
}

/**
 * 多租户拦截器
 */
public class TenantInterceptor implements InnerInterceptor {
    
    @Override
    public void beforeQuery(Executor executor, MappedStatement ms, Object parameter,
                           RowBounds rowBounds, ResultHandler resultHandler, BoundSql boundSql) throws SQLException {
        // 获取租户ID
        Long tenantId = TenantHelper.getTenantId();
        if (tenantId == null) {
            return;
        }
        
        // 修改SQL，添加租户条件
        String originalSql = boundSql.getSql();
        String newSql = originalSql + " AND tenant_id = " + tenantId;
        ReflectUtil.setFieldValue(boundSql, "sql", newSql);
    }
}

/**
 * 工作流服务接口
 */
public interface IFlwCommonService {
    /**
     * 构建工作流用户
     *
     * @param userId 用户ID
     * @return 工作流用户对象
     */
    User buildWorkFlowUser(Long userId);
    
    /**
     * 启动流程
     *
     * @param processKey 流程定义键
     * @param businessKey 业务键
     * @param variables 变量
     * @return 流程实例ID
     */
    String startProcess(String processKey, String businessKey, Map<String, Object> variables);
}

/**
 * 插件接口
 */
public interface Plugin {
    /**
     * 插件名称
     */
    String getName();
    
    /**
     * 插件版本
     */
    String getVersion();
    
    /**
     * 插件描述
     */
    String getDescription();
    
    /**
     * 初始化插件
     */
    void initialize();
    
    /**
     * 启动插件
     */
    void start();
    
    /**
     * 停止插件
     */
    void stop();
}

# 项目配置
ruoyi:
  # 名称
  name: RuoYi-Vue-Plus
  # 版本
  version: 5.3.0
  # 版权年份
  copyrightYear: 2023
  # 实例演示开关
  demoEnabled: true
  # 文件路径 示例（ Windows配置D:/ruoyi/uploadPath，Linux配置 /home/ruoyi/uploadPath）
  profile: D:/ruoyi/uploadPath
  # 获取ip地址开关
  addressEnabled: false
  # 验证码类型 math 数组计算 char 字符验证
  captchaType: math

# 开发环境配置
server:
  # 服务器的HTTP端口，默认为8080
  port: 8080
  servlet:
    # 应用的访问路径
    context-path: /
  tomcat:
    # tomcat的URI编码
    uri-encoding: UTF-8
    # tomcat最大线程数，默认为200
    max-threads: 800
    # Tomcat启动初始化的线程数，默认值25
    min-spare-threads: 30

/**
 * 登录服务实现
 */
@Service
public class SysLoginService {
    @Autowired
    private SysUserMapper userMapper;
    
    @Autowired
    private SysPermissionService permissionService;
    
    /**
     * 登录验证
     *
     * @param username 用户名
     * @param password 密码
     * @param code 验证码
     * @param uuid 唯一标识
     * @return 结果
     */
    public String login(String username, String password, String code, String uuid) {
        // 验证码校验
        validateCaptcha(username, code, uuid);
        
        // 登录前置校验
        loginPreCheck(username, password);
        
        // 用户验证
        SysUser user = loadUserByUsername(username);
        
        if (!SecurityUtils.matchesPassword(password, user.getPassword())) {
            throw new UserPasswordNotMatchException();
        }
        
        if (UserStatus.DISABLE.getCode().equals(user.getStatus())) {
            throw new UserBlockedException();
        }
        
        // 生成token
        return createToken(user);
    }
    
    /**
     * 创建令牌
     */
    public String createToken(SysUser user) {
        // 生成token
        String token = IdUtil.fastSimpleUUID();
        
        // 缓存用户信息
        LoginUser loginUser = new LoginUser();
        loginUser.setUserId(user.getUserId());
        loginUser.setUsername(user.getUserName());
        loginUser.setPermission(permissionService.getMenuPermission(user.getUserId()));
        
        // 缓存登录用户到Redis
        RedisUtils.setCacheObject(CacheConstants.LOGIN_TOKEN_KEY + token, loginUser, 
            CacheConstants.LOGIN_TOKEN_TTL, TimeUnit.MINUTES);
        
        return token;
    }
}

/**
 * 用户管理接口
 */
@RestController
@RequestMapping("/system/user")
public class SysUserController extends BaseController {
    
    @Autowired
    private ISysUserService userService;
    
    /**
     * 获取用户列表
     */
    @SaCheckPermission("system:user:list")
    @GetMapping("/list")
    public TableDataInfo<SysUserVo> list(SysUserBo user, PageQuery pageQuery) {
        return userService.selectPageUserList(user, pageQuery);
    }
    
    /**
     * 根据用户编号获取详细信息
     */
    @SaCheckPermission("system:user:query")
    @GetMapping("/{userId}")
    public R<SysUserVo> getInfo(@PathVariable Long userId) {
        userService.checkUserDataScope(userId);
        return R.ok(userService.selectUserById(userId));
    }
    
    /**
     * 新增用户
     */
    @SaCheckPermission("system:user:add")
    @Log(title = "用户管理", businessType = BusinessType.INSERT)
    @PostMapping
    public R<Void> add(@Validated @RequestBody SysUserBo user) {
        if (!userService.checkUserNameUnique(user.getUserName())) {
            return R.fail("新增用户'" + user.getUserName() + "'失败，登录账号已存在");
        }
        return toAjax(userService.insertUser(user));
    }
    
    /**
     * 修改用户
     */
    @SaCheckPermission("system:user:edit")
    @Log(title = "用户管理", businessType = BusinessType.UPDATE)
    @PutMapping
    public R<Void> edit(@Validated @RequestBody SysUserBo user) {
        userService.checkUserAllowed(user);
        userService.checkUserDataScope(user.getUserId());
        if (!userService.checkUserNameUnique(user.getUserName())) {
            return R.fail("修改用户'" + user.getUserName() + "'失败，登录账号已存在");
        }
        return toAjax(userService.updateUser(user));
    }
}