From c2110d59a01f3343a42cf55045bf67e456c2f182 Mon Sep 17 00:00:00 2001 From: hyu2010 Date: Mon, 7 Sep 2020 18:07:25 -0400 Subject: Implementation of TN NSSMF WF on SO (1) Workflow of Allocate TN NSSI (2) Workflow of Deallocate TN NSSI (3) Workflow of Activate and Deactivate TN NSSI (4) Workflow of Modify TN NSSI NOTE: 1. The full implementation of TN NSSMF consists of two layers: (1) The TN Sice definition layer, which is an orchestration layer that provides the NBI of TN NSSMF to its consumers (i.e., it concerns the "what" question), and (2) the TN slice realization layer, which is responsible for the actual network configurations of TN slicing (i.e., the "how" question). The first layer is done on the SO (i.e., this changeset), while the 2nd layer is implemented on the SDNC. That's why this changeset is relatively simple, since the "real work" is done by the SDNC. 2. This changeset depends on the common NSSMF WF (https://gerrit.onap.org/r/c/so/+/111477) Issue-ID: SO-2959 Signed-off-by: hyu2010 Change-Id: I9d4e77b7706d28fb4133ddca0ff1d6e307be613d Signed-off-by: hyu2010 --- .../subprocess/DoActivateTransportNSSI.bpmn | 207 +++++++++ .../subprocess/DoAllocateTransportNSSI.bpmn | 493 +++++++++++++++++++++ .../subprocess/DoCreateTnNssiInstance.bpmn | 179 ++++++++ .../subprocess/DoDeallocateTransportNSSI.bpmn | 221 +++++++++ .../subprocess/DoModifyTransportNSSI.bpmn | 222 ++++++++++ 5 files changed, 1322 insertions(+) create mode 100644 bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoActivateTransportNSSI.bpmn create mode 100644 bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoAllocateTransportNSSI.bpmn create mode 100644 bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoCreateTnNssiInstance.bpmn create mode 100644 bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoDeallocateTransportNSSI.bpmn create mode 100644 bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoModifyTransportNSSI.bpmn (limited to 'bpmn/so-bpmn-infrastructure-flows/src/main') diff --git a/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoActivateTransportNSSI.bpmn b/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoActivateTransportNSSI.bpmn new file mode 100644 index 0000000000..8ecce46ac0 --- /dev/null +++ b/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoActivateTransportNSSI.bpmn @@ -0,0 +1,207 @@ + + + + + SequenceFlow_03s744c + + + + SequenceFlow_1w67v6s + + + + SequenceFlow_08mlzwz + + + SequenceFlow_1w67v6s + SequenceFlow_08mlzwz + import org.onap.so.bpmn.common.scripts.* +ExceptionUtil ex = new ExceptionUtil() +ex.processJavaException(execution) + + + + + + Flow_1032bi1 + + + SequenceFlow_0kixzdj + SequenceFlow_1qv8qw1 + import org.onap.so.bpmn.infrastructure.scripts.* +def runScript = new DoActivateTnNssi() +runScript.prepareUpdateJobStatus(execution,"finished","100","Activate or Deactivate successfully") + + + + + SequenceFlow_1jdb2oq + SequenceFlow_0kixzdj + import org.onap.so.bpmn.infrastructure.scripts.* +def actionType = execution.getVariable("actionType") +execution.setVariable("orchestrationStatus", actionType) +def runScript = new DoActivateTnNssi() +runScript.updateAAIOrchStatus(execution) + + + + SequenceFlow_07e12rt + Flow_0cpctye + import org.onap.so.bpmn.infrastructure.scripts.* +def runScript = new DoActivateTnNssi() +runScript.preprocessSdncActOrDeactTnNssiRequest(execution) + + + + + + + + + + + + + Flow_0cpctye + Flow_0fuabjs + + + + Flow_0fuabjs + SequenceFlow_1jdb2oq + import org.onap.so.bpmn.infrastructure.scripts.* + +String response = execution.getVariable("TNNSSMF_SDNCAdapterResponse") + +def runScript = new DoActivateTnNssi() +runScript.validateSDNCResponse(execution, response) + + + + SequenceFlow_03s744c + SequenceFlow_07e12rt + import org.onap.so.bpmn.infrastructure.scripts.* +def runScript = new DoActivateTnNssi() +runScript.preProcessRequest(execution) + + + + + + + ${dbAdapterEndpoint} + + + application/soap+xml + Basic YnBlbDpwYXNzd29yZDEk + + + ${updateResourceOperationStatus} + POST + ${statusCode} + ${response} + + http-connector + + + SequenceFlow_1qv8qw1 + Flow_1032bi1 + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + diff --git a/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoAllocateTransportNSSI.bpmn b/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoAllocateTransportNSSI.bpmn new file mode 100644 index 0000000000..f4886322c2 --- /dev/null +++ b/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoAllocateTransportNSSI.bpmn @@ -0,0 +1,493 @@ + + + + + SequenceFlow_03s744c + + + SequenceFlow_1fk37v7 + + + + SequenceFlow_03s744c + SequenceFlow_07e12rt + import org.onap.so.bpmn.infrastructure.scripts.* +def css= new TnAllocateNssi() +css.preProcessRequest(execution) + + + SequenceFlow_1cv0wop + SequenceFlow_197cm2e + import org.onap.so.bpmn.infrastructure.scripts.* +def css = new TnAllocateNssi() +css.processOofSelection(execution) + + + SequenceFlow_197cm2e + SequenceFlow_12t5exy + SequenceFlow_038lb9m + + + SequenceFlow_1t19ips + SequenceFlow_0jrclmc + import org.onap.so.bpmn.infrastructure.scripts.* +def runScript = new TnAllocateNssi() +runScript.processDecomposition(execution) + + + SequenceFlow_0mlrlbv + SequenceFlow_1c6ka9h + SequenceFlow_0n4xku8 + + + SequenceFlow_1c6ka9h + + + + + SequenceFlow_1w67v6s + + + + SequenceFlow_08mlzwz + + + SequenceFlow_1w67v6s + SequenceFlow_08mlzwz + import org.onap.so.bpmn.common.scripts.* +ExceptionUtil ex = new ExceptionUtil() +ex.processJavaException(execution) + + + + + + Flow_06rrcwf + + + SequenceFlow_07e12rt + SequenceFlow_0t094g7 + import org.onap.so.bpmn.infrastructure.scripts.* +def rupScript = new TnAllocateNssi() +runScript.prepareUpdateJobStatus(execution,"progress","10","Allocate TN NSSI started") + + + SequenceFlow_0jrclmc + + + + SequenceFlow_0kixzdj + SequenceFlow_1qv8qw1 + import org.onap.so.bpmn.infrastructure.scripts.* +def runScript = new TnAllocateNssi() +runScript.prepareUpdateJobStatus(execution,"finished","100","Allocated TN NSSI successfully") + + + + + + + + + + + SequenceFlow_0q7yc2c + SequenceFlow_1t19ips + + + Flow_1k88aak + SequenceFlow_0q7yc2c + import org.onap.so.bpmn.infrastructure.scripts.* +def runScript = new TnAllocateNssi() +runScript.prepareDecomposeService(execution) + + + SequenceFlow_1fk37v7 + SequenceFlow_0h2oree + import org.onap.so.bpmn.infrastructure.scripts.* +def css = new TnAllocateNssi() +css.prepareOofSelection(execution) + + + SequenceFlow_1bevt3a + + + + SequenceFlow_12t5exy + + + + Flow_0pbq5q0 + + + + + + + + + + + + + + + + + + + SequenceFlow_1bevt3a + SequenceFlow_0mlrlbv + + + + + + + #{(execution.getVariable("isOofTnNssiSelected") == false)} + + + + + + + #{execution.getVariable("WorkflowException") == null} + + + + + + + + + + SequenceFlow_0n4xku8 + SequenceFlow_0kixzdj + import org.onap.so.bpmn.infrastructure.scripts.* +execution.setVariable("orchestrationStatus", "allocated") +def runScript = new TnAllocateNssi() +runScript.updateAAIOrchStatus(execution) + + + + SequenceFlow_038lb9m + Flow_1853sgs + import org.onap.so.bpmn.infrastructure.scripts.* +def runScript = new TnAllocateNssi() +runScript.prepareUpdateJobStatus(execution,"finished","100","Allocated TN NSSI successfully") + + + + + + + + + + + + + SequenceFlow_0h2oree + SequenceFlow_1cv0wop + + + + + + ${dbAdapterEndpoint} + + + application/soap+xml + Basic YnBlbDpwYXNzd29yZDEk + + + ${updateResourceOperationStatus} + POST + ${statusCode} + ${response} + + http-connector + + + Flow_1853sgs + Flow_0pbq5q0 + + + + + + + ${dbAdapterEndpoint} + + + application/soap+xml + Basic YnBlbDpwYXNzd29yZDEk + + + ${updateResourceOperationStatus} + POST + ${statusCode} + ${response} + + http-connector + + + SequenceFlow_0t094g7 + Flow_1k88aak + + + + + + + ${dbAdapterEndpoint} + + + application/soap+xml + Basic YnBlbDpwYXNzd29yZDEk + + + ${updateResourceOperationStatus} + POST + ${statusCode} + ${response} + + http-connector + + + SequenceFlow_1qv8qw1 + Flow_06rrcwf + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + diff --git a/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoCreateTnNssiInstance.bpmn b/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoCreateTnNssiInstance.bpmn new file mode 100644 index 0000000000..e9cbbb77cc --- /dev/null +++ b/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoCreateTnNssiInstance.bpmn @@ -0,0 +1,179 @@ + + + + + SequenceFlow_1qo2pln + + + + + SequenceFlow_1qo2pln + SequenceFlow_0khtova + import org.onap.so.bpmn.infrastructure.scripts.* +def dcsi = new DoCreateTnNssiInstance() +dcsi.preProcessRequest(execution) + + + SequenceFlow_0khtova + SequenceFlow_0g5bwvl + import org.onap.so.bpmn.infrastructure.scripts.* +def dcsi = new DoCreateTnNssiInstance() +dcsi.createServiceInstance(execution) + + + + + Flow_106ei42 + SequenceFlow_17u69c4 + import org.onap.so.bpmn.infrastructure.scripts.* +def dcsi = new DoCreateTnNssiInstance() +dcsi.createAllottedResource(execution) + + + + Flow_1c8zr59 + + + + Flow_1c8zr59 + Flow_0pko5tm + import org.onap.so.bpmn.infrastructure.scripts.* +def dcsi = new DoCreateTnNssiInstance() +dcsi.preprocessSdncAllocateTnNssiRequest(execution) + + + + + + + + + + + + Flow_0pko5tm + Flow_11kadz7 + + + Flow_11kadz7 + SequenceFlow_1uiz85h + import org.onap.so.bpmn.infrastructure.scripts.* + +String response = execution.getVariable("TNNSSMF_SDNCAdapterResponse") + +def dcsi = new DoCreateTnNssiInstance() +dcsi.validateSDNCResponse(execution, response, "allocate") + + + + + + SequenceFlow_1uiz85h + + + SequenceFlow_17u69c4 + + + + SequenceFlow_0g5bwvl + Flow_106ei42 + import org.onap.so.bpmn.infrastructure.scripts.* +def dcsi = new DoCreateTnNssiInstance() +dcsi.createSliceProfile(execution) + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + diff --git a/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoDeallocateTransportNSSI.bpmn b/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoDeallocateTransportNSSI.bpmn new file mode 100644 index 0000000000..a800289aaa --- /dev/null +++ b/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoDeallocateTransportNSSI.bpmn @@ -0,0 +1,221 @@ + + + + + SequenceFlow_03s744c + + + + SequenceFlow_1w67v6s + + + + SequenceFlow_08mlzwz + + + SequenceFlow_1w67v6s + SequenceFlow_08mlzwz + import org.onap.so.bpmn.common.scripts.* +ExceptionUtil ex = new ExceptionUtil() +ex.processJavaException(execution) + + + + + + Flow_0ca4l8d + + + SequenceFlow_0kixzdj + SequenceFlow_1qv8qw1 + import org.onap.so.bpmn.infrastructure.scripts.* +def runScript = new TnAllocateNssi() +runScript.prepareUpdateJobStatus(execution,"finished","100","Deallocated TN NSSI successfully") + + + + + SequenceFlow_1jygjln + SequenceFlow_0kixzdj + import org.onap.so.bpmn.infrastructure.scripts.* +execution.setVariable("orchestrationStatus", "deallocated") +def runScript = new DoDeallocateTnNssi() +runScript.updateAAIOrchStatus(execution) + + + + SequenceFlow_07e12rt + Flow_0cpctye + import org.onap.so.bpmn.infrastructure.scripts.* +def runScript = new DoDeallocateTnNssi() +runScript.preprocessSdncDeallocateTnNssiRequest(execution) + + + + + + + + + + + + + Flow_0cpctye + Flow_0fuabjs + + + + Flow_0fuabjs + SequenceFlow_1jdb2oq + import org.onap.so.bpmn.infrastructure.scripts.* + +String response = execution.getVariable("TNNSSMF_SDNCAdapterResponse") + +def runScript = new DoDeallocateTnNssi() +runScript.validateSDNCResponse(execution, response, "deallocate") + + + SequenceFlow_1jdb2oq + SequenceFlow_1jygjln + import org.onap.so.bpmn.infrastructure.scripts.* +def runScript = new DoDeallocateTnNssi() +runScript.deleteServiceInstance(execution) + + + + SequenceFlow_03s744c + SequenceFlow_07e12rt + import org.onap.so.bpmn.infrastructure.scripts.* +def runScript = new DoDeallocateTnNssi() +runScript.preProcessRequest(execution) + + + + + + + + ${dbAdapterEndpoint} + + + application/soap+xml + Basic YnBlbDpwYXNzd29yZDEk + + + ${updateResourceOperationStatus} + POST + ${statusCode} + ${response} + + http-connector + + + SequenceFlow_1qv8qw1 + Flow_0ca4l8d + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + diff --git a/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoModifyTransportNSSI.bpmn b/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoModifyTransportNSSI.bpmn new file mode 100644 index 0000000000..d70bed68cb --- /dev/null +++ b/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoModifyTransportNSSI.bpmn @@ -0,0 +1,222 @@ + + + + + SequenceFlow_03s744c + + + + SequenceFlow_1w67v6s + + + + SequenceFlow_08mlzwz + + + SequenceFlow_1w67v6s + SequenceFlow_08mlzwz + import org.onap.so.bpmn.common.scripts.* +ExceptionUtil ex = new ExceptionUtil() +ex.processJavaException(execution) + + + + + + Flow_1akxvak + + + SequenceFlow_0kixzdj + SequenceFlow_1qv8qw1 + import org.onap.so.bpmn.infrastructure.scripts.* +def runScript = new DoActivateTnNssi() +runScript.prepareUpdateJobStatus(execution,"finished","100","Modified TN NSSI successfully") + + + + + Flow_0h5rwlh + SequenceFlow_0kixzdj + import org.onap.so.bpmn.infrastructure.scripts.* +execution.setVariable("orchestrationStatus", "modified") +def runScript = new DoModifyTnNssi() +runScript.updateAAIOrchStatus(execution) + + + + SequenceFlow_07e12rt + SequenceFlow_1jdb2oq + import org.onap.so.bpmn.infrastructure.scripts.* + +def runScript = new DoModifyTnNssi() +runScript.updateTnNssiInAAI(execution) + + + + SequenceFlow_03s744c + SequenceFlow_07e12rt + import org.onap.so.bpmn.infrastructure.scripts.* +def runScript = new DoModifyTnNssi() +runScript.preProcessRequest(execution) + + + + SequenceFlow_1jdb2oq + Flow_1dvo5ih + import org.onap.so.bpmn.infrastructure.scripts.* +def runScript = new DoModifyTnNssi() +runScript.preprocessSdncModifyTnNssiRequest(execution) + + + + + + + + + + + + + Flow_1dvo5ih + Flow_139j3yd + + + + Flow_139j3yd + Flow_0h5rwlh + import org.onap.so.bpmn.infrastructure.scripts.* + +String response = execution.getVariable("TNNSSMF_SDNCAdapterResponse") + +def runScript = new DoModifyTnNssi() +runScript.validateSDNCResponse(execution, response, "modify") + + + + + + + ${dbAdapterEndpoint} + + + application/soap+xml + Basic YnBlbDpwYXNzd29yZDEk + + + ${updateResourceOperationStatus} + POST + ${statusCode} + ${response} + + http-connector + + + SequenceFlow_1qv8qw1 + Flow_1akxvak + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + -- cgit 1.2.3-korg