From 348ea248a6ef2bf3c644b194f31392215aa002e2 Mon Sep 17 00:00:00 2001
From: hello <stacks@outlook.com>
Date: Tue, 10 Sep 2024 22:07:43 +0800
Subject: [PATCH] =?UTF-8?q?=E8=AE=A2=E5=8D=95=E5=88=9B=E5=BB=BA=E5=91=BD?=
 =?UTF-8?q?=E4=BB=A4=E5=A4=84=E7=90=86=E7=A8=8B=E5=BA=8F?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../Behaviors/TransactionBehavior.cs          | 53 +++++++++++++++++++
 .../Orders/CreateOrderCommandHandler.cs       | 38 +++++++++++--
 .../Extensions/Extensions.cs                  |  1 +
 3 files changed, 89 insertions(+), 3 deletions(-)
 create mode 100644 src/HelloShop.OrderingService/Behaviors/TransactionBehavior.cs

diff --git a/src/HelloShop.OrderingService/Behaviors/TransactionBehavior.cs b/src/HelloShop.OrderingService/Behaviors/TransactionBehavior.cs
new file mode 100644
index 0000000..14ff297
--- /dev/null
+++ b/src/HelloShop.OrderingService/Behaviors/TransactionBehavior.cs
@@ -0,0 +1,53 @@
+using HelloShop.OrderingService.Extensions;
+using HelloShop.OrderingService.Infrastructure;
+using MediatR;
+using Microsoft.EntityFrameworkCore;
+using System.Data;
+
+namespace HelloShop.OrderingService.Behaviors
+{
+    public class TransactionBehavior<TRequest, TResponse>(OrderingServiceDbContext dbContext, ILoggerFactory loggerFactory) : IPipelineBehavior<TRequest, TResponse> where TRequest : IRequest<TResponse>
+    {
+        private readonly ILogger<TransactionBehavior<TRequest, TResponse>> _logger = loggerFactory.CreateLogger<TransactionBehavior<TRequest, TResponse>>();
+
+        public async Task<TResponse> Handle(TRequest request, RequestHandlerDelegate<TResponse> next, CancellationToken cancellationToken)
+        {
+            TResponse? response = default;
+
+            string typeName = request.GetGenericTypeName();
+
+            try
+            {
+                if (dbContext.Database.CurrentTransaction != null)
+                {
+                    return await next();
+                }
+
+                var strategy = dbContext.Database.CreateExecutionStrategy();
+
+                await strategy.ExecuteAsync(async () =>
+                {
+                    using var transaction = await dbContext.Database.BeginTransactionAsync(IsolationLevel.ReadCommitted);
+
+                    using (_logger.BeginScope(new List<KeyValuePair<string, object>> { new("TransactionContext", transaction.TransactionId) }))
+                    {
+                        _logger.LogInformation("Begin transaction {TransactionId} for {CommandName} {Command}", transaction.TransactionId, typeName, request);
+
+                        response = await next();
+
+                        _logger.LogInformation("Commit transaction {TransactionId} for {CommandName}", transaction.TransactionId, typeName);
+                    }
+
+                    await transaction.CommitAsync();
+                });
+
+                return response ?? throw new ApplicationException($"Command {typeName} returned null response");
+            }
+            catch (Exception ex)
+            {
+                _logger.LogError(ex, "Error Handling transaction for {CommandName} {Request}", typeName, request);
+                throw;
+            }
+        }
+    }
+}
diff --git a/src/HelloShop.OrderingService/Commands/Orders/CreateOrderCommandHandler.cs b/src/HelloShop.OrderingService/Commands/Orders/CreateOrderCommandHandler.cs
index 1d9c612..dd213fc 100644
--- a/src/HelloShop.OrderingService/Commands/Orders/CreateOrderCommandHandler.cs
+++ b/src/HelloShop.OrderingService/Commands/Orders/CreateOrderCommandHandler.cs
@@ -1,16 +1,48 @@
 // Copyright (c) HelloShop Corporation. All rights reserved.
 // See the license file in the project root for more information.
 
+using AutoMapper;
+using HelloShop.OrderingService.Entities.Buyers;
+using HelloShop.OrderingService.Entities.Orders;
+using HelloShop.OrderingService.Infrastructure;
 using HelloShop.OrderingService.Services;
 using MediatR;
+using Microsoft.EntityFrameworkCore;
 
 namespace HelloShop.OrderingService.Commands.Orders
 {
-    public class CreateOrderCommandHandler : IRequestHandler<CreateOrderCommand, bool>
+    public class CreateOrderCommandHandler(OrderingServiceDbContext dbContext, IMapper mapper) : IRequestHandler<CreateOrderCommand, bool>
     {
-        public Task<bool> Handle(CreateOrderCommand request, CancellationToken cancellationToken)
+        public async Task<bool> Handle(CreateOrderCommand request, CancellationToken cancellationToken)
         {
-            throw new NotImplementedException();
+            Address address = mapper.Map<Address>(request);
+
+            IEnumerable<OrderItem> orderItems = mapper.Map<IEnumerable<OrderItem>>(request.OrderItems);
+
+            Buyer? buyer = await dbContext.Set<Buyer>().FindAsync([request.UserId], cancellationToken);
+
+            if (buyer == null)
+            {
+                buyer = new() { Id = request.UserId, Name = request.UserName };
+                await dbContext.AddAsync(buyer, cancellationToken);
+                await dbContext.SaveChangesAsync(cancellationToken);
+            }
+
+            PaymentMethod? paymentMethod = await dbContext.Set<PaymentMethod>().SingleOrDefaultAsync(pm => pm.BuyerId == buyer.Id && pm.CardNumber == request.CardNumber, cancellationToken);
+
+            if (paymentMethod == null)
+            {
+                paymentMethod = new() { BuyerId = buyer.Id, Alias = request.CardAlias, CardNumber = request.CardNumber, SecurityNumber = request.CardSecurityNumber, CardHolderName = request.CardHolderName, Expiration = request.CardExpiration };
+                await dbContext.AddAsync(paymentMethod, cancellationToken);
+                await dbContext.SaveChangesAsync(cancellationToken);
+            }
+
+            Order order = new(buyer.Id, address, orderItems) { PaymentMethodId = paymentMethod.Id };
+
+            await dbContext.AddAsync(order, cancellationToken);
+            await dbContext.SaveChangesAsync(cancellationToken);
+
+            return await Task.FromResult(true);
         }
     }
 
diff --git a/src/HelloShop.OrderingService/Extensions/Extensions.cs b/src/HelloShop.OrderingService/Extensions/Extensions.cs
index ed4b93c..2492695 100644
--- a/src/HelloShop.OrderingService/Extensions/Extensions.cs
+++ b/src/HelloShop.OrderingService/Extensions/Extensions.cs
@@ -29,6 +29,7 @@ namespace HelloShop.OrderingService.Extensions
                 options.RegisterServicesFromAssembly(Assembly.GetExecutingAssembly());
                 options.AddBehavior(typeof(LoggingBehavior<,>));
                 options.AddBehavior(typeof(ValidatorBehavior<,>));
+                options.AddBehavior(typeof(TransactionBehavior<,>));
             });
 
             builder.Services.AddModelMapper().AddModelValidator();