From b2bc2401af335cef11cf4d84cee780f72e727255 Mon Sep 17 00:00:00 2001 From: hetengjiao Date: Wed, 4 Mar 2020 12:39:33 +0800 Subject: Add Create Communication Service workflow Issue-ID: SO-2368 Change-Id: I6ce7a8e2af31dce192468ab73247c53156183524 Signed-off-by: hetengjiao --- .../process/CreateCommunicationService.bpmn | 635 +++++++++++++++++++++ 1 file changed, 635 insertions(+) create mode 100644 bpmn/so-bpmn-infrastructure-flows/src/main/resources/process/CreateCommunicationService.bpmn (limited to 'bpmn/so-bpmn-infrastructure-flows/src/main/resources') diff --git a/bpmn/so-bpmn-infrastructure-flows/src/main/resources/process/CreateCommunicationService.bpmn b/bpmn/so-bpmn-infrastructure-flows/src/main/resources/process/CreateCommunicationService.bpmn new file mode 100644 index 0000000000..a632266c2e --- /dev/null +++ b/bpmn/so-bpmn-infrastructure-flows/src/main/resources/process/CreateCommunicationService.bpmn @@ -0,0 +1,635 @@ + + + + + SequenceFlow_0lzwdto + + + + + + + + + + SequenceFlow_0lzwdto + SequenceFlow_1gjmyhd + import org.onap.so.bpmn.infrastructure.scripts.* +def csi= new CreateCommunicationService() +csi.preProcessRequest(execution) + + + SequenceFlow_1gjmyhd + SequenceFlow_1vcepmd + import org.onap.so.bpmn.infrastructure.scripts.* +def csi= new CreateCommunicationService() +csi.prepareInitOperationStatus(execution) + + + + + + + ${dbAdapterEndpoint} + + + application/soap+xml + Basic YnBlbDpwYXNzd29yZDEk + + + ${updateOperationStatus} + POST + ${statusCode} + ${response} + + http-connector + + + SequenceFlow_1vcepmd + SequenceFlow_1ltd3dc + + + SequenceFlow_0kypqg8 + SequenceFlow_0akbbpi + import org.onap.so.bpmn.infrastructure.scripts.* +def csi= new CreateCommunicationService() +csi.generateE2EServiceProfile(execution) + + + SequenceFlow_0akbbpi + SequenceFlow_0j35uff + import org.onap.so.bpmn.infrastructure.scripts.* +def csi= new CreateCommunicationService() +csi.preRequestSend2NSMF(execution) + + + + + + ${NSMF_endpoint} + + + application/json + Basic SW5mcmFQb3J0YWxDbGllbnQ6cGFzc3dvcmQxJA== + + + ${CSMF_NSMFRequest} + POST + ${statusCode} + ${response} + + http-connector + + + SequenceFlow_0j35uff + SequenceFlow_1u66yqo + + + + + + ${dbAdapterEndpoint} + + + application/soap+xml + Basic YnBlbDpwYXNzd29yZDEk + + + ${updateOperationStatus} + POST + ${statusCode} + ${response} + + http-connector + + + SequenceFlow_1iiorr4 + SequenceFlow_15mad8z + + + + + + ${dbAdapterEndpoint} + + + application/soap+xml + Basic YnBlbDpwYXNzd29yZDEk + + + ${updateOperationStatus} + POST + ${statusCode} + ${response} + + http-connector + + + SequenceFlow_1inkg6e + SequenceFlow_0elkfli + + + SequenceFlow_0elkfli + + + + SequenceFlow_1uvyn2n + SequenceFlow_1j65sro + import org.onap.so.bpmn.infrastructure.scripts.* +def csi= new CreateCommunicationService() +csi.createCSAndSSRelationship(execution) + + + + + + + + + + + + + + + + + + + SequenceFlow_1ds2e2l + SequenceFlow_0x9rd1d + + + + + SequenceFlow_114tqpz + SequenceFlow_1fpj5vj + SequenceFlow_04321fy + import org.onap.so.bpmn.infrastructure.scripts.* +def csi= new CreateCommunicationService() +csi.updateFinishStatusInAAI(execution) + + + + + SequenceFlow_04321fy + SequenceFlow_1inkg6e + import org.onap.so.bpmn.infrastructure.scripts.* +def csi= new CreateCommunicationService() +csi.prepareCompleteStatus(execution) + + + + SequenceFlow_1j65sro + SequenceFlow_1iiorr4 + import org.onap.so.bpmn.infrastructure.scripts.* +def csi= new CreateCommunicationService() +csi.prepareUpdateOperationStatus(execution) + + + + + + + + + + + SequenceFlow_1ltd3dc + SequenceFlow_13aldsi + + + SequenceFlow_13aldsi + SequenceFlow_1f1zdf9 + import org.onap.so.bpmn.infrastructure.scripts.* +def csi= new CreateCommunicationService() +csi.prepareDoComposeE2E(execution) + + + + + + + + + + + SequenceFlow_1f1zdf9 + SequenceFlow_1ofzxsf + + + + SequenceFlow_18guyhw + + + + + + SequenceFlow_1ds2e2l + + + + + + SequenceFlow_1kmsen3 + + + SequenceFlow_07fl9jy + + + + + SequenceFlow_07fl9jy + SequenceFlow_1kmsen3 + import org.onap.so.bpmn.infrastructure.scripts.* +def csi= new CreateCommunicationService() +csi.sendSyncError(execution) + + + + + SequenceFlow_0x9rd1d + SequenceFlow_1b66kfh + SequenceFlow_0c89n51 + + + #{execution.getVariable("WorkflowException") == null} + + + SequenceFlow_1u66yqo + + + + SequenceFlow_0hkz9h0 + + + + SequenceFlow_0hkz9h0 + SequenceFlow_056nqyg + import org.onap.so.bpmn.infrastructure.scripts.* +def csi= new CreateCommunicationService() +csi.processNSMFResponse(execution) + + + + SequenceFlow_15mad8z + + + + SequenceFlow_0spge8t + + + + SequenceFlow_056nqyg + SequenceFlow_1uvyn2n + SequenceFlow_114tqpz + + + #{execution.getVariable("ProcessNsmfSuccess") == "OK"} + + + + + SequenceFlow_0c89n51 + + + + + #{execution.getVariable("ProcessNsmfSuccess") == "ERROR"} + + + SequenceFlow_1b66kfh + SequenceFlow_0kypqg8 + import org.onap.so.bpmn.infrastructure.scripts.* +def csi= new CreateCommunicationService() +csi.sendSyncResponse(execution) + + + SequenceFlow_1ofzxsf + SequenceFlow_18guyhw + import org.onap.so.bpmn.infrastructure.scripts.* +def csi= new CreateCommunicationService() +csi.parseCSParamsFromReq(execution) + + + + + + + + + + + + + + + + + + + + + + + + + SequenceFlow_079hxvu + SequenceFlow_1fpj5vj + + + + + SequenceFlow_0spge8t + SequenceFlow_079hxvu + import org.onap.so.bpmn.infrastructure.scripts.* +def csi= new CreateCommunicationService() +csi.prepareCallCheckProcessStatus(execution) + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + -- cgit 1.2.3-korg