搜索建议时上报产生建议的途径信息 用于统计分析

@@ -176,8 +176,8 @@ public class SearchKeyWordService {
         }
         }
     }
     }
 
 
-    public void recordSuggestRecom(String queryWord) {
-        recordKeyWord(RedisKeys.YOHO_SEARCH_KEYWORDS_TIPS, queryWord);
+    public void recordSearchRecommendCase(String caseType) {
+        recordKeyWord(RedisKeys.YOHO_SEARCH_KEYWORDS_TIPS, caseType);
     }
     }
 
 
     public Double getKeywordCount(String redisKeyTemplate, String queryWord) {
     public Double getKeywordCount(String redisKeyTemplate, String queryWord) {

 package com.yoho.search.service.servicenew.impl;
 package com.yoho.search.service.servicenew.impl;
 
 
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.Set;
-import java.util.stream.Collectors;
-
-import org.apache.commons.collections.CollectionUtils;
-import org.apache.commons.lang.StringUtils;
-import org.elasticsearch.common.lucene.search.function.CombineFunction;
-import org.elasticsearch.index.query.BoolQueryBuilder;
-import org.elasticsearch.index.query.MatchQueryBuilder;
-import org.elasticsearch.index.query.MultiMatchQueryBuilder;
-import org.elasticsearch.index.query.QueryBuilder;
-import org.elasticsearch.index.query.QueryBuilders;
-import org.elasticsearch.index.query.functionscore.FunctionScoreQueryBuilder;
-import org.elasticsearch.index.query.functionscore.ScoreFunctionBuilders;
-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.Component;
-import org.springframework.util.Assert;
-
 import com.alibaba.fastjson.JSONObject;
 import com.alibaba.fastjson.JSONObject;
 import com.yoho.search.base.utils.CharUtils;
 import com.yoho.search.base.utils.CharUtils;
 import com.yoho.search.base.utils.ISearchConstants;
 import com.yoho.search.base.utils.ISearchConstants;
@@ -43,6 +16,23 @@ import com.yoho.search.service.servicenew.ISearchRecommendService;
 import com.yoho.search.service.servicenew.ISuggestService;
 import com.yoho.search.service.servicenew.ISuggestService;
 import com.yoho.search.service.utils.SearchRequestParams;
 import com.yoho.search.service.utils.SearchRequestParams;
 import com.yoho.search.service.vo.SearchApiResult;
 import com.yoho.search.service.vo.SearchApiResult;
+import org.apache.commons.collections.CollectionUtils;
+import org.apache.commons.lang.StringUtils;
+import org.elasticsearch.common.lucene.search.function.CombineFunction;
+import org.elasticsearch.index.query.*;
+import org.elasticsearch.index.query.functionscore.FunctionScoreQueryBuilder;
+import org.elasticsearch.index.query.functionscore.ScoreFunctionBuilders;
+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.Component;
+import org.springframework.util.Assert;
+
+import java.util.*;
+import java.util.stream.Collectors;
 
 
 /**
 /**
  * Created by ginozhang on 2017/3/22.
  * Created by ginozhang on 2017/3/22.
@@ -101,6 +91,7 @@ public class SearchRecommendServiceImpl implements ISearchRecommendService {
 		String queryWord = paramMap.get(SearchRequestParams.PARAM_SEARCH_QUERY);
 		String queryWord = paramMap.get(SearchRequestParams.PARAM_SEARCH_QUERY);
 		long begin = System.currentTimeMillis();
 		long begin = System.currentTimeMillis();
 		logger.info("[func=recommend][queryWord={}][begin={}]", queryWord, begin);
 		logger.info("[func=recommend][queryWord={}][begin={}]", queryWord, begin);
+		String caseType = "DEFAULT_CASE";
 
 
 		try {
 		try {
 			Assert.isTrue(StringUtils.isNotEmpty(queryWord), "query keyword cannot be empty.");
 			Assert.isTrue(StringUtils.isNotEmpty(queryWord), "query keyword cannot be empty.");
@@ -111,12 +102,14 @@ public class SearchRecommendServiceImpl implements ISearchRecommendService {
 			// 1) 第一部分是最常见的情况，包括有结果、根据SKN搜索、关键词未出现在空结果Redis ZSet里
 			// 1) 第一部分是最常见的情况，包括有结果、根据SKN搜索、关键词未出现在空结果Redis ZSet里
 			if (containsProductInSearchResult(searchResult)) {
 			if (containsProductInSearchResult(searchResult)) {
 				// 1.1） 搜索有结果的 优先从搜索结果聚合出品牌等关键词进行查询
 				// 1.1） 搜索有结果的 优先从搜索结果聚合出品牌等关键词进行查询
+				caseType = "BY_PRODUCT_LIST_CASE";
 				JSONObject dataMap = ((JSONObject) searchResult.getData());
 				JSONObject dataMap = ((JSONObject) searchResult.getData());
 				List<Map<String, Object>> productList = (List<Map<String, Object>>) dataMap.get("product_list");
 				List<Map<String, Object>> productList = (List<Map<String, Object>>) dataMap.get("product_list");
 				String aggKeywords = aggKeywordsByProductList(productList);
 				String aggKeywords = aggKeywordsByProductList(productList);
 				keywordsToSearch = keywordsToSearch + " " + aggKeywords;
 				keywordsToSearch = keywordsToSearch + " " + aggKeywords;
 			} else if (isQuerySkn(queryWord)) {
 			} else if (isQuerySkn(queryWord)) {
 				// 1.2） 如果是查询SKN 没有查询到的 后续的逻辑也无法推荐 所以直接到ES里去获取关键词
 				// 1.2） 如果是查询SKN 没有查询到的 后续的逻辑也无法推荐 所以直接到ES里去获取关键词
+				caseType = "BY_SKN_PARAMS_CASE";
 				keywordsToSearch = aggKeywordsBySkns(queryWord);
 				keywordsToSearch = aggKeywordsBySkns(queryWord);
 				if (StringUtils.isEmpty(keywordsToSearch)) {
 				if (StringUtils.isEmpty(keywordsToSearch)) {
 					return defaultSuggestRecommendation();
 					return defaultSuggestRecommendation();
@@ -141,12 +134,15 @@ public class SearchRecommendServiceImpl implements ISearchRecommendService {
 			String spellingCorrentWord = null, dest = null;
 			String spellingCorrentWord = null, dest = null;
 			if (allowGetingDest(queryWord) && StringUtils.isNotEmpty((dest = getSuggestConversionDestBySource(queryWord)))) {
 			if (allowGetingDest(queryWord) && StringUtils.isNotEmpty((dest = getSuggestConversionDestBySource(queryWord)))) {
 				// 2.1) 爬虫和自定义的Conversion处理
 				// 2.1) 爬虫和自定义的Conversion处理
+				caseType = "BY_CONVERSION_CASE";
 				keywordsToSearch = dest;
 				keywordsToSearch = dest;
 			} else if (allowSpellingCorrent(queryWord) && StringUtils.isNotEmpty((spellingCorrentWord = suggestService.getSpellingCorrectKeyword(queryWord)))) {
 			} else if (allowSpellingCorrent(queryWord) && StringUtils.isNotEmpty((spellingCorrentWord = suggestService.getSpellingCorrectKeyword(queryWord)))) {
 				// 2.2) 执行拼写检查 由于在搜索建议的时候会进行拼写检查 所以缓存命中率高
 				// 2.2) 执行拼写检查 由于在搜索建议的时候会进行拼写检查 所以缓存命中率高
+				caseType = "BY_SPELLING_CORRECT_CASE";
 				keywordsToSearch = spellingCorrentWord;
 				keywordsToSearch = spellingCorrentWord;
 			} else {
 			} else {
 				// 2.3) 如果两者都没有 则直接返回
 				// 2.3) 如果两者都没有 则直接返回
+				caseType = "WORST_CASE";
 				return defaultSuggestRecommendation();
 				return defaultSuggestRecommendation();
 			}
 			}
 
 
@@ -158,10 +154,11 @@ public class SearchRecommendServiceImpl implements ISearchRecommendService {
 			logger.info("[func=recommend][queryWord={}][cost={}]", queryWord, System.currentTimeMillis() - begin);
 			logger.info("[func=recommend][queryWord={}][cost={}]", queryWord, System.currentTimeMillis() - begin);
 			return recommendResult;
 			return recommendResult;
 		} catch (Exception e) {
 		} catch (Exception e) {
+			caseType = "EXCEPTION_CASE";
 			logger.error("[func=recommend][queryWord=" + queryWord + "]", e);
 			logger.error("[func=recommend][queryWord=" + queryWord + "]", e);
 			return defaultSuggestRecommendation();
 			return defaultSuggestRecommendation();
 		} finally {
 		} finally {
-			searchKeyWordService.recordSuggestRecom(queryWord);
+			searchKeyWordService.recordSearchRecommendCase(caseType);
 		}
 		}
 	}
 	}