·

hwh

2025-01-15 131347ad63bb534b5abb6dbc979f0a47d780d8ff

 Wms/Wms/Controllers/JobController.cs

@@ -2,18 +2,22 @@
using Microsoft.AspNetCore.Mvc;
using Microsoft.AspNetCore.Mvc.RazorPages;
using Quartz;
using System;
using System.Collections.Generic;
using System.Threading.Tasks;
using Utility.Entity;
using Utility;
using Model.ModelVm;
using Microsoft.AspNetCore.Authorization;

namespace Wms.Controllers
{
    /// <summary>
    /// 任务调度
    /// </summary>
    [Route("api/[controller]/[Action]")]
    [EnableCors("AllowSameDomain")] //允许跨域 
    [Route("api/[controller]/[action]")]
    [ApiController]
    [Authorize]
    [ServiceFilter(typeof(ApiResponseActionFilter))]
    public class JobController : ControllerBase
    {
@@ -34,14 +38,13 @@
        /// <param name="entity"></param>
        /// <returns></returns>
        [HttpPost]
        public async Task<string> AddJob([FromBody] ScheduleEntity entity)
        public async Task<string> AddJob(ScheduleEntity entity)
        {
            if (entity.TriggerType == TriggerTypeEnum.Cron &&
                     entity.Cron == "* * * * * ?")
            {
                return "不允许过频繁执行任务！";
            }

            return await scheduler.AddScheduleJobAsync(entity);
        }

@@ -50,7 +53,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 +63,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 +73,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 +83,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);
        }
@@ -91,10 +94,18 @@
        /// <param name="entity"></param>
        /// <returns></returns>
        [HttpPost]
        public async Task<string> ModifyJob([FromBody] ModifyJobInput entity)
        public async Task<string> ModifyJob(ModifyJobInput entity)
        {
            var jobKey = new JobKey(entity.OldScheduleEntity.JobName, entity.OldScheduleEntity.JobGroup);
            var runNumber = await scheduler.GetRunNumberAsync(jobKey);
            long runNumber = 0;
            try
            {
                runNumber = await scheduler.GetRunNumberAsync(jobKey);
            }
            catch (Exception)
            {

            }
            await scheduler.StopOrDelScheduleJobAsync(entity.OldScheduleEntity.JobGroup, entity.OldScheduleEntity.JobName, true);
            await scheduler.AddScheduleJobAsync(entity.NewScheduleEntity, runNumber);
            return "修改计划任务成功！";
@@ -106,9 +117,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 +130,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;
        }
@@ -150,9 +163,16 @@
        /// </summary>
        /// <returns></returns>
        [HttpGet]
        public async Task<List<JobInfoEntity>> GetAllJob()
        public async Task<List<JobInfo>> GetAllJob()
        {
            return await scheduler.GetAllJobAsync();
            var list = await scheduler.GetAllJobAsync();
            var listJob = new List<JobInfo>();
            foreach (var mod in list)
            {
                mod.JobInfoList.ForEach(s => s.GroupName = mod.GroupName);
                listJob.AddRange(mod.JobInfoList);
            }
            return listJob;
        }

        /// <summary>