Commit e1ad9c53 authored by suhuiguang's avatar suhuiguang

1.树数量统计未包括自身数量

parent 72452dd5
...@@ -1322,7 +1322,7 @@ public class BuildingServiceImpl extends ServiceImpl<BuildingMapper, Building> i ...@@ -1322,7 +1322,7 @@ public class BuildingServiceImpl extends ServiceImpl<BuildingMapper, Building> i
return companyList.stream().filter(a -> companyList.stream().noneMatch(c -> c.getId().toString().equals(a.getParentId()))) return companyList.stream().filter(a -> companyList.stream().noneMatch(c -> c.getId().toString().equals(a.getParentId())))
.peek(b -> { .peek(b -> {
b.setChildren(getCompanyBuildingChildrenTree(b.getId().toString(), companyList)); b.setChildren(getCompanyBuildingChildrenTree(b.getId().toString(), companyList));
b.setTotal(b.getChildren().stream().filter(c -> c.getTotal() != null).mapToLong(BuildingTreeVo::getTotal).sum()); b.setTotal(b.getChildren().stream().filter(c -> c.getTotal() != null).mapToLong(BuildingTreeVo::getTotal).sum() + b.getTotal());
}).collect(Collectors.toList()); }).collect(Collectors.toList());
} }
......
...@@ -41,12 +41,9 @@ public class ElasticSearchClientConfig { ...@@ -41,12 +41,9 @@ public class ElasticSearchClientConfig {
final String[] parts = StringUtils.split(url, ":"); final String[] parts = StringUtils.split(url, ":");
HttpHost httpHost = new HttpHost(parts[0], Integer.parseInt(parts[1]), "http"); HttpHost httpHost = new HttpHost(parts[0], Integer.parseInt(parts[1]), "http");
RestClientBuilder builder = RestClient.builder(httpHost); RestClientBuilder builder = RestClient.builder(httpHost);
builder.setHttpClientConfigCallback(new RestClientBuilder.HttpClientConfigCallback() { builder.setHttpClientConfigCallback(httpClientBuilder -> {
@Override httpClientBuilder.disableAuthCaching();
public HttpAsyncClientBuilder customizeHttpClient(HttpAsyncClientBuilder httpClientBuilder) { return httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider);
httpClientBuilder.disableAuthCaching();
return httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider);
}
}); });
builder.setRequestConfigCallback(new RestClientBuilder.RequestConfigCallback() { builder.setRequestConfigCallback(new RestClientBuilder.RequestConfigCallback() {
// 该方法接收一个RequestConfig.Builder对象,对该对象进行修改后然后返回。 // 该方法接收一个RequestConfig.Builder对象,对该对象进行修改后然后返回。
......
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