admin/ShopSolution-backend
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

checkout

Browse Source
This commit is contained in:
Tizian.Breuch
2025-09-25 16:15:00 +02:00
parent aaec80d7ad
commit d4dae319f3
3 changed files with 77 additions and 57 deletions
Download Patch File Download Diff File Expand all files Collapse all files

52
Webshop.Api/Controllers/Customers/CheckoutController.cs
View File

@@ -1,18 +1,58 @@
// Auto-generiert von CreateWebshopFiles.ps1 // src/Webshop.Api/Controllers/Customer/CheckoutController.cs
using Microsoft.AspNetCore.Mvc; using Microsoft.AspNetCore.Mvc;
using Microsoft.AspNetCore.Authorization; using Microsoft.AspNetCore.Authorization;
using System;
using System.Collections.Generic;
using System.Threading.Tasks; using System.Threading.Tasks;
using Webshop.Application.Services.Customers.Interfaces;
using Webshop.Application.DTOs.Orders;
using System.Security.Claims;
using Microsoft.AspNetCore.Http;
using Webshop.Application;
namespace Webshop.Api.Controllers.Customers namespace Webshop.Api.Controllers.Customer
{ {
[ApiController] [ApiController]
[Route("api/v1/customer/[controller]")] [Route("api/v1/customer/[controller]")]
[Authorize(Roles = "Customer")] [Authorize(Roles = "Customer")]
public class CheckoutController : ControllerBase public class CheckoutController : ControllerBase
{ {
private readonly ICheckoutService _checkoutService;
public CheckoutController(ICheckoutService checkoutService)
{
_checkoutService = checkoutService;
}
[HttpPost("create-order")]
[ProducesResponseType(typeof(OrderDetailDto), StatusCodes.Status201Created)]
[ProducesResponseType(typeof(ProblemDetails), StatusCodes.Status400BadRequest)]
[ProducesResponseType(typeof(ProblemDetails), StatusCodes.Status401Unauthorized)]
[ProducesResponseType(typeof(ProblemDetails), StatusCodes.Status403Forbidden)]
[ProducesResponseType(typeof(ProblemDetails), StatusCodes.Status409Conflict)]
public async Task<IActionResult> CreateOrder([FromBody] CreateOrderDto orderDto)
{
if (!ModelState.IsValid)
{
return BadRequest(ModelState);
}
// UserId aus dem JWT-Token des eingeloggten Kunden extrahieren
var userId = User.FindFirstValue(ClaimTypes.NameIdentifier);
if (string.IsNullOrEmpty(userId))
{
return Unauthorized(new { Message = "Benutzer konnte nicht identifiziert werden." });
}
var result = await _checkoutService.CreateOrderAsync(orderDto, userId);
return result.Type switch
{
ServiceResultType.Success => Created($"/api/v1/customer/orders/{result.Value!.Id}", result.Value),
ServiceResultType.InvalidInput => BadRequest(new { Message = result.ErrorMessage }),
ServiceResultType.Conflict => Conflict(new { Message = result.ErrorMessage }),
ServiceResultType.Unauthorized => Unauthorized(new { Message = result.ErrorMessage }),
ServiceResultType.Forbidden => Forbid(), // Forbid returns 403 without a body
_ => StatusCode(StatusCodes.Status500InternalServerError, new { Message = result.ErrorMessage ?? "Ein unerwarteter Fehler ist aufgetreten." })
};
}
} }
} }

79
Webshop.Application/Services/Customers/CheckoutService.cs
View File

