短剧APP归因

src/main/java/com/lwby/marketing/att/videoapp/VideoAppBehavoirConsumer.java

@@ -38,27 +38,27 @@ public class VideoAppBehavoirConsumer {
 
         long begin = System.currentTimeMillis();
         if (VIDEO_SYS_LOG.isInfoEnabled()) {
-            VIDEO_SYS_LOG.info("media.active.onMessage start ,size = {}", datas.size());
+            VIDEO_SYS_LOG.info("media.behavoir.onMessage start ,size = {}", datas.size());
         }
 
 
         for (ConsumerRecord<String, String> data : datas) {
             try {
                 if (data == null) {
-                    VIDEO_SYS_LOG.warn("media.active.story.onMessage listen 消费数据为null");
+                    VIDEO_SYS_LOG.warn("media.behavoir.story.onMessage listen 消费数据为null");
                     return;
                 }
 
-                VIDEO_SYS_LOG.info("media.active.onMessage start, data={}", data == null ? null : data.value());
+                VIDEO_SYS_LOG.info("media.behavoir.onMessage start, data={}", data == null ? null : data.value());
 
                 StoreUserUploadEventBO event = JSON.parseObject(data.value(), StoreUserUploadEventBO.class);
-                VIDEO_SYS_LOG.info("media.active.topic={}, bookStoreEvent={}", data.topic(), JSON.toJSONString(event));
+                VIDEO_SYS_LOG.info("media.behavoir.topic={}, bookStoreEvent={}", data.topic(), JSON.toJSONString(event));
 
                 NovelAction action = new NovelAction(event.getClientInfo(), data.value(),event.getUserUploadEvent());
 
                 videoAppFlowExecutor.getExecutorByStory().execute(action);
             } catch (Throwable e) {
-                VIDEO_ERROR_LOG.info("media.active.onMessage failed, data={}, costTime={} ms", data.value(),
+                VIDEO_ERROR_LOG.info("media.behavoir.onMessage failed, data={}, costTime={} ms", data.value(),
                         System.currentTimeMillis() - begin, e);
             }
         }