forked from sanchezvem/PyroFetes
38 lines
1.4 KiB
C#
38 lines
1.4 KiB
C#
using FastEndpoints;
|
|
using Microsoft.EntityFrameworkCore;
|
|
using PyroFetes.DTO.QuotationProduct.Request;
|
|
using PyroFetes.DTO.QuotationProduct.Response;
|
|
using PyroFetes.DTO.WareHouseProduct.Request;
|
|
using PyroFetes.DTO.WareHouseProduct.Response;
|
|
|
|
namespace PyroFetes.Endpoints.WareHouseProduct;
|
|
|
|
public class PatchWareHouseProductQuantityEndpoint(PyroFetesDbContext database) : Endpoint<PatchWareHouseProductQuantityDto, GetWareHouseProductDto>
|
|
{
|
|
public override void Configure()
|
|
{
|
|
Patch("/api/wareHouseProduct/{ProductId}/{WareHouseId}/Quantity", x => new { x.ProductId, x.WareHouseId });
|
|
AllowAnonymous();
|
|
}
|
|
|
|
public override async Task HandleAsync(PatchWareHouseProductQuantityDto req, CancellationToken ct)
|
|
{
|
|
var wareHouseProduct = await database.WarehouseProducts.SingleOrDefaultAsync(wp => wp.ProductId == req.ProductId && wp.WarehouseId == req.WareHouseId, ct);
|
|
if (wareHouseProduct == null)
|
|
{
|
|
await Send.NotFoundAsync(ct);
|
|
return;
|
|
}
|
|
|
|
wareHouseProduct.Quantity = req.Quantity;
|
|
await database.SaveChangesAsync(ct);
|
|
|
|
GetWareHouseProductDto responseDto = new()
|
|
{
|
|
ProductId = wareHouseProduct.ProductId,
|
|
WareHouseId = wareHouseProduct.WarehouseId,
|
|
Quantity = wareHouseProduct.Quantity
|
|
};
|
|
await Send.OkAsync(responseDto, ct);
|
|
}
|
|
} |