@@ -4,6 +4,7 @@ using System;
using System.Collections.Generic; using System.Collections.Generic;
using System.Linq; using System.Linq;
using System.Threading.Tasks; using System.Threading.Tasks;
using Webshop.Application;
using Webshop.Application.DTOs.Customers; using Webshop.Application.DTOs.Customers;
using Webshop.Application.DTOs.Orders; using Webshop.Application.DTOs.Orders;
using Webshop.Application.Services.Customers.Interfaces; using Webshop.Application.Services.Customers.Interfaces;
@@ -25,12 +26,8 @@ namespace Webshop.Application.Services.Customers
private readonly IDiscountService _discountService; private readonly IDiscountService _discountService;
public CheckoutService( public CheckoutService(
ApplicationDbContext context, ApplicationDbContext context, IOrderRepository orderRepository, ICustomerRepository customerRepository,
IOrderRepository orderRepository, IShippingMethodRepository shippingMethodRepository, ISettingService settingService, IDiscountService discountService)
ICustomerRepository customerRepository,
IShippingMethodRepository shippingMethodRepository,
ISettingService settingService,
IDiscountService discountService)
{ {
_context = context; _context = context;
_orderRepository = orderRepository; _orderRepository = orderRepository;
@@ -40,41 +37,31 @@ namespace Webshop.Application.Services.Customers
_discountService = discountService; _discountService = discountService;
} }
public async Task<(bool Success, OrderDetailDto? CreatedOrder, string? ErrorMessage)> CreateOrderAsync(CreateOrderDto orderDto, string? userId) public async Task<ServiceResult<OrderDetailDto>> CreateOrderAsync(CreateOrderDto orderDto, string? userId)
{ {
await using var transaction = await _context.Database.BeginTransactionAsync(); await using var transaction = await _context.Database.BeginTransactionAsync();
try try
{ {
// --- 1. Validierung von Kunde, Adressen und Methoden --- // 1. Validierung von Kunde, Adressen und Methoden
Customer? customer = null; var customer = await _customerRepository.GetByUserIdAsync(userId!);
if (!string.IsNullOrEmpty(userId)) if (customer == null)
{ return ServiceResult.Fail<OrderDetailDto>(ServiceResultType.Unauthorized, "Kundenprofil nicht gefunden.");
customer = await _customerRepository.GetByUserIdAsync(userId);
if (customer == null) return (false, null, "Kundenprofil nicht gefunden.");
// Validiere, dass die Adressen zum eingeloggten Kunden gehören if (!await _context.Addresses.AnyAsync(a => a.Id == orderDto.ShippingAddressId && a.CustomerId == customer.Id) ||
if (!await _context.Addresses.AnyAsync(a => a.Id == orderDto.ShippingAddressId && a.CustomerId == customer.Id) || !await _context.Addresses.AnyAsync(a => a.Id == orderDto.BillingAddressId && a.CustomerId == customer.Id))
!await _context.Addresses.AnyAsync(a => a.Id == orderDto.BillingAddressId && a.CustomerId == customer.Id))
{
return (false, null, "Ungültige oder nicht zugehörige Liefer- oder Rechnungsadresse.");
}
}
else
{ {
// Gast-Checkout: Validierung der Gast-Daten return ServiceResult.Fail<OrderDetailDto>(ServiceResultType.Forbidden, "Ungültige oder nicht zugehörige Liefer- oder Rechnungsadresse.");
if (string.IsNullOrWhiteSpace(orderDto.GuestEmail))
return (false, null, "Für Gastbestellungen ist eine E-Mail-Adresse erforderlich.");
// Hinweis: Bei Gastbestellungen müssten die Adress-DTOs mitgesendet und hier neue Adressen erstellt werden.
// Der Einfachheit halber nehmen wir an, die Adress-IDs sind gültig, aber nicht mit einem Kunden verknüpft.
} }
var shippingMethod = await _shippingMethodRepository.GetByIdAsync(orderDto.ShippingMethodId); var shippingMethod = await _shippingMethodRepository.GetByIdAsync(orderDto.ShippingMethodId);
if (shippingMethod == null || !shippingMethod.IsActive) return (false, null, "Ungültige oder inaktive Versandmethode."); if (shippingMethod == null || !shippingMethod.IsActive)
return ServiceResult.Fail<OrderDetailDto>(ServiceResultType.InvalidInput, "Ungültige oder inaktive Versandmethode.");
var paymentMethod = await _context.PaymentMethods.FindAsync(orderDto.PaymentMethodId); var paymentMethod = await _context.PaymentMethods.FindAsync(orderDto.PaymentMethodId);
if (paymentMethod == null || !paymentMethod.IsActive) return (false, null, "Ungültige oder inaktive Zahlungsmethode."); if (paymentMethod == null || !paymentMethod.IsActive)
return ServiceResult.Fail<OrderDetailDto>(ServiceResultType.InvalidInput, "Ungültige oder inaktive Zahlungsmethode.");
// --- 2. Artikel verarbeiten und Lagerbestand prüfen --- // 2. Artikel verarbeiten und Lagerbestand prüfen
var orderItems = new List<OrderItem>(); var orderItems = new List<OrderItem>();
var productIds = orderDto.Items.Select(i => i.ProductId).ToList(); var productIds = orderDto.Items.Select(i => i.ProductId).ToList();
var products = await _context.Products.Where(p => productIds.Contains(p.Id)).ToListAsync(); var products = await _context.Products.Where(p => productIds.Contains(p.Id)).ToListAsync();
@@ -86,15 +73,15 @@ namespace Webshop.Application.Services.Customers
if (product == null || !product.IsActive) if (product == null || !product.IsActive)
{ {
await transaction.RollbackAsync(); await transaction.RollbackAsync();
return (false, null, $"Ein Produkt im Warenkorb ist nicht mehr verfügbar."); return ServiceResult.Fail<OrderDetailDto>(ServiceResultType.Conflict, "Ein Produkt im Warenkorb ist nicht mehr verfügbar.");
} }
if (product.StockQuantity < itemDto.Quantity) if (product.StockQuantity < itemDto.Quantity)
{ {
await transaction.RollbackAsync(); await transaction.RollbackAsync();
return (false, null, $"Nicht genügend Lagerbestand für '{product.Name}'. Verfügbar: {product.StockQuantity}, benötigt: {itemDto.Quantity}."); return ServiceResult.Fail<OrderDetailDto>(ServiceResultType.Conflict, $"Nicht genügend Lagerbestand für '{product.Name}'. Verfügbar: {product.StockQuantity}, benötigt: {itemDto.Quantity}.");
} }
product.StockQuantity -= itemDto.Quantity; // Lagerbestand reduzieren product.StockQuantity -= itemDto.Quantity;
var orderItem = new OrderItem var orderItem = new OrderItem
{ {
@@ -110,7 +97,7 @@ namespace Webshop.Application.Services.Customers
itemsTotal += orderItem.TotalPrice; itemsTotal += orderItem.TotalPrice;
} }
// --- 3. Preise, Rabatte, Steuern und Gesamtbetrag berechnen --- // 3. Preise, Rabatte, Steuern und Gesamtbetrag berechnen
var discountResult = await _discountService.CalculateDiscountAsync(orderItems, orderDto.CouponCode); var discountResult = await _discountService.CalculateDiscountAsync(orderItems, orderDto.CouponCode);
decimal discountAmount = discountResult.TotalDiscountAmount; decimal discountAmount = discountResult.TotalDiscountAmount;
decimal shippingCost = shippingMethod.BaseCost; decimal shippingCost = shippingMethod.BaseCost;
@@ -121,12 +108,10 @@ namespace Webshop.Application.Services.Customers
decimal taxAmount = subTotal * taxRate; decimal taxAmount = subTotal * taxRate;
decimal orderTotal = subTotal + taxAmount; decimal orderTotal = subTotal + taxAmount;
// --- 4. Bestellung erstellen --- // 4. Bestellung erstellen
var newOrder = new Order var newOrder = new Order
{ {
CustomerId = customer?.Id, CustomerId = customer.Id,
GuestEmail = customer == null ? orderDto.GuestEmail : null,
GuestPhoneNumber = customer == null ? orderDto.GuestPhoneNumber : null,
OrderNumber = $"WS-{DateTime.UtcNow:yyyyMMdd}-{new Random().Next(1000, 9999)}", OrderNumber = $"WS-{DateTime.UtcNow:yyyyMMdd}-{new Random().Next(1000, 9999)}",
OrderDate = DateTimeOffset.UtcNow, OrderDate = DateTimeOffset.UtcNow,
OrderStatus = OrderStatus.Pending.ToString(), OrderStatus = OrderStatus.Pending.ToString(),
@@ -144,30 +129,24 @@ namespace Webshop.Application.Services.Customers
}; };
await _orderRepository.AddAsync(newOrder); await _orderRepository.AddAsync(newOrder);
// --- 5. Rabattnutzung erhöhen --- // 5. Rabattnutzung erhöhen
if (discountResult.AppliedDiscountIds.Any()) if (discountResult.AppliedDiscountIds.Any())
{ {
var appliedDiscounts = await _context.Discounts var appliedDiscounts = await _context.Discounts.Where(d => discountResult.AppliedDiscountIds.Contains(d.Id)).ToListAsync();
.Where(d => discountResult.AppliedDiscountIds.Contains(d.Id)) foreach (var discount in appliedDiscounts) { discount.CurrentUsageCount++; }
.ToListAsync();
foreach (var discount in appliedDiscounts)
{
discount.CurrentUsageCount++;
}
} }
await _context.SaveChangesAsync(); // Speichert Lagerbestandsänderungen & Rabattnutzung await _context.SaveChangesAsync();
await transaction.CommitAsync(); await transaction.CommitAsync();
// --- 6. Erfolgreiche Antwort erstellen --- // 6. Erfolgreiche Antwort erstellen
var createdOrder = await _orderRepository.GetByIdAsync(newOrder.Id); var createdOrder = await _orderRepository.GetByIdAsync(newOrder.Id);
var orderDetailDto = MapToOrderDetailDto(createdOrder!); return ServiceResult.Ok(MapToOrderDetailDto(createdOrder!));
return (true, orderDetailDto, null);
} }
catch (Exception ex) catch (Exception ex)
{ {
await transaction.RollbackAsync(); await transaction.RollbackAsync();
return (false, null, $"Ein unerwarteter Fehler ist aufgetreten: {ex.Message}"); return ServiceResult.Fail<OrderDetailDto>(ServiceResultType.Failure, $"Ein unerwarteter Fehler ist aufgetreten: {ex.Message}");
} }
} }

3
Webshop.Application/Services/Customers/Interfaces/ICheckoutService.cs
View File

@@ -1,12 +1,13 @@
// src/Webshop.Application/Services/Customers/Interfaces/ICheckoutService.cs // src/Webshop.Application/Services/Customers/Interfaces/ICheckoutService.cs
using System; using System;
using System.Threading.Tasks; using System.Threading.Tasks;
using Webshop.Application;
using Webshop.Application.DTOs.Orders; using Webshop.Application.DTOs.Orders;
namespace Webshop.Application.Services.Customers.Interfaces namespace Webshop.Application.Services.Customers.Interfaces
{ {
public interface ICheckoutService public interface ICheckoutService
{ {
Task<(bool Success, OrderDetailDto? CreatedOrder, string? ErrorMessage)> CreateOrderAsync(CreateOrderDto orderDto, string userId); Task<ServiceResult<OrderDetailDto>> CreateOrderAsync(CreateOrderDto orderDto, string? userId);
} }
} }