using FastEndpoints;
using GB5Shared.DTO.Framework.Login;
using GB5Shared.DTO.Framework.ResponseStandard;
using GB5Shared.FastEndPoint;
using SwBLL.RolloutCampaign;
using static GB5Shared.GB5Constant.Constant;
using GB5Shared.Authorization;

namespace SwSL.EndPoints.RolloutCampaign;

// Internal system job, dispatched by GB5Framework's Track A scheduler (MJOBDEFINE/TSCHEDULER,
// tracker §45) — replaces the standalone in-memory Quartz job of the same name (2-minute
// interval) that used to run inside SwSL's own process. Same hardcoded Unisoft TenantId=1
// system login RolloutCampaignWorkerJob itself used (§38) — Track A's own caller-supplied Login
// header is accepted only to satisfy BaseEndpoint's required-header contract, not used for
// tenant routing here.
//[MenuRights("SWROLLOUT", RightOperation.Update)]
public class RunRolloutCampaignWorker : BaseEndpoint<RunRolloutCampaignWorker.Parameters, ResponseStandardDTO<object>>
{
    private readonly IRolloutCampaignBLL _bll;

    public RunRolloutCampaignWorker(IRolloutCampaignBLL bll) => _bll = bll;

    public override void Configure()
    {
        Get("/RolloutCampaign/RunRolloutCampaignWorker");
        AllowAnonymous();
    }

    public record Parameters([property: FromHeader] string Login);

    protected override string? GetCacheKey(Parameters req, LoginDTO loginDTO) => null;

    protected override async Task<ResponseStandardDTO<object>> ExecuteAsync(
        Parameters req, LoginDTO loginDTO, CancellationToken ct)
    {
        var systemLogin = new LoginDTO
        {
            DatabaseName = "Gb5System",
            ClientId     = 1,
            UserId       = -1,
            DatabaseType = 0,
            RoleId       = -1,
            UserName     = "system",
            LanguageId   = "1"
        };

        var processed = await _bll.ProcessDueTargetsAsync(systemLogin, ct);
        return await GB5Shared.ResponseStandard.Response.CreateSuccessResponse(
            $"RolloutCampaignWorker run completed. Processed={processed}.", CacheKeyLevel.NOT_REQUIRED, loginDTO);
    }
}