workflow

package
v0.1.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 6, 2026 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Overview

Package workflow 提供 workflow_* 二次封装表的方言感知行仓储（database/sql，不引 ORM）。 引擎 ACT_* 表的行仓储见 internal/persistence/flowable，二者相互独立； 本包不生成 ID（由调用方经 internal/idgen 生成后传入），仅自动填充 create_time/update_time。

Index

Constants

View Source 
const (
	// DialectMySQL 是 MySQL 方言（"?" 占位符）。
	DialectMySQL = "mysql"
	// DialectPostgres 是 PostgreSQL 方言（"$n" 占位符）。
	DialectPostgres = "postgres"
)

支持的数据库方言。

Variables

This section is empty.

Functions

This section is empty.

Types

type ActExtendRepository 

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

ActExtendRepository 是 workflow_act_extend（活动扩展，审阅人绑定）的仓储。

func NewActExtendRepository 

func NewActExtendRepository(store *Store) ActExtendRepository

NewActExtendRepository 创建 workflow_act_extend 仓储。 @param store 仓储入口 @return 仓储

func (ActExtendRepository) DeleteByPK 

func (b ActExtendRepository) DeleteByPK(ctx context.Context, id string) (int64, error)

DeleteByPK 按主键删除一行。 @param ctx 操作上下文 @param id 主键 @return 影响行数 @return 删除错误

func (ActExtendRepository) GetByPK 

func (b ActExtendRepository) GetByPK(ctx context.Context, id string) (Row, bool, error)

GetByPK 按主键查询单行。 @param ctx 操作上下文 @param id 主键 @return 行数据（列名→值） @return 是否存在 @return 查询错误

func (ActExtendRepository) Insert 

func (b ActExtendRepository) Insert(ctx context.Context, row Row) error

Insert 插入一行；id 必须由调用方生成传入（internal/idgen），本层不生成。 @param ctx 操作上下文 @param row 行数据 @return 插入错误

func (ActExtendRepository) ListByDefinitionAndActivity 

func (r ActExtendRepository) ListByDefinitionAndActivity(ctx context.Context, definitionKey, activityID string) ([]Row, error)

ListByDefinitionAndActivity 按流程定义 key 与 BPMN 节点查询绑定（运行期审阅人读取入口）。 @param ctx 操作上下文 @param definitionKey 流程定义 key @param activityID BPMN 节点 ID @return 行列表 @return 查询错误

func (ActExtendRepository) ListByStep 

func (r ActExtendRepository) ListByStep(ctx context.Context, stepID string) ([]Row, error)

ListByStep 查询步骤下绑定的活动扩展。 @param ctx 操作上下文 @param stepID 步骤 ID（→workflow_step.id） @return 行列表 @return 查询错误

func (ActExtendRepository) UpdateByPK 

func (b ActExtendRepository) UpdateByPK(ctx context.Context, id string, changes Row) (int64, error)

UpdateByPK 按主键更新指定列；update_time 缺省时自动填充，id 列不可修改。 @param ctx 操作上下文 @param id 主键 @param changes 变更列 @return 影响行数 @return 更新错误

type BusinessSystemRepository 

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

BusinessSystemRepository 是 workflow_business_system（业务系统注册，替代 auth 表）的仓储。

func NewBusinessSystemRepository 

func NewBusinessSystemRepository(store *Store) BusinessSystemRepository

NewBusinessSystemRepository 创建 workflow_business_system 仓储。 @param store 仓储入口 @return 仓储

func (BusinessSystemRepository) DeleteByPK 

func (b BusinessSystemRepository) DeleteByPK(ctx context.Context, id string) (int64, error)

DeleteByPK 按主键删除一行。 @param ctx 操作上下文 @param id 主键 @return 影响行数 @return 删除错误

func (BusinessSystemRepository) GetByPK 

func (b BusinessSystemRepository) GetByPK(ctx context.Context, id string) (Row, bool, error)

GetByPK 按主键查询单行。 @param ctx 操作上下文 @param id 主键 @return 行数据（列名→值） @return 是否存在 @return 查询错误

func (BusinessSystemRepository) GetBySymbol 

func (r BusinessSystemRepository) GetBySymbol(ctx context.Context, systemSymbol string) (Row, bool, error)

GetBySymbol 按系统代号查询注册信息（system_symbol 唯一）。 @param ctx 操作上下文 @param systemSymbol 系统代号（通常即租户） @return 行数据 @return 是否存在 @return 查询错误

func (BusinessSystemRepository) Insert 

func (b BusinessSystemRepository) Insert(ctx context.Context, row Row) error

Insert 插入一行；id 必须由调用方生成传入（internal/idgen），本层不生成。 @param ctx 操作上下文 @param row 行数据 @return 插入错误

func (BusinessSystemRepository) ListAll 

func (r BusinessSystemRepository) ListAll(ctx context.Context) ([]Row, error)

ListAll 查询全部业务系统注册。 @param ctx 操作上下文 @return 行列表 @return 查询错误

func (BusinessSystemRepository) UpdateByPK 

func (b BusinessSystemRepository) UpdateByPK(ctx context.Context, id string, changes Row) (int64, error)

UpdateByPK 按主键更新指定列；update_time 缺省时自动填充，id 列不可修改。 @param ctx 操作上下文 @param id 主键 @param changes 变更列 @return 影响行数 @return 更新错误

type Clock 

type Clock interface {
	// Now 返回当前时间。
	// @return 当前时间
	Now() time.Time
}

Clock 是仓储的统一时间源，测试可注入固定时钟。

type ClockFunc 

type ClockFunc func() time.Time

ClockFunc 将函数适配为时间源。

func (ClockFunc) Now 

func (f ClockFunc) Now() time.Time

Now 返回当前时间。 @return 当前时间

type CompleteToActivityRepository 

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

CompleteToActivityRepository 是 workflow_complete_to_activity（直送记录）的仓储。

func NewCompleteToActivityRepository 

func NewCompleteToActivityRepository(store *Store) CompleteToActivityRepository

NewCompleteToActivityRepository 创建 workflow_complete_to_activity 仓储。 @param store 仓储入口 @return 仓储

func (CompleteToActivityRepository) DeleteByPK 

func (b CompleteToActivityRepository) DeleteByPK(ctx context.Context, id string) (int64, error)

DeleteByPK 按主键删除一行。 @param ctx 操作上下文 @param id 主键 @return 影响行数 @return 删除错误

func (CompleteToActivityRepository) GetByPK 

func (b CompleteToActivityRepository) GetByPK(ctx context.Context, id string) (Row, bool, error)

GetByPK 按主键查询单行。 @param ctx 操作上下文 @param id 主键 @return 行数据（列名→值） @return 是否存在 @return 查询错误

func (CompleteToActivityRepository) Insert 

func (b CompleteToActivityRepository) Insert(ctx context.Context, row Row) error

Insert 插入一行；id 必须由调用方生成传入（internal/idgen），本层不生成。 @param ctx 操作上下文 @param row 行数据 @return 插入错误

func (CompleteToActivityRepository) ListByProcessInstance 

func (r CompleteToActivityRepository) ListByProcessInstance(ctx context.Context, processInstanceID string) ([]Row, error)

ListByProcessInstance 查询实例的直送记录（撤回策略纳入"下一节点集合"）。 @param ctx 操作上下文 @param processInstanceID 流程实例 ID @return 行列表 @return 查询错误

func (CompleteToActivityRepository) ListByTask 

func (r CompleteToActivityRepository) ListByTask(ctx context.Context, taskID string) ([]Row, error)

ListByTask 查询任务的直送记录。 @param ctx 操作上下文 @param taskID 任务 ID @return 行列表 @return 查询错误

func (CompleteToActivityRepository) UpdateByPK 

func (b CompleteToActivityRepository) UpdateByPK(ctx context.Context, id string, changes Row) (int64, error)

UpdateByPK 按主键更新指定列；update_time 缺省时自动填充，id 列不可修改。 @param ctx 操作上下文 @param id 主键 @param changes 变更列 @return 影响行数 @return 更新错误

type CountersignWeightRepository 

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

