Package org.openiam.srvc.activiti

Class ActivitiServiceImpl

java.lang.Object

org.openiam.srvc.AbstractApiService

org.openiam.srvc.activiti.ActivitiServiceImpl

All Implemented Interfaces:

ActivitiService

@Component("activitiBPMService")
public class ActivitiServiceImpl
extends AbstractApiService
implements ActivitiService

Field Summary

Fields inherited from class org.openiam.srvc.AbstractApiService

applicationContext, log, rabbitMQSender

Constructor Summary

Constructors

Constructor	Description
ActivitiServiceImpl(ActivitiServiceQueue queue, ActivitiCreateRequestServiceQueue activitiCreateRequestServiceQueue, ActivitiInitiateWorkflowQueue activitiInitiateWorkflowQueue, ActivitiMakeDecisionQueue activitiMakeDecisionQueue, ActivitiGetTaskRequestedResQueue activitiGetTaskRequestedResQueue)

Method Summary

Modifier and Type	Method	Description
String	addComment(AccessCertificationTaskCommentRequest request)
Response	addUserAndInvite(NewUserProfileRequestModel request)
Response	cancelTask(ActivitiRequestDecision request)
Response	claimRequest(ActivitiClaimRequest request)
int	count(HistorySearchBean searchBean)
IntResponse	countAccessCertificationTasks(HistorySearchBean searchBean)
int	countTasks(TaskSearchBean searchBean)
Response	delegateTask(DelegateRequestModel request)
Response	delegateTaskToAlternate(DelegateRequestModel request)
Response	deleteTask(String taskId)
void	deleteTasksByCertId(String certId, String deleteReason)	Method is used when certification config is deleted. after that we need to clean up hanged tasks - completed or not doesn't matter.
Response	deleteTasksForUser(String userId)
Boolean	doesUserHaveAccessToRevocation(RevokeAccessRequestModel request)
Response	escalateTask(EscalateRequestModel request)
CampaignStatsResponse	findCampaignsFullStat(AccessCertificationCampaignSearchBean searchBean)
CampaignTaskListResponse	findCampaignTasks(AccessCertificationCampaignSearchBean searchBean, int from, int size)
TaskListResponse	findTasks(TaskSearchBean searchBean, int from, int size)
List<AccessCertificationHistoryObject>	getAccessCertificationHistoryForUser(String userId, int from, int size)	get history of user's certification
TaskListResponse	getAccessCertificationTasks(HistorySearchBean searchBean, int from, int size)
List<String>	getApproverUserIds(List<String> associationIds, String targetUserId)
UploadAttachment	getAttachmentBody(String id)
List<UploadAttachment>	getAttachments(String processInstanceId)
List<String>	getCompletedProcessInstanceIds(Date completedBefore, Date completedAfter)
TaskListResponse	getHistory(HistorySearchBean searchBean, int from, int size)
List<TaskHistoryWrapper>	getHistoryForInstance(String executionId)
TaskListWrapper	getHistoryOfApproval(HistorySearchBean historySearchBean, int from, int size)
TaskListWrapper	getHistoryOfProcessInstances(HistorySearchBean historySearchBean, int from, int size)
int	getNumOfAssignedTasks(String userId)	Deprecated.
int	getNumOfAssignedTasksWithFilter(String userId, String description, Date fromDate, Date toDate)
int	getNumOfCandidateTasks(String userId)	Deprecated.
int	getNumOfCandidateTasksWithFilter(String userId, String description, Date fromDate, Date toDate)
TaskListResponse	getPivotViewData(HistorySearchBean searchBean, int from, int size)	Provides data only for Pivot view.
List<AccessCertificationTaskComment>	getProcessInstanceComments(GetAccessCertificationCommentsRequest request)
String	getProcessInstanceIdByExecutionId(String executionId)
List<ProcessInstanceComment>	getProcessInstancesComments(TaskSearchBean searchBean)	Get multiple comments for multiple process instance ids
List<TaskResRequestedWithProcessInstanceIdWrapper>	getProcessInstancesRequestedRes(TaskSearchBean searchBean)	no another choice, have to select this data for the set of active tasks by process instance Id.
List<TaskResRequestedWithProcessInstanceIdWrapper>	getRequestedResForOpenAndCompletedTasks(TaskSearchBean searchBean)
TaskResRequestedWrapper	getRequestedResourcesUserRelated(String taskId)
TaskWrapper	getTask(String taskId)
TaskWrapper	getTaskFromHistory(String executionId, String taskId)
TaskWrapper	getTaskInLastState(String processInstanceId)
TaskResRequestedWrapper	getTaskRequestedRes(String taskId, Map<String,String> blockedRoleIds, Map<String,String> blockedGroupIds)
TaskListWrapper	getTasksByInvolvedUser(String involvedUserId, int from, int size)
TaskListWrapper	getTasksForAssignedUserWithFilter(String userId, int from, int size, String description, Date fromDate, Date toDate)
TaskListWrapper	getTasksForCandidateUserWithFilter(String userId, int from, int size, String description, Date fromDate, Date toDate)
Boolean	hasAccessToExecution(String userId, String executionId)	check does given user has access to view given ExecutionId
boolean	hasCommentViewAccess(String processInstanceId, String userId)	Checks if the specified user has access to view comments associated with a task.
Boolean	hasMakeDecisionAccess(String userId, String taskId)	check does given user has access to make decision for given TaskId
Boolean	hasViewAccess(String userId, String taskId)	check does given user has access to view given TaskId
void	initiateAsyncCreateUserRequestWorkflowApprovers(CreateAccessRequestModel request)	Calls ActivitiAPI.CreateUserRequestWorkflowApprovers using rabbitMQSender.send (i.e., w/o waiting for the response)
BasicWorkflowResponse	initiateCertificationWorkflow(CreateCertificateRequestModel request)
SaveTemplateProfileResponse	initiateCreatePrivilegedAccessRequestWorkflow(CreateAccessRequestModel request)
SaveTemplateProfileResponse	initiateCreateUserRequestWorkflow(CreateAccessRequestModel request)
SaveTemplateProfileResponse	initiateCreateUserRequestWorkflowApprovers(CreateAccessRequestModel request)
SaveTemplateProfileResponse	initiateEditUserWorkflow(UserProfileRequestModel request)
SaveTemplateProfileResponse	initiateNewHireRequest(NewUserProfileRequestModel request)
SaveTemplateProfileResponse	initiateUserAcceptedInviteWorkflow(UserProfileRequestModel request)
BasicWorkflowResponse	initiateWorkflow(GenericWorkflowRequest request)
Boolean	isResourceOfTaskExist(String executionId)
Response	makeAccessReviewDecision(ActivitiRequestDecision request)
void	makeAccessReviewDecisionBulk(AccessReviewDecisionListRequest request)	Bulk complete for batch of requests in async mode
Response	makeDecision(ActivitiRequestDecision request)
Response	makeManualDecision(ActivitiRequestDecision request)
Response	revokeAccess(RevokeAccessRequestModel request)
Response	terminateUser(TerminateUserRequestModel request)
Response	unclaimTask(String taskId)
String	uploadAttachment(UploadAttachmentRequest request)	UploadAttachmentRequest#taskId - associated Task (optional) UploadAttachmentRequest#processInstanceId - associated Process instanceId (optional) UploadAttachmentRequest#fileName - original file name UploadAttachmentRequest#f - file content in Base64 encoded format UploadAttachmentRequest#referenceId - reference Id - if of reference for CommentTo.ROLE or CommentTo.GROUP or CommentTo.TASK UploadAttachmentRequest#referenceType - type of attachment CommentTo

