WeeklyTrigger.cs 3.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115
  1. using System;
  2. using System.Threading;
  3. using MediaBrowser.Model.Events;
  4. using MediaBrowser.Model.Tasks;
  5. namespace MediaBrowser.Common.ScheduledTasks
  6. {
  7. /// <summary>
  8. /// Represents a task trigger that fires on a weekly basis
  9. /// </summary>
  10. public class WeeklyTrigger : ITaskTrigger
  11. {
  12. /// <summary>
  13. /// Get the time of day to trigger the task to run
  14. /// </summary>
  15. /// <value>The time of day.</value>
  16. public TimeSpan TimeOfDay { get; set; }
  17. /// <summary>
  18. /// Gets or sets the day of week.
  19. /// </summary>
  20. /// <value>The day of week.</value>
  21. public DayOfWeek DayOfWeek { get; set; }
  22. /// <summary>
  23. /// Gets the execution properties of this task.
  24. /// </summary>
  25. /// <value>
  26. /// The execution properties of this task.
  27. /// </value>
  28. public TaskExecutionOptions TaskOptions { get; set; }
  29. /// <summary>
  30. /// Gets or sets the timer.
  31. /// </summary>
  32. /// <value>The timer.</value>
  33. private Timer Timer { get; set; }
  34. /// <summary>
  35. /// Stars waiting for the trigger action
  36. /// </summary>
  37. /// <param name="lastResult">The last result.</param>
  38. /// <param name="isApplicationStartup">if set to <c>true</c> [is application startup].</param>
  39. public void Start(TaskResult lastResult, bool isApplicationStartup)
  40. {
  41. DisposeTimer();
  42. var triggerDate = GetNextTriggerDateTime();
  43. Timer = new Timer(state => OnTriggered(), null, triggerDate - DateTime.Now, TimeSpan.FromMilliseconds(-1));
  44. }
  45. /// <summary>
  46. /// Gets the next trigger date time.
  47. /// </summary>
  48. /// <returns>DateTime.</returns>
  49. private DateTime GetNextTriggerDateTime()
  50. {
  51. var now = DateTime.Now;
  52. // If it's on the same day
  53. if (now.DayOfWeek == DayOfWeek)
  54. {
  55. // It's either later today, or a week from now
  56. return now.TimeOfDay < TimeOfDay ? now.Date.Add(TimeOfDay) : now.Date.AddDays(7).Add(TimeOfDay);
  57. }
  58. var triggerDate = now.Date;
  59. // Walk the date forward until we get to the trigger day
  60. while (triggerDate.DayOfWeek != DayOfWeek)
  61. {
  62. triggerDate = triggerDate.AddDays(1);
  63. }
  64. // Return the trigger date plus the time offset
  65. return triggerDate.Add(TimeOfDay);
  66. }
  67. /// <summary>
  68. /// Stops waiting for the trigger action
  69. /// </summary>
  70. public void Stop()
  71. {
  72. DisposeTimer();
  73. }
  74. /// <summary>
  75. /// Disposes the timer.
  76. /// </summary>
  77. private void DisposeTimer()
  78. {
  79. if (Timer != null)
  80. {
  81. Timer.Dispose();
  82. }
  83. }
  84. /// <summary>
  85. /// Occurs when [triggered].
  86. /// </summary>
  87. public event EventHandler<GenericEventArgs<TaskExecutionOptions>> Triggered;
  88. /// <summary>
  89. /// Called when [triggered].
  90. /// </summary>
  91. private void OnTriggered()
  92. {
  93. if (Triggered != null)
  94. {
  95. Triggered(this, new GenericEventArgs<TaskExecutionOptions>(TaskOptions));
  96. }
  97. }
  98. }
  99. }