log score

recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/service/RecommendService.java

@@ -160,43 +160,48 @@ public class RecommendService {
             return;
         }
 
-        List<Map<String, String>> data = videos.stream().map(v -> {
-            Map<String, String> map = new HashMap<>();
+        try {
+            List<Map<String, String>> data = videos.stream().map(v -> {
+                Map<String, String> map = new HashMap<>();
 
-            map.put("traceId", String.valueOf(TraceUtils.currentTraceId()));
+                map.put("traceId", String.valueOf(TraceUtils.currentTraceId()));
 
-            // TODO user
-            map.put("sessionId", String.valueOf(request.getSessionId()));
-            map.put("subsessionid", String.valueOf(request.getSubSessionId()));
-            map.put("mid", param.getMid());
+                // TODO user
+                map.put("sessionId", String.valueOf(request.getSessionId()));
+                map.put("subsessionid", String.valueOf(request.getSubSessionId()));
+                map.put("mid", param.getMid());
 
-            // scene
-            map.put("pagesource", String.valueOf(request.getPageSource()));
+                // scene
+                map.put("newexpgroup", String.valueOf(request.getNewExpGroup()));
 
-            // ab
+                // ab
+                map.put("pagesource", String.valueOf(request.getPageSource()));
 
+                // video
+                map.put("videoId", String.valueOf(v.getVideoId()));
+                map.put("relevantVideoId", String.valueOf(request.getVideoId()));
+                map.put("rovScore", String.valueOf(v.getRovScore()));
+                map.put("sortScore", String.valueOf(v.getSortScore()));
+                map.put("pushFrom", String.valueOf(v.getPushFrom()));
 
-            // video
-            map.put("videoId", String.valueOf(v.getVideoId()));
-            map.put("rovScore", String.valueOf(v.getRovScore()));
-            map.put("sortScore", String.valueOf(v.getSortScore()));
-            map.put("pushFrom", String.valueOf(v.getPushFrom()));
+                map.put("flowPool", String.valueOf(v.getFlowPool()));
+                map.put("level", String.valueOf(v.getLevel()));
+                map.put("flowPoolAbtestGroup", String.valueOf(v.getFlowPoolAbtestGroup()));
+                map.put("inFlowPool", String.valueOf(v.isInFlowPool()));
 
-            map.put("flowPool", String.valueOf(v.getFlowPool()));
-            map.put("level", String.valueOf(v.getLevel()));
-            map.put("flowPoolAbtestGroup", String.valueOf(v.getFlowPoolAbtestGroup()));
-            map.put("inFlowPool", String.valueOf(v.isInFlowPool()));
+                map.put("scoreRos", String.valueOf(v.getScoreRos()));
+                map.put("scoreStr", String.valueOf(v.getScoreStr()));
+                map.put("score", String.valueOf(v.getScore()));
+                map.put("scoresMap", JSONUtils.toJson(String.valueOf(v.getScoresMap())));
 
-            map.put("scoreRos", String.valueOf(v.getScoreRos()));
-            map.put("scoreStr", String.valueOf(v.getScoreStr()));
-            map.put("score", String.valueOf(v.getScore()));
-            map.put("scoresMap", JSONUtils.toJson(String.valueOf(v.getScoresMap())));
+                return map;
 
-            return map;
+            }).collect(Collectors.toList());
 
-        }).collect(Collectors.toList());
-
-        statisticsLogService.log(data);
+            statisticsLogService.log(data);
+        } catch (Exception e) {
+            log.error("logStatisticsInfo error", e);
+        }
     }
 
     private RecommendResponse specialMidRecommend(RecommendRequest request) {