123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162 |
- using Admin.Core.Common.Attributes;
- using Admin.Core.Common.Helpers;
- using Admin.Core.Common.Input;
- using Admin.Core.Common.Output;
- using Admin.Core.Model.Admin;
- using Admin.Core.Repository;
- using Admin.Core.Repository.Admin;
- using Admin.Core.Service.Admin.Tenant.Input;
- using Admin.Core.Service.Admin.Tenant.Output;
- using System.Linq;
- using System.Threading.Tasks;
- namespace Admin.Core.Service.Admin.Tenant
- {
- public class TenantService : BaseService, ITenantService
- {
- private readonly ITenantRepository _tenantRepository;
- private readonly IRoleRepository _roleRepository;
- private readonly IUserRepository _userRepository;
- private readonly IRepositoryBase<UserRoleEntity> _userRoleRepository;
- private readonly IRepositoryBase<RolePermissionEntity> _rolePermissionRepository;
- public TenantService(
- ITenantRepository tenantRepository,
- IRoleRepository roleRepository,
- IUserRepository userRepository,
- IRepositoryBase<UserRoleEntity> userRoleRepository,
- IRepositoryBase<RolePermissionEntity> rolePermissionRepository
- )
- {
- _tenantRepository = tenantRepository;
- _roleRepository = roleRepository;
- _userRepository = userRepository;
- _userRoleRepository = userRoleRepository;
- _rolePermissionRepository = rolePermissionRepository;
- }
- public async Task<IResponseOutput> GetAsync(long id)
- {
- var result = await _tenantRepository.GetAsync<TenantGetOutput>(id);
- return ResponseOutput.Ok(result);
- }
- public async Task<IResponseOutput> PageAsync(PageInput<TenantEntity> input)
- {
- var key = input.Filter?.Name;
- var list = await _tenantRepository.Select
- .WhereIf(key.NotNull(), a => a.Name.Contains(key))
- .Count(out var total)
- .OrderByDescending(true, c => c.Id)
- .Page(input.CurrentPage, input.PageSize)
- .ToListAsync<TenantListOutput>();
- var data = new PageOutput<TenantListOutput>()
- {
- List = list,
- Total = total
- };
- return ResponseOutput.Ok(data);
- }
- [Transaction]
- public async Task<IResponseOutput> AddAsync(TenantAddInput input)
- {
- var entity = Mapper.Map<TenantEntity>(input);
- var tenant = await _tenantRepository.InsertAsync(entity);
- var tenantId = tenant.Id;
- //添加用户
- var pwd = MD5Encrypt.Encrypt32("111111");
- var user = new UserEntity { TenantId = tenantId, UserName = input.Phone, NickName = input.RealName, Password = pwd, Status = 0 };
- await _userRepository.InsertAsync(user);
- //添加角色
- var role = new RoleEntity { TenantId = tenantId, Code = "plat_admin", Name = "平台管理员", Enabled = true };
- await _roleRepository.InsertAsync(role);
- //添加用户角色
- var userRole = new UserRoleEntity() { UserId = user.Id, RoleId = role.Id };
- await _userRoleRepository.InsertAsync(userRole);
- //更新租户用户和角色
- tenant.UserId = user.Id;
- tenant.RoleId = role.Id;
- await _tenantRepository.UpdateAsync(tenant);
- return ResponseOutput.Ok();
- }
- public async Task<IResponseOutput> UpdateAsync(TenantUpdateInput input)
- {
- if (!(input?.Id > 0))
- {
- return ResponseOutput.NotOk();
- }
- var entity = await _tenantRepository.GetAsync(input.Id);
- if (!(entity?.Id > 0))
- {
- return ResponseOutput.NotOk("租户不存在!");
- }
- Mapper.Map(input, entity);
- await _tenantRepository.UpdateAsync(entity);
- return ResponseOutput.Ok();
- }
- [Transaction]
- public async Task<IResponseOutput> DeleteAsync(long id)
- {
- //删除角色权限
- await _rolePermissionRepository.Where(a => a.Role.TenantId == id).DisableGlobalFilter("Tenant").ToDelete().ExecuteAffrowsAsync();
- //删除用户角色
- await _userRoleRepository.Where(a => a.User.TenantId == id).DisableGlobalFilter("Tenant").ToDelete().ExecuteAffrowsAsync();
- //删除用户
- await _userRepository.Where(a => a.TenantId == id).DisableGlobalFilter("Tenant").ToDelete().ExecuteAffrowsAsync();
- //删除角色
- await _roleRepository.Where(a => a.TenantId == id).DisableGlobalFilter("Tenant").ToDelete().ExecuteAffrowsAsync();
- //删除租户
- await _tenantRepository.DeleteAsync(id);
- return ResponseOutput.Ok();
- }
- [Transaction]
- public async Task<IResponseOutput> SoftDeleteAsync(long id)
- {
- //删除用户
- await _userRepository.SoftDeleteAsync(a => a.TenantId == id, "Tenant");
- //删除角色
- await _roleRepository.SoftDeleteAsync(a => a.TenantId == id, "Tenant");
- //删除租户
- var result = await _tenantRepository.SoftDeleteAsync(id);
- return ResponseOutput.Result(result);
- }
- [Transaction]
- public async Task<IResponseOutput> BatchSoftDeleteAsync(long[] ids)
- {
- //删除用户
- await _userRepository.SoftDeleteAsync(a => ids.Contains(a.TenantId.Value), "Tenant");
- //删除角色
- await _roleRepository.SoftDeleteAsync(a => ids.Contains(a.TenantId.Value), "Tenant");
- //删除租户
- var result = await _tenantRepository.SoftDeleteAsync(ids);
- return ResponseOutput.Result(result);
- }
- }
- }
|