c# Quartzs定時器的簡單使用

使用背景：

　　　　首先想到倒計時，定時任務。大家想到的肯定就是定時器。那么定時器在web和winfrom程序中有着很大的作用。那在服務器端有沒有像定時器一樣的存在呢。

有了這些需求，我找到了第三方的組件 Quartz.Net 來實現（源碼位置：https://github.com/quartznet/quartznet）

（1）第一步，通過NuGet下載Quartz.Net組件並且引用到當前工程中

 

 

 

 

（2）創建兩個類，一個是操作類，一個類繼承IJob 並且需要實現IJob的方法。 

    /// <summary>
    /// 操作類
    /// </summary>
    public class Operation : BaseBusiness<Auction>
    {

        #region 實例化

        public Operation()
        {
            _options = new Options();
        }

        internal IOptions _options { get; }

        #endregion

        public static IScheduler scheduler;
        public static ISchedulerFactory factory;
        /// <summary>
        /// 獲取cron表達式
        /// </summary>
        /// <param name="time">時間</param>
        /// <returns></returns>
        public string GetCron(DateTime? time)
        {
            var txt = Convert.ToDateTime(time).ToString("yyyy-MM-dd-HH-mm-ss");
            var arr = txt.Split('-');
            var result = string.Format("{0} {1} {2} {3} {4} ? {5}", arr[5], arr[4], arr[3], arr[2], arr[1], arr[0]);
            return result;
        }
        /// <summary>
        /// 刪除job
        /// </summary>
        /// <param name="Id">拍賣數據對象主鍵</param>
        /// <param name="GroupName">job的組名</param>
        public void RemoveJob(string Id, string MarkGoodsId, string GroupName)
        {
            //var jobKey = new JobKey(GroupName + Id + MId + "j", GroupName);
            var job = new JobKey(GroupName + Id + MarkGoodsId + "j", GroupName);
            scheduler.DeleteJob(job);
        }


        //清楚所有定時任務
        public void ClearJob()
        {
            if (scheduler != null)
            {
                scheduler.Clear();

            }
        }


    }

 

public class SetAuctionings : Operation, IJob
    {
        public async Task Execute(IJobExecutionContext context)
        {
            await Task.Run(() =>
            {

                DateTime freeTime = context.JobDetail.JobDataMap.GetDateTime("FreeTime");
                var now = DateTime.Now;

                //記錄兩個時間的差
                var days = freeTime.Subtract(now).Days;
                var hours = freeTime.Subtract(now).Hours;
                var minutes = freeTime.Subtract(now).Minutes;
                var seconds = freeTime.Subtract(now).Seconds;
                var result = days + "天" + hours + "時" + minutes + "分" + seconds + "秒";
//推送倒計時
                PushHelper.AuctionCountDown(markId, days, hours, minutes, seconds);





                //getTriggerState


            });
        }


/// <summary>
        /// 設置定時任務
        /// </summary>
        /// <param name="Id">標的ID</param>
        public void AddQz(DateTime BeginTime, DateTime FreeTime)
        {

            var GroupName = _options.GetPKById<Options_AuctionState>("1316283839361847296").ToString();
            factory = new StdSchedulerFactory();
            scheduler = factory.GetScheduler().Result;
            var jobKey = new JobKey(GroupName + Id + MId + "j", GroupName);
            var GjobDetail = scheduler.GetJobDetail(jobKey);
            if (GjobDetail != null)
            {
                //刪除任務
                scheduler.DeleteJob(jobKey);
            }


            //設置Job  StatefulJob 
            var job = JobBuilder.Create<SetAuctionings>()
                       .WithIdentity(GroupName + Id + MId + "j", GroupName)
                       .Build();



            job.JobDataMap.Put("FreeTime", FreeTime);
//【方法1】 設置每秒執行
            ITrigger trigger = TriggerBuilder.Create()
                .WithIdentity(GroupName + Id + MId + "t", GroupName)
                .WithSimpleSchedule(x => x.WithIntervalInSeconds(1)
                .RepeatForever())
                .StartAt(new DateTimeOffset(BeginTime))
                .EndAt(new DateTimeOffset(FreeTime))
                .Build();


            //【方法2】
            //var ExecSs = "0/1 * * * * ?";
            //ITrigger trigger = TriggerBuilder.Create()
            //    .WithIdentity(GroupName + Id + MeetingPlace + "t", GroupName)
            //    .WithCronSchedule(ExecSs)
            //    .StartAt(new DateTimeOffset(BeginTime))
            //    .EndAt(new DateTimeOffset(FreeTime))
            //    .Build();

            scheduler.ScheduleJob(job, trigger);
        }

    }

