|
@@ -3,7 +3,6 @@ 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;
|
|
@@ -47,7 +46,6 @@ 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();
|
|
@@ -55,7 +53,6 @@ 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;
|