优化了定时任务

Author: weishakeji

Sourcecode/Song.WebSite/Global.asax.cs

@@ -10,6 +10,9 @@
 using Song.Entities;
 using System.Data;
 using WeiSha.Core;
+using System.Threading.Tasks;
+using Quartz;
+using Quartz.Impl;
 
 namespace Song.WebSite
 {
@@ -46,11 +49,61 @@ protected void Application_Start()
             {
                 Log.Error(this.GetType().ToString(), ex);
             }
-            //更新统计数据,延迟执行
-            WeiSha.Core.Business.Do<IOrganization>().UpdateStatisticalData_Delay(10);
-            //创建定时任务
-            WeiSha.Core.Business.Do<IOrganization>().UpdateStatisticalData_CronJob();
-            
+            ////更新统计数据,延迟执行
+            //WeiSha.Core.Business.Do<IOrganization>().UpdateStatisticalData_Delay(10);
+            ////创建定时任务
+            //WeiSha.Core.Business.Do<IOrganization>().UpdateStatisticalData_CronJob();
+
+            //执行定时任务
+            // 启动 Quartz 调度器  
+            StartScheduler().GetAwaiter().GetResult();
+
+        }
+        // 定时任务的调度器
+        private static IScheduler _scheduler;
+        private async Task StartScheduler()
+        {
+            // 创建调度器  
+            _scheduler = await StdSchedulerFactory.GetDefaultScheduler();
+
+
+            // 定义作业  
+            IJobDetail job = JobBuilder.Create<ScheduledTaskJob>()
+                .WithIdentity("ScheduledTaskJob", "group1")
+                .Build();
+
+            //定时的时间，CRON 表达式
+            string cron = WeiSha.Core.App.Get["QueryDetail_Cron"].String;
+            // 创建触发器，设置指定时间执行  
+            ITrigger trigger = TriggerBuilder.Create()
+                .WithIdentity("myTrigger", "group1")
+                .StartNow()
+                .WithCronSchedule(cron) // CRON 表达式
+                .Build();
+
+            // 调度作业  
+            await _scheduler.ScheduleJob(job, trigger);
+
+            await _scheduler.Start();
+        }
+        protected void Application_End(object sender, EventArgs e)
+        {
+            // 停止并释放 Quartz 调度器  
+            _scheduler?.Shutdown(waitForJobsToComplete: true);
+        }
+       
+    }
+    /// <summary>
+    /// 定时任务的执行类
+    /// </summary>
+    public class ScheduledTaskJob : IJob
+    {
+        public async Task Execute(IJobExecutionContext context)
+        {
+            //执行方法          
+            //更新统计数据
+            WeiSha.Core.Business.Do<IOrganization>().UpdateStatisticalData();
+            await Task.CompletedTask;
         }
     }
 }

Sourcecode/Song.WebSite/Song.WebSite.csproj

@@ -75,12 +75,18 @@
       <HintPath>..\packages\Microsoft.CodeDom.Providers.DotNetCompilerPlatform.2.0.1\lib\net45\Microsoft.CodeDom.Providers.DotNetCompilerPlatform.dll</HintPath>
     </Reference>
     <Reference Include="Microsoft.CSharp" />
+    <Reference Include="Microsoft.Extensions.Logging.Abstractions, Version=2.1.1.0, Culture=neutral, PublicKeyToken=adb9793829ddae60, processorArchitecture=MSIL">
+      <HintPath>..\packages\Microsoft.Extensions.Logging.Abstractions.2.1.1\lib\netstandard2.0\Microsoft.Extensions.Logging.Abstractions.dll</HintPath>
+    </Reference>
     <Reference Include="Microsoft.Web.Infrastructure, Version=1.0.0.0, Culture=neutral, PublicKeyToken=31bf3856ad364e35, processorArchitecture=MSIL">
       <HintPath>..\packages\Microsoft.Web.Infrastructure.1.0.0.0\lib\net40\Microsoft.Web.Infrastructure.dll</HintPath>
     </Reference>
     <Reference Include="Newtonsoft.Json, Version=12.0.0.0, Culture=neutral, PublicKeyToken=30ad4fe6b2a6aeed, processorArchitecture=MSIL">
       <HintPath>..\packages\Newtonsoft.Json.12.0.3\lib\net45\Newtonsoft.Json.dll</HintPath>
     </Reference>
+    <Reference Include="Quartz, Version=3.13.1.0, Culture=neutral, PublicKeyToken=f6b8c98a402cc8a4, processorArchitecture=MSIL">
+      <HintPath>..\packages\Quartz.3.13.1\lib\net462\Quartz.dll</HintPath>
+    </Reference>
     <Reference Include="System" />
     <Reference Include="System.Buffers, Version=4.0.2.0, Culture=neutral, PublicKeyToken=cc7b13ffcd2ddd51, processorArchitecture=MSIL">
       <HintPath>..\packages\System.Buffers.4.4.0\lib\netstandard2.0\System.Buffers.dll</HintPath>
@@ -124,6 +130,7 @@
     <Reference Include="System.Runtime.CompilerServices.Unsafe, Version=4.0.4.1, Culture=neutral, PublicKeyToken=b03f5f7f11d50a3a, processorArchitecture=MSIL">
       <HintPath>..\packages\System.Runtime.CompilerServices.Unsafe.4.5.2\lib\netstandard2.0\System.Runtime.CompilerServices.Unsafe.dll</HintPath>
     </Reference>
+    <Reference Include="System.Runtime.Remoting" />
     <Reference Include="System.Security" />
     <Reference Include="System.Security.Cryptography.Algorithms, Version=4.1.0.0, Culture=neutral, PublicKeyToken=b03f5f7f11d50a3a, processorArchitecture=MSIL">
       <HintPath>..\packages\System.Security.Cryptography.Algorithms.4.3.0\lib\net461\System.Security.Cryptography.Algorithms.dll</HintPath>