CountersignWeightRepository 是 workflow_countersign_weight（会签权重配置）的仓储。

func NewCountersignWeightRepository 

func NewCountersignWeightRepository(store *Store) CountersignWeightRepository

NewCountersignWeightRepository 创建 workflow_countersign_weight 仓储。 @param store 仓储入口 @return 仓储

func (CountersignWeightRepository) DeleteByPK 

func (b CountersignWeightRepository) DeleteByPK(ctx context.Context, id string) (int64, error)

DeleteByPK 按主键删除一行。 @param ctx 操作上下文 @param id 主键 @return 影响行数 @return 删除错误

func (CountersignWeightRepository) GetByPK 

func (b CountersignWeightRepository) GetByPK(ctx context.Context, id string) (Row, bool, error)

GetByPK 按主键查询单行。 @param ctx 操作上下文 @param id 主键 @return 行数据（列名→值） @return 是否存在 @return 查询错误

func (CountersignWeightRepository) Insert 

func (b CountersignWeightRepository) Insert(ctx context.Context, row Row) error

Insert 插入一行；id 必须由调用方生成传入（internal/idgen），本层不生成。 @param ctx 操作上下文 @param row 行数据 @return 插入错误

func (CountersignWeightRepository) ListByDefinitionAndActivity 

func (r CountersignWeightRepository) ListByDefinitionAndActivity(ctx context.Context, definitionKey, activityID string) ([]Row, error)

ListByDefinitionAndActivity 按流程定义 key 与节点查询权重配置（节点×身份）。 @param ctx 操作上下文 @param definitionKey 流程定义 key @param activityID BPMN 节点 ID @return 行列表 @return 查询错误

func (CountersignWeightRepository) ListByIdentity 

func (r CountersignWeightRepository) ListByIdentity(ctx context.Context, definitionKey, identityID string) ([]Row, error)

ListByIdentity 查询身份参与的权重配置。 @param ctx 操作上下文 @param definitionKey 流程定义 key @param identityID 身份 ID @return 行列表 @return 查询错误

func (CountersignWeightRepository) UpdateByPK 

func (b CountersignWeightRepository) UpdateByPK(ctx context.Context, id string, changes Row) (int64, error)

UpdateByPK 按主键更新指定列；update_time 缺省时自动填充，id 列不可修改。 @param ctx 操作上下文 @param id 主键 @param changes 变更列 @return 影响行数 @return 更新错误

type DelegateTaskRepository 

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

DelegateTaskRepository 是 workflow_delegate_task（委托镜像待办）的仓储。

func NewDelegateTaskRepository 

func NewDelegateTaskRepository(store *Store) DelegateTaskRepository

NewDelegateTaskRepository 创建 workflow_delegate_task 仓储。 @param store 仓储入口 @return 仓储

func (DelegateTaskRepository) DeleteByPK 

func (b DelegateTaskRepository) DeleteByPK(ctx context.Context, id string) (int64, error)

DeleteByPK 按主键删除一行。 @param ctx 操作上下文 @param id 主键 @return 影响行数 @return 删除错误

func (DelegateTaskRepository) DeleteByProcessInstance 

func (r DelegateTaskRepository) DeleteByProcessInstance(ctx context.Context, processInstanceID string) (int64, error)

DeleteByProcessInstance 删除实例下全部镜像待办（实例删除级联）。 @param ctx 操作上下文 @param processInstanceID 流程实例 ID @return 影响行数 @return 删除错误

func (DelegateTaskRepository) GetByPK 

func (b DelegateTaskRepository) GetByPK(ctx context.Context, id string) (Row, bool, error)

GetByPK 按主键查询单行。 @param ctx 操作上下文 @param id 主键 @return 行数据（列名→值） @return 是否存在 @return 查询错误

func (DelegateTaskRepository) GetByTask 

func (r DelegateTaskRepository) GetByTask(ctx context.Context, taskID string) (Row, bool, error)

GetByTask 按任务 ID 查询镜像待办。 @param ctx 操作上下文 @param taskID 任务 ID @return 行数据 @return 是否存在 @return 查询错误

func (DelegateTaskRepository) Insert 

func (b DelegateTaskRepository) Insert(ctx context.Context, row Row) error

Insert 插入一行；id 必须由调用方生成传入（internal/idgen），本层不生成。 @param ctx 操作上下文 @param row 行数据 @return 插入错误

func (DelegateTaskRepository) ListByEntrust 

func (r DelegateTaskRepository) ListByEntrust(ctx context.Context, entrustID string) ([]Row, error)

ListByEntrust 查询被委托人的镜像待办列表。 @param ctx 操作上下文 @param entrustID 被委托人 ID @return 行列表 @return 查询错误

func (DelegateTaskRepository) ListByProcessInstance 

func (r DelegateTaskRepository) ListByProcessInstance(ctx context.Context, processInstanceID string) ([]Row, error)

ListByProcessInstance 查询实例下全部镜像待办。 @param ctx 操作上下文 @param processInstanceID 流程实例 ID @return 行列表 @return 查询错误

func (DelegateTaskRepository) UpdateByPK 

func (b DelegateTaskRepository) UpdateByPK(ctx context.Context, id string, changes Row) (int64, error)

UpdateByPK 按主键更新指定列；update_time 缺省时自动填充，id 列不可修改。 @param ctx 操作上下文 @param id 主键 @param changes 变更列 @return 影响行数 @return 更新错误

type DocumentRepository 

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

DocumentRepository 是 workflow_document（业务单据↔流程实例绑定与状态快照）的仓储。 business_id 在租户内唯一（uk_wf_document_business），查询统一过滤 deleted = 0。

func NewDocumentRepository 

func NewDocumentRepository(store *Store) DocumentRepository

NewDocumentRepository 创建 workflow_document 仓储。 @param store 仓储入口 @return 仓储

func (DocumentRepository) DeleteByPK 

func (b DocumentRepository) DeleteByPK(ctx context.Context, id string) (int64, error)

DeleteByPK 按主键删除一行。 @param ctx 操作上下文 @param id 主键 @return 影响行数 @return 删除错误

func (DocumentRepository) GetByBusinessID 

func (r DocumentRepository) GetByBusinessID(ctx context.Context, businessID, tenantID string) (Row, bool, error)

GetByBusinessID 按业务单据与租户查询未删除的单据状态。 @param ctx 操作上下文 @param businessID 业务单据 ID @param tenantID 租户 @return 行数据 @return 是否存在 @return 查询错误

func (DocumentRepository) GetByPK 

func (b DocumentRepository) GetByPK(ctx context.Context, id string) (Row, bool, error)

GetByPK 按主键查询单行。 @param ctx 操作上下文 @param id 主键 @return 行数据（列名→值） @return 是否存在 @return 查询错误

func (DocumentRepository) Insert 

func (b DocumentRepository) Insert(ctx context.Context, row Row) error

Insert 插入一行；id 必须由调用方生成传入（internal/idgen），本层不生成。 @param ctx 操作上下文 @param row 行数据 @return 插入错误

func (DocumentRepository) ListByFlowInstance 

func (r DocumentRepository) ListByFlowInstance(ctx context.Context, instanceID string) ([]Row, error)

ListByFlowInstance 按流程实例查询未删除的单据状态。 @param ctx 操作上下文 @param instanceID 流程实例 ID @return 行列表 @return 查询错误

func (DocumentRepository) MarkDeletedByBusinessID 

func (r DocumentRepository) MarkDeletedByBusinessID(ctx context.Context, businessID, tenantID string) (int64, error)

MarkDeletedByBusinessID 按业务单据与租户逻辑删除（deleted=1，手工过滤语义）。 @param ctx 操作上下文 @param businessID 业务单据 ID @param tenantID 租户 @return 影响行数 @return 更新错误

func (DocumentRepository) UpdateByPK 

func (b DocumentRepository) UpdateByPK(ctx context.Context, id string, changes Row) (int64, error)

UpdateByPK 按主键更新指定列；update_time 缺省时自动填充，id 列不可修改。 @param ctx 操作上下文 @param id 主键 @param changes 变更列 @return 影响行数 @return 更新错误

