From f2d6094a88bcba5778b929965d78b3c1d89aea93 Mon Sep 17 00:00:00 2001 From: "Kalkere Ramesh, Sharan (sk720x)" Date: Fri, 7 Dec 2018 14:18:26 -0500 Subject: Fix issues with DoCreateNetworkInstance Change-Id: I8aa535b0577560c13a00b3c9a5eed49a3892f644 Issue-ID: SO-1303 Signed-off-by: Kalkere Ramesh, Sharan (sk720x) --- .../subprocess/DoCreateNetworkInstance.bpmn | 541 ++++++++++----------- 1 file changed, 251 insertions(+), 290 deletions(-) diff --git a/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoCreateNetworkInstance.bpmn b/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoCreateNetworkInstance.bpmn index 2f5fa39dbc..c049eaafa0 100644 --- a/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoCreateNetworkInstance.bpmn +++ b/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoCreateNetworkInstance.bpmn @@ -1,16 +1,12 @@ - + SequenceFlow_1n61wit - - isReturnCode404_No_SequenceFlow - - isNetworkActiveNo_SequenceFlow - isReturnCode404_Yes_SequenceFlow + isAAIQueryNameNo_SequenceFlow SequenceFlow_21 @@ -18,27 +14,27 @@ SequenceFlow_21 isNameSentNo_SequenceFlow SequenceFlow_32 - import org.onap.so.bpmn.infrastructure.scripts.* def DoCreateNetworkInstance = new DoCreateNetworkInstance() -DoCreateNetworkInstance.callRESTQueryAAICloudRegion(execution)]]> +DoCreateNetworkInstance.callRESTQueryAAICloudRegion(execution) isSdncRpc1No_SequenceFlow1 SequenceFlow_11 - import org.onap.so.bpmn.infrastructure.scripts.* def DoCreateNetworkInstance = new DoCreateNetworkInstance() DoCreateNetworkInstance.prepareSDNCRequest(execution) -]]> + SequenceFlow_12 SequenceFlow_0d93bqw SequenceFlow_5 - import org.onap.so.bpmn.infrastructure.scripts.* def DoCreateNetworkInstance = new DoCreateNetworkInstance() -DoCreateNetworkInstance.validateSDNCResponse(execution)]]> +DoCreateNetworkInstance.validateSDNCResponse(execution) SequenceFlow_5 @@ -47,7 +43,7 @@ DoCreateNetworkInstance.validateSDNCResponse(execution)]]> - + #{execution.getVariable("CRENWKI_sdncResponseSuccess" ) == true} @@ -63,9 +59,9 @@ DoCreateNetworkInstance.validateSDNCResponse(execution)]]> sdncTopoYes_SequenceFlow SequenceFlow_16 - import org.onap.so.bpmn.infrastructure.scripts.* def DoCreateNetworkInstance = new DoCreateNetworkInstance() -DoCreateNetworkInstance.callRESTQueryAAINetworkId(execution)]]> +DoCreateNetworkInstance.callRESTQueryAAINetworkId(execution) @@ -85,9 +81,9 @@ DoCreateNetworkInstance.callRESTQueryAAINetworkId(execution)]]> SequenceFlow_59 SequenceFlow_13 - import org.onap.so.bpmn.infrastructure.scripts.* def DoCreateNetworkInstance = new DoCreateNetworkInstance() -DoCreateNetworkInstance.validateCreateNetworkResponse(execution)]]> +DoCreateNetworkInstance.validateCreateNetworkResponse(execution) isAAIQueryNameYes_SequenceFlow @@ -95,7 +91,7 @@ DoCreateNetworkInstance.validateCreateNetworkResponse(execution)]]>isNetworkActiveNo_SequenceFlow - + #{execution.getVariable("CRENWKI_orchestrationStatus") == "ACTIVE"} @@ -103,20 +99,9 @@ DoCreateNetworkInstance.validateCreateNetworkResponse(execution)]]>isAAIQueryNameNo_SequenceFlow isAAIQueryNameYes_SequenceFlow - + - - - - isAAIQueryNameNo_SequenceFlow - isReturnCode404_No_SequenceFlow - isReturnCode404_Yes_SequenceFlow - - - - + #{execution.getVariable("CRENWKI_isAAIqueryNameGood") == true} @@ -130,7 +115,7 @@ DoCreateNetworkInstance.validateCreateNetworkResponse(execution)]]>isPONR_No_SequenceFlow - + #{execution.getVariable("CRENWKI_isPONR") == true} @@ -139,15 +124,15 @@ DoCreateNetworkInstance.validateCreateNetworkResponse(execution)]]>sdncOk_No_ExclusiveGateway - + #{execution.getVariable("CRENWKI_isSdncRollbackNeeded" ) == true} isSdncRpc4No_SequenceFlow4 SequenceFlow_0lndbvr - import org.onap.so.bpmn.infrastructure.scripts.* def DoCreateNetworkInstance = new DoCreateNetworkInstance() -DoCreateNetworkInstance.prepareSDNCRollbackRequest(execution)]]> +DoCreateNetworkInstance.prepareSDNCRollbackRequest(execution) isPONR_No_SequenceFlow @@ -155,7 +140,7 @@ DoCreateNetworkInstance.prepareSDNCRollbackRequest(execution)]]> SequenceFlow_12tlymf - + #{execution.getVariable("CRENWKI_isSdncActivateRollbackNeeded" ) == true} @@ -164,15 +149,15 @@ DoCreateNetworkInstance.prepareSDNCRollbackRequest(execution)]]> isSdncRpc4No_SequenceFlow4 - + #{execution.getVariable("sdncVersion") != '1610'} isSdncRpc4Yes_SequenceFlow4 SequenceFlow_0bwpkkb - import org.onap.so.bpmn.infrastructure.scripts.* def DoCreateNetworkInstance = new DoCreateNetworkInstance() -DoCreateNetworkInstance.prepareRpcSDNCRollbackRequest(execution)]]> +DoCreateNetworkInstance.prepareRpcSDNCRollbackRequest(execution) SequenceFlow_1qwubew @@ -180,17 +165,17 @@ DoCreateNetworkInstance.prepareRpcSDNCRollbackRequest(execution)]]> SequenceFlow_15sffxc SequenceFlow_096tad6 - import org.onap.so.bpmn.infrastructure.scripts.* def DoCreateNetworkInstance = new DoCreateNetworkInstance() -DoCreateNetworkInstance.prepareRollbackData(execution)]]> +DoCreateNetworkInstance.prepareRollbackData(execution) SequenceFlow_0cly7z2 SequenceFlow_0b8j5rw - import org.onap.so.bpmn.infrastructure.scripts.* def DoCreateNetworkInstance = new DoCreateNetworkInstance() -DoCreateNetworkInstance.prepareRpcSDNCActivateRollback(execution)]]> +DoCreateNetworkInstance.prepareRpcSDNCActivateRollback(execution) @@ -218,9 +203,9 @@ DoCreateNetworkInstance.prepareRpcSDNCActivateRollback(execution)]]>SequenceFlow_0vzsyrd SequenceFlow_17nx822 SequenceFlow_1qwubew - import org.onap.so.bpmn.infrastructure.scripts.* def DoCreateNetworkInstance = new DoCreateNetworkInstance() -DoCreateNetworkInstance.postProcessResponse(execution)]]> +DoCreateNetworkInstance.postProcessResponse(execution) @@ -229,7 +214,7 @@ DoCreateNetworkInstance.postProcessResponse(execution)]]> isRollbackOn_SequenceFlow_No - + #{execution.getVariable("CRENWKI_rollbackEnabled") == true && execution.getVariable("CRENWKI_isSdncRollbackNeeded") == true} @@ -254,24 +239,26 @@ DoCreateNetworkInstance.postProcessResponse(execution)]]> SequenceFlow_23 SequenceFlow_10ttvwn - import org.onap.so.bpmn.infrastructure.scripts.* def DoCreateNetworkInstance = new DoCreateNetworkInstance() DoCreateNetworkInstance.setExceptionFlag(execution) -]]> + - +    Include ONLY inputs/varrables:   rollbackData, as Map -rollbackSDNCRequest -rollbackActivateSDNCRequest -rollbackNetworkRequest WorkflowException - ]]> - +  + - PO Network Rollback is created in validation. - + + PO Network Rollback is created in validation. + @@ -279,8 +266,8 @@ WorkflowException ${CRENWKI_createNetworkRequest} - + ${UrnPropertiesReader.getVariable("mso.adapters.network.rest.endpoint", execution)} + #{BasicAuthHeaderValuePO} @@ -302,25 +289,25 @@ WorkflowException SequenceFlow_13 SequenceFlow_35 - import org.onap.so.bpmn.infrastructure.scripts.* def DoCreateNetworkInstance = new DoCreateNetworkInstance() -DoCreateNetworkInstance.callRESTReQueryAAINetworkId(execution)]]> +DoCreateNetworkInstance.callRESTReQueryAAINetworkId(execution) SequenceFlow_35 SequenceFlow_1ipz2ze - import org.onap.so.bpmn.infrastructure.scripts.* def DoCreateNetworkInstance = new DoCreateNetworkInstance() -DoCreateNetworkInstance.callRESTUpdateContrailAAINetwork(execution)]]> +DoCreateNetworkInstance.callRESTUpdateContrailAAINetwork(execution) SequenceFlow_10 SequenceFlow_14 - import org.onap.so.bpmn.infrastructure.scripts.* def DoCreateNetworkInstance = new DoCreateNetworkInstance() -DoCreateNetworkInstance.processJavaException(execution)]]> +DoCreateNetworkInstance.processJavaException(execution) @@ -335,52 +322,52 @@ DoCreateNetworkInstance.processJavaException(execution)]]> isNameSentYes_SequenceFlow SequenceFlow_6 - import org.onap.so.bpmn.infrastructure.scripts.* def DoCreateNetworkInstance = new DoCreateNetworkInstance() -DoCreateNetworkInstance.callRESTQueryAAINetworkName(execution)]]> +DoCreateNetworkInstance.callRESTQueryAAINetworkName(execution) SequenceFlow_16 SequenceFlow_15 - import org.onap.so.bpmn.infrastructure.scripts.* def DoCreateNetworkInstance = new DoCreateNetworkInstance() -DoCreateNetworkInstance.callRESTQueryAAINetworkVpnBinding(execution)]]> +DoCreateNetworkInstance.callRESTQueryAAINetworkVpnBinding(execution) SequenceFlow_15 SequenceFlow_38 - import org.onap.so.bpmn.infrastructure.scripts.* def DoCreateNetworkInstance = new DoCreateNetworkInstance() -DoCreateNetworkInstance.callRESTQueryAAINetworkPolicy(execution)]]> +DoCreateNetworkInstance.callRESTQueryAAINetworkPolicy(execution) SequenceFlow_20 SequenceFlow_61 - import org.onap.so.bpmn.infrastructure.scripts.* def DoCreateNetworkInstance = new DoCreateNetworkInstance() DoCreateNetworkInstance.prepareCreateNetworkRequest(execution) -]]> + SequenceFlow_38 SequenceFlow_20 - import org.onap.so.bpmn.infrastructure.scripts.* def DoCreateNetworkInstance = new DoCreateNetworkInstance() -DoCreateNetworkInstance.callRESTQueryAAINetworkTableRef(execution)]]> +DoCreateNetworkInstance.callRESTQueryAAINetworkTableRef(execution) SequenceFlow_1n61wit SequenceFlow_0ftylq3 - import org.onap.so.bpmn.infrastructure.scripts.* def DoCreateNetworkInstance = new DoCreateNetworkInstance() -DoCreateNetworkInstance.preProcessRequest(execution)]]> +DoCreateNetworkInstance.preProcessRequest(execution) @@ -389,7 +376,7 @@ DoCreateNetworkInstance.preProcessRequest(execution)]]> isNameSentNo_SequenceFlow - + #{execution.getVariable("CRENWKI_networkName") != ""} @@ -408,9 +395,9 @@ DoCreateNetworkInstance.preProcessRequest(execution)]]> isSdncRpc2Yes_SequenceFlow2 SequenceFlow_13deudk - import org.onap.so.bpmn.infrastructure.scripts.* def DoCreateNetworkInstance = new DoCreateNetworkInstance() -DoCreateNetworkInstance.prepareRpcSDNCActivateRequest(execution)]]> +DoCreateNetworkInstance.prepareRpcSDNCActivateRequest(execution) SequenceFlow_1t03rs2 @@ -421,15 +408,15 @@ DoCreateNetworkInstance.prepareRpcSDNCActivateRequest(execution)]]> - + #{execution.getVariable("CRENWKI_sdncResponseSuccess" ) == true} SequenceFlow_08qibb9 SequenceFlow_1t03rs2 - import org.onap.so.bpmn.infrastructure.scripts.* def DoCreateNetworkInstance = new DoCreateNetworkInstance() -DoCreateNetworkInstance.validateRpcSDNCActivateResponse(execution)]]> +DoCreateNetworkInstance.validateRpcSDNCActivateResponse(execution) SequenceFlow_0s51ns0 @@ -448,7 +435,7 @@ DoCreateNetworkInstance.validateRpcSDNCActivateResponse(execution)]]> - + #{execution.getVariable("sdncVersion") != '1610'} @@ -471,16 +458,16 @@ DoCreateNetworkInstance.validateRpcSDNCActivateResponse(execution)]]>isSdncRpc2No_SequenceFlow2 - + #{execution.getVariable("sdncVersion") != '1610'} isSdncRpc1Yes_SequenceFlow1 SequenceFlow_0j8bxnb - import org.onap.so.bpmn.infrastructure.scripts.* def DoCreateNetworkInstance = new DoCreateNetworkInstance() DoCreateNetworkInstance.prepareRpcSDNCRequest(execution) -]]> + SequenceFlow_1s8b1m1 @@ -493,28 +480,29 @@ DoCreateNetworkInstance.prepareRpcSDNCRequest(execution) SequenceFlow_1jia57e isSdncRpc2No_SequenceFlow2 SequenceFlow_1s8b1m1 - import org.onap.so.bpmn.infrastructure.scripts.* def DoCreateNetworkInstance = new DoCreateNetworkInstance() -DoCreateNetworkInstance.postProcessResponse(execution)]]> +DoCreateNetworkInstance.postProcessResponse(execution) isNetworkActiveYes_SequenceFlow SequenceFlow_18ylufb - import org.onap.so.bpmn.infrastructure.scripts.* def DoCreateNetworkInstance = new DoCreateNetworkInstance() -DoCreateNetworkInstance.postProcessResponse(execution)]]> +DoCreateNetworkInstance.postProcessResponse(execution) SequenceFlow_0ftylq3 SequenceFlow_3 - import org.onap.so.bpmn.infrastructure.scripts.* def DoCreateNetworkInstance = new DoCreateNetworkInstance() -DoCreateNetworkInstance.getServiceInstance(execution)]]> +DoCreateNetworkInstance.getServiceInstance(execution) - - + + if '200', Prepare PO Network Rollback + @@ -537,8 +525,8 @@ DoCreateNetworkInstance.getServiceInstance(execution)]]> - - + + @@ -546,50 +534,23 @@ DoCreateNetworkInstance.getServiceInstance(execution)]]> - - - + + + + - + - - - - + + + + - - - - - - - - - - - - - - - - - - - - - - - - - - - - @@ -612,15 +573,15 @@ DoCreateNetworkInstance.getServiceInstance(execution)]]> - - + + - - + + @@ -635,22 +596,22 @@ DoCreateNetworkInstance.getServiceInstance(execution)]]> - - + + - - + + - - + + @@ -659,10 +620,10 @@ DoCreateNetworkInstance.getServiceInstance(execution)]]> - - - - + + + + @@ -674,22 +635,22 @@ DoCreateNetworkInstance.getServiceInstance(execution)]]> - - + + - - + + - - + + @@ -710,8 +671,8 @@ DoCreateNetworkInstance.getServiceInstance(execution)]]> - - + + @@ -720,28 +681,28 @@ DoCreateNetworkInstance.getServiceInstance(execution)]]> - - - - + + + + - - - - + + + + - - - - + + + + @@ -750,10 +711,10 @@ DoCreateNetworkInstance.getServiceInstance(execution)]]> - - - - + + + + @@ -762,8 +723,8 @@ DoCreateNetworkInstance.getServiceInstance(execution)]]> - - + + @@ -775,16 +736,16 @@ DoCreateNetworkInstance.getServiceInstance(execution)]]> - - - + + + - - + + @@ -796,17 +757,17 @@ DoCreateNetworkInstance.getServiceInstance(execution)]]> - - - + + + - - - + + + @@ -815,8 +776,8 @@ DoCreateNetworkInstance.getServiceInstance(execution)]]> - - + + @@ -828,8 +789,8 @@ DoCreateNetworkInstance.getServiceInstance(execution)]]> - - + + @@ -838,8 +799,8 @@ DoCreateNetworkInstance.getServiceInstance(execution)]]> - - + + @@ -863,23 +824,23 @@ DoCreateNetworkInstance.getServiceInstance(execution)]]> - - + + - - + + - - - + + + @@ -888,19 +849,19 @@ DoCreateNetworkInstance.getServiceInstance(execution)]]> - - - - + + + + - - - - + + + + @@ -909,10 +870,10 @@ DoCreateNetworkInstance.getServiceInstance(execution)]]> - - - - + + + + @@ -924,17 +885,17 @@ DoCreateNetworkInstance.getServiceInstance(execution)]]> - - - - + + + + - - + + @@ -952,36 +913,36 @@ DoCreateNetworkInstance.getServiceInstance(execution)]]> - - + + - - + + - - + + - - + + - - + + @@ -996,9 +957,9 @@ DoCreateNetworkInstance.getServiceInstance(execution)]]> - - - + + + @@ -1016,16 +977,16 @@ DoCreateNetworkInstance.getServiceInstance(execution)]]> - - + + - - - + + + @@ -1037,16 +998,16 @@ DoCreateNetworkInstance.getServiceInstance(execution)]]> - - - + + + - - + + @@ -1055,15 +1016,15 @@ DoCreateNetworkInstance.getServiceInstance(execution)]]> - - + + - - + + @@ -1075,16 +1036,16 @@ DoCreateNetworkInstance.getServiceInstance(execution)]]> - - + + - - - + + + @@ -1096,16 +1057,16 @@ DoCreateNetworkInstance.getServiceInstance(execution)]]> - - + + - - - + + + @@ -1135,10 +1096,10 @@ DoCreateNetworkInstance.getServiceInstance(execution)]]> - - - - + + + + @@ -1150,8 +1111,8 @@ DoCreateNetworkInstance.getServiceInstance(execution)]]> - - + + @@ -1160,10 +1121,10 @@ DoCreateNetworkInstance.getServiceInstance(execution)]]> - - - - + + + + @@ -1172,30 +1133,30 @@ DoCreateNetworkInstance.getServiceInstance(execution)]]> - - + + - - + + - - - + + + - - + + @@ -1204,15 +1165,15 @@ DoCreateNetworkInstance.getServiceInstance(execution)]]> - - + + - - + + @@ -1224,15 +1185,15 @@ DoCreateNetworkInstance.getServiceInstance(execution)]]> - - + + - - + + @@ -1244,8 +1205,8 @@ DoCreateNetworkInstance.getServiceInstance(execution)]]> - - + + @@ -1257,8 +1218,8 @@ DoCreateNetworkInstance.getServiceInstance(execution)]]> - - + + @@ -1267,8 +1228,8 @@ DoCreateNetworkInstance.getServiceInstance(execution)]]> - - + + @@ -1280,9 +1241,9 @@ DoCreateNetworkInstance.getServiceInstance(execution)]]> - - - + + + @@ -1291,22 +1252,22 @@ DoCreateNetworkInstance.getServiceInstance(execution)]]> - - + + - - + + - - + + -- cgit 1.2.3-korg