| 
														
															@@ -17,6 +17,7 @@ import com.tzld.piaoquan.recommend.server.service.score.ScorerUtils; 
														 | 
													
												
											
												
													
														| 
														 | 
														
															 import com.tzld.piaoquan.recommend.server.util.CommonCollectionUtils; 
														 | 
														
														 | 
														
															 import com.tzld.piaoquan.recommend.server.util.CommonCollectionUtils; 
														 | 
													
												
											
												
													
														| 
														 | 
														
															 import com.tzld.piaoquan.recommend.server.util.FeatureBucketUtils; 
														 | 
														
														 | 
														
															 import com.tzld.piaoquan.recommend.server.util.FeatureBucketUtils; 
														 | 
													
												
											
												
													
														| 
														 | 
														
															 import com.tzld.piaoquan.recommend.server.util.JSONUtils; 
														 | 
														
														 | 
														
															 import com.tzld.piaoquan.recommend.server.util.JSONUtils; 
														 | 
													
												
											
												
													
														| 
														 | 
														
															 
														 | 
														
														 | 
														
															+import com.tzld.piaoquan.recommend.server.util.RecallUtils; 
														 | 
													
												
											
												
													
														| 
														 | 
														
															 import lombok.extern.slf4j.Slf4j; 
														 | 
														
														 | 
														
															 import lombok.extern.slf4j.Slf4j; 
														 | 
													
												
											
												
													
														| 
														 | 
														
															 import org.apache.commons.collections4.MapUtils; 
														 | 
														
														 | 
														
															 import org.apache.commons.collections4.MapUtils; 
														 | 
													
												
											
												
													
														| 
														 | 
														
															 import org.apache.commons.lang3.StringUtils; 
														 | 
														
														 | 
														
															 import org.apache.commons.lang3.StringUtils; 
														 | 
													
												
											
										
											
												
													
														 | 
														
															@@ -26,7 +27,6 @@ import org.springframework.stereotype.Service; 
														 | 
													
												
											
												
													
														| 
														 | 
														
															 import java.util.*; 
														 | 
														
														 | 
														
															 import java.util.*; 
														 | 
													
												
											
												
													
														| 
														 | 
														
															 import java.util.concurrent.Future; 
														 | 
														
														 | 
														
															 import java.util.concurrent.Future; 
														 | 
													
												
											
												
													
														| 
														 | 
														
															 import java.util.concurrent.TimeUnit; 
														 | 
														
														 | 
														
															 import java.util.concurrent.TimeUnit; 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-import java.util.stream.Collectors; 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															  
														 | 
														
														 | 
														
															  
														 | 
													
												
											
												
													
														| 
														 | 
														
															 @Service 
														 | 
														
														 | 
														
															 @Service 
														 | 
													
												
											
												
													
														| 
														 | 
														
															 @Slf4j 
														 | 
														
														 | 
														
															 @Slf4j 
														 | 
													
												
											
										
											
												
													
														 | 
														
															@@ -47,65 +47,28 @@ public class RankStrategy4RegionMergeModelV536 extends RankStrategy4RegionMergeM 
														 | 
													
												
											
												
													
														| 
														 | 
														
															         //-------------------辑------------------- 
														 | 
														
														 | 
														
															         //-------------------辑------------------- 
														 | 
													
												
											
												
													
														| 
														 | 
														
															  
														 | 
														
														 | 
														
															  
														 | 
													
												
											
												
													
														| 
														 | 
														
															         long currentMs = System.currentTimeMillis(); 
														 | 
														
														 | 
														
															         long currentMs = System.currentTimeMillis(); 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        List<Video> oldRovs = new ArrayList<>(); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        oldRovs.addAll(extractAndSort(param, RegionHRecallStrategy.PUSH_FORM)); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        oldRovs.addAll(extractAndSort(param, RegionHDupRecallStrategy.PUSH_FORM)); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        oldRovs.addAll(extractAndSort(param, Region24HRecallStrategy.PUSH_FORM)); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        oldRovs.addAll(extractAndSort(param, RegionRelative24HRecallStrategy.PUSH_FORM)); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        oldRovs.addAll(extractAndSort(param, RegionRelative24HDupRecallStrategy.PUSH_FORM)); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        removeDuplicate(oldRovs); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        int sizeReturn = param.getSize(); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        List<Video> v0 = oldRovs.size() <= sizeReturn 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-                ? oldRovs 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-                : oldRovs.subList(0, sizeReturn); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															         Set<Long> setVideo = new HashSet<>(); 
														 | 
														
														 | 
														
															         Set<Long> setVideo = new HashSet<>(); 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        this.duplicate(setVideo, v0); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        setVideo.addAll(v0.stream().map(Video::getVideoId).collect(Collectors.toSet())); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        List<Video> rovRecallRank = new ArrayList<>(v0); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															 
														 | 
														
														 | 
														
															+        List<Video> rovRecallRank = new ArrayList<>(); 
														 | 
													
												
											
												
													
														| 
														 | 
														
															 
														 | 
														
														 | 
														
															+        // -------------------5路特殊旧召回------------------ 
														 | 
													
												
											
												
													
														| 
														 | 
														
															 
														 | 
														
														 | 
														
															+        RecallUtils.extractOldSpecialRecall(param, setVideo, rovRecallRank); 
														 | 
													
												
											
												
													
														| 
														 | 
														
															         //-------------------return相似召回------------------ 
														 | 
														
														 | 
														
															         //-------------------return相似召回------------------ 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        List<Video> v6 = extractAndSort(param, ReturnVideoRecallStrategy.PUSH_FORM); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        v6 = v6.stream().filter(r -> !setVideo.contains(r.getVideoId())).collect(Collectors.toList()); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        v6 = v6.subList(0, Math.min(mergeWeight.getOrDefault("v6", 5.0).intValue(), v6.size())); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        rovRecallRank.addAll(v6); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        setVideo.addAll(v6.stream().map(Video::getVideoId).collect(Collectors.toSet())); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															 
														 | 
														
														 | 
														
															+        RecallUtils.extractRecall(mergeWeight.getOrDefault("v6", 5.0).intValue(), param, ReturnVideoRecallStrategy.PUSH_FORM, setVideo, rovRecallRank); 
														 | 
													
												
											
												
													
														| 
														 | 
														
															         //-------------------新地域召回------------------ 
														 | 
														
														 | 
														
															         //-------------------新地域召回------------------ 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        List<Video> v1 = extractAndSort(param, RegionRealtimeRecallStrategyV1.PUSH_FORM); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        v1 = v1.stream().filter(r -> !setVideo.contains(r.getVideoId())).collect(Collectors.toList()); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        v1 = v1.subList(0, Math.min(mergeWeight.getOrDefault("v1", 5.0).intValue(), v1.size())); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        rovRecallRank.addAll(v1); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        setVideo.addAll(v1.stream().map(Video::getVideoId).collect(Collectors.toSet())); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															 
														 | 
														
														 | 
														
															+        RecallUtils.extractRecall(mergeWeight.getOrDefault("v1", 5.0).intValue(), param, RegionRealtimeRecallStrategyV1.PUSH_FORM, setVideo, rovRecallRank); 
														 | 
													
												
											
												
													
														| 
														 | 
														
															         //-------------------scene cf rovn------------------ 
														 | 
														
														 | 
														
															         //-------------------scene cf rovn------------------ 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        List<Video> sceneCFRovn = extractAndSort(param, SceneCFRovnRecallStrategy.PUSH_FORM); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        sceneCFRovn = sceneCFRovn.stream().filter(r -> !setVideo.contains(r.getVideoId())).collect(Collectors.toList()); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        sceneCFRovn = sceneCFRovn.subList(0, Math.min(mergeWeight.getOrDefault("sceneCFRovn", 5.0).intValue(), sceneCFRovn.size())); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        rovRecallRank.addAll(sceneCFRovn); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        setVideo.addAll(sceneCFRovn.stream().map(Video::getVideoId).collect(Collectors.toSet())); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															 
														 | 
														
														 | 
														
															+        RecallUtils.extractRecall(mergeWeight.getOrDefault("sceneCFRovn", 5.0).intValue(), param, SceneCFRovnRecallStrategy.PUSH_FORM, setVideo, rovRecallRank); 
														 | 
													
												
											
												
													
														| 
														 | 
														
															         //-------------------scene cf rosn------------------ 
														 | 
														
														 | 
														
															         //-------------------scene cf rosn------------------ 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        List<Video> sceneCFRosn = extractAndSort(param, SceneCFRosnRecallStrategy.PUSH_FORM); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        sceneCFRosn = sceneCFRosn.stream().filter(r -> !setVideo.contains(r.getVideoId())).collect(Collectors.toList()); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        sceneCFRosn = sceneCFRosn.subList(0, Math.min(mergeWeight.getOrDefault("sceneCFRosn", 5.0).intValue(), sceneCFRosn.size())); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        rovRecallRank.addAll(sceneCFRosn); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        setVideo.addAll(sceneCFRosn.stream().map(Video::getVideoId).collect(Collectors.toSet())); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        // -------------------cate1------------------ 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        int cate1RecallN = mergeWeight.getOrDefault("cate1RecallN", 5.0).intValue(); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        addRecall(param, cate1RecallN, UserCate1RecallStrategy.PUSH_FORM, setVideo, rovRecallRank); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        // -------------------cate2------------------ 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        int cate2RecallN = mergeWeight.getOrDefault("cate2RecallN", 5.0).intValue(); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        addRecall(param, cate2RecallN, UserCate2RecallStrategy.PUSH_FORM, setVideo, rovRecallRank); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															 
														 | 
														
														 | 
														
															+        RecallUtils.extractRecall(mergeWeight.getOrDefault("sceneCFRosn", 5.0).intValue(), param, SceneCFRosnRecallStrategy.PUSH_FORM, setVideo, rovRecallRank); 
														 | 
													
												
											
												
													
														| 
														 | 
														
															 
														 | 
														
														 | 
														
															+        // -------------------user cate1------------------ 
														 | 
													
												
											
												
													
														| 
														 | 
														
															 
														 | 
														
														 | 
														
															+        RecallUtils.extractRecall(mergeWeight.getOrDefault("cate1RecallN", 5.0).intValue(), param, UserCate1RecallStrategy.PUSH_FORM, setVideo, rovRecallRank); 
														 | 
													
												
											
												
													
														| 
														 | 
														
															 
														 | 
														
														 | 
														
															+        // -------------------user cate2------------------ 
														 | 
													
												
											
												
													
														| 
														 | 
														
															 
														 | 
														
														 | 
														
															+        RecallUtils.extractRecall(mergeWeight.getOrDefault("cate2RecallN", 5.0).intValue(), param, UserCate2RecallStrategy.PUSH_FORM, setVideo, rovRecallRank); 
														 | 
													
												
											
												
													
														| 
														 | 
														
															         // -------------------head province cate1------------------ 
														 | 
														
														 | 
														
															         // -------------------head province cate1------------------ 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        int headCate1RecallN = mergeWeight.getOrDefault("headCate1RecallN", 3.0).intValue(); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        addRecall(param, headCate1RecallN, HeadProvinceCate1RecallStrategy.PUSH_FORM, setVideo, rovRecallRank); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															 
														 | 
														
														 | 
														
															+        RecallUtils.extractRecall(mergeWeight.getOrDefault("headCate1RecallN", 3.0).intValue(), param, HeadProvinceCate1RecallStrategy.PUSH_FORM, setVideo, rovRecallRank); 
														 | 
													
												
											
												
													
														| 
														 | 
														
															         // -------------------head province cate2------------------ 
														 | 
														
														 | 
														
															         // -------------------head province cate2------------------ 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        int headCate2RecallN = mergeWeight.getOrDefault("headCate2RecallN", 3.0).intValue(); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        addRecall(param, headCate2RecallN, HeadProvinceCate2RecallStrategy.PUSH_FORM, setVideo, rovRecallRank); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															 
														 | 
														
														 | 
														
															+        RecallUtils.extractRecall(mergeWeight.getOrDefault("headCate2RecallN", 3.0).intValue(), param, HeadProvinceCate2RecallStrategy.PUSH_FORM, setVideo, rovRecallRank); 
														 | 
													
												
											
												
													
														| 
														 | 
														
															         //-------------------head cate2 of rovn------------------ 
														 | 
														
														 | 
														
															         //-------------------head cate2 of rovn------------------ 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        List<Video> headCate2Rov = extractAndSort(param, HeadCate2RovRecallStrategy.PUSH_FROM); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        // 视频去重 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        removeDuplicate(headCate2Rov); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        headCate2Rov = headCate2Rov.stream().filter(o -> !setVideo.contains(o.getVideoId())).collect(Collectors.toList()); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        headCate2Rov = headCate2Rov.subList(0, Math.min(mergeWeight.getOrDefault("headCate2Rov", 5.0).intValue(), headCate2Rov.size())); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        rovRecallRank.addAll(headCate2Rov); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        setVideo.addAll(headCate2Rov.stream().map(Video::getVideoId).collect(Collectors.toSet())); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															 
														 | 
														
														 | 
														
															+        RecallUtils.extractRecall(mergeWeight.getOrDefault("headCate2Rov", 5.0).intValue(), param, HeadCate2RovRecallStrategy.PUSH_FROM, setVideo, rovRecallRank); 
														 | 
													
												
											
												
													
														| 
														 | 
														
															  
														 | 
														
														 | 
														
															  
														 | 
													
												
											
												
													
														| 
														 | 
														
															         //-------------------排------------------- 
														 | 
														
														 | 
														
															         //-------------------排------------------- 
														 | 
													
												
											
												
													
														| 
														 | 
														
															         //-------------------序------------------- 
														 | 
														
														 | 
														
															         //-------------------序------------------- 
														 | 
													
												
											
										
											
												
													
														 | 
														
															@@ -136,7 +99,7 @@ public class RankStrategy4RegionMergeModelV536 extends RankStrategy4RegionMergeM 
														 | 
													
												
											
												
													
														| 
														 | 
														
															  
														 | 
														
														 | 
														
															  
														 | 
													
												
											
												
													
														| 
														 | 
														
															         // 4. 排序模型计算 
														 | 
														
														 | 
														
															         // 4. 排序模型计算 
														 | 
													
												
											
												
													
														| 
														 | 
														
															         Map<String, Float> sceneFeatureMap = new HashMap<>(0); 
														 | 
														
														 | 
														
															         Map<String, Float> sceneFeatureMap = new HashMap<>(0); 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        List<RankItem> items = ScorerUtils.getScorerPipeline("feeds_score_config_fm_xgb_20250317.conf").scoring(sceneFeatureMap, userFeatureMap, userFeatureMap, rankItems); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															 
														 | 
														
														 | 
														
															+        List<RankItem> items = ScorerUtils.getScorerPipeline("feeds_score_config_fm_xgb_20250613.conf").scoring(sceneFeatureMap, userFeatureMap, userFeatureMap, rankItems); 
														 | 
													
												
											
												
													
														| 
														 | 
														
															  
														 | 
														
														 | 
														
															  
														 | 
													
												
											
												
													
														| 
														 | 
														
															         // 5. 排序公式特征 
														 | 
														
														 | 
														
															         // 5. 排序公式特征 
														 | 
													
												
											
												
													
														| 
														 | 
														
															         double xgbRovNegRate = mergeWeight.getOrDefault("xgbRovNegRate", 0.059); 
														 | 
														
														 | 
														
															         double xgbRovNegRate = mergeWeight.getOrDefault("xgbRovNegRate", 0.059); 
														 | 
													
												
											
										
											
												
													
														 | 
														
															@@ -202,9 +165,7 @@ public class RankStrategy4RegionMergeModelV536 extends RankStrategy4RegionMergeM 
														 | 
													
												
											
												
													
														| 
														 | 
														
															             } 
														 | 
														
														 | 
														
															             } 
														 | 
													
												
											
												
													
														| 
														 | 
														
															             result.add(video); 
														 | 
														
														 | 
														
															             result.add(video); 
														 | 
													
												
											
												
													
														| 
														 | 
														
															         } 
														 | 
														
														 | 
														
															         } 
														 | 
													
												
											
												
													
														| 
														 | 
														
															- 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															         ExtractVideoMergeCate.addOtherParam(result, videoBaseInfoMap); 
														 | 
														
														 | 
														
															         ExtractVideoMergeCate.addOtherParam(result, videoBaseInfoMap); 
														 | 
													
												
											
												
													
														| 
														 | 
														
															- 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															         result.sort(Comparator.comparingDouble(o -> -o.getSortScore())); 
														 | 
														
														 | 
														
															         result.sort(Comparator.comparingDouble(o -> -o.getSortScore())); 
														 | 
													
												
											
												
													
														| 
														 | 
														
															         return result; 
														 | 
														
														 | 
														
															         return result; 
														 | 
													
												
											
												
													
														| 
														 | 
														
															     } 
														 | 
														
														 | 
														
															     } 
														 | 
													
												
											
										
											
												
													
														 | 
														
															@@ -385,16 +346,6 @@ public class RankStrategy4RegionMergeModelV536 extends RankStrategy4RegionMergeM 
														 | 
													
												
											
												
													
														| 
														 | 
														
															         return newScore; 
														 | 
														
														 | 
														
															         return newScore; 
														 | 
													
												
											
												
													
														| 
														 | 
														
															     } 
														 | 
														
														 | 
														
															     } 
														 | 
													
												
											
												
													
														| 
														 | 
														
															  
														 | 
														
														 | 
														
															  
														 | 
													
												
											
												
													
														| 
														 | 
														
															-    private void addRecall(RankParam param, int recallNum, String recallName, Set<Long> setVideo, List<Video> rovRecallRank) { 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        if (recallNum > 0) { 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-            List<Video> list = extractAndSort(param, recallName); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-            list = list.stream().filter(r -> !setVideo.contains(r.getVideoId())).collect(Collectors.toList()); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-            list = list.subList(0, Math.min(recallNum, list.size())); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-            rovRecallRank.addAll(list); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-            setVideo.addAll(list.stream().map(Video::getVideoId).collect(Collectors.toSet())); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        } 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-    } 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															- 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															     private Map<String, Double> findSimCateScore(String headCate2, int length) { 
														 | 
														
														 | 
														
															     private Map<String, Double> findSimCateScore(String headCate2, int length) { 
														 | 
													
												
											
												
													
														| 
														 | 
														
															         if (StringUtils.isBlank(headCate2)) { 
														 | 
														
														 | 
														
															         if (StringUtils.isBlank(headCate2)) { 
														 | 
													
												
											
												
													
														| 
														 | 
														
															             return new HashMap<>(); 
														 | 
														
														 | 
														
															             return new HashMap<>(); 
														 |