From 5ba453fad72b59cd677814007f724d0d699e8c4d Mon Sep 17 00:00:00 2001
From: Franklin-F <dewujie64@gmail.com>
Date: Tue, 20 May 2025 21:35:17 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E6=B7=BB=E5=8A=A0=20fetch=5Fkeyword=5F?=
 =?UTF-8?q?title=20=E6=96=B9=E6=B3=95=E4=BB=A5=E6=94=AF=E6=8C=81=E5=85=B3?=
 =?UTF-8?q?=E9=94=AE=E8=AF=8D=E6=A0=87=E9=A2=98=E7=9A=84=E6=95=B0=E6=8D=AE?=
 =?UTF-8?q?=E5=BA=93=E6=9F=A5=E8=AF=A2?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 DB.py | 24 ++++++++++++++++++++++++
 1 file changed, 24 insertions(+)

diff --git a/DB.py b/DB.py
index 2513e8c..2c3feda 100644
--- a/DB.py
+++ b/DB.py
@@ -264,6 +264,30 @@ class DBVidcon:
                     print("[交由Redis处理]")
                     break
 
+    @mysql_retry()
+    def fetch_keyword_title(self, level: int = 99):
+        sql = """
+        SELECT
+            k.keyword,
+            k.rn,
+            t.title            AS v_name,
+            ANY_VALUE(t.level) AS level
+        FROM
+            sh_dm_keyword k
+        LEFT JOIN
+            sh_dm_title  t ON k.title = t.title
+        WHERE
+            k.status = 1
+            AND t.status = 1
+            AND NOT EXISTS (
+                SELECT 1 FROM sh_dm_black_keyword b WHERE b.title = t.title
+            )
+            AND t.level = %s
+        GROUP BY k.keyword, k.rn
+        """
+        self.cursor.execute(sql, (level,))
+        return self.cursor.fetchall()
+
     @mysql_retry()
     def flush(self):
         """批量执行完后手动提交。"""