|  | @@ -3,6 +3,7 @@ package com.tzld.piaoquan.recommend.server.service.filter.strategy;
 | 
	
		
			
				|  |  |  import com.tzld.piaoquan.recommend.server.common.ThreadPoolFactory;
 | 
	
		
			
				|  |  |  import com.tzld.piaoquan.recommend.server.service.filter.FilterParam;
 | 
	
		
			
				|  |  |  import com.tzld.piaoquan.recommend.server.service.filter.FilterStrategy;
 | 
	
		
			
				|  |  | +import com.tzld.piaoquan.recommend.server.util.JSONUtils;
 | 
	
		
			
				|  |  |  import lombok.extern.slf4j.Slf4j;
 | 
	
		
			
				|  |  |  import org.apache.commons.collections4.CollectionUtils;
 | 
	
		
			
				|  |  |  import org.apache.commons.lang3.StringUtils;
 | 
	
	
		
			
				|  | @@ -46,6 +47,7 @@ public class ViewedStrategy implements FilterStrategy {
 | 
	
		
			
				|  |  |          }
 | 
	
		
			
				|  |  |          String key = String.format(keyFormat, user);
 | 
	
		
			
				|  |  |          Set<String> viewedVideoIds = redisTemplate.opsForSet().members(key);
 | 
	
		
			
				|  |  | +        log.info("viewed filter from redis key={} value={}", key, JSONUtils.toJson(viewedVideoIds));
 | 
	
		
			
				|  |  |          if (CollectionUtils.isEmpty(viewedVideoIds)) {
 | 
	
		
			
				|  |  |              // 从mongo取曝光数据
 | 
	
		
			
				|  |  |              Criteria criteria = new Criteria();
 | 
	
	
		
			
				|  | @@ -53,6 +55,7 @@ public class ViewedStrategy implements FilterStrategy {
 | 
	
		
			
				|  |  |              Query query = new Query();
 | 
	
		
			
				|  |  |              query.addCriteria(criteria);
 | 
	
		
			
				|  |  |              List<VideoView> list = mongoTemplate.find(query, VideoView.class);
 | 
	
		
			
				|  |  | +            log.info("viewed filter from mongo key={} value={}", key, JSONUtils.toJson(list));
 | 
	
		
			
				|  |  |              //TODO 为什么限制最多10000条?是不是限制近几天更合适?
 | 
	
		
			
				|  |  |              if (CollectionUtils.isNotEmpty(list)) {
 | 
	
		
			
				|  |  |                  int limit = 10000;
 |