123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405 |
- using System;
- using System.Collections.Generic;
- using System.IO;
- using System.Linq;
- using System.Linq.Expressions;
- using InABox.Core;
- namespace Comal.Classes
- {
- public enum SchedulePeriod
- {
- Minute,
- Hour,
- Day,
- Week,
- Month,
- Year
- }
- public enum ScheduleTrigger
- {
- Distance,
- Usage,
- Counter1,
- Counter2,
- Counter3,
- Counter4,
- Counter5
- }
- public enum ScheduleRollover
- {
- FromDueDate,
- FromActualDate
- }
- public enum ScheduleType
- {
- None,
- Job,
- Task
- }
- public class ScheduleOffset : BaseObject, IPackable
- {
- public ScheduleOffset()
- {
- }
- public ScheduleOffset(int offset, SchedulePeriod period)
- {
- Period = period;
- Offset = offset;
- }
- [EnumLookupEditor(typeof(SchedulePeriod), Visible = Visible.Default)]
- [EditorSequence(1)]
- public SchedulePeriod Period { get; set; }
- [IntegerEditor(Visible = Visible.Default)]
- [EditorSequence(2)]
- public int Offset { get; set; }
- public void Pack(BinaryWriter writer)
- {
- writer.Write((int)Period);
- writer.Write(Offset);
- }
- public void Unpack(BinaryReader reader)
- {
- Period = (SchedulePeriod)reader.ReadInt32();
- Offset = reader.ReadInt32();
- }
- }
- public class ScheduleOffsetList : PackableList<ScheduleOffset>
- {
- }
- public class ScheduleLink : EntityLink<Schedule>
- {
- [NullEditor]
- public override Guid ID { get; set; }
- [TextBoxEditor(Editable = Editable.Hidden)]
- public string Title { get; set; }
- [EnumLookupEditor(typeof(ScheduleRollover), Editable = Editable.Hidden)]
- public ScheduleRollover Rollover { get; set; }
- }
- public class NextScheduleDue : CoreAggregate<Entity, Schedule, DateTime>
- {
- public override Expression<Func<Schedule, DateTime>> Aggregate => x => x.DueDate;
- public override AggregateCalculation Calculation => AggregateCalculation.Minimum;
- public override Filter<Schedule> Filter => new Filter<Schedule>(x => x.IncludeInAggregate).IsEqualTo(true);
- public override Dictionary<Expression<Func<Schedule, object>>, Expression<Func<Entity, object>>> Links =>
- new Dictionary<Expression<Func<Schedule, object>>, Expression<Func<Entity, object>>>()
- {
- { Schedule => Schedule.DocumentID, Entity => Entity.ID }
- };
- }
- public class ActiveSchedules : CoreAggregate<Entity, Schedule, Guid>
- {
- public override Expression<Func<Schedule, Guid>> Aggregate => x => x.ID;
- public override AggregateCalculation Calculation => AggregateCalculation.Count;
- public override Dictionary<Expression<Func<Schedule, object>>, Expression<Func<Entity, object>>> Links =>
- new Dictionary<Expression<Func<Schedule, object>>, Expression<Func<Entity, object>>>()
- {
- { Schedule => Schedule.DocumentID, Entity => Entity.ID }
- };
- }
- [UserTracking("Task Scheduler")]
- public class Schedule : Entity, IPersistent, IRemotable, IOneToMany<Employee>, ILicense<ScheduleEngineLicense>
- {
- #region Constructors
- //public Schedule() : base()
- //{
- //}
- protected override void Init()
- {
- base.Init();
- ScheduleType = ScheduleType.Task;
- KanbanType = new KanbanTypeLink();
- Offsets = new ScheduleOffsetList();
- DueDate = DateTime.Today.AddDays(1);
- Frequency = 1;
- Period = SchedulePeriod.Month;
- Report = new DocumentLink();
- EmployeeLink = new EmployeeLink();
- ManagerLink = new EmployeeLink();
- IncludeInAggregate = true;
- }
- // Second Tuesday of Every Month
- //new ScheduleItem(1, SchedulePeriod.Month, new ScheduleOffset(1, SchedulePeriod.Week), new ScheduleOffset(2, SchedulePeriod.Day));
- // Ten minutes after the every hour
- //new ScheduleItem(1, SchedulePeriod.Hour, new ScheduleOffset(10, SchedulePeriod.Minute));
- //public Schedule(int frequency, SchedulePeriod period, params ScheduleOffset[] offsets) : base()
- //{
- // ID = Guid.NewGuid();
- // Frequency = frequency;
- // Period = period;
- // Offsets = offsets.ToList();
- //}
- #endregion
- #region Private Fields
- private DateTime _EndDate = DateTime.MinValue;
- private uint _Iterations = 0;
- #endregion
- #region Public Properties
- [NullEditor]
- public string DocumentClass { get; set; }
- //[NullEditor]
- //[DoNotSerialize]
- public Type DocumentType()
- {
- try
- {
- return CoreUtils.GetEntityOrNull(DocumentClass);
- }
- catch
- {
- return null;
- }
- }
- [NullEditor]
- public Guid DocumentID { get; set; }
- [TextBoxEditor]
- [EditorSequence(0)]
- public string Title { get; set; }
- [MemoEditor]
- [EditorSequence(1)]
- public string Description { get; set; }
- // Date Based Scheduling
- [IntegerEditor]
- [EditorSequence(2)]
- [Caption("Schedule Frequency")]
- public int Frequency { get; set; }
- [EnumLookupEditor(typeof(SchedulePeriod))]
- [EditorSequence(3)]
- [Caption("Schedule Type")]
- public SchedulePeriod Period { get; set; }
- [DateTimeEditor]
- [EditorSequence(4)]
- [Caption("Schedule Due")]
- public DateTime DueDate { get; set; }
- // Trigger-Based Scheduling
- [IntegerEditor]
- [EditorSequence(5)]
- [Caption("Trigger Frequency")]
- public int Threshold { get; set; }
- [EnumLookupEditor(typeof(ScheduleTrigger))]
- [Caption("Trigger Type")]
- [EditorSequence(6)]
- public ScheduleTrigger Trigger { get; set; }
- [IntegerEditor]
- [EditorSequence(7)]
- [Caption("Trigger Level")]
- public int DueThreshold { get; set; }
- [EnumLookupEditor(typeof(ScheduleType))]
- [EditorSequence(8)]
- [Caption("Scheduled Action")]
- public ScheduleType ScheduleType { get; set; }
- //[LookupEditor(typeof(KanbanType))]
- [EditorSequence(9)]
- [Caption("Task Type")]
- public KanbanTypeLink KanbanType { get; set; }
- [IntegerEditor]
- [EditorSequence(10)]
- [Caption("Lead Time")]
- public int LeadTime { get; set; }
- public ScheduleOffsetList Offsets { get; set; }
- [Caption("Assigned To")]
- [EditorSequence(11)]
- public EmployeeLink EmployeeLink { get; set; }
- [Caption("Managed By")]
- [EditorSequence(12)]
- public EmployeeLink ManagerLink { get; set; }
- [Caption("Report Type")]
- [EditorSequence(13)]
- public DocumentLink Report { get; set; }
- [EnumLookupEditor(typeof(ScheduleRollover))]
- [EditorSequence(14)]
- public ScheduleRollover Rollover { get; set; }
- [TimestampEditor(Editable = Editable.Hidden)]
- public DateTime Completed { get; set; }
- [NullEditor]
- public bool Active { get; set; }
- [CheckBoxEditor]
- [EditorSequence(15)]
- public bool IncludeInAggregate { get; set; }
- #endregion
- #region Public Methods
- private DateTime ApplyPeriod(DateTime date)
- {
- var result = date;
- switch (Period)
- {
- case SchedulePeriod.Year:
- return date.AddYears(Frequency);
- case SchedulePeriod.Month:
- return date.AddMonths(Frequency);
- case SchedulePeriod.Week:
- return date.AddDays(7 * Frequency);
- case SchedulePeriod.Day:
- return date.AddDays(Frequency);
- case SchedulePeriod.Hour:
- return date.AddHours(Frequency);
- case SchedulePeriod.Minute:
- return date.AddMinutes(Frequency);
- }
- return result;
- }
- private DateTime ApplyOffsets(DateTime date, int index)
- {
- if (index >= Offsets.Count)
- return date;
- var offset = Offsets[index];
- var result = date;
- var skip = 1;
- switch (offset.Period)
- {
- case SchedulePeriod.Year:
- result = date.AddYears(offset.Offset);
- break;
- case SchedulePeriod.Month:
- result = date.AddMonths(offset.Offset);
- break;
- case SchedulePeriod.Week:
- // First Lets get to the start of the month
- var startOfMonth = date.Date.AddDays(1 - date.Day);
- // Calculate the DOW for the start of the month
- var dow = (int)startOfMonth.DayOfWeek;
- // If the next offset is a day-type
- var tgtdow = 0;
- if (index < Offsets.Count - 1)
- {
- skip++;
- if (Offsets[index + 1].Period == SchedulePeriod.Day)
- tgtdow = Offsets[index + 1].Offset;
- else if (Offsets[index + 1].Period == SchedulePeriod.Hour)
- tgtdow = Offsets[index + 1].Offset / 24;
- else if (Offsets[index + 1].Period == SchedulePeriod.Minute)
- tgtdow = Offsets[index + 1].Offset / (24 * 60);
- else
- skip--;
- }
- result = startOfMonth.AddDays(0 - dow).AddDays(tgtdow);
- if (dow > tgtdow)
- result = result.AddDays(7);
- result = result.AddDays(Offsets[index].Offset * 7);
- break;
- case SchedulePeriod.Day:
- result = date.AddDays(offset.Offset);
- break;
- case SchedulePeriod.Hour:
- result = date.AddHours(offset.Offset);
- break;
- case SchedulePeriod.Minute:
- result = date.AddMinutes(offset.Offset);
- break;
- }
- return ApplyOffsets(result, index + skip);
- }
- public DateTime GetNextDate(DateTime last)
- {
- // if this is the first time run, then
- // just return the due date
- if (last.IsEmpty())
- return DueDate;
- // Get the base date for the next scheduled run
- var result = Rollover.Equals(ScheduleRollover.FromDueDate) ? DueDate : last;
- // Roll it forward to the next due date
- result = ApplyPeriod(result);
- // Apply any offsets we need
- if (Offsets != null && Offsets.Any())
- result = ApplyOffsets(result, 0);
- return result;
- }
- #endregion
- }
- public interface ISchedulable
- {
- //bool ScheduleEnabled { get; set; }
- [NullEditor]
- int ActiveSchedules { get; set; }
- }
- public interface IScheduleAction
- {
- DateTime Completed { get; set; }
- ScheduleLink ScheduleLink { get; set; }
- }
- }
|