feat:添加dnn v3模型

recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/service/rank/strategy/RankStrategy4RegionMergeModelV566.java

@@ -15,6 +15,7 @@ import com.tzld.piaoquan.recommend.server.service.recall.strategy.*;
 import com.tzld.piaoquan.recommend.server.service.score.ScorerUtils;
 import com.tzld.piaoquan.recommend.server.util.*;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.collections4.MapUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -23,6 +24,8 @@ import org.springframework.stereotype.Service;
 import java.util.*;
 import java.util.concurrent.Future;
 import java.util.concurrent.TimeUnit;
+import java.util.stream.Collectors;
+import java.util.stream.Stream;
 
 @Service
 @Slf4j
@@ -91,8 +94,22 @@ public class RankStrategy4RegionMergeModelV566 extends RankStrategy4RegionMergeM
         // 1. 批量获取特征  省份参数要对齐  headvid  要传递过来！
         // k1:视频、k2:表、k3:特征、v:特征值
         Map<String, String> headVideoInfo = param.getHeadInfo();
+
+        // 用户的序列特征
+        Map<String, Map<String, String>> unionIdFeature = featureService.getUnionIdFeature(param.getUnionId());
+        Map<String, String> userNetworkSeqFeature = unionIdFeature.getOrDefault("alg_user_network_seq_feature", new HashMap<>());
+        List<String> actVidSeq = FeatureUtils.extractVidsFromUserNetworkSeqFeature(userNetworkSeqFeature, "a_v_s");
+        List<String> netVidSeq = FeatureUtils.extractVidsFromUserNetworkSeqFeature(userNetworkSeqFeature, "n_v_s");
+
         List<String> vids = CommonCollectionUtils.toListDistinct(rovRecallRank, v -> String.valueOf(v.getVideoId()));
-        Map<String, Map<String, Map<String, String>>> videoBaseInfoMap = featureService.getVideoBaseInfo("", vids);
+
+        List<String> allVids = Stream.of(actVidSeq, netVidSeq, vids)
+                .flatMap(Collection::stream)
+                .distinct()
+                .filter(StringUtils::isNotBlank)
+                .collect(Collectors.toList());
+
+        Map<String, Map<String, Map<String, String>>> videoBaseInfoMap = featureService.getVideoBaseInfo("", allVids);
         Map<String, Map<String, Map<String, String>>> videoBCData = featureService.getVideoStatistics(vids);
 
         FeatureService.Feature feature = featureService.getFeatureV4(param, headVideoInfo, videoBaseInfoMap, vids);
@@ -106,15 +123,20 @@ public class RankStrategy4RegionMergeModelV566 extends RankStrategy4RegionMergeM
         Map<String, Map<String, String>> userBehaviorVideoMap = param.getBehaviorVideos();
         Map<String, String> creativeInfo = param.getCreativeInfoFeature();
 
+        Map<String, String> featureMapToString = new HashMap<>();
+        FeatureV6.parseStringFeatureMap(featureMapToString, param);
+        FeatureV6.putVideoStringFeatures("h", headVideoInfo, featureMapToString);
+
         // 3. 特征处理
         List<RankItem> rankItems = CommonCollectionUtils.toList(rovRecallRank, RankItem::new);
         Map<String, Float> userFeatureMap = getUserFeature(currentMs, param, creativeInfo, headVideoInfo, userProfile, featureOriginUser);
         batchGetVideoFeature(currentMs, userProfile, creativeInfo, headVideoInfo, videoBaseInfoMap,
-                newC7Map, newC8Map, featureOriginUser, userBehaviorVideoMap, featureOriginVideo, rankItems);
+                newC7Map, newC8Map, featureOriginUser, userBehaviorVideoMap, featureOriginVideo, featureMapToString, userFeatureMap, rankItems);
+
 
         // 4. 排序模型计算
         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_ros_dnn_20260424.conf").scoring(sceneFeatureMap, userFeatureMap, rankItems);
 
         // 5. 排序公式特征
         double xgbRovNegRate = mergeWeight.getOrDefault("xgbRovNegRate", 0.059);
