NewLife
/
AntJob
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

优化字段注释

This commit is contained in:
大石头 2021-04-29 09:03:35 +08:00
parent 77955b82fc
commit 3c4aa45766
6 changed files with 114 additions and 112 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

72
AntJob.Data/Entity/作业.cs
View File

@ -84,19 +84,19 @@ namespace AntJob.Data.Entity
public Int32 MessageCount { get => _MessageCount; set { if (OnPropertyChanging("MessageCount", value)) { _MessageCount = value; OnPropertyChanged("MessageCount"); } } }
private DateTime _Start;
/// <summary>开始。大于等于，下一个任务的起点</summary>
/// <summary>开始。大于等于，定时调度到达该时间点后触发（可能有偏移量），消息调度不适用</summary>
[DisplayName("开始")]
[Description("开始。大于等于，下一个任务的起点")]
[Description("开始。大于等于，定时调度到达该时间点后触发（可能有偏移量），消息调度不适用")]
[DataObjectField(false, false, true, 0)]
[BindColumn("Start", "开始。大于等于，下一个任务的起点", "")]
[BindColumn("Start", "开始。大于等于，定时调度到达该时间点后触发（可能有偏移量），消息调度不适用", "")]
public DateTime Start { get => _Start; set { if (OnPropertyChanging("Start", value)) { _Start = value; OnPropertyChanged("Start"); } } }
private DateTime _End;
/// <summary>结束。小于不等于，默认空表示无止境</summary>
/// <summary>结束。小于不等于，数据调度到达该时间点后触发（可能有偏移量），默认空表示无止境，消息调度不适用</summary>
[DisplayName("结束")]
[Description("结束。小于不等于，默认空表示无止境")]
[Description("结束。小于不等于，数据调度到达该时间点后触发（可能有偏移量），默认空表示无止境，消息调度不适用")]
[DataObjectField(false, false, true, 0)]
[BindColumn("End", "结束。小于不等于，默认空表示无止境", "")]
[BindColumn("End", "结束。小于不等于，数据调度到达该时间点后触发（可能有偏移量），默认空表示无止境，消息调度不适用", "")]
public DateTime End { get => _End; set { if (OnPropertyChanging("End", value)) { _End = value; OnPropertyChanged("End"); } } }
private Int32 _Step;
@ -108,27 +108,27 @@ namespace AntJob.Data.Entity
public Int32 Step { get => _Step; set { if (OnPropertyChanging("Step", value)) { _Step = value; OnPropertyChanged("Step"); } } }
private Int32 _BatchSize;
/// <summary>批大小。在任务时间区间内分页处理，或者每个任务的消息数</summary>
/// <summary>批大小。数据调度每次抽取数据的分页大小，或消息调度每次处理的消息数，定时调度不适用</summary>
[DisplayName("批大小")]
[Description("批大小。在任务时间区间内分页处理，或者每个任务的消息数")]
[Description("批大小。数据调度每次抽取数据的分页大小，或消息调度每次处理的消息数，定时调度不适用")]
[DataObjectField(false, false, false, 0)]
[BindColumn("BatchSize", "批大小。在任务时间区间内分页处理，或者每个任务的消息数", "")]
[BindColumn("BatchSize", "批大小。数据调度每次抽取数据的分页大小，或消息调度每次处理的消息数，定时调度不适用", "")]
public Int32 BatchSize { get => _BatchSize; set { if (OnPropertyChanging("BatchSize", value)) { _BatchSize = value; OnPropertyChanged("BatchSize"); } } }
private Int32 _Offset;
/// <summary>偏移。距离实时时间的秒数，部分业务不能跑到实时，秒</summary>
/// <summary>偏移。距离AntServer当前时间的秒数，避免因服务器之间的时间误差而错过部分数据，秒</summary>
[DisplayName("偏移")]
[Description("偏移。距离实时时间的秒数，部分业务不能跑到实时，秒")]
[Description("偏移。距离AntServer当前时间的秒数，避免因服务器之间的时间误差而错过部分数据，秒")]
[DataObjectField(false, false, false, 0)]
[BindColumn("Offset", "偏移。距离实时时间的秒数，部分业务不能跑到实时，秒", "")]
[BindColumn("Offset", "偏移。距离AntServer当前时间的秒数，避免因服务器之间的时间误差而错过部分数据，秒", "")]
public Int32 Offset { get => _Offset; set { if (OnPropertyChanging("Offset", value)) { _Offset = value; OnPropertyChanged("Offset"); } } }
private Int32 _MaxTask;
/// <summary>并行。多任务并行处理</summary>
[DisplayName("并行")]
[Description("并行。多任务并行处理")]
/// <summary>并行度。一共允许多少个任务并行处理，多执行端时平均分配，确保该作业整体并行度</summary>
[DisplayName("并行度")]
[Description("并行度。一共允许多少个任务并行处理，多执行端时平均分配，确保该作业整体并行度")]
[DataObjectField(false, false, false, 0)]
[BindColumn("MaxTask", "并行。多任务并行处理", "")]
[BindColumn("MaxTask", "并行度。一共允许多少个任务并行处理，多执行端时平均分配，确保该作业整体并行度", "")]
public Int32 MaxTask { get => _MaxTask; set { if (OnPropertyChanging("MaxTask", value)) { _MaxTask = value; OnPropertyChanged("MaxTask"); } } }
private Int32 _MaxError;
@ -180,19 +180,19 @@ namespace AntJob.Data.Entity
public Int32 ErrorDelay { get => _ErrorDelay; set { if (OnPropertyChanging("ErrorDelay", value)) { _ErrorDelay = value; OnPropertyChanged("ErrorDelay"); } } }
private Int64 _Total;
/// <summary>总数</summary>
/// <summary>总数。任务处理的总数据，例如数据调度抽取得到的总行数，定时调度默认1</summary>
[DisplayName("总数")]
[Description("总数")]
[Description("总数。任务处理的总数据，例如数据调度抽取得到的总行数，定时调度默认1")]
[DataObjectField(false, false, false, 0)]
[BindColumn("Total", "总数", "")]
[BindColumn("Total", "总数。任务处理的总数据，例如数据调度抽取得到的总行数，定时调度默认1", "")]
public Int64 Total { get => _Total; set { if (OnPropertyChanging("Total", value)) { _Total = value; OnPropertyChanged("Total"); } } }
private Int64 _Success;
/// <summary>成功</summary>
/// <summary>成功。成功处理的数据，取自于Handler.Execute返回值，或者ProcessItem返回true的个数</summary>
[DisplayName("成功")]
[Description("成功")]
[Description("成功。成功处理的数据，取自于Handler.Execute返回值，或者ProcessItem返回true的个数")]
[DataObjectField(false, false, false, 0)]
[BindColumn("Success", "成功", "")]
[BindColumn("Success", "成功。成功处理的数据，取自于Handler.Execute返回值，或者ProcessItem返回true的个数", "")]
public Int64 Success { get => _Success; set { if (OnPropertyChanging("Success", value)) { _Success = value; OnPropertyChanged("Success"); } } }
private Int32 _Error;
@ -431,22 +431,22 @@ namespace AntJob.Data.Entity
/// <summary>消息数</summary>
public static readonly Field MessageCount = FindByName("MessageCount");
/// <summary>开始。大于等于，下一个任务的起点</summary>
/// <summary>开始。大于等于，定时调度到达该时间点后触发（可能有偏移量），消息调度不适用</summary>
public static readonly Field Start = FindByName("Start");
/// <summary>结束。小于不等于，默认空表示无止境</summary>
/// <summary>结束。小于不等于，数据调度到达该时间点后触发（可能有偏移量），默认空表示无止境，消息调度不适用</summary>
public static readonly Field End = FindByName("End");
/// <summary>步进。切分任务的时间区间，秒</summary>
public static readonly Field Step = FindByName("Step");
/// <summary>批大小。在任务时间区间内分页处理，或者每个任务的消息数</summary>
/// <summary>批大小。数据调度每次抽取数据的分页大小，或消息调度每次处理的消息数，定时调度不适用</summary>
public static readonly Field BatchSize = FindByName("BatchSize");
/// <summary>偏移。距离实时时间的秒数，部分业务不能跑到实时，秒</summary>
/// <summary>偏移。距离AntServer当前时间的秒数，避免因服务器之间的时间误差而错过部分数据，秒</summary>
public static readonly Field Offset = FindByName("Offset");
/// <summary>并行。多任务并行处理</summary>
/// <summary>并行度。一共允许多少个任务并行处理，多执行端时平均分配，确保该作业整体并行度</summary>
public static readonly Field MaxTask = FindByName("MaxTask");
/// <summary>最大错误。连续错误达到最大错误数时停止</summary>
@ -467,10 +467,10 @@ namespace AntJob.Data.Entity
/// <summary>错误延迟。默认60秒，出错延迟后重新发放</summary>
public static readonly Field ErrorDelay = FindByName("ErrorDelay");
/// <summary>总数</summary>
/// <summary>总数。任务处理的总数据，例如数据调度抽取得到的总行数，定时调度默认1</summary>
public static readonly Field Total = FindByName("Total");
/// <summary>成功</summary>
/// <summary>成功。成功处理的数据，取自于Handler.Execute返回值，或者ProcessItem返回true的个数</summary>
public static readonly Field Success = FindByName("Success");
/// <summary>错误</summary>
@ -545,22 +545,22 @@ namespace AntJob.Data.Entity
/// <summary>消息数</summary>
public const String MessageCount = "MessageCount";
/// <summary>开始。大于等于，下一个任务的起点</summary>
/// <summary>开始。大于等于，定时调度到达该时间点后触发（可能有偏移量），消息调度不适用</summary>
public const String Start = "Start";
/// <summary>结束。小于不等于，默认空表示无止境</summary>
/// <summary>结束。小于不等于，数据调度到达该时间点后触发（可能有偏移量），默认空表示无止境，消息调度不适用</summary>
public const String End = "End";
/// <summary>步进。切分任务的时间区间，秒</summary>
public const String Step = "Step";
/// <summary>批大小。在任务时间区间内分页处理，或者每个任务的消息数</summary>
/// <summary>批大小。数据调度每次抽取数据的分页大小，或消息调度每次处理的消息数，定时调度不适用</summary>
public const String BatchSize = "BatchSize";
/// <summary>偏移。距离实时时间的秒数，部分业务不能跑到实时，秒</summary>
/// <summary>偏移。距离AntServer当前时间的秒数，避免因服务器之间的时间误差而错过部分数据，秒</summary>
public const String Offset = "Offset";
/// <summary>并行。多任务并行处理</summary>
/// <summary>并行度。一共允许多少个任务并行处理，多执行端时平均分配，确保该作业整体并行度</summary>
public const String MaxTask = "MaxTask";
/// <summary>最大错误。连续错误达到最大错误数时停止</summary>
@ -581,10 +581,10 @@ namespace AntJob.Data.Entity
/// <summary>错误延迟。默认60秒，出错延迟后重新发放</summary>
public const String ErrorDelay = "ErrorDelay";
/// <summary>总数</summary>
/// <summary>总数。任务处理的总数据，例如数据调度抽取得到的总行数，定时调度默认1</summary>
public const String Total = "Total";
/// <summary>成功</summary>
/// <summary>成功。成功处理的数据，取自于Handler.Execute返回值，或者ProcessItem返回true的个数</summary>
public const String Success = "Success";
/// <summary>错误</summary>

