使用AbstractCacheComponent重构RecommendShopService的缓存

 package com.yoho.search.service.scene.shopbrand;
 
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.List;
-import java.util.Map;
-
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.yoho.search.base.utils.CollectionUtils;
-import com.yoho.search.base.utils.ISearchConstants;
-import com.yoho.search.cache.beans.AbstractCacheAbleService;
-import com.yoho.search.cache.log.SearchCacheMatchLogger;
-import com.yoho.search.cache.model.SearchCache;
+import com.yoho.search.cache.CacheTimeConstants;
+import com.yoho.search.cache.beans.AbstractCacheComponent;
+import com.yoho.search.common.SearchDynamicConfigService;
+import com.yoho.search.common.SearchRequestParams;
 import com.yoho.search.common.utils.SearchApiResultUtils;
 import com.yoho.search.core.es.agg.IAggregation;
 import com.yoho.search.core.es.model.SearchParam;
+import com.yoho.search.models.SearchApiResult;
 import com.yoho.search.service.aggregations.AggregationsService;
 import com.yoho.search.service.aggregations.impls.AggregationFactory;
-import com.yoho.search.common.SearchDynamicConfigService;
-import com.yoho.search.common.SearchRequestParams;
 import com.yoho.search.service.helper.SearchParamHelper;
-import org.apache.commons.lang.StringUtils;
-
-import com.yoho.search.models.SearchApiResult;
+import org.apache.commons.collections.MapUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.List;
+import java.util.Map;
+
 @Service
-public class RecommendShopService extends AbstractCacheAbleService {
+public class RecommendShopService extends AbstractCacheComponent<JSONArray> {
 
     private static final Logger logger = LoggerFactory.getLogger(RecommendShopService.class);
-    private static final int DEFAULT_AGGREGATION_COUNT = 100;
 
     @Autowired
     private AggregationsService aggregationsService;
@@ -43,22 +39,18 @@ public class RecommendShopService extends AbstractCacheAbleService {
     @Autowired
     private SearchDynamicConfigService searchDynamicConfigService;
 
-    public SearchCache getSearchCache() {
-        return searchCacheFactory.getRecommendCache();
-    }
-
     public SearchApiResult recommendShop(Map<String, String> paramMap) {
         try {
-            // 0、开关支持是否关闭个性化
+            // 1、开关支持是否关闭个性化
             if (!searchDynamicConfigService.isRecommendPersionalOpen()) {
                 paramMap.remove("uid");
             }
 
-            // 1、获取核心参数
-            final int page = StringUtils.isBlank(paramMap.get("page")) ? 1 : Integer.parseInt(paramMap.get("page"));
-            final int count = StringUtils.isBlank(paramMap.get("viewNum")) ? 1 : Integer.parseInt(paramMap.get("viewNum"));
+            // 2、获取核心参数
+            int page = MapUtils.getIntValue(paramMap,"page",1);
+            int pageSize = MapUtils.getIntValue(paramMap,"viewNum",1);
 
-            // 1.1添加默认参数
+            // 3、添加默认参数
             paramMap.remove(SearchRequestParams.PARAM_SEARCH_ORDER);// 此接口不支持order
             paramMap.put(SearchRequestParams.PARAM_SEARCH_GLOBAL_FILTER_BRAND, "Y");// 页面屏蔽
             paramMap.put(SearchRequestParams.PARAM_SEARCH_STATUS, "1");// 上架
@@ -66,42 +58,20 @@ public class RecommendShopService extends AbstractCacheAbleService {
             paramMap.put(SearchRequestParams.PARAM_SEARCH_ISOUTLETS, "2");// 非奥莱
             paramMap.put(SearchRequestParams.PARAM_SEARCH_ATTRIBUTE_NOT, "2");// 非赠品
 
-            // 2、构建带queryBuilder和filter的SearchParam
+            // 4、构建SearchParam
             SearchParam searchParam = searchParamHelper.buildWithPersional(paramMap, true);
 
-            // 3、构造聚合操作
-            IAggregation recommendShopAgg = aggregationFactory.getRecommendShopAggregation(paramMap, 100, 2);
-            searchParam.setAggregationBuilders(Arrays.asList(recommendShopAgg.getBuilder()));
-
-            // 4、构建offset
-            searchParam.setOffset(DEFAULT_AGGREGATION_COUNT);// justForCache
+            // 5、执行查询
+            JSONArray recommendShops = super.queryWithCache(searchParam, paramMap);
+            return this.getRecommendShopSearchApiResult(recommendShops, page, pageSize);
 
-            // 5、从缓存中获取
-            final String productIndexName = ISearchConstants.INDEX_NAME_PRODUCT_INDEX;
-            JSONArray cacheJSONArray = searchCacheService.getJSONArrayFromCache(searchCache, productIndexName, searchParam);
-            if (cacheJSONArray != null) {
-                SearchCacheMatchLogger.doSearchCacheMatchLog("/productindex/aggRecommendShop.json", paramMap);
-                return this.getRecommendShopSearchApiResult(cacheJSONArray, page, count);
-            }
-            // 6、从ES中获取
-            JSONObject recommendShopResult = aggregationsService.getAggNameAndResponse(recommendShopAgg, searchParam);
-            if (recommendShopResult == null) {
-                return new SearchApiResult().setData(500).setMessage("exception");
-            }
-            // 7、生成结果并且加入缓存
-            JSONArray recommendShops = recommendShopResult.getJSONArray(recommendShopAgg.aggName());
-            if (recommendShops != null) {
-                searchCacheService.addJSONArrayToCache(searchCache, productIndexName, searchParam, recommendShops);
-                return this.getRecommendShopSearchApiResult(recommendShops, page, count);
-            }
-            return new SearchApiResult().setData(new ArrayList<Map<String, Object>>());
         } catch (Exception e) {
             return SearchApiResultUtils.errorSearchApiResult(logger, paramMap, e);
         }
     }
 
     private SearchApiResult getRecommendShopSearchApiResult(JSONArray cacheJSONArray, int page, int count) {
-        List<Map<String, Object>> cacheList = new ArrayList<Map<String, Object>>();
+        List<Map<String, Object>> cacheList = new ArrayList<>();
         for (int i = 0; i < cacheJSONArray.size(); i++) {
             cacheList.add(cacheJSONArray.getJSONObject(i));
         }
@@ -109,4 +79,32 @@ public class RecommendShopService extends AbstractCacheAbleService {
         return new SearchApiResult().setData(results);
     }
 
+    @Override
+    protected JSONArray doRealQuery(SearchParam searchParam, Map<String, String> paramMap) throws Exception {
+        // 1、构造聚合操作
+        IAggregation recommendShopAgg = aggregationFactory.getRecommendShopAggregation(paramMap, 100, 2);
+        searchParam.setAggregationBuilders(Arrays.asList(recommendShopAgg.getBuilder()));
+
+        // 2、构建offset
+        searchParam.setOffset(0);
+
+        // 3、执行查询
+        JSONObject recommendShopResult = aggregationsService.getAggNameAndResponse(recommendShopAgg, searchParam);
+        if (recommendShopResult == null) {
+            return new JSONArray();
+        }
+        // 4、生成结果
+        JSONArray recommendShops = recommendShopResult.getJSONArray(recommendShopAgg.aggName());
+        return recommendShops;
+    }
+
+    @Override
+    protected int cacheTimeInMinute() {
+        return CacheTimeConstants.CACHE_30_MINUTE;
+    }
+
+    @Override
+    protected String cacheSceneKey() {
+        return "RECOMMEND_SHOPS";
+    }
 }