|
|
|
|
|
using Furion.DataEncryption;
|
|
|
using Furion.DependencyInjection;
|
|
|
using Furion.DynamicApiController;
|
|
|
using Furion.FriendlyException;
|
|
|
using Myshipping.Core.Entity;
|
|
|
using Mapster;
|
|
|
using Microsoft.AspNetCore.Http;
|
|
|
using Microsoft.AspNetCore.Mvc;
|
|
|
using MiniExcelLibs;
|
|
|
using SqlSugar;
|
|
|
using System;
|
|
|
using System.Collections.Generic;
|
|
|
using System.IO;
|
|
|
using System.Linq;
|
|
|
using System.Threading.Tasks;
|
|
|
using Yitter.IdGenerator;
|
|
|
using Furion;
|
|
|
|
|
|
namespace Myshipping.Core.Service;
|
|
|
|
|
|
/// <summary>
|
|
|
/// 用户服务
|
|
|
/// </summary>
|
|
|
[ApiDescriptionSettings(Name = "User", Order = 150)]
|
|
|
public class SysUserService : ISysUserService, IDynamicApiController, ITransient
|
|
|
{
|
|
|
private readonly SqlSugarRepository<SysUser> _sysUserRep; // 用户表仓储
|
|
|
private readonly ISysCacheService _sysCacheService;
|
|
|
private readonly ISysConfigService _sysConfigService;
|
|
|
private readonly ISysEmpService _sysEmpService;
|
|
|
private readonly ISysUserDataScopeService _sysUserDataScopeService;
|
|
|
private readonly ISysUserRoleService _sysUserRoleService;
|
|
|
|
|
|
public SysUserService(SqlSugarRepository<SysUser> sysUserRep,
|
|
|
ISysCacheService sysCacheService,
|
|
|
ISysEmpService sysEmpService,
|
|
|
ISysUserDataScopeService sysUserDataScopeService,
|
|
|
ISysUserRoleService sysUserRoleService,
|
|
|
ISysConfigService sysConfigService)
|
|
|
{
|
|
|
_sysUserRep = sysUserRep;
|
|
|
_sysCacheService = sysCacheService;
|
|
|
_sysEmpService = sysEmpService;
|
|
|
_sysUserDataScopeService = sysUserDataScopeService;
|
|
|
_sysUserRoleService = sysUserRoleService;
|
|
|
_sysConfigService = sysConfigService;
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 分页查询用户
|
|
|
/// </summary>
|
|
|
/// <param name="input"></param>
|
|
|
/// <returns></returns>
|
|
|
[HttpGet("/sysUser/page")]
|
|
|
public async Task<dynamic> QueryUserPageList([FromQuery] UserInput input)
|
|
|
{
|
|
|
var superAdmin = UserManager.IsSuperAdmin;
|
|
|
var searchValue = input.SearchValue;
|
|
|
var pid = input.SysEmpParam.OrgId;
|
|
|
var users = await _sysUserRep.AsQueryable().InnerJoin<SysEmp>((u, e) => u.Id == e.Id)
|
|
|
.InnerJoin<SysOrg>((u, e, o) => e.OrgId == o.Id)
|
|
|
.InnerJoin<SysTenant>((u, e, o, t) => u.TenantId == t.Id)
|
|
|
.WhereIF(!string.IsNullOrWhiteSpace(searchValue), (u, e, o) => u.Account.Contains(input.SearchValue.Trim()) ||
|
|
|
u.Name.Contains(input.SearchValue.Trim()) ||
|
|
|
u.Phone.Contains(input.SearchValue.Trim()))
|
|
|
.WhereIF(!string.IsNullOrWhiteSpace(pid), (u, e, o) => e.OrgId == long.Parse(pid) ||
|
|
|
o.Pids.Contains(pid.Trim()))
|
|
|
.WhereIF(Enum.IsDefined(typeof(CommonStatus), input.SearchStatus), (u, e, o) => u.Status == input.SearchStatus)
|
|
|
.Where((u, e, o) => u.AdminType == AdminType.None)
|
|
|
.Select<UserOutput>("u.*,t.Name As TenantName ").ToDataFilter("u", "Id", FilterType.User).ToPagedListAsync(input.PageNo, input.PageSize);
|
|
|
|
|
|
var empInfos = await _sysEmpService.GetEmpInfo(users.Items.Select(m => long.Parse(m.Id)).ToList());
|
|
|
foreach (var user in users.Items)
|
|
|
{
|
|
|
user.SysEmpInfo = empInfos.FirstOrDefault(m => m.Id == long.Parse(user.Id));
|
|
|
}
|
|
|
|
|
|
//foreach (var user in users.Items)
|
|
|
//{
|
|
|
// user.SysEmpInfo = await _sysEmpService.GetEmpInfo(long.Parse(user.Id));
|
|
|
//}
|
|
|
return users.XnPagedResult();
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 增加用户
|
|
|
/// </summary>
|
|
|
/// <param name="input"></param>
|
|
|
/// <returns></returns>
|
|
|
[HttpPost("/sysUser/add")]
|
|
|
public async Task AddUser(AddUserInput input)
|
|
|
{
|
|
|
// 数据范围检查
|
|
|
CheckDataScope(input.SysEmpParam == null || string.IsNullOrEmpty(input.SysEmpParam.OrgId) ? 0 : long.Parse(input.SysEmpParam.OrgId));
|
|
|
|
|
|
var isExist = await _sysUserRep.AnyAsync(u => u.Account == input.Account);
|
|
|
if (isExist) throw Oops.Oh(ErrorCode.D1003);
|
|
|
|
|
|
var keyDES = App.GetOptions<EncryptKeyOptions>().DES;
|
|
|
var user = input.Adapt<SysUser>();
|
|
|
user.AdminType = AdminType.None;
|
|
|
user.Password = DESCEncryption.Encrypt(input.Password, keyDES);
|
|
|
if (string.IsNullOrEmpty(user.Name))
|
|
|
user.Name = user.Account;
|
|
|
if (string.IsNullOrEmpty(user.NickName))
|
|
|
user.NickName = user.Account;
|
|
|
|
|
|
try
|
|
|
{
|
|
|
_sysUserRep.CurrentBeginTran();
|
|
|
var newUser = await _sysUserRep.InsertReturnEntityAsync(user);
|
|
|
input.SysEmpParam.Id = newUser.Id.ToString();
|
|
|
// 增加员工信息
|
|
|
await _sysEmpService.AddOrUpdate(input.SysEmpParam);
|
|
|
_sysUserRep.CurrentCommitTran();
|
|
|
await _sysCacheService.DelByPatternAsync(CommonConst.CACHE_KEY_USERSDATASCOPE);
|
|
|
}
|
|
|
catch (Exception)
|
|
|
{
|
|
|
_sysUserRep.CurrentRollbackTran();
|
|
|
throw;
|
|
|
}
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 删除用户
|
|
|
/// </summary>
|
|
|
/// <param name="input"></param>
|
|
|
/// <returns></returns>
|
|
|
[HttpPost("/sysUser/delete")]
|
|
|
public async Task DeleteUser(DeleteUserInput input)
|
|
|
{
|
|
|
var user = await _sysUserRep.FirstOrDefaultAsync(u => u.Id == input.Id);
|
|
|
if (user.AdminType != AdminType.None)
|
|
|
throw Oops.Oh(ErrorCode.D1014);
|
|
|
|
|
|
if (user.Account == UserManager.Account)
|
|
|
{
|
|
|
throw Oops.Oh(ErrorCode.D1001);
|
|
|
}
|
|
|
|
|
|
// 数据范围检查
|
|
|
CheckDataScopeByUserId(input.Id);
|
|
|
|
|
|
try
|
|
|
{
|
|
|
_sysUserRep.CurrentBeginTran();
|
|
|
// 直接删除用户
|
|
|
await _sysUserRep.AsUpdateable(new SysUser { IsDeleted = true }).UpdateColumns(user.FalseDeleteColumn()).Where(wh => wh.Id == user.Id).ExecuteCommandAsync();
|
|
|
|
|
|
// 删除员工及附属机构职位信息
|
|
|
await _sysEmpService.DeleteEmpInfoByUserId(user.Id);
|
|
|
|
|
|
//删除该用户对应的用户-角色表关联信息
|
|
|
await _sysUserRoleService.DeleteUserRoleListByUserId(user.Id);
|
|
|
|
|
|
//删除该用户对应的用户-数据范围表关联信息
|
|
|
await _sysUserDataScopeService.DeleteUserDataScopeListByUserId(user.Id);
|
|
|
_sysUserRep.CurrentCommitTran();
|
|
|
await _sysCacheService.DelByPatternAsync(CommonConst.CACHE_KEY_USERSDATASCOPE);
|
|
|
}
|
|
|
catch (Exception)
|
|
|
{
|
|
|
_sysUserRep.CurrentRollbackTran();
|
|
|
throw;
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 更新用户
|
|
|
/// </summary>
|
|
|
/// <param name="input"></param>
|
|
|
/// <returns></returns>
|
|
|
[HttpPost("/sysUser/edit")]
|
|
|
public async Task UpdateUser(UpdateUserInput input)
|
|
|
{
|
|
|
// 数据范围检查
|
|
|
CheckDataScopeByUserId(input.Id);
|
|
|
|
|
|
// 排除自己并且判断与其他是否相同
|
|
|
var isExist = await _sysUserRep.AnyAsync(u => u.Account == input.Account && u.Id != input.Id);
|
|
|
if (isExist) throw Oops.Oh(ErrorCode.D1003);
|
|
|
|
|
|
var user = input.Adapt<SysUser>();
|
|
|
|
|
|
try
|
|
|
{
|
|
|
_sysUserRep.CurrentBeginTran();
|
|
|
await _sysUserRep.AsUpdateable(user).IgnoreColumns(it => new { it.Password, it.Status, it.AdminType }).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommandAsync();
|
|
|
input.SysEmpParam.Id = user.Id.ToString();
|
|
|
// 更新员工及附属机构职位信息
|
|
|
await _sysEmpService.AddOrUpdate(input.SysEmpParam);
|
|
|
_sysUserRep.CurrentCommitTran();
|
|
|
await _sysCacheService.DelByPatternAsync(CommonConst.CACHE_KEY_USERSDATASCOPE);
|
|
|
}
|
|
|
catch (Exception)
|
|
|
{
|
|
|
_sysUserRep.CurrentRollbackTran();
|
|
|
throw;
|
|
|
}
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 查看用户
|
|
|
/// </summary>
|
|
|
/// <param name="input"></param>
|
|
|
/// <returns></returns>
|
|
|
[HttpGet("/sysUser/detail")]
|
|
|
public async Task<dynamic> GetUser([FromQuery] QueryUserInput input)
|
|
|
{
|
|
|
var user = await _sysUserRep.FirstOrDefaultAsync(u => u.Id == input.Id);
|
|
|
var userDto = user.Adapt<UserOutput>();
|
|
|
if (userDto != null)
|
|
|
{
|
|
|
userDto.SysEmpInfo = await _sysEmpService.GetEmpInfo(user.Id);
|
|
|
}
|
|
|
return userDto;
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 修改用户状态
|
|
|
/// </summary>
|
|
|
/// <param name="input"></param>
|
|
|
/// <returns></returns>
|
|
|
[HttpPost("/sysUser/changeStatus")]
|
|
|
public async Task ChangeUserStatus(UpdateUserInput input)
|
|
|
{
|
|
|
var user = await _sysUserRep.FirstOrDefaultAsync(u => u.Id == input.Id);
|
|
|
if (user.AdminType == AdminType.SuperAdmin)
|
|
|
throw Oops.Oh(ErrorCode.D1015);
|
|
|
|
|
|
if (!Enum.IsDefined(typeof(CommonStatus), input.Status))
|
|
|
throw Oops.Oh(ErrorCode.D3005);
|
|
|
user.Status = input.Status;
|
|
|
await _sysUserRep.AsUpdateable(user).ExecuteCommandAsync();
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 授权用户角色
|
|
|
/// </summary>
|
|
|
/// <param name="input"></param>
|
|
|
/// <returns></returns>
|
|
|
[HttpPost("/sysUser/grantRole")]
|
|
|
public async Task GrantUserRole(UpdateUserInput input)
|
|
|
{
|
|
|
// 数据范围检查
|
|
|
CheckDataScopeByUserId(input.Id);
|
|
|
await _sysUserRoleService.GrantRole(input);
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 授权用户数据范围
|
|
|
/// </summary>
|
|
|
/// <param name="input"></param>
|
|
|
/// <returns></returns>
|
|
|
[HttpPost("/sysUser/grantData")]
|
|
|
public async Task GrantUserData(UpdateUserInput input)
|
|
|
{
|
|
|
// 清除缓存
|
|
|
await _sysCacheService.DelAsync(CommonConst.CACHE_KEY_DATASCOPE + $"{input.Id}");
|
|
|
await _sysCacheService.DelAsync(CommonConst.CACHE_KEY_USERSDATASCOPE + $"{input.Id}");
|
|
|
// 数据范围检查
|
|
|
CheckDataScopeByUserId(input.Id);
|
|
|
await _sysUserDataScopeService.GrantData(input);
|
|
|
await _sysCacheService.DelByPatternAsync(CommonConst.CACHE_KEY_USERSDATASCOPE);
|
|
|
await _sysCacheService.DelByPatternAsync(CommonConst.CACHE_KEY_DATASCOPE);
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 更新用户信息
|
|
|
/// </summary>
|
|
|
/// <param name="input"></param>
|
|
|
/// <returns></returns>
|
|
|
[HttpPost("/sysUser/updateInfo")]
|
|
|
public async Task UpdateUserInfo(UpdateUserInput input)
|
|
|
{
|
|
|
var user = input.Adapt<SysUser>();
|
|
|
await _sysUserRep.AsUpdateable(user)
|
|
|
.IgnoreColumns(ignoreAllNullColumns: true)
|
|
|
.IgnoreColumns(it => new { it.AdminType, it.LastLoginTime })
|
|
|
.ExecuteCommandAsync();
|
|
|
await _sysCacheService.DelByPatternAsync(CommonConst.CACHE_KEY_USERSDATASCOPE);
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 修改用户密码
|
|
|
/// </summary>
|
|
|
/// <param name="input"></param>
|
|
|
/// <returns></returns>
|
|
|
[HttpPost("/sysUser/updatePwd")]
|
|
|
public async Task UpdateUserPwd(ChangePasswordUserInput input)
|
|
|
{
|
|
|
var keyDES = App.GetOptions<EncryptKeyOptions>().DES;
|
|
|
var user = await _sysUserRep.FirstOrDefaultAsync(u => u.Id == input.Id);
|
|
|
if (DESCEncryption.Encrypt(input.Password, keyDES) != user.Password)
|
|
|
throw Oops.Oh(ErrorCode.D1004);
|
|
|
user.Password = DESCEncryption.Encrypt(input.NewPassword, keyDES);
|
|
|
await _sysUserRep.AsUpdateable(user).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommandAsync();
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 获取用户拥有角色
|
|
|
/// </summary>
|
|
|
/// <param name="input"></param>
|
|
|
/// <returns></returns>
|
|
|
[HttpGet("/sysUser/ownRole")]
|
|
|
public async Task<dynamic> GetUserOwnRole([FromQuery] QueryUserInput input)
|
|
|
{
|
|
|
return await _sysUserRoleService.GetUserRoleIdList(input.Id);
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 获取用户拥有数据
|
|
|
/// </summary>
|
|
|
/// <param name="input"></param>
|
|
|
/// <returns></returns>
|
|
|
[HttpGet("/sysUser/ownData")]
|
|
|
public async Task<dynamic> GetUserOwnData([FromQuery] QueryUserInput input)
|
|
|
{
|
|
|
return await _sysUserDataScopeService.GetUserDataScopeIdList(input.Id);
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 重置用户密码
|
|
|
/// </summary>
|
|
|
/// <param name="input"></param>
|
|
|
/// <returns></returns>
|
|
|
[HttpPost("/sysUser/resetPwd")]
|
|
|
public async Task ResetUserPwd(QueryUserInput input)
|
|
|
{
|
|
|
var keyDES = App.GetOptions<EncryptKeyOptions>().DES;
|
|
|
var user = await _sysUserRep.FirstOrDefaultAsync(u => u.Id == input.Id);
|
|
|
user.Password = DESCEncryption.Encrypt(await _sysConfigService.GetDefaultPassword(), keyDES);
|
|
|
await _sysUserRep.AsUpdateable(user).IgnoreColumns(it => new { it.AdminType }).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommandAsync();
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 修改用户头像
|
|
|
/// </summary>
|
|
|
/// <param name="input"></param>
|
|
|
/// <returns></returns>
|
|
|
[HttpPost("/sysUser/updateAvatar")]
|
|
|
public async Task UpdateAvatar(UploadAvatarInput input)
|
|
|
{
|
|
|
var user = await _sysUserRep.FirstOrDefaultAsync(u => u.Id == input.Id);
|
|
|
user.Avatar = input.Avatar.ToString();
|
|
|
await _sysUserRep.AsUpdateable(user).IgnoreColumns(it => new { it.AdminType }).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommandAsync();
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 获取用户选择器
|
|
|
/// </summary>
|
|
|
/// <param name="input"></param>
|
|
|
/// <returns></returns>
|
|
|
[HttpGet("/sysUser/selector")]
|
|
|
public async Task<dynamic> GetUserSelector([FromQuery] UserInput input)
|
|
|
{
|
|
|
return await _sysUserRep.AsQueryable()
|
|
|
.WhereIF(!string.IsNullOrWhiteSpace(input.Name), u => (u.Name.Contains(input.Name.Trim())))
|
|
|
.Where(u => u.Status != CommonStatus.DELETED)
|
|
|
.Where(u => u.AdminType != AdminType.SuperAdmin)
|
|
|
.Select(u => new
|
|
|
{
|
|
|
u.Id,
|
|
|
u.Name
|
|
|
}).ToListAsync();
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 用户导出
|
|
|
/// </summary>
|
|
|
/// <param name="input"></param>
|
|
|
/// <returns></returns>
|
|
|
[HttpGet("/sysUser/export")]
|
|
|
public async Task<IActionResult> ExportUser([FromQuery] UserInput input)
|
|
|
{
|
|
|
|
|
|
//这里如果报错看下AdminType的值 不能是0，必须是在枚举值内的
|
|
|
var users = await _sysUserRep.ToListAsync();
|
|
|
var uu= users.Adapt<List<_SysUser>>();
|
|
|
if (!users.Any()) {
|
|
|
throw Oops.Oh("没有数据");
|
|
|
}
|
|
|
using (MemoryStream ms = new MemoryStream()) {
|
|
|
ms.SaveAs(uu);
|
|
|
ms.Seek(0, SeekOrigin.Begin);
|
|
|
return await Task.FromResult(new FileStreamResult(ms, "application/vnd.openxmlformats-officedocument.spreadsheetml.sheet")
|
|
|
{
|
|
|
FileDownloadName = "user.xlsx"
|
|
|
});
|
|
|
}
|
|
|
}
|
|
|
|
|
|
|
|
|
/// 用户导入
|
|
|
/// </summary>
|
|
|
/// <param name="file"></param>
|
|
|
/// <returns></returns>
|
|
|
[HttpPost("/sysUser/import")]
|
|
|
public async Task ImportUser(IFormFile file)
|
|
|
{
|
|
|
var path = Path.Combine(Path.GetTempPath(), $"{YitIdHelper.NextId()}.xlsx");
|
|
|
using (var stream = File.Create(path))
|
|
|
{
|
|
|
await file.CopyToAsync(stream);
|
|
|
}
|
|
|
throw Oops.Oh("请自行完善入库操作");
|
|
|
|
|
|
//var rows = MiniExcel.Query(path); // 解析
|
|
|
//foreach (var row in rows)
|
|
|
//{
|
|
|
// var a = row.A;
|
|
|
// var b = row.B;
|
|
|
// // 入库等操作
|
|
|
|
|
|
//}
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 根据用户Id获取用户
|
|
|
/// </summary>
|
|
|
/// <param name="userId"></param>
|
|
|
/// <returns></returns>
|
|
|
[NonAction]
|
|
|
public async Task<dynamic> GetUserById(long userId)
|
|
|
{
|
|
|
return await _sysUserRep.FirstOrDefaultAsync(u => u.Id == userId);
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 将OAuth账号转换成账号
|
|
|
/// </summary>
|
|
|
/// <param name="authUser"></param>
|
|
|
/// <param name="sysUser"></param>
|
|
|
/// <returns></returns>
|
|
|
[NonAction]
|
|
|
public async Task SaveAuthUserToUser(AuthUserInput authUser, UserInput sysUser)
|
|
|
{
|
|
|
var user = sysUser.Adapt<SysUser>();
|
|
|
user.AdminType = AdminType.None; // 非管理员
|
|
|
|
|
|
// oauth账号与系统账号判断
|
|
|
var isExist = await _sysUserRep.AnyAsync(u => u.Account == authUser.Username);
|
|
|
user.Account = isExist ? authUser.Username + DateTime.Now.Ticks : authUser.Username;
|
|
|
user.Name = user.NickName = authUser.Nickname;
|
|
|
user.Email = authUser.Email;
|
|
|
user.Sex = authUser.Gender;
|
|
|
await _sysUserRep.InsertAsync(user);
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 获取用户数据范围（机构Id集合）并缓存
|
|
|
/// </summary>
|
|
|
/// <param name="userId"></param>
|
|
|
/// <returns></returns>
|
|
|
[NonAction]
|
|
|
public async Task<List<long>> GetUserDataScopeIdList(long userId = 0)
|
|
|
{
|
|
|
userId = userId <= 0 ? UserManager.UserId : userId;
|
|
|
var dataScopes = await _sysCacheService.GetDataScope(userId); // 先从缓存里面读取
|
|
|
if (dataScopes == null || dataScopes.Count < 1)
|
|
|
{
|
|
|
if (!UserManager.IsSuperAdmin && !UserManager.IsTenantAdmin)
|
|
|
{
|
|
|
var orgId = await _sysEmpService.GetEmpOrgId(userId);
|
|
|
// 获取该用户对应的数据范围集合
|
|
|
var userDataScopeIdListForUser = await _sysUserDataScopeService.GetUserDataScopeIdList(userId);
|
|
|
// 获取该用户的角色对应的数据范围集合
|
|
|
var userDataScopeIdListForRole = await _sysUserRoleService.GetUserRoleDataScopeIdList(userId, orgId);
|
|
|
dataScopes = userDataScopeIdListForUser.Concat(userDataScopeIdListForRole).Distinct().ToList(); // 并集
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
dataScopes = await _sysUserRep.Change<SysOrg>().AsQueryable().Select(u => u.Id).ToListAsync();
|
|
|
}
|
|
|
await _sysCacheService.SetDataScope(userId, dataScopes); // 缓存结果
|
|
|
}
|
|
|
return dataScopes;
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 检查普通用户数据范围
|
|
|
/// </summary>
|
|
|
/// <param name="orgId"></param>
|
|
|
/// <returns></returns>
|
|
|
[NonAction]
|
|
|
public async void CheckDataScope(long orgId)
|
|
|
{
|
|
|
// 如果当前用户不是超级管理员，则进行数据范围校验
|
|
|
if (!UserManager.IsSuperAdmin)
|
|
|
{
|
|
|
var dataScopes = await GetUserDataScopeIdList(UserManager.UserId);
|
|
|
if (dataScopes == null || orgId <= 0 || !dataScopes.Contains(orgId))
|
|
|
throw Oops.Oh(ErrorCode.D1013);
|
|
|
}
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 获取用户数据范围（用户Id集合）
|
|
|
/// </summary>
|
|
|
/// <returns></returns>
|
|
|
[NonAction]
|
|
|
public async Task<List<long>> GetDataScopeIdUserList(long userId = 0)
|
|
|
{
|
|
|
userId = userId <= 0 ? UserManager.UserId : userId;
|
|
|
var list = await _sysCacheService.GetUsersDataScope(userId); // 先从缓存里面读取
|
|
|
if (list == null || list.Count < 1)
|
|
|
{
|
|
|
var dataScopes = await GetUserDataScopeIdList(userId);
|
|
|
list = (await _sysEmpService.HasOrgEmp(dataScopes)).Select(a => a.Id).ToList();
|
|
|
list.Add(userId);
|
|
|
list = list.Distinct().ToList();
|
|
|
await _sysCacheService.SetUsersDataScope(userId, list); // 缓存结果
|
|
|
}
|
|
|
return list;
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 检查普通用户数据范围
|
|
|
/// </summary>
|
|
|
/// <param name="userId"></param>
|
|
|
/// <returns></returns>
|
|
|
[NonAction]
|
|
|
public async void CheckDataScopeByUserId(long userId)
|
|
|
{
|
|
|
// 如果当前用户不是超级管理员，则进行数据范围校验
|
|
|
if (!UserManager.IsSuperAdmin)
|
|
|
{
|
|
|
var dataScopes = await GetDataScopeIdUserList(UserManager.UserId);
|
|
|
if (dataScopes == null || userId <= 0 || !dataScopes.Contains(userId))
|
|
|
throw Oops.Oh(ErrorCode.D1013);
|
|
|
}
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 获取租户下的用户
|
|
|
/// </summary>
|
|
|
/// <param name="name"></param>
|
|
|
/// <returns></returns>
|
|
|
[HttpGet("/sysUser/GetTenantUser")]
|
|
|
public Task<List<SysUser>> GetTenantUser(string name)
|
|
|
{
|
|
|
return _sysUserRep.AsQueryable().Where(x => x.TenantId == Convert.ToInt64(UserManager.TENANT_ID)).WhereIF(!string.IsNullOrWhiteSpace(name), x => x.Name.Contains(name)).ToListAsync();
|
|
|
}
|
|
|
|
|
|
}
|