|
@@ -78,6 +78,8 @@ public class RankStrategy4RegionMergeModelV569 extends RankStrategy4RegionMergeM
|
|
|
RecallUtils.extractRecall(mergeWeight.getOrDefault("return1Cate2Ros", 5.0).intValue(), param, Return1Cate2RosRecallStrategy.PUSH_FORM, setVideo, rovRecallRank);
|
|
RecallUtils.extractRecall(mergeWeight.getOrDefault("return1Cate2Ros", 5.0).intValue(), param, Return1Cate2RosRecallStrategy.PUSH_FORM, setVideo, rovRecallRank);
|
|
|
//-------------------return1 cate2 str------------------
|
|
//-------------------return1 cate2 str------------------
|
|
|
RecallUtils.extractRecall(mergeWeight.getOrDefault("return1Cate2Str", 5.0).intValue(), param, Return1Cate2StrRecallStrategy.PUSH_FORM, setVideo, rovRecallRank);
|
|
RecallUtils.extractRecall(mergeWeight.getOrDefault("return1Cate2Str", 5.0).intValue(), param, Return1Cate2StrRecallStrategy.PUSH_FORM, setVideo, rovRecallRank);
|
|
|
|
|
+ //--------------deconstruction keywords ros-------------
|
|
|
|
|
+ RecallUtils.extractRecall(mergeWeight.getOrDefault("deconstructionKeywordsRos", 5.0).intValue(), param, UserDeconstructionKeywordsRecallStrategy.PUSH_FORM, setVideo, rovRecallRank);
|
|
|
|
|
|
|
|
// 记录召回源中的视频
|
|
// 记录召回源中的视频
|
|
|
this.rankBeforePostProcessor(rovRecallRank);
|
|
this.rankBeforePostProcessor(rovRecallRank);
|
|
@@ -114,7 +116,7 @@ public class RankStrategy4RegionMergeModelV569 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_20250729.conf").scoring(sceneFeatureMap, userFeatureMap, userFeatureMap, rankItems);
|
|
|
|
|
|
|
+ List<RankItem> items = ScorerUtils.getScorerPipeline("feeds_score_config_str_and_ros_20260319.conf").scoring(sceneFeatureMap, userFeatureMap, userFeatureMap, rankItems);
|
|
|
|
|
|
|
|
// 5. 排序公式特征
|
|
// 5. 排序公式特征
|
|
|
double xgbRovNegRate = mergeWeight.getOrDefault("xgbRovNegRate", 0.059);
|
|
double xgbRovNegRate = mergeWeight.getOrDefault("xgbRovNegRate", 0.059);
|
|
@@ -136,12 +138,6 @@ public class RankStrategy4RegionMergeModelV569 extends RankStrategy4RegionMergeM
|
|
|
double b0Ror1hW = mergeWeight.getOrDefault("b0_ror_1h_w", 0d);
|
|
double b0Ror1hW = mergeWeight.getOrDefault("b0_ror_1h_w", 0d);
|
|
|
double b0Ror24hW = mergeWeight.getOrDefault("b0_ror_24h_w", 0d);
|
|
double b0Ror24hW = mergeWeight.getOrDefault("b0_ror_24h_w", 0d);
|
|
|
|
|
|
|
|
- double cnRovn1hW = mergeWeight.getOrDefault("cn_rovn_1h_w", 0d);
|
|
|
|
|
- double cnRovn24hW = mergeWeight.getOrDefault("cn_rovn_24h_w", 0d);
|
|
|
|
|
-
|
|
|
|
|
- double dnRovn1hW = mergeWeight.getOrDefault("dn_rovn_1h_w", 0d);
|
|
|
|
|
- double dnRovn24hW = mergeWeight.getOrDefault("dn_rovn_24h_w", 0d);
|
|
|
|
|
-
|
|
|
|
|
Map<String, Map<String, String>> vid2MapFeature = this.getVideoRedisFeature(vids, "redis:vid_hasreturn_vor:");
|
|
Map<String, Map<String, String>> vid2MapFeature = this.getVideoRedisFeature(vids, "redis:vid_hasreturn_vor:");
|
|
|
|
|
|
|
|
// 获取权重
|
|
// 获取权重
|
|
@@ -169,7 +165,6 @@ public class RankStrategy4RegionMergeModelV569 extends RankStrategy4RegionMergeM
|
|
|
item.getScoresMap().put("vorW", vorW);
|
|
item.getScoresMap().put("vorW", vorW);
|
|
|
|
|
|
|
|
Map<String, String> bcData = videoBCData.getOrDefault(String.valueOf(item.getVideoId()), new HashMap<>()).getOrDefault("alg_vid_feature_b_c_data", new HashMap<>());
|
|
Map<String, String> bcData = videoBCData.getOrDefault(String.valueOf(item.getVideoId()), new HashMap<>()).getOrDefault("alg_vid_feature_b_c_data", new HashMap<>());
|
|
|
- Map<String, String> cdNData = videoBCData.getOrDefault(String.valueOf(item.getVideoId()), new HashMap<>()).getOrDefault("alg_vid_feature_cn_dn_data", new HashMap<>());
|
|
|
|
|
|
|
|
|
|
double c1Rovn1h = Double.parseDouble(bcData.getOrDefault("c1_rovn_1h", "0"));
|
|
double c1Rovn1h = Double.parseDouble(bcData.getOrDefault("c1_rovn_1h", "0"));
|
|
|
double c1Rovn24h = Double.parseDouble(bcData.getOrDefault("c1_rovn_24h", "0"));
|
|
double c1Rovn24h = Double.parseDouble(bcData.getOrDefault("c1_rovn_24h", "0"));
|
|
@@ -198,25 +193,7 @@ public class RankStrategy4RegionMergeModelV569 extends RankStrategy4RegionMergeM
|
|
|
item.getScoresMap().put("b0Ror24hW", b0Ror24hW);
|
|
item.getScoresMap().put("b0Ror24hW", b0Ror24hW);
|
|
|
item.getScoresMap().put("b0Ror24h", b0Ror24h);
|
|
item.getScoresMap().put("b0Ror24h", b0Ror24h);
|
|
|
|
|
|
|
|
- double cnRovn1h = Double.parseDouble(cdNData.getOrDefault("cn_rovn_1h", "0"));
|
|
|
|
|
- double cnRovn24h = Double.parseDouble(cdNData.getOrDefault("cn_rovn_24h", "0"));
|
|
|
|
|
- double cnRovnScore = cnRovn1hW * cnRovn1h + cnRovn24hW * cnRovn24h;
|
|
|
|
|
- item.getScoresMap().put("cnRovnScore", cnRovnScore);
|
|
|
|
|
- item.getScoresMap().put("cnRovn1hW", cnRovn1hW);
|
|
|
|
|
- item.getScoresMap().put("cnRovn1h", cnRovn1h);
|
|
|
|
|
- item.getScoresMap().put("cnRovn24hW", cnRovn24hW);
|
|
|
|
|
- item.getScoresMap().put("cnRovn24h", cnRovn24h);
|
|
|
|
|
-
|
|
|
|
|
- double dnRovn1h = Double.parseDouble(cdNData.getOrDefault("dn_rovn_1h", "0"));
|
|
|
|
|
- double dnRovn24h = Double.parseDouble(cdNData.getOrDefault("dn_rovn_24h", "0"));
|
|
|
|
|
- double dnRovnScore = dnRovn1hW * dnRovn1h + dnRovn24hW * dnRovn24h;
|
|
|
|
|
- item.getScoresMap().put("dnRovnScore", dnRovnScore);
|
|
|
|
|
- item.getScoresMap().put("dnRovn1hW", dnRovn1hW);
|
|
|
|
|
- item.getScoresMap().put("dnRovn1h", dnRovn1h);
|
|
|
|
|
- item.getScoresMap().put("dnRovn24hW", dnRovn24hW);
|
|
|
|
|
- item.getScoresMap().put("dnRovn24h", dnRovn24h);
|
|
|
|
|
-
|
|
|
|
|
- score = fmRov * (rosAdd + rosW * newNorXGBScore) * (vorAdd + vorW * vor) + c1RovnScore + b0StrScore + b0RorScore + cnRovnScore * dnRovnScore;
|
|
|
|
|
|
|
+ score = fmRov * (rosAdd + rosW * newNorXGBScore) * (vorAdd + vorW * vor) + c1RovnScore + b0StrScore + b0RorScore;
|
|
|
|
|
|
|
|
Video video = item.getVideo();
|
|
Video video = item.getVideo();
|
|
|
video.setScore(score);
|
|
video.setScore(score);
|