diff --git a/content.py b/content.py index 2ff76a5..0d0f061 100644 --- a/content.py +++ b/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" \ No newline at end of file +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("未匹配到任何子字符串") \ No newline at end of file diff --git a/dm.py b/dm.py index 5fee0f2..52dedf0 100644 --- a/dm.py +++ b/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