Package com.codingapi.flow.context

Class RepositoryHolderContext

java.lang.Object

com.codingapi.flow.context.RepositoryHolderContext

public class RepositoryHolderContext
extends Object

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

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<FlowRecord>	findCurrentNodeRecords(long fromId, String nodeId)
List<DelayTask>	findDelayTasks()
List<IFlowOperator>	findOperatorByIds(List<Long> ids)
List<FlowRecord>	findProcessRecords(String processId)
IFlowOperator	getOperatorById(long id)
int	getParallelBranchTriggerCount(String parallelId)
FlowRecord	getRecordById(long id)
boolean	isRegistered()	是否已经注册成功
void	register(WorkflowRepository workflowRepository, WorkflowBackupRepository workflowBackupRepository, FlowRecordRepository flowRecordRepository, FlowTodoRecordRepository flowTodoRecordRepository, FlowTodoMergeRepository flowTodoMergeRepository, FlowOperatorGateway flowOperatorGateway, ParallelBranchRepository parallelBranchRepository, DelayTaskRepository delayTaskRepository, UrgeIntervalRepository urgeIntervalRepository)
void	saveDelayTask(DelayTask delayTask)
void	saveRecord(FlowRecord flowRecord)
void	saveRecords(List<FlowRecord> flowRecords)
void	verify()

Methods inherited from class java.lang.Object

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

Method Details

isRegistered

public boolean isRegistered()

是否已经注册成功

verify

public void verify()

register

public void register(WorkflowRepository workflowRepository,
 WorkflowBackupRepository workflowBackupRepository,
 FlowRecordRepository flowRecordRepository,
 FlowTodoRecordRepository flowTodoRecordRepository,
 FlowTodoMergeRepository flowTodoMergeRepository,
 FlowOperatorGateway flowOperatorGateway,
 ParallelBranchRepository parallelBranchRepository,
 DelayTaskRepository delayTaskRepository,
 UrgeIntervalRepository urgeIntervalRepository)

createDelayTriggerService

public FlowDelayTriggerService createDelayTriggerService(DelayTask task)

构建延迟触发执行服务

Parameters:

task - 延迟任务

Returns:

延迟触发执行服务

createFlowActionService

public FlowActionService createFlowActionService(FlowSession flowSession)

构建流程动作服务

Parameters:

flowSession - 流程会话

Returns:

流程动作服务

createFlowService

public FlowService createFlowService()

构建流程服务

Returns:

流程服务

getRecordById

public FlowRecord getRecordById(long id)

findOperatorByIds

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

getOperatorById

public IFlowOperator getOperatorById(long id)

saveDelayTask

public void saveDelayTask(DelayTask delayTask)

deleteDelayTask

public void deleteDelayTask(DelayTask delayTask)

saveRecords

public void saveRecords(List<FlowRecord> flowRecords)

saveRecord

public void saveRecord(FlowRecord flowRecord)

findCurrentNodeRecords

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

findProcessRecords

public List<FlowRecord> findProcessRecords(String processId)

findAfterRecords

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

getParallelBranchTriggerCount

public int getParallelBranchTriggerCount(String parallelId)

addParallelTriggerCount

public void addParallelTriggerCount(String parallelId)

clearParallelTriggerCount

public void clearParallelTriggerCount(String parallelId)

findDelayTasks

public List<DelayTask> findDelayTasks()