rt log

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

@@ -135,6 +135,7 @@ public class RecommendService {
             updateCache(request, param, videos);
             long updateCacheTime = stopwatch.elapsed(TimeUnit.MILLISECONDS);
             timerLogMapTL.get().put("updateCacheTime", updateCacheTime);
+            timerLogService.log(timerLogMapTL.get());
             logStatisticsInfo(request, param, videos);
             // 更新position
             List<VideoProto> vps = new ArrayList<>();

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

@@ -42,14 +42,14 @@ public class TimerLogService {
         producer.putProjectConfig(new ProjectConfig(project, endpoint, accessKeyId, accessKeySecret));
     }
 
-    public void log(Map<String, String> data) {
+    public void log(Map<String, Long> data) {
         if (MapUtils.isEmpty(data)) {
             return;
         }
         try {
             LogItem logItem = new LogItem();
             data.entrySet().stream().forEach(e -> {
-                logItem.PushBack(e.getKey(), e.getValue());
+                logItem.PushBack(e.getKey(), e.getValue() + "");
             });
             producer.send(project, logStore, logItem);
         } catch (InterruptedException e) {

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

@@ -151,7 +151,6 @@ public class VideoRecommendService {
         } catch (Exception e) {
             log.error("traceId = {}, topRecommendVideoList error", request.getRequestId(), e);
         } finally {
-            ThreadPoolFactory.logPool().submit(() -> timerLogService.log(timeLogMap));
         }
         try {
             stopwatch.reset().start();