123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703 |
- using System.Collections.Generic;
- using System.Linq;
- using System.Threading.Tasks;
- using Microsoft.AspNetCore.Mvc;
- using Microsoft.AspNetCore.Http;
- using Microsoft.Extensions.Options;
- using ZhonTai.Admin.Core.Attributes;
- using ZhonTai.Admin.Core.Configs;
- using ZhonTai.Common.Helpers;
- using ZhonTai.Admin.Core.Dto;
- using ZhonTai.Admin.Domain.Api;
- using ZhonTai.Admin.Domain.PermissionApi;
- using ZhonTai.Admin.Domain.Role;
- using ZhonTai.Admin.Domain.RolePermission;
- using ZhonTai.Admin.Domain.Tenant;
- using ZhonTai.Admin.Domain.User;
- using ZhonTai.Admin.Domain.UserRole;
- using ZhonTai.Admin.Services.Auth.Dto;
- using ZhonTai.Admin.Services.User.Dto;
- using ZhonTai.DynamicApi;
- using ZhonTai.DynamicApi.Attributes;
- using ZhonTai.Admin.Core.Helpers;
- using ZhonTai.Admin.Core.Consts;
- using ZhonTai.Admin.Domain.UserStaff;
- using ZhonTai.Admin.Domain.Org;
- using System.Data;
- using ZhonTai.Admin.Domain.TenantPermission;
- using FreeSql;
- using ZhonTai.Admin.Domain.User.Dto;
- using ZhonTai.Admin.Domain.RoleOrg;
- using ZhonTai.Admin.Domain.UserOrg;
- namespace ZhonTai.Admin.Services.User;
- /// <summary>
- /// 用户服务
- /// </summary>
- [DynamicApi(Area = AdminConsts.AreaName)]
- public class UserService : BaseService, IUserService, IDynamicApi
- {
- private AppConfig _appConfig => LazyGetRequiredService<AppConfig>();
- private IUserRepository _userRepository => LazyGetRequiredService<IUserRepository>();
- private IOrgRepository _orgRepository => LazyGetRequiredService<IOrgRepository>();
- private ITenantRepository _tenantRepository => LazyGetRequiredService<ITenantRepository>();
- private IApiRepository _apiRepository => LazyGetRequiredService<IApiRepository>();
- private IUserStaffRepository _staffRepository => LazyGetRequiredService<IUserStaffRepository>();
- private IUserRoleRepository _userRoleRepository => LazyGetRequiredService<IUserRoleRepository>();
- private IRoleOrgRepository _roleOrgRepository => LazyGetRequiredService<IRoleOrgRepository>();
- private IUserOrgRepository _userOrgRepository => LazyGetRequiredService<IUserOrgRepository>();
- public UserService()
- {
- }
- /// <summary>
- /// 查询用户
- /// </summary>
- /// <param name="id"></param>
- /// <returns></returns>
- public async Task<UserGetOutput> GetAsync(long id)
- {
- var userEntity = await _userRepository.Select
- .WhereDynamic(id)
- .IncludeMany(a => a.Roles.Select(b => new RoleEntity { Id = b.Id, Name = b.Name }))
- .IncludeMany(a => a.Orgs.Select(b => new OrgEntity { Id = b.Id, Name = b.Name }))
- .ToOneAsync(a => new
- {
- a.Id,
- a.UserName,
- a.Name,
- a.Mobile,
- a.Email,
- a.Roles,
- a.Orgs,
- a.OrgId,
- a.ManagerUserId,
- ManagerUserName = a.ManagerUser.Name,
- Staff = new
- {
- a.Staff.JobNumber,
- a.Staff.Sex,
- a.Staff.Position,
- a.Staff.Introduce
- }
- });
- var output = Mapper.Map<UserGetOutput>(userEntity);
- return output;
- }
- /// <summary>
- /// 查询分页
- /// </summary>
- /// <param name="input"></param>
- /// <returns></returns>
- [HttpPost]
- public async Task<PageOutput<UserGetPageOutput>> GetPageAsync(PageInput<UserGetPageDto> input)
- {
- var orgId = input.Filter?.OrgId;
- var list = await _userRepository.Select
- .WhereIf(orgId.HasValue && orgId > 0, a => _userOrgRepository.Where(b => b.UserId == a.Id && b.OrgId == orgId).Any())
- .Where(a=>a.Type != UserType.Member)
- .WhereDynamicFilter(input.DynamicFilter)
- .Count(out var total)
- .OrderByDescending(true, a => a.Id)
- .IncludeMany(a => a.Roles.Select(b => new RoleEntity { Name = b.Name }))
- .Page(input.CurrentPage, input.PageSize)
- .ToListAsync(a => new UserGetPageOutput { Roles = a.Roles });
- if(orgId.HasValue && orgId > 0)
- {
- var managerUserIds = await _userOrgRepository.Select.Where(a => a.OrgId == orgId && a.IsManager == true).ToListAsync(a => a.UserId);
- if (managerUserIds.Any())
- {
- var managerUsers = list.Where(a => managerUserIds.Contains(a.Id));
- foreach (var managerUser in managerUsers)
- {
- managerUser.IsManager = true;
- }
- }
- }
- var data = new PageOutput<UserGetPageOutput>()
- {
- List = Mapper.Map<List<UserGetPageOutput>>(list),
- Total = total
- };
- return data;
- }
- /// <summary>
- /// 查询登录用户信息
- /// </summary>
- /// <param name="id"></param>
- /// <returns></returns>
- [NonAction]
- public async Task<AuthLoginOutput> GetLoginUserAsync(long id)
- {
- var output = new ResultOutput<AuthLoginOutput>();
- var entityDto = await _userRepository.Select.DisableGlobalFilter(FilterNames.Tenant)
- .WhereDynamic(id).ToOneAsync<AuthLoginOutput>();
- if (_appConfig.Tenant && entityDto?.TenantId.Value > 0)
- {
- var tenant = await _tenantRepository.Select.DisableGlobalFilter(FilterNames.Tenant)
- .WhereDynamic(entityDto.TenantId).ToOneAsync(a => new { a.TenantType, a.DbKey });
- entityDto.TenantType = tenant.TenantType;
- entityDto.DbKey = tenant.DbKey;
- }
- return entityDto;
- }
- /// <summary>
- /// 获得数据权限
- /// </summary>
- /// <returns></returns>
- [NonAction]
- public async Task<DataPermissionDto> GetDataPermissionAsync()
- {
- if (!(User?.Id > 0))
- {
- return null;
- }
- var key = CacheKeys.DataPermission + User.Id;
- return await Cache.GetOrSetAsync(key, async () =>
- {
- using (_userRepository.DataFilter.Disable(FilterNames.Self, FilterNames.Data))
- {
- var user = await _userRepository.Select
- .IncludeMany(a => a.Roles.Select(b => new RoleEntity
- {
- Id = b.Id,
- DataScope = b.DataScope
- }))
- .WhereDynamic(User.Id)
- .ToOneAsync(a => new
- {
- a.OrgId,
- a.Roles
- });
- if (user == null)
- return null;
- //数据范围
- DataScope dataScope = DataScope.Self;
- var customRoleIds = new List<long>();
- user.Roles?.ToList().ForEach(role =>
- {
- if (role.DataScope == DataScope.Custom)
- {
- customRoleIds.Add(role.Id);
- }
- else if (role.DataScope <= dataScope)
- {
- dataScope = role.DataScope;
- }
- });
- //部门列表
- var orgIds = new List<long>();
- if (dataScope != DataScope.All)
- {
- //本部门
- if (dataScope == DataScope.Dept)
- {
- orgIds.Add(user.OrgId);
- }
- //本部门和下级部门
- else if (dataScope == DataScope.DeptWithChild)
- {
- orgIds = await _orgRepository
- .Where(a => a.Id == user.OrgId)
- .AsTreeCte()
- .ToListAsync(a => a.Id);
- }
- //指定部门
- if (customRoleIds.Count > 0)
- {
- var customRoleOrgIds = await _roleOrgRepository.Select.Where(a => customRoleIds.Contains(a.RoleId)).ToListAsync(a => a.OrgId);
- orgIds = orgIds.Concat(customRoleOrgIds).ToList();
- }
- }
- return new DataPermissionDto
- {
- OrgId = user.OrgId,
- OrgIds = orgIds.Distinct().ToList(),
- DataScope = dataScope
- };
- }
- });
- }
- /// <summary>
- /// 查询用户基本信息
- /// </summary>
- /// <returns></returns>
- [Login]
- public async Task<UserGetBasicOutput> GetBasicAsync()
- {
- if (!(User?.Id > 0))
- {
- throw ResultOutput.Exception("未登录!");
- }
- var data = await _userRepository.GetAsync<UserGetBasicOutput>(User.Id);
- return data;
- }
- /// <summary>
- /// 查询用户权限信息
- /// </summary>
- /// <returns></returns>
- public async Task<IList<UserPermissionsOutput>> GetPermissionsAsync()
- {
- var key = CacheKeys.UserPermissions + User.Id;
- var result = await Cache.GetOrSetAsync(key, async () =>
- {
- if (User.TenantAdmin)
- {
- var cloud = LazyGetRequiredService<FreeSqlCloud>();
- var db = cloud.Use(DbKeys.AppDb);
- return await db.Select<ApiEntity>()
- .Where(a => db.Select<TenantPermissionEntity, PermissionApiEntity>()
- .InnerJoin((b, c) => b.PermissionId == c.PermissionId && b.TenantId == User.TenantId)
- .Where((b, c) => c.ApiId == a.Id).Any())
- .ToListAsync<UserPermissionsOutput>();
- }
- return await _apiRepository
- .Where(a => _apiRepository.Orm.Select<UserRoleEntity, RolePermissionEntity, PermissionApiEntity>()
- .InnerJoin((b, c, d) => b.RoleId == c.RoleId && b.UserId == User.Id)
- .InnerJoin((b, c, d) => c.PermissionId == d.PermissionId)
- .Where((b, c, d) => d.ApiId == a.Id).Any())
- .ToListAsync<UserPermissionsOutput>();
- });
- return result;
- }
- /// <summary>
- /// 新增用户
- /// </summary>
- /// <param name="input"></param>
- /// <returns></returns>
- [AdminTransaction]
- public virtual async Task<long> AddAsync(UserAddInput input)
- {
- if (await _userRepository.Select.AnyAsync(a => a.UserName == input.UserName))
- {
- throw ResultOutput.Exception($"账号已存在");
- }
- if (input.Mobile.NotNull() && await _userRepository.Select.AnyAsync(a => a.Mobile == input.Mobile))
- {
- throw ResultOutput.Exception($"手机号已存在");
- }
- if (input.Email.NotNull() && await _userRepository.Select.AnyAsync(a => a.Email == input.Email))
- {
- throw ResultOutput.Exception($"邮箱已存在");
- }
- // 用户信息
- if (input.Password.IsNull())
- {
- input.Password = _appConfig.DefaultPassword;
- }
- input.Password = MD5Encrypt.Encrypt32(input.Password);
- var entity = Mapper.Map<UserEntity>(input);
- entity.Type = UserType.DefaultUser;
- var user = await _userRepository.InsertAsync(entity);
- var userId = user.Id;
- //用户角色
- if (input.RoleIds != null && input.RoleIds.Any())
- {
- var roles = input.RoleIds.Select(roleId => new UserRoleEntity
- {
- UserId = userId,
- RoleId = roleId
- }).ToList();
- await _userRoleRepository.InsertAsync(roles);
- }
- // 员工信息
- var staff = input.Staff == null ? new UserStaffEntity() : Mapper.Map<UserStaffEntity>(input.Staff);
- staff.Id = userId;
- await _staffRepository.InsertAsync(staff);
- //所属部门
- if (input.OrgIds != null && input.OrgIds.Any())
- {
- var orgs = input.OrgIds.Select(orgId => new UserOrgEntity
- {
- UserId = userId,
- OrgId = orgId
- }).ToList();
- await _userOrgRepository.InsertAsync(orgs);
- }
- return userId;
- }
- /// <summary>
- /// 新增会员
- /// </summary>
- /// <param name="input"></param>
- /// <returns></returns>
- public virtual async Task<long> AddMemberAsync(UserAddMemberInput input)
- {
- using (_userRepository.DataFilter.DisableAll())
- {
- if (await _userRepository.Select.AnyAsync(a => a.UserName == input.UserName))
- {
- throw ResultOutput.Exception($"账号已存在");
- }
- if (input.Mobile.NotNull() && await _userRepository.Select.AnyAsync(a => a.Mobile == input.Mobile))
- {
- throw ResultOutput.Exception($"手机号已存在");
- }
- if (input.Email.NotNull() && await _userRepository.Select.AnyAsync(a => a.Email == input.Email))
- {
- throw ResultOutput.Exception($"邮箱已存在");
- }
- // 用户信息
- if (input.Password.IsNull())
- {
- input.Password = _appConfig.DefaultPassword;
- }
- input.Password = MD5Encrypt.Encrypt32(input.Password);
- var entity = Mapper.Map<UserEntity>(input);
- entity.Type = UserType.Member;
- var user = await _userRepository.InsertAsync(entity);
- return user.Id;
- }
- }
- /// <summary>
- /// 修改会员
- /// </summary>
- /// <param name="input"></param>
- /// <returns></returns>
- [AdminTransaction]
- public virtual async Task UpdateMemberAsync(UserUpdateMemberInput input)
- {
- var user = await _userRepository.GetAsync(input.Id);
- if (!(user?.Id > 0))
- {
- throw ResultOutput.Exception("用户不存在");
- }
- if (await _userRepository.Select.AnyAsync(a => a.Id != input.Id && a.UserName == input.UserName))
- {
- throw ResultOutput.Exception($"账号已存在");
- }
- if (input.Mobile.NotNull() && await _userRepository.Select.AnyAsync(a => a.Id != input.Id && a.Mobile == input.Mobile))
- {
- throw ResultOutput.Exception($"手机号已存在");
- }
- if (input.Email.NotNull() && await _userRepository.Select.AnyAsync(a => a.Id != input.Id && a.Email == input.Email))
- {
- throw ResultOutput.Exception($"邮箱已存在");
- }
- Mapper.Map(input, user);
- await _userRepository.UpdateAsync(user);
- }
- /// <summary>
- /// 修改用户
- /// </summary>
- /// <param name="input"></param>
- /// <returns></returns>
- [AdminTransaction]
- public virtual async Task UpdateAsync(UserUpdateInput input)
- {
- var user = await _userRepository.GetAsync(input.Id);
- if (!(user?.Id > 0))
- {
- throw ResultOutput.Exception("用户不存在");
- }
- if (input.Id == input.ManagerUserId)
- {
- throw ResultOutput.Exception("直属主管不能是自己");
- }
- if (await _userRepository.Select.AnyAsync(a => a.Id != input.Id && a.UserName == input.UserName))
- {
- throw ResultOutput.Exception($"账号已存在");
- }
- if (input.Mobile.NotNull() && await _userRepository.Select.AnyAsync(a => a.Id != input.Id && a.Mobile == input.Mobile))
- {
- throw ResultOutput.Exception($"手机号已存在");
- }
- if (input.Email.NotNull() && await _userRepository.Select.AnyAsync(a => a.Id != input.Id && a.Email == input.Email))
- {
- throw ResultOutput.Exception($"邮箱已存在");
- }
- Mapper.Map(input, user);
- await _userRepository.UpdateAsync(user);
- var userId = user.Id;
- // 用户角色
- await _userRoleRepository.DeleteAsync(a => a.UserId == userId);
- if (input.RoleIds != null && input.RoleIds.Any())
- {
- var roles = input.RoleIds.Select(roleId => new UserRoleEntity
- {
- UserId = userId,
- RoleId = roleId
- }).ToList();
- await _userRoleRepository.InsertAsync(roles);
- }
- // 员工信息
- var staff = await _staffRepository.GetAsync(userId);
- if(staff == null)
- {
- staff = new UserStaffEntity();
- }
- Mapper.Map(input.Staff, staff);
- staff.Id = userId;
- await _staffRepository.InsertOrUpdateAsync(staff);
- //所属部门
- await _userOrgRepository.DeleteAsync(a => a.UserId == userId);
- if (input.OrgIds != null && input.OrgIds.Any())
- {
- var orgs = input.OrgIds.Select(orgId => new UserOrgEntity
- {
- UserId = userId,
- OrgId = orgId
- }).ToList();
- await _userOrgRepository.InsertAsync(orgs);
- }
- await Cache.DelAsync(CacheKeys.DataPermission + user.Id);
- }
- /// <summary>
- /// 更新用户基本信息
- /// </summary>
- /// <param name="input"></param>
- /// <returns></returns>
- [Login]
- public async Task UpdateBasicAsync(UserUpdateBasicInput input)
- {
- var entity = await _userRepository.GetAsync(input.Id);
- entity = Mapper.Map(input, entity);
- await _userRepository.UpdateAsync(entity);
- }
- /// <summary>
- /// 修改用户密码
- /// </summary>
- /// <param name="input"></param>
- /// <returns></returns>
- [Login]
- public async Task ChangePasswordAsync(UserChangePasswordInput input)
- {
- if (input.ConfirmPassword != input.NewPassword)
- {
- throw ResultOutput.Exception("新密码和确认密码不一致");
- }
- var entity = await _userRepository.GetAsync(input.Id);
- var oldPassword = MD5Encrypt.Encrypt32(input.OldPassword);
- if (oldPassword != entity.Password)
- {
- throw ResultOutput.Exception("旧密码不正确");
- }
- entity.Password = MD5Encrypt.Encrypt32(input.NewPassword);
- await _userRepository.UpdateAsync(entity);
- }
- /// <summary>
- /// 重置密码
- /// </summary>
- /// <param name="input"></param>
- /// <returns></returns>
- public async Task<string> ResetPasswordAsync(UserResetPasswordInput input)
- {
- var entity = await _userRepository.GetAsync(input.Id);
- var password = input.Password;
- if (password.IsNull())
- {
- password = _appConfig.DefaultPassword;
- }
- if (password.IsNull())
- {
- password = "111111";
- }
- entity.Password = MD5Encrypt.Encrypt32(password);
- await _userRepository.UpdateAsync(entity);
- return password;
- }
- /// <summary>
- /// 设置主管
- /// </summary>
- /// <param name="input"></param>
- /// <returns></returns>
- public async Task SetManagerAsync(UserSetManagerInput input)
- {
- var entity = await _userOrgRepository.Where(a => a.UserId == input.UserId && a.OrgId == input.OrgId).FirstAsync();
- entity.IsManager = input.IsManager;
- await _userOrgRepository.UpdateAsync(entity);
- }
- /// <summary>
- /// 彻底删除用户
- /// </summary>
- /// <param name="id"></param>
- /// <returns></returns>
- [AdminTransaction]
- public virtual async Task DeleteAsync(long id)
- {
- var user = await _userRepository.Select.WhereDynamic(id).ToOneAsync(a => new { a.Type });
- if(user == null)
- {
- throw ResultOutput.Exception("用户不存在");
- }
- if(user.Type == UserType.PlatformAdmin || user.Type == UserType.TenantAdmin)
- {
- throw ResultOutput.Exception("平台管理员禁止删除");
- }
- //删除用户角色
- await _userRoleRepository.DeleteAsync(a => a.UserId == id);
- //删除用户所属部门
- await _userOrgRepository.DeleteAsync(a => a.UserId == id);
- //删除员工
- await _staffRepository.DeleteAsync(a => a.Id == id);
- //删除用户
- await _userRepository.DeleteAsync(a => a.Id == id);
- await Cache.DelAsync(CacheKeys.DataPermission + id);
- }
- /// <summary>
- /// 批量彻底删除用户
- /// </summary>
- /// <param name="ids"></param>
- /// <returns></returns>
- [AdminTransaction]
- public virtual async Task BatchDeleteAsync(long[] ids)
- {
- var admin = await _userRepository.Select.Where(a => ids.Contains(a.Id) &&
- (a.Type == UserType.PlatformAdmin || a.Type == UserType.TenantAdmin)).AnyAsync();
- if (admin)
- {
- throw ResultOutput.Exception("平台管理员禁止删除");
- }
-
- //删除用户角色
- await _userRoleRepository.DeleteAsync(a => ids.Contains(a.UserId));
- //删除用户所属部门
- await _userOrgRepository.DeleteAsync(a => ids.Contains(a.UserId));
- //删除员工
- await _staffRepository.DeleteAsync(a => ids.Contains(a.Id));
- //删除用户
- await _userRepository.DeleteAsync(a => ids.Contains(a.Id));
- foreach (var userId in ids)
- {
- await Cache.DelAsync(CacheKeys.DataPermission + userId);
- }
- }
- /// <summary>
- /// 删除用户
- /// </summary>
- /// <param name="id"></param>
- /// <returns></returns>
- [AdminTransaction]
- public virtual async Task SoftDeleteAsync(long id)
- {
- var user = await _userRepository.Select.WhereDynamic(id).ToOneAsync(a => new { a.Type });
- if (user == null)
- {
- throw ResultOutput.Exception("用户不存在");
- }
- if (user.Type == UserType.PlatformAdmin || user.Type == UserType.TenantAdmin)
- {
- throw ResultOutput.Exception("平台管理员禁止删除");
- }
- await _userRoleRepository.DeleteAsync(a => a.UserId == id);
- await _userOrgRepository.DeleteAsync(a => a.UserId == id);
- await _staffRepository.SoftDeleteAsync(a => a.Id == id);
- await _userRepository.SoftDeleteAsync(id);
- await Cache.DelAsync(CacheKeys.DataPermission + id);
- }
- /// <summary>
- /// 批量删除用户
- /// </summary>
- /// <param name="ids"></param>
- /// <returns></returns>
- [AdminTransaction]
- public virtual async Task BatchSoftDeleteAsync(long[] ids)
- {
- var admin = await _userRepository.Select.Where(a => ids.Contains(a.Id) &&
- (a.Type == UserType.PlatformAdmin || a.Type == UserType.TenantAdmin)).AnyAsync();
- if (admin)
- {
- throw ResultOutput.Exception("平台管理员禁止删除");
- }
- await _userRoleRepository.DeleteAsync(a => ids.Contains(a.UserId));
- await _userOrgRepository.DeleteAsync(a => ids.Contains(a.UserId));
- await _staffRepository.SoftDeleteAsync(a => ids.Contains(a.Id));
- await _userRepository.SoftDeleteAsync(ids);
- foreach (var userId in ids)
- {
- await Cache.DelAsync(CacheKeys.DataPermission + userId);
- }
- }
- /// <summary>
- /// 上传头像
- /// </summary>
- /// <param name="file"></param>
- /// <returns></returns>
- [HttpPost]
- [Login]
- public async Task<string> AvatarUpload([FromForm] IFormFile file)
- {
- var uploadConfig = LazyGetRequiredService<IOptionsMonitor<UploadConfig>>().CurrentValue;
- var uploadHelper = LazyGetRequiredService<UploadHelper>();
- var config = uploadConfig.Avatar;
- var fileInfo = await uploadHelper.UploadAsync(file, config, new { User.Id });
- return fileInfo.FileRelativePath;
- }
- }
|