From c7caf208e96a9f1f7d9fd43bb3c3d2cb1347a399 Mon Sep 17 00:00:00 2001 From: aleemraja Date: Thu, 17 Sep 2020 13:41:56 +0530 Subject: Implement Allocate Core NSSMF workflow Issue-ID: SO-3234 Signed-off-by: aleemraja Change-Id: I37ce7d21eaba8ea60a91a7034509696b2cf3a987 --- .../resources/subprocess/DoAllocateCoreNSSI.bpmn | 309 +++++++++++++++++ .../subprocess/DoAllocateCoreNonSharedSlice.bpmn | 368 +++++++++++++++++++++ .../subprocess/DoAllocateCoreSharedSlice.bpmn | 367 ++++++++++++++++++++ 3 files changed, 1044 insertions(+) create mode 100644 bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoAllocateCoreNSSI.bpmn create mode 100644 bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoAllocateCoreNonSharedSlice.bpmn create mode 100644 bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoAllocateCoreSharedSlice.bpmn (limited to 'bpmn/so-bpmn-infrastructure-flows/src/main') diff --git a/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoAllocateCoreNSSI.bpmn b/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoAllocateCoreNSSI.bpmn new file mode 100644 index 0000000000..92407e9b2a --- /dev/null +++ b/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoAllocateCoreNSSI.bpmn @@ -0,0 +1,309 @@ + + + + + SequenceFlow_0bjz7up + + + + + + Flow_0kbpihh + SequenceFlow_1scva4p + SequenceFlow_1ygklb8 + + + + #{execution.getVariable("solutions") !="" } + + + + SequenceFlow_0tytimn + SequenceFlow_0tubodn + + + SequenceFlow_0bjz7up + SequenceFlow_1xiszom + import org.onap.so.bpmn.infrastructure.scripts.* +def allocateNssi = new DoAllocateCoreNSSI() +allocateNssi.preProcessRequest(execution) + + + SequenceFlow_1xiszom + SequenceFlow_0enouyb + import org.onap.so.bpmn.infrastructure.scripts.* +def allocateNssi = new DoAllocateCoreNSSI() +allocateNssi.getNSSTName(execution) + + + SequenceFlow_0enouyb + SequenceFlow_1r5aycw + import org.onap.so.bpmn.infrastructure.scripts.* +def allocateNssi = new DoAllocateCoreNSSI() +allocateNssi.prepareOOFRequest(execution) + + + + + + + + + + + + + + + + + + + SequenceFlow_1scva4p + SequenceFlow_0tubodn + + + + + + + + + + + + + + + + + + + SequenceFlow_1ygklb8 + SequenceFlow_0tytimn + + + + + + + + + + + + + + SequenceFlow_1r5aycw + Flow_1navrbe + + + + Flow_1navrbe + Flow_0kbpihh + import org.onap.so.bpmn.infrastructure.scripts.* +def allocateNssi = new DoAllocateCoreNSSI() +allocateNssi.processOOFAsyncResponse(execution) + + + + + Flow_1bd9s44 + + + + Flow_1rrkw3k + + + Flow_1jn84pa + Flow_1rrkw3k + import org.onap.so.bpmn.common.scripts.* +ExceptionUtil ex = new ExceptionUtil() +ex.processJavaException(execution) + + + Flow_1bd9s44 + Flow_167qlhy + import org.onap.so.bpmn.infrastructure.scripts.* +def allocateNssi= new DoAllocateCoreNSSI() +allocateNssi.prepareFailedOperationStatusUpdate(execution) + + + + + + ${dbAdapterEndpoint} + + + application/soap+xml + Basic YnBlbDpwYXNzd29yZDEk + + + ${updateResourceOperationStatus} + POST + ${statusCode} + ${response} + + http-connector + + + Flow_167qlhy + Flow_1jn84pa + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + diff --git a/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoAllocateCoreNonSharedSlice.bpmn b/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoAllocateCoreNonSharedSlice.bpmn new file mode 100644 index 0000000000..22eeceea51 --- /dev/null +++ b/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoAllocateCoreNonSharedSlice.bpmn @@ -0,0 +1,368 @@ + + + + + SequenceFlow_0vxnxew + + + SequenceFlow_0pkw03j + Flow_1xofp8o + Flow_0ebyiqk + + + + + + Flow_13lzgo4 + SequenceFlow_1terk7m + import org.onap.so.bpmn.infrastructure.scripts.* +def allocateNssi = new DoAllocateCoreNonSharedSlice() +allocateNssi.createNSSIinAAI(execution) + + + SequenceFlow_1terk7m + SequenceFlow_0qeif6i + import org.onap.so.bpmn.infrastructure.scripts.* +def allocateNssi = new DoAllocateCoreNonSharedSlice() +allocateNssi.prepareServiceOrderRequest(execution) + + + SequenceFlow_0cqjgbm + SequenceFlow_0pkw03j + import org.onap.so.bpmn.infrastructure.scripts.* +def allocateNssi = new DoAllocateCoreNonSharedSlice() +allocateNssi.postNBIServiceOrder(execution) + + + #{(execution.getVariable("ServiceOrderId" ) != null && execution.getVariable("ServiceOrderId" ) != "" )} + + + SequenceFlow_1g8lnjx + Flow_1hjbkma + SequenceFlow_0zuc4mh + + + + Flow_0ginxdy + + + + SequenceFlow_0vxnxew + Flow_13lzgo4 + import org.onap.so.bpmn.infrastructure.scripts.* +def allocateNssi = new DoAllocateCoreNonSharedSlice() +allocateNssi.preProcessRequest(execution) + + + Flow_1xofp8o + Flow_0d9xaja + SequenceFlow_1g8lnjx + import org.onap.so.bpmn.infrastructure.scripts.* +def allocateNssi = new DoAllocateCoreNonSharedSlice() +allocateNssi.getNBIServiceOrderProgress(execution) + + + + + + ${dbAdapterEndpoint} + + + application/soap+xml + Basic YnBlbDpwYXNzd29yZDEk + + + ${updateResourceOperationStatus} + POST + ${statusCode} + ${response} + + http-connector + + + Flow_0ebyiqk + Flow_140j38y + Flow_0ginxdy + + + + + + #{(execution.getVariable("status" ) == "processing" )} + + + + SequenceFlow_0zuc4mh + Flow_0d9xaja + import org.onap.so.bpmn.infrastructure.scripts.* +def allocateNssi = new DoAllocateCoreNonSharedSlice() +allocateNssi.timeDelay(execution) + + + Flow_1hjbkma + Flow_140j38y + import org.onap.so.bpmn.infrastructure.scripts.* +def allocateNssi = new DoAllocateCoreNonSharedSlice() +allocateNssi.updateRelationship(execution) + + + + + SequenceFlow_0qeif6i + + + + SequenceFlow_0cqjgbm + + + + + + Flow_022y6dc + + + + Flow_0luurk9 + + + Flow_07lojd9 + Flow_0luurk9 + import org.onap.so.bpmn.common.scripts.* +ExceptionUtil ex = new ExceptionUtil() +ex.processJavaException(execution) + + + Flow_022y6dc + Flow_0g444ik + import org.onap.so.bpmn.infrastructure.scripts.* +def allocateNssi = new DoAllocateCoreNonSharedSlice() +allocateNssi.prepareFailedOperationStatusUpdate(execution) + + + + + + ${dbAdapterEndpoint} + + + application/soap+xml + Basic YnBlbDpwYXNzd29yZDEk + + + ${updateResourceOperationStatus} + POST + ${statusCode} + ${response} + + http-connector + + + Flow_0g444ik + Flow_07lojd9 + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + diff --git a/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoAllocateCoreSharedSlice.bpmn b/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoAllocateCoreSharedSlice.bpmn new file mode 100644 index 0000000000..0a482beca0 --- /dev/null +++ b/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoAllocateCoreSharedSlice.bpmn @@ -0,0 +1,367 @@ + + + + + SequenceFlow_1ym7ydc + + + + Flow_09uu75h + + + + Flow_1r07vnu + Flow_1973d9m + import org.onap.so.bpmn.infrastructure.scripts.* +def allocateNssi = new DoAllocateCoreSharedSlice() +allocateNssi.getNetworkInstanceAssociatedWithNssiId(execution) + + + + SequenceFlow_1ym7ydc + Flow_1r07vnu + import org.onap.so.bpmn.infrastructure.scripts.* +def allocateNssi = new DoAllocateCoreSharedSlice() +allocateNssi.preProcessRequest(execution) + + + + Flow_0da7dao + SequenceFlow_1j1qqcs + import org.onap.so.bpmn.infrastructure.scripts.* +def allocateNssi = new DoAllocateCoreSharedSlice() +allocateNssi.prepareSOMacroRequestPayload(execution) + + + SequenceFlow_013bc74 + SequenceFlow_08q2fd9 + import org.onap.so.bpmn.infrastructure.scripts.* +def allocateNssi = new DoAllocateCoreSharedSlice() +allocateNssi.sendPutRequestToSOMacro(execution) + + + Flow_0x7shtq + Flow_1c9nkx4 + import org.onap.so.bpmn.infrastructure.scripts.* +def allocateNssi = new DoAllocateCoreSharedSlice() +allocateNssi.prepareCallCheckProcessStatus(execution) + + + + + + + + + + + + + + + + + + + + + Flow_1c9nkx4 + Flow_0c94gye + + + + + Flow_1973d9m + Flow_0da7dao + import org.onap.so.bpmn.infrastructure.scripts.* +def allocateNssi = new DoAllocateCoreSharedSlice() +allocateNssi.getServiceVNFAndVFsFromCatalogDB(execution) + + + Flow_0c94gye + SequenceFlow_1re5jor + import org.onap.so.bpmn.infrastructure.scripts.* +def allocateNssi = new DoAllocateCoreSharedSlice() +allocateNssi.prepareUpdateResourceOperationStatus(execution) + + + + + + ${dbAdapterEndpoint} + + + application/soap+xml + Basic YnBlbDpwYXNzd29yZDEk + + + ${updateOperationStatus} + POST + ${statusCode} + ${response} + + http-connector + + + SequenceFlow_1re5jor + Flow_1nn15tq + Flow_09uu75h + + + + + + + SequenceFlow_1j1qqcs + + + + SequenceFlow_013bc74 + + + + + SequenceFlow_08q2fd9 + Flow_0x7shtq + Flow_1nn15tq + + + + #{(execution.getVariable("isSOResponseSucceed" ) == "no")} + + + + Flow_0nauwik + + + + Flow_0y8rsb3 + + + Flow_128o22z + Flow_0y8rsb3 + import org.onap.so.bpmn.common.scripts.* +ExceptionUtil ex = new ExceptionUtil() +ex.processJavaException(execution) + + + Flow_0nauwik + Flow_0kadgoq + import org.onap.so.bpmn.infrastructure.scripts.* +def allocateNssi = new DoAllocateCoreSharedSlice() +allocateNssi.prepareFailedOperationStatusUpdate(execution) + + + + + + ${dbAdapterEndpoint} + + + application/soap+xml + Basic YnBlbDpwYXNzd29yZDEk + + + ${updateResourceOperationStatus} + POST + ${statusCode} + ${response} + + http-connector + + + Flow_0kadgoq + Flow_128o22z + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + -- cgit 1.2.3-korg