diff options
author | Pawel <pawel.kasperkiewicz@nokia.com> | 2018-04-20 13:43:06 +0200 |
---|---|---|
committer | James Forsyth <jf2512@att.com> | 2018-05-23 20:18:59 +0000 |
commit | 6bbcdab2b14a179524db0efb34fb2f90d88b266e (patch) | |
tree | b282c9a3370ef17570ee12a6f8ac3da940068367 | |
parent | c01d79c6605f11b29d65f6f7fa6a909554df5e2b (diff) |
fixes in AggregateSummaryProcessor.java
Issue-ID: AAI-1048
Change-Id: I3cc8be604b41b48c4a881c1b6b816f2a7b97abaa
Signed-off-by: Pawel <pawel.kasperkiewicz@nokia.com>
-rw-r--r-- | sparkybe-onap-service/src/main/java/org/onap/aai/sparky/aggregatevnf/search/AggregateSummaryProcessor.java | 23 |
1 files changed, 10 insertions, 13 deletions
diff --git a/sparkybe-onap-service/src/main/java/org/onap/aai/sparky/aggregatevnf/search/AggregateSummaryProcessor.java b/sparkybe-onap-service/src/main/java/org/onap/aai/sparky/aggregatevnf/search/AggregateSummaryProcessor.java index 949c369..24ba725 100644 --- a/sparkybe-onap-service/src/main/java/org/onap/aai/sparky/aggregatevnf/search/AggregateSummaryProcessor.java +++ b/sparkybe-onap-service/src/main/java/org/onap/aai/sparky/aggregatevnf/search/AggregateSummaryProcessor.java @@ -47,6 +47,10 @@ public class AggregateSummaryProcessor { LoggerFactory.getInstance().getLogger(AggregateSummaryProcessor.class); private static final String KEY_FILTERS = "filters"; + private static final String FILTER_ID_KEY = "filterId"; + private static final String FILTER_VALUE_KEY = "filterValue"; + private static final String TOTAL = "total"; + private static final int DEFAULT_SHOULD_MATCH_SCORE = 1; private ElasticSearchAdapter elasticSearchAdapter = null; @@ -99,7 +103,7 @@ public class AggregateSummaryProcessor { } if (requestFilters != null && requestFilters.length() > 0) { - List<JSONObject> filtersToQuery = new ArrayList<JSONObject>(); + List<JSONObject> filtersToQuery = new ArrayList<>(); for (int i = 0; i < requestFilters.length(); i++) { JSONObject filterEntry = requestFilters.getJSONObject(i); filtersToQuery.add(filterEntry); @@ -122,7 +126,6 @@ public class AggregateSummaryProcessor { LOG.error(AaiUiMsgs.ERROR_GENERIC, "AggregateSummaryProcessor failed to process request due to error = " + exc.getMessage()); - } } @@ -136,15 +139,9 @@ public class AggregateSummaryProcessor { return payload.toString(); } - private static final String FILTER_ID_KEY = "filterId"; - private static final String FILTER_VALUE_KEY = "filterValue"; - private static final int DEFAULT_SHOULD_MATCH_SCORE = 1; - private static final String VNF_FILTER_AGGREGATION = "vnfFilterAggregation"; - - - private String getVnfFilterAggregations(List<JSONObject> filtersToQuery) throws IOException { + private String getVnfFilterAggregations(List<JSONObject> filtersToQuery) { - List<SearchFilter> searchFilters = new ArrayList<SearchFilter>(); + List<SearchFilter> searchFilters = new ArrayList<>(); for (JSONObject filterEntry : filtersToQuery) { String filterId = filterEntry.getString(FILTER_ID_KEY); @@ -180,7 +177,7 @@ public class AggregateSummaryProcessor { private String buildEmptyAggregateVnfResponseJson() { JSONObject finalOutputToFe = new JSONObject(); - finalOutputToFe.put("total", 0); + finalOutputToFe.put(TOTAL, 0); return finalOutputToFe.toString(); } @@ -191,8 +188,8 @@ public class AggregateSummaryProcessor { JSONObject hits = responseJson.getJSONObject("hits"); - int totalHits = hits.getInt("total"); - finalOutputToFe.put("total", totalHits); + int totalHits = hits.getInt(TOTAL); + finalOutputToFe.put(TOTAL, totalHits); JSONObject aggregations = responseJson.getJSONObject("aggregations"); String[] aggKeys = JSONObject.getNames(aggregations); |