以上是一個簡單的封裝，可以根據這個倒計時的推送。增加一些封裝 如：暫停，恢復，結束，更新等。

調用的話只需要簡單的實例化一下進行調用。

然后我在大概說下其他封裝的思路和代碼片段；

延時倒計時：

根據傳過來的參數時間進行一個修改，刪除之前的任務重新開始一個任務；

/// <summary>
        /// 【拍賣延時】修改倒計時任務
        /// </summary>
        /// <param name="Id"></param>
        /// <param name="MeetingPlace"></param>
        /// <param name="FreeTime"></param>
        public void UpdateQz(String Id, string Mid, DateTime FreeTime, DateTime LimitTime)
        {


            //scheduler = factory.GetScheduler().Result;
            //if (scheduler == null)
            //    return;

            //拍賣進行中
            var GroupName = _options.GetPKById<Options_AuctionState>("1316283839361847296").ToString();
            var jobKey = new JobKey(GroupName + Id + Mid + "j", GroupName);
            var GjobDetail = scheduler.GetJobDetail(jobKey);
            if (GjobDetail.Result == null)
                return;


            var triggerKey = new TriggerKey(GroupName + Id + Mid + "t", GroupName);
            var triggerr = scheduler.GetTrigger(triggerKey);
            var triggerBuilder = triggerr.Result.GetTriggerBuilder();
            //修改結束時間 WithCronSchedule(ExecSs).
            ITrigger newTrigger = triggerBuilder.EndAt(new DateTimeOffset(FreeTime)).Build();



            var job = GjobDetail.Result;
            job.JobDataMap.Put("AuctionId", Id);
            job.JobDataMap.Put("MarkId", Mid);
            job.JobDataMap.Put("FreeTime", FreeTime);
            job.JobDataMap.Put("LimitTime", LimitTime);


            //刪除任務
            scheduler.DeleteJob(jobKey);
            scheduler.ScheduleJob(job, newTrigger);


            //修改最終結束的定時任務；
            SetAuctioneds setAuctioneds = new SetAuctioneds();
            setAuctioneds.SetEndQz(Id, FreeTime, Mid);
        }

　

倒計時暫停：

調用組件的PauseTrigger方法可以進行暫停；

        /// <summary>
        /// 倒計時暫停
        /// </summary>
        public AjaxResult StopQz(string Id, string MId)
        {
            try
            {



                //方法1
                //拍賣進行中
                var GroupName = _options.GetPKById<Options_AuctionState>("1316283839361847296").ToString();



                var mark = Service.GetIQueryable<MarkGoods>().FirstOrDefault(x => x.Id == MId);
                if (mark == null)
                    return Error("找不到標的！");


                //獲取實際結束時間。
                var subEndTime = mark.EndTime.Value;
                //計算暫停后剩余的時間  = audEndTime（結束時間） - 當前時間
                var nowEndTime = DateTime.Now;
                var DifferTime = subEndTime.Subtract(nowEndTime);

                //追加 剩余時間 和 當前結束時間；
                mark.SurplusTime = DifferTime.ToString();
                //mark.EndTime = nowEndTime;




                //GroupName + Id + MId + "t", GroupName
                var TriKey = new TriggerKey(GroupName + Id + MId + "t", GroupName);


                var Result = scheduler.GetTriggerState(TriKey).Result;
                if (Result == TriggerState.None)
                {
                    return Error("失敗：不存在此任務！");
                }


                if (Result == TriggerState.Paused)//暫停
                {
                    return Success("失敗：該任務已暫停！");

                }
                else
                {
                    scheduler.PauseTrigger(TriKey);
                    mark.AucTimeStatus = 2;
                    Service.UpdateAny<MarkGoods>(mark, new List<string> { "SurplusTime", "AucTimeStatus" });
                    return Success("成功：任務已暫停");
                }




                //方法2
                //var mark = Service.GetIQueryable<MarkGoods>().FirstOrDefault(x => x.Id == MId);
                //if (mark == null)
                //    return;


                ////獲取實際結束時間。
                //var subEndTime = mark.EndTime.Value;
                ////計算暫停后剩余的時間  = audEndTime（結束時間） - 當前時間
                //var nowEndTime = DateTime.Now;
                //var DifferTime = subEndTime.Subtract(nowEndTime);

                ////追加 剩余時間 和 當前結束時間；
                //mark.SurplusTime = DifferTime.ToString();
                ////mark.EndTime = nowEndTime;
                //Service.UpdateAny<MarkGoods>(mark, new List<string> { "SurplusTime" });



                ////拍賣進行中
                //var GroupName = _options.GetPKById<Options_AuctionState>("1316283839361847296").ToString();
                ////關閉該定時器
                //RemoveJob(mark.AuctionId, mark.Id, GroupName);

            }
            catch (Exception)
            {

                throw;
            }


        }

　　