func (DocumentRepository) UpsertByBusinessID 

func (r DocumentRepository) UpsertByBusinessID(ctx context.Context, row Row) error

UpsertByBusinessID 按业务单据与租户保存在单据状态：存在则更新，不存在则插入。 需在 WithTx 中调用以保证查询与写入的原子性。 @param ctx 操作上下文 @param row 单据行（必须含 id、business_id、tenant_id） @return 保存错误

type HisNextActivityRepository 

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

HisNextActivityRepository 是 workflow_his_next_activity（下一步历史，双写落库）的仓储。

func NewHisNextActivityRepository 

func NewHisNextActivityRepository(store *Store) HisNextActivityRepository

NewHisNextActivityRepository 创建 workflow_his_next_activity 仓储。 @param store 仓储入口 @return 仓储

func (HisNextActivityRepository) DeleteByPK 

func (b HisNextActivityRepository) DeleteByPK(ctx context.Context, id string) (int64, error)

DeleteByPK 按主键删除一行。 @param ctx 操作上下文 @param id 主键 @return 影响行数 @return 删除错误

func (HisNextActivityRepository) DeleteByProcessInstanceAndActivities 

func (r HisNextActivityRepository) DeleteByProcessInstanceAndActivities(ctx context.Context, processInstanceID string, nextActivityIDs []string) (int64, error)

DeleteByProcessInstanceAndActivities 按实例与活动集合删除历史记录（退回/撤回规则清理）。 @param ctx 操作上下文 @param processInstanceID 流程实例 ID @param nextActivityIDs 下一活动 ID 集合 @return 影响行数 @return 删除错误

func (HisNextActivityRepository) GetByPK 

func (b HisNextActivityRepository) GetByPK(ctx context.Context, id string) (Row, bool, error)

GetByPK 按主键查询单行。 @param ctx 操作上下文 @param id 主键 @return 行数据（列名→值） @return 是否存在 @return 查询错误

func (HisNextActivityRepository) Insert 

func (b HisNextActivityRepository) Insert(ctx context.Context, row Row) error

Insert 插入一行；id 必须由调用方生成传入（internal/idgen），本层不生成。 @param ctx 操作上下文 @param row 行数据 @return 插入错误

func (HisNextActivityRepository) ListByActivityByVersionDesc 

func (r HisNextActivityRepository) ListByActivityByVersionDesc(ctx context.Context, processInstanceID, nextActivityID string) ([]Row, error)

ListByActivityByVersionDesc 查询实例下指定节点的历史记录（版本号降序，便于取最新版本）。 @param ctx 操作上下文 @param processInstanceID 流程实例 ID @param nextActivityID 下一活动 ID @return 行列表 @return 查询错误

func (HisNextActivityRepository) ListByProcessInstance 

func (r HisNextActivityRepository) ListByProcessInstance(ctx context.Context, processInstanceID string) ([]Row, error)

ListByProcessInstance 查询实例的全部下一步历史（轨迹回放）。 @param ctx 操作上下文 @param processInstanceID 流程实例 ID @return 行列表 @return 查询错误

func (HisNextActivityRepository) MarkUsed 

func (r HisNextActivityRepository) MarkUsed(ctx context.Context, id, taskID string) (int64, error)

MarkUsed 标记历史记录已消耗并回写任务 ID。 @param ctx 操作上下文 @param id 记录 ID @param taskID 任务 ID @return 影响行数 @return 更新错误

func (HisNextActivityRepository) UpdateByPK 

func (b HisNextActivityRepository) UpdateByPK(ctx context.Context, id string, changes Row) (int64, error)

UpdateByPK 按主键更新指定列；update_time 缺省时自动填充，id 列不可修改。 @param ctx 操作上下文 @param id 主键 @param changes 变更列 @return 影响行数 @return 更新错误

type HisStepRepository 

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

HisStepRepository 是 workflow_his_step（步骤部署快照，运行期规则字典）的仓储。

func NewHisStepRepository 

func NewHisStepRepository(store *Store) HisStepRepository

NewHisStepRepository 创建 workflow_his_step 仓储。 @param store 仓储入口 @return 仓储

func (HisStepRepository) DeleteByPK 

func (b HisStepRepository) DeleteByPK(ctx context.Context, id string) (int64, error)

DeleteByPK 按主键删除一行。 @param ctx 操作上下文 @param id 主键 @return 影响行数 @return 删除错误

func (HisStepRepository) GetByDeploymentAndStepCode 

func (r HisStepRepository) GetByDeploymentAndStepCode(ctx context.Context, deploymentID, stepCode string) (Row, bool, error)

GetByDeploymentAndStepCode 按部署与步骤代号定位快照行。 @param ctx 操作上下文 @param deploymentID 部署 ID @param stepCode 步骤代号 @return 行数据 @return 是否存在 @return 查询错误

func (HisStepRepository) GetByPK 

func (b HisStepRepository) GetByPK(ctx context.Context, id string) (Row, bool, error)

GetByPK 按主键查询单行。 @param ctx 操作上下文 @param id 主键 @return 行数据（列名→值） @return 是否存在 @return 查询错误

func (HisStepRepository) Insert 

func (b HisStepRepository) Insert(ctx context.Context, row Row) error

Insert 插入一行；id 必须由调用方生成传入（internal/idgen），本层不生成。 @param ctx 操作上下文 @param row 行数据 @return 插入错误

func (HisStepRepository) ListByDeployment 

func (r HisStepRepository) ListByDeployment(ctx context.Context, deploymentID string) ([]Row, error)

ListByDeployment 查询某次部署的全部步骤快照（部署后按 deploymentId 读取规则）。 @param ctx 操作上下文 @param deploymentID 部署 ID（→ACT_RE_PROCDEF.DEPLOYMENT_ID_） @return 行列表 @return 查询错误

func (HisStepRepository) ListByModel 

func (r HisStepRepository) ListByModel(ctx context.Context, modelID string) ([]Row, error)

ListByModel 查询模型的历史步骤快照。 @param ctx 操作上下文 @param modelID 模型 ID @return 行列表 @return 查询错误

func (HisStepRepository) UpdateByPK 

func (b HisStepRepository) UpdateByPK(ctx context.Context, id string, changes Row) (int64, error)

UpdateByPK 按主键更新指定列；update_time 缺省时自动填充，id 列不可修改。 @param ctx 操作上下文 @param id 主键 @param changes 变更列 @return 影响行数 @return 更新错误

type HistoryExtendRepository 

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

HistoryExtendRepository 是 workflow_task_history_extend（已办扩展，ACT_HI_TASKINST 1:1）的仓储。

func NewHistoryExtendRepository 

func NewHistoryExtendRepository(store *Store) HistoryExtendRepository

NewHistoryExtendRepository 创建 workflow_task_history_extend 仓储。 @param store 仓储入口 @return 仓储

func (HistoryExtendRepository) DeleteByPK 

func (b HistoryExtendRepository) DeleteByPK(ctx context.Context, id string) (int64, error)

DeleteByPK 按主键删除一行。 @param ctx 操作上下文 @param id 主键 @return 影响行数 @return 删除错误

func (HistoryExtendRepository) GetByPK 

func (b HistoryExtendRepository) GetByPK(ctx context.Context, id string) (Row, bool, error)

GetByPK 按主键查询单行。 @param ctx 操作上下文 @param id 主键 @return 行数据（列名→值） @return 是否存在 @return 查询错误

func (HistoryExtendRepository) GetByTask 

func (r HistoryExtendRepository) GetByTask(ctx context.Context, taskID string) (Row, bool, error)

GetByTask 按任务 ID 查询已办扩展。 @param ctx 操作上下文 @param taskID 任务 ID @return 行数据 @return 是否存在 @return 查询错误

func (HistoryExtendRepository) Insert 

func (b HistoryExtendRepository) Insert(ctx context.Context, row Row) error

Insert 插入一行；id 必须由调用方生成传入（internal/idgen），本层不生成。 @param ctx 操作上下文 @param row 行数据 @return 插入错误

func (HistoryExtendRepository) ListByBusiness 

