service

type Cronjob interface {
	Create(ctx context.Context, task domain.Task) error
}

type ExecService interface {
	Execute(ctx context.Context, task domain.Task) error
}

type Service interface {
	// CreateTask 创建任务
	CreateTask(ctx context.Context, processInstId int, nodeId string) error
	// StartTask 启动任务
	StartTask(ctx context.Context, processInstId int, nodeId string) error
	RetryTask(ctx context.Context, id int64) error
	UpdateTaskStatus(ctx context.Context, req domain.TaskResult) (int64, error)
	UpdateArgs(ctx context.Context, id int64, args map[string]interface{}) (int64, error)
	UpdateVariables(ctx context.Context, id int64, variables []domain.Variables) (int64, error)
	// ListTaskByStatus 列表任务
	ListTaskByStatus(ctx context.Context, offset, limit int64, status uint8) ([]domain.Task, int64, error)
	ListTask(ctx context.Context, offset, limit int64) ([]domain.Task, int64, error)
	ListTaskByInstanceId(ctx context.Context, offset, limit int64, instanceId int) ([]domain.Task, int64, error)

	ListSuccessTasksByUtime(ctx context.Context, offset, limit int64, utime int64) ([]domain.Task, int64, error)

	// FindTaskResult 查找自动化任务
	FindTaskResult(ctx context.Context, instanceId int, nodeId string) (domain.Task, error)

	// Detail 查看任务信息
	Detail(ctx context.Context, id int64) (domain.Task, error)

	// MarkTaskAsAutoPassed 自动化通过处理成功标记
	MarkTaskAsAutoPassed(ctx context.Context, id int64) error
}