YBEE.EQM/YBEE.EQM.Application/System/Role/Services/SysRoleService.cs

using Furion.DatabaseAccessor.Extensions;
using YBEE.EQM.Core;

namespace YBEE.EQM.Application;

/// <summary>
/// 角色服务
/// </summary>
public class SysRoleService : ISysRoleService, ITransient
{
    private readonly IRepository<SysRole> _roleRep;
    private readonly IRepository<SysRoleUser> _roleUserRep;
    private readonly ISysRoleMenuService _roleMenuService;
    private readonly ICacheService _cacheService;

    public SysRoleService(IRepository<SysRole> roleRep, IRepository<SysRoleUser> roleUserRep, ISysRoleMenuService roleMenuService, ICacheService cacheService)
    {
        _roleRep = roleRep;
        _roleUserRep = roleUserRep;
        _roleMenuService = roleMenuService;
        _cacheService = cacheService;
    }

    /// <summary>
    /// 添加角色
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    public async Task Add(AddSysRoleInput input)
    {
        var isExist = await _roleRep.DetachedEntities.AnyAsync(u => u.Name == input.Name);
        if (isExist)
        {
            throw Oops.Oh(ErrorCode.E2004);
        }

        var role = input.Adapt<SysRole>();
        role.RoleType = RoleType.NORMAL;

        await role.InsertNowAsync();
    }
    /// <summary>
    /// 删除角色
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    public async Task Del(DeleteSysRoleInput input)
    {
        var sysRole = await _roleRep.FirstOrDefaultAsync(u => u.Id == input.Id);
        if (sysRole.RoleType != RoleType.NORMAL)
        {
            throw Oops.Oh(ErrorCode.E8201);
        }

        await sysRole.DeleteNowAsync();

        //级联删除该角色对应的用户-角色表关联信息
        var userRoles = await _roleUserRep.Where(u => u.SysRoleId == sysRole.Id).ToListAsync();
        await _roleUserRep.DeleteAsync(userRoles);

        //级联删除该角色对应的角色-菜单表关联信息
        await _roleMenuService.DeleteRoleMenuListByRoleId(sysRole.Id);
    }
    /// <summary>
    /// 更新角色
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    public async Task Update(UpdateSysRoleInput input)
    {
        var role = await _roleRep.DetachedEntities.FirstOrDefaultAsync(u => u.Id == input.Id);
        if (role.RoleType != RoleType.NORMAL)
        {
            throw Oops.Oh(ErrorCode.E8202);
        }

        var isExist = await _roleRep.DetachedEntities.AnyAsync(u => u.Name == input.Name && u.Id != input.Id);
        if (isExist)
        {
            throw Oops.Oh(ErrorCode.E2004);
        }

        var sysRole = input.Adapt<SysRole>();
        await sysRole.UpdateExcludeNowAsync(new[] { nameof(sysRole.RoleDataScope) });
    }
    /// <summary>
    /// 设置角色数据权限范围
    /// </summary>
    /// <returns></returns>
    public async Task SetDataScope()
    {
        // TODO:
        // 清空缓存，DelByPatternAsync，CommonConst.CACHE_KEY_PERMISSION
    }
    /// <summary>
    /// 获取当前用户角色数据权限范围
    /// </summary>
    /// <returns></returns>
    public async Task<RoleDataScope> GetCurrentUserDataScope()
    {
        var roles = await _cacheService.GetRoleDataScope(CurrentSysUserInfo.SysUserId);
        if (roles == null)
        {
            return new();
        }
        RoleDataScope roleDataScope = new();
        foreach (var role in roles)
        {
            roleDataScope.EducationStages.AddRange(role.RoleDataScope.EducationStages);
            roleDataScope.SysOrgIds.AddRange(role.RoleDataScope.SysOrgIds);
        }
        roleDataScope.EducationStages = roleDataScope.EducationStages.Distinct().ToList();
        roleDataScope.SysOrgIds = roleDataScope.SysOrgIds.Distinct().ToList();
        return roleDataScope;
    }
    /// <summary>
    /// 获取所有角色
    /// </summary>
    /// <returns></returns>
    public async Task<List<SysRoleOutput>> GetAllList()
    {
        return await _roleRep.DetachedEntities.OrderBy(u => u.RoleType).ProjectToType<SysRoleOutput>().ToListAsync();
    }
    /// <summary>
    /// 根据角色ID列表获取角色列表
    /// </summary>
    /// <param name="ids"></param>
    /// <returns></returns>
    public async Task<List<SysRoleOutput>> GetListByIds(List<int> ids)
    {
        return await _roleRep.DetachedEntities.Where(t => ids.Contains(t.Id)).ProjectToType<SysRoleOutput>().ToListAsync();
    }
}