Merge branch 'feature_20260417_zhaohaipeng_dnn_v2' of algorithm/recommend-server into master

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

@@ -136,7 +136,7 @@ public class RankStrategy4RegionMergeModelV562 extends RankStrategy4RegionMergeM
 
         // 4. 排序模型计算
         Map<String, Float> sceneFeatureMap = new HashMap<>(0);
-        List<RankItem> items = ScorerUtils.getScorerPipeline("feeds_score_config_xgb_ros_20250311.conf").scoring(sceneFeatureMap, userFeatureMap, rankItems);
+        List<RankItem> items = ScorerUtils.getScorerPipeline("feeds_score_config_dnn_20260407.conf").scoring(sceneFeatureMap, userFeatureMap, rankItems);
 
         // 5. 排序公式特征
         double xgbRovNegRate = mergeWeight.getOrDefault("xgbRovNegRate", 0.059);

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

@@ -136,7 +136,7 @@ public class RankStrategy4RegionMergeModelV563 extends RankStrategy4RegionMergeM
 
         // 4. 排序模型计算
         Map<String, Float> sceneFeatureMap = new HashMap<>(0);
-        List<RankItem> items = ScorerUtils.getScorerPipeline("feeds_score_config_xgb_ros_20250311.conf").scoring(sceneFeatureMap, userFeatureMap, rankItems);
+        List<RankItem> items = ScorerUtils.getScorerPipeline("feeds_score_config_dnn_20260407.conf").scoring(sceneFeatureMap, userFeatureMap, rankItems);
 
         // 5. 排序公式特征
         double xgbRovNegRate = mergeWeight.getOrDefault("xgbRovNegRate", 0.059);

recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/service/rank/strategy/RankStrategy4RegionMergeModelV564.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,24 @@ public class RankStrategy4RegionMergeModelV564 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);
         Map<String, Map<String, String>> featureOriginUser = feature.getUserFeature();
         Map<String, Map<String, Map<String, String>>> featureOriginVideo = feature.getVideoFeature();
@@ -104,34 +123,49 @@ public class RankStrategy4RegionMergeModelV564 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_20260116.conf").scoring(sceneFeatureMap, userFeatureMap, userFeatureMap, rankItems);
+        List<RankItem> items = ScorerUtils.getScorerPipeline("feeds_score_config_dnn_20260417.conf").scoring(sceneFeatureMap, userFeatureMap, rankItems);
 
         // 5. 排序公式特征
         double xgbRovNegRate = mergeWeight.getOrDefault("xgbRovNegRate", 0.059);
         double xgbNorPowerWeight = mergeWeight.getOrDefault("xgbNorPowerWeight", 1.22);
         double xgbNorPowerExp = mergeWeight.getOrDefault("xgbNorPowerExp", 1.15);
+
+        double rosAdd = mergeWeight.getOrDefault("ros_add", 0.1);
+        double rosW = mergeWeight.getOrDefault("ros_w", 1.0d);
+
+        double vorAdd = mergeWeight.getOrDefault("vor_add", 0.1d);
+        double vorW = mergeWeight.getOrDefault("vor_w", 1.0d);
+
+        double c1Rovn1hW = mergeWeight.getOrDefault("c1_rovn_1h_w", 0d);
+        double c1Rovn24hW = mergeWeight.getOrDefault("c1_rovn_24h_w", 0d);
+
+        double b0Str1hW = mergeWeight.getOrDefault("b0_str_1h_w", 0d);
+        double b0Str24hW = mergeWeight.getOrDefault("b0_str_24h_w", 0d);
+
+        double b0Ror1hW = mergeWeight.getOrDefault("b0_ror_1h_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, Double> cate2Coefficient = new HashMap<>();
-        double cate2CoefficientFunc = mergeWeight.getOrDefault("cate2CoefficientFunc", 0d);
-        if (cate2CoefficientFunc == 1d) {
-            String headVidStr = String.valueOf(param.getHeadVid());
-            String mergeCate2 = this.findVideoMergeCate2(videoBaseInfoMap, headVidStr);
-            Double length = mergeWeight.getOrDefault("cate2CoefficientLength", 10000d);
-            Map<String, Double> simCateScore = this.findSimCateScore(mergeCate2, length.intValue());
-            cate2Coefficient.putAll(simCateScore);
-        }
-        Double cate2CoefficientDenominator = mergeWeight.getOrDefault("cate2CoefficientDenominator", 1d);
-        Double statPowerExp = mergeWeight.getOrDefault("statPowerExp", 1.1d);
 
         Map<String, String> contextInfo = getContextInfo(param);
 
@@ -142,20 +176,71 @@ public class RankStrategy4RegionMergeModelV564 extends RankStrategy4RegionMergeM
             item.getScoresMap().put("fmRovOrigin", fmRovOrigin);
             double fmRov = restoreScore(fmRovOrigin, xgbRovNegRate);
             item.getScoresMap().put("fmRov", fmRov);
+
             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);
