|
...
|
...
|
@@ -5,8 +5,6 @@ import java.util.Arrays; |
|
|
|
import java.util.List;
|
|
|
|
import java.util.Map;
|
|
|
|
|
|
|
|
import javax.annotation.PostConstruct;
|
|
|
|
|
|
|
|
import org.apache.commons.lang.StringUtils;
|
|
|
|
import org.elasticsearch.index.query.BoolQueryBuilder;
|
|
|
|
import org.elasticsearch.index.query.QueryBuilder;
|
|
...
|
...
|
@@ -14,21 +12,19 @@ import org.elasticsearch.index.query.QueryBuilders; |
|
|
|
import org.elasticsearch.search.sort.SortBuilder;
|
|
|
|
import org.elasticsearch.search.sort.SortBuilders;
|
|
|
|
import org.elasticsearch.search.sort.SortOrder;
|
|
|
|
import org.slf4j.Logger;
|
|
|
|
import org.slf4j.LoggerFactory;
|
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
|
|
|
import com.alibaba.fastjson.JSONObject;
|
|
|
|
import com.yoho.search.base.utils.ISearchConstants;
|
|
|
|
import com.yoho.search.common.cache.SearchCacheFactory;
|
|
|
|
import com.yoho.search.common.cache.model.SearchCache;
|
|
|
|
import com.yoho.search.core.es.model.SearchParam;
|
|
|
|
import com.yoho.search.models.SearchApiResult;
|
|
|
|
import com.yoho.search.service.base.SearchCacheService;
|
|
|
|
import com.yoho.search.service.base.SearchCommonService;
|
|
|
|
import com.yoho.search.service.base.SearchDynamicConfigService;
|
|
|
|
import com.yoho.search.service.base.SearchRequestParams;
|
|
|
|
import com.yoho.search.service.base.index.ProductIndexBaseService;
|
|
|
|
import com.yoho.search.service.helper.AggProductListHelper;
|
|
|
|
import com.yoho.search.service.scene.common.AbstractCacheAbleService;
|
|
|
|
|
|
|
|
/**
|
|
|
|
* 店铺外找相似
|
|
...
|
...
|
@@ -37,28 +33,20 @@ import com.yoho.search.service.helper.AggProductListHelper; |
|
|
|
*
|
|
|
|
*/
|
|
|
|
@Service
|
|
|
|
public class SearchLikeNotInShopService {
|
|
|
|
|
|
|
|
@Autowired
|
|
|
|
private SearchCommonService searchCommonService;
|
|
|
|
@Autowired
|
|
|
|
private AggProductListHelper aggProductListHelper;
|
|
|
|
public class SearchLikeNotInShopService extends AbstractCacheAbleService {
|
|
|
|
|
|
|
|
private static final Logger logger = LoggerFactory.getLogger(SearchLikeNotInShopService.class);
|
|
|
|
|
|
|
|
@Autowired
|
|
|
|
private SearchLikeHelper searchLikeHelper;
|
|
|
|
@Autowired
|
|
|
|
private ProductIndexBaseService productIndexBaseService;
|
|
|
|
@Autowired
|
|
|
|
private SearchCacheService searchCacheService;
|
|
|
|
@Autowired
|
|
|
|
private SearchCacheFactory searchCacheFactory;
|
|
|
|
@Autowired
|
|
|
|
private SearchDynamicConfigService searchDynamicConfigService;
|
|
|
|
|
|
|
|
private SearchCache searchLikeSearchCache;
|
|
|
|
|
|
|
|
@PostConstruct
|
|
|
|
void init() {
|
|
|
|
searchLikeSearchCache = searchCacheFactory.getSearchLikeSearchCache();
|
|
|
|
|
|
|
|
@Override
|
|
|
|
public SearchCache getSearchCache() {
|
|
|
|
return searchCacheFactory.getSearchLikeSearchCache();
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
...
|
...
|
@@ -68,51 +56,62 @@ public class SearchLikeNotInShopService { |
|
|
|
* @return
|
|
|
|
*/
|
|
|
|
public SearchApiResult searchLikeNotInShop(Map<String, String> paramMap) {
|
|
|
|
// 1、获取参数
|
|
|
|
String productSkn = paramMap.get(SearchRequestParams.PARAM_SEARCH_PRODUCT_SKN);
|
|
|
|
if (StringUtils.isBlank(productSkn)) {
|
|
|
|
return new SearchApiResult().setCode(400).setMessage("请输入SKN");
|
|
|
|
}
|
|
|
|
// 2、获取当前查询的SKN的基本信息
|
|
|
|
JSONObject productInfoInEs = searchLikeHelper.getProductInfoInEs(productSkn);
|
|
|
|
if (productInfoInEs == null) {
|
|
|
|
return new SearchApiResult().setCode(400).setMessage("SKN不存在");
|
|
|
|
}
|
|
|
|
// 3、检测数量参数[默认展示20条，最多展示60条]
|
|
|
|
int pageSize = StringUtils.isBlank(paramMap.get("viewNum")) ? 20 : Integer.parseInt(paramMap.get("viewNum"));
|
|
|
|
if (pageSize > 60 || pageSize <= 0) {
|
|
|
|
pageSize = 60;
|
|
|
|
}
|
|
|
|
// 4、找相似参数[按比例寻找同品类和不同品类的数量]
|
|
|
|
List<SearchParam> searchParams = new ArrayList<SearchParam>();
|
|
|
|
int sameSortCount = searchDynamicConfigService.getSearchLikeNotInShopSameSortPercent() * pageSize / 100;
|
|
|
|
searchParams.add(this.builderSearchParam(productInfoInEs, Arrays.asList(productSkn), sameSortCount, true));
|
|
|
|
searchParams.add(this.builderSearchParam(productInfoInEs, Arrays.asList(productSkn), pageSize - sameSortCount, false));
|
|
|
|
try {
|
|
|
|
// 1、获取参数
|
|
|
|
String productSkn = paramMap.get(SearchRequestParams.PARAM_SEARCH_PRODUCT_SKN);
|
|
|
|
if (StringUtils.isBlank(productSkn)) {
|
|
|
|
return new SearchApiResult().setCode(400).setMessage("请输入SKN");
|
|
|
|
}
|
|
|
|
// 2、检测分页参数【默认30条，最多60条】
|
|
|
|
int pageSize = searchLikeHelper.getPageSize(paramMap);
|
|
|
|
|
|
|
|
|
|
|
|
// 3、从缓存中获取，找到则直接返回
|
|
|
|
String redisCacheKey = searchCacheKeyHelper.getSearchLikeNotInShopKeyCache(productSkn, pageSize);
|
|
|
|
JSONObject cacheObject = searchCacheService.getJSONObjectFromCache(this.searchCache, redisCacheKey);
|
|
|
|
if (cacheObject != null) {
|
|
|
|
return new SearchApiResult().setData(cacheObject);
|
|
|
|
}
|
|
|
|
|
|
|
|
// 4、获取当前查询的SKN的基本信息
|
|
|
|
JSONObject productInfoInEs = searchLikeHelper.getProductInfoInEs(productSkn);
|
|
|
|
if (productInfoInEs == null) {
|
|
|
|
return new SearchApiResult().setCode(400).setMessage("SKN不存在");
|
|
|
|
}
|
|
|
|
|
|
|
|
// 5、设置SearchParams
|
|
|
|
List<SearchParam> searchParams = new ArrayList<SearchParam>();
|
|
|
|
int sameSortCount = searchDynamicConfigService.getSearchLikeNotInShopSameSortPercent() * pageSize / 100;
|
|
|
|
searchParams.add(this.builderSearchParam(productInfoInEs, Arrays.asList(productSkn), sameSortCount, true));
|
|
|
|
searchParams.add(this.builderSearchParam(productInfoInEs, Arrays.asList(productSkn), pageSize - sameSortCount, false));
|
|
|
|
|
|
|
|
// 5、从缓存中获取数据，有则直接返回
|
|
|
|
String productIndexName = ISearchConstants.INDEX_NAME_PRODUCT_INDEX;
|
|
|
|
JSONObject cacheObject = searchCacheService.getJSONObjectFromCache(searchLikeSearchCache, productIndexName, searchParams);
|
|
|
|
if (cacheObject != null) {
|
|
|
|
return new SearchApiResult().setData(cacheObject);
|
|
|
|
}
|
|
|
|
|
|
|
|
// 6、获取商品列表
|
|
|
|
List<Map<String, Object>> productList = searchLikeHelper.queryProductList(searchParams);
|
|
|
|
// 6、获取搜索结果[截取条数]
|
|
|
|
List<Map<String, Object>> tempProductList = searchLikeHelper.queryProductList(searchParams);
|
|
|
|
if (tempProductList.size() > pageSize) {
|
|
|
|
tempProductList = tempProductList.subList(0, pageSize);
|
|
|
|
}
|
|
|
|
|
|
|
|
// 7、构造真实返回结果
|
|
|
|
List<Map<String, Object>> productListResults = new ArrayList<Map<String, Object>>();
|
|
|
|
if (!productList.isEmpty()) {
|
|
|
|
productListResults = productIndexBaseService.getProductListWithPricePlan(productList);
|
|
|
|
// 7、构造真实返回结果
|
|
|
|
List<Map<String, Object>> productListResults = new ArrayList<Map<String, Object>>();
|
|
|
|
if (!tempProductList.isEmpty()) {
|
|
|
|
productListResults = productIndexBaseService.getProductListWithPricePlan(tempProductList);
|
|
|
|
}
|
|
|
|
JSONObject result = new JSONObject();
|
|
|
|
result.put("page", 1);
|
|
|
|
result.put("page_total", 1);
|
|
|
|
result.put("page_size", pageSize);
|
|
|
|
result.put("total", productListResults.size());
|
|
|
|
result.put("product_info", searchLikeHelper.genProductInfoResult(productInfoInEs));
|
|
|
|
result.put("product_list", productListResults);
|
|
|
|
|
|
|
|
// 8、结果加入缓存
|
|
|
|
searchCacheService.addJSONObjectToCache(this.searchCache, redisCacheKey, result);
|
|
|
|
return new SearchApiResult().setData(result);
|
|
|
|
} catch (Exception e) {
|
|
|
|
logger.error(e.getMessage(), e);
|
|
|
|
return new SearchApiResult().setData(null).setMessage("searchLikeNotInShop Exception").setCode(500);
|
|
|
|
}
|
|
|
|
JSONObject result = new JSONObject();
|
|
|
|
result.put("page", 1);
|
|
|
|
result.put("page_total", 1);
|
|
|
|
result.put("page_size", pageSize);
|
|
|
|
result.put("total", productListResults.size());
|
|
|
|
result.put("product_info", searchLikeHelper.genProductInfoResult(productInfoInEs));
|
|
|
|
result.put("product_list", productListResults);
|
|
|
|
searchCacheService.addJSONObjectToCache(searchLikeSearchCache, productIndexName, searchParams, result);
|
|
|
|
return new SearchApiResult().setData(result);
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
private SearchParam builderSearchParam(JSONObject productInfoInEs, List<String> productSkns, int pageSize, boolean inSameSort) {
|
|
...
|
...
|
@@ -162,7 +161,7 @@ public class SearchLikeNotInShopService { |
|
|
|
}
|
|
|
|
return boolFilter;
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
private QueryBuilder builderQueryBuilder(JSONObject productInfoInEs, String minimumShouldMatch) {
|
|
|
|
String queryString = searchLikeHelper.genYohoQueryStringWithOutBrandName(productInfoInEs);
|
|
|
|
String productFeatureFactor = productInfoInEs.getString("productFeatureFactor");
|
...
|
...
|
|
