召回时不招断码的商品

@@ -120,10 +120,10 @@ public class UserRecallCacheBean extends AbstractCacheBean<UserRecallRequest, Us
                 RecallRequest recallRequest = recallRequestResponse.getRequest();
                 RecallResponse recallRespone = recallRequestResponse.getResponse();
                 StringBuilder responseValue = new StringBuilder();
-                responseValue.append( recallRespone==null?"null":JSON.toJSONString(recallRespone));
-                if(recallRespone!=null  && (recallRespone.getSkns()==null || recallRespone.getSkns().isEmpty())){
-                    responseValue.append(",dsl is [").append(SearchParamUtils.genSearchSourceBuilderFromSearchParam(recallRequest.searchParam()).toString());
-                }
+                responseValue.append(recallRespone==null?"null":JSON.toJSONString(recallRespone));
+//                if(recallRespone!=null  && (recallRespone.getSkns()==null || recallRespone.getSkns().isEmpty())){
+//                    responseValue.append(",dsl is [").append(SearchParamUtils.genSearchSourceBuilderFromSearchParam(recallRequest.searchParam()).toString());
+//                }
                 RECALL_NEW_LOGGER.info("request_type is [{}], response is [{}] ", recallRequest.requestStrategy().name(),responseValue.toString());
             }
         }

@@ -2,6 +2,8 @@ package com.yoho.search.recall.scene.beans.helper;
 
 import com.yoho.search.base.utils.DateUtil;
 import com.yoho.search.base.utils.ProductIndexEsField;
+import com.yoho.search.core.es.model.SearchParam;
+import com.yoho.search.core.es.utils.SearchParamUtils;
 import com.yoho.search.core.personalized.models.SortBrand;
 import org.apache.lucene.search.join.ScoreMode;
 import org.elasticsearch.index.query.BoolQueryBuilder;
@@ -22,6 +24,7 @@ public class ExtendFilterHelper {
         BoolQueryBuilder filter = QueryBuilders.boolQuery();
         filter.must(QueryBuilders.termQuery(ProductIndexEsField.flowType, "1"));
         filter.mustNot(QueryBuilders.rangeQuery(ProductIndexEsField.breakSizePercent).gt(50));
+        filter.mustNot(QueryBuilders.termQuery(ProductIndexEsField.isGlobal, "Y"));
         return filter;
     }
 
@@ -33,6 +36,7 @@ public class ExtendFilterHelper {
         BoolQueryBuilder filter = QueryBuilders.boolQuery();
         filter.must(QueryBuilders.termQuery(ProductIndexEsField.toAddScore, "Y"));
         filter.mustNot(QueryBuilders.rangeQuery(ProductIndexEsField.breakSizePercent).gt(50));
+        filter.mustNot(QueryBuilders.termQuery(ProductIndexEsField.isGlobal, "Y"));
         return filter;
     }
 
@@ -178,4 +182,19 @@ public class ExtendFilterHelper {
         return filter;
     }
 
+
+    public static void main(String[] args) {
+        BoolQueryBuilder filter = QueryBuilders.boolQuery();
+//        filter.mustNot(QueryBuilders.termQuery(ProductIndexEsField.flowType, "2"));
+//        filter.mustNot(QueryBuilders.termQuery(ProductIndexEsField.isGlobal, "Y"));
+//        filter.mustNot(QueryBuilders.rangeQuery(ProductIndexEsField.breakSizePercent).gt(50));
+
+        filter.mustNot(notRecallFilter());
+        SearchParam searchParam = new SearchParam();
+        searchParam.setFiter(filter);
+        System.out.println(SearchParamUtils.genSearchSourceBuilderFromSearchParam(searchParam).toString());
+
+
+    }
+
 }