1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
|
/*******************************************************************************
* ============LICENSE_START=======================================================
* slice-analysis-ms
* ================================================================================
* Copyright (C) 2020 Wipro Limited.
* ==============================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
* ============LICENSE_END=========================================================
*
*******************************************************************************/
package org.onap.slice.analysis.ms.service;
import java.util.HashMap;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;
import org.onap.slice.analysis.ms.models.MeasurementObject;
import org.onap.slice.analysis.ms.models.pmnotification.Event;
import org.onap.slice.analysis.ms.models.pmnotification.MeasInfoList;
import org.onap.slice.analysis.ms.models.pmnotification.MeasResult;
import org.onap.slice.analysis.ms.models.pmnotification.MeasValuesList;
import org.springframework.context.annotation.Scope;
import org.springframework.stereotype.Component;
/**
* This class is responsible for processing PmEvent
*/
@Component
@Scope("prototype")
public class PmEventProcessor implements IPmEventProcessor{
protected Map<String, List<MeasurementObject>> instanceMap = new HashMap<>();
/**
* Process the PM event
*/
public Map<String, List<MeasurementObject>> processEvent(Event event) {
List<MeasInfoList> measurements = event.getPerf3gppFields().getMeasDataCollection().getMeasInfoList();
measurements.forEach(measurement -> {
List<String> collectedSubCounters = measurement.getMeasTypes().getsMeasTypesList();
List<MeasValuesList> subCounterMeasurements = measurement.getMeasValuesList();
subCounterMeasurements.forEach(subCounterMeasurement -> processMeasurementObjectData(collectedSubCounters, subCounterMeasurement));
});
return instanceMap;
}
/**
* Process the measurement data from every measurement object. eg cell
*/
public void processMeasurementObjectData(List<String> collectedSubCounters, MeasValuesList subCounterMeasurement) {
List<MeasResult> measResultList = subCounterMeasurement.getMeasResults();
String measObjId = subCounterMeasurement.getMeasObjInstId();
measResultList.forEach(measResult -> {
String pmName = collectedSubCounters.get(measResult.getP()-1);
Integer pmValue = Integer.valueOf(measResult.getsValue());
Map<String,String> pmMapping = getMapKey(pmName);
String snssai = pmMapping.get("snssai");
String pm = pmMapping.get("pm");
Map<String, Integer> pmData = new HashMap<>();
pmData.put(pm, pmValue);
if (instanceMap.containsKey(snssai)) {
int index = instanceMap.get(snssai).indexOf(new MeasurementObject(measObjId));
if (index == -1) {
instanceMap.get(snssai).add(new MeasurementObject(measObjId,pmData));
}
else {
instanceMap.get(snssai).get(index).getPmData().put(pmName, pmValue);
}
}
else {
List<MeasurementObject> l = new LinkedList<>();
l.add(new MeasurementObject(measObjId,pmData));
instanceMap.put(snssai, l);
}
});
}
/**
* Fetch pm name and S-NSSAI
*/
public Map<String, String> getMapKey(String pmName) {
String [] pmNameArr = pmName.split("\\.");
String snssai = "";
String pm = pmNameArr[1];
Map<String, String> result = new HashMap<>();
result.put("pm", pm);
if ((pm.equalsIgnoreCase("PrbUsedDl")) || (pm.equalsIgnoreCase("PrbUsedUl"))){
snssai = pmNameArr[2];
}
result.put("snssai", snssai);
return result;
}
}
|
