From 6d102f9e84e35c8b031f32feb1e51b0ce0906cf8 Mon Sep 17 00:00:00 2001
From: Franklin-F <dewujie64@gmail.com>
Date: Tue, 1 Jul 2025 19:39:27 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E7=A7=BB=E9=99=A4DB.py=E4=B8=AD?=
 =?UTF-8?q?=E7=9A=84=E5=86=97=E4=BD=99=E5=AD=97=E6=AE=B5=E5=B9=B6=E4=BC=98?=
 =?UTF-8?q?=E5=8C=96=E8=A7=86=E9=A2=91=E8=AE=B0=E5=BD=95=E5=AD=97=E6=AE=B5?=
 =?UTF-8?q?=E4=BF=9D=E7=95=99=E9=80=BB=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 DB.py | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)

diff --git a/DB.py b/DB.py
index aef23d4..57aea96 100644
--- a/DB.py
+++ b/DB.py
@@ -759,10 +759,13 @@ class DBSA:
                 "follow_number": data.get("fans", 0),
                 "video_number": data.get("videos", 0),
                 "is_repeat": 3,
-                # "is_piracy": data.get("is_piracy", 3),
                 "ts_status": data.get("ts_status", 1),
             }
 
+            # 仅保留 sh_dm_video_v3 表中存在的字段
+            video_fields = {c.name for c in video.columns}
+            vid_row = {k: v for k, v in vid_row.items() if k in video_fields}
+
             cls._buf_op.append(op_row)
             cls._buf_vid.append(vid_row)
             cls._buf_payload.append(data)
@@ -854,7 +857,6 @@ class DBSA:
                 upd = {
                     "title": stmt.inserted.title,
                     "link": stmt.inserted.link,
-                    # "is_piracy": stmt.inserted.is_piracy,
                     "edition": stmt.inserted.edition,
                     "duration": stmt.inserted.duration,
                     "watch_number": stmt.inserted.watch_number,
@@ -892,4 +894,4 @@ class DBSA:
                 if getattr(e.orig, "args", [None])[0] == 1213 and attempt < 2:
                     time.sleep(0.5 * (attempt + 1))
                     continue
-                raise
+                raise
\ No newline at end of file