using System.Data.Common;
using GB5Shared.DTO.Framework.Criteria;
using GB5Shared.DTO.Framework.Login;
using GB5Shared.ResponseStandard;
using MMDAL.DTO.BOM;
using MMDAL.DTO.MRP;
using MMDAL.DTO.MRPRun;

namespace MMDAL.CustomCode.MRPRun
{
    public interface IMRPRunDAL
    {
        // ── Legacy ──────────────────────────────────────────────────────────
        Task<string>                            UndoMRP(UndoMRPDTO undoMRPDTO, LoginDTO loginDTO);
        Task<string>                            GetSelectListMRP(CriteriaDTO crt, LoginDTO loginDTO, int firstNumber = -1, int maxResult = -1);

        // ── MRP Run CRUD ─────────────────────────────────────────────────────
        Task<MRPRunDTO?>                        GetMRPRun(int MRPRunId, LoginDTO loginDTO);
        Task<Result<string>>                    SaveMRPRun(MRPRunDTO dto, LoginDTO loginDTO, DbTransaction tx);
        Task<Result<string>>                    UpdateMRPRun(MRPRunDTO dto, LoginDTO loginDTO, DbTransaction tx);
        Task<Result<string>>                    DeleteMRPRun(int MRPRunId, LoginDTO loginDTO, DbTransaction tx);
        Task<IEnumerable<MRPRunListDTO>>        GetMRPRunList(int pageOffset, int pageSize, LoginDTO loginDTO);
        Task<int>                               GetMRPRunListCount(LoginDTO loginDTO);

        // ── Processing engine ────────────────────────────────────────────────
        Task<MRPDTO?>                           GetMRPConfig(int mrpId, LoginDTO login, CancellationToken ct);
        Task<bool>                              CheckMPSRunExists(int mrpId, LoginDTO login, CancellationToken ct);
        IAsyncEnumerable<MRPDemandLineDTO>      StreamDemandForMRP(int masterScheduleId, DemandFilterSpecDTO spec, LoginDTO login, CancellationToken ct);
        IAsyncEnumerable<MRPDemandLineDTO>      StreamDemandFromSalesOrder(int salesOrderId, LoginDTO login, CancellationToken ct);
        Task<IEnumerable<MRPOpeningStockDTO>>   GetOpeningStock(int ouId, LoginDTO login, CancellationToken ct);
        Task<IEnumerable<MRPOpeningStockDTO>>   GetOpeningStockAllocationScoped(int allocationId, int ouId, LoginDTO login, CancellationToken ct);
        Task<IEnumerable<MRPScheduledReceiptDTO>> GetScheduledReceipts(int ouId, DateTime fromDate, LoginDTO login, CancellationToken ct);
        Task<IEnumerable<BOMMRPDTO>>            GetBOMExplosion(IEnumerable<int> itemIds, LoginDTO login, CancellationToken ct);

        // ── Run status ───────────────────────────────────────────────────────
        Task<int>                               SaveMRPRunStatus(MRPRunStatusDTO dto, LoginDTO login, CancellationToken ct);
        Task                                    UpdateMRPRunStatus(int mrpRunStatusId, byte status, byte percent, string step, string? error, DateTime? completedAt, LoginDTO login, CancellationToken ct);
        Task<MRPRunStatusDTO?>                  GetMRPRunStatus(int mrpRunId, LoginDTO login, CancellationToken ct);

        // ── Bulk inserts ─────────────────────────────────────────────────────
        Task                                    BulkInsertMRPRunDetails(IEnumerable<MRPRunDetailInsertDTO> rows, LoginDTO login, CancellationToken ct);
        Task                                    BulkInsertMRPActions(IEnumerable<MRPActionInsertDTO> rows, LoginDTO login, CancellationToken ct);
        Task<Dictionary<int, int>>              GetMRPActionIdsByRunAsync(int mrpRunId, LoginDTO login, CancellationToken ct);
        Task                                    BulkInsertPegging(IEnumerable<MRPPeggingInsertDTO> rows, LoginDTO login, CancellationToken ct);
        Task                                    UpdateMasterScheduleDetailMRPRunId(int mrpId,int mrpRunId, int masterScheduleId,int typeofrun, LoginDTO login, CancellationToken ct);

        // ── Post-run write-backs (Gap 1 & 2) ────────────────────────────────
        Task                                    InsertMRPRunDetailParts(int mrpRunId, LoginDTO login, CancellationToken ct);
        Task                                    InsertDependentDemandRows(int mrpRunId, int masterScheduleId, int levelCode, LoginDTO login, CancellationToken ct);

        // ── Trace export ─────────────────────────────────────────────────────
        Task<MRPRunTraceDTO?>                   GetMRPRunTrace(int mrpRunId, LoginDTO login, CancellationToken ct);
    }
}