41 lines
1.6 KiB
C#
41 lines
1.6 KiB
C#
using F9WebAiTest.Application.Common.Exceptions;
|
|
using F9WebAiTest.Application.Interfaces.SnowflakeID;
|
|
using F9WebAiTest.Domain.Entities.SYS.RBAC;
|
|
using F9WebAiTest.Domain.Interfaces.SYS.RBAC.Users;
|
|
using MediatR;
|
|
|
|
namespace F9WebAiTest.Application.CQRS.SYS.RBAC.Users.Commands;
|
|
|
|
/// <summary>命令定义</summary>
|
|
public record UserRole_AssignCommand(long UserId, long RoleId) : IRequest<long>;
|
|
|
|
/// <summary>命令处理器</summary>
|
|
public class UserRole_AssignCommandHandler(
|
|
IUserRoleWriteRepository userRoleWriteRepository,
|
|
IUserWriteRepository userWriteRepository,
|
|
ISnowflakeIdGenerator snowflakeIdGenerator,
|
|
IPublisher eventBus) : IRequestHandler<UserRole_AssignCommand, long>
|
|
{
|
|
public async Task<long> Handle(UserRole_AssignCommand command, CancellationToken cancellationToken)
|
|
{
|
|
if (command.UserId <= 0) throw new F9OperationException("用户ID不能为空");
|
|
if (command.RoleId <= 0) throw new F9OperationException("角色ID不能为空");
|
|
|
|
var newEntity = new UserRole(snowflakeIdGenerator.CreateId(), command.UserId, command.RoleId);
|
|
|
|
var user = await userWriteRepository.GetByIdAsync(command.UserId);
|
|
if (user == null) throw new F9NotFoundException("用户", command.UserId);
|
|
user.AddRole(newEntity.Id);
|
|
|
|
var result = await userRoleWriteRepository.AssignAsync(newEntity);
|
|
if (result == false) throw new F9OperationException("权限", "绑定");
|
|
|
|
// 发布领域事件
|
|
foreach (var domainEvent in user.DomainEvents)
|
|
await eventBus.Publish(domainEvent, cancellationToken);
|
|
user.ClearDomainEvents();
|
|
|
|
return newEntity.Id;
|
|
}
|
|
}
|