...
|
...
|
@@ -29,8 +29,9 @@ public class AggBrandListService extends AbstractCacheComponent<List<AggBrand>> |
|
|
|
|
|
public List<AggBrand> aggBrands(ParamQueryFilter paramQueryFilter) {
|
|
|
List<AggBrand> value;
|
|
|
SearchParam searchParam = searchParamHelper.buildSearchParam(paramQueryFilter);
|
|
|
try {
|
|
|
value = queryWithCache(paramQueryFilter, null);
|
|
|
value = queryWithCache(searchParam, null);
|
|
|
} catch (Exception e) {
|
|
|
return Collections.emptyList();
|
|
|
}
|
...
|
...
|
@@ -52,12 +53,11 @@ public class AggBrandListService extends AbstractCacheComponent<List<AggBrand>> |
|
|
}
|
|
|
|
|
|
@Override
|
|
|
protected List<AggBrand> doRealQuery(ParamQueryFilter paramQueryFilter, Map<String, String> paramMap) {
|
|
|
protected List<AggBrand> doRealQuery(SearchParam searchParam, Map<String, String> paramMap) {
|
|
|
List<AbstractAggregationBuilder<?>> aggregationBuilders = new ArrayList<>();
|
|
|
TermsAggregationBuilder firstAggregationBuilder = AggregationBuilders.terms("brandAgg").field(ProductIndexEsField.brandId).size(500);
|
|
|
aggregationBuilders.add(firstAggregationBuilder);
|
|
|
|
|
|
SearchParam searchParam = searchParamHelper.buildSearchParam(paramQueryFilter);
|
|
|
searchParam.setAggregationBuilders(aggregationBuilders);
|
|
|
SearchResult searchResult = searchCommonService.doSearch(ISearchConstants.INDEX_NAME_PRODUCT_INDEX, searchParam);
|
|
|
Map<String, Aggregation> aggregationMap = searchResult.getAggMaps();
|
...
|
...
|
|