Methods inherited from class org.openiam.srvc.AbstractApiService

broadcast, crudRequest, getBooleanValue, getIntValue, getIntValue, getRabbitMqQueue, getResponse, getResponse, getValue, getValue, getValueList, getValueList, idRequest, manageApiRequest, manageApiRequest, manageCrudApiRequest, manageCrudApiRequest, manageCrudApiRequest, manageCrudApiRequest, membershipRequestProcessing, membershipRequestProcessing, publish, publish, sendAsync, sendAsync

Methods inherited from class java.lang.Object

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

Constructor Detail

ActivitiServiceImpl

@Autowired
public ActivitiServiceImpl(ActivitiServiceQueue queue,
                           ActivitiCreateRequestServiceQueue activitiCreateRequestServiceQueue,
                           ActivitiInitiateWorkflowQueue activitiInitiateWorkflowQueue,
                           ActivitiMakeDecisionQueue activitiMakeDecisionQueue,
                           ActivitiGetTaskRequestedResQueue activitiGetTaskRequestedResQueue)

Method Detail

initiateNewHireRequest

public SaveTemplateProfileResponse initiateNewHireRequest(NewUserProfileRequestModel request)

Specified by:

initiateNewHireRequest in interface ActivitiService

claimRequest

public Response claimRequest(ActivitiClaimRequest request)

