PyroFetes-Sujet1/PyroFetes/Endpoints/PurchaseProduct/CreatePurchaseProductEndpoint.cs

using Microsoft.EntityFrameworkCore;
using FastEndpoints;
using PyroFetes.DTO.PurchaseProduct.Request;
using PyroFetes.DTO.PurchaseProduct.Response;

namespace PyroFetes.Endpoints.PurchaseProduct;

public class CreatePurchaseProductEndpoint(PyroFetesDbContext database)
    : Endpoint<CreatePurchaseProductDto, GetPurchaseProductDto>
{
    public override void Configure()
    {
        Post("/api/purchaseProducts");
        AllowAnonymous();
    }

    public override async Task HandleAsync(CreatePurchaseProductDto req, CancellationToken ct)
    {
        // Vérifie que le produit existe
        var product = await database.Products.FirstOrDefaultAsync(p => p.Id == req.ProductId, ct);
        if (product == null)
        {
            await Send.NotFoundAsync(ct);
            return;
        }

        // Si la commande existe déjà, on la récupère
        var purchaseOrder = await database.PurchaseOrders.FirstOrDefaultAsync(po => po.Id == req.PurchaseOrderId, ct);

        // Si elle n'existe pas, on la crée
        if (purchaseOrder == null)
        {
            purchaseOrder = new Models.PurchaseOrder()
            {
                PurchaseConditions = req.PurchaseOrderPurchaseConditions ?? "Conditions non précisées"
            };
            database.PurchaseOrders.Add(purchaseOrder);
            await database.SaveChangesAsync(ct); // important pour avoir l'Id
        }

        // Création du lien produit-commande
        var purchaseProduct = new Models.PurchaseProduct()
        {
            ProductId = product.Id,
            PurchaseOrderId = purchaseOrder.Id,
            Quantity = req.Quantity
        };

        database.PurchaseProducts.Add(purchaseProduct);
        await database.SaveChangesAsync(ct);

        // Prépare la réponse
        var responseDto = new GetPurchaseProductDto()
        {
            ProductId = product.Id,
            ProductReferences = int.TryParse(product.Reference, out var refInt) ? refInt : 0,
            ProductName = product.Name,
            ProductDuration = product.Duration,
            ProductCaliber = product.Caliber,
            ProductApprovalNumber = product.ApprovalNumber,
            ProductWeight = product.Weight,
            ProductNec = product.Nec,
            ProductImage = product.Image,
            ProductLink = product.Link,
            ProductMinimalQuantity = product.MinimalQuantity,

            PurchaseOrderId = purchaseOrder.Id,
            PurchaseOrderPurchaseConditions = purchaseOrder.PurchaseConditions,
            Quantity = purchaseProduct.Quantity
        };

        await Send.OkAsync(responseDto, ct);
    }
}