using System.Data.Common;
using GB5Shared.DTO.Framework.Login;
using GB5Shared.QueryExecutor;

namespace DXPDAL.Party;

public class PartyDAL : IPartyDAL
{
    private readonly IQueryExecutor _QueryExecutor;

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

    public async Task<PartyDTO?> GetPartyAsync(int dxpPartyId, LoginDTO login, CancellationToken ct)
    {
        return await _QueryExecutor.QuerySingleAsync<PartyDTO>(
            login, PartyQB.GET_BY_ID,
            new { DxpPartyId = dxpPartyId },
            cancellationToken: ct).ConfigureAwait(false);
    }

    public async Task<IEnumerable<PartyDTO>> FindByIdentityHashAsync(
        string? gstinHash, string? panHash, string? mobileHash, string? emailHash,
        LoginDTO login, CancellationToken ct)
    {
        return await _QueryExecutor.QueryAsync<PartyDTO>(
            login, PartyQB.FIND_BY_IDENTITY_HASH,
            new { GstinHash = gstinHash, PanHash = panHash, MobileHash = mobileHash, EmailHash = emailHash },
            cancellationToken: ct).ConfigureAwait(false)
            ?? Enumerable.Empty<PartyDTO>();
    }

    public async Task SavePartyAsync(PartyDTO dto, LoginDTO login, DbTransaction tx, CancellationToken ct)
    {
        await _QueryExecutor.ExecuteAsync(
            login, PartyQB.INSERT, dto, tx, cancellationToken: ct).ConfigureAwait(false);
    }

    public async Task UpdatePartyAsync(PartyDTO dto, LoginDTO login, DbTransaction tx, CancellationToken ct)
    {
        await _QueryExecutor.ExecuteAsync(
            login, PartyQB.UPDATE, dto, tx, cancellationToken: ct).ConfigureAwait(false);
    }

    public async Task<IEnumerable<PartyLinkDTO>> GetPartyLinksAsync(int dxpPartyId, LoginDTO login, CancellationToken ct)
    {
        return await _QueryExecutor.QueryAsync<PartyLinkDTO>(
            login, PartyQB.GET_LINKS_BY_PARTY,
            new { DxpPartyId = dxpPartyId },
            cancellationToken: ct).ConfigureAwait(false)
            ?? Enumerable.Empty<PartyLinkDTO>();
    }

    public async Task SavePartyLinkAsync(PartyLinkDTO dto, LoginDTO login, DbTransaction tx, CancellationToken ct)
    {
        await _QueryExecutor.ExecuteAsync(
            login, PartyQB.INSERT_LINK, dto, tx, cancellationToken: ct).ConfigureAwait(false);
    }

    public async Task RevokePartyLinkAsync(int dxpPartyLinkId, LoginDTO login, DbTransaction tx, CancellationToken ct)
    {
        var param = new
        {
            DxpPartyLinkId = dxpPartyLinkId,
            ModifiedById   = login.UserId,
            ModifiedOn     = DateTime.UtcNow
        };
        await _QueryExecutor.ExecuteAsync(
            login, PartyQB.REVOKE_LINK, param, tx, cancellationToken: ct).ConfigureAwait(false);
    }

    public async Task<IEnumerable<PartyBranchLinkDTO>> GetPartyBranchLinksAsync(int dxpPartyId, LoginDTO login, CancellationToken ct)
    {
        return await _QueryExecutor.QueryAsync<PartyBranchLinkDTO>(
            login, PartyQB.GET_BRANCH_LINKS_BY_PARTY,
            new { DxpPartyId = dxpPartyId },
            cancellationToken: ct).ConfigureAwait(false)
            ?? Enumerable.Empty<PartyBranchLinkDTO>();
    }

    public async Task SavePartyBranchLinkAsync(PartyBranchLinkDTO dto, LoginDTO login, DbTransaction tx, CancellationToken ct)
    {
        await _QueryExecutor.ExecuteAsync(
            login, PartyQB.INSERT_BRANCH_LINK, dto, tx, cancellationToken: ct).ConfigureAwait(false);
    }
}