first commit

ZR.Tasks/TaskScheduler/JobBase.cs

@@ -0,0 +1,87 @@
+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}");
+        }
+    }
+}