|  | @@ -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()
 |