func (r HistoryExtendRepository) ListByBusiness(ctx context.Context, businessID, tenantID string) ([]Row, error)

ListByBusiness 按业务单据与租户查询已办扩展。 @param ctx 操作上下文 @param businessID 业务单据 ID @param tenantID 租户 @return 行列表 @return 查询错误

func (HistoryExtendRepository) ListByProcessInstance 

func (r HistoryExtendRepository) ListByProcessInstance(ctx context.Context, processInstanceID string) ([]Row, error)

ListByProcessInstance 查询实例下全部已办扩展（按办结时间排序，聚合已办轨迹）。 @param ctx 操作上下文 @param processInstanceID 流程实例 ID @return 行列表 @return 查询错误

func (HistoryExtendRepository) UpdateByPK 

func (b HistoryExtendRepository) UpdateByPK(ctx context.Context, id string, changes Row) (int64, error)

UpdateByPK 按主键更新指定列；update_time 缺省时自动填充，id 列不可修改。 @param ctx 操作上下文 @param id 主键 @param changes 变更列 @return 影响行数 @return 更新错误

type MessageExtendRepository 

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

MessageExtendRepository 是 workflow_task_message_extend（待办扩展，待办中心唯一数据源）的仓储。

func NewMessageExtendRepository 

func NewMessageExtendRepository(store *Store) MessageExtendRepository

NewMessageExtendRepository 创建 workflow_task_message_extend 仓储。 @param store 仓储入口 @return 仓储

func (MessageExtendRepository) DeleteByPK 

func (b MessageExtendRepository) DeleteByPK(ctx context.Context, id string) (int64, error)

DeleteByPK 按主键删除一行。 @param ctx 操作上下文 @param id 主键 @return 影响行数 @return 删除错误

func (MessageExtendRepository) DeleteByProcessInstanceAndSteps 

func (r MessageExtendRepository) DeleteByProcessInstanceAndSteps(ctx context.Context, processInstanceID string, stepCodes []string) (int64, error)

DeleteByProcessInstanceAndSteps 删除实例下指定步骤代号的待办扩展（退回/撤回清理）。 @param ctx 操作上下文 @param processInstanceID 流程实例 ID @param stepCodes 步骤代号集合 @return 影响行数 @return 删除错误

func (MessageExtendRepository) DeleteByTask 

func (r MessageExtendRepository) DeleteByTask(ctx context.Context, taskID string) (int64, error)

DeleteByTask 删除任务的待办扩展（办结流转时先删后增）。 @param ctx 操作上下文 @param taskID 任务 ID @return 影响行数 @return 删除错误

func (MessageExtendRepository) GetByPK 

func (b MessageExtendRepository) GetByPK(ctx context.Context, id string) (Row, bool, error)

GetByPK 按主键查询单行。 @param ctx 操作上下文 @param id 主键 @return 行数据（列名→值） @return 是否存在 @return 查询错误

func (MessageExtendRepository) GetByTask 

func (r MessageExtendRepository) GetByTask(ctx context.Context, taskID string) (Row, bool, error)

GetByTask 按任务 ID 查询待办扩展（与 ACT_RU_TASK 1:1）。 @param ctx 操作上下文 @param taskID 任务 ID @return 行数据 @return 是否存在 @return 查询错误

func (MessageExtendRepository) Insert 

func (b MessageExtendRepository) Insert(ctx context.Context, row Row) error

Insert 插入一行；id 必须由调用方生成传入（internal/idgen），本层不生成。 @param ctx 操作上下文 @param row 行数据 @return 插入错误

func (MessageExtendRepository) ListByBusiness 

func (r MessageExtendRepository) ListByBusiness(ctx context.Context, businessID, tenantID string) ([]Row, error)

ListByBusiness 按业务单据与租户查询待办扩展。 @param ctx 操作上下文 @param businessID 业务单据 ID @param tenantID 租户 @return 行列表 @return 查询错误

func (MessageExtendRepository) ListByOwner 

func (r MessageExtendRepository) ListByOwner(ctx context.Context, ownerID string) ([]Row, error)

ListByOwner 按处理人查询待办扩展。 @param ctx 操作上下文 @param ownerID 处理人身份 ID @return 行列表 @return 查询错误

func (MessageExtendRepository) ListByProcessInstance 

func (r MessageExtendRepository) ListByProcessInstance(ctx context.Context, processInstanceID string) ([]Row, error)

ListByProcessInstance 查询实例下全部待办扩展。 @param ctx 操作上下文 @param processInstanceID 流程实例 ID @return 行列表 @return 查询错误

func (MessageExtendRepository) MarkRead 

func (r MessageExtendRepository) MarkRead(ctx context.Context, taskID string, readTime any) (int64, error)

MarkRead 标记待办已读并回写阅读时间。 @param ctx 操作上下文 @param taskID 任务 ID @param readTime 阅读时间 @return 影响行数 @return 更新错误

func (MessageExtendRepository) UpdateByPK 

func (b MessageExtendRepository) UpdateByPK(ctx context.Context, id string, changes Row) (int64, error)

UpdateByPK 按主键更新指定列；update_time 缺省时自动填充，id 列不可修改。 @param ctx 操作上下文 @param id 主键 @param changes 变更列 @return 影响行数 @return 更新错误

type ModelRepository 

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

ModelRepository 是 workflow_model（流程模型/分类主数据）的仓储。

func NewModelRepository 

func NewModelRepository(store *Store) ModelRepository

NewModelRepository 创建 workflow_model 仓储。 @param store 仓储入口 @return 仓储

func (ModelRepository) DeleteByPK 

func (b ModelRepository) DeleteByPK(ctx context.Context, id string) (int64, error)

DeleteByPK 按主键删除一行。 @param ctx 操作上下文 @param id 主键 @return 影响行数 @return 删除错误

func (ModelRepository) GetByModelCode 

func (r ModelRepository) GetByModelCode(ctx context.Context, modelCode, tenantID string) (Row, bool, error)

GetByModelCode 按模型编码（=流程定义 key）与租户查询模型（分类页与模型页共用）。 @param ctx 操作上下文 @param modelCode 模型编码 @param tenantID 租户 @return 行数据 @return 是否存在 @return 查询错误

func (ModelRepository) GetByPK 

func (b ModelRepository) GetByPK(ctx context.Context, id string) (Row, bool, error)

GetByPK 按主键查询单行。 @param ctx 操作上下文 @param id 主键 @return 行数据（列名→值） @return 是否存在 @return 查询错误

func (ModelRepository) Insert 

func (b ModelRepository) Insert(ctx context.Context, row Row) error

Insert 插入一行；id 必须由调用方生成传入（internal/idgen），本层不生成。 @param ctx 操作上下文 @param row 行数据 @return 插入错误

func (ModelRepository) ListByParent 

func (r ModelRepository) ListByParent(ctx context.Context, parentID string) ([]Row, error)

ListByParent 查询指定父节点下的子模型/子分类。 @param ctx 操作上下文 @param parentID 父节点 ID @return 行列表 @return 查询错误

func (ModelRepository) ListByTenant 

func (r ModelRepository) ListByTenant(ctx context.Context, tenantID string) ([]Row, error)

ListByTenant 查询租户下全部模型与分类。 @param ctx 操作上下文 @param tenantID 租户 @return 行列表 @return 查询错误

func (ModelRepository) UpdateByPK 

func (b ModelRepository) UpdateByPK(ctx context.Context, id string, changes Row) (int64, error)

UpdateByPK 按主键更新指定列；update_time 缺省时自动填充，id 列不可修改。 @param ctx 操作上下文 @param id 主键 @param changes 变更列 @return 影响行数 @return 更新错误

func (ModelRepository) UpdateLastDeployTime 

func (r ModelRepository) UpdateLastDeployTime(ctx context.Context, id string, deployTime any) (int64, error)

UpdateLastDeployTime 回写模型最近部署时间。 @param ctx 操作上下文 @param id 模型 ID @param deployTime 部署时间 @return 影响行数 @return 更新错误

type NextActivityRepository 

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

NextActivityRepository 是 workflow_next_activity（下一步节点及处理人，预生成-消耗核心记账表）的仓储。