90
AntJob.Data/Entity/作业任务.cs
View File

@ -54,43 +54,43 @@ namespace AntJob.Data.Entity
public String Client { get => _Client; set { if (OnPropertyChanging("Client", value)) { _Client = value; OnPropertyChanged("Client"); } } }
private DateTime _Start;
/// <summary>开始。大于等于</summary>
/// <summary>开始。大于等于，定时调度到达该时间点后触发（可能有偏移量），消息调度不适用</summary>
[DisplayName("开始")]
[Description("开始。大于等于")]
[Description("开始。大于等于，定时调度到达该时间点后触发（可能有偏移量），消息调度不适用")]
[DataObjectField(false, false, true, 0)]
[BindColumn("Start", "开始。大于等于", "")]
[BindColumn("Start", "开始。大于等于，定时调度到达该时间点后触发（可能有偏移量），消息调度不适用", "")]
public DateTime Start { get => _Start; set { if (OnPropertyChanging("Start", value)) { _Start = value; OnPropertyChanged("Start"); } } }
private DateTime _End;
/// <summary>结束。小于，不等于</summary>
/// <summary>结束。小于不等于，数据调度到达该时间点后触发（可能有偏移量），消息调度不适用</summary>
[DisplayName("结束")]
[Description("结束。小于，不等于")]
[Description("结束。小于不等于，数据调度到达该时间点后触发（可能有偏移量），消息调度不适用")]
[DataObjectField(false, false, true, 0)]
[BindColumn("End", "结束。小于，不等于", "")]
[BindColumn("End", "结束。小于不等于，数据调度到达该时间点后触发（可能有偏移量），消息调度不适用", "")]
public DateTime End { get => _End; set { if (OnPropertyChanging("End", value)) { _End = value; OnPropertyChanged("End"); } } }
private Int32 _BatchSize;
/// <summary>批大小</summary>
/// <summary>批大小。数据调度每次抽取数据的分页大小，或消息调度每次处理的消息数，定时调度不适用</summary>
[DisplayName("批大小")]
[Description("批大小")]
[Description("批大小。数据调度每次抽取数据的分页大小，或消息调度每次处理的消息数，定时调度不适用")]
[DataObjectField(false, false, false, 0)]
[BindColumn("BatchSize", "批大小", "")]
[BindColumn("BatchSize", "批大小。数据调度每次抽取数据的分页大小，或消息调度每次处理的消息数，定时调度不适用", "")]
public Int32 BatchSize { get => _BatchSize; set { if (OnPropertyChanging("BatchSize", value)) { _BatchSize = value; OnPropertyChanged("BatchSize"); } } }
private Int32 _Total;
/// <summary>总数</summary>
/// <summary>总数。任务处理的总数据，例如数据调度抽取得到的总行数，定时调度默认1</summary>
[DisplayName("总数")]
[Description("总数")]
[Description("总数。任务处理的总数据，例如数据调度抽取得到的总行数，定时调度默认1")]
[DataObjectField(false, false, false, 0)]
[BindColumn("Total", "总数", "")]
[BindColumn("Total", "总数。任务处理的总数据，例如数据调度抽取得到的总行数，定时调度默认1", "")]
public Int32 Total { get => _Total; set { if (OnPropertyChanging("Total", value)) { _Total = value; OnPropertyChanged("Total"); } } }
private Int32 _Success;
/// <summary>成功</summary>
/// <summary>成功。成功处理的数据，取自于Handler.Execute返回值，或者ProcessItem返回true的个数</summary>
[DisplayName("成功")]
[Description("成功")]
[Description("成功。成功处理的数据，取自于Handler.Execute返回值，或者ProcessItem返回true的个数")]
[DataObjectField(false, false, false, 0)]
[BindColumn("Success", "成功", "")]
[BindColumn("Success", "成功。成功处理的数据，取自于Handler.Execute返回值，或者ProcessItem返回true的个数", "")]
public Int32 Success { get => _Success; set { if (OnPropertyChanging("Success", value)) { _Success = value; OnPropertyChanged("Success"); } } }
private Int32 _Error;
@ -110,19 +110,19 @@ namespace AntJob.Data.Entity
public Int32 Times { get => _Times; set { if (OnPropertyChanging("Times", value)) { _Times = value; OnPropertyChanged("Times"); } } }
private Int32 _Speed;
/// <summary>速度</summary>
/// <summary>速度。每秒处理数，执行端计算</summary>
[DisplayName("速度")]
[Description("速度")]
[Description("速度。每秒处理数，执行端计算")]
[DataObjectField(false, false, false, 0)]
[BindColumn("Speed", "速度", "")]
[BindColumn("Speed", "速度。每秒处理数，执行端计算", "")]
public Int32 Speed { get => _Speed; set { if (OnPropertyChanging("Speed", value)) { _Speed = value; OnPropertyChanged("Speed"); } } }
private Int32 _Cost;
/// <summary>耗时。秒</summary>
/// <summary>耗时。秒，执行端计算的执行时间</summary>
[DisplayName("耗时")]
[Description("耗时。秒")]
[Description("耗时。秒，执行端计算的执行时间")]
[DataObjectField(false, false, false, 0)]
[BindColumn("Cost", "耗时。秒", "")]
[BindColumn("Cost", "耗时。秒，执行端计算的执行时间", "")]
public Int32 Cost { get => _Cost; set { if (OnPropertyChanging("Cost", value)) { _Cost = value; OnPropertyChanged("Cost"); } } }
private Int32 _FullCost;
@ -166,11 +166,11 @@ namespace AntJob.Data.Entity
public Int32 ProcessID { get => _ProcessID; set { if (OnPropertyChanging("ProcessID", value)) { _ProcessID = value; OnPropertyChanged("ProcessID"); } } }
private String _Key;
/// <summary>最后键</summary>
/// <summary>最后键。Handler内记录作为样本的数据</summary>
[DisplayName("最后键")]
[Description("最后键")]
[Description("最后键。Handler内记录作为样本的数据")]
[DataObjectField(false, false, true, 50)]
[BindColumn("Key", "最后键", "")]
[BindColumn("Key", "最后键。Handler内记录作为样本的数据", "")]
public String Key { get => _Key; set { if (OnPropertyChanging("Key", value)) { _Key = value; OnPropertyChanged("Key"); } } }
private String _Data;
@ -182,11 +182,11 @@ namespace AntJob.Data.Entity
public String Data { get => _Data; set { if (OnPropertyChanging("Data", value)) { _Data = value; OnPropertyChanged("Data"); } } }
private String _Message;
/// <summary>消息内容。异常信息或其它任务消息</summary>
/// <summary>消息内容。Handler内记录的异常信息或其它任务消息</summary>
[DisplayName("消息内容")]
[Description("消息内容。异常信息或其它任务消息")]
[Description("消息内容。Handler内记录的异常信息或其它任务消息")]
[DataObjectField(false, false, true, -1)]
[BindColumn("Message", "消息内容。异常信息或其它任务消息", "")]
[BindColumn("Message", "消息内容。Handler内记录的异常信息或其它任务消息", "")]
public String Message { get => _Message; set { if (OnPropertyChanging("Message", value)) { _Message = value; OnPropertyChanged("Message"); } } }
private DateTime _CreateTime;
@ -291,19 +291,19 @@ namespace AntJob.Data.Entity
/// <summary>客户端。IP加进程</summary>
public static readonly Field Client = FindByName("Client");
/// <summary>开始。大于等于</summary>
/// <summary>开始。大于等于，定时调度到达该时间点后触发（可能有偏移量），消息调度不适用</summary>
public static readonly Field Start = FindByName("Start");
/// <summary>结束。小于，不等于</summary>
/// <summary>结束。小于不等于，数据调度到达该时间点后触发（可能有偏移量），消息调度不适用</summary>
public static readonly Field End = FindByName("End");
/// <summary>批大小</summary>
/// <summary>批大小。数据调度每次抽取数据的分页大小，或消息调度每次处理的消息数，定时调度不适用</summary>
public static readonly Field BatchSize = FindByName("BatchSize");
/// <summary>总数</summary>
/// <summary>总数。任务处理的总数据，例如数据调度抽取得到的总行数，定时调度默认1</summary>
public static readonly Field Total = FindByName("Total");
/// <summary>成功</summary>
/// <summary>成功。成功处理的数据，取自于Handler.Execute返回值，或者ProcessItem返回true的个数</summary>
public static readonly Field Success = FindByName("Success");
/// <summary>错误</summary>
@ -312,10 +312,10 @@ namespace AntJob.Data.Entity
/// <summary>次数</summary>
public static readonly Field Times = FindByName("Times");
/// <summary>速度</summary>
/// <summary>速度。每秒处理数，执行端计算</summary>
public static readonly Field Speed = FindByName("Speed");
/// <summary>耗时。秒</summary>
/// <summary>耗时。秒，执行端计算的执行时间</summary>
public static readonly Field Cost = FindByName("Cost");
/// <summary>全部耗时。秒，从任务发放到执行完成的时间</summary>
@ -333,13 +333,13 @@ namespace AntJob.Data.Entity
/// <summary>进程</summary>
public static readonly Field ProcessID = FindByName("ProcessID");
/// <summary>最后键</summary>
/// <summary>最后键。Handler内记录作为样本的数据</summary>
public static readonly Field Key = FindByName("Key");
/// <summary>数据。可以是Json数据，比如StatID</summary>
public static readonly Field Data = FindByName("Data");
/// <summary>消息内容。异常信息或其它任务消息</summary>
/// <summary>消息内容。Handler内记录的异常信息或其它任务消息</summary>
public static readonly Field Message = FindByName("Message");
/// <summary>创建时间</summary>
@ -366,19 +366,19 @@ namespace AntJob.Data.Entity
/// <summary>客户端。IP加进程</summary>
public const String Client = "Client";
/// <summary>开始。大于等于</summary>
/// <summary>开始。大于等于，定时调度到达该时间点后触发（可能有偏移量），消息调度不适用</summary>
public const String Start = "Start";
/// <summary>结束。小于，不等于</summary>
/// <summary>结束。小于不等于，数据调度到达该时间点后触发（可能有偏移量），消息调度不适用</summary>
public const String End = "End";
/// <summary>批大小</summary>
/// <summary>批大小。数据调度每次抽取数据的分页大小，或消息调度每次处理的消息数，定时调度不适用</summary>
public const String BatchSize = "BatchSize";
/// <summary>总数</summary>
/// <summary>总数。任务处理的总数据，例如数据调度抽取得到的总行数，定时调度默认1</summary>
public const String Total = "Total";
/// <summary>成功</summary>
/// <summary>成功。成功处理的数据，取自于Handler.Execute返回值，或者ProcessItem返回true的个数</summary>
public const String Success = "Success";
/// <summary>错误</summary>
@ -387,10 +387,10 @@ namespace AntJob.Data.Entity
/// <summary>次数</summary>
public const String Times = "Times";
/// <summary>速度</summary>
/// <summary>速度。每秒处理数，执行端计算</summary>
public const String Speed = "Speed";
/// <summary>耗时。秒</summary>
/// <summary>耗时。秒，执行端计算的执行时间</summary>
public const String Cost = "Cost";
/// <summary>全部耗时。秒，从任务发放到执行完成的时间</summary>
@ -408,13 +408,13 @@ namespace AntJob.Data.Entity
/// <summary>进程</summary>
public const String ProcessID = "ProcessID";
/// <summary>最后键</summary>
/// <summary>最后键。Handler内记录作为样本的数据</summary>
public const String Key = "Key";
/// <summary>数据。可以是Json数据，比如StatID</summary>
public const String Data = "Data";
/// <summary>消息内容。异常信息或其它任务消息</summary>
/// <summary>消息内容。Handler内记录的异常信息或其它任务消息</summary>
public const String Message = "Message";
/// <summary>创建时间</summary>

