message_bus / message_bus_service · 提交

转到一个项目

作者 朱兆平
提交 5142a54b02463887ce633648aedc5ab926f10251 1 个父辈 6f1d0a2c

时间段查询采用MUST

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