Specified by:

claimRequest in interface ActivitiService

delegateTask

public Response delegateTask(DelegateRequestModel request)

Specified by:

delegateTask in interface ActivitiService

escalateTask

public Response escalateTask(EscalateRequestModel request)

Specified by:

escalateTask in interface ActivitiService

delegateTaskToAlternate

public Response delegateTaskToAlternate(DelegateRequestModel request)

Specified by:

delegateTaskToAlternate in interface ActivitiService

revokeAccess

public Response revokeAccess(RevokeAccessRequestModel request)

Specified by:

revokeAccess in interface ActivitiService

terminateUser

public Response terminateUser(TerminateUserRequestModel request)

Specified by:

terminateUser in interface ActivitiService

initiateEditUserWorkflow

public SaveTemplateProfileResponse initiateEditUserWorkflow(UserProfileRequestModel request)

Specified by:

initiateEditUserWorkflow in interface ActivitiService

initiateUserAcceptedInviteWorkflow

public SaveTemplateProfileResponse initiateUserAcceptedInviteWorkflow(UserProfileRequestModel request)

Specified by:

initiateUserAcceptedInviteWorkflow in interface ActivitiService

addUserAndInvite

public Response addUserAndInvite(NewUserProfileRequestModel request)

Specified by:

addUserAndInvite in interface ActivitiService

initiateCreateUserRequestWorkflow

public SaveTemplateProfileResponse initiateCreateUserRequestWorkflow(CreateAccessRequestModel request)

Specified by:

initiateCreateUserRequestWorkflow in interface ActivitiService

initiateCreatePrivilegedAccessRequestWorkflow

public SaveTemplateProfileResponse initiateCreatePrivilegedAccessRequestWorkflow(CreateAccessRequestModel request)

Specified by:

initiateCreatePrivilegedAccessRequestWorkflow in interface ActivitiService

initiateCreateUserRequestWorkflowApprovers

public SaveTemplateProfileResponse initiateCreateUserRequestWorkflowApprovers(CreateAccessRequestModel request)

Specified by:

initiateCreateUserRequestWorkflowApprovers in interface ActivitiService

initiateWorkflow

public BasicWorkflowResponse initiateWorkflow(GenericWorkflowRequest request)

Specified by:

initiateWorkflow in interface ActivitiService

initiateCertificationWorkflow

public BasicWorkflowResponse initiateCertificationWorkflow(CreateCertificateRequestModel request)

Specified by:

initiateCertificationWorkflow in interface ActivitiService

getProcessInstanceIdByExecutionId

public String getProcessInstanceIdByExecutionId(String executionId)

Specified by:

getProcessInstanceIdByExecutionId in interface ActivitiService

makeDecision

public Response makeDecision(ActivitiRequestDecision request)

Specified by:

makeDecision in interface ActivitiService

makeManualDecision

public Response makeManualDecision(ActivitiRequestDecision request)

Specified by:

makeManualDecision in interface ActivitiService

