fix bug

@@ -29,11 +29,11 @@ public abstract class AbstractCacheRequestResponseComponent<K extends ICacheRequ
      * @param useEhCache
      * @param useEhCache
      * @return
      * @return
      */
      */
-    public void bacthFillResponseWithCache(final List<T> requests, boolean useEhCache) {
+    public void bacthFillResponseWithCache(final List<T> requests, boolean useEhCache,int maxMissRequestCount){
         //1、批量从缓存中获取
         //1、批量从缓存中获取
         this.batchFillResponseFromCache(requests, useEhCache);
         this.batchFillResponseFromCache(requests, useEhCache);
         //2、获取未命中缓存的请求
         //2、获取未命中缓存的请求
-        List<T> missCacheRequests = this.filterMissCacheRequests(requests);
+        List<T> missCacheRequests = this.filterMissCacheRequests(requests,maxMissRequestCount);
         //3、如果remainRequests为空，则说明全部命中了缓存，直接返回即可
         //3、如果remainRequests为空，则说明全部命中了缓存，直接返回即可
         if (missCacheRequests.isEmpty()) {
         if (missCacheRequests.isEmpty()) {
             return ;
             return ;
@@ -77,12 +77,15 @@ public abstract class AbstractCacheRequestResponseComponent<K extends ICacheRequ
      * @param cacheRequestResponses
      * @param cacheRequestResponses
      * @return
      * @return
      */
      */
-    private List<T> filterMissCacheRequests(List<T> cacheRequestResponses) {
+    private List<T> filterMissCacheRequests(List<T> cacheRequestResponses,int maxMissRequestCount) {
         List<T> notCachedRequests = new ArrayList<>();
         List<T> notCachedRequests = new ArrayList<>();
         for (T requestResponse : cacheRequestResponses) {
         for (T requestResponse : cacheRequestResponses) {
             if (requestResponse != null && requestResponse.getResponse() == null) {
             if (requestResponse != null && requestResponse.getResponse() == null) {
                 notCachedRequests.add(requestResponse);
                 notCachedRequests.add(requestResponse);
             }
             }
+            if(notCachedRequests.size()>=maxMissRequestCount){
+                break;
+            }
         }
         }
         return notCachedRequests;
         return notCachedRequests;
     }
     }

@@ -55,7 +55,7 @@ public class CacheQuerySknInfoProductInfoBean extends AbstractCacheRequestRespon
             requests.add(new CacheQuerySknInfoProductInfo(new QuerySknInfo(productSkn)));
             requests.add(new CacheQuerySknInfoProductInfo(new QuerySknInfo(productSkn)));
         }
         }
         //2、调父类方法
         //2、调父类方法
-        this.bacthFillResponseWithCache(requests,true);
+        this.bacthFillResponseWithCache(requests,true,productSkns.size());
 
 
         //3、返回结果
         //3、返回结果
         return requests;
         return requests;

@@ -37,7 +37,7 @@ public class CacheRecallRequestRecallResponseBean extends AbstractCacheRequestRe
             results.add(new CacheRecallRequestRecallResponse(request));
             results.add(new CacheRecallRequestRecallResponse(request));
         }
         }
         //2、执行查询
         //2、执行查询
-        this.bacthFillResponseWithCache(results,false);
+        this.bacthFillResponseWithCache(results,false,10);
 
 
         //3、返回结果
         //3、返回结果
         return results;
         return results;
@@ -49,10 +49,6 @@ public class CacheRecallRequestRecallResponseBean extends AbstractCacheRequestRe
         List<SearchParam> searchParams = new ArrayList<>();
         List<SearchParam> searchParams = new ArrayList<>();
         for (CacheRecallRequestRecallResponse requestResponse : missCacheRequests) {
         for (CacheRecallRequestRecallResponse requestResponse : missCacheRequests) {
             searchParams.add(requestResponse.getRequest().searchParam());
             searchParams.add(requestResponse.getRequest().searchParam());
-            //控制每次请求es的数量
-            if(searchParams.size()>=maxEsRequestCountPerTime){
-                break;
-            }
         }
         }
         //2、执行搜索
         //2、执行搜索
         List<SearchResult> searchResults = searchCommonService.doMutiSearch(ISearchConstants.INDEX_NAME_PRODUCT_INDEX, searchParams);
         List<SearchResult> searchResults = searchCommonService.doMutiSearch(ISearchConstants.INDEX_NAME_PRODUCT_INDEX, searchParams);

@@ -48,7 +48,7 @@ public class CacheRecallSknParamsRecallSknListBean extends AbstractCacheRequestR
         requests.add(new CacheRecallSknParamsRecallSknList(recallSknParams));
         requests.add(new CacheRecallSknParamsRecallSknList(recallSknParams));
 
 
         //2、执行父类方法
         //2、执行父类方法
-        this.bacthFillResponseWithCache(requests,false);
+        this.bacthFillResponseWithCache(requests,false,1);
 
 
         //3、判断
         //3、判断
         if(requests.size()==1 && requests.get(0).getResponse()!=null){
         if(requests.size()==1 && requests.get(0).getResponse()!=null){

 package com.yoho.search.recall.scene.constants;
 package com.yoho.search.recall.scene.constants;
 
 
+
+/**
+ * 缓存时间定义-单位秒
+ */
 public class CacheTimeConstants {
 public class CacheTimeConstants {
 
 
+
     public static final int COMMON = 10 * 60;//通用缓存
     public static final int COMMON = 10 * 60;//通用缓存
 
 
     public static final int BRAND_HEATVALUE = 1 * 60 * 60;//人气缓存
     public static final int BRAND_HEATVALUE = 1 * 60 * 60;//人气缓存