Package com.codingapi.flow.context

Class RepositoryHolderContext

java.lang.Object

com.codingapi.flow.context.RepositoryHolderContext

All Implemented Interfaces:

IRepositoryHolder

public class RepositoryHolderContext
extends Object
implements IRepositoryHolder

流程引擎仓库持有者上下文,负责持有流程引擎相关的仓库实例,并提供相关服务的构建方法

Method Summary

Modifier and Type	Method	Description
void	addParallelTriggerCount(String parallelId)	添加并发流程的触发总数
void	clearParallelTriggerCount(String parallelId)	清空流程并发的触发总数
FlowDelayTriggerService	createDelayTriggerService(DelayTask task)	构建延迟触发执行服务
FlowActionService	createFlowActionService(FlowSession flowSession)	构建流程动作服务
FlowService	createFlowService()	构建流程服务
void	deleteDelayTask(DelayTask delayTask)	删除延迟任务
List<FlowRecord>	findAfterRecords(String processId, long currentId)	查询后续的流程记录
List<Long>	findAssignedOperatorIds(String processId, String nodeId)	查询节点已分配的操作人 ID 列表
List<FlowRecord>	findCurrentNodeRecords(long fromId, String nodeId)	查询当前的节点下的流程记录
List<DelayTask>	findDelayTasks()	获取延迟任务
List<IFlowOperator>	findOperatorByIds(List<Long> ids)	获取流程操作人
List<FlowRecord>	findProcessRecords(String processId)	查询当前流程标识下的流程记录
UrgeInterval	getLatestUrgeInterval(String processId, long recordId)	获取最新的催办控制对象
IFlowOperator	getOperatorById(long id)	获取流程操作人
int	getParallelBranchTriggerCount(String parallelId)	获取并行分支的触发总数
FlowRecord	getRecordById(long id)	获取流程详情
boolean	isRegistered()	是否已经注册成功
void	register(WorkflowService workflowService, FlowRecordService flowRecordService, FlowOperatorGateway flowOperatorGateway, ParallelBranchRepository parallelBranchRepository, DelayTaskRepository delayTaskRepository, UrgeIntervalRepository urgeIntervalRepository, FlowOperatorAssignmentRepository flowOperatorAssignmentRepository)
void	saveDelayTask(DelayTask delayTask)	保存延迟任务
void	saveOperatorAssignment(String processId, String nodeId, List<Long> operatorIds)	保存节点操作人手动分配信息
void	saveRecord(FlowRecord flowRecord)	流程记录
void	saveRecords(List<FlowRecord> flowRecords)	流程记录列表
void	saveUrgeInterval(UrgeInterval interval)	保存催办控制
void	verify()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.codingapi.flow.session.IRepositoryHolder

getFlowOperatorGateway, getFlowRecordService, getWorkflowService

Method Details

isRegistered

public boolean isRegistered()

是否已经注册成功

verify

public void verify()

register

public void register(WorkflowService workflowService,
 FlowRecordService flowRecordService,
 FlowOperatorGateway flowOperatorGateway,
 ParallelBranchRepository parallelBranchRepository,
 DelayTaskRepository delayTaskRepository,
 UrgeIntervalRepository urgeIntervalRepository,
 FlowOperatorAssignmentRepository flowOperatorAssignmentRepository)

createDelayTriggerService

public FlowDelayTriggerService createDelayTriggerService(DelayTask task)

构建延迟触发执行服务

Specified by:

createDelayTriggerService in interface IRepositoryHolder

Parameters:

task - 延迟任务

Returns:

延迟触发执行服务

createFlowActionService

public FlowActionService createFlowActionService(FlowSession flowSession)

构建流程动作服务

Specified by:

createFlowActionService in interface IRepositoryHolder

Parameters:

flowSession - 流程会话

Returns:

流程动作服务

createFlowService

public FlowService createFlowService()

构建流程服务

Specified by:

createFlowService in interface IRepositoryHolder

Returns:

流程服务

getRecordById

public FlowRecord getRecordById(long id)

Description copied from interface: IRepositoryHolder

获取流程详情

Specified by:

getRecordById in interface IRepositoryHolder

Returns:

流程详情

findOperatorByIds

public List<IFlowOperator> findOperatorByIds(List<Long> ids)

Description copied from interface: IRepositoryHolder

获取流程操作人

Specified by:

findOperatorByIds in interface IRepositoryHolder

Parameters:

ids - 流程人Id

Returns:

流程操作人

getOperatorById

public IFlowOperator getOperatorById(long id)

Description copied from interface: IRepositoryHolder

获取流程操作人

Specified by:

