using FastEndpoints;
using FrameworkBLL.SchedulerTaskGenerator;
using FrameworkDAL.CustomCode.SchedulerTaskGenerator;
using GB5Shared.DTO.Framework.Login;
using GB5Shared.DTO.Framework.ResponseStandard;
using GB5Shared.FastEndPoint;
using static GB5Shared.GB5Constant.Constant;
namespace FrameworkSL.Endpoints.JobDefine
{
///
/// Pauses a job: sets MJOBDEFINE.STATUS=Inactive and removes its Quartz trigger.
/// The job's row and history are preserved — Resume re-registers the trigger.
///
public sealed class PauseJobDefine
: BaseEndpoint>
{
private readonly IJobDefineOperationsBLL _ops;
private readonly ILoginContextProvider _loginProvider;
public PauseJobDefine(IJobDefineOperationsBLL ops, ILoginContextProvider loginProvider)
{
_ops = ops;
_loginProvider = loginProvider;
}
public override void Configure()
{
Post("/JobDefine/Pause");
AllowAnonymous(); // Internal scheduler admin call — matches Scheduler/* endpoint convention
}
public sealed record PauseJobDefineParameters(
int JobId,
[property: FromHeader] string Login
);
protected override async Task> ExecuteAsync(
PauseJobDefineParameters req, LoginDTO loginDTO, CancellationToken ct)
{
try
{
if (string.IsNullOrWhiteSpace(loginDTO?.DatabaseName))
loginDTO = _loginProvider.GetLogin();
await _ops.PauseAsync(req.JobId, loginDTO, ct);
return await GB5Shared.ResponseStandard.Response.CreateSuccessResponse(
$"Job {req.JobId} paused.", CacheKeyLevel.NOT_REQUIRED, loginDTO);
}
catch (Exception ex)
{
return await GB5Shared.ResponseStandard.Response.CreateExceptionError