32
AntJob.Data/Model.xml
View File

@ -101,20 +101,20 @@
<Column Name="Mode" DataType="Int32" Description="调度模式。定时调度只要达到时间片开头就可以跑，数据调度要求达到时间片末尾才可以跑" Type="JobModes" />
<Column Name="Topic" DataType="String" Description="主题。消息调度时消费的主题" />
<Column Name="MessageCount" DataType="Int32" Description="消息数" />
<Column Name="Start" DataType="DateTime" Description="开始。大于等于，下一个任务的起点" />
<Column Name="End" DataType="DateTime" Description="结束。小于不等于，默认空表示无止境" />
<Column Name="Start" DataType="DateTime" Description="开始。大于等于，定时调度到达该时间点后触发（可能有偏移量），消息调度不适用" />
<Column Name="End" DataType="DateTime" Description="结束。小于不等于，数据调度到达该时间点后触发（可能有偏移量），默认空表示无止境，消息调度不适用" />
<Column Name="Step" DataType="Int32" Description="步进。切分任务的时间区间，秒" />
<Column Name="BatchSize" DataType="Int32" Description="批大小。在任务时间区间内分页处理，或者每个任务的消息数" />
<Column Name="Offset" DataType="Int32" Description="偏移。距离实时时间的秒数，部分业务不能跑到实时，秒" />
<Column Name="MaxTask" DataType="Int32" Description="并行。多任务并行处理" />
<Column Name="BatchSize" DataType="Int32" Description="批大小。数据调度每次抽取数据的分页大小，或消息调度每次处理的消息数，定时调度不适用" />
<Column Name="Offset" DataType="Int32" Description="偏移。距离AntServer当前时间的秒数，避免因服务器之间的时间误差而错过部分数据，秒" />
<Column Name="MaxTask" DataType="Int32" Description="并行度。一共允许多少个任务并行处理，多执行端时平均分配，确保该作业整体并行度" />
<Column Name="MaxError" DataType="Int32" Description="最大错误。连续错误达到最大错误数时停止" />
<Column Name="MaxRetry" DataType="Int32" Description="最大重试。默认10次，超过该次数后将不再重试" />
<Column Name="MaxTime" DataType="Int32" Description="最大执行时间。默认600秒，超过该时间则认为执行器故障，将会把该任务分配给其它执行器" />
<Column Name="MaxRetain" DataType="Int32" Description="保留。任务项保留天数，超过天数的任务项将被删除，默认3天" />
<Column Name="MaxIdle" DataType="Int32" Description="最大空闲时间。默认3600秒，超过该时间不更新则认为应用程序故障，系统触发告警" />
<Column Name="ErrorDelay" DataType="Int32" Description="错误延迟。默认60秒，出错延迟后重新发放" />
<Column Name="Total" DataType="Int64" Description="总数" />
<Column Name="Success" DataType="Int64" Description="成功" />
<Column Name="Total" DataType="Int64" Description="总数。任务处理的总数据，例如数据调度抽取得到的总行数，定时调度默认1" />
<Column Name="Success" DataType="Int64" Description="成功。成功处理的数据，取自于Handler.Execute返回值，或者ProcessItem返回true的个数" />
<Column Name="Error" DataType="Int32" Description="错误" />
<Column Name="Times" DataType="Int32" Description="次数" />
<Column Name="Speed" DataType="Int32" Description="速度" />
@ -140,23 +140,23 @@
<Column Name="AppID" DataType="Int32" Description="应用" />
<Column Name="JobID" DataType="Int32" Description="作业" />
<Column Name="Client" DataType="String" Description="客户端。IP加进程" />
<Column Name="Start" DataType="DateTime" Description="开始。大于等于" />
<Column Name="End" DataType="DateTime" Description="结束。小于，不等于" />
<Column Name="BatchSize" DataType="Int32" Description="批大小" />
<Column Name="Total" DataType="Int32" Description="总数" />
<Column Name="Success" DataType="Int32" Description="成功" />
<Column Name="Start" DataType="DateTime" Description="开始。大于等于，定时调度到达该时间点后触发（可能有偏移量），消息调度不适用" />
<Column Name="End" DataType="DateTime" Description="结束。小于不等于，数据调度到达该时间点后触发（可能有偏移量），消息调度不适用" />
<Column Name="BatchSize" DataType="Int32" Description="批大小。数据调度每次抽取数据的分页大小，或消息调度每次处理的消息数，定时调度不适用" />
<Column Name="Total" DataType="Int32" Description="总数。任务处理的总数据，例如数据调度抽取得到的总行数，定时调度默认1" />
<Column Name="Success" DataType="Int32" Description="成功。成功处理的数据，取自于Handler.Execute返回值，或者ProcessItem返回true的个数" />
<Column Name="Error" DataType="Int32" Description="错误" />
<Column Name="Times" DataType="Int32" Description="次数" />
<Column Name="Speed" DataType="Int32" Description="速度" />
<Column Name="Cost" DataType="Int32" Description="耗时。秒" />
<Column Name="Speed" DataType="Int32" Description="速度。每秒处理数，执行端计算" />
<Column Name="Cost" DataType="Int32" Description="耗时。秒，执行端计算的执行时间" />
<Column Name="FullCost" DataType="Int32" Description="全部耗时。秒，从任务发放到执行完成的时间" />
<Column Name="Status" DataType="Int32" Description="状态" Type="JobStatus" />
<Column Name="MsgCount" DataType="Int32" Description="消费消息数" />
<Column Name="Server" DataType="String" Description="服务器" />
<Column Name="ProcessID" DataType="Int32" Description="进程" />
<Column Name="Key" DataType="String" Description="最后键" />
<Column Name="Key" DataType="String" Description="最后键。Handler内记录作为样本的数据" />
<Column Name="Data" DataType="String" Length="-1" Description="数据。可以是Json数据，比如StatID" />
<Column Name="Message" DataType="String" Length="-1" Description="消息内容。异常信息或其它任务消息" />
<Column Name="Message" DataType="String" Length="-1" Description="消息内容。Handler内记录的异常信息或其它任务消息" />
<Column Name="CreateTime" DataType="DateTime" Description="创建时间" />
<Column Name="UpdateTime" DataType="DateTime" Description="更新时间" />
</Columns>

