欢迎光临
我的个人博客网站

c# Quartzs定时器的简单使用

使用背景:

    首先想到倒计时,定时任务。大家想到的肯定就是定时器。那么定时器在web和winfrom程序中有着很大的作用。那在服务器端有没有像定时器一样的存在呢。

有了这些需求,我找到了第三方的组件 Quartz.Net 来实现(源码位置:https://github.com/quartznet/quartznet)

(1)第一步,通过NuGet下载Quartz.Net组件并且引用到当前工程中c# Quartzs定时器的简单使用

 

 

 

 

(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;             }          }

以上代码均是提供思路,需要进行代码简单改动。

赞(0) 打赏
未经允许不得转载:张拓的天空 » c# Quartzs定时器的简单使用
分享到: 更多 (0)

评论 抢沙发

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址

专业的IT技术经验分享 更专业 更方便

联系我们本站主机

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

微信扫一扫打赏