func NewNextActivityRepository 

func NewNextActivityRepository(store *Store) NextActivityRepository

NewNextActivityRepository 创建 workflow_next_activity 仓储。 @param store 仓储入口 @return 仓储

func (NextActivityRepository) DeleteByPK 

func (b NextActivityRepository) DeleteByPK(ctx context.Context, id string) (int64, error)

DeleteByPK 按主键删除一行。 @param ctx 操作上下文 @param id 主键 @return 影响行数 @return 删除错误

func (NextActivityRepository) DeleteByProcessInstance 

func (r NextActivityRepository) DeleteByProcessInstance(ctx context.Context, processInstanceID string) (int64, error)

DeleteByProcessInstance 删除实例的全部未消耗预生成记录。 @param ctx 操作上下文 @param processInstanceID 流程实例 ID @return 影响行数 @return 删除错误

func (NextActivityRepository) DeleteByProcessInstanceAndActivities 

func (r NextActivityRepository) DeleteByProcessInstanceAndActivities(ctx context.Context, processInstanceID string, nextActivityIDs []string) (int64, error)

DeleteByProcessInstanceAndActivities 删除实例下指定活动集合的记录（退回/转办清理）。 @param ctx 操作上下文 @param processInstanceID 流程实例 ID @param nextActivityIDs 下一活动 ID 集合 @return 影响行数 @return 删除错误

func (NextActivityRepository) GetByPK 

func (b NextActivityRepository) GetByPK(ctx context.Context, id string) (Row, bool, error)

GetByPK 按主键查询单行。 @param ctx 操作上下文 @param id 主键 @return 行数据（列名→值） @return 是否存在 @return 查询错误

func (NextActivityRepository) Insert 

func (b NextActivityRepository) Insert(ctx context.Context, row Row) error

Insert 插入一行；id 必须由调用方生成传入（internal/idgen），本层不生成。 @param ctx 操作上下文 @param row 行数据 @return 插入错误

func (NextActivityRepository) InsertDual 

func (r NextActivityRepository) InsertDual(ctx context.Context, row Row) error

InsertDual 双写运行态与历史表（同 ID 同内容），需在 WithTx 中调用以保证原子性。 @param ctx 操作上下文 @param row 下一步记录（两表共用同一行数据） @return 双写错误

func (NextActivityRepository) ListByPreTask 

func (r NextActivityRepository) ListByPreTask(ctx context.Context, preTaskID string) ([]Row, error)

ListByPreTask 查询以上一任务为来源的下一步记录（退回/撤回清理入口）。 @param ctx 操作上下文 @param preTaskID 上一任务 ID @return 行列表 @return 查询错误

func (NextActivityRepository) ListByTask 

func (r NextActivityRepository) ListByTask(ctx context.Context, taskID string) ([]Row, error)

ListByTask 查询已挂到任务上的记录。 @param ctx 操作上下文 @param taskID 任务 ID @return 行列表 @return 查询错误

func (NextActivityRepository) ListUnusedByActivity 

func (r NextActivityRepository) ListUnusedByActivity(ctx context.Context, processInstanceID, nextActivityID string) ([]Row, error)

ListUnusedByActivity 查询实例下指定节点尚未消耗（used=0）的下一步记录。 @param ctx 操作上下文 @param processInstanceID 流程实例 ID @param nextActivityID 下一活动 ID @return 行列表 @return 查询错误

func (NextActivityRepository) ListUnusedByProcessInstance 

func (r NextActivityRepository) ListUnusedByProcessInstance(ctx context.Context, processInstanceID string) ([]Row, error)

ListUnusedByProcessInstance 查询实例下全部未消耗记录（执行人重写钩子读取）。 @param ctx 操作上下文 @param processInstanceID 流程实例 ID @return 行列表 @return 查询错误

func (NextActivityRepository) MarkUsed 

func (r NextActivityRepository) MarkUsed(ctx context.Context, id, taskID string) (int64, error)

MarkUsed 标记记录已消耗并回写任务 ID（仅未消耗记录生效，防并发重复消耗）。 @param ctx 操作上下文 @param id 记录 ID @param taskID 任务 ID（→ACT_RU_TASK.ID_） @return 影响行数 @return 更新错误

func (NextActivityRepository) UpdateByPK 

func (b NextActivityRepository) UpdateByPK(ctx context.Context, id string, changes Row) (int64, error)

UpdateByPK 按主键更新指定列；update_time 缺省时自动填充，id 列不可修改。 @param ctx 操作上下文 @param id 主键 @param changes 变更列 @return 影响行数 @return 更新错误

type OperationRecordRepository 

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

OperationRecordRepository 是 workflow_operation_record（操作记录/意见留痕）的仓储。

func NewOperationRecordRepository 

func NewOperationRecordRepository(store *Store) OperationRecordRepository

NewOperationRecordRepository 创建 workflow_operation_record 仓储。 @param store 仓储入口 @return 仓储

func (OperationRecordRepository) DeleteByPK 

func (b OperationRecordRepository) DeleteByPK(ctx context.Context, id string) (int64, error)

DeleteByPK 按主键删除一行。 @param ctx 操作上下文 @param id 主键 @return 影响行数 @return 删除错误

func (OperationRecordRepository) GetByPK 

func (b OperationRecordRepository) GetByPK(ctx context.Context, id string) (Row, bool, error)

GetByPK 按主键查询单行。 @param ctx 操作上下文 @param id 主键 @return 行数据（列名→值） @return 是否存在 @return 查询错误

func (OperationRecordRepository) Insert 

func (b OperationRecordRepository) Insert(ctx context.Context, row Row) error

Insert 插入一行；id 必须由调用方生成传入（internal/idgen），本层不生成。 @param ctx 操作上下文 @param row 行数据 @return 插入错误

func (OperationRecordRepository) ListByBusiness 

func (r OperationRecordRepository) ListByBusiness(ctx context.Context, businessID string) ([]Row, error)

ListByBusiness 查询业务单据的操作记录。 @param ctx 操作上下文 @param businessID 业务单据 ID @return 行列表 @return 查询错误

func (OperationRecordRepository) ListByProcessInstance 

func (r OperationRecordRepository) ListByProcessInstance(ctx context.Context, processInstanceID string) ([]Row, error)

ListByProcessInstance 查询实例的操作记录。 @param ctx 操作上下文 @param processInstanceID 流程实例 ID @return 行列表 @return 查询错误

func (OperationRecordRepository) ListByTask 

func (r OperationRecordRepository) ListByTask(ctx context.Context, taskID string) ([]Row, error)

ListByTask 查询任务的操作记录。 @param ctx 操作上下文 @param taskID 任务 ID @return 行列表 @return 查询错误

func (OperationRecordRepository) UpdateByPK 

func (b OperationRecordRepository) UpdateByPK(ctx context.Context, id string, changes Row) (int64, error)

UpdateByPK 按主键更新指定列；update_time 缺省时自动填充，id 列不可修改。 @param ctx 操作上下文 @param id 主键 @param changes 变更列 @return 影响行数 @return 更新错误

type Option 

type Option func(*Store)

Option 是 Store 的可选配置。

func WithClock 

func WithClock(clock Clock) Option

WithClock 注入时间源。 @param clock 时间源 @return 配置项

type RemindRepository 

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

RemindRepository 是 workflow_remind（催办配置主表）的仓储。查询统一过滤 deleted = 0。

func NewRemindRepository 

func NewRemindRepository(store *Store) RemindRepository

NewRemindRepository 创建 workflow_remind 仓储。 @param store 仓储入口 @return 仓储

func (RemindRepository) DeleteByPK 

func (b RemindRepository) DeleteByPK(ctx context.Context, id string) (int64, error)

DeleteByPK 按主键删除一行。 @param ctx 操作上下文 @param id 主键 @return 影响行数 @return 删除错误

func (RemindRepository) GetByPK 

func (b RemindRepository) GetByPK(ctx context.Context, id string) (Row, bool, error)

GetByPK 按主键查询单行。 @param ctx 操作上下文 @param id 主键 @return 行数据（列名→值） @return 是否存在 @return 查询错误

