using F9WebAiTest.Application.Common;
using F9WebAiTest.Application.Dtos.SYS.Employees;
using F9WebAiTest.Application.Interfaces.Repositories.SYS.Employees;
using F9WebAiTest.Domain.Enums.SYS.Employees;
using MediatR;

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

/// <summary>职工分页查询（部门含子部门 + 工种 + 在职状态 + 班次 + 关键字）</summary>
public record GetEmployeePagedQuery(long DepId = 0, long WorktypeId = 0, Employee_WorkStatus_Enum? WorkStatus = null,
    Prod_Banci_Enum? Banci = null, string Like = "", int PageIndex = 1, int PageSize = 20)
    : IRequest<PageResult<EmployeeReadDto_View>>;

public class GetEmployeePagedQueryHandler(IEmployeeReadRepository readRepository)
    : IRequestHandler<GetEmployeePagedQuery, PageResult<EmployeeReadDto_View>>
{
    public async Task<PageResult<EmployeeReadDto_View>> Handle(GetEmployeePagedQuery query, CancellationToken ct)
        => await readRepository.GetPagedAsync(query.DepId, query.WorktypeId, query.WorkStatus, query.Banci,
            query.Like, query.PageIndex, query.PageSize);
}

/// <summary>按 Id 查询职工（编辑回显）</summary>
public record GetEmployeeByIdQuery(long Id) : IRequest<EmployeeReadDto_Edit>;

public class GetEmployeeByIdQueryHandler(IEmployeeReadRepository readRepository)
    : IRequestHandler<GetEmployeeByIdQuery, EmployeeReadDto_Edit>
{
    public async Task<EmployeeReadDto_Edit> Handle(GetEmployeeByIdQuery query, CancellationToken ct)
        => await readRepository.GetByIdForEditAsync(query.Id);
}

/// <summary>职工变更记录</summary>
public record GetEmployeeChangeRecordsQuery(long EmployeeId) : IRequest<List<EmployeeChangeRecordDto>>;

public class GetEmployeeChangeRecordsQueryHandler(IEmployeeReadRepository readRepository)
    : IRequestHandler<GetEmployeeChangeRecordsQuery, List<EmployeeChangeRecordDto>>
{
    public async Task<List<EmployeeChangeRecordDto>> Handle(GetEmployeeChangeRecordsQuery query, CancellationToken ct)
        => await readRepository.GetChangeRecordsAsync(query.EmployeeId);
}

/// <summary>职工调岗记录</summary>
public record GetEmployeeTiaogangRecordsQuery(long EmployeeId) : IRequest<List<EmployeeTiaogangRecordDto>>;

public class GetEmployeeTiaogangRecordsQueryHandler(IEmployeeReadRepository readRepository)
    : IRequestHandler<GetEmployeeTiaogangRecordsQuery, List<EmployeeTiaogangRecordDto>>
{
    public async Task<List<EmployeeTiaogangRecordDto>> Handle(GetEmployeeTiaogangRecordsQuery query, CancellationToken ct)
        => await readRepository.GetTiaogangRecordsAsync(query.EmployeeId);
}