using Application.Abstractions.Data;
using Application.Abstractions.Messaging;
using Microsoft.EntityFrameworkCore;
using SharedKernel.Results;

namespace Application.Features.Api.Stocks.GetDividendCalendar;

internal sealed class Handler(IAppDbContext db) : IQueryHandler<Query, Result<Response>>
{
    private const ushort MaxPerPage = 200;

    public async Task<Result<Response>> Handle(Query request, CancellationToken ct)
    {
        var page = request.Page < 1 ? 1 : request.Page;
        var perPage = request.PerPage is 0 or > MaxPerPage ? (ushort)30 : request.PerPage;

        var query = db.DividendSchedule.AsNoTracking();

        if (request.From.HasValue)
        {
            query = query.Where(c => c.RgtStdDt >= request.From.Value);
        }

        if (request.To.HasValue)
        {
            query = query.Where(c => c.RgtStdDt <= request.To.Value);
        }

        var total = await query.CountAsync(ct);

        var list = await query
            .OrderByDescending(c => c.RgtStdDt)
            .ThenBy(c => c.IssucoCustno)
            .ThenBy(c => c.RgtRsnDetailSortCd)
            .Skip((page - 1) * perPage)
            .Take(perPage)
            .Select(c => new Response.Row
            {
                IssucoCustno = c.IssucoCustno,
                Name = c.RepSecnNm,
                RgtStdDt = c.RgtStdDt,
                XrgtDt = c.XrgtDt,
                SortCode = c.RgtRsnDetailSortCd,
                FixType = c.FixTpcd,
                SettleType = c.SetaccTpcd
            })
            .ToListAsync(ct);

        return new Response
        {
            Total = total,
            List = list
        };
    }
}