domain

const (
	// KAFKA 工作节点 kafka 推送
	KAFKA Kind = "KAFKA"
	// GRPC 绑定分布式任务平台执行节点
	GRPC Kind = "GRPC"
)

const (
	// SUCCESS 成功
	SUCCESS Status = 1
	// FAILED 失败
	FAILED Status = 2
	// RUNNING 运行中
	RUNNING Status = 3
	// WAITING 等待/初始化: 流程刚流转到该节点，刚入库
	WAITING Status = 4
	// BLOCKED 挂起/阻塞: 找不到执行路由或参数缺失等异常，流程无法推进
	BLOCKED Status = 5
	// SCHEDULED 已分配/已就绪: 任务已提交给 Dispatcher，或处于定时等待触发的状态
	SCHEDULED Status = 6
)

const (
	// 正常流转与调度相关
	TriggerPositionTaskWaiting          TriggerPosition = "任务等待"
	TriggerPositionReadyToStartNode     TriggerPosition = "准备启动节点"
	TriggerPositionDispatchDelivered    TriggerPosition = "分发已送达执行端，当前任务执行中"
	TriggerPositionTaskExecutionSuccess TriggerPosition = "任务执行成功"
	TriggerPositionTaskExecutionFailed  TriggerPosition = "任务执行失败"

	// 重试与恢复相关
	TriggerPositionManualRetry            TriggerPosition = "人工手动重试"
	TriggerPositionAutoRetry              TriggerPosition = "自动补发任务"
	TriggerPositionAutoRetryLimitExceeded TriggerPosition = "超过最大重试次数"
	TriggerPositionManualSuccess          TriggerPosition = "手动修改状态为成功"

	// 错误处理相关
	TriggerPositionErrorGetOrder              TriggerPosition = "获取工单失败"
	TriggerPositionErrorGetProcessInst        TriggerPosition = "获取流程实例失败"
	TriggerPositionErrorGetProcessInfo        TriggerPosition = "获取流程信息失败"
	TriggerPositionErrorExtractAutomationInfo TriggerPosition = "提取自动化信息失败"
	TriggerPositionErrorGetDispatcherNode     TriggerPosition = "获取调度节点失败"
	TriggerPositionErrorGetTaskTemplate       TriggerPosition = "获取任务模版失败"
)