kafka修改dId

c72be8f4 · 宋新宇 · 44a5de00 · c72be8f4
Commit c72be8f4 authored Mar 18, 2024 by 宋新宇
Hide whitespace changes
Inline Side-by-side

Showing with 1 addition and 0 deletions

DyStoryUniversalProcess.java ...m/lwby/marketing/att/bystory/DyStoryUniversalProcess.java +1 -0

No files found.
--- a/src/main/java/com/lwby/marketing/att/bystory/DyStoryUniversalProcess.java
+++ b/src/main/java/com/lwby/marketing/att/bystory/DyStoryUniversalProcess.java
@@ -43,6 +43,7 @@ public class DyStoryUniversalProcess extends UniversalProcess {

        ddi.setIs_call(status.id);
        ddi.setUserId(action.getUserId());
+        ddi.setDevice_id(String.valueOf(action.getUserId()));
        ddi.setActive_time(System.currentTimeMillis());
        ddi.setChannel(String.valueOf(action.getChannelId()));
        ddi.setUserId(action.getUserId());