From b5dfb58a8b7efd44700e926b54c30bf10ef3c22c Mon Sep 17 00:00:00 2001 From: MSuMshk <2039814060@qq.com> Date: Thu, 29 Jan 2026 13:56:33 +0000 Subject: [PATCH] =?UTF-8?q?refactor:=20=E8=AE=A2=E5=8D=95=E5=86=99?= =?UTF-8?q?=E6=93=8D=E4=BD=9C=E7=A7=BB=E9=99=A4=E7=A7=9F=E6=88=B7=E4=B8=8A?= =?UTF-8?q?=E4=B8=8B=E6=96=87=E4=BE=9D=E8=B5=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../Orders/Handlers/DeleteOrderCommandHandler.cs | 15 ++++++--------- .../Orders/Handlers/UpdateOrderCommandHandler.cs | 16 +++++++--------- 2 files changed, 13 insertions(+), 18 deletions(-) diff --git a/src/Application/TakeoutSaaS.Application/App/Orders/Handlers/DeleteOrderCommandHandler.cs b/src/Application/TakeoutSaaS.Application/App/Orders/Handlers/DeleteOrderCommandHandler.cs index 77e6e95..50c0318 100644 --- a/src/Application/TakeoutSaaS.Application/App/Orders/Handlers/DeleteOrderCommandHandler.cs +++ b/src/Application/TakeoutSaaS.Application/App/Orders/Handlers/DeleteOrderCommandHandler.cs @@ -2,7 +2,6 @@ using MediatR; using Microsoft.Extensions.Logging; using TakeoutSaaS.Application.App.Orders.Commands; using TakeoutSaaS.Domain.Orders.Repositories; -using TakeoutSaaS.Shared.Abstractions.Tenancy; namespace TakeoutSaaS.Application.App.Orders.Handlers; @@ -11,29 +10,27 @@ namespace TakeoutSaaS.Application.App.Orders.Handlers; /// public sealed class DeleteOrderCommandHandler( IOrderRepository orderRepository, - ITenantProvider tenantProvider, ILogger logger) : IRequestHandler { /// public async Task Handle(DeleteOrderCommand request, CancellationToken cancellationToken) { - // 1. 校验存在性 - var tenantId = tenantProvider.GetCurrentTenantId(); - var existing = await orderRepository.FindByIdAsync(request.OrderId, tenantId, cancellationToken); + // 1. 校验存在性(跨租户) + var existing = await orderRepository.FindByIdAsync(request.OrderId, cancellationToken); if (existing == null) { return false; } - // 2. 删除 - await orderRepository.DeleteOrderAsync(request.OrderId, tenantId, cancellationToken); + // 2. (空行后) 删除 + await orderRepository.DeleteOrderAsync(request.OrderId, existing.TenantId, cancellationToken); await orderRepository.SaveChangesAsync(cancellationToken); - // 3. 记录日志 + // 3. (空行后) 记录日志 logger.LogInformation("删除订单 {OrderId}", request.OrderId); - // 4. 返回执行结果 + // 4. (空行后) 返回执行结果 return true; } } diff --git a/src/Application/TakeoutSaaS.Application/App/Orders/Handlers/UpdateOrderCommandHandler.cs b/src/Application/TakeoutSaaS.Application/App/Orders/Handlers/UpdateOrderCommandHandler.cs index 53f6c88..9dc25ca 100644 --- a/src/Application/TakeoutSaaS.Application/App/Orders/Handlers/UpdateOrderCommandHandler.cs +++ b/src/Application/TakeoutSaaS.Application/App/Orders/Handlers/UpdateOrderCommandHandler.cs @@ -4,7 +4,6 @@ using TakeoutSaaS.Application.App.Orders.Commands; using TakeoutSaaS.Application.App.Orders.Dto; using TakeoutSaaS.Domain.Orders.Entities; using TakeoutSaaS.Domain.Orders.Repositories; -using TakeoutSaaS.Shared.Abstractions.Tenancy; namespace TakeoutSaaS.Application.App.Orders.Handlers; @@ -13,22 +12,21 @@ namespace TakeoutSaaS.Application.App.Orders.Handlers; /// public sealed class UpdateOrderCommandHandler( IOrderRepository orderRepository, - ITenantProvider tenantProvider, ILogger logger) : IRequestHandler { /// public async Task Handle(UpdateOrderCommand request, CancellationToken cancellationToken) { - // 1. 读取订单 - var tenantId = tenantProvider.GetCurrentTenantId(); - var existing = await orderRepository.FindByIdAsync(request.OrderId, tenantId, cancellationToken); + // 1. 读取订单(跨租户) + var existing = await orderRepository.FindByIdAsync(request.OrderId, cancellationToken); if (existing == null) { return null; } + var tenantId = existing.TenantId; - // 2. 更新字段 + // 2. (空行后) 更新字段 existing.OrderNo = request.OrderNo.Trim(); existing.StoreId = request.StoreId; existing.Channel = request.Channel; @@ -50,14 +48,14 @@ public sealed class UpdateOrderCommandHandler( existing.CancelReason = request.CancelReason?.Trim(); existing.Remark = request.Remark?.Trim(); - // 3. 持久化 + // 3. (空行后) 持久化 await orderRepository.UpdateOrderAsync(existing, cancellationToken); await orderRepository.SaveChangesAsync(cancellationToken); - // 4. 记录更新日志 + // 4. (空行后) 记录更新日志 logger.LogInformation("更新订单 {OrderNo} ({OrderId})", existing.OrderNo, existing.Id); - // 5. 读取关联数据并返回 + // 5. (空行后) 读取关联数据并返回 var items = await orderRepository.GetItemsAsync(existing.Id, tenantId, cancellationToken); var histories = await orderRepository.GetStatusHistoryAsync(existing.Id, tenantId, cancellationToken); var refunds = await orderRepository.GetRefundsAsync(existing.Id, tenantId, cancellationToken);