aboutsummaryrefslogtreecommitdiffstats
path: root/ransim/ransimctrlr/RANSIM-CTRLR/src/main/java/org/onap/ransim/rest/api/services/SlicingPMDataGenerator.java
diff options
context:
space:
mode:
authorNiranjana <niranjana.y60@wipro.com>2021-06-15 10:19:24 +0000
committerNiranjana <niranjana.y60@wipro.com>2021-06-15 10:19:24 +0000
commit410d8e3b6e201d607f6c7c291ed7125cfd7103aa (patch)
tree59482d59880df52add6ea0b4d7c278a6944c9f09 /ransim/ransimctrlr/RANSIM-CTRLR/src/main/java/org/onap/ransim/rest/api/services/SlicingPMDataGenerator.java
parentf11ea46a4b97f89c27d3c7129fb2500b54cc04f7 (diff)
Fix bugs in updating RIC data in ransim db
Issue-ID: INT-1931 Signed-off-by: Niranjana <niranjana.y60@wipro.com> Change-Id: Icc268e6168f1a7f93514b2168e53a838bfe663d7
Diffstat (limited to 'ransim/ransimctrlr/RANSIM-CTRLR/src/main/java/org/onap/ransim/rest/api/services/SlicingPMDataGenerator.java')
-rw-r--r--ransim/ransimctrlr/RANSIM-CTRLR/src/main/java/org/onap/ransim/rest/api/services/SlicingPMDataGenerator.java5
1 files changed, 4 insertions, 1 deletions
diff --git a/ransim/ransimctrlr/RANSIM-CTRLR/src/main/java/org/onap/ransim/rest/api/services/SlicingPMDataGenerator.java b/ransim/ransimctrlr/RANSIM-CTRLR/src/main/java/org/onap/ransim/rest/api/services/SlicingPMDataGenerator.java
index 1a74c25..e61e14f 100644
--- a/ransim/ransimctrlr/RANSIM-CTRLR/src/main/java/org/onap/ransim/rest/api/services/SlicingPMDataGenerator.java
+++ b/ransim/ransimctrlr/RANSIM-CTRLR/src/main/java/org/onap/ransim/rest/api/services/SlicingPMDataGenerator.java
@@ -31,6 +31,7 @@ import java.util.Collections;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
+import java.util.Objects;
import java.util.Random;
import java.util.Set;
import java.util.concurrent.atomic.AtomicInteger;
@@ -104,10 +105,12 @@ public class SlicingPMDataGenerator {
List<NRCellDUModel> duCellList = du.getCellDUList();
int ricId = du.getNearRTRICId();
List<PLMNInfoModel> plmnInfoList = new ArrayList<>();
+ duCellList.stream().filter(cell -> (!Objects.isNull(cell.getpLMNInfoList())));
duCellList.forEach(cell -> plmnInfoList.addAll(cell.getpLMNInfoList()));
List<NSSAIData> nssaiData = new ArrayList<>();
plmnInfoList.forEach(plmnInfo -> nssaiData.add(plmnInfo.getsNSSAI()));
- nssaiData.stream().filter(nssai -> nssai.getStatus().equalsIgnoreCase("active"))
+ nssaiData.stream().filter(
+ nssai -> (!(Objects.isNull(nssai.getStatus()))) && nssai.getStatus().equalsIgnoreCase("active"))
.forEach(x -> activeNssaiDetails.put(x.getsNSSAI(), x.getConfigData()));
produceMeasurementCollectionFile(du, activeNssaiDetails, duCellList, ricId);
logger.info("PM data generated for DU : " + du.getgNBDUName() + " Id: " + du.getgNBDUId());