{"type":"doc","content":[{"type":"paragraph","content":[{"text":"e) ","type":"text"},{"text":"Integration with workflow","type":"text","marks":[{"type":"underline"},{"type":"strong"}]},{"text":" - Integration with workflow service requires the following steps - ","type":"text"}]},{"type":"paragraph","content":[{"text":"i) Add a workflow object to ","type":"text"},{"text":"VoterRegistrationApplication","type":"text","marks":[{"type":"code"}]},{"text":" POJO -","type":"text"}]},{"type":"codeBlock","content":[{"text":"@Valid\n@JsonProperty(\"workflow\")\nprivate Workflow workflow = null; ","type":"text"}]},{"type":"paragraph","content":[{"text":"Create ","type":"text"},{"text":"ProcessInstance","type":"text","marks":[{"type":"code"}]},{"text":", ","type":"text"},{"text":"State","type":"text","marks":[{"type":"code"}]},{"text":", ","type":"text"},{"text":"Action","type":"text","marks":[{"type":"code"}]},{"text":", ","type":"text"},{"text":"ProcessInstanceRequest","type":"text","marks":[{"type":"code"}]},{"text":", ","type":"text"},{"text":"ProcessInstanceResponse","type":"text","marks":[{"type":"code"}]},{"text":" , ","type":"text"},{"text":"BusinessService","type":"text","marks":[{"type":"code"}]},{"text":" , ","type":"text"},{"text":"BusinessServiceResponse","type":"text","marks":[{"type":"code"}]},{"text":" POJOs -","type":"text"}]},{"type":"codeBlock","content":[{"text":"@Getter\n@Setter\n@AllArgsConstructor\n@NoArgsConstructor\n@Builder\n@EqualsAndHashCode(of = { \"id\" })\n@ToString\npublic class ProcessInstance {\n\n @Size(max = 64)\n @JsonProperty(\"id\")\n private String id;\n\n @NotNull\n @Size(max = 128)\n @JsonProperty(\"tenantId\")\n private String tenantId;\n\n @NotNull\n @Size(max = 128)\n @JsonProperty(\"businessService\")\n private String businessService;\n\n @NotNull\n @Size(max = 128)\n @JsonProperty(\"businessId\")\n private String businessId;\n\n @NotNull\n @Size(max = 128)\n @JsonProperty(\"action\")\n private String action;\n\n @NotNull\n @Size(max = 64)\n @JsonProperty(\"moduleName\")\n private String moduleName;\n\n @JsonProperty(\"state\")\n private State state;\n\n @JsonProperty(\"comment\")\n private String comment;\n\n @JsonProperty(\"documents\")\n @Valid\n private List documents;\n\n @JsonProperty(\"assignes\")\n private List assignes;\n\n public ProcessInstance addDocumentsItem(Document documentsItem) {\n if (this.documents == null) {\n this.documents = new ArrayList<>();\n }\n if (!this.documents.contains(documentsItem))\n this.documents.add(documentsItem);\n\n return this;\n }\n\n} \n@Getter\n@Setter\n@AllArgsConstructor\n@NoArgsConstructor\n@Builder\n@ToString\n@EqualsAndHashCode(of = {\"tenantId\",\"businessServiceId\",\"state\"})\npublic class State {\n\n @Size(max=256)\n @JsonProperty(\"uuid\")\n private String uuid;\n\n @Size(max=256)\n @JsonProperty(\"tenantId\")\n private String tenantId;\n\n @Size(max=256)\n @JsonProperty(\"businessServiceId\")\n private String businessServiceId;\n\n @JsonProperty(\"sla\")\n private Long sla;\n\n @Size(max=256)\n @JsonProperty(\"state\")\n private String state;\n\n @Size(max=256)\n @JsonProperty(\"applicationStatus\")\n private String applicationStatus;\n\n @JsonProperty(\"docUploadRequired\")\n private Boolean docUploadRequired;\n\n @JsonProperty(\"isStartState\")\n private Boolean isStartState;\n\n @JsonProperty(\"isTerminateState\")\n private Boolean isTerminateState;\n\n @JsonProperty(\"isStateUpdatable\")\n private Boolean isStateUpdatable;\n\n @JsonProperty(\"actions\")\n @Valid\n private List actions;\n\n private AuditDetails auditDetails;\n\n\n public State addActionsItem(Action actionsItem) {\n if (this.actions == null) {\n this.actions = new ArrayList<>();\n }\n this.actions.add(actionsItem);\n return this;\n }\n\n}\n@Getter\n@Setter\n@AllArgsConstructor\n@NoArgsConstructor\n@Builder\n@ToString\n@EqualsAndHashCode(of = {\"tenantId\",\"currentState\",\"action\"})\npublic class Action {\n\n @Size(max=256)\n @JsonProperty(\"uuid\")\n private String uuid;\n\n @Size(max=256)\n @JsonProperty(\"tenantId\")\n private String tenantId;\n\n @Size(max=256)\n @JsonProperty(\"currentState\")\n private String currentState;\n\n @Size(max=256)\n @JsonProperty(\"action\")\n private String action;\n\n @Size(max=256)\n @JsonProperty(\"nextState\")\n private String nextState;\n\n @Size(max=1024)\n @JsonProperty(\"roles\")\n @Valid\n private List roles;\n\n private AuditDetails auditDetails;\n\n\n public Action addRolesItem(String rolesItem) {\n if (this.roles == null) {\n this.roles = new ArrayList<>();\n }\n this.roles.add(rolesItem);\n return this;\n }\n\n}\n@Getter\n@Setter\n@AllArgsConstructor\n@NoArgsConstructor\n@Builder\n@ToString\npublic class ProcessInstanceRequest {\n @JsonProperty(\"RequestInfo\")\n private RequestInfo requestInfo;\n\n @JsonProperty(\"ProcessInstances\")\n @Valid\n @NotNull\n private List processInstances;\n\n\n public ProcessInstanceRequest addProcessInstanceItem(ProcessInstance processInstanceItem) {\n if (this.processInstances == null) {\n this.processInstances = new ArrayList<>();\n }\n this.processInstances.add(processInstanceItem);\n return this;\n }\n\n}\n@Getter\n@Setter\n@AllArgsConstructor\n@NoArgsConstructor\n@Builder\npublic class ProcessInstanceResponse {\n @JsonProperty(\"ResponseInfo\")\n private ResponseInfo responseInfo;\n\n @JsonProperty(\"ProcessInstances\")\n @Valid\n private List processInstances;\n\n\n public ProcessInstanceResponse addProceInstanceItem(ProcessInstance proceInstanceItem) {\n if (this.processInstances == null) {\n this.processInstances = new ArrayList<>();\n }\n this.processInstances.add(proceInstanceItem);\n return this;\n }\n\n}\n@Getter\n@Setter\n@AllArgsConstructor\n@NoArgsConstructor\n@Builder\n@ToString\n@EqualsAndHashCode(of = {\"tenantId\",\"businessService\"})\n@JsonInclude(JsonInclude.Include.NON_NULL)\npublic class BusinessService {\n\n @Size(max=256)\n @JsonProperty(\"tenantId\")\n private String tenantId = null;\n\n @Size(max=256)\n @JsonProperty(\"uuid\")\n private String uuid = null;\n\n @Size(max=256)\n @JsonProperty(\"businessService\")\n private String businessService = null;\n\n @Size(max=256)\n @JsonProperty(\"business\")\n private String business = null;\n\n @Size(max=1024)\n @JsonProperty(\"getUri\")\n private String getUri = null;\n\n @Size(max=1024)\n @JsonProperty(\"postUri\")\n private String postUri = null;\n\n @JsonProperty(\"businessServiceSla\")\n private Long businessServiceSla = null;\n\n @NotNull\n @Valid\n @JsonProperty(\"states\")\n private List states = null;\n\n @JsonProperty(\"auditDetails\")\n private AuditDetails auditDetails = null;\n\n\n\n public BusinessService addStatesItem(State statesItem) {\n if (this.states == null) {\n this.states = new ArrayList<>();\n }\n this.states.add(statesItem);\n return this;\n }\n\n\n /**\n * Returns the currentState with the given uuid if not present returns null\n * @param uuid the uuid of the currentState to be returned\n * @return\n */\n public State getStateFromUuid(String uuid) {\n State state = null;\n if(this.states!=null){\n for(State s : this.states){\n if(s.getUuid().equalsIgnoreCase(uuid)){\n state = s;\n break;\n }\n }\n }\n return state;\n }\n\n\n\n}\n@Data\n@NoArgsConstructor\n@AllArgsConstructor\n@Builder\n@ToString\npublic class BusinessServiceResponse {\n\n @JsonProperty(\"ResponseInfo\")\n private ResponseInfo responseInfo;\n\n @JsonProperty(\"BusinessServices\")\n @Valid\n @NotNull\n private List businessServices;\n\n\n public BusinessServiceResponse addBusinessServiceItem(BusinessService businessServiceItem) {\n if (this.businessServices == null) {\n this.businessServices = new ArrayList<>();\n }\n this.businessServices.add(businessServiceItem);\n return this;\n }\n\n\n\n}","type":"text"}]},{"type":"paragraph","content":[{"text":"ii) Next, we have to create a class to transition the workflow object across its states. For this, create a class by the name of ","type":"text"},{"text":"WorkflowService","type":"text","marks":[{"type":"code"}]},{"text":" and annotate it with ","type":"text"},{"text":"@Service","type":"text","marks":[{"type":"code"}]},{"text":" annotation. Add the following content to this class - ","type":"text"}]},{"type":"codeBlock","content":[{"text":"@Component\npublic class WorkflowService {\n\n @Autowired\n private ObjectMapper mapper;\n\n @Autowired\n private ServiceRequestRepository repository;\n\n @Autowired\n private VTRConfiguration config;\n\n public void updateWorkflowStatus(VoterRegistrationRequest voterRegistrationRequest) {\n voterRegistrationRequest.getVoterRegistrationApplications().forEach(application -> {\n ProcessInstance processInstance = getProcessInstanceForVTR(application, voterRegistrationRequest.getRequestInfo());\n ProcessInstanceRequest workflowRequest = new ProcessInstanceRequest(voterRegistrationRequest.getRequestInfo(), Collections.singletonList(processInstance));\n callWorkFlow(workflowRequest);\n });\n }\n\n public State callWorkFlow(ProcessInstanceRequest workflowReq) {\n\n ProcessInstanceResponse response = null;\n StringBuilder url = new StringBuilder(config.getWfHost().concat(config.getWfTransitionPath()));\n Object optional = repository.fetchResult(url, workflowReq);\n response = mapper.convertValue(optional, ProcessInstanceResponse.class);\n return response.getProcessInstances().get(0).getState();\n }\n\n private ProcessInstance getProcessInstanceForVTR(VoterRegistrationApplication application, RequestInfo requestInfo) {\n Workflow workflow = application.getWorkflow();\n\n ProcessInstance processInstance = new ProcessInstance();\n processInstance.setBusinessId(application.getApplicationNumber());\n processInstance.setAction(workflow.getAction());\n processInstance.setModuleName(\"voter-services\");\n processInstance.setTenantId(application.getTenantId());\n processInstance.setBusinessService(\"VTR\");\n processInstance.setDocuments(workflow.getDocuments());\n processInstance.setComment(workflow.getComments());\n\n if(!CollectionUtils.isEmpty(workflow.getAssignes())){\n List users = new ArrayList<>();\n\n workflow.getAssignes().forEach(uuid -> {\n digit.web.models.User user = new digit.web.models.User();\n user.setUuid(uuid);\n users.add(user);\n });\n\n processInstance.setAssignes(users);\n }\n\n return processInstance;\n\n }\n\n private BusinessService getBusinessService(VoterRegistrationApplication application, RequestInfo requestInfo) {\n String tenantId = application.getTenantId();\n StringBuilder url = getSearchURLWithParams(tenantId, \"VTR\");\n RequestInfoWrapper requestInfoWrapper = RequestInfoWrapper.builder().requestInfo(requestInfo).build();\n Object result = repository.fetchResult(url, requestInfoWrapper);\n BusinessServiceResponse response = null;\n try {\n response = mapper.convertValue(result, BusinessServiceResponse.class);\n } catch (IllegalArgumentException e) {\n throw new CustomException(\"PARSING ERROR\", \"Failed to parse response of workflow business service search\");\n }\n\n if (CollectionUtils.isEmpty(response.getBusinessServices()))\n throw new CustomException(\"BUSINESSSERVICE_NOT_FOUND\", \"The businessService \" + \"VTR\" + \" is not found\");\n\n return response.getBusinessServices().get(0);\n }\n\n private StringBuilder getSearchURLWithParams(String tenantId, String businessService) {\n\n StringBuilder url = new StringBuilder(config.getWfHost());\n url.append(config.getWfBusinessServiceSearchPath());\n url.append(\"?tenantId=\");\n url.append(tenantId);\n url.append(\"&businessServices=\");\n url.append(businessService);\n return url;\n }\n\n public ProcessInstanceRequest getProcessInstanceForVoterRegistrationPayment(VoterRegistrationRequest updateRequest) {\n\n VoterRegistrationApplication application = updateRequest.getVoterRegistrationApplications().get(0);\n\n ProcessInstance process = ProcessInstance.builder()\n .businessService(\"VTR\")\n .businessId(application.getApplicationNumber())\n .comment(\"Payment for voter registration processed\")\n .moduleName(\"voter-services\")\n .tenantId(application.getTenantId())\n .action(\"PAY\")\n .build();\n\n return ProcessInstanceRequest.builder()\n .requestInfo(updateRequest.getRequestInfo())\n .processInstances(Arrays.asList(process))\n .build();\n\n }\n}","type":"text"}]},{"type":"paragraph","content":[{"text":"iii) Add the following properties to application.properties file - ","type":"text"}]},{"type":"codeBlock","content":[{"text":"#Workflow config\nis.workflow.enabled=true\negov.workflow.host=http://localhost:8282\negov.workflow.transition.path=/egov-workflow-v2/egov-wf/process/_transition\negov.workflow.businessservice.search.path=/egov-workflow-v2/egov-wf/businessservice/_search\negov.workflow.processinstance.search.path=/egov-workflow-v2/egov-wf/process/_search","type":"text"}]}],"version":1}