MVC 使用Quartz.Net組件實現定時計劃任務

-Advertisement-

最近，項目中需要執行一個計劃任務，組長就讓我瞭解一下Quartz.net 這個組件，挺簡單的一個組件，實現起來特別的方便，靈活，值得推薦給大家一起學習一下這個小工具。以前我有的時候是使用定時器Timer，還有資料庫中的計劃任務，後來發現這些真的太不好用了。下麵我介紹一下這個組件的使用步驟和註意事項 ...

最近，項目中需要執行一個計劃任務，組長就讓我瞭解一下Quartz.net 這個組件，挺簡單的一個組件，實現起來特別的方便，靈活，值得推薦給大家一起學習一下這個小工具。以前我有的時候是使用定時器Timer，還有資料庫中的計劃任務，後來發現這些真的太不好用了。下麵我介紹一下這個組件的使用步驟和註意事項，僅供參考，有什麼不對的地方，希望大家多多見諒並幫我指出來，大家相互學習嘛。

首先，簡述一下Quartz.net 組件的基本概念：它是一個簡單的執行任務計劃的組件，基本包括這三部分：Job(作業)、Trigger(觸發器)、scheduler(調度器)。

1.Job 作業：需要在任務計劃中執行的具體邏輯操作

2.Trigger 觸發器：需要什麼時間什麼規則來去執行Job 作業

3.scheduler 調度器：將Job 和 Trigger 註冊到 scheduler 調度器中，主要負責協調Job、Trigger 的運行

第一步：下載Quartz.net 組件

在VS 中工具 > NuGet 程式包管理器 > 程式包管理控制台點擊打開在控制臺上輸入 Install-Package Quartz 就可以成功下載下來了，詳見如圖所示：

第二步：在VS 中我們創建一個類庫，這樣方便我們移植程式，也方便我們代碼的分離；一個Job 創建一個實例類，下麵我會創建兩個實例類一個是UpdateCompleteJob.cs、UpdateAutoCancelStateJob.cs (之所以創建兩個Job是為了能方便大家瞭解這個組件可以同時執行多個任務)

(1) UpdateCompleteJob.cs 代碼如下：

using Quartz;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using WechatMall.Application.BLL;
using WechatMall.Application.Data;
using WechatMall.Model.ExpressModel;

namespace WechatMallJobLibrary
{
    public class UpdateCompleteJob : IJob
    {
        /// <summary>
        ///在Job 中我們必須實現IJob介面中的Execute 這個方法，才能正確的使用Job
        /// </summary>
        public void Execute(IJobExecutionContext context)
        {
            using (var _ctx = new BtDbContext())
            {
                List<string> expressCode = new List<string>();

                var query = _ctx.Orders.Where(c => c.OrderStatus ==  WechatMall.Common.EnumHelper.OrderStatus.Sended 
                                                && c.PayStatus == WechatMall.Common.EnumHelper.PayStatus.Paid).OrderBy(c => c.CreateTime).ToList().Take(20);

                foreach (var item in query)
                {
                    if (!string.IsNullOrEmpty(item.ExpressCode))
                    {
                        ExpressModel model = ExpressAPI._GetExpress(item.ExpressCode);
                        
                        //確定 快遞已簽收  修改訂單狀態 已完成
                        if (model.state == "3" && model.ischeck == "1")
                        {
                            var order = _ctx.Orders.FirstOrDefault( c => c.OrderId == item.OrderId);

                            order.OrderStatus = WechatMall.Common.EnumHelper.OrderStatus.Over;
                            order.FlowStatus  = WechatMall.Common.EnumHelper.FlowStatus.Over;
                            order.UpdateTime  = DateTime.Now;

                            _ctx.SaveChanges();
                        }
                    }
                  
                }

            }
        }
    }
}

View Code

(2) UpdateAutoCancelStateJob.cs 代碼如下：

using Quartz;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using WechatMall.Application.Data;

namespace WechatMallJobLibrary
{
   public class UpdateAutoCancelStateJob:IJob
    {
       public void Execute(IJobExecutionContext context)
       {
           using (var _ctx = new BtDbContext())
           {
               var order = _ctx.Orders.FirstOrDefault(c => c.OrderStatus == WechatMall.Common.EnumHelper.OrderStatus.UnSend 
                                                        && c.PayStatus == WechatMall.Common.EnumHelper.PayStatus.UnPaid);

               if (this.DateDiff(DateTime.Now,order.CreateTime) > 30)
               {
                   order.OrderStatus = WechatMall.Common.EnumHelper.OrderStatus.Cancel;
                   order.FlowStatus  = WechatMall.Common.EnumHelper.FlowStatus.Cancel;
                   order.UpdateTime  = DateTime.Now;

                   _ctx.SaveChanges();
               }
           }
       }

      //計算時間差的方法
       private int DateDiff(DateTime DateTime1, DateTime DateTime2)
       {
           int dateDiff = 0;
           TimeSpan ts1 = new TimeSpan(DateTime1.Ticks);
           TimeSpan ts2 = new
           TimeSpan(DateTime2.Ticks);
           TimeSpan ts = ts1.Subtract(ts2).Duration();
          // dateDiff = ts.Days.ToString()+"天"+ ts.Hours.ToString()+"小時"+ ts.Minutes.ToString()+"分鐘"+ ts.Seconds.ToString()+"秒";
            dateDiff =  ts.Minutes;
          
           return dateDiff;
       }
    }
}

View Code

備註：解釋一下上面兩個類中的方法中的IJobExecutionContext 參數是什麼意思，在Execute方法有一個IJobExecutionContext的介面對象作為參數，這個參數包含了定義這個類的job(作業)的配置信息。作為實例在這裡我就沒有展示是怎麼使用的，有時間我會補充上去的。

第三步：就該設置Trigger 觸發器，在實際中我是將Trigger和Job 直接註冊到 scheduler 調度器中；在這裡其實還有一小步沒有指出來就是需要將類庫生成的DLL 拷貝到你的需要執行的項目的文件中.詳見3.1 中的圖

3.1 下麵標紅的是dll 所放文件的名字，在下麵的代碼中需要使用的，小伙伴們多註意一下

您的分享是我們最大的動力!

-Advertisement-