|
@@ -8,6 +8,7 @@ import com.tzld.piaoquan.recommend.server.service.filter.FilterStrategy;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
import org.apache.commons.collections.CollectionUtils;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
+import org.springframework.beans.factory.annotation.Qualifier;
|
|
|
import org.springframework.data.redis.core.RedisTemplate;
|
|
|
import org.springframework.stereotype.Component;
|
|
|
|
|
@@ -24,7 +25,8 @@ public class VovLowerStrategy implements FilterStrategy {
|
|
|
private Map<String, Double> vovFilterCondition;
|
|
|
|
|
|
@Autowired
|
|
|
- private RedisTemplate<String, String> redisTemplate;
|
|
|
+ @Qualifier("longVideoRedisTemplate")
|
|
|
+ private RedisTemplate<String, String> longVideoRedisTemplate;
|
|
|
|
|
|
private static final String KEY_FORMAT = "video:vov:%s";
|
|
|
|
|
@@ -42,7 +44,7 @@ public class VovLowerStrategy implements FilterStrategy {
|
|
|
List<String> redisKeys = videoIds.stream()
|
|
|
.map(r -> String.format(KEY_FORMAT, r))
|
|
|
.collect(Collectors.toList());
|
|
|
- List<String> vovInfos = redisTemplate.opsForValue().multiGet(redisKeys);
|
|
|
+ List<String> vovInfos = longVideoRedisTemplate.opsForValue().multiGet(redisKeys);
|
|
|
if (CollectionUtils.isEmpty(vovInfos) || vovInfos.size() != videoIds.size()) {
|
|
|
log.info("VOV过滤 -- 获取到的视频VOV信息为空或长度与videoIds长度不一致,跳过: {}, {}", videoIds.size(), vovInfos.size());
|
|
|
return result;
|