func (RemindRepository) Insert 

func (b RemindRepository) Insert(ctx context.Context, row Row) error

Insert 插入一行；id 必须由调用方生成传入（internal/idgen），本层不生成。 @param ctx 操作上下文 @param row 行数据 @return 插入错误

func (RemindRepository) ListByModel 

func (r RemindRepository) ListByModel(ctx context.Context, modelID string) ([]Row, error)

ListByModel 查询模型的催办配置。 @param ctx 操作上下文 @param modelID 模型 ID（pid → workflow_model.id） @return 行列表 @return 查询错误

func (RemindRepository) MarkSent 

func (r RemindRepository) MarkSent(ctx context.Context, id string) (int64, error)

MarkSent 标记催办配置已发送。 @param ctx 操作上下文 @param id 催办配置 ID @return 影响行数 @return 更新错误

func (RemindRepository) UpdateByPK 

func (b RemindRepository) UpdateByPK(ctx context.Context, id string, changes Row) (int64, error)

UpdateByPK 按主键更新指定列；update_time 缺省时自动填充，id 列不可修改。 @param ctx 操作上下文 @param id 主键 @param changes 变更列 @return 影响行数 @return 更新错误

type RemindTargetRepository 

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

RemindTargetRepository 是 workflow_remind_target（催办对象）的仓储。查询统一过滤 deleted = 0。

func NewRemindTargetRepository 

func NewRemindTargetRepository(store *Store) RemindTargetRepository

NewRemindTargetRepository 创建 workflow_remind_target 仓储。 @param store 仓储入口 @return 仓储

func (RemindTargetRepository) DeleteByPK 

func (b RemindTargetRepository) DeleteByPK(ctx context.Context, id string) (int64, error)

DeleteByPK 按主键删除一行。 @param ctx 操作上下文 @param id 主键 @return 影响行数 @return 删除错误

func (RemindTargetRepository) DeleteByRemind 

func (r RemindTargetRepository) DeleteByRemind(ctx context.Context, remindID string) (int64, error)

DeleteByRemind 删除催办配置的全部对象（配置重建时先删后增）。 @param ctx 操作上下文 @param remindID 催办配置 ID @return 影响行数 @return 删除错误

func (RemindTargetRepository) GetByPK 

func (b RemindTargetRepository) GetByPK(ctx context.Context, id string) (Row, bool, error)

GetByPK 按主键查询单行。 @param ctx 操作上下文 @param id 主键 @return 行数据（列名→值） @return 是否存在 @return 查询错误

func (RemindTargetRepository) Insert 

func (b RemindTargetRepository) Insert(ctx context.Context, row Row) error

Insert 插入一行；id 必须由调用方生成传入（internal/idgen），本层不生成。 @param ctx 操作上下文 @param row 行数据 @return 插入错误

func (RemindTargetRepository) ListByRemind 

func (r RemindTargetRepository) ListByRemind(ctx context.Context, remindID string) ([]Row, error)

ListByRemind 查询催办配置的对象列表。 @param ctx 操作上下文 @param remindID 催办配置 ID（pid → workflow_remind.id） @return 行列表 @return 查询错误

func (RemindTargetRepository) MarkSent 

func (r RemindTargetRepository) MarkSent(ctx context.Context, id string) (int64, error)

MarkSent 标记催办对象已发送。 @param ctx 操作上下文 @param id 催办对象 ID @return 影响行数 @return 更新错误

func (RemindTargetRepository) UpdateByPK 

func (b RemindTargetRepository) UpdateByPK(ctx context.Context, id string, changes Row) (int64, error)

UpdateByPK 按主键更新指定列；update_time 缺省时自动填充，id 列不可修改。 @param ctx 操作上下文 @param id 主键 @param changes 变更列 @return 影响行数 @return 更新错误

type Repositories 

type Repositories struct {
	BusinessSystems      BusinessSystemRepository     // 业务系统注册
	Models               ModelRepository              // 流程模型/分类
	Steps                StepRepository               // 设计时步骤配置
	HisSteps             HisStepRepository            // 步骤部署快照（规则字典）
	Templates            TemplateRepository           // 设计器模板
	ActExtends           ActExtendRepository          // 活动扩展（审阅人绑定）
	CountersignWeights   CountersignWeightRepository  // 会签权重
	NextActivities       NextActivityRepository       // 下一步预生成（运行态）
	HisNextActivities    HisNextActivityRepository    // 下一步历史（双写）
	MessageExtends       MessageExtendRepository      // 待办扩展
	HistoryExtends       HistoryExtendRepository      // 已办扩展
	DelegateTasks        DelegateTaskRepository       // 委托镜像待办
	Documents            DocumentRepository           // 业务单据流程状态
	OperationRecords     OperationRecordRepository    // 操作记录
	ReviewTasks          ReviewTaskRepository         // 审阅影子任务
	TaskExceptions       TaskExceptionRepository      // 任务异常
	CompleteToActivities CompleteToActivityRepository // 直送记录
	TaskDelegates        TaskDelegateRepository       // 委托规则主表
	TaskConsigners       TaskConsignersRepository     // 被委托人
	TaskConsignObjs      TaskConsignObjRepository     // 委托对象
	Reminds              RemindRepository             // 催办配置
	RemindTargets        RemindTargetRepository       // 催办对象
}

Repositories 聚合全部 workflow 表仓储，便于调用方一次构建后按域访问。

func NewRepositories 

func NewRepositories(store *Store) *Repositories

NewRepositories 按仓储入口构建全部 workflow 表仓储。 @param store 仓储入口 @return 聚合仓储

type ReviewTaskRepository 

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

ReviewTaskRepository 是 workflow_review_task（审阅/知会影子任务）的仓储。

func NewReviewTaskRepository 

func NewReviewTaskRepository(store *Store) ReviewTaskRepository

NewReviewTaskRepository 创建 workflow_review_task 仓储。 @param store 仓储入口 @return 仓储

func (ReviewTaskRepository) DeleteByPK 

func (b ReviewTaskRepository) DeleteByPK(ctx context.Context, id string) (int64, error)

DeleteByPK 按主键删除一行。 @param ctx 操作上下文 @param id 主键 @return 影响行数 @return 删除错误

func (ReviewTaskRepository) GetByPK 

func (b ReviewTaskRepository) GetByPK(ctx context.Context, id string) (Row, bool, error)

GetByPK 按主键查询单行。 @param ctx 操作上下文 @param id 主键 @return 行数据（列名→值） @return 是否存在 @return 查询错误

func (ReviewTaskRepository) GetByTask 

func (r ReviewTaskRepository) GetByTask(ctx context.Context, taskID string) (Row, bool, error)

GetByTask 按任务 ID 查询审阅任务。 @param ctx 操作上下文 @param taskID 任务 ID @return 行数据 @return 是否存在 @return 查询错误

func (ReviewTaskRepository) Insert 

func (b ReviewTaskRepository) Insert(ctx context.Context, row Row) error

Insert 插入一行；id 必须由调用方生成传入（internal/idgen），本层不生成。 @param ctx 操作上下文 @param row 行数据 @return 插入错误

func (ReviewTaskRepository) ListByProcessInstance 

func (r ReviewTaskRepository) ListByProcessInstance(ctx context.Context, processInstanceID string) ([]Row, error)

ListByProcessInstance 查询实例的审阅任务。 @param ctx 操作上下文 @param processInstanceID 流程实例 ID @return 行列表 @return 查询错误

func (ReviewTaskRepository) ListPendingByReviewer 

func (r ReviewTaskRepository) ListPendingByReviewer(ctx context.Context, reviewer string) ([]Row, error)

ListPendingByReviewer 查询审阅人的未审任务（status=0）。 @param ctx 操作上下文 @param reviewer 审阅人 ID @return 行列表 @return 查询错误

func (ReviewTaskRepository) MarkReviewed 

func (r ReviewTaskRepository) MarkReviewed(ctx context.Context, id, opinion string, reviewTime any) (int64, error)

MarkReviewed 完成审阅：置已审状态、回写意见与审阅时间。 @param ctx 操作上下文 @param id 审阅任务 ID @param opinion 审阅意见 @param reviewTime 审阅时间 @return 影响行数 @return 更新错误

