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

namespace Application.Features.Api.Stocks.GetCommodities;

/// <summary>
/// 일반상품(석유/금/배출권) 목록 — 시장별 지정일(미지정 시 최신 TradeDate) 행을 거래대금 내림차순으로 페이징 (KRX 일반상품 수집, 익명).
/// </summary>
internal sealed class Handler(IAppDbContext db) : IQueryHandler<Query, Response>
{
    private const ushort MaxPerPage = 100;

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

        var targetDate = request.Date;
        if (targetDate is null)
        {
            targetDate = await db.CommodityDailyTrade.AsNoTracking()
                .Where(c => c.CommodityMarket == request.Market)
                .OrderByDescending(c => c.TradeDate)
                .Select(c => (DateOnly?)c.TradeDate)
                .FirstOrDefaultAsync(ct);
        }

        if (targetDate is null)
        {
            return new Response
            {
                Total = 0,
                TradeDate = null,
                List = []
            };
        }

        var query = db.CommodityDailyTrade.AsNoTracking().Where(c => c.CommodityMarket == request.Market && c.TradeDate == targetDate.Value);

        var total = await query.CountAsync(ct);

        var list = await query
            .OrderByDescending(c => c.TradeValue).ThenBy(c => c.Code)
            .Skip((page - 1) * perPage)
            .Take(perPage)
            .Select(c => new Response.Row
            {
                Market = c.CommodityMarket,
                Code = c.Code,
                Name = c.Name,
                Close = c.Close,
                ChangeAmount = c.ChangeAmount,
                ChangeRate = c.ChangeRate,
                WeightedDiscussionPrice = c.WeightedDiscussionPrice,
                Volume = c.Volume,
                TradeValue = c.TradeValue
            })
            .ToListAsync(ct);

        return new Response
        {
            Total = total,
            TradeDate = targetDate.Value,
            List = list
        };
    }
}