WeeklyTrigger.cs 3.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114
  1. using System;
  2. using System.Threading;
  3. using MediaBrowser.Model.Tasks;
  4. using Microsoft.Extensions.Logging;
  5. namespace Emby.Server.Implementations.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 or sets the options of this task.
  24. /// </summary>
  25. public TaskOptions TaskOptions { get; set; }
  26. /// <summary>
  27. /// Gets or sets the timer.
  28. /// </summary>
  29. /// <value>The timer.</value>
  30. private Timer Timer { get; set; }
  31. /// <summary>
  32. /// Stars waiting for the trigger action.
  33. /// </summary>
  34. /// <param name="lastResult">The last result.</param>
  35. /// <param name="logger">The logger.</param>
  36. /// <param name="taskName">The name of the task.</param>
  37. /// <param name="isApplicationStartup">if set to <c>true</c> [is application startup].</param>
  38. public void Start(TaskResult lastResult, ILogger logger, string taskName, bool isApplicationStartup)
  39. {
  40. DisposeTimer();
  41. var triggerDate = GetNextTriggerDateTime();
  42. Timer = new Timer(state => OnTriggered(), null, triggerDate - DateTime.Now, TimeSpan.FromMilliseconds(-1));
  43. }
  44. /// <summary>
  45. /// Gets the next trigger date time.
  46. /// </summary>
  47. /// <returns>DateTime.</returns>
  48. private DateTime GetNextTriggerDateTime()
  49. {
  50. var now = DateTime.Now;
  51. // If it's on the same day
  52. if (now.DayOfWeek == DayOfWeek)
  53. {
  54. // It's either later today, or a week from now
  55. return now.TimeOfDay < TimeOfDay ? now.Date.Add(TimeOfDay) : now.Date.AddDays(7).Add(TimeOfDay);
  56. }
  57. var triggerDate = now.Date;
  58. // Walk the date forward until we get to the trigger day
  59. while (triggerDate.DayOfWeek != DayOfWeek)
  60. {
  61. triggerDate = triggerDate.AddDays(1);
  62. }
  63. // Return the trigger date plus the time offset
  64. return triggerDate.Add(TimeOfDay);
  65. }
  66. /// <summary>
  67. /// Stops waiting for the trigger action.
  68. /// </summary>
  69. public void Stop()
  70. {
  71. DisposeTimer();
  72. }
  73. /// <summary>
  74. /// Disposes the timer.
  75. /// </summary>
  76. private void DisposeTimer()
  77. {
  78. if (Timer != null)
  79. {
  80. Timer.Dispose();
  81. }
  82. }
  83. /// <summary>
  84. /// Occurs when [triggered].
  85. /// </summary>
  86. public event EventHandler<EventArgs> Triggered;
  87. /// <summary>
  88. /// Called when [triggered].
  89. /// </summary>
  90. private void OnTriggered()
  91. {
  92. if (Triggered != null)
  93. {
  94. Triggered(this, EventArgs.Empty);
  95. }
  96. }
  97. }
  98. }