reignem/PyroFetes-Sujet1
1
2
Fork 0
forked from sanchezvem/PyroFetes
Code Pull Requests Activity

17:17 09/10

Browse Source
This commit is contained in:
oistig
2025-10-09 17:17:42 +02:00
parent 1734ec0219
commit 91b4aca2fa
76 changed files with 815 additions and 388 deletions
Download Patch File Download Diff File Expand all files Collapse all files

34
PyroFetes/Endpoints/Warehouse/CreateWarehouseEndpoint.cs
View File

@@ -1,10 +1,12 @@
using API.DTO.Warehouse.Request;
using API.DTO.Warehouse.Response;
using FastEndpoints;
using PyroFetes.Models;
namespace PyroFetes.Endpoints.Warehouse;
public class CreateWarehouseEndpoint(PyroFetesDbContext pyrofetesdbcontext) : Endpoint<CreateWarehouseDto, GetWarehouseDto>
public class CreateWarehouseEndpoint(PyroFetesDbContext db)
: Endpoint<CreateWarehouseDto, GetWarehouseDto>
{
public override void Configure()
{
@@ -14,7 +16,7 @@ public class CreateWarehouseEndpoint(PyroFetesDbContext pyrofetesdbcontext) : En
public override async Task HandleAsync(CreateWarehouseDto req, CancellationToken ct)
{
Models.Warehouse warehouse = new()
var warehouse = new Models.Warehouse
{
Name = req.Name,
MaxWeight = req.MaxWeight,
@@ -24,13 +26,27 @@ public class CreateWarehouseEndpoint(PyroFetesDbContext pyrofetesdbcontext) : En
ZipCode = req.ZipCode,
City = req.City
};
pyrofetesdbcontext.Warehouses.Add(warehouse);
await pyrofetesdbcontext.SaveChangesAsync(ct);
Console.WriteLine("Entrepôt créé avec succès !");
GetWarehouseDto responseDto = new()
db.Warehouses.Add(warehouse);
await db.SaveChangesAsync(ct);
// 🔹 Ajout des produits liés à cet entrepôt
if (req.Products is not null && req.Products.Any())
{
foreach (var p in req.Products)
{
var warehouseProduct = new WarehouseProduct
{
WarehouseId = warehouse.Id,
ProductId = p.ProductId,
Quantity = p.Quantity
};
db.WarehouseProducts.Add(warehouseProduct);
}
await db.SaveChangesAsync(ct);
}
var response = new GetWarehouseDto
{
Id = warehouse.Id,
Name = warehouse.Name,
@@ -42,6 +58,6 @@ public class CreateWarehouseEndpoint(PyroFetesDbContext pyrofetesdbcontext) : En
City = warehouse.City
};
await Send.OkAsync(responseDto, ct);
await Send.OkAsync(response, ct);
}
}