@@ -127,6 +149,9 @@ public class RankStrategy4RegionMergeModelV566 extends RankStrategy4RegionMergeM
         double vorAdd = mergeWeight.getOrDefault("vor_add", 0.1d);
         double vorW = mergeWeight.getOrDefault("vor_w", 1.0d);
 
+        double leaveW = mergeWeight.getOrDefault("leave_w", 1d);
+        double leaveExp = mergeWeight.getOrDefault("leave_exp", 1d);
+
         double c1Rovn1hW = mergeWeight.getOrDefault("c1_rovn_1h_w", 0d);
         double c1Rovn24hW = mergeWeight.getOrDefault("c1_rovn_24h_w", 0d);
 
@@ -144,7 +169,7 @@ public class RankStrategy4RegionMergeModelV566 extends RankStrategy4RegionMergeM
 
         Map<String, Map<String, String>> vid2MapFeature = this.getVideoRedisFeature(vids, "redis:vid_hasreturn_vor:");
 
-        // 获取权重
+
         Map<String, String> contextInfo = getContextInfo(param);
 
         List<Video> result = new ArrayList<>();
@@ -158,8 +183,9 @@ public class RankStrategy4RegionMergeModelV566 extends RankStrategy4RegionMergeM
             double hasReturnRovScore = Double.parseDouble(vid2MapFeature.getOrDefault(item.getVideoId() + "", new HashMap<>()).getOrDefault("rov", "0"));
             item.getScoresMap().put("hasReturnRovScore", hasReturnRovScore);
 
-            double norXGBScore = item.getScoresMap().getOrDefault("NorXGBScore", 0d);
-            double newNorXGBScore = norPowerCalibration(xgbNorPowerWeight, xgbNorPowerExp, norXGBScore);
+            double norDNNScore = item.getScoresMap().getOrDefault("NorDNNScore", 0d);
+            double newNorDNNScore = norPowerCalibration(xgbNorPowerWeight, xgbNorPowerExp, norDNNScore);
+            item.getScoresMap().put("newNorDNNScore", newNorDNNScore);
             item.getScoresMap().put("rosAdd", rosAdd);
             item.getScoresMap().put("rosW", rosW);
 
@@ -168,6 +194,12 @@ public class RankStrategy4RegionMergeModelV566 extends RankStrategy4RegionMergeM
             item.getScoresMap().put("vorAdd", vorAdd);
             item.getScoresMap().put("vorW", vorW);
 
+            double pLeave = item.getScoresMap().getOrDefault("pLeave", 0d);
+            double newPLeave = Math.pow((1 - leaveW * pLeave), leaveExp);
+            item.getScoresMap().put("leaveW", leaveW);
+            item.getScoresMap().put("leaveExp", leaveExp);
+            item.getScoresMap().put("newPLeave", newPLeave);
+
             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<>());
 
@@ -217,7 +249,7 @@ public class RankStrategy4RegionMergeModelV566 extends RankStrategy4RegionMergeM
             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 * newNorDNNScore) * (vorAdd + vorW * vor) * newPLeave + c1RovnScore + b0StrScore + b0RorScore + cnRovnScore + dnRovnScore;
 
             Video video = item.getVideo();
             video.setScore(score);
@@ -251,7 +283,7 @@ public class RankStrategy4RegionMergeModelV566 extends RankStrategy4RegionMergeM
             if (MapUtils.isNotEmpty(contextInfo)) {
                 video.getMetaFeatureMap().put("context", contextInfo);
             }
