调用内部代码的定时任务

hwh

2024-06-22 f52bacd52cbc8f8250766d2910e638a8bf4dbcc8

 Wms/Wms/Controllers/JobController.cs

@@ -6,6 +6,7 @@
using System.Threading.Tasks;
using Utility.Entity;
using Utility;
using Model.ModelVm;

namespace Wms.Controllers
{
@@ -50,7 +51,7 @@
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        public async Task<string> StopJob([FromBody] JobKey job)
        public async Task<string> StopJob(JobVm job)
        {
            return await scheduler.StopOrDelScheduleJobAsync(job.Group, job.Name);
        }
@@ -60,7 +61,7 @@
        /// </summary> 
        /// <returns></returns>
        [HttpPost]
        public async Task<string> RemoveJob([FromBody] JobKey job)
        public async Task<string> RemoveJob(JobVm job)
        {
            return await scheduler.StopOrDelScheduleJobAsync(job.Group, job.Name, true);
        }
@@ -70,7 +71,7 @@
        /// </summary> 
        /// <returns></returns>
        [HttpPost]
        public async Task<string> ResumeJob([FromBody] JobKey job)
        public async Task<string> ResumeJob(JobVm job)
        {
            return await scheduler.ResumeJobAsync(job.Group, job.Name);
        }
@@ -80,7 +81,7 @@
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        public async Task<ScheduleEntity> QueryJob([FromBody] JobKey job)
        public async Task<ScheduleEntity> QueryJob(JobVm job)
        {
            return await scheduler.QueryJobAsync(job.Group, job.Name);
        }
@@ -106,9 +107,10 @@
        /// <param name="job"></param>
        /// <returns></returns>
        [HttpPost]
        public async Task<bool> TriggerJob([FromBody] JobKey job)
        public async Task<bool> TriggerJob(JobVm job)
        {
            await scheduler.TriggerJobAsync(job);
            JobKey modKey = new JobKey(job.Name, job.Group);
            await scheduler.TriggerJobAsync(modKey);
            return true;
        }

@@ -118,9 +120,10 @@
        /// <param name="jobKey"></param>
        /// <returns></returns>
        [HttpPost]
        public async Task<List<string>> GetJobLogs([FromBody] JobKey jobKey)
        public async Task<List<string>> GetJobLogs(JobVm job)
        {
            var logs = await scheduler.GetJobLogsAsync(jobKey);
            JobKey modKey = new JobKey(job.Name, job.Group);
            var logs = await scheduler.GetJobLogsAsync(modKey);
            logs?.Reverse();
            return logs;
        }