召回改造

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

@@ -48,25 +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());
+//        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());
+//        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());
+//        obj.put("size3", videoIds.size());
+//        log.info(obj.toString());
         // log.info("filterByViewed videoIds={}", JSONUtils.toJson(videoIds));
         return videoIds;
     }
@@ -83,7 +83,7 @@ public abstract class AbstractFilterService {
 //                .collect(Collectors.groupingBy(it -> it / chunkSize))
 //                .values();
 
-        int chunkSize = 100;
+        int chunkSize = 20;
         List<List<Long>> chunks = new ArrayList<>();
         int size = videoIds.size();
 
@@ -102,7 +102,7 @@ public abstract class AbstractFilterService {
             futures.add(future);
         }
         try {
-            cdl.await(800, TimeUnit.MILLISECONDS);
+            cdl.await(300, TimeUnit.MILLISECONDS);
         } catch (InterruptedException e) {
             log.error("filter error", e);
             return null;

recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/service/score4recall/strategy/RegionRecallScorerV1.java

@@ -30,7 +30,7 @@ public class RegionRecallScorerV1 extends AbstractScorer4Recall {
             lists = model.kv.getOrDefault("中国", new ArrayList<>());
         }
 
-        return lists.subList(0, Math.min(50, lists.size()));
+        return lists.subList(0, Math.min(80, lists.size()));
     }
 
 

recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/service/score4recall/strategy/RegionRecallScorerV2.java

@@ -24,7 +24,7 @@ public class RegionRecallScorerV2 extends AbstractScorer4Recall {
         // todo zhangbo 这里要写实现功能
         Model4RecallList model = (Model4RecallList) this.getModel();
         List<Pair<Long, Double>> lists = model.recallList;
-        return lists.subList(0, Math.min(20, lists.size()));
+        return lists.subList(0, Math.min(40, lists.size()));
     }
 
 

recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/service/score4recall/strategy/RegionRecallScorerV3.java

@@ -30,7 +30,7 @@ public class RegionRecallScorerV3 extends AbstractScorer4Recall {
             lists = model.kv.getOrDefault("中国", new ArrayList<>());
         }
 
-        return lists.subList(0, Math.min(20, lists.size()));
+        return lists.subList(0, Math.min(60, lists.size()));
     }
 
 

recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/service/score4recall/strategy/RegionRecallScorerV4.java

@@ -24,7 +24,7 @@ public class RegionRecallScorerV4 extends AbstractScorer4Recall {
         // todo zhangbo 这里要写实现功能
         Model4RecallList model = (Model4RecallList) this.getModel();
         List<Pair<Long, Double>> lists = model.recallList;
-        return lists.subList(0, Math.min(20, lists.size()));
+        return lists.subList(0, Math.min(40, lists.size()));
     }