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}");
|
||
}
|
||
}
|
||
}
|