From 416faa25c06b4cf16bb532ea395f6732df102086 Mon Sep 17 00:00:00 2001 From: hetengjiao Date: Thu, 27 Feb 2020 14:44:57 +0800 Subject: Add ActivateCommunicationService workflow Issue-ID: SO-2368 Change-Id: I9d1c591ea965e243fb9558ff24bc2f0acad4bf4c Signed-off-by: hetengjiao --- .../scripts/ActivateCommunicationService.groovy | 2 +- .../process/ActivateCommunicationService.bpmn | 486 +++++++++++++++++++++ 2 files changed, 487 insertions(+), 1 deletion(-) create mode 100644 bpmn/so-bpmn-infrastructure-flows/src/main/resources/process/ActivateCommunicationService.bpmn diff --git a/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/ActivateCommunicationService.groovy b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/ActivateCommunicationService.groovy index d3a28eef25..dc33bc930a 100644 --- a/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/ActivateCommunicationService.groovy +++ b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/ActivateCommunicationService.groovy @@ -168,7 +168,7 @@ class ActivateCommunicationService extends AbstractServiceTaskProcessor { } } else { msg = "the communication service has no e2e service" - exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg) + exceptionUtil.buildAndThrowWorkflowException(execution, 500, msg) } } diff --git a/bpmn/so-bpmn-infrastructure-flows/src/main/resources/process/ActivateCommunicationService.bpmn b/bpmn/so-bpmn-infrastructure-flows/src/main/resources/process/ActivateCommunicationService.bpmn new file mode 100644 index 0000000000..92fd5ef52b --- /dev/null +++ b/bpmn/so-bpmn-infrastructure-flows/src/main/resources/process/ActivateCommunicationService.bpmn @@ -0,0 +1,486 @@ + + + + + SequenceFlow_199lc2s + + + SequenceFlow_199lc2s + SequenceFlow_0rl5u9x + import org.onap.so.bpmn.infrastructure.scripts.* +def act= new ActivateCommunicationService() +act.preProcessRequest(execution) + + + + SequenceFlow_0cg4k4f + SequenceFlow_0xunetn + import org.onap.so.bpmn.infrastructure.scripts.* +def act= new ActivateCommunicationService() +act.prepareInitOperationStatus(execution) + + + + + + ${dbAdapterEndpoint} + + + application/soap+xml + Basic YnBlbDpwYXNzd29yZDEk + + + ${updateOperationStatus} + POST + ${statusCode} + ${response} + + http-connector + + + SequenceFlow_0xunetn + SequenceFlow_07brvnu + + + + SequenceFlow_07brvnu + SequenceFlow_0c01147 + import org.onap.so.bpmn.infrastructure.scripts.* +def act= new ActivateCommunicationService() +act.sendSyncResponse(execution) + + + SequenceFlow_0rl5u9x + SequenceFlow_0337wg2 + import org.onap.so.bpmn.infrastructure.scripts.* +def act= new ActivateCommunicationService() +act.checkAAIOrchStatus(execution) + + + + + SequenceFlow_0c01147 + + + + SequenceFlow_1om5m6o + + + + + SequenceFlow_1i6cshg + SequenceFlow_176pwpd + SequenceFlow_1r6lo31 + + + SequenceFlow_1w1h5vl + SequenceFlow_1r6lo31 + SequenceFlow_1b8q7l5 + import org.onap.so.bpmn.infrastructure.scripts.* +def act= new ActivateCommunicationService() +act.updateFinishStatusInAAI(execution) + + + SequenceFlow_1b8q7l5 + SequenceFlow_103y3rz + import org.onap.so.bpmn.infrastructure.scripts.* +def act= new ActivateCommunicationService() +act.prepareCompleteStatus(execution) + + + + + + ${dbAdapterEndpoint} + + + application/soap+xml + Basic YnBlbDpwYXNzd29yZDEk + + + ${updateOperationStatus} + POST + ${statusCode} + ${response} + + http-connector + + + SequenceFlow_103y3rz + SequenceFlow_15dmqcp + + + + + #{execution.getVariable("ProcessNsmfSuccess") == "OK"} + + + SequenceFlow_15dmqcp + + + + SequenceFlow_0337wg2 + SequenceFlow_0cg4k4f + SequenceFlow_0hpybf9 + + + #{execution.getVariable("isContinue") == "true"} + + + + + SequenceFlow_0hpybf9 + + + + + SequenceFlow_1dkviys + + + + SequenceFlow_18sqlo7 + + + SequenceFlow_1dkviys + SequenceFlow_18sqlo7 + import org.onap.so.bpmn.infrastructure.scripts.* +def act= new ActivateCommunicationService() +act.sendSyncError(execution) + + + + + + SequenceFlow_176pwpd + SequenceFlow_0mruwcs + import org.onap.so.bpmn.infrastructure.scripts.* +def act= new ActivateCommunicationService() +act.prepareUpdateOperationStatus(execution) + + + + + + ${dbAdapterEndpoint} + + + application/soap+xml + Basic YnBlbDpwYXNzd29yZDEk + + + ${updateOperationStatus} + POST + ${statusCode} + ${response} + + http-connector + + + SequenceFlow_0mruwcs + SequenceFlow_0f57hgr + + + + SequenceFlow_1om5m6o + SequenceFlow_12ax52p + import org.onap.so.bpmn.infrastructure.scripts.* +def act= new ActivateCommunicationService() +act.preRequestSend2NSMF(execution) + + + + + + ${NSMF_endpoint} + + + application/json + Basic SW5mcmFQb3J0YWxDbGllbnQ6cGFzc3dvcmQxJA== + + + ${CSMF_NSMFRequest} + POST + ${statusCode} + ${response} + + http-connector + + + SequenceFlow_12ax52p + SequenceFlow_1e9r8tc + + + SequenceFlow_1e9r8tc + SequenceFlow_1i6cshg + import org.onap.so.bpmn.infrastructure.scripts.* +def act= new ActivateCommunicationService() +act.processNSMFResponse(execution) + + + + + + SequenceFlow_1hsbli0 + SequenceFlow_102nqyb + import org.onap.so.bpmn.infrastructure.scripts.* +def act= new ActivateCommunicationService() +act.prepareCallCheckProcessStatus(execution) + + + + + SequenceFlow_0f57hgr + + + + + SequenceFlow_1hsbli0 + + + + + + + + + + + + + + + + + + + + + + + + + SequenceFlow_102nqyb + SequenceFlow_1w1h5vl + + + + #{execution.getVariable("ProcessNsmfSuccess") == "ERROR"} + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + -- cgit 1.2.3-korg