WeeklyTrigger.cs 3.2 KB

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