using System.Linq; using System.Threading.Tasks; using System.Collections.Generic; using AutoMapper; using Admin.Core.Common; using Admin.Core.Common.Helpers; using Admin.Core.Common.Auth; using Admin.Core.Common.Cache; using Admin.Core.Model.Input; using Admin.Core.Model.Output; using Admin.Core.Model.Admin; using Admin.Core.Repository.Admin; using Admin.Core.Service.Admin.User; using Admin.Core.Service.Admin.User.Input; using Admin.Core.Service.Admin.User.Output; namespace Admin.Core.FrameWork.Service.User { /// /// 用户服务 /// public class UserService : IUserService { private readonly IUser _user; private readonly ICache _cache; private readonly IMapper _mapper; private readonly IUserRepository _userRepository; private readonly IUserRoleRepository _userRoleRepository; private readonly IRolePermissionRepository _rolePermissionRepository; public UserService( IUser user, ICache cache, IMapper mapper, IUserRepository userRepository, IUserRoleRepository userRoleRepository, IRolePermissionRepository rolePermissionRepository ) { _user = user; _cache = cache; _mapper = mapper; _userRepository = userRepository; _userRoleRepository = userRoleRepository; _rolePermissionRepository = rolePermissionRepository; } public async Task> GetAsync(long id) { var res = new ResponseOutput(); var entity = await _userRepository.Select .WhereDynamic(id) .IncludeMany(a => a.Roles.Select(b => new RoleEntity { Id = b.Id })) .ToOneAsync(); var entityDto = _mapper.Map(entity); return res.Ok(entityDto); } public async Task PageAsync(PageInput input) { var key = input.Filter?.Name; var list = await _userRepository.Select .WhereIf(key.NotNull(), a => a.Status >= 0 && (a.UserName.Contains(key) || a.NickName.Contains(key) || a.Name.Contains(key))) .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() { List = _mapper.Map>(list), Total = total }; return ResponseOutput.Ok(data); } [Transaction] public async Task AddAsync(UserAddInput input) { if (input.Password.IsNull()) { input.Password = "111111"; } input.Password = MD5Encrypt.Encrypt32(input.Password); var entity = _mapper.Map(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(d => new UserRoleEntity(user.Id, d)); await _userRoleRepository.InsertAsync(roles); } return ResponseOutput.Ok(); } [Transaction] public async Task UpdateAsync(UserUpdateInput input) { if (!(input?.Id > 0)) { return ResponseOutput.NotOk(); } var entity = await _userRepository.GetAsync(input.Id); if (!(entity?.Id > 0)) { return ResponseOutput.NotOk("用户不存在!"); } _mapper.Map(input, entity); await _userRepository.UpdateAsync(entity); await _userRoleRepository.Where(m => m.UserId == entity.Id).ToDelete().ExecuteAffrowsAsync(); if (input.RoleIds != null && input.RoleIds.Any()) { var roles = input.RoleIds.Select(d => new UserRoleEntity(entity.Id, d)); await _userRoleRepository.InsertAsync(roles); } return ResponseOutput.Ok(); } public async Task DeleteAsync(long id) { var result = false; if (id > 0) { result = (await _userRepository.DeleteAsync(m => m.Id == id)) > 0; } return ResponseOutput.Result(result); } public async Task SoftDeleteAsync(long id) { var result = await _userRepository.SoftDeleteAsync(id); return ResponseOutput.Result(result); } public async Task BatchSoftDeleteAsync(long[] ids) { var result = await _userRepository.SoftDeleteAsync(ids); return ResponseOutput.Result(result); } public async Task 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 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 GetBasicAsync() { if (!(_user?.Id > 0)) { return ResponseOutput.NotOk("未登录!"); } var data = await _userRepository.Select.WhereDynamic(_user.Id).ToOneAsync(); return ResponseOutput.Ok(data); } public async Task> GetPermissionsAsync() { var key = string.Format(CacheKey.UserPermissions, _user.Id); if(await _cache.ExistsAsync(key)) { return await _cache.GetAsync>(key); } else { var userPermissoins = await _rolePermissionRepository.Select .InnerJoin((a, b) => a.RoleId == b.RoleId && b.UserId == _user.Id && a.Permission.Type == PermissionType.Api) .Include(a => a.Permission.Api) .Distinct() .ToListAsync(a => a.Permission.Api.Path); await _cache.SetAsync(key, userPermissoins); return userPermissoins; } } } }