org.apache.syncope.core.flowable.impl

Class FlowableUserRequestHandler

java.lang.Object

org.apache.syncope.core.flowable.impl.FlowableUserRequestHandler

All Implemented Interfaces:

UserRequestHandler

@Transactional(propagation=REQUIRES_NEW,
               rollbackFor=java.lang.Throwable.class)
public class FlowableUserRequestHandler
extends Object
implements UserRequestHandler

Field Summary

Fields

Modifier and Type	Field and Description
protected String	adminUser
protected UserDataBinder	dataBinder
protected DomainProcessEngine	engine
protected EntityFactory	entityFactory
protected static org.slf4j.Logger	LOG
protected UserDAO	userDAO
protected WorkflowTaskManager	wfTaskManager

Constructor Summary

Constructors

Constructor and Description
FlowableUserRequestHandler()

Method Summary

Modifier and Type	Method and Description
void	cancel(org.flowable.engine.runtime.ProcessInstance procInst, String reason) Cancel a running user request.
void	cancelByProcessDefinition(String processDefinitionId) Cancel all running user requests for the given process definition id.
void	cancelByUser(AnyLifecycleEvent<Any<?>> event) Cancel all running user requests for the user in the given delete event.
UserRequestForm	claimForm(String taskId) Claim a form for a given object.
protected int	countProcessInstances(StringBuilder processInstanceQuery)
protected StringBuilder	createProcessInstanceQuery(String userKey)
protected UserRequestFormPropertyType	fromFlowableFormType(org.flowable.engine.form.FormType flowableFormType)
protected UserRequestForm	getForm(org.flowable.task.api.history.HistoricTaskInstance task)
UserRequestForm	getForm(String userKey, String taskId) Get the form matching the provided task id.
protected UserRequestForm	getForm(String procInstId, String taskId, String formKey, List<org.flowable.engine.form.FormProperty> props)
protected UserRequestForm	getForm(org.flowable.task.api.Task task)
protected UserRequestForm	getForm(org.flowable.task.api.Task task, org.flowable.engine.form.TaskFormData fd)
Pair<Integer,List<UserRequestForm>>	getForms(String userKey, int page, int size, List<OrderByClause> ob) Get the forms matching the provided parameters.
protected Pair<Integer,List<UserRequestForm>>	getForms(org.flowable.task.api.TaskQuery query, int page, int size, List<OrderByClause> orderByClauses)
protected UserRequestForm	getHistoricFormTO(String procInstId, String taskId, String formKey, List<org.flowable.engine.impl.persistence.entity.HistoricFormPropertyEntity> props)
protected <T> T	getHistoricVariable(List<org.flowable.variable.api.history.HistoricVariableInstance> historicVariables, String name, Class<T> valueRef)
protected Map<String,String>	getPropertiesForSubmit(UserRequestForm form)
protected org.flowable.task.api.Task	getTask(String taskId)
protected String	getUserKey(String procInstId)
protected UserRequest	getUserRequest(org.flowable.engine.runtime.ProcessInstance procInst)
Pair<Integer,List<UserRequest>>	getUserRequests(String userKey, int page, int size, List<OrderByClause> orderByClauses) Get the running user requests matching the provided parameters.
protected User	lazyLoad(User user)
Pair<org.flowable.engine.runtime.ProcessInstance,String>	parse(String executionId) Parses the given execution id to find matching user request and owner.
protected Pair<org.flowable.task.api.Task,org.flowable.engine.form.TaskFormData>	parseTask(String taskId)
UserRequest	start(String bpmnProcess, User user, WorkflowTaskExecInput inputVariables) Starts a new user request, for the given BPMN process and user.
UserWorkflowResult<UserPatch>	submitForm(UserRequestForm form) Submit a form.
UserRequestForm	unclaimForm(String taskId) Unclaim a form for a given object.

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final org.slf4j.Logger LOG

wfTaskManager

@Autowired
protected WorkflowTaskManager wfTaskManager

dataBinder

@Autowired
protected UserDataBinder dataBinder

adminUser

protected String adminUser

engine

@Autowired
protected DomainProcessEngine engine

userDAO

@Autowired
protected UserDAO userDAO

entityFactory

@Autowired
protected EntityFactory entityFactory

Constructor Detail

FlowableUserRequestHandler

public FlowableUserRequestHandler()

Method Detail

createProcessInstanceQuery

protected StringBuilder createProcessInstanceQuery(String userKey)

countProcessInstances

protected int countProcessInstances(StringBuilder processInstanceQuery)

getUserRequest

protected UserRequest getUserRequest(org.flowable.engine.runtime.ProcessInstance procInst)

getUserRequests

@Transactional(readOnly=true)
public Pair<Integer,List<UserRequest>> getUserRequests(String userKey,
                                                                                     int page,
                                                                                     int size,
                                                                                     List<OrderByClause> orderByClauses)

Description copied from interface: UserRequestHandler

Get the running user requests matching the provided parameters.

Specified by:

getUserRequests in interface UserRequestHandler

Parameters:

userKey - user key (optional)

page - result page