8
AntJob.Web/Areas/Ant/Views/Job/_List_Data.cshtml
View File

@ -34,10 +34,10 @@
<th class="text-center"><a href="@Html.Raw(page.GetSortUrl("BatchSize"))" title="@Job._.BatchSize.Description">批大小</a></th>
<th class="text-center"><a href="@Html.Raw(page.GetSortUrl("Offset"))" title="@Job._.Offset.Description">偏移</a></th>
<th class="text-center"><a href="@Html.Raw(page.GetSortUrl("MaxTask"))" title="@Job._.MaxTask.Description">并行</a></th>
<th class="text-center"><a href="@Html.Raw(page.GetSortUrl("Total"))">总数</a></th>
<th class="text-center"><a href="@Html.Raw(page.GetSortUrl("Success"))">成功</a></th>
<th class="text-center"><a href="@Html.Raw(page.GetSortUrl("Error"))">错误</a></th>
<th class="text-center"><a href="@Html.Raw(page.GetSortUrl("Times"))">次数</a></th>
<th class="text-center"><a href="@Html.Raw(page.GetSortUrl("Total"))" title="@Job._.Total.Description">总数</a></th>
<th class="text-center"><a href="@Html.Raw(page.GetSortUrl("Success"))" title="@Job._.Success.Description">成功</a></th>
<th class="text-center"><a href="@Html.Raw(page.GetSortUrl("Error"))" title="@Job._.Error.Description">错误</a></th>
<th class="text-center"><a href="@Html.Raw(page.GetSortUrl("Times"))" title="@Job._.Times.Description">次数</a></th>
<th class="text-center"><a href="@Html.Raw(page.GetSortUrl("Speed"))">速度</a></th>
<th class="text-center"><a href="@Html.Raw(page.GetSortUrl("Enable"))">启用</a></th>
<th class="text-center"><a href="@Html.Raw(page.GetSortUrl("UpdateTime"))">更新时间</a></th>