makeAccessReviewDecision

public Response makeAccessReviewDecision(ActivitiRequestDecision request)

Specified by:

makeAccessReviewDecision in interface ActivitiService

makeAccessReviewDecisionBulk

public void makeAccessReviewDecisionBulk(AccessReviewDecisionListRequest request)

Description copied from interface: ActivitiService

Bulk complete for batch of requests in async mode

Specified by:

makeAccessReviewDecisionBulk in interface ActivitiService

getNumOfAssignedTasks

@Deprecated
public int getNumOfAssignedTasks(String userId)

Deprecated.

Specified by:

getNumOfAssignedTasks in interface ActivitiService

getNumOfCandidateTasks

@Deprecated
public int getNumOfCandidateTasks(String userId)

Deprecated.

Specified by:

getNumOfCandidateTasks in interface ActivitiService

getTask

public TaskWrapper getTask(String taskId)

Specified by:

getTask in interface ActivitiService

getTasksByInvolvedUser

public TaskListWrapper getTasksByInvolvedUser(String involvedUserId,
                                              int from,
                                              int size)

Specified by:

getTasksByInvolvedUser in interface ActivitiService

getTaskFromHistory

public TaskWrapper getTaskFromHistory(String executionId,
                                      String taskId)

Specified by:

getTaskFromHistory in interface ActivitiService

getTaskInLastState

public TaskWrapper getTaskInLastState(String processInstanceId)

Specified by:

getTaskInLastState in interface ActivitiService

getNumOfAssignedTasksWithFilter

public int getNumOfAssignedTasksWithFilter(String userId,
                                           String description,
                                           Date fromDate,
                                           Date toDate)

Specified by:

getNumOfAssignedTasksWithFilter in interface ActivitiService

getNumOfCandidateTasksWithFilter

public int getNumOfCandidateTasksWithFilter(String userId,
                                            String description,
                                            Date fromDate,
                                            Date toDate)

Specified by:

getNumOfCandidateTasksWithFilter in interface ActivitiService

getTasksForCandidateUserWithFilter

public TaskListWrapper getTasksForCandidateUserWithFilter(String userId,
                                                          int from,
                                                          int size,
                                                          String description,
                                                          Date fromDate,
                                                          Date toDate)

Specified by:

getTasksForCandidateUserWithFilter in interface ActivitiService

getTasksForAssignedUserWithFilter

public TaskListWrapper getTasksForAssignedUserWithFilter(String userId,
                                                         int from,
                                                         int size,
                                                         String description,
                                                         Date fromDate,
                                                         Date toDate)

Specified by:

getTasksForAssignedUserWithFilter in interface ActivitiService

getHistoryForInstance

public List<TaskHistoryWrapper> getHistoryForInstance(String executionId)

Specified by:

getHistoryForInstance in interface ActivitiService

getHistory

public TaskListResponse getHistory(HistorySearchBean searchBean,
                                   int from,
                                   int size)

Specified by:

getHistory in interface ActivitiService

countAccessCertificationTasks

public IntResponse countAccessCertificationTasks(HistorySearchBean searchBean)

Specified by:

countAccessCertificationTasks in interface ActivitiService

getAccessCertificationTasks

public TaskListResponse getAccessCertificationTasks(HistorySearchBean searchBean,
                                                    int from,
                                                    int size)

Specified by:

getAccessCertificationTasks in interface ActivitiService

getPivotViewData

public TaskListResponse getPivotViewData(HistorySearchBean searchBean,
                                         int from,
                                         int size)

Description copied from interface: ActivitiService

Provides data only for Pivot view. Don't reuse it if any changes are required.

Specified by:

getPivotViewData in interface ActivitiService

Parameters:

searchBean - - search bean for filtering

from - - 1st result

size - - number of entities to return

Returns:

list of entities wrapped by TaskListWrapper

count

public int count(HistorySearchBean searchBean)

Specified by:

count in interface ActivitiService

deleteTask

public Response deleteTask(String taskId)

