flowpool

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

@@ -642,9 +642,6 @@ public class RecommendService {
         }
 
         switch (param.getFlowPoolAbtestGroup()) {
-            case FlowPoolConstants.SUPPLY_FLOW_SET_LEVEL:
-                flowPoolService.updateSupplyDistributeCountWithLevel(flowPoolVideos);
-                break;
             case FlowPoolConstants.EXPERIMENTAL_FLOW_SET_LEVEL:
                 flowPoolService.updateDistributeCountWithLevel(flowPoolVideos);
                 break;

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

@@ -3,7 +3,6 @@ package com.tzld.piaoquan.recommend.server.service.flowpool;
 import com.tzld.piaoquan.recommend.server.model.TripleConsumer;
 import com.tzld.piaoquan.recommend.server.model.Video;
 import com.tzld.piaoquan.recommend.server.common.ThreadPoolFactory;
-import com.tzld.piaoquan.recommend.server.util.JSONUtils;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.collections4.MapUtils;
@@ -84,6 +83,11 @@ public class FlowPoolService {
             Long count = redisTemplate.opsForSet().remove(key, values);
             redisTemplate.opsForSet().remove(String.format(KEY_QUICK_WITH_LEVEL_FORMAT, appType), values);
         });
+
+        asyncDelDistributeCount(videoFlowPoolMap, (appType, level, values) -> {
+            redisTemplate.opsForSet().remove(KEY_WITH_LEVEL_FORMAT_V2, values);
+            redisTemplate.opsForSet().remove(KEY_QUICK_WITH_LEVEL_FORMAT_V2, values);
+        });
     }
 
     public Map<Long, Integer> getDistributeCountWithLevelScore(Map<Long, String> videoFlowPoolMap) {
@@ -119,6 +123,11 @@ public class FlowPoolService {
             redisTemplate.opsForZSet().remove(key, values);
             redisTemplate.opsForZSet().remove(String.format(KEY_QUICK_WITH_LEVEL_SCORE_FORMAT, appType), values);
         });
+
+        asyncDelDistributeCount(videoFlowPoolMap, (appType, level, values) -> {
+            redisTemplate.opsForZSet().remove(KEY_WITH_LEVEL_SCORE_FORMAT_V2, values);
+            redisTemplate.opsForZSet().remove(KEY_QUICK_WITH_LEVEL_SCORE_FORMAT_V2, values);
+        });
     }
 
     public Map<Long, Integer> getDistributeCountWithScore(Map<Long, String> videoFlowPoolMap) {
@@ -152,6 +161,11 @@ public class FlowPoolService {
 
             redisTemplate.opsForZSet().remove(String.format(KEY_QUICK_WITH_SCORE_FORMAT, appType), values);
         });
+
+        asyncDelDistributeCount(videoFlowPoolMap, (appType, level, values) -> {
+            redisTemplate.opsForZSet().remove(KEY_WITH_SCORE_FORMAT_V2, values);
+            redisTemplate.opsForZSet().remove(KEY_QUICK_WITH_SCORE_FORMAT_V2, values);
+        });
     }
 
     private Map<Long, Integer> getDistributeCount(Map<Long, String> videoFlowPoolMap) {