74 lines
3.1 KiB
C#
74 lines
3.1 KiB
C#
using F9WebAiTest.Application.Common.Exceptions;
|
|
using F9WebAiTest.Application.Interfaces.Security;
|
|
using F9WebAiTest.Application.Interfaces.SnowflakeID;
|
|
using F9WebAiTest.Application.Interfaces.UOW;
|
|
using F9WebAiTest.Domain.Entities.SYS.Departments;
|
|
using F9WebAiTest.Domain.Entities.SYS.RBAC;
|
|
using F9WebAiTest.Domain.Interfaces.SYS.Departments;
|
|
using F9WebAiTest.Domain.Interfaces.SYS.RBAC.Users;
|
|
using MediatR;
|
|
|
|
namespace F9WebAiTest.Application.CQRS.SYS.RBAC.Users.Commands;
|
|
|
|
/// <summary>命令定义</summary>
|
|
public record User_CreateCommand(string UserName, string PhoneNumber, string LoginName, long DepartmentId, int SortOrder) : IRequest<long>;
|
|
|
|
/// <summary>命令处理器</summary>
|
|
public class CreateUserCommandHandler(
|
|
IUnitOfWork_F9 unitOfWork,
|
|
IUserWriteRepository userRepository,
|
|
IDepartmentWriteRepository departmentWriteRepository,
|
|
IDepartmentUserRepository departmentUserRepository,
|
|
IPasswordHasher passwordHasher,
|
|
ISnowflakeIdGenerator snowflakeIdGenerator,
|
|
IPublisher eventBus) : IRequestHandler<User_CreateCommand, long>
|
|
{
|
|
public async Task<long> Handle(User_CreateCommand command, CancellationToken cancellationToken)
|
|
{
|
|
// 手写校验
|
|
if (string.IsNullOrWhiteSpace(command.UserName)) throw new F9OperationException("用户名不能为空");
|
|
if (string.IsNullOrWhiteSpace(command.LoginName)) throw new F9OperationException("登录名不能为空");
|
|
if (command.DepartmentId <= 0) throw new F9OperationException("部门不能为空");
|
|
|
|
User createdUser = null;
|
|
var ok = await unitOfWork.ExecuteWithUow(async () =>
|
|
{
|
|
// 1. 验证部门是否存在（应用层协调）
|
|
var department = await departmentWriteRepository.GetByIdAsync(command.DepartmentId, cancellationToken);
|
|
if (department == null) throw new F9NotFoundException("部门不存在");
|
|
|
|
// 2. 创建用户聚合根
|
|
var user = new User(
|
|
id: snowflakeIdGenerator.CreateId(),
|
|
command.UserName,
|
|
command.PhoneNumber,
|
|
command.LoginName,
|
|
command.DepartmentId,
|
|
command.SortOrder);
|
|
|
|
// 设置默认密码
|
|
var defaultPasswordMd5 = passwordHasher.GetMd5Hash(user.GetDefaultPasswordText());
|
|
var passwordHash = passwordHasher.HashPassword(defaultPasswordMd5);
|
|
user.SetPassword(passwordHash);
|
|
|
|
await userRepository.AddAsync(user);
|
|
|
|
// 3. 创建部门用户关联
|
|
var depUser = new DepartmentUser(snowflakeIdGenerator.CreateId(), command.DepartmentId, user.Id);
|
|
await departmentUserRepository.AssignAsync(depUser);
|
|
|
|
createdUser = user;
|
|
return true;
|
|
});
|
|
|
|
if (!ok) throw new F9OperationException("用户", "新增");
|
|
|
|
// 4. 事务提交后发布领域事件
|
|
foreach (var domainEvent in createdUser.DomainEvents)
|
|
await eventBus.Publish(domainEvent, cancellationToken);
|
|
createdUser.ClearDomainEvents();
|
|
|
|
return createdUser.Id;
|
|
}
|
|
}
|