kali/DailyMotion
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: 修改视频数据插入逻辑以使用“is_piracy”字段并更新“is_repeat”字段的获取方式

Browse Source
This commit is contained in:
晓丰 2025-05-17 13:29:25 +08:00
parent 8239dde04c
commit e4ae20acb4
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
DB.py
View File

@ -161,7 +161,7 @@ class DBVidcon:
def upsert_video(self, data: dict): def upsert_video(self, data: dict):
data.setdefault("a_id", 0) data.setdefault("a_id", 0)
data.setdefault("history_status", "") data.setdefault("history_status", "")
data.setdefault("is_repeat", 3) data.setdefault("is_piracy", 3)
data["sort"] = data.get("index", 0) data["sort"] = data.get("index", 0)
max_retries = 1 # 除了第一次外，再重试一次 max_retries = 1 # 除了第一次外，再重试一次
@ -180,7 +180,7 @@ class DBVidcon:
self.cursor.execute(select_repeat, data) self.cursor.execute(select_repeat, data)
row = self.cursor.fetchone() row = self.cursor.fetchone()
if row: if row:
data['is_repeat'] = row[0] data['is_repeat'] = row.get('is_repeat', 3)
# 2) 插入到 op 表 # 2) 插入到 op 表
sql_op = """ sql_op = """
@ -228,6 +228,7 @@ class DBVidcon:
break # 成功跳出重试循环 break # 成功跳出重试循环
except Exception as e: except Exception as e:
# 回滚这次未提交的改动 # 回滚这次未提交的改动
self.conn.rollback() self.conn.rollback()
print("[数据库写入异常]", str(e)) print("[数据库写入异常]", str(e))