private BoolQueryBuilder getQueryBuilder(QueryCollectWaterDataPageRequestVO requestVO) {BoolQueryBuilder queryBuilder = QueryBuilders.boolQuery();if (!CollectionUtils.isEmpty(requestVO.getCompanyIds())) {//termsQuery 精確查找corpId字段為精確的多個值，和mysql的in類似queryBuilder.must(QueryBuilders.termsQuery("corpId", requestVO.getCompanyIds()));}if (requestVO.getWaterMeterNumber() != null) {//matchPhraseQuery 模糊查詢waterMeterNumber中包含某一個值，如果值為字符串最好用這個queryBuilder.must(QueryBuilders.matchPhraseQuery("waterMeterNumber", "*" + requestVO.getWaterMeterNumber() + "*"));}//rangeQuery 范圍查詢collectTime 大于等于和小于等于某個值if (requestVO.getStartCollectTime() != null) {queryBuilder.must(QueryBuilders.rangeQuery("collectTime").gte(requestVO.getStartCollectTime().getTime()).lte(requestVO.getEndCollectTime().getTime()));}return queryBuilder;}

 BoolQueryBuilder queryBuilder = getQueryBuilder(requestVO);NativeSearchQuery searchQuery = new NativeSearchQueryBuilder()//條件過濾.withQuery(queryBuilder)//分頁.withPageable(PageRequest.of(requestVO.getPageNum(), requestVO.getPageSize())).withSort(SortBuilders.fieldSort("collectTime").order(SortOrder.DESC))//設置查詢時返回的總數是否超過es設置的限制，true是解除限制默認為false.withTrackTotalHits(true).build();SearchHits<ESCollectWaterDataPageResultVO> searchHit = elasticsearchRestTemplate.search(searchQuery, ESCollectWaterDataPageResultVO.class);List<QueryCollectWaterDataPageResultVO> resultList = new ArrayList<>();if (searchHit.getTotalHits() > 0) {searchHit.forEach(content -> {QueryCollectWaterDataPageResultVO resultVO = new QueryCollectWaterDataPageResultVO();BeanUtils.copyProperties(content.getContent(), resultVO);resultVO.setCuWaterData(content.getContent().getData());resultVO.setOneWaterData(content.getContent().getOneData());resultVO.setTwoWaterData(content.getContent().getTwoData());resultVO.setThreeWaterData(content.getContent().getThreeData());resultVO.setCurrentCollectTime(content.getContent().getCollectTime());resultList.add(resultVO);});}BasePageResultDto<QueryCollectWaterDataPageResultVO> pageResultVOBasePageResultDto = new BasePageResultDto((int)searchHit.getTotalHits(), resultList);