+
             double vor = Double.parseDouble(vid2MapFeature.getOrDefault(item.getVideoId() + "", new HashMap<>()).getOrDefault("vor", "0"));
             item.getScoresMap().put("vor", vor);
-
-            String vidMergeCate2 = this.findVideoMergeCate2(videoBaseInfoMap, String.valueOf(item.getVideoId()));
-            Double scoreCoefficient = cate2Coefficient.getOrDefault(vidMergeCate2, 0d);
-            item.getScoresMap().put("scoreCoefficient", scoreCoefficient);
-            item.getScoresMap().put("cate2CoefficientDenominator", cate2CoefficientDenominator);
-            item.getScoresMap().put("statPowerExp", statPowerExp);
-            // score = fmRov * (0.1 + hasReturnRovScore) * (0.1 + vor) * (1 + scoreCoefficient / cate2CoefficientDenominator);
-            score = fmRov * (0.1 + Math.pow(hasReturnRovScore, statPowerExp)) * (0.1 + vor) * (1 + scoreCoefficient / cate2CoefficientDenominator);
+            item.getScoresMap().put("vorAdd", vorAdd);
+            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> 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 c1Rovn24h = Double.parseDouble(bcData.getOrDefault("c1_rovn_24h", "0"));
+            double c1RovnScore = c1Rovn1hW * c1Rovn1h + c1Rovn24hW * c1Rovn24h;
+            item.getScoresMap().put("c1RovnScore", c1RovnScore);
+            item.getScoresMap().put("c1Rovn1hW", c1Rovn1hW);
+            item.getScoresMap().put("c1Rovn1h", c1Rovn1h);
+            item.getScoresMap().put("c1Rovn24hW", c1Rovn24hW);
+            item.getScoresMap().put("c1Rovn24h", c1Rovn24h);
+
+            double b0Str1h = Double.parseDouble(bcData.getOrDefault("b_str1_1h", "0"));
+            double b0Str24h = Double.parseDouble(bcData.getOrDefault("b_str1_24h", "0"));
+            double b0StrScore = b0Str1hW * b0Str1h + b0Str24hW * b0Str24h;
+            item.getScoresMap().put("b0StrScore", b0StrScore);
+            item.getScoresMap().put("b0Str1hW", b0Str1hW);
+            item.getScoresMap().put("b0Str1h", b0Str1h);
+            item.getScoresMap().put("b0Str24hW", b0Str24hW);
+            item.getScoresMap().put("b0Str24h", b0Str24h);
+
+
+            double b0Ror1h = Double.parseDouble(bcData.getOrDefault("b_ror1_1h", "0"));
+            double b0Ror24h = Double.parseDouble(bcData.getOrDefault("b_ror1_24h", "0"));
+            double b0RorScore = b0Ror1hW * b0Ror1h + b0Ror24hW * b0Ror24h;
+            item.getScoresMap().put("b0RorScore", b0RorScore);
+            item.getScoresMap().put("b0Ror1hW", b0Ror1hW);
+            item.getScoresMap().put("b0Ror1h", b0Ror1h);
+            item.getScoresMap().put("b0Ror24hW", b0Ror24hW);
+            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 * newNorDNNScore) * (vorAdd + vorW * vor) + c1RovnScore + b0StrScore + b0RorScore + cnRovnScore + dnRovnScore;
 
             Video video = item.getVideo();
             video.setScore(score);
@@ -189,7 +274,7 @@ public class RankStrategy4RegionMergeModelV564 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());
             }
@@ -276,15 +361,28 @@ public class RankStrategy4RegionMergeModelV564 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);
@@ -356,48 +454,4 @@ public class RankStrategy4RegionMergeModelV564 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/rank/strategy/RankStrategy4RegionMergeModelV568.java

