using F9WebAiTest.Application.Common;
using F9WebAiTest.Application.Dtos.SYS.WuziMulus;
using F9WebAiTest.Application.Interfaces.Repositories.SYS.WuziMulus;
using MediatR;

namespace F9WebAiTest.Application.CQRS.SYS.WuziMulus.Queries;

// ==================== 物资分组 ====================

/// <summary>全部物资分组（用于构建分组树）</summary>
public record GetWuziGroupAllQuery() : IRequest<List<WuziGroupReadDto_View>>;

public class GetWuziGroupAllQueryHandler(IWuziGroupReadRepository readRepository)
    : IRequestHandler<GetWuziGroupAllQuery, List<WuziGroupReadDto_View>>
{
    public async Task<List<WuziGroupReadDto_View>> Handle(GetWuziGroupAllQuery query, CancellationToken ct)
        => await readRepository.GetAllAsync();
}

/// <summary>按 Id 查询分组（编辑回显）</summary>
public record GetWuziGroupByIdQuery(long Id) : IRequest<WuziGroupReadDto_Edit>;

public class GetWuziGroupByIdQueryHandler(IWuziGroupReadRepository readRepository)
    : IRequestHandler<GetWuziGroupByIdQuery, WuziGroupReadDto_Edit>
{
    public async Task<WuziGroupReadDto_Edit> Handle(GetWuziGroupByIdQuery query, CancellationToken ct)
        => await readRepository.GetByIdForEditAsync(query.Id);
}

/// <summary>分组新编号</summary>
public record GetWuziGroupNewCodeQuery(long ParentId) : IRequest<string>;

public class GetWuziGroupNewCodeQueryHandler(IWuziGroupReadRepository readRepository)
    : IRequestHandler<GetWuziGroupNewCodeQuery, string>
{
    public async Task<string> Handle(GetWuziGroupNewCodeQuery query, CancellationToken ct)
        => await readRepository.GetNewCodeAsync(query.ParentId);
}

/// <summary>是否存在下级（删除前校验）</summary>
public record GetWuziGroupExistChildQuery(long Id) : IRequest<bool>;

public class GetWuziGroupExistChildQueryHandler(IWuziGroupReadRepository readRepository)
    : IRequestHandler<GetWuziGroupExistChildQuery, bool>
{
    public async Task<bool> Handle(GetWuziGroupExistChildQuery query, CancellationToken ct)
        => await readRepository.ExistChildAsync(query.Id);
}

// ==================== 物资目录 ====================

/// <summary>按分组分页查询物资</summary>
public record GetWuziMuluPagedQuery(long GroupId = 0, string Keyword = "", int PageIndex = 1, int PageSize = 20)
    : IRequest<PageResult<WuziMuluReadDto_View>>;

public class GetWuziMuluPagedQueryHandler(IWuziMuluReadRepository readRepository)
    : IRequestHandler<GetWuziMuluPagedQuery, PageResult<WuziMuluReadDto_View>>
{
    public async Task<PageResult<WuziMuluReadDto_View>> Handle(GetWuziMuluPagedQuery query, CancellationToken ct)
        => await readRepository.GetPagedAsync(query.GroupId, query.Keyword, query.PageIndex, query.PageSize);
}

/// <summary>按 Id 查询物资（编辑回显）</summary>
public record GetWuziMuluByIdQuery(long Id) : IRequest<WuziMuluReadDto_Edit>;

public class GetWuziMuluByIdQueryHandler(IWuziMuluReadRepository readRepository)
    : IRequestHandler<GetWuziMuluByIdQuery, WuziMuluReadDto_Edit>
{
    public async Task<WuziMuluReadDto_Edit> Handle(GetWuziMuluByIdQuery query, CancellationToken ct)
        => await readRepository.GetByIdForEditAsync(query.Id);
}

/// <summary>物资新编号</summary>
public record GetWuziMuluNewCodeQuery(long GroupId) : IRequest<string>;

public class GetWuziMuluNewCodeQueryHandler(IWuziMuluReadRepository readRepository)
    : IRequestHandler<GetWuziMuluNewCodeQuery, string>
{
    public async Task<string> Handle(GetWuziMuluNewCodeQuery query, CancellationToken ct)
        => await readRepository.GetNewCodeAsync(query.GroupId);
}

/// <summary>物资选项（供其它模块选择物资）</summary>
public record GetWuziMuluOptionsQuery(string Keyword = "", int Limit = 200) : IRequest<List<WuziMuluOptionDto>>;

public class GetWuziMuluOptionsQueryHandler(IWuziMuluReadRepository readRepository)
    : IRequestHandler<GetWuziMuluOptionsQuery, List<WuziMuluOptionDto>>
{
    public async Task<List<WuziMuluOptionDto>> Handle(GetWuziMuluOptionsQuery query, CancellationToken ct)
        => await readRepository.GetOptionsAsync(query.Keyword, query.Limit);
}