workflow

type ActionContext struct {
	TenantID       int64
	InstanceID     int64
	BusinessID     int64
	BusinessType   string
	Status         int32
	IdempotencyKey string
	Payload        map[string]any
}

type ActionHandler func(context.Context, ActionContext) error

type BindingVerifier func(ctx context.Context, tenantID, instanceID, businessID int64) (bool, error)

type BusinessHook func(ctx context.Context, tenantID, instanceID, businessID int64, status adminv1.WorkflowInstanceStatus)

type Engine interface {
	// Submit 创建实例并执行 OnCreated 关联回写，成功后推进并返回流程实例编号。
	Submit(ctx context.Context, params SubmitParams) (int64, error)
	// StatusByBusiness 查询业务单据最新关联实例的状态摘要。
	StatusByBusiness(ctx context.Context, tenantID int64, businessType string, businessID int64) (InstanceStatus, error)
}

type EventRegistry struct {
	// contains filtered or unexported fields
}

type InstanceStatus struct {
	// InstanceID 是流程实例编号。
	InstanceID int64
	// Status 是实例状态。
	Status adminv1.WorkflowInstanceStatus
	// EndAt 是终结时间展示文本，未终结为空串。
	EndAt string
}

type SubmitParams struct {
	// TenantID 是所属租户编号，0 表示取请求上下文登录租户。
	TenantID int64
	// ApplicantUserID 是申请人用户编号，0 表示取请求上下文登录用户。
	ApplicantUserID int64
	// Code 是流程编码。
	Code string
	// Version 是流程版本。
	Version int32
	// FormData 是申请表单数据 JSON 文本。
	FormData string
	// BusinessType 是业务单据类型编码，用于终结回调分发。
	BusinessType string
	// BusinessID 是业务单据编号。
	BusinessID int64
	// OnCreated 在实例创建提交后、首次推进前保存宿主单据与实例的关联。
	// 使用回调前必须为业务类型注册 BindingVerifier，恢复任务以持久化关联判断是否允许推进。
	// 宿主自行提交回写；返回错误时终结未推进实例且不触发业务回调。
	OnCreated func(ctx context.Context, instanceID int64) error
}