@@ -117,7 +117,7 @@ public class RankStrategy4RegionMergeModelV568 extends RankStrategy4RegionMergeM
 
         // 4. 排序模型计算
         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_str_and_ros_20260319.conf").scoring(sceneFeatureMap, userFeatureMap, userFeatureMap, rankItems);
 
         // 5. 排序公式特征
         double xgbRovNegRate = mergeWeight.getOrDefault("xgbRovNegRate", 0.059);

recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/service/rank/tansform/FGEncoderManager.java

@@ -42,6 +42,7 @@ public class FGEncoderManager {
 
     public void registerAllFGEncoder() {
         this.registerFGEncoder("zhaohaipeng/pai/config/fg/feature_list_20260403.json");
+        this.registerFGEncoder("zhaohaipeng/pai/config/fg/feature_list_20260417.json");
     }
 
     public void registerFGEncoder(final String fgConfigJsonPath) {

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

@@ -0,0 +1,19 @@
+package com.tzld.piaoquan.recommend.server.service.score;
+
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+public class DnnConfigParam {
+
+    private String fgConfigFilePath;
+
+    private String easToken;
+
+    private String easEndpoint;
+
+    private String modelName;
+
+    private List<String> fetchs;
+}

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

@@ -1,5 +1,6 @@
 package com.tzld.piaoquan.recommend.server.service.score;
 
+import com.alibaba.fastjson.JSON;
 import com.google.common.collect.Lists;
 import com.tzld.piaoquan.recommend.feature.domain.video.base.UserFeature;
 import com.tzld.piaoquan.recommend.server.common.base.RankItem;
@@ -23,10 +24,15 @@ public class PAIScorer extends AbstractScorer {
     private final static Logger LOGGER = LoggerFactory.getLogger(PAIScorer.class);
     private static final ExecutorService executorService = Executors.newFixedThreadPool(128);
     private static final int BATCH_SIZE = 300;
-
+    private PAIModel model;
 
     public PAIScorer(ScorerConfigInfo scorerConfigInfo) {
         super(scorerConfigInfo);
+
+        // 初始化PAI Model
+        String dnnConfig = JSON.toJSONString(scorerConfigInfo.getParamMap().get("dnnConfig").unwrapped());
+        DnnConfigParam param = JSON.parseObject(dnnConfig, DnnConfigParam.class);
+        model = new PAIModel(param);
     }
 
     @Override
@@ -54,7 +60,7 @@ public class PAIScorer extends AbstractScorer {
         for (List<RankItem> items : partition) {
             futures.add(executorService.submit(() -> {
                 try {
-                    batchCallScore(PAIModel.getModelInstance(), items);
+                    batchCallScore(this.model, items);
                 } catch (Exception e) {
                     LOGGER.error("batchCallScore error ", e);
                 }
@@ -77,8 +83,8 @@ public class PAIScorer extends AbstractScorer {
     public void batchCallScore(final PAIModel model, final List<RankItem> rankItems) {
         try {
             Map<String, List<Float>> scoreMap = model.score(rankItems);
-            List<Float> returnNUvScoreList = scoreMap.get("y_return_n_uv");
-            List<Float> isShareScoreList = scoreMap.get("probs_is_share");
+            List<Float> returnNUvScoreList = scoreMap.getOrDefault("y_return_n_uv", Collections.nCopies(rankItems.size(), 0.0f));
+            List<Float> isShareScoreList = scoreMap.getOrDefault("probs_is_share", Collections.nCopies(rankItems.size(), 0.0f));
             for (int i = 0; i < rankItems.size(); i++) {
                 RankItem rankItem = rankItems.get(i);
                 Float ros = returnNUvScoreList.get(i);

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

@@ -35,11 +35,11 @@ public final class ScorerUtils {
         // ScorerUtils.init("feeds_score_config_20240609.conf");
         // ScorerUtils.init("feeds_score_config_20240807.conf");
         ScorerUtils.init("feeds_score_config_str_and_ros_20260319.conf");
-        ScorerUtils.init("feeds_score_config_fm_xgb_20250317.conf");
+        ScorerUtils.init("feeds_score_config_dnn_20260417.conf");
         ScorerUtils.init("feeds_score_config_fm_xgb_20250729.conf");
         ScorerUtils.init("feeds_score_config_fm_xgb_20260116.conf");
         ScorerUtils.init("feeds_score_config_fm_xgb_20260123.conf");
-        ScorerUtils.init("feeds_score_config_xgb_ros_20250311.conf");
+        ScorerUtils.init("feeds_score_config_dnn_20260407.conf");
 
         // 召回配置
         ScorerUtils.init4Recall("feeds_recall_config_region_v1.conf");

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

@@ -2,6 +2,7 @@ package com.tzld.piaoquan.recommend.server.service.score.model;
 
 import com.aliyun.openservices.eas.predict.http.HttpConfig;
 import com.aliyun.openservices.eas.predict.http.PredictClient;
+import com.aliyun.openservices.eas.predict.proto.PredictProtos;
 import com.aliyun.openservices.eas.predict.request.TFDataType;
 import com.aliyun.openservices.eas.predict.request.TFRequest;
 import com.aliyun.openservices.eas.predict.response.TFResponse;
@@ -9,9 +10,11 @@ import com.tzld.piaoquan.recommend.server.common.base.RankItem;
 import com.tzld.piaoquan.recommend.server.model.Tuple4;
 import com.tzld.piaoquan.recommend.server.service.rank.tansform.FGEncoder;
 import com.tzld.piaoquan.recommend.server.service.rank.tansform.FGEncoderManager;
+import com.tzld.piaoquan.recommend.server.service.score.DnnConfigParam;
 import org.apache.commons.lang3.math.NumberUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import org.springframework.util.Assert;
 
 import java.util.*;
 
@@ -23,33 +26,39 @@ public class PAIModel {
     private final String easToken;
     private final String easEndpoint;
     private final String modelName;
+    private final List<String> fetchs;
 
     private PredictClient predictClient;
-    private List<Tuple4<String, String, String, TFDataType>> featureKeys = new ArrayList<>();
+    private final List<Tuple4<String, String, String, TFDataType>> featureKeys = new ArrayList<>();
+
+    public PAIModel(DnnConfigParam param) {
+        this(param.getFgConfigFilePath(), param.getEasToken(), param.getEasEndpoint(), param.getModelName(), param.getFetchs());
+    }
+
+    public PAIModel(String fgConfigFilePath, String easToken, String easEndpoint, String modelName, List<String> fetchs) {
+        // this.fgConfigFilePath = "zhaohaipeng/pai/config/fg/feature_list_20260403.json";
+        // this.easToken = "MmEwYzVlZGFiOTM4YWM3ZTE5ZDMzNTgzY2Q5YjZlYjVjODE5ZjIzYQ==";
+        // this.easEndpoint = "1894469520484605.vpc.cn-hangzhou.pai-eas.aliyuncs.com";
+        // this.modelName = "recsys_dnn_v1_20260327";
+
+        Assert.hasText(fgConfigFilePath, "fgConfigFilePath must not be empty");
+        Assert.hasText(easToken, "easToken must not be empty");
+        Assert.hasText(easEndpoint, "easEndpoint must not be empty");
+        Assert.hasText(modelName, "modelName must not be empty");
+        Assert.notEmpty(fetchs, "fetch must not be empty");
+        Assert.noNullElements(fetchs, "fetch all item must not be empty");
 
-    private static volatile PAIModel MODEL;
 
-    private PAIModel() {
-        this.fgConfigFilePath = "zhaohaipeng/pai/config/fg/feature_list_20260403.json";
-        this.easToken = "MmEwYzVlZGFiOTM4YWM3ZTE5ZDMzNTgzY2Q5YjZlYjVjODE5ZjIzYQ==";
-        this.easEndpoint = "1894469520484605.vpc.cn-hangzhou.pai-eas.aliyuncs.com";
-        this.modelName = "recsys_dnn_v1_20260327";
+        this.fgConfigFilePath = fgConfigFilePath;
+        this.easToken = easToken;
+        this.easEndpoint = easEndpoint;
+        this.modelName = modelName;
+        this.fetchs = fetchs;
 
         this.parseFeatureKey();
         this.initPredictClient();
     }
 
-    public static PAIModel getModelInstance() {
-        if (MODEL == null) {
-            synchronized (PAIModel.class) {
-                if (MODEL == null) {
-                    MODEL = new PAIModel();
-                }
-            }
-        }
-        return MODEL;
-    }
-
     private void parseFeatureKey() {
         // 初始化fg key与特征生产时的key的映射
         FGEncoder fgEncoder = FGEncoderManager.getInstance().getFGEncoder(fgConfigFilePath);
@@ -74,7 +83,6 @@ public class PAIModel {
 
     public Map<String, List<Float>> score(List<RankItem> rankItems) {
 
-        List<String> scoreKeys = Arrays.asList("y_return_n_uv", "probs_is_share");
         int size = rankItems.size();
         String currentName = "";
         // 生成特征名与特征值数组的映射
@@ -126,20 +134,25 @@ public class PAIModel {
                     request.addFeed(featureName, TFDataType.DT_DOUBLE, shape, doubleFeatureArr.get(featureName));
                 }
             }
-            request.addFetch("y_return_n_uv");
-            request.addFetch("probs_is_share");
+
+            currentName = "";
+
+            for (String fetch : this.fetchs) {
+                request.addFetch(fetch);
+            }
+
             TFResponse response = predictClient.predict(request);
-            // Map<String, PredictProtos.ArrayProto> outputsMap = response.getOutputsMap();
+            Map<String, PredictProtos.ArrayProto> outputsMap = response.getOutputsMap();
             // LOGGER.info("response keys: {}", outputsMap.keySet());
             Map<String, List<Float>> resultMap = new HashMap<>();
-            for (String scoreKey : scoreKeys) {
+            for (String scoreKey : this.fetchs) {
                 resultMap.put(scoreKey, response.getFloatVals(scoreKey));
             }
             return resultMap;
         } catch (Exception e) {
             LOGGER.error("pai eas error currentName: {}", currentName, e);
             Map<String, List<Float>> resultMap = new HashMap<>();
-            for (String scoreKey : scoreKeys) {
+            for (String scoreKey : this.fetchs) {
                 resultMap.put(scoreKey, Collections.nCopies(size, 0.0f));
             }
             return resultMap;

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

@@ -0,0 +1,15 @@
+scorer-config = {
+  pai-eas-score-config = {
+     scorer-name = "com.tzld.piaoquan.recommend.server.service.score.PAIScorer"
+     scorer-priority = 100
+     param = {
+       dnnConfig = {
+         "fgConfigFilePath": "zhaohaipeng/pai/config/fg/feature_list_20260403.json",
+         "easToken": "MmEwYzVlZGFiOTM4YWM3ZTE5ZDMzNTgzY2Q5YjZlYjVjODE5ZjIzYQ==",
+         "easEndpoint": "1894469520484605.vpc.cn-hangzhou.pai-eas.aliyuncs.com",
+         "modelName": "recsys_dnn_v1_20260327",
+         "fetchs":["y_return_n_uv","probs_is_share"]
+       }
+     }
+  }
+}

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

@@ -0,0 +1,15 @@
+scorer-config = {
+  pai-eas-score-config = {
+     scorer-name = "com.tzld.piaoquan.recommend.server.service.score.PAIScorer"
+     scorer-priority = 100
+     param = {
+       dnnConfig = {
+         "fgConfigFilePath": "zhaohaipeng/pai/config/fg/feature_list_20260417.json",
+         "easToken": "YzhhMGY5OGYxNWUxNWNjNWIzNjgyOWYyZmFiMDAzNThlZTA3ODUwMA==",
+         "easEndpoint": "1894469520484605.vpc.cn-hangzhou.pai-eas.aliyuncs.com",
+         "modelName": "recsys_dnn_v2_20260417",
+         "fetchs":["probs_is_share"]
+       }
+     }
+  }
+}

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

@@ -1,449 +0,0 @@
-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_deconstruction_str.txt"
-  }
-  nor-score-config = {
-    scorer-name = "com.tzld.piaoquan.recommend.server.service.score.NorXGBRegressionScorer"
-    scorer-priority = 97
-    model-path = "zhangbo/model_xgb_for_recsys_v7_nor.tar.gz"
-    param = {
-      localDir = "xgboost/recsys_v7_nor"
-      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"
-      ]
-    }
-  }
-}

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

@@ -1,6 +0,0 @@
-scorer-config = {
-  pai-eas-score-config = {
-     scorer-name = "com.tzld.piaoquan.recommend.server.service.score.PAIScorer"
-     scorer-priority = 100
-  }
-}