PyroFetes-Sujet1/PyroFetes/Endpoints/Price/CreatePriceEndpoint.cs

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

namespace PyroFetes.Endpoints.Price;

public class CreatePriceEndpoint(PyroFetesDbContext database) : Endpoint<CreatePriceDto, GetPriceDto>
{
    public override void Configure()
    {
        Post("/api/prices");
        AllowAnonymous();
    }

    public override async Task HandleAsync(CreatePriceDto req, CancellationToken ct)
    {
        var price = await database.Prices.SingleOrDefaultAsync(p => p.ProductId == req.ProductId && p.SupplierId == req.SupplierId, ct);
        if (price == null)
        {
            await Send.NotFoundAsync(ct);
            return;
        }
        
        var supplier = await database.Suppliers.FirstOrDefaultAsync(s => s.Id == req.SupplierId, ct);
        
        var product = await database.Products.SingleOrDefaultAsync(p => p.Id == req.ProductId, ct);
        if (product == null)
        {
            await Send.NotFoundAsync(ct);
            return;
        }
        
        if (supplier == null)
        {
            supplier = new Models.Supplier()
            {
                Name = req.SupplierName,
                Email = req.SupplierEmail,
                Phone = req.SupplierPhone,
                Address = req.SupplierAddress,
                City = req.SupplierCity,
                ZipCode = req.SupplierZipCode,
                DeliveryDelay = req.SupplierDeliveryDelay

            };
            database.Suppliers.Add(supplier);
            await database.SaveChangesAsync(ct);
        }
        
        var priceAdded = new Models.Price()
        {
            SellingPrice = price.SellingPrice,
            SupplierId = supplier.Id,
            ProductId = product.Id,
        };
        database.Prices.Add(priceAdded);
        await database.SaveChangesAsync(ct);
        
        var productAdded = new Models.Product()
        {
            Reference = req.ProductReferences,
            Name = req.ProductName,
            Duration = req.ProductDuration,
            Caliber = req.ProductCaliber,
            ApprovalNumber = req.ProductApprovalNumber,
            Weight = req.ProductWeight,
            Nec = req.ProductNec,
            Image = req.ProductImage,
            Link = req.ProductLink,
            MinimalQuantity = req.ProductMinimalQuantity
        };
        database.Products.Add(productAdded);
        await database.SaveChangesAsync(ct);
        
        var responseDto = new GetPriceDto()
        {
            
        };

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