diff options
Diffstat (limited to 'bpmn')
3 files changed, 15 insertions, 11 deletions
diff --git a/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoAllocateNSIandNSSI.groovy b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoAllocateNSIandNSSI.groovy index a22819f2e9..2317e98dac 100644 --- a/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoAllocateNSIandNSSI.groovy +++ b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoAllocateNSIandNSSI.groovy @@ -80,7 +80,7 @@ class DoAllocateNSIandNSSI extends AbstractServiceTaskProcessor{ logger.trace("Enter preProcessRequest()") Map<String, Object> nssiMap = new HashMap<>() int nsstCount=execution.getVariable("nsstCount") as int - if(nsstCount==5){ + if(nsstCount==6){ execution.setVariable("processFHandMH", true) } else{ @@ -313,7 +313,7 @@ class DoAllocateNSIandNSSI extends AbstractServiceTaskProcessor{ SliceProfile sliceProfile = new SliceProfile() sliceProfile.setProfileId(profileId) - sliceProfile.setCoverageAreaTAList(anSliceProfile.coverageAreaTAList) + sliceProfile.setCoverageAreaTAList(anSliceProfile.coverageAreaTAList as String) sliceProfile.setMaxNumberOfUEs(anSliceProfile.maxNumberOfUEs) sliceProfile.setLatency(anSliceProfile.latency) sliceProfile.setMaxNumberOfPDUSession(anSliceProfile.maxNumberOfPDUSession) @@ -1197,8 +1197,8 @@ class DoAllocateNSIandNSSI extends AbstractServiceTaskProcessor{ TransportSliceNetwork transportSliceNetwork = new TransportSliceNetwork() List<ConnectionLink> connectionLinks = new ArrayList<>() ConnectionLink connectionLink = new ConnectionLink() - connectionLink.setTransportEndpointA(execution.getVariable("tranportEp_ID_RU") as String) - connectionLink.setTransportEndpointB(execution.getVariable("tranportEp_ID_DUIN") as String) + connectionLink.setTransportEndpointA(UUID.randomUUID().toString()) + connectionLink.setTransportEndpointB(UUID.randomUUID().toString()) connectionLinks.add(connectionLink) transportSliceNetwork.setConnectionLinks(connectionLinks) transportSliceNetworks.add(transportSliceNetwork) @@ -1222,7 +1222,7 @@ class DoAllocateNSIandNSSI extends AbstractServiceTaskProcessor{ .subscriptionServiceType(subscriptionServiceType) .nsiId(sliceParams.getSuggestNsiId()) .serviceInvariantUuid(sliceTaskInfo.getNSSTInfo().getInvariantUUID()) - .setServiceUuid(sliceTaskInfo.getNSSTInfo().getUUID()) + .serviceUuid(sliceTaskInfo.getNSSTInfo().getUUID()) .nssiId(sliceTaskInfo.getSuggestNssiId()) .sST(sliceTaskInfo.getSliceProfile().getSST() ?: sliceParams.getServiceProfile().get("sST")) .nssiName("nssi_tn_fh_" + execution.getVariable("sliceServiceInstanceName") as String) @@ -1234,7 +1234,7 @@ class DoAllocateNSIandNSSI extends AbstractServiceTaskProcessor{ execution.setVariable("TnFHAllocateNssiNbiRequest", nbiRequest) execution.setVariable("tnFHSliceTaskInfo", sliceTaskInfo) - execution.setVariable("tnFHSubnetType", SubnetType.TN_BH) + execution.setVariable("tnFHSubnetType", SubnetType.TN_FH) } /** @@ -1350,8 +1350,8 @@ class DoAllocateNSIandNSSI extends AbstractServiceTaskProcessor{ TransportSliceNetwork transportSliceNetwork = new TransportSliceNetwork() List<ConnectionLink> connectionLinks = new ArrayList<>() ConnectionLink connectionLink = new ConnectionLink() - connectionLink.setTransportEndpointA(execution.getVariable("tranportEp_ID_DUEG") as String) - connectionLink.setTransportEndpointB(execution.getVariable("tranportEp_ID_CUIN") as String) + connectionLink.setTransportEndpointA(UUID.randomUUID().toString()) + connectionLink.setTransportEndpointB(UUID.randomUUID().toString()) connectionLinks.add(connectionLink) transportSliceNetwork.setConnectionLinks(connectionLinks) transportSliceNetworks.add(transportSliceNetwork) @@ -1378,7 +1378,7 @@ class DoAllocateNSIandNSSI extends AbstractServiceTaskProcessor{ .serviceUuid(sliceTaskInfo.getNSSTInfo().getUUID()) .nssiId(sliceTaskInfo.getSuggestNssiId()) .sST(sliceTaskInfo.getSliceProfile().getSST() ?: sliceParams.getServiceProfile().get("sST")) - .nssiName("nssi_tn_bh_" + execution.getVariable("sliceServiceInstanceName") as String) + .nssiName("nssi_tn_mh_" + execution.getVariable("sliceServiceInstanceName") as String) .build() nbiRequest.setServiceInfo(serviceInfo) @@ -1387,7 +1387,7 @@ class DoAllocateNSIandNSSI extends AbstractServiceTaskProcessor{ execution.setVariable("TnMHAllocateNssiNbiRequest", nbiRequest) execution.setVariable("tnMHSliceTaskInfo", sliceTaskInfo) - execution.setVariable("tnMHSubnetType", SubnetType.TN_BH) + execution.setVariable("tnMHSubnetType", SubnetType.TN_MH) } /** diff --git a/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoAllocateNSSI.groovy b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoAllocateNSSI.groovy index 6981d94324..fc873be28e 100644 --- a/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoAllocateNSSI.groovy +++ b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoAllocateNSSI.groovy @@ -110,7 +110,9 @@ class DoAllocateNSSI extends AbstractServiceTaskProcessor { execution.setVariable("nssiAllocateStatus", jobStatusResponse) if (jobStatusResponse.getResponseDescriptor().getProgress() == 100) { + if (nssiId == null) { nssiAllocateResult.setNssiId(jobStatusResponse.getResponseDescriptor().getNssiId()) + } execution.setVariable("jobFinished", true) } } diff --git a/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoAllocateNSIandNSSI.bpmn b/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoAllocateNSIandNSSI.bpmn index 51f96ee8a9..e35a197b7b 100644 --- a/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoAllocateNSIandNSSI.bpmn +++ b/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoAllocateNSIandNSSI.bpmn @@ -413,7 +413,9 @@ dcnsio.updateTnMHRelationship(execution)</bpmn:script> <bpmn:incoming>Flow_13i03hb</bpmn:incoming> <bpmn:linkEventDefinition id="LinkEventDefinition_1rscmuw" name="CreateTnFHSliceProfile" /> </bpmn:intermediateThrowEvent> - <bpmn:sequenceFlow id="Flow_0ehx22x" sourceRef="Gateway_0tpcoai" targetRef="EndEvent_02c8wsp" /> + <bpmn:sequenceFlow id="Flow_0ehx22x" name="no" sourceRef="Gateway_0tpcoai" targetRef="EndEvent_02c8wsp"> + <bpmn:conditionExpression xsi:type="bpmn:tFormalExpression">#{(execution.getVariable("processFHandMH" ) == false)}</bpmn:conditionExpression> + </bpmn:sequenceFlow> <bpmn:sequenceFlow id="Flow_13i03hb" name="yes" sourceRef="Gateway_0tpcoai" targetRef="Event_1hemevb"> <bpmn:conditionExpression xsi:type="bpmn:tFormalExpression">#{(execution.getVariable("processFHandMH" ) == true)}</bpmn:conditionExpression> </bpmn:sequenceFlow> |