定时调度只要达到时间片开头就可以跑,数据调度要求达到时间片末尾才可以跑

This commit is contained in:
智能石头 2020-11-26 12:16:14 +08:00
parent 538e32034f
commit 166138316d
7 changed files with 15 additions and 8 deletions

View File

@ -60,11 +60,11 @@ namespace AntJob.Data.Entity
public String DisplayName { get => _DisplayName; set { if (OnPropertyChanging("DisplayName", value)) { _DisplayName = value; OnPropertyChanged("DisplayName"); } } }
private JobModes _Mode;
/// <summary>调度模式</summary>
/// <summary>调度模式。定时调度只要达到时间片开头就可以跑,数据调度要求达到时间片末尾才可以跑</summary>
[DisplayName("调度模式")]
[Description("调度模式")]
[Description("调度模式。定时调度只要达到时间片开头就可以跑,数据调度要求达到时间片末尾才可以跑")]
[DataObjectField(false, false, false, 0)]
[BindColumn("Mode", "调度模式", "")]
[BindColumn("Mode", "调度模式。定时调度只要达到时间片开头就可以跑,数据调度要求达到时间片末尾才可以跑", "")]
public JobModes Mode { get => _Mode; set { if (OnPropertyChanging("Mode", value)) { _Mode = value; OnPropertyChanged("Mode"); } } }
private String _Topic;
@ -422,7 +422,7 @@ namespace AntJob.Data.Entity
/// <summary>显示名</summary>
public static readonly Field DisplayName = FindByName("DisplayName");
/// <summary>调度模式</summary>
/// <summary>调度模式。定时调度只要达到时间片开头就可以跑,数据调度要求达到时间片末尾才可以跑</summary>
public static readonly Field Mode = FindByName("Mode");
/// <summary>主题。消息调度时消费的主题</summary>
@ -536,7 +536,7 @@ namespace AntJob.Data.Entity
/// <summary>显示名</summary>
public const String DisplayName = "DisplayName";
/// <summary>调度模式</summary>
/// <summary>调度模式。定时调度只要达到时间片开头就可以跑,数据调度要求达到时间片末尾才可以跑</summary>
public const String Mode = "Mode";
/// <summary>主题。消息调度时消费的主题</summary>

View File

@ -98,7 +98,7 @@
<Column Name="Name" DataType="String" Master="True" Description="名称" />
<Column Name="ClassName" DataType="String" Description="类名。支持该作业的处理器实现" />
<Column Name="DisplayName" DataType="String" Description="显示名" />
<Column Name="Mode" DataType="Int32" Description="调度模式" Type="JobModes" />
<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="开始。大于等于,下一个任务的起点" />

View File

@ -8,6 +8,9 @@ using XCode.Configuration;
namespace AntJob
{
/// <summary>从数据库抽取数据</summary>
/// <remarks>
/// 定时调度只要达到时间片开头就可以跑,数据调度要求达到时间片末尾才可以跑。
/// </remarks>
public abstract class DataHandler : Handler
{
#region

View File

@ -32,7 +32,7 @@ namespace AntJob.Data
/// <summary>并行度。最大同时执行任务数</summary>
Int32 MaxTask { get; set; }
/// <summary>调度模式</summary>
/// <summary>调度模式。定时调度只要达到时间片开头就可以跑,数据调度要求达到时间片末尾才可以跑</summary>
JobModes Mode { get; set; }
/// <summary>消息主题</summary>

View File

@ -4,6 +4,7 @@ using System.Xml.Serialization;
namespace AntJob.Data
{
/// <summary>作业模型</summary>
/// <remarks>定时调度只要达到时间片开头就可以跑,数据调度要求达到时间片末尾才可以跑</remarks>
public partial class JobModel
{
#region
@ -43,7 +44,7 @@ namespace AntJob.Data
[XmlAttribute]
public Int32 MaxTask { get; set; }
/// <summary>调度模式</summary>
/// <summary>调度模式。定时调度只要达到时间片开头就可以跑,数据调度要求达到时间片末尾才可以跑</summary>
[XmlAttribute]
public JobModes Mode { get; set; }

View File

@ -3,6 +3,7 @@
namespace AntJob.Data
{
/// <summary>作业模式</summary>
/// <remarks>定时调度只要达到时间片开头就可以跑,数据调度要求达到时间片末尾才可以跑</remarks>
//[Description("作业模式")]
public enum JobModes
{

View File

@ -14,6 +14,8 @@ namespace AntJob
/// <remarks>
/// 每个作业一个处理器类,负责一个业务处理模块。
/// 例如在数据同步或数据清洗中,每张表就写一个处理器,如果一组数据表有共同特性,还可以为它们封装一个自己的处理器基类。
///
/// 定时调度只要达到时间片开头就可以跑,数据调度要求达到时间片末尾才可以跑。
/// </remarks>
public abstract class Handler
{