88 lines
3.0 KiB
C#
88 lines
3.0 KiB
C#
|
using Infrastructure;
|
|||
|
|
using NLog;
|
|||
|
|
using Quartz;
|
|||
|
|
using System;
|
|||
|
|
using System.Collections.Generic;
|
|||
|
|
using System.Diagnostics;
|
|||
|
|
using System.Threading.Tasks;
|
|||
|
|
using ZR.Model.System;
|
|||
|
|
using ZR.Service.IService;
|
|||
|
|
|
|||
|
|
namespace ZR.Tasks
|
|||
|
|
{
|
|||
|
|
public class JobBase
|
|||
|
|
{
|
|||
|
|
/// <summary>
|
|||
|
|
/// 日志接口
|
|||
|
|
/// </summary>
|
|||
|
|
private static readonly Logger logger = LogManager.GetCurrentClassLogger();
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 执行指定任务
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="context">作业上下文</param>
|
|||
|
|
/// <param name="job">业务逻辑方法</param>
|
|||
|
|
public async Task<Dictionary<string,object>> ExecuteJob(IJobExecutionContext context, Func<Task> job)
|
|||
|
|
{
|
|||
|
|
string logMsg = "";
|
|||
|
|
double elapsed = 0;
|
|||
|
|
int status = 0;
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
//var s = context.Trigger.Key.Name;
|
|||
|
|
//记录Job时间
|
|||
|
|
Stopwatch stopwatch = new Stopwatch();
|
|||
|
|
stopwatch.Start();
|
|||
|
|
//执行任务
|
|||
|
|
await job();
|
|||
|
|
stopwatch.Stop();
|
|||
|
|
elapsed = stopwatch.Elapsed.TotalMilliseconds;
|
|||
|
|
logMsg = "Succeed";
|
|||
|
|
}
|
|||
|
|
catch (Exception ex)
|
|||
|
|
{
|
|||
|
|
JobExecutionException e2 = new JobExecutionException(ex);
|
|||
|
|
//true 是立即重新执行任务
|
|||
|
|
e2.RefireImmediately = true;
|
|||
|
|
status = 1;
|
|||
|
|
logMsg = $"Fail，Exception：{ex.Message}";
|
|||
|
|
}
|
|||
|
|
Dictionary<string, object> dic = new Dictionary<string, object>();
|
|||
|
|
dic.Add("elapsed", elapsed);
|
|||
|
|
dic.Add("status", status);
|
|||
|
|
dic.Add("content", logMsg);
|
|||
|
|
|
|||
|
|
RecordTaskLog(context, dic);
|
|||
|
|
return dic;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 记录到日志
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="context"></param>
|
|||
|
|
/// <param name="executeLog"></param>
|
|||
|
|
protected void RecordTaskLog(IJobExecutionContext context, Dictionary<string, object> executeLog)
|
|||
|
|
{
|
|||
|
|
var tasksLogService = (ISysTasksLogService)App.GetRequiredService(typeof(ISysTasksLogService));
|
|||
|
|
|
|||
|
|
// 可以直接获取 JobDetail 的值
|
|||
|
|
IJobDetail job = context.JobDetail;
|
|||
|
|
//var param = context.MergedJobDataMap;
|
|||
|
|
|
|||
|
|
// 也可以通过数据库配置，获取传递过来的参数
|
|||
|
|
//JobDataMap data = context.JobDetail.JobDataMap;
|
|||
|
|
//int jobId = data.GetInt("JobParam");
|
|||
|
|
|
|||
|
|
var logModel = new SysTasksLog();
|
|||
|
|
|
|||
|
|
logModel.InvokeTarget = job.JobType.FullName;
|
|||
|
|
logModel.Elapsed = (double)executeLog.GetValueOrDefault("elapsed", "0");
|
|||
|
|
logModel.JobMessage = executeLog.GetValueOrDefault("content").ToString();
|
|||
|
|
logModel.Status = executeLog.GetValueOrDefault("status", "0").ToString();
|
|||
|
|
logModel = tasksLogService.AddTaskLog(job.Key.Name, logModel);
|
|||
|
|
|
|||
|
|
logger.Info($"执行任务【{job.Key.Name}|{logModel.JobName}】结果={logModel.JobMessage}");
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|