Merge pull request #25 from netcorepal/v2

合并Command、CommandHandler、CommandValidator到一个文件

template/src/ABC.Template.Web/Application/Commands/CreateOrderCommand.cs

@@ -1,7 +1,31 @@
 using ABC.Template.Domain.AggregatesModel.OrderAggregate;
+using ABC.Template.Infrastructure.Repositories;
+using ABC.Template.Web.Application.IntegrationEventHandlers;
+using FluentValidation;
+using NetCorePal.Extensions.Mappers;
 using NetCorePal.Extensions.Primitives;
 
-namespace ABC.Template.Web.Application.Commands
+namespace ABC.Template.Web.Application.Commands;
+
+public record CreateOrderCommand(string Name, int Price, int Count) : ICommand<OrderId>;
+
+public class CreateOrderCommandValidator : AbstractValidator<CreateOrderCommand>
 {
-    public record CreateOrderCommand(string Name, int Price, int Count) : ICommand<OrderId>;
+    public CreateOrderCommandValidator()
+    {
+        RuleFor(x => x.Name).NotEmpty().MaximumLength(10).WithErrorCode("name error code");
+        RuleFor(x => x.Price).InclusiveBetween(18, 60).WithErrorCode("price error code");
+    }
 }
+
+public class CreateOrderCommandHandler(IOrderRepository orderRepository, IMapperProvider mapperProvider, ILogger<OrderPaidIntegrationEventHandler> logger) : ICommandHandler<CreateOrderCommand, OrderId>
+{
+
+    public async Task<OrderId> Handle(CreateOrderCommand request, CancellationToken cancellationToken)
+    {
+        var order = request.MapTo<Order>(mapperProvider);
+        order = await orderRepository.AddAsync(order, cancellationToken);
+        logger.LogInformation("order created, id:{orderId}", order.Id);
+        return order.Id;
+    }
+}

template/src/ABC.Template.Web/Application/Commands/DeliverGoodsCommand.cs

@@ -1,8 +1,19 @@
 using ABC.Template.Domain.AggregatesModel.DeliverAggregate;
 using ABC.Template.Domain.AggregatesModel.OrderAggregate;
+using ABC.Template.Infrastructure.Repositories;
 using NetCorePal.Extensions.Primitives;
 
-namespace ABC.Template.Web.Application.Commands
+namespace ABC.Template.Web.Application.Commands;
+
+public record DeliverGoodsCommand(OrderId OrderId) : ICommand<DeliverRecordId>;
+
+public class DeliverGoodsCommandHandler(IDeliverRecordRepository deliverRecordRepository)
+    : ICommandHandler<DeliverGoodsCommand, DeliverRecordId>
 {
-    public record DeliverGoodsCommand(OrderId OrderId) : ICommand<DeliverRecordId>;
-}
+    public Task<DeliverRecordId> Handle(DeliverGoodsCommand request, CancellationToken cancellationToken)
+    {
+        var record = new DeliverRecord(request.OrderId);
+        deliverRecordRepository.Add(record);
+        return Task.FromResult(record.Id);
+    }
+}

template/src/ABC.Template.Web/Application/Commands/OrderPaidCommand.cs

@@ -1,7 +1,17 @@
 using ABC.Template.Domain.AggregatesModel.OrderAggregate;
+using ABC.Template.Infrastructure.Repositories;
 using NetCorePal.Extensions.Primitives;
 
-namespace ABC.Template.Web.Application.Commands
+namespace ABC.Template.Web.Application.Commands;
+
+public record class OrderPaidCommand(OrderId OrderId) : ICommand;
+
+public class OrderPaidCommandHandler(IOrderRepository orderRepository) : ICommandHandler<OrderPaidCommand>
 {
-    public record class OrderPaidCommand(OrderId OrderId) : ICommand;
-}
+    public async Task Handle(OrderPaidCommand request, CancellationToken cancellationToken)
+    {
+        var order = await orderRepository.GetAsync(request.OrderId, cancellationToken) ??
+                    throw new KnownException($"未找到订单，OrderId = {request.OrderId}");
+        order.OrderPaid();
+    }
+}