func (ReviewTaskRepository) UpdateByPK 

func (b ReviewTaskRepository) UpdateByPK(ctx context.Context, id string, changes Row) (int64, error)

UpdateByPK 按主键更新指定列；update_time 缺省时自动填充，id 列不可修改。 @param ctx 操作上下文 @param id 主键 @param changes 变更列 @return 影响行数 @return 更新错误

type Row 

type Row map[string]any

Row 是一行数据的通用载体：键为列名（与 DDL 一致的小写下划线名），值为可入库的 Go 值。

type StepRepository 

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

StepRepository 是 workflow_step（设计时步骤配置）的仓储。

func NewStepRepository 

func NewStepRepository(store *Store) StepRepository

NewStepRepository 创建 workflow_step 仓储。 @param store 仓储入口 @return 仓储

func (StepRepository) DeleteByPK 

func (b StepRepository) DeleteByPK(ctx context.Context, id string) (int64, error)

DeleteByPK 按主键删除一行。 @param ctx 操作上下文 @param id 主键 @return 影响行数 @return 删除错误

func (StepRepository) GetByModelAndStepCode 

func (r StepRepository) GetByModelAndStepCode(ctx context.Context, modelID, stepCode string) (Row, bool, error)

GetByModelAndStepCode 按步骤代号查询单个步骤配置。 @param ctx 操作上下文 @param modelID 模型 ID @param stepCode 步骤代号 @return 行数据 @return 是否存在 @return 查询错误

func (StepRepository) GetByPK 

func (b StepRepository) GetByPK(ctx context.Context, id string) (Row, bool, error)

GetByPK 按主键查询单行。 @param ctx 操作上下文 @param id 主键 @return 行数据（列名→值） @return 是否存在 @return 查询错误

func (StepRepository) Insert 

func (b StepRepository) Insert(ctx context.Context, row Row) error

Insert 插入一行；id 必须由调用方生成传入（internal/idgen），本层不生成。 @param ctx 操作上下文 @param row 行数据 @return 插入错误

func (StepRepository) ListByModel 

func (r StepRepository) ListByModel(ctx context.Context, modelID string) ([]Row, error)

ListByModel 查询模型下全部步骤配置（按 sort 升序）。 @param ctx 操作上下文 @param modelID 模型 ID @return 行列表 @return 查询错误

func (StepRepository) UpdateByPK 

func (b StepRepository) UpdateByPK(ctx context.Context, id string, changes Row) (int64, error)

UpdateByPK 按主键更新指定列；update_time 缺省时自动填充，id 列不可修改。 @param ctx 操作上下文 @param id 主键 @param changes 变更列 @return 影响行数 @return 更新错误

type Store 

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

Store 是 workflow_* 表仓储入口，持有连接池、方言与时间源。

func NewStore 

func NewStore(db *sql.DB, dialect string, options ...Option) (*Store, error)

NewStore 创建 workflow 仓储入口。 @param db 数据库连接池（与引擎共享同一连接池） @param dialect 数据库方言（mysql/postgres） @param options 可选配置 @return 仓储入口 @return 方言非法或 db 为空错误

func (*Store) Dialect 

func (s *Store) Dialect() string

Dialect 返回仓储方言。 @return 方言名

func (*Store) Now 

func (s *Store) Now() time.Time

Now 返回仓储统一时间源的当前时间。 @return 当前时间

func (*Store) WithTx 

func (s *Store) WithTx(ctx context.Context, fn func(ctx context.Context) error) error

WithTx 在独立事务中执行 fn，fn 通过 ctx 获得同一事务实现多表原子提交； fn 返回错误或 panic 时整体回滚，否则提交。已在事务中时直接复用当前事务（不嵌套开启）。 @param ctx 操作上下文 @param fn 事务体逻辑 @return fn 的错误或事务开启/提交错误

type TaskConsignObjRepository 

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

TaskConsignObjRepository 是 workflow_task_consign_obj（委托对象）的仓储。

func NewTaskConsignObjRepository 

func NewTaskConsignObjRepository(store *Store) TaskConsignObjRepository

NewTaskConsignObjRepository 创建 workflow_task_consign_obj 仓储。 @param store 仓储入口 @return 仓储

func (TaskConsignObjRepository) DeleteByDelegate 

func (r TaskConsignObjRepository) DeleteByDelegate(ctx context.Context, delegateID string) (int64, error)

DeleteByDelegate 删除委托规则的全部委托对象（规则重建时先删后增）。 @param ctx 操作上下文 @param delegateID 委托规则 ID @return 影响行数 @return 删除错误

func (TaskConsignObjRepository) DeleteByPK 

func (b TaskConsignObjRepository) DeleteByPK(ctx context.Context, id string) (int64, error)

DeleteByPK 按主键删除一行。 @param ctx 操作上下文 @param id 主键 @return 影响行数 @return 删除错误

func (TaskConsignObjRepository) GetByPK 

func (b TaskConsignObjRepository) GetByPK(ctx context.Context, id string) (Row, bool, error)

GetByPK 按主键查询单行。 @param ctx 操作上下文 @param id 主键 @return 行数据（列名→值） @return 是否存在 @return 查询错误

func (TaskConsignObjRepository) Insert 

func (b TaskConsignObjRepository) Insert(ctx context.Context, row Row) error

Insert 插入一行；id 必须由调用方生成传入（internal/idgen），本层不生成。 @param ctx 操作上下文 @param row 行数据 @return 插入错误

func (TaskConsignObjRepository) ListByDelegate 

func (r TaskConsignObjRepository) ListByDelegate(ctx context.Context, delegateID string) ([]Row, error)

ListByDelegate 查询委托规则的委托对象列表。 @param ctx 操作上下文 @param delegateID 委托规则 ID @return 行列表 @return 查询错误

func (TaskConsignObjRepository) UpdateByPK 

func (b TaskConsignObjRepository) UpdateByPK(ctx context.Context, id string, changes Row) (int64, error)

UpdateByPK 按主键更新指定列；update_time 缺省时自动填充，id 列不可修改。 @param ctx 操作上下文 @param id 主键 @param changes 变更列 @return 影响行数 @return 更新错误

type TaskConsignersRepository 

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

TaskConsignersRepository 是 workflow_task_consigners（被委托人）的仓储。

func NewTaskConsignersRepository 

func NewTaskConsignersRepository(store *Store) TaskConsignersRepository

NewTaskConsignersRepository 创建 workflow_task_consigners 仓储。 @param store 仓储入口 @return 仓储

func (TaskConsignersRepository) DeleteByDelegate 

func (r TaskConsignersRepository) DeleteByDelegate(ctx context.Context, delegateID string) (int64, error)

DeleteByDelegate 删除委托规则的全部被委托人（规则重建时先删后增）。 @param ctx 操作上下文 @param delegateID 委托规则 ID @return 影响行数 @return 删除错误

func (TaskConsignersRepository) DeleteByPK 

func (b TaskConsignersRepository) DeleteByPK(ctx context.Context, id string) (int64, error)

DeleteByPK 按主键删除一行。 @param ctx 操作上下文 @param id 主键 @return 影响行数 @return 删除错误

func (TaskConsignersRepository) GetByPK 

func (b TaskConsignersRepository) GetByPK(ctx context.Context, id string) (Row, bool, error)

GetByPK 按主键查询单行。 @param ctx 操作上下文 @param id 主键 @return 行数据（列名→值） @return 是否存在 @return 查询错误

func (TaskConsignersRepository) Insert 

func (b TaskConsignersRepository) Insert(ctx context.Context, row Row) error

Insert 插入一行；id 必须由调用方生成传入（internal/idgen），本层不生成。 @param ctx 操作上下文 @param row 行数据 @return 插入错误

func (TaskConsignersRepository) ListByDelegate 

func (r TaskConsignersRepository) ListByDelegate(ctx context.Context, delegateID string) ([]Row, error)

ListByDelegate 查询委托规则的被委托人列表。 @param ctx 操作上下文 @param delegateID 委托规则 ID @return 行列表 @return 查询错误

