新增字段，content_trace_id

server/api/record.py

@@ -11,6 +11,7 @@ class Record(object):
     """
 
     def __init__(self, params, mysql_client, config):
+        self.content_trace_id = None
         self.flow_pool_level = None
         self.content_id = None
         self.account_name = None
@@ -39,6 +40,7 @@ class Record(object):
             self.flow_pool_level = self.params['flowPoolLevelTag']
             self.publish_flag = self.params.get('publishFlag', 1)
             self.channel_content_id = self.params.get("channelContentId")
+            self.content_trace_id = self.params.get("contentTraceId")
             logging(
                 code="1001",
                 info="搜索视频内容接口请求成功, 参数校验成功",
@@ -71,9 +73,9 @@ class Record(object):
         request_time = int(time.time())
         insert_sql = f"""
             INSERT INTO {self.article_match_video_table}
-                (trace_id, content_id, flow_pool_level, gh_id, account_name, request_timestamp, publish_flag)
+                (trace_id, content_id, flow_pool_level, gh_id, account_name, request_timestamp, publish_flag, content_trace_id)
             VALUES 
-                (%s, %s, %s, %s, %s, %s, %s);
+                (%s, %s, %s, %s, %s, %s, %s, %s);
             """
         await self.mysql_client.async_insert(
             sql=insert_sql,
@@ -84,7 +86,8 @@ class Record(object):
                 self.gh_id,
                 self.account_name,
                 request_time,
-                self.publish_flag
+                self.publish_flag,
+                self.content_trace_id
             )
         )
         logging(