ADD: filter 日志打印

recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/framework/recaller/FilterPipeline.java

@@ -9,7 +9,6 @@ import org.slf4j.LoggerFactory;
 
 import java.util.ArrayList;
 import java.util.List;
-import java.util.stream.Collectors;
 
 
 public class FilterPipeline<T> {
@@ -55,13 +54,11 @@ public class FilterPipeline<T> {
     }
 
     public List<T> doFilter(Candidate candidate, List<T> list) {
-        LOGGER.info("FilterPipeline doFilter start traceId:{}, before list:{}", requestContext.getRequestId(),
-                list.stream().map(Object::toString).collect(Collectors.joining(",")));
+        LOGGER.info("FilterPipeline doFilter start traceId:{}, before list size:{}", requestContext.getRequestId(), list.size());
         for (AbstractFilter filter : filters) {
             filter.doFilter(candidate, list);
         }
-        LOGGER.info("FilterPipeline doFilter end traceId:{}, after list:{}", requestContext.getRequestId(),
-                list.stream().map(Object::toString).collect(Collectors.joining(",")));
+        LOGGER.info("FilterPipeline doFilter end traceId:{}, after list size:{}", requestContext.getRequestId(), list.size());
         return list;
     }
 }

recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/implement/recall/ViewedHistoryFilter.java

@@ -70,10 +70,10 @@ public class ViewedHistoryFilter extends AbstractFilter<Video> {
     public Set<String> loadUserHistory(User user) {
         String userid = StringUtils.isNotBlank(user.getUid()) ? user.getUid() : user.getMid();
         if (StringUtils.isBlank(userid)) {
-            return new HashSet<String>();
+            return new HashSet<>();
         }
 
-        String key = String.format(keyFormat, user.getMid());
+        String key = String.format(keyFormat, userid);
         Set<String> viewedVideoIds = redisTemplate.opsForSet().members(key);
         if (CollectionUtils.isEmpty(viewedVideoIds)) {
             // 从mongo取曝光数据