添加项目文件。

yl

2025-03-19 14ebf45749361ad5043ff3f1562cd66b7b82a50d

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
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;
        public TaskBackGroundController(ISchedulerFactory schedulerFactory, IJobFactory jobFactory)
        {
            this._jobFactory = jobFactory;
            this._schedulerFactory = schedulerFactory;
        }
 
        /// <summary>
        /// 获取所有的作业
        /// </summary>
        /// <returns></returns>
        [Route(template: "GetJobs")]
        [HttpGet]
        public async Task<IActionResult> GetJobs()
        {
            mes.code = "200";
            mes.message = "查询成功！";
            mes.data = await _schedulerFactory.GetJobs();
            return Json(mes);
        }
 
        /// <summary>
        /// 获取作业运行日志
        /// </summary>
        /// <param name="taskName"></param>
        /// <param name="groupName"></param>
        /// <param name="page"></param>
        /// <returns></returns>
        [Route(template: "GetRunLog")]
        [HttpGet]
        public IActionResult GetRunLog(string taskName, string groupName, int page = 1)
        {
            mes.code = "200";
            mes.data = FileQuartz.GetJobRunLog(taskName, groupName, page);
            return Json(mes);
        }
 
        /// <summary>
        /// 添加任务
        /// </summary>
        /// <param name="taskOptions"></param>
        /// <returns></returns>
        [Route(template: "Add")]
        [HttpPost]
        //[TaskAuthor]
        public async Task<IActionResult> Add(TaskOptions taskOptions)
        {
            return Json(await taskOptions.AddJob(_schedulerFactory, jobFactory: _jobFactory));
        }
 
        /// <summary>
        /// 删除任务
        /// </summary>
        /// <param name="taskOptions"></param>
        /// <returns></returns>
        [Route(template: "Remove")]
        [HttpPost]
        //[TaskAuthor]
        public async Task<IActionResult> Remove(TaskOptions taskOptions)
        {
            return Json(await _schedulerFactory.Remove(taskOptions));
        }
 
        /// <summary>
        /// 修改任务
        /// </summary>
        /// <param name="taskOptions"></param>
        /// <returns></returns>
        [Route(template: "Update")]
        [HttpPost]
        //[TaskAuthor]
        public async Task<IActionResult> Update(TaskOptions taskOptions)
        {
            return Json(await _schedulerFactory.Update(taskOptions));
        }
 
        /// <summary>
        /// 暂停任务
        /// </summary>
        /// <param name="taskOptions"></param>
        /// <returns></returns>
        [Route(template: "Pause")]
        [HttpPost]
        //[TaskAuthor]
        public async Task<IActionResult> Pause(TaskOptions taskOptions)
        {
            return Json(await _schedulerFactory.Pause(taskOptions));
        }
 
        /// <summary>
        /// 开启任务
        /// </summary>
        /// <param name="taskOptions"></param>
        /// <returns></returns>
        [Route(template: "Start")]
        [HttpPost]
        //[TaskAuthor]
        public async Task<IActionResult> Start(TaskOptions taskOptions)
        {
            return Json(await _schedulerFactory.Start(taskOptions));
        }
 
        /// <summary>
        /// 立即执行
        /// </summary>
        /// <param name="taskOptions"></param>
        /// <returns></returns>
        [Route(template: "Run")]
        [HttpPost]
        //[TaskAuthor]
        public async Task<IActionResult> Run(TaskOptions taskOptions)
        {
            return Json(await _schedulerFactory.Run(taskOptions));
        }
    }
}