Kalana B. Thilakarathna
99 lines
3.6 KiB
C#
99 lines
3.6 KiB
C#
using Distribution.Infra.Authorization;
|
|
using Distribution.Models;
|
|
using Microsoft.AspNetCore.Authorization;
|
|
using Microsoft.AspNetCore.Mvc;
|
|
|
|
namespace Distribution.Features.Stock;
|
|
|
|
[ApiController]
|
|
[Route("api/stock")]
|
|
[Authorize]
|
|
public class StockController(StockService service, ICurrentUserService currentUser) : ControllerBase
|
|
{
|
|
// ── Query ──────────────────────────────────────────────────────────────
|
|
|
|
[HttpGet("balances")]
|
|
public async Task<IActionResult> GetBalances(
|
|
[FromQuery] Guid? locationId,
|
|
[FromQuery] LocationType? locationType,
|
|
[FromQuery] Guid? itemId,
|
|
[FromQuery] int page = 1,
|
|
[FromQuery] int pageSize = 20)
|
|
{
|
|
var result = await service.GetBalancesAsync(locationId, locationType, itemId, page, pageSize);
|
|
return Ok(result);
|
|
}
|
|
|
|
[HttpGet("balances/{itemId}/total")]
|
|
public async Task<IActionResult> GetItemTotal(Guid itemId)
|
|
{
|
|
var result = await service.GetItemTotalAsync(itemId);
|
|
if (result is null) return NotFound();
|
|
return Ok(result);
|
|
}
|
|
|
|
[HttpGet("movements")]
|
|
public async Task<IActionResult> GetMovements(
|
|
[FromQuery] Guid? locationId,
|
|
[FromQuery] Guid? itemId,
|
|
[FromQuery] MovementType? type,
|
|
[FromQuery] DateTime? from,
|
|
[FromQuery] DateTime? to,
|
|
[FromQuery] int page = 1,
|
|
[FromQuery] int pageSize = 20)
|
|
{
|
|
var result = await service.GetMovementsAsync(locationId, itemId, type, from, to, page, pageSize);
|
|
return Ok(result);
|
|
}
|
|
|
|
// ── Write ──────────────────────────────────────────────────────────────
|
|
|
|
[HttpPost("transfer")]
|
|
public async Task<IActionResult> Transfer(TransferRequest request, CancellationToken ct)
|
|
{
|
|
if (currentUser.UserId is null) return Unauthorized();
|
|
try
|
|
{
|
|
var result = await service.TransferAsync(request, currentUser.UserId.Value, ct);
|
|
return Ok(result);
|
|
}
|
|
catch (InvalidOperationException ex) { return BadRequest(ex.Message); }
|
|
}
|
|
|
|
[HttpPost("damage")]
|
|
public async Task<IActionResult> RecordDamage(DamageRequest request, CancellationToken ct)
|
|
{
|
|
if (currentUser.UserId is null) return Unauthorized();
|
|
try
|
|
{
|
|
var result = await service.RecordDamageAsync(request, currentUser.UserId.Value, ct);
|
|
return Ok(result);
|
|
}
|
|
catch (InvalidOperationException ex) { return BadRequest(ex.Message); }
|
|
}
|
|
|
|
[HttpPost("customer-return")]
|
|
public async Task<IActionResult> RecordCustomerReturn(CustomerReturnRequest request, CancellationToken ct)
|
|
{
|
|
if (currentUser.UserId is null) return Unauthorized();
|
|
try
|
|
{
|
|
var result = await service.RecordCustomerReturnAsync(request, currentUser.UserId.Value, ct);
|
|
return Ok(result);
|
|
}
|
|
catch (InvalidOperationException ex) { return BadRequest(ex.Message); }
|
|
}
|
|
|
|
[HttpPost("adjustment")]
|
|
public async Task<IActionResult> Adjust(AdjustmentRequest request, CancellationToken ct)
|
|
{
|
|
if (currentUser.UserId is null) return Unauthorized();
|
|
try
|
|
{
|
|
var result = await service.AdjustAsync(request, currentUser.UserId.Value, ct);
|
|
return Ok(result);
|
|
}
|
|
catch (InvalidOperationException ex) { return BadRequest(ex.Message); }
|
|
}
|
|
}
|