Skip to content

A
amos-boot-biz
Commit 878fde0e authored by 刘凡's avatar 刘凡
Browse files
Options

*）设置聚合数量

parent 9adf3fec
Hide whitespace changes
Inline Side-by-side
Showing with 2 additions and 4 deletions
amos-boot-system-tzs/amos-boot-module-statistics/amos-boot-module-statistics-biz/src/main/java/com/yeejoin/amos/boot/module/statistcs/biz/service/impl/ZLDPStatisticsServiceImpl.java
View file @ 878fde0e
...@@ -465,9 +465,7 @@ public class ZLDPStatisticsServiceImpl { ...@@ -465,9 +465,7 @@ public class ZLDPStatisticsServiceImpl {
String orgCode = getAndSetOrgCode(screenDto.getCityCode()); String orgCode = getAndSetOrgCode(screenDto.getCityCode());
searchSourceBuilder.query(QueryBuilders.boolQuery() searchSourceBuilder.query(QueryBuilders.boolQuery()
.must(QueryBuilders.wildcardQuery("ORG_BRANCH_CODE.keyword", QueryParser.escape(orgCode) + "*"))); .must(QueryBuilders.wildcardQuery("ORG_BRANCH_CODE.keyword", QueryParser.escape(orgCode) + "*")));
searchSourceBuilder.aggregation( searchSourceBuilder.aggregation(AggregationBuilders.terms("count_by_use_site_code").field("USE_SITE_CODE").size(20));
AggregationBuilders.terms("USE_SITE_CODE").field("USE_SITE_CODE")
);
searchRequest.source(searchSourceBuilder); searchRequest.source(searchSourceBuilder);
Map<String, Integer> dataMap = new HashMap<>(); Map<String, Integer> dataMap = new HashMap<>();
List<Map<String, Object>> returnList = new ArrayList<>(); List<Map<String, Object>> returnList = new ArrayList<>();
...@@ -476,7 +474,7 @@ public class ZLDPStatisticsServiceImpl { ...@@ -476,7 +474,7 @@ public class ZLDPStatisticsServiceImpl {
SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT); SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);
// 获取所有聚合结果 // 获取所有聚合结果
Aggregations aggregations = searchResponse.getAggregations(); Aggregations aggregations = searchResponse.getAggregations();
Terms termsResult = aggregations.get("USE_SITE_CODE"); Terms termsResult = aggregations.get("count_by_use_site_code");
for (Terms.Bucket bucket : termsResult.getBuckets()) { for (Terms.Bucket bucket : termsResult.getBuckets()) {
String category = bucket.getKeyAsString(); // 或者使用 bucket.getKey() 对于非字符串类型 String category = bucket.getKeyAsString(); // 或者使用 bucket.getKey() 对于非字符串类型
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment