message_bus / message_bus_service · 提交

转到一个项目

作者 朱兆平
提交 87dd2a04d5c8dc4480805d3d0c9e15800307a84c 1 个父辈 5142a54b

Revert "时间段查询采用MUST" 

This reverts commit 5142a54b
内嵌 并排对比
正在显示 1 个修改的文件 包含 3 行增加 和 4 行删除
... ... @@ -173,20 +173,19 @@ public class ElasticSearchInfoController {
queryBuilder = queryBuilder.must(QueryBuilders.termQuery("ADMIN.RCVLOG.USER",messageBusMsg.getRcvlogUsername()));
}
if (messageBusMsg.getCreatimeSearch() !=null && !messageBusMsg.getCreatimeSearch().isEmpty() && StringUtils.isNotBlank(messageBusMsg.getCreatimeSearch().get(0)) && StringUtils.isNotBlank(messageBusMsg.getCreatimeSearch().get(1))){
queryBuilder = queryBuilder.must(QueryBuilders.rangeQuery("MSG.HEADER.DDTM").from(messageBusMsg.getCreatimeSearch().get(0)).to(messageBusMsg.getCreatimeSearch().get(1)));
// queryBuilder = queryBuilder.must(QueryBuilders.rangeQuery("MSG.HEADER.DDTM").from(messageBusMsg.getCreatimeSearch().get(0)).to(messageBusMsg.getCreatimeSearch().get(1)));
//or条件
//queryBuilder = queryBuilder.should(QueryBuilders.rangeQuery("ADMIN.CREATTIME").from(messageBusMsg.getCreatimeSearch().get(0)).to(messageBusMsg.getCreatimeSearch().get(1)));
queryBuilder = queryBuilder.should(QueryBuilders.rangeQuery("ADMIN.CREATTIME").from(messageBusMsg.getCreatimeSearch().get(0)).to(messageBusMsg.getCreatimeSearch().get(1)));
}
if (StringUtils.isNotBlank(messageBusMsg.getMsgid())){
queryBuilder = queryBuilder.must(QueryBuilders.termQuery("_id",messageBusMsg.getMsgid()));
queryBuilder = queryBuilder.should(QueryBuilders.termQuery("_id",messageBusMsg.getMsgid()));
}
//wild搜索大写搜不到小写也搜不到大写的包含，要转成小写
if (StringUtils.isNotBlank(messageBusMsg.getAlias_sendContent())){
queryBuilder = queryBuilder.must(QueryBuilders.wildcardQuery("MSG.BODY", "*"+messageBusMsg.getAlias_sendContent().toLowerCase()+"*"));
}
log.info("bool查询语句为:{}",queryBuilder);
queryBuilder.minimumShouldMatch(1);
return queryBuilder;
}
... ...