using GB5Shared.DTO.Framework.Login;
using GB5Shared.QueryExecutor;

namespace DXPDAL.VendorPo;

public class VendorPoDAL : IVendorPoDAL
{
    private readonly IQueryExecutor _QueryExecutor;

    public VendorPoDAL(IQueryExecutor queryExecutor)
    {
        _QueryExecutor = queryExecutor;
    }

    public async Task<VendorPoDTO?> GetPoHeaderAsync(int mmHeadId, int partyId, LoginDTO tenantLogin, CancellationToken ct)
    {
        return await _QueryExecutor.QuerySingleAsync<VendorPoDTO>(
            tenantLogin, VendorPoQB.GET_PO_HEADER,
            new { MMHeadId = mmHeadId, PartyId = partyId },
            cancellationToken: ct).ConfigureAwait(false);
    }

    public async Task<IEnumerable<VendorPoDetailDTO>> GetPoDetailsAsync(int mmHeadId, LoginDTO tenantLogin, CancellationToken ct)
    {
        return await _QueryExecutor.QueryAsync<VendorPoDetailDTO>(
            tenantLogin, VendorPoQB.GET_PO_DETAILS,
            new { MMHeadId = mmHeadId },
            cancellationToken: ct).ConfigureAwait(false)
            ?? Enumerable.Empty<VendorPoDetailDTO>();
    }

    public async Task<IEnumerable<PartyOuLinkDTO>> GetPartyOuLinksAsync(int partyId, LoginDTO tenantLogin, CancellationToken ct)
    {
        return await _QueryExecutor.QueryAsync<PartyOuLinkDTO>(
            tenantLogin, VendorPoQB.GET_PARTY_OU_LINKS,
            new { PartyId = partyId },
            cancellationToken: ct).ConfigureAwait(false)
            ?? Enumerable.Empty<PartyOuLinkDTO>();
    }

    public async Task<VendorPoDTO?> FindNewlyCreatedDocumentAsync(
        string referenceNumber, int bizTransactionTypeId, int partyId, LoginDTO tenantLogin, CancellationToken ct)
    {
        // QueryAsync + FirstOrDefault, not QuerySingleAsync — ORDER BY ... DESC is a tie-breaker,
        // not a guarantee of exactly one row, so this must tolerate more than one match.
        var rows = await _QueryExecutor.QueryAsync<VendorPoDTO>(
            tenantLogin, VendorPoQB.FIND_NEWLY_CREATED_DOCUMENT,
            new { ReferenceNumber = referenceNumber, BizTransactionTypeId = bizTransactionTypeId, PartyId = partyId },
            cancellationToken: ct).ConfigureAwait(false);
        return rows?.FirstOrDefault();
    }
}