匹配成功后，将content_id

存储到audit_title表

tasks/new_contentId_task.py

@@ -644,6 +644,24 @@ class NewContentIdTask(object):
             )
             print(e)
 
+    async def record_for_audit(self, content_id):
+        """
+        视频下载成功后，记录到audit表中
+        """
+        insert_sql = f"""
+            INSERT IGNORE INTO long_articles_title_audit
+            (content_id, create_timestamp)
+            VALUES
+            (%s, %s);
+        """
+        await self.long_articles_client.async_insert(
+            sql=insert_sql,
+            params=(
+                content_id,
+                int(time.time() * 1000)
+            )
+        )
+
     async def start_process(self, params):
         """
         处理单篇文章
@@ -681,10 +699,9 @@ class NewContentIdTask(object):
                         info="etl_success",
                         trace_id=trace_id
                     )
-                    """
-                    todo 若新建计划，计划为设置托管，但接入账号又在配置账号中，仍会走托管逻辑，需考虑历史存量的处理
-                    目前先对这两种情况都做托管操作
-                    """
+                    # ETL下载成功，记录审核
+                    await self.record_for_audit(content_id)
+
                     if publish_flag == NewContentIdTaskConst.DO_NOT_NEED_PUBLISH:
                         logging(
                             code="3013",