Blame view

netcore/src/Infrastructure/NCC/TaskScheduler/Attributes/SpareTimeAttribute.cs 2.71 KB
de2bd2f9   “wangming”   项目初始化
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
  using NCC.Dependency;
  using NCC.Templates.Extensions;
  using System;
  
  namespace NCC.TaskScheduler
  {
      /// <summary>
      /// 配置定时任务特性
      /// </summary>
      [SuppressSniffer, AttributeUsage(AttributeTargets.Method, AllowMultiple = true)]
      public class SpareTimeAttribute : Attribute
      {
          /// <summary>
          /// 构造函数
          /// </summary>
          /// <param name="interval"></param>
          /// <param name="workerName"></param>
          public SpareTimeAttribute(double interval, string workerName = default)
          {
              Interval = interval;
              Type = SpareTimeTypes.Interval;
              WorkerName = workerName;
          }
  
          /// <summary>
          /// 构造函数
          /// </summary>
          /// <param name="expressionOrKey">表达式或配置Key</param>
          /// <param name="workName"></param>
          public SpareTimeAttribute(string expressionOrKey, string workName = default)
          {
              // 支持从配置文件读取
              var realValue = expressionOrKey.Render();
  
              // 如果能够转换成整型,则采用间隔,间隔时间必须大于 0
              if (long.TryParse(realValue, out var interval) && interval > 0)
              {
                  Interval = interval;
                  Type = SpareTimeTypes.Interval;
              }
              // 否则当作 Cron 表达式
              else
              {
                  CronExpression = realValue;
                  Type = SpareTimeTypes.Cron;
              }
  
              WorkerName = workName;
          }
  
          /// <summary>
          /// 间隔
          /// </summary>
          public double Interval { get; private set; }
  
          /// <summary>
          /// Cron 表达式
          /// </summary>
          public string CronExpression { get; private set; }
  
          /// <summary>
          /// 任务名称
          /// </summary>
          public string WorkerName { get; private set; }
  
          /// <summary>
          /// 任务类型
          /// </summary>
          internal SpareTimeTypes Type { get; private set; }
  
          /// <summary>
          /// 任务描述
          /// </summary>
          public string Description { get; set; }
  
          /// <summary>
          /// 只执行一次
          /// </summary>
          public bool DoOnce { get; set; } = false;
  
          /// <summary>
          /// 立即执行(默认等待启动)
          /// </summary>
          public bool StartNow { get; set; } = false;
  
          /// <summary>
          /// 执行类型
          /// </summary>
          public SpareTimeExecuteTypes ExecuteType { get; set; } = SpareTimeExecuteTypes.Parallel;
  
          /// <summary>
          /// Cron 表达式格式化方式
          /// </summary>
          public object CronFormat { get; set; }
      }
  }