From 17cebfec221a9518e16b8555f3aa5f54beaafaa1 Mon Sep 17 00:00:00 2001
From: hwh <332078369@qq.com>
Date: 星期二, 25 六月 2024 14:05:49 +0800
Subject: [PATCH] 定时任务
---
Wms/Wms/Controllers/JobController.cs | 15 ++++++++++++---
1 files changed, 12 insertions(+), 3 deletions(-)
diff --git a/Wms/Wms/Controllers/JobController.cs b/Wms/Wms/Controllers/JobController.cs
index 2875076..6b1f28f 100644
--- a/Wms/Wms/Controllers/JobController.cs
+++ b/Wms/Wms/Controllers/JobController.cs
@@ -2,6 +2,7 @@
using Microsoft.AspNetCore.Mvc;
using Microsoft.AspNetCore.Mvc.RazorPages;
using Quartz;
+using System;
using System.Collections.Generic;
using System.Threading.Tasks;
using Utility.Entity;
@@ -37,7 +38,7 @@
/// <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 == "* * * * * ?")
@@ -94,10 +95,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 "淇敼璁″垝浠诲姟鎴愬姛锛�";
--
Gitblit v1.8.0