22
AntJob.Web/Areas/Ant/Views/JobTask/_List_Data.cshtml
View File

@ -22,16 +22,17 @@
}
<th class="text-center hidden-md hidden-sm hidden-xs"><a href="@Html.Raw(page.GetSortUrl("ID"))">编号</a></th>
<th class="text-center"><a href="@Html.Raw(page.GetSortUrl("TaskID"))">任务</a></th>
<th class="text-center"><a href="@Html.Raw(page.GetSortUrl("Start"))">开始</a></th>
<th class="text-center"><a href="@Html.Raw(page.GetSortUrl("Client"))">客户端</a></th>
<th class="text-center"><a href="@Html.Raw(page.GetSortUrl("BatchSize"))">批大小</a></th>
<th class="text-center"><a href="@Html.Raw(page.GetSortUrl("Total"))">总数</a></th>
<th class="text-center"><a href="@Html.Raw(page.GetSortUrl("Success"))">成功</a></th>
<th class="text-center"><a href="@Html.Raw(page.GetSortUrl("Error"))">错误</a></th>
<th class="text-center"><a href="@Html.Raw(page.GetSortUrl("Times"))">次数</a></th>
<th class="text-center"><a href="@Html.Raw(page.GetSortUrl("Speed"))">速度</a></th>
<th class="text-center"><a href="@Html.Raw(page.GetSortUrl("Cost"))">耗时</a></th>
<th class="text-center"><a href="@Html.Raw(page.GetSortUrl("FullCost"))">全耗时</a></th>
<th class="text-center"><a href="@Html.Raw(page.GetSortUrl("Start"))" title="@JobTask._.Start.Description">开始</a></th>
<th class="text-center"><a href="@Html.Raw(page.GetSortUrl("End"))" title="@JobTask._.End.Description">结束</a></th>
<th class="text-center"><a href="@Html.Raw(page.GetSortUrl("Client"))" title="@JobTask._.Client.Description">客户端</a></th>
<th class="text-center"><a href="@Html.Raw(page.GetSortUrl("BatchSize"))" title="@JobTask._.BatchSize.Description">批大小</a></th>
<th class="text-center"><a href="@Html.Raw(page.GetSortUrl("Total"))" title="@JobTask._.Total.Description">总数</a></th>
<th class="text-center"><a href="@Html.Raw(page.GetSortUrl("Success"))" title="@JobTask._.Success.Description">成功</a></th>
<th class="text-center"><a href="@Html.Raw(page.GetSortUrl("Error"))" title="@JobTask._.Error.Description">错误</a></th>
<th class="text-center"><a href="@Html.Raw(page.GetSortUrl("Times"))" title="@JobTask._.Times.Description">次数</a></th>
<th class="text-center"><a href="@Html.Raw(page.GetSortUrl("Speed"))" title="@JobTask._.Speed.Description">速度</a></th>
<th class="text-center"><a href="@Html.Raw(page.GetSortUrl("Cost"))" title="@JobTask._.Cost.Description">耗时</a></th>
<th class="text-center"><a href="@Html.Raw(page.GetSortUrl("FullCost"))" title="@JobTask._.FullCost.Description">全耗时</a></th>
<th class="text-center"><a href="@Html.Raw(page.GetSortUrl("Status"))">状态</a></th>
<th class="text-center"><a href="@Html.Raw(page.GetSortUrl("Key"))">最后键</a></th>
<th class="text-center" style="min-width:134px;"><a href="@Html.Raw(page.GetSortUrl("UpdateTime"))">更新时间</a></th>
@ -75,6 +76,7 @@
<td class="text-center hidden-md hidden-sm hidden-xs">@entity.ID</td>
<td class="text-center"><a href="Job?ID=@entity.JobID">@entity.JobName</a></td>
<td>@entity.Start.ToFullString("")</td>
<td>@entity.End.ToString("HH:mm:ss")</td>
<td>@entity.Client</td>
<td class="text-right">@entity.BatchSize.ToString("n0")</td>
<td class="text-right">@entity.Total.ToString("n0")</td>

2
AntJob/Providers/NetworkJobProvider.cs
View File

@ -207,7 +207,7 @@ namespace AntJob.Providers
else
{
task.Status = JobStatus.完成;
task.Cost = (Int32)(ctx.Cost / 1000);
task.Cost = (Int32)Math.Round(ctx.Cost / 1000);
}
if (task.Message.IsNullOrEmpty()) task.Message = ctx.Remark;