homepage recommend

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

@@ -17,6 +17,7 @@ public class RecommendParam {
     private String abCode;
     private String ruleKey;
     private String dataKey;
+    private int flowPoolId;
     private String flowPoolAbtestGroup;
     private String rankKeyPrefix;
     private int appType;

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

@@ -163,6 +163,7 @@ public class RecommendService {
         if (recallParam.getSize() < rankResult.getVideos().size()) {
             videos = rankResult.getVideos().subList(0, recallParam.getSize());
         }
+
         if (CollectionUtils.isNotEmpty(videos)) {
             Video lastVideo = videos.get(videos.size() - 1);
             log.info("update recall last video  lastVideo={}", JSONUtils.toJson(lastVideo));
@@ -196,6 +197,7 @@ public class RecommendService {
         Map<String, String> abExpCode = abExpCodeMap.get(abInitialConfig);
         param.setAbCode(abExpCode.get("ab_code"));
         param.setRuleKey(abExpCode.get("rule_key"));
+        param.setDataKey(abExpCode.get("data_key"));
         param.setRankKeyPrefix("rank:score1:");
 
         // 实验配置
@@ -246,6 +248,7 @@ public class RecommendService {
 
         // 流量池分发实验组划分
         int flowPoolIdChoice = flowPoolIds.get(RandomUtils.nextInt(0, flowPoolIds.size() - 1));
+        param.setFlowPoolId(flowPoolIdChoice);
         param.setFlowPoolAbtestGroup("control_group");
         Map<String, List<Integer>> flowPoolConfig = flowPoolConfigService.getFlowPoolConfig();
         for (Map.Entry<String, List<Integer>> entry : flowPoolConfig.entrySet()) {