Specified by:

deleteTask in interface ActivitiService

deleteTasksByCertId

public void deleteTasksByCertId(String certId,
                                String deleteReason)

Description copied from interface: ActivitiService

Method is used when certification config is deleted. after that we need to clean up hanged tasks - completed or not doesn't matter.

Specified by:

deleteTasksByCertId in interface ActivitiService

cancelTask

public Response cancelTask(ActivitiRequestDecision request)

Specified by:

cancelTask in interface ActivitiService

getTaskRequestedRes

public TaskResRequestedWrapper getTaskRequestedRes(String taskId,
                                                   Map<String,String> blockedRoleIds,
                                                   Map<String,String> blockedGroupIds)

Specified by:

getTaskRequestedRes in interface ActivitiService

getProcessInstancesRequestedRes

public List<TaskResRequestedWithProcessInstanceIdWrapper> getProcessInstancesRequestedRes(TaskSearchBean searchBean)

Description copied from interface: ActivitiService

no another choice, have to select this data for the set of active tasks by process instance Id.

Specified by:

getProcessInstancesRequestedRes in interface ActivitiService

Returns:

getRequestedResForOpenAndCompletedTasks

public List<TaskResRequestedWithProcessInstanceIdWrapper> getRequestedResForOpenAndCompletedTasks(TaskSearchBean searchBean)

Specified by:

getRequestedResForOpenAndCompletedTasks in interface ActivitiService

getProcessInstancesComments

public List<ProcessInstanceComment> getProcessInstancesComments(TaskSearchBean searchBean)

Description copied from interface: ActivitiService

Get multiple comments for multiple process instance ids

Specified by:

getProcessInstancesComments in interface ActivitiService

Returns:

unclaimTask

public Response unclaimTask(String taskId)

Specified by:

unclaimTask in interface ActivitiService

deleteTasksForUser

public Response deleteTasksForUser(String userId)

Specified by:

deleteTasksForUser in interface ActivitiService

findTasks

public TaskListResponse findTasks(TaskSearchBean searchBean,
                                  int from,
                                  int size)

Specified by:

findTasks in interface ActivitiService

getHistoryOfApproval

public TaskListWrapper getHistoryOfApproval(HistorySearchBean historySearchBean,
                                            int from,
                                            int size)

Specified by:

getHistoryOfApproval in interface ActivitiService

getHistoryOfProcessInstances

public TaskListWrapper getHistoryOfProcessInstances(HistorySearchBean historySearchBean,
                                                    int from,
                                                    int size)

Specified by:

getHistoryOfProcessInstances in interface ActivitiService

getAccessCertificationHistoryForUser

public List<AccessCertificationHistoryObject> getAccessCertificationHistoryForUser(String userId,
                                                                                   int from,
                                                                                   int size)

Description copied from interface: ActivitiService

get history of user's certification

Specified by:

getAccessCertificationHistoryForUser in interface ActivitiService

Parameters:

userId - - id of required user

from - - 1st result

size - - size of the result

Returns:

List of AccessCertificationHistoryObject

countTasks

public int countTasks(TaskSearchBean searchBean)

Specified by:

countTasks in interface ActivitiService

getApproverUserIds

public List<String> getApproverUserIds(List<String> associationIds,
                                       String targetUserId)

Specified by:

getApproverUserIds in interface ActivitiService

isResourceOfTaskExist

public Boolean isResourceOfTaskExist(String executionId)

Specified by:

isResourceOfTaskExist in interface ActivitiService

doesUserHaveAccessToRevocation

public Boolean doesUserHaveAccessToRevocation(RevokeAccessRequestModel request)

Specified by:

doesUserHaveAccessToRevocation in interface ActivitiService

getCompletedProcessInstanceIds

public List<String> getCompletedProcessInstanceIds(Date completedBefore,
                                                   Date completedAfter)

Specified by:

getCompletedProcessInstanceIds in interface ActivitiService

hasMakeDecisionAccess

public Boolean hasMakeDecisionAccess(String userId,
                                     String taskId)

