Some scripts.

content.py

@@ -1,3 +1,43 @@
+import aiohttp
 
 base_url = "https://dm.video.qq.com/barrage/base/"
-dm_url = "https://dm.video.qq.com/barrage/segment/p0047eb164c/t/v1/0/30000"
+dm_url = "https://dm.video.qq.com/barrage/segment/p0047eb164c/t/v1/0/30000"
+
+
+async def getTxVideoData(url, video_id):
+    url = "https://example.com/api/data.json"  # 替换成你要请求的JSON数据的URL
+    json_data = await fetch_json(url)
+    if json_data:
+        # 在这里处理解析后的JSON数据
+        print(json_data)
+
+async def fetch_json(url):
+    async with aiohttp.ClientSession() as session:
+        async with session.get(url) as response:
+            if response.status == 200:
+                data = await response.json()
+                return data
+            else:
+                print(f"Failed to fetch data. Status code: {response.status}")
+                return None
+
+if __name__ == "__main__":
+
+    url = "https://v.qq.com/x/cover/mzc00200pppnnhl/p0047eb164c.html"
+    if "v.qq.com" in url:
+        # 调用 v.qq.com 对应的接口
+        await getTxVideoData(url, "p0047eb164c")
+
+    # 检查是否存在 "rainss.cn"
+    elif "rainss.cn" in url:
+        # 调用 rainss.cn 对应的接口
+        print("调用 rainss.cn 的接口")
+
+    # 检查是否存在 "allms.cn"
+    elif "allms.cn" in url:
+        # 调用 allms.cn 对应的接口
+        print("调用 allms.cn 的接口")
+
+    # 如果都不匹配
+    else:
+        print("未匹配到任何子字符串")

dm.py

@@ -250,19 +250,36 @@ class TableWidgetExample(QMainWindow):
         self.table.setItem(row, 1, item)
 
     def get_video_dm_data(self, url):
-        # 判断url类型
-
         md5_hash = hashlib.md5()
         md5_hash.update(url.encode('utf-8'))
         encrypted_text = md5_hash.hexdigest()
 
         # 取出MD5加密后的后20位数
         last_20_chars = encrypted_text[-20:]
-
-        # 创建新的字符串，加上空格P
         video_id = last_20_chars + " P"
+        # 弹幕池id
         self.logger.debug("video_id: %s", video_id)
 
+        # 检查是否存在 "v.qq.com"
+        if "v.qq.com" in url:
+            # 调用 v.qq.com 对应的接口
+            print("调用 v.qq.com 的接口")
+
+        # 检查是否存在 "rainss.cn"
+        elif "rainss.cn" in url:
+            # 调用 rainss.cn 对应的接口
+            print("调用 rainss.cn 的接口")
+
+        # 检查是否存在 "allms.cn"
+        elif "allms.cn" in url:
+            # 调用 allms.cn 对应的接口
+            print("调用 allms.cn 的接口")
+
+        # 如果都不匹配
+        else:
+            print("未匹配到任何子字符串")
+
+
     def generate_insert_sql(self, data):
         sql = "INSERT INTO `danmaku_list` (`id`, `cid`, `type`, `text`, `color`, `size`, `videotime`, `ip`, `time`) VALUES ('de9d5e3f5b7f9ea2197d35f383530643', NULL, 'right', '不错哦', '#FFFFFF', '27.5px', '48.275', '58.62.32.191', '1666319003')"
         return sql