clear log

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

@@ -58,10 +58,8 @@ public class RecallService implements ApplicationContextAware {
         CountDownLatch cdl = new CountDownLatch(strategies.size());
         List<Future<RecallResult.RecallData>> recallResultFutures = new ArrayList<>();
         for (final RecallStrategy strategy : strategies) {
-            log.info("supply flowpool strategy = {}", strategy.getClass().toString());
             Future<RecallResult.RecallData> future = pool.submit(() -> {
                 List<Video> result = strategy.recall(param);
-                log.info("supply flowpool strategy = {}, result = {}", strategy.getClass().toString(), result);
                 cdl.countDown();
                 return new RecallResult.RecallData(strategy.pushFrom(), result);
             });
@@ -183,7 +181,6 @@ public class RecallService implements ApplicationContextAware {
                 if (Objects.equals(Constant.SUPPLY_AB_CODE, abCode)) {
                     // 供给流量池策略 648 实验 random
                     strategies.add(strategyMap.get(FlowPoolWithLevelSupplyRecallStrategy.class.getSimpleName()));
-                    log.info("supply flowpool {}", abCode);
                 //2:通过“流量池标记”控制“流量池召回子策略” 其中有9组会走EXPERIMENTAL_FLOW_SET_LEVEL 有1组会走EXPERIMENTAL_FLOW_SET_LEVEL_SCORE
                 } else if ("60116".equals(abCode)) {
                     int lastDigit = param.getLastDigit();

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

@@ -40,7 +40,6 @@ public abstract class AbstractFlowPoolWithLevelRecallStrategy implements RecallS
         int getSize = param.getSize() * 5;
         List<Video> results = new ArrayList<>();
         List<String> data = redisTemplate.opsForSet().randomMembers(flowPoolKey, getSize);
-        log.info("supply flowpool flowPoolKey = {} level = {} data = {}", flowPoolKey, level, data);
         if (CollectionUtils.isEmpty(data)) {
             return null;
         }
@@ -49,9 +48,7 @@ public abstract class AbstractFlowPoolWithLevelRecallStrategy implements RecallS
             String[] values = value.split("-");
             videoFlowPoolMap.put(NumberUtils.toLong(values[0], 0), values[1]);
         }
-        log.info("supply flowpool videoFlowPoolMap = {}", videoFlowPoolMap);
         FilterResult filterResult = filterService.filter(FilterParamFactory.create(param, videoFlowPoolMap));
-        log.info("supply flowpool filterResult = {}", filterResult);
         if (filterResult != null && CollectionUtils.isNotEmpty(filterResult.getVideoIds())) {
             filterResult.getVideoIds().stream().forEach(vid -> {
                 Video recallData = new Video();

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

@@ -28,12 +28,10 @@ public class FlowPoolWithLevelSupplyRecallStrategy extends AbstractFlowPoolWithL
     Pair<String, String> flowPoolKeyAndLevel(RecallParam param) {
         //# 1. 获取流量池各层级分发概率权重
         Map<String, Double> levelWeightMap = flowPoolConfigService.getLevelWeight();
-        log.info("supply flowpool levelWeightMap = {}", levelWeightMap);
         // 2. 判断各层级是否有视频需分发
         List<LevelWeight> availableLevels = new ArrayList<>();
         for (Map.Entry<String, Double> entry : levelWeightMap.entrySet()) {
             String levelKey = String.format(KEY_WITH_LEVEL_SUPPLY_FORMAT, param.getAppType(), entry.getKey());
-            log.info("supply flowpool levelKey = {}", levelKey);
             if (redisTemplate.hasKey(levelKey)) {
                 LevelWeight lw = new LevelWeight();
                 lw.setLevel(entry.getKey());
@@ -42,7 +40,6 @@ public class FlowPoolWithLevelSupplyRecallStrategy extends AbstractFlowPoolWithL
                 availableLevels.add(lw);
             }
         }
-        log.info("supply flowpool availableLevels = {}", availableLevels);
         if (CollectionUtils.isEmpty(availableLevels)) {
             return Pair.of("", "");
         }
@@ -74,7 +71,6 @@ public class FlowPoolWithLevelSupplyRecallStrategy extends AbstractFlowPoolWithL
         for (Map.Entry<String, LevelP> entry : level_p_mapping.entrySet()) {
             if (random_p >= entry.getValue().getMin()
                     && random_p <= entry.getValue().getMax()) {
-                log.info("supply flowpool result {} {}", entry.getKey(), entry.getValue());
                 return Pair.of(entry.getValue().getLevelKey(), entry.getKey());
             }
         }