-            if (Objects.nonNull(video.getRankVideoInfoMap()) && video.getRankVideoInfoMap().containsKey(video.getVideoId())){
+            if (Objects.nonNull(video.getRankVideoInfoMap()) && video.getRankVideoInfoMap().containsKey(video.getVideoId())) {
                 video.getRankVideoInfoMap().get(video.getVideoId()).setScore(score);
                 video.getRankVideoInfoMap().get(video.getVideoId()).setScoresMap(video.getScoresMap());
             }
@@ -338,15 +370,28 @@ public class RankStrategy4RegionMergeModelV566 extends RankStrategy4RegionMergeM
                                       Map<String, Map<String, String>> userOriginInfo,
                                       Map<String, Map<String, String>> historyVideoMap,
                                       Map<String, Map<String, Map<String, String>>> videoOriginInfo,
+                                      Map<String, String> featureMapToString,
+                                      Map<String, Float> userFeatureMap,
                                       List<RankItem> rankItems) {
-        if (null != rankItems && !rankItems.isEmpty()) {
+        if (CollectionUtils.isNotEmpty(rankItems)) {
             List<Future<Integer>> futures = new ArrayList<>();
             for (RankItem item : rankItems) {
                 String vid = item.getVideoId() + "";
                 Map<String, String> rankInfo = videoBaseInfoMap.getOrDefault(vid, new HashMap<>()).getOrDefault("alg_vid_feature_basic_info", new HashMap<>());
                 Future<Integer> future = ThreadPoolFactory.defaultPool().submit(() -> {
-                    item.featureMap = getVideoFeature(currentMs, vid, userProfile, creativeInfo, headInfo, rankInfo, c7Map, c8Map, userOriginInfo, historyVideoMap, videoOriginInfo);
-                    item.norFeatureMap = item.featureMap;
+                    Map<String, Float> featureMap = new HashMap<>(userFeatureMap);
+                    Map<String, Float> videoFeature = getVideoFeature(currentMs, vid, userProfile, creativeInfo, headInfo, rankInfo, c7Map, c8Map, userOriginInfo, historyVideoMap, videoOriginInfo);
+                    featureMap.putAll(videoFeature);
+                    item.featureMap = featureMap;
+
+                    Map<String, String> userNetworkSeqFeature = userOriginInfo.getOrDefault("alg_user_network_seq_feature", new HashMap<>());
+
+                    Map<String, String> featureMapString = new HashMap<>(featureMapToString);
+                    FeatureV6.putVideoStringFeatures("r", rankInfo, featureMapString);
+                    featureMapString.put("r@vid", "r_vid_" + vid);
+                    FeatureV6.putProfileVideoCrossStringFeature(currentMs, userProfile, historyVideoMap, featureMapString);
+                    FeatureV6.putUserNetworkSeqFeature(featureMapString, userNetworkSeqFeature, videoBaseInfoMap);
+                    item.featureMapString = featureMapString;
                     return 1;
                 });
                 futures.add(future);
@@ -418,48 +463,4 @@ public class RankStrategy4RegionMergeModelV566 extends RankStrategy4RegionMergeM
         }
         return newScore;
     }
-
-    private Map<String, Double> findSimCateScore(String headCate2, int length) {
-        if (StringUtils.isBlank(headCate2)) {
-            return new HashMap<>();
-        }
-
-        String redisKey = String.format("alg_recsys_good_cate_pair_list:%s", headCate2);
-        String cate2Value = redisTemplate.opsForValue().get(redisKey);
-        if (StringUtils.isEmpty(cate2Value)) {
-            return new HashMap<>();
-        }
-
-        return this.parsePair(cate2Value, length);
-    }
-
-    private Map<String, Double> parsePair(String value, int length) {
-        if (StringUtils.isBlank(value)) {
-            return new HashMap<>();
-        }
-
-        String[] split = value.split("\t");
-        if (split.length != 2) {
-            return new HashMap<>();
-        }
-
-        String[] valueList = split[0].trim().split(",");
-        String[] scoreList = split[1].trim().split(",");
-        if (valueList.length != scoreList.length) {
-            return new HashMap<>();
-        }
-
-        int minLength = Math.min(length, valueList.length);
-        Map<String, Double> resultMap = new HashMap<>();
-        for (int i = 0; i < minLength; i++) {
-            resultMap.put(valueList[i].trim(), Double.parseDouble(scoreList[i].trim()));
-        }
-
-        return resultMap;
-    }
-
-    private String findVideoMergeCate2(Map<String, Map<String, Map<String, String>>> featureOriginVideo, String vid) {
-        Map<String, String> videoInfo = featureOriginVideo.getOrDefault(vid, new HashMap<>()).getOrDefault("alg_vid_feature_basic_info", new HashMap<>());
-        return videoInfo.get("merge_second_level_cate");
-    }
 }

recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/service/score/ScorerUtils.java

@@ -42,6 +42,7 @@ public final class ScorerUtils {
         ScorerUtils.init("feeds_score_config_dnn_20260407.conf");
         ScorerUtils.init("feeds_score_config_dnn_20260417.conf");
         ScorerUtils.init("feeds_score_config_dnn_20260424.conf");
+        ScorerUtils.init("feeds_score_config_str_ros_dnn_20260424.conf");
 
         // 召回配置
         ScorerUtils.init4Recall("feeds_recall_config_region_v1.conf");

recommend-server-service/src/main/resources/feeds_score_config_dnn_20260424.conf

@@ -4,11 +4,11 @@ scorer-config = {
      scorer-priority = 100
      param = {
        dnnConfig = {
-         "fgConfigFilePath": "zhaohaipeng/pai/config/fg/feature_list_20260417.json",
-         "easToken": "YzhhMGY5OGYxNWUxNWNjNWIzNjgyOWYyZmFiMDAzNThlZTA3ODUwMA==",
+         "fgConfigFilePath": "zhaohaipeng/pai/config/fg/feature_list_20260403.json",
+         "easToken": "MmEwYzVlZGFiOTM4YWM3ZTE5ZDMzNTgzY2Q5YjZlYjVjODE5ZjIzYQ==",
          "easEndpoint": "1894469520484605.vpc.cn-hangzhou.pai-eas.aliyuncs.com",
-         "modelName": "recsys_dnn_v2_20260417",
-         "fetchs":["probs_is_share"]
+         "modelName": "recsys_dnn_v1_20260327",
+         "fetchs":["y_return_n_uv","probs_is_share"]
        }
      }
   }

recommend-server-service/src/main/resources/feeds_score_config_str_ros_dnn_20260424.conf

@@ -0,0 +1,462 @@
+scorer-config = {
+  rov-score-config = {
+       scorer-name = "com.tzld.piaoquan.recommend.server.service.score.VlogRovFMScorer"
+       scorer-priority = 96
+       model-path = "zhangbo/model_fm_for_recsys_str_20260317.txt"
+    }
+    nor-score-config = {
+      scorer-name = "com.tzld.piaoquan.recommend.server.service.score.NorXGBRegressionScorer"
+      scorer-priority = 97
+      model-path = "zhangbo/model_xgb_for_recsys_ros_20260317.tar.gz"
+      param = {
+        localDir = "xgboost/model_xgb_for_recsys_ros_20260317"
+        features = [
+        "b0_12h@return_1_uv",
+        "b0_12h@ros1_#",
+        "b0_12h@ros_#",
+        "b0_12h@ros_minus1_#",
+        "b0_12h@ros_minus_#",
+        "b0_12h@ros_n1_#",
+        "b0_12h@ros_n_#",
+        "b0_12h@ros_one",
+        "b0_12h@rovn1_#",
+        "b0_12h@rovn_#",
+        "b0_1h@return_1_uv",
+        "b0_1h@ros1_#",
+        "b0_1h@ros_#",
+        "b0_1h@ros_minus1_#",
+        "b0_1h@ros_minus_#",
+        "b0_1h@ros_n1_#",
+        "b0_1h@ros_n_#",
+        "b0_1h@ros_one",
+        "b0_1h@rovn1_#",
+        "b0_1h@rovn_#",
+        "b0_3h@return_1_uv",
+        "b0_3h@ros1_#",
+        "b0_3h@ros_#",
+        "b0_3h@ros_minus1_#",
+        "b0_3h@ros_minus_#",
+        "b0_3h@ros_n1_#",
+        "b0_3h@ros_n_#",
+        "b0_3h@ros_one",
+        "b0_3h@rovn1_#",
+        "b0_3h@rovn_#",
+        "b0_6h@return_1_uv",
+        "b0_6h@ros1_#",
+        "b0_6h@ros_#",
+        "b0_6h@ros_minus1_#",
+        "b0_6h@ros_minus_#",
+        "b0_6h@ros_n1_#",
+        "b0_6h@ros_n_#",
+        "b0_6h@ros_one",
+        "b0_6h@rovn1_#",
+        "b0_6h@rovn_#",
+        "b10_12h@is_share",
+        "b10_12h@return_n_uv",
+        "b10_12h@ros_#",
+        "b10_12h@ros_minus_#",
+        "b10_12h@rovn_#",
+        "b10_12h@str",
+        "b10_12h@str_plus",
+        "b10_1h@is_share",
+        "b10_1h@return_n_uv",
+        "b10_1h@ros_#",
+        "b10_1h@ros_minus_#",
+        "b10_1h@rovn_#",
+        "b10_1h@str",
+        "b10_1h@str_plus",
+        "b11_12h@is_share",
+        "b11_12h@return_n_uv",
+        "b11_12h@ros_#",
+        "b11_12h@ros_minus_#",
+        "b11_12h@rovn_#",
+        "b11_12h@str",
+        "b11_12h@str_plus",
+        "b13_1h@exp",
+        "b13_1h@is_share",
+        "b13_1h@ros_#",
+        "b13_1h@ros_minus_#",
+        "b13_1h@ros_n_#",
+        "b13_1h@ros_one",
+        "b13_1h@rovn_#",
+        "b13_1h@share_cnt",
+        "b13_1h@str",
+        "b13_1h@str_plus",
+        "b13_24h@exp",
+        "b13_24h@is_share",
+        "b13_24h@ros_#",
+        "b13_24h@ros_minus_#",
+        "b13_24h@ros_n_#",
+        "b13_24h@ros_one",
+        "b13_24h@rovn_#",
+        "b13_24h@share_cnt",
+        "b13_24h@str",
+        "b13_24h@str_plus",
+        "b13_3h@exp",
+        "b13_3h@is_share",
+        "b13_3h@ros_#",
+        "b13_3h@ros_minus_#",
+        "b13_3h@ros_n_#",
+        "b13_3h@ros_one",
+        "b13_3h@rovn_#",
+        "b13_3h@share_cnt",
+        "b13_3h@str",
+        "b13_3h@str_plus",
+        "b13_72h@exp",
+        "b13_72h@is_share",
+        "b13_72h@ros_#",
+        "b13_72h@ros_minus_#",
+        "b13_72h@ros_n_#",
+        "b13_72h@ros_one",
+        "b13_72h@rovn_#",
+        "b13_72h@share_cnt",
+        "b13_72h@str",
+        "b13_72h@str_plus",
+        "b1_1h@ros_#",
+        "b1_1h@ros_minus_#",
+        "b1_1h@ros_n_#",
+        "b1_1h@ros_one",
+        "b1_1h@rovn_#",
+        "b1_24h@ros_#",
+        "b1_24h@ros_minus_#",
+        "b1_24h@ros_n_#",
+        "b1_24h@ros_one",
+        "b1_24h@rovn_#",
+        "b1_3h@ros_#",
+        "b1_3h@ros_minus_#",
+        "b1_3h@ros_n_#",
+        "b1_3h@ros_one",
+        "b1_3h@rovn_#",
+        "b1_72h@ros_#",
+        "b1_72h@ros_minus_#",
+        "b1_72h@ros_n_#",
+        "b1_72h@ros_one",
+        "b1_72h@rovn_#",
+        "b2_24h@return_n_uv",
+        "b2_24h@ros_#",
+        "b2_24h@ros_minus_#",
+        "b2_24h@ros_n_#",
+        "b2_24h@ros_one",
+        "b2_24h@rovn_#",
+        "b2_3h@return_n_uv",
+        "b2_3h@ros_#",
+        "b2_3h@ros_minus_#",
+        "b2_3h@ros_n_#",
+        "b2_3h@ros_one",
+        "b2_3h@rovn_#",
+        "b3_24h@is_share",
+        "b3_24h@return_n_uv",
+        "b3_24h@ros_#",
+        "b3_24h@ros_minus_#",
+        "b3_24h@ros_n_#",
+        "b3_24h@ros_one",
+        "b3_24h@rovn_#",
+        "b3_24h@str",
+        "b3_24h@str_plus",
+        "b3_72h@is_share",
+        "b3_72h@return_n_uv",
+        "b3_72h@ros_#",
+        "b3_72h@ros_minus_#",
+        "b3_72h@ros_n_#",
+        "b3_72h@ros_one",
+        "b3_72h@rovn_#",
+        "b3_72h@str",
+        "b3_72h@str_plus",
+        "b4_12h@is_share",
+        "b4_12h@return_n_uv",
+        "b4_12h@ros_#",
+        "b4_12h@ros_minus_#",
+        "b4_12h@ros_n_#",
+        "b4_12h@ros_one",
+        "b4_12h@rovn_#",
+        "b4_3h@is_share",
+        "b4_3h@return_n_uv",
+        "b4_3h@ros_#",
+        "b4_3h@ros_minus_#",
+        "b4_3h@ros_n_#",
+        "b4_3h@ros_one",
+        "b4_3h@rovn_#",
+        "b5_12h@exp",
+        "b5_12h@is_share",
+        "b5_12h@return_n_uv",
+        "b5_12h@ros_#",
+        "b5_12h@ros_minus_#",
+        "b5_12h@ros_n_#",
+        "b5_12h@ros_one",
+        "b5_12h@rovn_#",
+        "b5_12h@share_cnt",
+        "b5_12h@str",
+        "b5_12h@str_plus",
+        "b5_1h@exp",
+        "b5_1h@is_share",
+        "b5_1h@return_n_uv",
+        "b5_1h@ros_#",
+        "b5_1h@ros_minus_#",
+        "b5_1h@ros_n_#",
+        "b5_1h@ros_one",
+        "b5_1h@rovn_#",
+        "b5_1h@share_cnt",
+        "b5_1h@str",
+        "b5_1h@str_plus",
+        "b5_24h@exp",
+        "b5_24h@is_share",
+        "b5_24h@return_n_uv",
+        "b5_24h@ros_#",
+        "b5_24h@ros_minus_#",
+        "b5_24h@ros_n_#",
+        "b5_24h@ros_one",
+        "b5_24h@rovn_#",
+        "b5_24h@share_cnt",
+        "b5_24h@str",
+        "b5_24h@str_plus",
+        "b5_3h@exp",
+        "b5_3h@is_share",
+        "b5_3h@return_n_uv",
+        "b5_3h@ros_#",
+        "b5_3h@ros_minus_#",
+        "b5_3h@ros_n_#",
+        "b5_3h@ros_one",
+        "b5_3h@rovn_#",
+        "b5_3h@share_cnt",
+        "b5_3h@str",
+        "b5_3h@str_plus",
+        "b5_6h@exp",
+        "b5_6h@is_share",
+        "b5_6h@return_n_uv",
+        "b5_6h@ros_#",
+        "b5_6h@ros_minus_#",
+        "b5_6h@ros_n_#",
+        "b5_6h@ros_one",
+        "b5_6h@rovn_#",
+        "b5_6h@share_cnt",
+        "b5_6h@str",
+        "b5_6h@str_plus",
+        "b5_72h@exp",
+        "b5_72h@is_share",
+        "b5_72h@return_n_uv",
+        "b5_72h@ros_#",
+        "b5_72h@ros_minus_#",
+        "b5_72h@ros_n_#",
+        "b5_72h@ros_one",
+        "b5_72h@rovn_#",
+        "b5_72h@share_cnt",
+        "b5_72h@str",
+        "b5_72h@str_plus",
+        "b6_1h@is_share",
+        "b6_1h@return_n_uv",
+        "b6_1h@ros_#",
+        "b6_1h@ros_minus_#",
+        "b6_1h@ros_n_#",
+        "b6_1h@ros_one",
+        "b6_1h@rovn_#",
+        "b6_1h@str",
+        "b6_1h@str_plus",
+        "b6_24h@is_share",
+        "b6_24h@return_n_uv",
+        "b6_24h@ros_#",
+        "b6_24h@ros_minus_#",
+        "b6_24h@ros_n_#",
+        "b6_24h@ros_one",
+        "b6_24h@rovn_#",
+        "b6_24h@str",
+        "b6_24h@str_plus",
+        "b7_1h@is_share",
+        "b7_1h@return_n_uv",
+        "b7_1h@ros_#",
+        "b7_1h@ros_minus_#",
+        "b7_1h@ros_n_#",
+        "b7_1h@ros_one",
+        "b7_1h@rovn_#",
+        "b7_1h@str",
+        "b7_1h@str_plus",
+        "b7_24h@is_share",
+        "b7_24h@return_n_uv",
+        "b7_24h@ros_#",
+        "b7_24h@ros_minus_#",
+        "b7_24h@ros_n_#",
+        "b7_24h@ros_one",
+        "b7_24h@rovn_#",
+        "b7_24h@str",
+        "b7_24h@str_plus",
+        "b7_3h@is_share",
+        "b7_3h@return_n_uv",
+        "b7_3h@ros_#",
+        "b7_3h@ros_minus_#",
+        "b7_3h@ros_n_#",
+        "b7_3h@ros_one",
+        "b7_3h@rovn_#",
+        "b7_3h@str",
+        "b7_3h@str_plus",
+        "b7_72h@is_share",
+        "b7_72h@return_n_uv",
+        "b7_72h@ros_#",
+        "b7_72h@ros_minus_#",
+        "b7_72h@ros_n_#",
+        "b7_72h@ros_one",
+        "b7_72h@rovn_#",
+        "b7_72h@str",
+        "b7_72h@str_plus",
+        "b8_1h@is_share",
+        "b8_1h@return_n_uv",
+        "b8_1h@ros_#",
+        "b8_1h@ros_minus_#",
+        "b8_1h@rovn_#",
+        "b8_1h@str",
+        "b8_1h@str_plus",
+        "b8_24h@is_share",
+        "b8_24h@return_n_uv",
+        "b8_24h@ros_#",
+        "b8_24h@ros_minus_#",
+        "b8_24h@rovn_#",
+        "b8_24h@str",
+        "b8_24h@str_plus",
+        "b8_3h@is_share",
+        "b8_3h@return_n_uv",
+        "b8_3h@ros_#",
+        "b8_3h@ros_minus_#",
+        "b8_3h@rovn_#",
+        "b8_3h@str",
+        "b8_3h@str_plus",
+        "b9_1h@is_share",
+        "b9_1h@return_n_uv",
+        "b9_1h@ros_#",
+        "b9_1h@ros_minus_#",
+        "b9_1h@rovn_#",
+        "b9_1h@str",
+        "b9_1h@str_plus",
+        "b9_24h@is_share",
+        "b9_24h@return_n_uv",
+        "b9_24h@ros_#",
+        "b9_24h@ros_minus_#",
+        "b9_24h@rovn_#",
+        "b9_24h@str",
+        "b9_24h@str_plus",
+        "b9_3h@is_share",
+        "b9_3h@return_n_uv",
+        "b9_3h@ros_#",
+        "b9_3h@ros_minus_#",
+        "b9_3h@rovn_#",
+        "b9_3h@str",
+        "b9_3h@str_plus",
+        "c1_168h@is_share",
+        "c1_168h@return_n_uv",
+        "c1_168h@ros_#",
+        "c1_168h@ros_minus_#",
+        "c1_168h@ros_n_#",
+        "c1_168h@ros_one",
+        "c1_168h@rovn_#",
+        "c1_168h@str",
+        "c1_168h@str_plus",
+        "c1_72h@is_share",
+        "c1_72h@return_n_uv",
+        "c1_72h@ros_#",
+        "c1_72h@ros_minus_#",
+        "c1_72h@ros_n_#",
+        "c1_72h@ros_one",
+        "c1_72h@rovn_#",
+        "c1_72h@str",
+        "c1_72h@str_plus",
+        "c5_tags_1d@avgscore",
+        "c5_tags_1d@maxscore",
+        "c5_tags_3d@avgscore",
+        "c5_tags_3d@maxscore",
+        "c5_tags_7d@avgscore",
+        "c5_tags_7d@maxscore",
+        "c6_tags_1d@avgscore",
+        "c6_tags_1d@maxscore",
+        "c6_tags_3d@avgscore",
+        "c6_tags_3d@maxscore",
+        "c6_tags_7d@avgscore",
+        "c6_tags_7d@maxscore",
+        "c9@m_r_uv",
+        "c9@m_s_cnt",
+        "c9@r_pv",
+        "c9@r_uv",
+        "c9@ros",
+        "c9@ros_minus",
+        "c9@ros_one",
+        "c9@s_cnt",
+        "c9@s_pv",
+        "c9_c1s@mu",
+        "c9_c1s@ros",
+        "c9_c1s@ros_minus",
+        "c9_c1s@ros_one",
+        "c9_c1s@rp",
+        "c9_c1s@ru",
+        "c9_c1s@sp",
+        "c9_c2s@mu",
+        "c9_c2s@ros",
+        "c9_c2s@ros_minus",
+        "c9_c2s@ros_one",
+        "c9_c2s@rp",
+        "c9_c2s@ru",
+        "c9_c2s@sp",
+        "c9_l1s@mu",
+        "c9_l1s@ros",
+        "c9_l1s@ros_minus",
+        "c9_l1s@sp",
+        "c9_l2s@mu",
+        "c9_l2s@ros",
+        "c9_l2s@ros_minus",
+        "c9_l2s@sp",
+        "c9_lrs@1@title",
+        "c9_lrs@1@ts",
+        "c9_lrs@1@uv",
+        "c9_lrs@2@title",
+        "c9_lrs@2@ts",
+        "c9_lrs@2@uv",
+        "c9_lss@1@cnt",
+        "c9_lss@1@title",
+        "c9_lss@1@ts",
+        "c9_lss@2@cnt",
+        "c9_lss@2@title",
+        "c9_lss@2@ts",
+        "c9_mrs@1@title",
+        "c9_mrs@1@ts",
+        "c9_mrs@1@uv",
+        "c9_mrs@2@title",
+        "c9_mrs@2@ts",
+        "c9_mrs@2@uv",
+        "c9_mss@1@cnt",
+        "c9_mss@1@title",
+        "c9_mss@1@ts",
+        "c9_mss@2@cnt",
+        "c9_mss@2@title",
+        "c9_mss@2@ts",
+        "d1@ros_cf_rank",
+        "d1@ros_cf_score",
+        "d1@rov_cf_rank",
+        "d1@rov_cf_score",
+        "d2@rank",
+        "d2@score",
+        "d3@exp",
+        "d3@return_n",
+        "d3@rovn",
+        "h@bit_rate",
+        "h@total_time",
+        "h@ts",
+        "hour",
+        "hr_sim@cate2",
+        "hr_sim@cate2_list",
+        "hr_sim@keywords",
+        "hr_sim@title",
+        "r@bit_rate",
+        "r@total_time",
+        "r@ts"
+        ]
+      }
+    }
+  pai-eas-leave-config = {
+     scorer-name = "com.tzld.piaoquan.recommend.server.service.score.PAIScorer"
+     scorer-priority = 101
+     param = {
+       dnnConfig = {
+         "fgConfigFilePath": "zhaohaipeng/pai/config/fg/feature_list_20260424.json",
+         "easToken": "ZjgyMDgyOTRlZjZlN2QxNjNjN2VjNzdmNThlMGYxZjRlY2U2MTE0MA==",
+         "easEndpoint": "1894469520484605.vpc.cn-hangzhou.pai-eas.aliyuncs.com",
+         "modelName": "recsys_dnn_v3_20260424",
+         "fetchs":["probs_pLeave"]
+       }
+     }
+  }
+}