using Microsoft.AspNetCore.Mvc;
|
using Quartz;
|
using Quartz.Spi;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Threading.Tasks;
|
using VueWebCoreApi.Extensions;
|
using VueWebCoreApi.Quartz;
|
using VueWebCoreApi.Tools;
|
|
namespace VueWebCoreApi.Controllers
|
{
|
[ApiExplorerSettings(GroupName = "周期任务")]
|
[ApiController]
|
[Route("api/[controller]")]
|
public class TaskBackGroundController : Controller
|
{
|
ToMessage mes = new ToMessage();
|
private readonly ISchedulerFactory _schedulerFactory;
|
private readonly IJobFactory _jobFactory;
|
private readonly QuartzRepository _quartzRepo;
|
|
public TaskBackGroundController(ISchedulerFactory schedulerFactory,
|
IJobFactory jobFactory,
|
QuartzRepository quartzRepo)
|
{
|
_schedulerFactory = schedulerFactory;
|
_jobFactory = jobFactory;
|
_quartzRepo = quartzRepo;
|
}
|
|
[Route("GetJobs")]
|
[HttpGet]
|
public async Task<IActionResult> GetJobs()
|
{
|
try
|
{
|
mes.code = "200";
|
mes.message = "查询成功！";
|
mes.data = await _schedulerFactory.GetJobs(_quartzRepo);
|
}
|
catch (Exception ex)
|
{
|
mes.code = "300";
|
mes.message = "查询失败：" + ex.Message;
|
mes.data = null;
|
}
|
return Json(mes);
|
}
|
|
[Route("GetRunLog")]
|
[HttpGet]
|
public async Task<IActionResult> GetRunLog(string taskName, string groupName, int page = 1)
|
{
|
// 入参校验
|
if (string.IsNullOrEmpty(taskName) || string.IsNullOrEmpty(groupName))
|
{
|
mes.code = "300";
|
mes.message = "任务名和分组名不能为空！";
|
mes.data = null;
|
return Json(mes);
|
}
|
try
|
{
|
mes.code = "200";
|
mes.message = "查询成功！";
|
mes.data = await _quartzRepo.GetJobRunLogAsync(taskName, groupName, page);
|
}
|
catch (Exception ex)
|
{
|
mes.code = "300";
|
mes.message = "查询失败：" + ex.Message;
|
mes.data = null;
|
}
|
return Json(mes);
|
}
|
|
[Route("Add")]
|
[HttpPost]
|
public async Task<IActionResult> Add(TaskOptions taskOptions)
|
{
|
if (string.IsNullOrEmpty(taskOptions.TaskName) || string.IsNullOrEmpty(taskOptions.GroupName))
|
{
|
mes.code = "300";
|
mes.message = "任务名和分组名不能为空！";
|
return Json(mes);
|
}
|
return Json(await taskOptions.AddJob(_schedulerFactory, false, _jobFactory, _quartzRepo));
|
}
|
|
[Route("Remove")]
|
[HttpPost]
|
public async Task<IActionResult> Remove(TaskOptions taskOptions)
|
{
|
if (string.IsNullOrEmpty(taskOptions.TaskName) || string.IsNullOrEmpty(taskOptions.GroupName))
|
{
|
mes.code = "300";
|
mes.message = "任务名和分组名不能为空！";
|
return Json(mes);
|
}
|
return Json(await _schedulerFactory.Remove(taskOptions, _quartzRepo));
|
}
|
|
[Route("Update")]
|
[HttpPost]
|
public async Task<IActionResult> Update(TaskOptions taskOptions)
|
{
|
if (string.IsNullOrEmpty(taskOptions.TaskName) || string.IsNullOrEmpty(taskOptions.GroupName))
|
{
|
mes.code = "300";
|
mes.message = "任务名和分组名不能为空！";
|
return Json(mes);
|
}
|
return Json(await _schedulerFactory.Update(taskOptions, _quartzRepo));
|
}
|
|
[Route("Pause")]
|
[HttpPost]
|
public async Task<IActionResult> Pause(TaskOptions taskOptions)
|
{
|
if (string.IsNullOrEmpty(taskOptions.TaskName) || string.IsNullOrEmpty(taskOptions.GroupName))
|
{
|
mes.code = "300";
|
mes.message = "任务名和分组名不能为空！";
|
return Json(mes);
|
}
|
// 校验任务是否存在
|
if (!await _quartzRepo.TaskExistsAsync(taskOptions.TaskName, taskOptions.GroupName))
|
{
|
mes.code = "300";
|
mes.message = "任务不存在！";
|
return Json(mes);
|
}
|
return Json(await _schedulerFactory.Pause(taskOptions, _quartzRepo));
|
}
|
|
[Route("Start")]
|
[HttpPost]
|
public async Task<IActionResult> Start(TaskOptions taskOptions)
|
{
|
if (string.IsNullOrEmpty(taskOptions.TaskName) || string.IsNullOrEmpty(taskOptions.GroupName))
|
{
|
mes.code = "300";
|
mes.message = "任务名和分组名不能为空！";
|
return Json(mes);
|
}
|
if (!await _quartzRepo.TaskExistsAsync(taskOptions.TaskName, taskOptions.GroupName))
|
{
|
mes.code = "300";
|
mes.message = "任务不存在！";
|
return Json(mes);
|
}
|
return Json(await _schedulerFactory.Start(taskOptions, _quartzRepo));
|
}
|
|
[Route("Run")]
|
[HttpPost]
|
public async Task<IActionResult> Run(TaskOptions taskOptions)
|
{
|
if (string.IsNullOrEmpty(taskOptions.TaskName) || string.IsNullOrEmpty(taskOptions.GroupName))
|
{
|
mes.code = "300";
|
mes.message = "任务名和分组名不能为空！";
|
return Json(mes);
|
}
|
if (!await _quartzRepo.TaskExistsAsync(taskOptions.TaskName, taskOptions.GroupName))
|
{
|
mes.code = "300";
|
mes.message = "任务不存在！";
|
return Json(mes);
|
}
|
return Json(await _schedulerFactory.Run(taskOptions, _quartzRepo));
|
}
|
}
|
}
|