func (TaskConsignersRepository) UpdateByPK 

func (b TaskConsignersRepository) UpdateByPK(ctx context.Context, id string, changes Row) (int64, error)

UpdateByPK 按主键更新指定列；update_time 缺省时自动填充，id 列不可修改。 @param ctx 操作上下文 @param id 主键 @param changes 变更列 @return 影响行数 @return 更新错误

type TaskDelegateRepository 

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

TaskDelegateRepository 是 workflow_task_delegate（委托规则主表）的仓储。 condition 为保留字列（MySQL 反引号 / PostgreSQL 双引号），vaild_from/vaild_to 保留 Java 拼写。

func NewTaskDelegateRepository 

func NewTaskDelegateRepository(store *Store) TaskDelegateRepository

NewTaskDelegateRepository 创建 workflow_task_delegate 仓储。 @param store 仓储入口 @return 仓储

func (TaskDelegateRepository) DeleteByPK 

func (b TaskDelegateRepository) DeleteByPK(ctx context.Context, id string) (int64, error)

DeleteByPK 按主键删除一行。 @param ctx 操作上下文 @param id 主键 @return 影响行数 @return 删除错误

func (TaskDelegateRepository) GetByPK 

func (b TaskDelegateRepository) GetByPK(ctx context.Context, id string) (Row, bool, error)

GetByPK 按主键查询单行。 @param ctx 操作上下文 @param id 主键 @return 行数据（列名→值） @return 是否存在 @return 查询错误

func (TaskDelegateRepository) Insert 

func (b TaskDelegateRepository) Insert(ctx context.Context, row Row) error

Insert 插入一行；id 必须由调用方生成传入（internal/idgen），本层不生成。 @param ctx 操作上下文 @param row 行数据 @return 插入错误

func (TaskDelegateRepository) ListByOwner 

func (r TaskDelegateRepository) ListByOwner(ctx context.Context, ownerID string) ([]Row, error)

ListByOwner 查询委托人启用的委托规则（命中优先级由服务层按范围类型计算）。 @param ctx 操作上下文 @param ownerID 委托人 ID @return 行列表 @return 查询错误

func (TaskDelegateRepository) ListBySourceCode 

func (r TaskDelegateRepository) ListBySourceCode(ctx context.Context, sourceCode string) ([]Row, error)

ListBySourceCode 按来源租户/系统查询委托规则。 @param ctx 操作上下文 @param sourceCode 来源代号 @return 行列表 @return 查询错误

func (TaskDelegateRepository) Retire 

func (r TaskDelegateRepository) Retire(ctx context.Context, id string) (int64, error)

Retire 按主键退休委托规则（retire=1，退休委托语义）。 @param ctx 操作上下文 @param id 委托规则 ID @return 影响行数 @return 更新错误

func (TaskDelegateRepository) UpdateByPK 

func (b TaskDelegateRepository) UpdateByPK(ctx context.Context, id string, changes Row) (int64, error)

UpdateByPK 按主键更新指定列；update_time 缺省时自动填充，id 列不可修改。 @param ctx 操作上下文 @param id 主键 @param changes 变更列 @return 影响行数 @return 更新错误

type TaskExceptionRepository 

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

TaskExceptionRepository 是 workflow_task_exception（任务异常落库）的仓储。 handle_status：0 未处理、1 已处理（Go 侧新增的异常处理状态列）。

func NewTaskExceptionRepository 

func NewTaskExceptionRepository(store *Store) TaskExceptionRepository

NewTaskExceptionRepository 创建 workflow_task_exception 仓储。 @param store 仓储入口 @return 仓储

func (TaskExceptionRepository) DeleteByPK 

func (b TaskExceptionRepository) DeleteByPK(ctx context.Context, id string) (int64, error)

DeleteByPK 按主键删除一行。 @param ctx 操作上下文 @param id 主键 @return 影响行数 @return 删除错误

func (TaskExceptionRepository) GetByPK 

func (b TaskExceptionRepository) GetByPK(ctx context.Context, id string) (Row, bool, error)

GetByPK 按主键查询单行。 @param ctx 操作上下文 @param id 主键 @return 行数据（列名→值） @return 是否存在 @return 查询错误

func (TaskExceptionRepository) Insert 

func (b TaskExceptionRepository) Insert(ctx context.Context, row Row) error

Insert 插入一行；id 必须由调用方生成传入（internal/idgen），本层不生成。 @param ctx 操作上下文 @param row 行数据 @return 插入错误

func (TaskExceptionRepository) ListByProcessInstance 

func (r TaskExceptionRepository) ListByProcessInstance(ctx context.Context, processInstanceID string) ([]Row, error)

ListByProcessInstance 查询实例的异常记录。 @param ctx 操作上下文 @param processInstanceID 流程实例 ID @return 行列表 @return 查询错误

func (TaskExceptionRepository) ListByTask 

func (r TaskExceptionRepository) ListByTask(ctx context.Context, taskID string) ([]Row, error)

ListByTask 查询任务的异常记录。 @param ctx 操作上下文 @param taskID 任务 ID @return 行列表 @return 查询错误

func (TaskExceptionRepository) ListUnhandled 

func (r TaskExceptionRepository) ListUnhandled(ctx context.Context) ([]Row, error)

ListUnhandled 查询未处理异常（handle_status=0，管理台重发与僵尸监控数据源）。 @param ctx 操作上下文 @return 行列表 @return 查询错误

func (TaskExceptionRepository) MarkHandled 

func (r TaskExceptionRepository) MarkHandled(ctx context.Context, id string) (int64, error)

MarkHandled 标记异常已处理（管理台重发成功后调用）。 @param ctx 操作上下文 @param id 异常记录 ID @return 影响行数 @return 更新错误

func (TaskExceptionRepository) UpdateByPK 

func (b TaskExceptionRepository) UpdateByPK(ctx context.Context, id string, changes Row) (int64, error)

UpdateByPK 按主键更新指定列；update_time 缺省时自动填充，id 列不可修改。 @param ctx 操作上下文 @param id 主键 @param changes 变更列 @return 影响行数 @return 更新错误

type TemplateRepository 

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

TemplateRepository 是 workflow_template（设计器模板）的仓储。

func NewTemplateRepository 

func NewTemplateRepository(store *Store) TemplateRepository

NewTemplateRepository 创建 workflow_template 仓储。 @param store 仓储入口 @return 仓储

func (TemplateRepository) DeleteByPK 

func (b TemplateRepository) DeleteByPK(ctx context.Context, id string) (int64, error)

DeleteByPK 按主键删除一行。 @param ctx 操作上下文 @param id 主键 @return 影响行数 @return 删除错误

func (TemplateRepository) GetByPK 

func (b TemplateRepository) GetByPK(ctx context.Context, id string) (Row, bool, error)

GetByPK 按主键查询单行。 @param ctx 操作上下文 @param id 主键 @return 行数据（列名→值） @return 是否存在 @return 查询错误

func (TemplateRepository) Insert 

func (b TemplateRepository) Insert(ctx context.Context, row Row) error

Insert 插入一行；id 必须由调用方生成传入（internal/idgen），本层不生成。 @param ctx 操作上下文 @param row 行数据 @return 插入错误

func (TemplateRepository) ListByCategory 

func (r TemplateRepository) ListByCategory(ctx context.Context, categoryID string) ([]Row, error)

ListByCategory 查询分类下的设计器模板。 @param ctx 操作上下文 @param categoryID 分类 ID @return 行列表 @return 查询错误

func (TemplateRepository) ListDefault 

func (r TemplateRepository) ListDefault(ctx context.Context) ([]Row, error)

ListDefault 查询默认模板。 @param ctx 操作上下文 @return 行列表 @return 查询错误

func (TemplateRepository) UpdateByPK 

func (b TemplateRepository) UpdateByPK(ctx context.Context, id string, changes Row) (int64, error)

UpdateByPK 按主键更新指定列；update_time 缺省时自动填充，id 列不可修改。 @param ctx 操作上下文 @param id 主键 @param changes 变更列 @return 影响行数 @return 更新错误

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.