查询方法
@Override
public Page
查询结果方法
Page
封装的查询条件
// 查询条件
BoolQueryBuilder getQueryByEntity(QueryListDomain query){
formatQueryTime(query);
// query 条件
BoolQueryBuilder queryBuilder = QueryBuilders.boolQuery();
// 完全匹配
if(query.getLoanSource().size() > 0){
queryBuilder.must(QueryBuilders.termsQuery("loanSource.keyword", query.getLoanSource()));
}
// 模糊
if(StringUtils.isNotEmpty(query.getCustNo())){
queryBuilder.must(QueryBuilders.matchPhraseQuery("custNo", query.getCustNo()));
}
List address = new ArrayList<>();
if(query.getAddressArr() != null && query.getAddressArr().length > 0){
address.add(StringUtils.join(query.getAddressArr(), ""));
}
if(query.getAddressCensus() != null && query.getAddressCensus().length > 0){
address.add(StringUtils.join(query.getAddressCensus(), ""));
}
// 多个or
if(address.size() > 0) {
BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
address.stream().forEach(str -> {
boolQueryBuilder.should(QueryBuilders.matchPhrasePrefixQuery("address.keyword", str));
});
queryBuilder.must(boolQueryBuilder);
}
// 范围
if(query.getLoanBalMax() != null && query.getLoanBalMin() != null){
// 剩余本金
queryBuilder.must(QueryBuilders.rangeQuery("loanBal").gte(query.getLoanBalMin().doublevalue()).lt(query.getLoanBalMax().doublevalue()));
}else if(query.getLoanBalMin() != null){
queryBuilder.must(QueryBuilders.rangeQuery("loanBal").gte(query.getLoanBalMin().doublevalue()));
}else if(query.getLoanBalMax() != null){
queryBuilder.must(QueryBuilders.rangeQuery("loanBal").lt(query.getLoanBalMax().doublevalue()));
}
// 完全匹配
if(StringUtils.isNotEmpty(query.getSourceName())){
queryBuilder.must(QueryBuilders.termsQuery("sourceName", query.getSourceName()));
}
return queryBuilder;
}
private void formatQueryTime(QueryListDomain queryDomain) {
// str to date
if (queryDomain.getOverDueDaysMin() != null) {
Date endDate = DateUtils.reduceDay(new Date(), queryDomain.getOverDueDaysMin());
queryDomain.setOverDueDateEnd(DateUtils.getTheDayEnd(endDate));
}
}
es DAO
@Configuration
@Log4j2
public class ElasticSearchConfig{
@Value("${elastic.search.cluster.name:my-app}")
String clusterName;
@Value("${elastic.search.host:localhost:9200}")
String host;
@Value("${elastic.search.username:")
String userName;
@Value("${elastic.search.password:}")
String password;
@PostConstruct
void init(){
System.setProperty("es.set.netty.runtime.available.processors", "false");
}
@Bean
public RestHighLevelClient restHighLevelClient(){
String[] split = host.split(":");
final CredentialsProvider credentialProvider = new BasicCredentialsProvider();
credentialProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials(userName, password));
RestHighLevelClient restHighLevelClient = new RestHighLevelClient(RestClient.builder(new HttpHost(split[0], Integer.parseInt(split[1])))
.setHttpClientConfigCallback(new RestClientBuilder.HttpClientConfigCallback() {
@Override
public HttpAsyncClientBuilder customizeHttpClient(HttpAsyncClientBuilder httpAsyncClientBuilder) {
httpAsyncClientBuilder.disableAuthCaching();
return httpAsyncClientBuilder.setDefaultCredentialsProvider(credentialProvider);
}
}));
return restHighLevelClient;
}
}
ES搭建可视化图形查询Kibana 界面
1. 下载对应版本 Kibana
Kibana 6.4.2 | Elastic
2. 解压及访问
搭建Elasticsearch可视化界面 Kibana - 1024。 - 博客园前言 每一个版本的es都有一个对应的Kibana版本，建议和es相同版本，官网地址： 点击进入下载地址 步骤 1.解压 tar -zxvf kibana-7.2.0-linux-x86_64 2.修改https://www.cnblogs.com/xhq1024/p/12844190.html
ES 创建索引mapping
一文搞懂Elasticsearch索引的mapping与setting_way_more的博客-CSDN博客
