数据归档

src/main/java/com/adx/tencent/honor/model/HonorBidRecord.java

@@ -1,5 +1,7 @@
 package com.adx.tencent.honor.model;
 
+import com.adx.tencent.util.TraceIds;
+
 import java.time.Instant;
 import java.util.LinkedHashMap;
 import java.util.List;
@@ -32,7 +34,7 @@ public class HonorBidRecord {
     public String getMedia() { return media; }
     public void setMedia(String v) { this.media = v; }
     public String getMediaTraceId() { return mediaTraceId; }
-    public void setMediaTraceId(String v) { this.mediaTraceId = v; }
+    public void setMediaTraceId(String v) { this.mediaTraceId = TraceIds.normalize(v); }
     public String getPlatform() { return platform; }
     public void setPlatform(String v) { this.platform = v; }
     public String getAdId() { return adId; }

src/main/java/com/adx/tencent/honor/store/HonorColdStore.java

@@ -120,6 +120,7 @@ public class HonorColdStore {
 
     public void saveBid(HonorBidRecord record) {
         if (record.getCreatedAt() == null) record.setCreatedAt(Instant.now());
+        record.setMediaTraceId(record.getMediaTraceId());
         try (SqlSession session = sqlSessionFactory.openSession(true)) {
             HonorBidEventMapper mapper = session.getMapper(HonorBidEventMapper.class);
             mapper.insertOrUpdate(record.toColdRecord());

src/main/java/com/adx/tencent/kuaishou/model/KuaishouBidRecord.java

@@ -1,5 +1,6 @@
 package com.adx.tencent.kuaishou.model;
 
+import com.adx.tencent.util.TraceIds;
 import com.fasterxml.jackson.annotation.JsonInclude;
 
 import java.time.Instant;
@@ -38,7 +39,7 @@ public class KuaishouBidRecord {
     public String getMedia() { return media; }
     public void setMedia(String v) { this.media = v; }
     public String getMediaTraceId() { return mediaTraceId; }
-    public void setMediaTraceId(String v) { this.mediaTraceId = v; }
+    public void setMediaTraceId(String v) { this.mediaTraceId = TraceIds.normalize(v); }
     public String getPlatform() { return platform; }
     public void setPlatform(String v) { this.platform = v; }
     public String getAccountId() { return accountId; }

src/main/java/com/adx/tencent/kuaishou/store/KuaishouColdStore.java

@@ -122,6 +122,7 @@ public class KuaishouColdStore {
 
     public void saveBid(KuaishouBidRecord record) {
         if (record.getCreatedAt() == null) record.setCreatedAt(Instant.now());
+        record.setMediaTraceId(record.getMediaTraceId());
         try (SqlSession session = sqlSessionFactory.openSession(true)) {
             session.getMapper(KuaishouBidEventMapper.class).insertOrUpdate(record.toColdRecord());
         }

src/main/java/com/adx/tencent/storage/TiDBColdStore.java

@@ -206,6 +206,7 @@ public class TiDBColdStore {
             throw new IllegalArgumentException("qk is required");
         }
         if (record.getCreatedAt() == null) record.setCreatedAt(Instant.now());
+        record.setMediaTraceId(record.getMediaTraceId());
         BidRecord cold = record.toColdRecord();
 
         String mediaParams = toJson(cold.getMediaParams());

src/main/java/com/adx/tencent/storage/model/BidRecord.java

@@ -1,5 +1,6 @@
 package com.adx.tencent.storage.model;
 
+import com.adx.tencent.util.TraceIds;
 import com.fasterxml.jackson.annotation.JsonInclude;
 import com.fasterxml.jackson.annotation.JsonProperty;
 import java.time.Instant;
@@ -39,7 +40,7 @@ public class BidRecord {
     public String getMedia() { return media; }
     public void setMedia(String v) { this.media = v; }
     public String getMediaTraceId() { return mediaTraceId; }
-    public void setMediaTraceId(String v) { this.mediaTraceId = v; }
+    public void setMediaTraceId(String v) { this.mediaTraceId = TraceIds.normalize(v); }
     public String getPlatform() { return platform; }
     public void setPlatform(String v) { this.platform = v; }
     public String getAdId() { return adId; }