|
@@ -4,6 +4,7 @@
|
|
|
import json
|
|
|
import time
|
|
|
import asyncio
|
|
|
+import random
|
|
|
|
|
|
from typing import List, Dict
|
|
|
|
|
@@ -652,17 +653,19 @@ class NewContentIdTask(object):
|
|
|
"""
|
|
|
视频下载成功后,记录到audit表中
|
|
|
"""
|
|
|
+ audit_account = chr(random.randint(97, 106))
|
|
|
insert_sql = f"""
|
|
|
INSERT IGNORE INTO long_articles_title_audit
|
|
|
- (content_id, create_timestamp)
|
|
|
+ (content_id, create_timestamp, audit_account)
|
|
|
VALUES
|
|
|
- (%s, %s);
|
|
|
+ (%s, %s, %s);
|
|
|
"""
|
|
|
await self.long_articles_client.async_insert(
|
|
|
sql=insert_sql,
|
|
|
params=(
|
|
|
content_id,
|
|
|
- int(time.time() * 1000)
|
|
|
+ int(time.time() * 1000),
|
|
|
+ audit_account
|
|
|
)
|
|
|
)
|
|
|
|