Yuebon.NetCore/Yuebon.Quartz.Jobs/TestJob.cs

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

namespace Yuebon.Quartz.Jobs;

/// <summary>
/// 测试demo
/// 必须实现IJob接口中的Execute()方法
/// </summary>
public class TestJob : IJob
{
   private readonly ITaskManagerService iService;
    private readonly ILogService iLogService;

    public TestJob(ITaskManagerService _iService, ILogService _iLogService)
    {
        this.iService = _iService;
        this.iLogService = _iLogService;
    }

    public async Task Execute(IJobExecutionContext context)
    { 
        DateTime dateTime = DateTime.Now;
        Stopwatch stopwatch = new Stopwatch();
        stopwatch.Start();
        AbstractTrigger trigger = (context as JobExecutionContextImpl).Trigger as AbstractTrigger;
        string sqlWhere = string.Format("Id='{0}' and GroupName='{1}'", trigger.Name, trigger.Group);
        TaskManager taskManager = iService.GetWhere(sqlWhere);
        if (taskManager == null)
        {
            FileQuartz.WriteErrorLog($"任务不存在");
        }
        try
        {
            string msg = $"开始时间:{dateTime.ToString("yyyy-MM-dd HH:mm:ss ffff")}";
            //记录任务执行记录
            iService.RecordRun(taskManager.Id, JobAction.开始,true, msg);
            //初始化任务日志
            FileQuartz.InitTaskJobLogPath(taskManager.Id);
            var jobId = context.MergedJobDataMap.GetString("OpenJob");
            //todo:这里可以加入自己的自动任务逻辑
            Log4NetHelper.Info(DateTime.Now.ToString() + "执行任务");


            stopwatch.Stop();
            string content = $"结束时间:{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss ffff")} 共耗时{stopwatch.ElapsedMilliseconds} 毫秒\r\n";
            iService.RecordRun(taskManager.Id, JobAction.结束, true, content);
            if ((MsgType)taskManager.SendMail == MsgType.All)
            {
                if (!string.IsNullOrEmpty(taskManager.EmailAddress))
                {
                    List<string> recipients = new List<string>();
                    recipients = taskManager.EmailAddress.Split(",").ToList();
                    var mailBodyEntity = new MailBodyEntity()
                    {
                        Body = msg + content + ",请勿回复本邮件",
                        Recipients = recipients,
                        Subject = taskManager.TaskName
                    };
                   await SendMailHelper.SendMail(mailBodyEntity);
                }

            }