Description copied from interface: ActivitiService

check does given user has access to make decision for given TaskId

Specified by:

hasMakeDecisionAccess in interface ActivitiService

Parameters:

userId - - id of requestor user

taskId - - id of Task to check

Returns:

true if user has access to make decision (he is assignee user or CANDIDATE user), false - otherwise

hasAccessToExecution

public Boolean hasAccessToExecution(String userId,
                                    String executionId)

Description copied from interface: ActivitiService

check does given user has access to view given ExecutionId

Specified by:

hasAccessToExecution in interface ActivitiService

Parameters:

userId - - user id of requester

executionId - - id of execution to check

Returns:

true if user has access to execution (he is assignee user or CANDIDATE user or Owner of the task), false - otherwise

uploadAttachment

public String uploadAttachment(UploadAttachmentRequest request)

Description copied from interface: ActivitiService

UploadAttachmentRequest#taskId - associated Task (optional) UploadAttachmentRequest#processInstanceId - associated Process instanceId (optional) UploadAttachmentRequest#fileName - original file name UploadAttachmentRequest#f - file content in Base64 encoded format UploadAttachmentRequest#referenceId - reference Id - if of reference for CommentTo.ROLE or CommentTo.GROUP or CommentTo.TASK UploadAttachmentRequest#referenceType - type of attachment CommentTo

Specified by:

uploadAttachment in interface ActivitiService

Returns:

- Id of new attachment, null if any errors happen

addComment

public String addComment(AccessCertificationTaskCommentRequest request)

Specified by:

addComment in interface ActivitiService

getProcessInstanceComments

public List<AccessCertificationTaskComment> getProcessInstanceComments(GetAccessCertificationCommentsRequest request)

Specified by:

getProcessInstanceComments in interface ActivitiService

getAttachmentBody

public UploadAttachment getAttachmentBody(String id)

Specified by:

getAttachmentBody in interface ActivitiService

getAttachments

public List<UploadAttachment> getAttachments(String processInstanceId)

Specified by:

getAttachments in interface ActivitiService

hasViewAccess

public Boolean hasViewAccess(String userId,
                             String taskId)

Description copied from interface: ActivitiService

check does given user has access to view given TaskId

Specified by:

hasViewAccess in interface ActivitiService

Parameters:

userId - - user id of requester

taskId - - id of task to check

Returns:

true if user has access to view task (he is assignee user or CANDIDATE user or Owner of the task), false - otherwise

findCampaignTasks

public CampaignTaskListResponse findCampaignTasks(AccessCertificationCampaignSearchBean searchBean,
                                                  int from,
                                                  int size)

Specified by:

findCampaignTasks in interface ActivitiService

findCampaignsFullStat

public CampaignStatsResponse findCampaignsFullStat(AccessCertificationCampaignSearchBean searchBean)

Specified by:

findCampaignsFullStat in interface ActivitiService

getRequestedResourcesUserRelated

public TaskResRequestedWrapper getRequestedResourcesUserRelated(String taskId)

Specified by:

getRequestedResourcesUserRelated in interface ActivitiService

hasCommentViewAccess

public boolean hasCommentViewAccess(String processInstanceId,
                                    String userId)

Checks if the specified user has access to view comments associated with a task.

Specified by:

hasCommentViewAccess in interface ActivitiService

Parameters:

processInstanceId - The ID of the process instance.

userId - The ID of the user whose access is being checked.

Returns:

true if the user has access to view comments, false otherwise.

initiateAsyncCreateUserRequestWorkflowApprovers

public void initiateAsyncCreateUserRequestWorkflowApprovers(CreateAccessRequestModel request)

Description copied from interface: ActivitiService

Calls ActivitiAPI.CreateUserRequestWorkflowApprovers using rabbitMQSender.send (i.e., w/o waiting for the response)

Specified by:

initiateAsyncCreateUserRequestWorkflowApprovers in interface ActivitiService

Parameters:

request - CreateAccessRequestModel