召回改造

recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/service/filter/AbstractFilterService.java

@@ -1,5 +1,6 @@
 package com.tzld.piaoquan.recommend.server.service.filter;
 
+import com.alibaba.fastjson.JSONObject;
 import com.google.common.base.Stopwatch;
 import com.tzld.piaoquan.recommend.server.common.ThreadPoolFactory;
 import com.tzld.piaoquan.recommend.server.service.PreViewedService;
@@ -47,17 +48,25 @@ public abstract class AbstractFilterService {
                 param.getAppType(), param.getRegionCode(), param.getAppRegionFiltered(), param.getVideosWithRisk(),
                 param.getVideoIds(), param.getForceTruncation());
         // log.info("filterByRiskVideos videoIds={}", JSONUtils.toJson(videoIds));
+        JSONObject obj = new JSONObject();
+        obj.put("zhangbotest", "");
+        obj.put("concurrent", param.concurrent);
+        obj.put("notUsePreView", param.notUsePreView);
+        obj.put("size1", videoIds.size());
         if (param.isNotUsePreView()){
            ;
         }else {
             videoIds = filterByPreViewed(param.getAppType(), param.getMid(), videoIds);
         }
+        obj.put("size2", videoIds.size());
         // log.info("filterByPreViewed videoIds={}", JSONUtils.toJson(videoIds));
         if (param.isConcurrent()) {
             videoIds = filterByViewedConcurrent(param.getAppType(), param.getMid(), param.getUid(), videoIds);
         } else {
             videoIds = filterByViewed(param.getAppType(), param.getMid(), param.getUid(), videoIds);
         }
+        obj.put("size3", videoIds.size());
+        log.info(obj.toString());
         // log.info("filterByViewed videoIds={}", JSONUtils.toJson(videoIds));
         return videoIds;
     }

recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/service/filter/FilterParam.java

@@ -25,6 +25,6 @@ public class FilterParam {
     private int forceTruncation = 1000;
     private Set<String> abExpCodes;
 
-    private boolean concurrent=false; // hardcode 临时解决过滤慢的问题
-    private boolean notUsePreView=false;
+    public boolean concurrent=false; // hardcode 临时解决过滤慢的问题
+    public boolean notUsePreView=false;
 }