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

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

@@ -50,6 +50,8 @@ public class FlowPoolWithLevelFilterService extends AbstractFilterService {
                 remainVideoIds.add(videoId);
             }
         }
+        log.info("distribute count filter size before:{} after:{} equals:{}", videoIds.size(), remainVideoIds.size(),
+                videoIds.size() == remainVideoIds.size());
         return remainVideoIds;
     }
 }

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

@@ -92,21 +92,6 @@ public class FlowPoolService {
 
     }
 
-    private void asyncLocalDistributeCountWithLevelScore(Map<Long, String> videoFlowPoolMap) {
-        if (flowPoolUpgradeSwitch) {
-            asyncDelDistributeCountV2(videoFlowPoolMap, (appType, level, values) -> {
-                redisTemplate.opsForZSet().remove(String.format(KEY_WITH_LEVEL_SCORE_FORMAT_V2, appType, level), values);
-                redisTemplate.opsForZSet().remove(KEY_QUICK_WITH_LEVEL_SCORE_FORMAT_V2, values);
-            });
-        } else {
-            asyncDelDistributeCount(videoFlowPoolMap, (appType, level, values) -> {
-                String key = String.format(KEY_WITH_LEVEL_SCORE_FORMAT, appType, level);
-                redisTemplate.opsForZSet().remove(key, values);
-                redisTemplate.opsForZSet().remove(String.format(KEY_QUICK_WITH_LEVEL_SCORE_FORMAT, appType), values);
-            });
-        }
-    }
-
     private Map<Long, Integer> getDistributeCount(Map<Long, String> videoFlowPoolMap) {
         // 为了保证有序
         List<Map.Entry<Long, String>> entries = videoFlowPoolMap.entrySet().stream()