|  | @@ -9,7 +9,6 @@ import com.tzld.piaoquan.recommend.server.service.ServiceBeanFactory;
 | 
	
		
			
				|  |  |  import com.tzld.piaoquan.recommend.server.service.ViewedService;
 | 
	
		
			
				|  |  |  import com.tzld.piaoquan.recommend.server.service.filter.strategy.*;
 | 
	
		
			
				|  |  |  import com.tzld.piaoquan.recommend.server.util.CommonCollectionUtils;
 | 
	
		
			
				|  |  | -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;
 | 
	
	
		
			
				|  | @@ -225,8 +224,6 @@ public abstract class AbstractFilterService {
 | 
	
		
			
				|  |  |          param.setVideoIds(riskVideoIds);
 | 
	
		
			
				|  |  |  
 | 
	
		
			
				|  |  |          List<FilterStrategy> strategies = getStrategies(param);
 | 
	
		
			
				|  |  | -        log.info("filter strategies {}", JSONUtils.toJson(CommonCollectionUtils.toList(strategies,
 | 
	
		
			
				|  |  | -                o -> o.getClass().getSimpleName())));
 | 
	
		
			
				|  |  |          CountDownLatch cdl = new CountDownLatch(strategies.size());
 | 
	
		
			
				|  |  |          List<Future<List<Long>>> futures = new ArrayList<>();
 | 
	
		
			
				|  |  |          for (final FilterStrategy strategy : strategies) {
 | 
	
	
		
			
				|  | @@ -234,10 +231,6 @@ public abstract class AbstractFilterService {
 | 
	
		
			
				|  |  |                  Stopwatch stopwatch = Stopwatch.createStarted();
 | 
	
		
			
				|  |  |                  List<Long> result = strategy.filter(param);
 | 
	
		
			
				|  |  |                  cdl.countDown();
 | 
	
		
			
				|  |  | -                log.info("{} param {} result {} cost {} ms", strategy.getClass().getSimpleName(),
 | 
	
		
			
				|  |  | -                        JSONUtils.toJson(param.getVideoIds()),
 | 
	
		
			
				|  |  | -                        JSONUtils.toJson(result),
 | 
	
		
			
				|  |  | -                        stopwatch.elapsed(TimeUnit.MILLISECONDS));
 | 
	
		
			
				|  |  |                  return result;
 | 
	
		
			
				|  |  |              });
 | 
	
		
			
				|  |  |              futures.add(future);
 | 
	
	
		
			
				|  | @@ -264,7 +257,6 @@ public abstract class AbstractFilterService {
 | 
	
		
			
				|  |  |          for (int i = 0; i < videoIds.size(); ++i) {
 | 
	
		
			
				|  |  |              result.retainAll(videoIds.get(i));
 | 
	
		
			
				|  |  |          }
 | 
	
		
			
				|  |  | -        log.info("filter result {}", JSONUtils.toJson(result));
 | 
	
		
			
				|  |  |          return result;
 | 
	
		
			
				|  |  |      }
 | 
	
		
			
				|  |  |  
 |