倒計時恢復：

俗話說得好破鏡難圓，潑出去的水很難收回來。恢復也是這個道理，比如：倒計時走到了7暫停，那么恢復的時候如何從7繼續呢。這里就牽扯到了時間戳並且存入數據庫的介入了。

        /// <summary>
        /// 恢復倒計時
        /// </summary>
        public AjaxResult ReturnQz(string Id, string MId)
        {
            try
            {


                var mark = Service.GetIQueryable<MarkGoods>().FirstOrDefault(x => x.Id == MId);
                if (mark == null)
                    return Error();
                //獲取實際結束時間。
                if (mark.SurplusTime.IsNullOrEmpty())
                {
                    return Error();
                }
                TimeSpan.TryParse(mark.SurplusTime, out TimeSpan surplusTime);
                //方法1
                //拍賣進行中
                //拍賣進行中
                var GroupName = _options.GetPKById<Options_AuctionState>("1316283839361847296").ToString();
                var TriKey = new TriggerKey(GroupName + Id + MId + "t", GroupName);

                var Result = scheduler.GetTriggerState(TriKey).Result;
                if (Result == TriggerState.None)
                {
                    return Error("失敗：不存在此任務！");
                }
                if (Result == TriggerState.Normal)//暫停
                {
                    return Error("失敗：任務正在進行，無需恢復！");

                }
                else
                {

                    //結束時間  = 當前時間 + 剩余時間
                    var endTime = DateTime.Now.Add(surplusTime);
                    //獲取限時競價時間
                    var LimitTime = endTime.AddHours(-mark.LimitHH.Value).AddMinutes(-mark.LimitMM.Value).AddSeconds(-mark.LimitSS.Value);
                    //修改倒計時任務；
                    UpdateQz(mark.AuctionId, mark.Id, endTime, LimitTime);


                    //追加 剩余時間 和 當前結束時間；
                    mark.SurplusTime = "";
                    mark.EndTime = endTime;
                    var C1 = endTime.Subtract(DateTime.Now);
                    var C2 = endTime.Subtract(LimitTime);
                    if (C1 > C2)
                        mark.AucTimeStatus = 0;
                    else
                        mark.AucTimeStatus = 1;
                    Service.UpdateAny<MarkGoods>(mark, new List<string> { "SurplusTime", "EndTime", "AucTimeStatus" });

                    return Success();


                }








                //方法2
                //var mark = Service.GetIQueryable<MarkGoods>().FirstOrDefault(x => x.Id == MId);
                //if (mark == null)
                //    return;


                ////獲取實際結束時間。
                //if (mark.SurplusTime.IsNullOrEmpty())
                //{
                //    return;
                //}
                //TimeSpan.TryParse(mark.SurplusTime, out TimeSpan surplusTime);
                //TimeSpan a = new TimeSpan(1, 1, 1);
                ////結束時間  = 當前時間 + 剩余時間
                //var endTime = DateTime.Now.Add(surplusTime);
                ////獲取限時競價時間
                //var LimitTime = endTime.AddHours(-mark.LimitHH.Value).AddMinutes(-mark.LimitMM.Value).AddSeconds(-mark.LimitSS.Value);
                ////新增倒計時任務；
                //AddQz(mark.AuctionId, mark.Id, DateTime.Now, endTime, LimitTime);


                ////追加 剩余時間 和 當前結束時間；
                //mark.SurplusTime = "";
                //mark.EndTime = endTime;
                //Service.UpdateAny<MarkGoods>(mark, new List<string> { "SurplusTime", "EndTime" });


            }
            catch (Exception ex)
            {

                throw;
            }

        }

以上代碼均是提供思路，需要進行代碼簡單改動。