size - items per page

orderByClauses - sort conditions

Returns:

total number of user requests, list of user requests matching the provided parameters

lazyLoad

protected User lazyLoad(User user)

start

public UserRequest start(String bpmnProcess,
                         User user,
                         WorkflowTaskExecInput inputVariables)

Description copied from interface: UserRequestHandler

Starts a new user request, for the given BPMN process and user.

Specified by:

start in interface UserRequestHandler

Parameters:

bpmnProcess - BPMN process

user - user

inputVariables - variables

Returns:

data about the started request service, including execution id

parse

public Pair<org.flowable.engine.runtime.ProcessInstance,String> parse(String executionId)

Description copied from interface: UserRequestHandler

Parses the given execution id to find matching user request and owner.

Specified by:

parse in interface UserRequestHandler

Parameters:

executionId - execution id

Returns:

matching user request and owner

cancel

public void cancel(org.flowable.engine.runtime.ProcessInstance procInst,
                   String reason)

Description copied from interface: UserRequestHandler

Cancel a running user request.

Specified by:

cancel in interface UserRequestHandler

Parameters:

procInst - process instance for user request

reason - reason to cancel the user request

cancelByProcessDefinition

public void cancelByProcessDefinition(String processDefinitionId)

Description copied from interface: UserRequestHandler

Cancel all running user requests for the given process definition id.

Specified by:

cancelByProcessDefinition in interface UserRequestHandler

Parameters:

processDefinitionId - process definition id

cancelByUser

public void cancelByUser(AnyLifecycleEvent<Any<?>> event)

Description copied from interface: UserRequestHandler

Cancel all running user requests for the user in the given delete event.

Specified by:

cancelByUser in interface UserRequestHandler

Parameters:

event - delete event

fromFlowableFormType

protected UserRequestFormPropertyType fromFlowableFormType(org.flowable.engine.form.FormType flowableFormType)

getForm

protected UserRequestForm getForm(org.flowable.task.api.Task task)

getForm

protected UserRequestForm getForm(org.flowable.task.api.Task task,
                                  org.flowable.engine.form.TaskFormData fd)

getForm

protected UserRequestForm getForm(org.flowable.task.api.history.HistoricTaskInstance task)

getUserKey

protected String getUserKey(String procInstId)

getHistoricFormTO

protected UserRequestForm getHistoricFormTO(String procInstId,
                                            String taskId,
                                            String formKey,
                                            List<org.flowable.engine.impl.persistence.entity.HistoricFormPropertyEntity> props)

getForm

protected UserRequestForm getForm(String procInstId,
                                  String taskId,
                                  String formKey,
                                  List<org.flowable.engine.form.FormProperty> props)

getForm

public UserRequestForm getForm(String userKey,
                               String taskId)

Description copied from interface: UserRequestHandler

Get the form matching the provided task id.

Specified by:

getForm in interface UserRequestHandler

Parameters:

userKey - user key

taskId - task id

Returns:

the form for the given task id

getForms

@Transactional(readOnly=true)
public Pair<Integer,List<UserRequestForm>> getForms(String userKey,
                                                                                  int page,
                                                                                  int size,
                                                                                  List<OrderByClause> ob)

Description copied from interface: UserRequestHandler

Get the forms matching the provided parameters.

Specified by:

getForms in interface UserRequestHandler

Parameters:

userKey - user key (optional)

page - result page

size - items per page

ob - sort conditions

Returns:

total number of forms, list of forms matching the provided parameters

getForms

protected Pair<Integer,List<UserRequestForm>> getForms(org.flowable.task.api.TaskQuery query,
                                                       int page,
                                                       int size,
                                                       List<OrderByClause> orderByClauses)

parseTask

protected Pair<org.flowable.task.api.Task,org.flowable.engine.form.TaskFormData> parseTask(String taskId)

getTask

protected org.flowable.task.api.Task getTask(String taskId)
                                      throws NotFoundException

Throws:

NotFoundException

claimForm

public UserRequestForm claimForm(String taskId)

Description copied from interface: UserRequestHandler

Claim a form for a given object.

Specified by:

claimForm in interface UserRequestHandler

Parameters:

taskId - Workflow task to which the form is associated

Returns:

updated form

unclaimForm

public UserRequestForm unclaimForm(String taskId)

Description copied from interface: UserRequestHandler

Unclaim a form for a given object.

Specified by:

unclaimForm in interface UserRequestHandler

Parameters:

taskId - Workflow task to which the form is associated

Returns:

updated form

getPropertiesForSubmit

protected Map<String,String> getPropertiesForSubmit(UserRequestForm form)

getHistoricVariable

protected <T> T getHistoricVariable(List<org.flowable.variable.api.history.HistoricVariableInstance> historicVariables,
                                    String name,
                                    Class<T> valueRef)

submitForm

public UserWorkflowResult<UserPatch> submitForm(UserRequestForm form)

Description copied from interface: UserRequestHandler

Submit a form.

Specified by:

submitForm in interface UserRequestHandler

Parameters:

form - to be submitted

Returns:

user updated by this form submit