add log

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

@@ -347,9 +347,11 @@ public class RecommendService {
         int flowPoolIdChoice = flowPoolIds.get(RandomUtils.nextInt(0, flowPoolIds.size()));
         Map<String, List<Integer>> flowPoolConfig = flowPoolConfigService.getFlowPoolConfig();
         Set<String> abExpCodes = param.getAbExpCodes();
+        log.info("supply flowpool 1 flowPoolIdChoice = {} abExpCodes = {}", flowPoolIdChoice,abExpCodes);
         if (Objects.nonNull(abExpCodes) && abExpCodes.contains(Constant.SUPPLY_AB_CODE_ID)) {
 //        if (Objects.equals(Constant.SUPPLY_AB_CODE, param.getAbCode())) {
             List<Integer> supplyFlowPoolIdList = flowPoolConfig.get(FlowPoolConstants.SUPPLY_FLOW_SET_LEVEL);
+            log.info("supply flowpool 1 supplyFlowPoolIdList = {}", supplyFlowPoolIdList);
             if (Objects.nonNull(supplyFlowPoolIdList) && !supplyFlowPoolIdList.isEmpty()) {
                 flowPoolIdChoice = supplyFlowPoolIdList.get(0);
                 param.setFlowPoolId(flowPoolIdChoice);
@@ -364,7 +366,7 @@ public class RecommendService {
                 }
             }
         }
-
+        log.info("supply flowpool 2 flowPoolIdChoice = {} abExpCodes = {}", flowPoolIdChoice,abExpCodes);
         // @desc 新的流量池分发实验组划分，每个尾号不同策略分组。 @time 20240318 @author 张博
         int lastDigit = RandomUtils.nextInt(0, 10);
         param.setLastDigit(lastDigit);

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

@@ -45,13 +45,14 @@ public class FlowPoolWithLevelFilterService extends AbstractFilterService {
         Map<Long, Integer> distributeCountMap;
         //供给流量池实验
         Set<String> abExpCodes = param.getAbExpCodes();
+        log.info("supply flowpool abExpCodes = {}", abExpCodes);
         if (Objects.nonNull(abExpCodes) && abExpCodes.contains(Constant.SUPPLY_AB_CODE_ID)) {
 //        if (Objects.equals(Constant.SUPPLY_AB_CODE, param.getAbCode())) {
             distributeCountMap = flowPoolService.getSupplyDistributeCountWithLevel(flowPoolMap);
         } else {
             distributeCountMap = flowPoolService.getDistributeCountWithLevel(flowPoolMap);
         }
-
+        log.info("supply flowpool distributeCountMap = {}", distributeCountMap);
 //        Map<Long, Integer> distributeCountMap = flowPoolService.getDistributeCountWithLevel(flowPoolMap);
 
         List<Long> remainVideoIds = new ArrayList<>();

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

@@ -173,9 +173,11 @@ public class RecallService implements ApplicationContextAware {
         // 命中用户黑名单不走流量池
         if (!hitUserBlacklist || !isInBlacklist) {
             Set<String> abExpCodes = param.getAbExpCodes();
+            log.info("supply flowpool abExpCodes = {}", abExpCodes);
             if (Objects.nonNull(abExpCodes) && abExpCodes.contains(Constant.SUPPLY_AB_CODE_ID)) {
 //            if (Objects.equals(Constant.SUPPLY_AB_CODE, abCode)) {
                 // 供给流量池策略 648 实验 random
+                log.info("supply flowpool 648 = {}", Constant.SUPPLY_AB_CODE_ID);
                 strategies.add(strategyMap.get(FlowPoolWithLevelSupplyRecallStrategy.class.getSimpleName()));
                 //2:通过“流量池标记”控制“流量池召回子策略” 其中有9组会走EXPERIMENTAL_FLOW_SET_LEVEL 有1组会走EXPERIMENTAL_FLOW_SET_LEVEL_SCORE
             } else if ("60116".equals(abCode)) {