120 lines
4.8 KiB
C#
120 lines
4.8 KiB
C#
using SqlSugar;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using System.Threading.Tasks;
|
|
using Yi.Framework.Common.Models;
|
|
using Yi.Framework.DTOModel;
|
|
using Yi.Framework.Interface;
|
|
using Yi.Framework.Model.Models;
|
|
using Yi.Framework.Repository;
|
|
|
|
namespace Yi.Framework.Service
|
|
{
|
|
public partial class RoleService
|
|
{
|
|
public async Task<List<RoleEntity>> DbTest()
|
|
{
|
|
return await _repository._Db.Queryable<RoleEntity>().ToListAsync();
|
|
}
|
|
public async Task<bool> GiveRoleSetMenu(List<long> roleIds, List<long> menuIds)
|
|
{
|
|
var _repositoryRoleMenu= _repository.ChangeRepository<Repository<RoleMenuEntity>>();
|
|
//多次操作，需要事务确保原子性
|
|
return await _repositoryRoleMenu.UseTranAsync(async () =>
|
|
{ //删除用户之前所有的用户角色关系（物理删除，没有恢复的必要）
|
|
await _repositoryRoleMenu.DeleteAsync(u => roleIds.Contains((long)u.RoleId) );
|
|
|
|
//遍历用户
|
|
foreach (var roleId in roleIds)
|
|
{
|
|
//添加新的关系
|
|
List<RoleMenuEntity> roleMenuEntity = new();
|
|
foreach (var menu in menuIds)
|
|
{
|
|
roleMenuEntity.Add(new RoleMenuEntity() { RoleId = roleId,MenuId=menu });
|
|
}
|
|
|
|
//一次性批量添加
|
|
await _repositoryRoleMenu.InsertReturnSnowflakeIdAsync(roleMenuEntity);
|
|
}
|
|
});
|
|
|
|
|
|
}
|
|
|
|
public async Task<RoleEntity> GetInMenuByRoleId(long roleId)
|
|
{
|
|
return await _repository._Db.Queryable<RoleEntity>().Includes(u => u.Menus).InSingleAsync(roleId);
|
|
|
|
}
|
|
|
|
|
|
|
|
public async Task<PageModel<List<RoleEntity>>> SelctPageList(RoleEntity role, PageParModel page)
|
|
{
|
|
RefAsync<int> total = 0;
|
|
var data = await _repository._DbQueryable
|
|
.WhereIF(!string.IsNullOrEmpty(role.RoleName), u => u.RoleName.Contains(role.RoleName))
|
|
.WhereIF(!string.IsNullOrEmpty(role.RoleCode), u => u.RoleCode.Contains(role.RoleCode))
|
|
.WhereIF(page.StartTime.IsNotNull() && page.EndTime.IsNotNull(), u => u.CreateTime >= page.StartTime && u.CreateTime <= page.EndTime)
|
|
.WhereIF(role.IsDeleted.IsNotNull(), u => u.IsDeleted == role.IsDeleted)
|
|
.OrderBy(u => u.OrderNum, OrderByType.Desc)
|
|
.ToPageListAsync(page.PageNum, page.PageSize, total);
|
|
|
|
return new PageModel<List<RoleEntity>>(data, total);
|
|
}
|
|
|
|
|
|
|
|
public async Task<bool> AddInfo(RoleInfoDto roleDto)
|
|
{
|
|
var res1 = await _repository.InsertReturnSnowflakeIdAsync(roleDto.Role);
|
|
var res2 = await GiveRoleSetMenu(new List<long> { res1 }, roleDto.MenuIds);
|
|
return !0.Equals(res1) && res2;
|
|
}
|
|
|
|
public async Task<bool> GiveRoleSetDept(List<long> roleIds,List<long> deptIds)
|
|
{
|
|
var _repositoryRoleDept = _repository.ChangeRepository<Repository<RoleDeptEntity>>();
|
|
//多次操作，需要事务确保原子性
|
|
return await _repositoryRoleDept.UseTranAsync(async () =>
|
|
{ //删除用户之前所有的用户角色关系（物理删除，没有恢复的必要）
|
|
await _repositoryRoleDept.DeleteAsync(u => roleIds.Contains((long)u.RoleId));
|
|
|
|
//遍历角色
|
|
foreach (var roleId in roleIds)
|
|
{
|
|
//添加新的关系
|
|
List<RoleDeptEntity> roleDeptEntity = new();
|
|
foreach (var dept in deptIds)
|
|
{
|
|
roleDeptEntity.Add(new RoleDeptEntity() { RoleId = roleId, DeptId = dept });
|
|
}
|
|
|
|
//一次性批量添加
|
|
await _repositoryRoleDept.InsertReturnSnowflakeIdAsync(roleDeptEntity);
|
|
}
|
|
});
|
|
}
|
|
|
|
public async Task<bool> UpdateInfo(RoleInfoDto roleDto)
|
|
{
|
|
var res1 = await _repository.UpdateIgnoreNullAsync(roleDto.Role);
|
|
var res2 = await GiveRoleSetMenu(new List<long> { roleDto.Role.Id }, roleDto.MenuIds);
|
|
var res3 = await GiveRoleSetDept(new List<long> { roleDto.Role.Id }, roleDto.DeptIds);
|
|
return res1 && res2&& res3;
|
|
}
|
|
|
|
public async Task<bool> UpdateDataScpoce(RoleInfoDto roleDto)
|
|
{
|
|
var role= new RoleEntity();
|
|
role.Id = roleDto.Role.Id;
|
|
role.DataScope = roleDto.Role.DataScope;
|
|
var res1 = await _repository.UpdateIgnoreNullAsync(role);
|
|
var res3 = await GiveRoleSetDept(new List<long> { roleDto.Role.Id }, roleDto.DeptIds);
|
|
return res1 && res3;
|
|
}
|
|
}
|
|
}
|