[fix] 修正Factory为空

This commit is contained in:
智能大石头 2025-04-14 11:06:45 +08:00
parent 8b02319242
commit c1be441cd9
3 changed files with 4 additions and 4 deletions

View File

@ -110,7 +110,7 @@ public abstract class DataHandler : Handler
/// <summary>初始化。作业处理器启动之前</summary>
public override void Init()
{
if (Factory == null) throw new ArgumentNullException(nameof(Factory));
if (Factory == null) throw new ArgumentNullException(nameof(Factory), $"{GetType().FullName}的参数错误");
// 自动识别雪花Id字段
if (Field == null)

View File

@ -16,7 +16,7 @@ namespace AntJob;
///
/// 定时调度只要当前时间达到时间片开头就可以跑,数据调度要求达到时间片末尾才可以跑。
///
/// 调度器控制方法:Start|Stop|Acquire
/// 调度器控制方法:Init|Start|Stop|Acquire
/// 任务处理流程Process->OnProcess->Execute->OnFinish
/// 任务控制方法Produce|Delay
/// </remarks>

View File

@ -20,13 +20,13 @@ class BuildWill : DataHandler
job.BatchSize = 1000;
}
public override Boolean Start()
public override void Init()
{
// 指定要抽取数据的实体类以及时间字段
Factory = ZYBH0.Meta.Factory;
Field = ZYBH0._.CreateTime;
return base.Start();
base.Init();
}
public override Boolean ProcessItem(JobContext ctx, IEntity entity)