getOperatorById in interface IRepositoryHolder

Parameters:

id - 人员id

Returns:

流程操作人

saveDelayTask

public void saveDelayTask(DelayTask delayTask)

Description copied from interface: IRepositoryHolder

保存延迟任务

Specified by:

saveDelayTask in interface IRepositoryHolder

Parameters:

delayTask - 延迟任务

deleteDelayTask

public void deleteDelayTask(DelayTask delayTask)

Description copied from interface: IRepositoryHolder

删除延迟任务

Specified by:

deleteDelayTask in interface IRepositoryHolder

Parameters:

delayTask - 延迟任务

saveRecords

public void saveRecords(List<FlowRecord> flowRecords)

Description copied from interface: IRepositoryHolder

流程记录列表

Specified by:

saveRecords in interface IRepositoryHolder

Parameters:

flowRecords - 流程记录

saveRecord

public void saveRecord(FlowRecord flowRecord)

Description copied from interface: IRepositoryHolder

流程记录

Specified by:

saveRecord in interface IRepositoryHolder

Parameters:

flowRecord - 流程记录

findCurrentNodeRecords

public List<FlowRecord> findCurrentNodeRecords(long fromId,
 String nodeId)

Description copied from interface: IRepositoryHolder

查询当前的节点下的流程记录

Specified by:

findCurrentNodeRecords in interface IRepositoryHolder

Parameters:

fromId - 上级流程

nodeId - 节点id

Returns:

流程记录

findProcessRecords

public List<FlowRecord> findProcessRecords(String processId)

Description copied from interface: IRepositoryHolder

查询当前流程标识下的流程记录

Specified by:

findProcessRecords in interface IRepositoryHolder

Parameters:

processId - 当前流程标识

Returns:

流程记录

findAfterRecords

public List<FlowRecord> findAfterRecords(String processId,
 long currentId)

Description copied from interface: IRepositoryHolder

查询后续的流程记录

Specified by:

findAfterRecords in interface IRepositoryHolder

Parameters:

processId - 当前流程标识

currentId - 当前流程id

Returns:

流程记录

getParallelBranchTriggerCount

public int getParallelBranchTriggerCount(String parallelId)

Description copied from interface: IRepositoryHolder

获取并行分支的触发总数

Specified by:

getParallelBranchTriggerCount in interface IRepositoryHolder

Parameters:

parallelId - 并行id

Returns:

数量

addParallelTriggerCount

public void addParallelTriggerCount(String parallelId)

Description copied from interface: IRepositoryHolder

添加并发流程的触发总数

Specified by:

addParallelTriggerCount in interface IRepositoryHolder

Parameters:

parallelId - 并行id

clearParallelTriggerCount

public void clearParallelTriggerCount(String parallelId)

Description copied from interface: IRepositoryHolder

清空流程并发的触发总数

Specified by:

clearParallelTriggerCount in interface IRepositoryHolder

Parameters:

parallelId - 并行id

findDelayTasks

public List<DelayTask> findDelayTasks()

Description copied from interface: IRepositoryHolder

获取延迟任务

Specified by:

findDelayTasks in interface IRepositoryHolder

Returns:

延迟任务列表

saveUrgeInterval

public void saveUrgeInterval(UrgeInterval interval)

Description copied from interface: IRepositoryHolder

保存催办控制

Specified by:

saveUrgeInterval in interface IRepositoryHolder

Parameters:

interval - 催办间隔控制

getLatestUrgeInterval

public UrgeInterval getLatestUrgeInterval(String processId,
 long recordId)

Description copied from interface: IRepositoryHolder

获取最新的催办控制对象

Specified by:

getLatestUrgeInterval in interface IRepositoryHolder

Parameters:

processId - 任务唯一标识

recordId - 当前流程id

Returns:

催办间隔控制

saveOperatorAssignment

public void saveOperatorAssignment(String processId,
 String nodeId,
 List<Long> operatorIds)

Description copied from interface: IRepositoryHolder

保存节点操作人手动分配信息

Specified by:

saveOperatorAssignment in interface IRepositoryHolder

Parameters:

processId - 流程实例唯一标识

nodeId - 节点 ID

operatorIds - 操作人 ID 列表

findAssignedOperatorIds

public List<Long> findAssignedOperatorIds(String processId,
 String nodeId)

Description copied from interface: IRepositoryHolder

查询节点已分配的操作人 ID 列表

Specified by:

findAssignedOperatorIds in interface IRepositoryHolder

Parameters:

processId - 流程实例唯一标识

nodeId - 节点 ID

Returns:

操作人 ID 列表（未分配时返回空列表）