ADD: filter 日志打印

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

@@ -11,12 +11,18 @@ import com.tzld.piaoquan.recommend.server.service.PreViewedService;
 import com.tzld.piaoquan.recommend.server.service.ServiceBeanFactory;
 import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.lang3.StringUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 import java.util.List;
+import java.util.Objects;
 import java.util.Set;
+import java.util.stream.Collectors;
 
 public class PreViewedFilter extends AbstractFilter<Video> {
 
+    private static final Logger LOGGER = LoggerFactory.getLogger(PreViewedFilter.class);
+
     private final PreViewedService preViewedService;
 
     public PreViewedFilter(FilterConfigInfo filterConfigInfo,
@@ -28,15 +34,24 @@ public class PreViewedFilter extends AbstractFilter<Video> {
 
     @Override
     public void doFilter(Candidate candidate, List<Video> list) {
+        LOGGER.info("PreViewedFilter doFilter start traceId:{}, user:{}, apptype:{}", requestContext.getRequestId(),
+                user, requestContext.getAppType());
         if (StringUtils.isBlank(user.getMid())
                 || CollectionUtils.isEmpty(list)) {
             return;
         }
         Set<Long> preViewedVideoIds = preViewedService.getVideoIds(this.requestContext.getAppType(), user.getMid());
+        LOGGER.info("PreViewedFilter doFilter traceId:{}, preViewedVideoIds:{}", requestContext.getRequestId(),
+                preViewedVideoIds);
+
         if (CollectionUtils.isEmpty(preViewedVideoIds)) {
             return;
         }
+        LOGGER.info("PreViewedFilter doFilter traceId:{}, list:{}", requestContext.getRequestId(),
+                list.stream().map(Video::getVideoId).map(Objects::toString).collect(Collectors.joining(",")));
         list.removeIf(video -> preViewedVideoIds.contains(video.getVideoId()));
+        LOGGER.info("PreViewedFilter doFilter end traceId:{}, list:{}", requestContext.getRequestId(),
+                list.stream().map(Video::getVideoId).map(Objects::toString).collect(Collectors.joining(",")));
     }
 
 

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

@@ -1,6 +1,7 @@
 package com.tzld.piaoquan.recommend.server.implement.recall;
 
 
+import com.alibaba.fastjson.JSONObject;
 import com.tzld.piaoquan.recommend.server.common.ThreadPoolFactory;
 import com.tzld.piaoquan.recommend.server.framework.candidiate.Candidate;
 import com.tzld.piaoquan.recommend.server.framework.common.User;
@@ -26,6 +27,7 @@ import java.util.HashSet;
 import java.util.List;
 import java.util.Set;
 import java.util.concurrent.TimeUnit;
+import java.util.stream.Collectors;
 
 public class ViewedHistoryFilter extends AbstractFilter<Video> {
 
@@ -51,12 +53,17 @@ public class ViewedHistoryFilter extends AbstractFilter<Video> {
     }
 
     @Override
-    public void doFilter(Candidate candidate, List<Video> t) {
-        if (CollectionUtils.isEmpty(t)) {
+    public void doFilter(Candidate candidate, List<Video> videoList) {
+        if (CollectionUtils.isEmpty(videoList)) {
             return;
         }
-
-        t.removeIf(video -> this.historySet.contains(String.valueOf(video.getVideoId())));
+        LOGGER.info("ViewedHistoryFilter doFilter start traceId:{}, user:{}, apptype:{}", requestContext.getRequestId(),
+                user, requestContext.getAppType());
+        LOGGER.info("ViewedHistoryFilter doFilter traceId:{}, historySet:{}", requestContext.getRequestId(),
+                JSONObject.toJSONString(historySet));
+        videoList.removeIf(video -> this.historySet.contains(String.valueOf(video.getVideoId())));
+        LOGGER.info("ViewedHistoryFilter doFilter end traceId:{}, list:{}", requestContext.getRequestId(),
+                videoList.stream().map(Video::getVideoId).map(Object::toString).collect(Collectors.joining(",")));
     }