lostecho/mall
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

搜索功能查询结果为空问题修复

Browse Source
This commit is contained in:
macro
2022-10-14 19:01:12 +08:00
parent fe2f43f3f1
commit 485aec3f31
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
mall-search/src/main/java/com/macro/mall/search/service/impl/EsProductServiceImpl.java
View File

@@ -1,5 +1,6 @@
package com.macro.mall.search.service.impl; package com.macro.mall.search.service.impl;
import cn.hutool.core.collection.ListUtil;
import cn.hutool.core.util.StrUtil; import cn.hutool.core.util.StrUtil;
import com.macro.mall.search.dao.EsProductDao; import com.macro.mall.search.dao.EsProductDao;
import com.macro.mall.search.domain.EsProduct; import com.macro.mall.search.domain.EsProduct;
@@ -162,7 +163,7 @@ public class EsProductServiceImpl implements EsProductService {
LOGGER.info("DSL:{}", searchQuery.getQuery().toString()); LOGGER.info("DSL:{}", searchQuery.getQuery().toString());
SearchHits<EsProduct> searchHits = elasticsearchRestTemplate.search(searchQuery, EsProduct.class); SearchHits<EsProduct> searchHits = elasticsearchRestTemplate.search(searchQuery, EsProduct.class);
if(searchHits.getTotalHits()<=0){ if(searchHits.getTotalHits()<=0){
return new PageImpl<>(null,pageable,0); return new PageImpl<>(ListUtil.empty(),pageable,0);
} }
List<EsProduct> searchProductList = searchHits.stream().map(SearchHit::getContent).collect(Collectors.toList()); List<EsProduct> searchProductList = searchHits.stream().map(SearchHit::getContent).collect(Collectors.toList());
return new PageImpl<>(searchProductList,pageable,searchHits.getTotalHits()); return new PageImpl<>(searchProductList,pageable,searchHits.getTotalHits());
@@ -206,12 +207,12 @@ public class EsProductServiceImpl implements EsProductService {
LOGGER.info("DSL:{}", searchQuery.getQuery().toString()); LOGGER.info("DSL:{}", searchQuery.getQuery().toString());
SearchHits<EsProduct> searchHits = elasticsearchRestTemplate.search(searchQuery, EsProduct.class); SearchHits<EsProduct> searchHits = elasticsearchRestTemplate.search(searchQuery, EsProduct.class);
if(searchHits.getTotalHits()<=0){ if(searchHits.getTotalHits()<=0){
return new PageImpl<>(null,pageable,0); return new PageImpl<>(ListUtil.empty(),pageable,0);
} }
List<EsProduct> searchProductList = searchHits.stream().map(SearchHit::getContent).collect(Collectors.toList()); List<EsProduct> searchProductList = searchHits.stream().map(SearchHit::getContent).collect(Collectors.toList());
return new PageImpl<>(searchProductList,pageable,searchHits.getTotalHits()); return new PageImpl<>(searchProductList,pageable,searchHits.getTotalHits());
} }
return new PageImpl<>(null); return new PageImpl<>(ListUtil.empty());
} }
@Override @Override