123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218 |
- using System.Linq;
- using System.Threading.Tasks;
- using System.Collections.Generic;
- using Admin.Core.Common.Helpers;
- using Admin.Core.Common.Cache;
- using Admin.Core.Common.Input;
- using Admin.Core.Common.Output;
- using Admin.Core.Model.Admin;
- using Admin.Core.Repository.Admin;
- using Admin.Core.Service.Admin.User.Input;
- using Admin.Core.Service.Admin.User.Output;
- using Admin.Core.Common.Attributes;
- using Admin.Core.Service.Admin.Auth.Output;
- namespace Admin.Core.Service.Admin.User
- {
- /// <summary>
- /// 用户服务
- /// </summary>
- public class UserService : BaseService, IUserService
- {
- private readonly ICache _cache;
- private readonly IUserRepository _userRepository;
- private readonly IUserRoleRepository _userRoleRepository;
- private readonly IRolePermissionRepository _rolePermissionRepository;
- public UserService(
- ICache cache,
- IUserRepository userRepository,
- IUserRoleRepository userRoleRepository,
- IRolePermissionRepository rolePermissionRepository
- )
- {
- _cache = cache;
- _userRepository = userRepository;
- _userRoleRepository = userRoleRepository;
- _rolePermissionRepository = rolePermissionRepository;
- }
- public async Task<ResponseOutput<AuthLoginOutput>> GetLoginUserAsync(long id)
- {
- var output = new ResponseOutput<AuthLoginOutput>();
- var entityDto = await _userRepository.GetAsync<AuthLoginOutput>(id);
- return output.Ok(entityDto);
- }
- public async Task<ResponseOutput<UserGetOutput>> GetAsync(long id)
- {
- var res = new ResponseOutput<UserGetOutput>();
- var entity = await _userRepository.Select
- .WhereDynamic(id)
- .IncludeMany(a => a.Roles.Select(b => new RoleEntity { Id = b.Id }))
- .ToOneAsync();
- var entityDto = Mapper.Map<UserGetOutput>(entity);
- return res.Ok(entityDto);
- }
- public async Task<IResponseOutput> GetBasicAsync()
- {
- if (!(User?.Id > 0))
- {
- return ResponseOutput.NotOk("未登录!");
- }
- var data = await _userRepository.GetAsync<UserUpdateBasicInput>(User.Id);
- return ResponseOutput.Ok(data);
- }
- public async Task<IList<UserPermissionsOutput>> GetPermissionsAsync()
- {
- var key = string.Format(CacheKey.UserPermissions, User.Id);
- var result = await _cache.GetOrSetAsync(key, async () =>
- {
- var userPermissoins = await _rolePermissionRepository.Select
- .InnerJoin<UserRoleEntity>((a, b) => a.RoleId == b.RoleId && b.UserId == User.Id && a.Permission.Type == PermissionType.Api)
- .Include(a => a.Permission.Api)
- .Distinct()
- .ToListAsync(a => new UserPermissionsOutput { HttpMethods = a.Permission.Api.HttpMethods, Path = a.Permission.Api.Path });
- return userPermissoins;
- });
- return result;
- }
- public async Task<IResponseOutput> PageAsync(PageInput<UserEntity> input)
- {
- var list = await _userRepository.Select
- .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();
- var data = new PageOutput<UserListOutput>()
- {
- List = Mapper.Map<List<UserListOutput>>(list),
- Total = total
- };
- return ResponseOutput.Ok(data);
- }
- [Transaction]
- public async Task<IResponseOutput> AddAsync(UserAddInput input)
- {
- if (input.Password.IsNull())
- {
- input.Password = "111111";
- }
- input.Password = MD5Encrypt.Encrypt32(input.Password);
- var entity = Mapper.Map<UserEntity>(input);
- var user = await _userRepository.InsertAsync(entity);
- if (!(user?.Id > 0))
- {
- return ResponseOutput.NotOk();
- }
- if (input.RoleIds != null && input.RoleIds.Any())
- {
- var roles = input.RoleIds.Select(a => new UserRoleEntity { UserId = user.Id, RoleId = a });
- await _userRoleRepository.InsertAsync(roles);
- }
- return ResponseOutput.Ok();
- }
- [Transaction]
- public async Task<IResponseOutput> UpdateAsync(UserUpdateInput input)
- {
- if (!(input?.Id > 0))
- {
- return ResponseOutput.NotOk();
- }
- var user = await _userRepository.GetAsync(input.Id);
- if (!(user?.Id > 0))
- {
- return ResponseOutput.NotOk("用户不存在!");
- }
- Mapper.Map(input, user);
- await _userRepository.UpdateAsync(user);
- await _userRoleRepository.DeleteAsync(a => a.UserId == user.Id);
- if (input.RoleIds != null && input.RoleIds.Any())
- {
- var roles = input.RoleIds.Select(a => new UserRoleEntity { UserId = user.Id, RoleId = a });
- await _userRoleRepository.InsertAsync(roles);
- }
- return ResponseOutput.Ok();
- }
- public async Task<IResponseOutput> UpdateBasicAsync(UserUpdateBasicInput input)
- {
- var entity = await _userRepository.GetAsync(input.Id);
- entity = Mapper.Map(input, entity);
- var result = (await _userRepository.UpdateAsync(entity)) > 0;
- return ResponseOutput.Result(result);
- }
- public async Task<IResponseOutput> ChangePasswordAsync(UserChangePasswordInput input)
- {
- if (input.ConfirmPassword != input.NewPassword)
- {
- return ResponseOutput.NotOk("新密码和确认密码不一致!");
- }
- var entity = await _userRepository.GetAsync(input.Id);
- var oldPassword = MD5Encrypt.Encrypt32(input.OldPassword);
- if (oldPassword != entity.Password)
- {
- return ResponseOutput.NotOk("旧密码不正确!");
- }
- input.Password = MD5Encrypt.Encrypt32(input.NewPassword);
- entity = Mapper.Map(input, entity);
- var result = (await _userRepository.UpdateAsync(entity)) > 0;
- return ResponseOutput.Result(result);
- }
- public async Task<IResponseOutput> DeleteAsync(long id)
- {
- var result = false;
- if (id > 0)
- {
- result = (await _userRepository.DeleteAsync(m => m.Id == id)) > 0;
- }
- return ResponseOutput.Result(result);
- }
- [Transaction]
- public async Task<IResponseOutput> SoftDeleteAsync(long id)
- {
- var result = await _userRepository.SoftDeleteAsync(id);
- await _userRoleRepository.DeleteAsync(a => a.UserId == id);
- return ResponseOutput.Result(result);
- }
- [Transaction]
- public async Task<IResponseOutput> BatchSoftDeleteAsync(long[] ids)
- {
- var result = await _userRepository.SoftDeleteAsync(ids);
- await _userRoleRepository.DeleteAsync(a => ids.Contains(a.UserId));
- return ResponseOutput.Result(result);
- }
- }
- }
|