更新源 202602030246

py/剧王短剧.py

@@ -0,0 +1,329 @@
+# coding=utf-8
+# !/usr/bin/python
+
+"""
+
+作者 丢丢喵推荐 🚓 内容均从互联网收集而来 仅供交流学习使用 版权归原创者所有 如侵犯了您的权益 请通知作者 将及时删除侵权内容
+                    ====================Diudiumiao====================
+
+"""
+
+from Crypto.Util.Padding import unpad
+from Crypto.Util.Padding import pad
+from urllib.parse import unquote
+from Crypto.Cipher import ARC4
+from urllib.parse import quote
+from base.spider import Spider
+from Crypto.Cipher import AES
+from datetime import datetime
+from bs4 import BeautifulSoup
+from base64 import b64decode
+import urllib.request
+import urllib.parse
+import datetime
+import binascii
+import requests
+import base64
+import json
+import time
+import sys
+import re
+import os
+
+sys.path.append('..')
+
+xurl = "https://djw1.com"
+
+headerx = {
+    'User-Agent': 'Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/50.0.2661.87 Safari/537.36'
+          }
+
+class Spider(Spider):
+    global xurl
+    global headerx
+
+    def getName(self):
+        return "首页"
+
+    def init(self, extend):
+        pass
+
+    def isVideoFormat(self, url):
+        pass
+
+    def manualVideoCheck(self):
+        pass
+
+    def extract_middle_text(self, text, start_str, end_str, pl, start_index1: str = '', end_index2: str = ''):
+        if pl == 3:
+            plx = []
+            while True:
+                start_index = text.find(start_str)
+                if start_index == -1:
+                    break
+                end_index = text.find(end_str, start_index + len(start_str))
+                if end_index == -1:
+                    break
+                middle_text = text[start_index + len(start_str):end_index]
+                plx.append(middle_text)
+                text = text.replace(start_str + middle_text + end_str, '')
+            if len(plx) > 0:
+                purl = ''
+                for i in range(len(plx)):
+                    matches = re.findall(start_index1, plx[i])
+                    output = ""
+                    for match in matches:
+                        match3 = re.search(r'(?:^|[^0-9])(\d+)(?:[^0-9]|$)', match[1])
+                        if match3:
+                            number = match3.group(1)
+                        else:
+                            number = 0
+                        if 'http' not in match[0]:
+                            output += f"#{match[1]}${number}{xurl}{match[0]}"
+                        else:
+                            output += f"#{match[1]}${number}{match[0]}"
+                    output = output[1:]
+                    purl = purl + output + "$$$"
+                purl = purl[:-3]
+                return purl
+            else:
+                return ""
+        else:
+            start_index = text.find(start_str)
+            if start_index == -1:
+                return ""
+            end_index = text.find(end_str, start_index + len(start_str))
+            if end_index == -1:
+                return ""
+
+        if pl == 0:
+            middle_text = text[start_index + len(start_str):end_index]
+            return middle_text.replace("\\", "")
+
+        if pl == 1:
+            middle_text = text[start_index + len(start_str):end_index]
+            matches = re.findall(start_index1, middle_text)
+            if matches:
+                jg = ' '.join(matches)
+                return jg
+
+        if pl == 2:
+            middle_text = text[start_index + len(start_str):end_index]
+            matches = re.findall(start_index1, middle_text)
+            if matches:
+                new_list = [f'{item}' for item in matches]
+                jg = '$$$'.join(new_list)
+                return jg
+
+    def homeContent(self, filter):
+        result = {"class": []}
+
+        detail = requests.get(url=xurl + "/all/", headers=headerx)
+        detail.encoding = "utf-8"
+        res = detail.text
+
+        doc = BeautifulSoup(res, "lxml")
+
+        soups = doc.find_all('section', class_="container items")
+
+        for soup in soups:
+            vods = soup.find_all('li')
+
+            for vod in vods:
+
+                id = vod.find('a')['href']
+
+                name = vod.text.strip()
+
+                result["class"].append({"type_id": id, "type_name": "" + name})
+
+        return result
+
+    def homeVideoContent(self):
+        pass
+
+    def categoryContent(self, cid, pg, filter, ext):
+        result = {}
+        videos = []
+
+        if pg:
+            page = int(pg)
+        else:
+            page = 1
+
+        url = f'{cid}page/{str(page)}/'
+        detail = requests.get(url=url, headers=headerx)
+        detail.encoding = "utf-8"
+        res = detail.text
+        doc = BeautifulSoup(res, "lxml")
+
+        soups = doc.find_all('section', class_="container items")
+
+        for soup in soups:
+            vods = soup.find_all('li')
+
+            for vod in vods:
+
+                name = vod.find('img')['alt']
+
+                ids = vod.find('a', class_="image-line")
+                id = ids['href']
+
+                pic = vod.find('img')['src']
+
+                remark = self.extract_middle_text(str(vod), 'class="remarks light">', '<', 0)
+
+                video = {
+                    "vod_id": id,
+                    "vod_name": name,
+                    "vod_pic": pic,
+                    "vod_remarks": '▶️' + remark
+                        }
+                videos.append(video)
+
+        result = {'list': videos}
+        result['page'] = pg
+        result['pagecount'] = 9999
+        result['limit'] = 90
+        result['total'] = 999999
+        return result
+
+    def detailContent(self, ids):
+        did = ids[0]
+        result = {}
+        videos = []
+        xianlu = ''
+        bofang = ''
+
+        if 'http' not in did:
+            did = xurl + did
+
+        res = requests.get(url=did, headers=headerx)
+        res.encoding = "utf-8"
+        res = res.text
+        doc = BeautifulSoup(res, "lxml")
+
+        url = 'https://fs-im-kefu.7moor-fs1.com/ly/4d2c3f00-7d4c-11e5-af15-41bf63ae4ea0/1732707176882/jiduo.txt'
+        response = requests.get(url)
+        response.encoding = 'utf-8'
+        code = response.text
+        name = self.extract_middle_text(code, "s1='", "'", 0)
+        Jumps = self.extract_middle_text(code, "s2='", "'", 0)
+
+        content = self.extract_middle_text(res,'class="info-detail">','<', 0)
+
+        remarks = self.extract_middle_text(res, 'class="info-mark">', '<', 0)
+
+        year = self.extract_middle_text(res, 'class="info-addtime">', '<', 0)
+
+        if name not in content:
+            bofang = Jumps
+            xianlu = '1'
+        else:
+            soups = doc.find('div', class_="ep-list-items")
+
+            soup = soups.find_all('a')
+
+            for sou in soup:
+
+                id = sou['href']
+
+                name = sou.text.strip()
+
+                bofang = bofang + name + '$' + id + '#'
+
+            bofang = bofang[:-1]
+
+            xianlu = '专线'
+
+        videos.append({
+            "vod_id": did,
+            "vod_remarks": remarks,
+            "vod_year": year,
+            "vod_content": content,
+            "vod_play_from": xianlu,
+            "vod_play_url": bofang
+                     })
+
+        result['list'] = videos
+        return result
+
+    def playerContent(self, flag, id, vipFlags):
+
+        res = requests.get(url=id, headers=headerx)
+        res.encoding = "utf-8"
+        res = res.text
+
+        url = self.extract_middle_text(res, '"wwm3u8":"', '"', 0).replace('\\', '')
+
+        result = {}
+        result["parse"] = 0
+        result["playUrl"] = ''
+        result["url"] = url
+        result["header"] = headerx
+        return result
+
+    def searchContentPage(self, key, quick, pg):
+        result = {}
+        videos = []
+
+        if pg:
+            page = int(pg)
+        else:
+            page = 1
+
+        url = f'{xurl}/search/{key}/page/{str(page)}/'
+        detail = requests.get(url=url, headers=headerx)
+        detail.encoding = "utf-8"
+        res = detail.text
+        doc = BeautifulSoup(res, "lxml")
+
+        soups = doc.find_all('section', class_="container items")
+
+        for soup in soups:
+            vods = soup.find_all('li')
+
+            for vod in vods:
+
+                name = vod.find('img')['alt']
+
+                ids = vod.find('a', class_="image-line")
+                id = ids['href']
+
+                pic = vod.find('img')['src']
+
+                remark = self.extract_middle_text(str(vod), 'class="remarks light">', '<', 0)
+
+                video = {
+                    "vod_id": id,
+                    "vod_name": name,
+                    "vod_pic": pic,
+                    "vod_remarks": '▶️' + remark
+                        }
+                videos.append(video)
+
+        result['list'] = videos
+        result['page'] = pg
+        result['pagecount'] = 9999
+        result['limit'] = 90
+        result['total'] = 999999
+        return result
+
+    def searchContent(self, key, quick, pg="1"):
+        return self.searchContentPage(key, quick, '1')
+
+    def localProxy(self, params):
+        if params['type'] == "m3u8":
+            return self.proxyM3u8(params)
+        elif params['type'] == "media":
+            return self.proxyMedia(params)
+        elif params['type'] == "ts":
+            return self.proxyTs(params)
+        return None
+
+
+
+
+
+
+

py/哔哩直播.py

@@ -0,0 +1,314 @@
+# coding=utf-8
+# !/usr/bin/python
+
+"""
+
+作者 丢丢喵 🚓 内容均从互联网收集而来 仅供交流学习使用 版权归原创者所有 如侵犯了您的权益 请通知作者 将及时删除侵权内容
+                    ====================Diudiumiao====================
+
+"""
+
+from Crypto.Util.Padding import unpad
+from Crypto.Util.Padding import pad
+from urllib.parse import unquote
+from Crypto.Cipher import ARC4
+from urllib.parse import quote
+from base.spider import Spider
+from Crypto.Cipher import AES
+from datetime import datetime
+from bs4 import BeautifulSoup
+from base64 import b64decode
+import urllib.request
+import urllib.parse
+import datetime
+import binascii
+import requests
+import base64
+import json
+import time
+import sys
+import re
+import os
+
+sys.path.append('..')
+
+xurl = "https://search.bilibili.com"
+
+xurl1 = "https://api.live.bilibili.com"
+
+headerx = {
+    'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/129.0.0.0 Safari/537.36 Edg/129.0.0.0'
+          }
+
+class Spider(Spider):
+    global xurl
+    global xurl1
+    global headerx
+
+    def getName(self):
+        return "首页"
+
+    def init(self, extend):
+        pass
+
+    def isVideoFormat(self, url):
+        pass
+
+    def manualVideoCheck(self):
+        pass
+
+    def extract_middle_text(self, text, start_str, end_str, pl, start_index1: str = '', end_index2: str = ''):
+        if pl == 3:
+            plx = []
+            while True:
+                start_index = text.find(start_str)
+                if start_index == -1:
+                    break
+                end_index = text.find(end_str, start_index + len(start_str))
+                if end_index == -1:
+                    break
+                middle_text = text[start_index + len(start_str):end_index]
+                plx.append(middle_text)
+                text = text.replace(start_str + middle_text + end_str, '')
+            if len(plx) > 0:
+                purl = ''
+                for i in range(len(plx)):
+                    matches = re.findall(start_index1, plx[i])
+                    output = ""
+                    for match in matches:
+                        match3 = re.search(r'(?:^|[^0-9])(\d+)(?:[^0-9]|$)', match[1])
+                        if match3:
+                            number = match3.group(1)
+                        else:
+                            number = 0
+                        if 'http' not in match[0]:
+                            output += f"#{match[1]}${number}{xurl}{match[0]}"
+                        else:
+                            output += f"#{match[1]}${number}{match[0]}"
+                    output = output[1:]
+                    purl = purl + output + "$$$"
+                purl = purl[:-3]
+                return purl
+            else:
+                return ""
+        else:
+            start_index = text.find(start_str)
+            if start_index == -1:
+                return ""
+            end_index = text.find(end_str, start_index + len(start_str))
+            if end_index == -1:
+                return ""
+
+        if pl == 0:
+            middle_text = text[start_index + len(start_str):end_index]
+            return middle_text.replace("\\", "")
+
+        if pl == 1:
+            middle_text = text[start_index + len(start_str):end_index]
+            matches = re.findall(start_index1, middle_text)
+            if matches:
+                jg = ' '.join(matches)
+                return jg
+
+        if pl == 2:
+            middle_text = text[start_index + len(start_str):end_index]
+            matches = re.findall(start_index1, middle_text)
+            if matches:
+                new_list = [f'{item}' for item in matches]
+                jg = '$$$'.join(new_list)
+                return jg
+
+    def homeContent(self, filter):
+        result = {}
+        result = {"class": [{"type_id": "舞", "type_name": "舞蹈"},
+                            {"type_id": "音乐", "type_name": "音乐"},
+                            {"type_id": "手游", "type_name": "手游"},
+                            {"type_id": "网游", "type_name": "网游"},
+                            {"type_id": "单机游戏", "type_name": "单机游戏"},
+                            {"type_id": "虚拟主播", "type_name": "虚拟主播"},
+                            {"type_id": "电台", "type_name": "电台"},
+                            {"type_id": "体育", "type_name": "体育"},
+                            {"type_id": "聊天", "type_name": "聊天"},
+                            {"type_id": "娱乐", "type_name": "娱乐"},
+                            {"type_id": "电影", "type_name": "影视"},
+                            {"type_id": "新闻", "type_name": "新闻"}]
+                 }
+
+        return result
+
+    def homeVideoContent(self):
+        pass
+
+    def categoryContent(self, cid, pg, filter, ext):
+        result = {}
+        videos = []
+
+        if pg:
+            page = int(pg)
+        else:
+            page = 1
+
+        url = f'{xurl}/live?keyword={cid}&page={str(page)}'
+        detail = requests.get(url=url, headers=headerx)
+        detail.encoding = "utf-8"
+        res = detail.text
+        doc = BeautifulSoup(res, "lxml")
+
+        soups = doc.find_all('div', class_="video-list-item")
+
+        for vod in soups:
+
+            names = vod.find('h3', class_="bili-live-card__info--tit")
+            name = names.text.strip().replace('直播中', '')
+
+            id = names.find('a')['href']
+            id = self.extract_middle_text(id, 'bilibili.com/', '?', 0)
+
+            pic = vod.find('img')['src']
+            if 'http' not in pic:
+                pic = "https:" + pic
+
+            remarks = vod.find('a', class_="bili-live-card__info--uname")
+            remark = remarks.text.strip()
+
+            video = {
+                "vod_id": id,
+                "vod_name": name,
+                "vod_pic": pic,
+                "vod_remarks": remark
+                    }
+            videos.append(video)
+
+        result = {'list': videos}
+        result['page'] = pg
+        result['pagecount'] = 9999
+        result['limit'] = 90
+        result['total'] = 999999
+        return result
+
+    def detailContent(self, ids):
+        did = ids[0]
+        result = {}
+        videos = []
+        xianlu = ''
+        bofang = ''
+
+        url = f'{xurl1}/xlive/web-room/v2/index/getRoomPlayInfo?room_id={did}&platform=web&protocol=0,1&format=0,1,2&codec=0,1'
+        detail = requests.get(url=url, headers=headerx)
+        detail.encoding = "utf-8"
+        data = detail.json()
+
+        content = '欢迎观看哔哩直播'
+
+        setup = data['data']['playurl_info']['playurl']['stream']
+
+        nam = 0
+
+        for vod in setup:
+
+            try:
+                host = vod['format'][nam]['codec'][0]['url_info'][1]['host']
+            except (KeyError, IndexError):
+                continue
+
+            base = vod['format'][nam]['codec'][0]['base_url']
+
+            extra = vod['format'][nam]['codec'][0]['url_info'][1]['extra']
+
+            id = host + base + extra
+
+            nam = nam + 1
+
+            namc = f"{nam}号线路"
+
+            bofang = bofang + namc + '$' + id + '#'
+
+        bofang = bofang[:-1]
+
+        xianlu = '哔哩专线'
+
+        videos.append({
+            "vod_id": did,
+            "vod_content": content,
+            "vod_play_from": xianlu,
+            "vod_play_url": bofang
+                     })
+
+        result['list'] = videos
+        return result
+
+    def playerContent(self, flag, id, vipFlags):
+
+        result = {}
+        result["parse"] = 0
+        result["playUrl"] = ''
+        result["url"] = id
+        result["header"] = headerx
+        return result
+
+    def searchContentPage(self, key, quick, pg):
+        result = {}
+        videos = []
+
+        if pg:
+            page = int(pg)
+        else:
+            page = 1
+
+        url = f'{xurl}/live?keyword={key}&page={str(page)}'
+        detail = requests.get(url=url, headers=headerx)
+        detail.encoding = "utf-8"
+        res = detail.text
+        doc = BeautifulSoup(res, "lxml")
+
+        soups = doc.find_all('div', class_="video-list-item")
+
+        for vod in soups:
+
+            names = vod.find('h3', class_="bili-live-card__info--tit")
+            name = names.text.strip().replace('直播中', '')
+
+            id = names.find('a')['href']
+            id = self.extract_middle_text(id, 'bilibili.com/', '?', 0)
+
+            pic = vod.find('img')['src']
+            if 'http' not in pic:
+                pic = "https:" + pic
+
+            remarks = vod.find('a', class_="bili-live-card__info--uname")
+            remark = remarks.text.strip()
+
+            video = {
+                "vod_id": id,
+                "vod_name": name,
+                "vod_pic": pic,
+                "vod_remarks": remark
+                    }
+            videos.append(video)
+
+        result['list'] = videos
+        result['page'] = pg
+        result['pagecount'] = 9999
+        result['limit'] = 90
+        result['total'] = 999999
+        return result
+
+    def searchContent(self, key, quick, pg="1"):
+        return self.searchContentPage(key, quick, '1')
+
+    def localProxy(self, params):
+        if params['type'] == "m3u8":
+            return self.proxyM3u8(params)
+        elif params['type'] == "media":
+            return self.proxyMedia(params)
+        elif params['type'] == "ts":
+            return self.proxyTs(params)
+        return None
+
+
+
+
+
+
+
+

py/星芽短剧.py

@@ -0,0 +1,343 @@
+# coding = utf-8
+# !/usr/bin/python
+
+"""
+"""
+
+from Crypto.Util.Padding import unpad
+from Crypto.Util.Padding import pad
+from urllib.parse import unquote
+from Crypto.Cipher import ARC4
+from urllib.parse import quote
+from base.spider import Spider
+from Crypto.Cipher import AES
+from bs4 import BeautifulSoup
+from base64 import b64decode
+import urllib.request
+import urllib.parse
+import binascii
+import requests
+import base64
+import json
+import time
+import sys
+import re
+import os
+
+sys.path.append('..')
+
+xurl = "https://app.whjzjx.cn"
+
+headers = {
+    'User-Agent': 'Linux; Android 12; Pixel 3 XL) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/98.0.4758.101 Mobile Safari/537.36'
+          }
+
+headerf = {
+    "platform": "1",
+    "user_agent": "Mozilla/5.0 (Linux; Android 9; V1938T Build/PQ3A.190705.08211809; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/91.0.4472.114 Safari/537.36",
+    "content-type": "application/json; charset=utf-8"
+          }
+
+times = int(time.time() * 1000)
+
+data = {
+    "device": "2a50580e69d38388c94c93605241fb306",
+    "package_name": "com.jz.xydj",
+    "android_id": "ec1280db12795506",
+    "install_first_open": True,
+    "first_install_time": 1752505243345,
+    "last_update_time": 1752505243345,
+    "report_link_url": "",
+    "authorization": "",
+    "timestamp": times
+        }
+
+plain_text = json.dumps(data, separators=(',', ':'), ensure_ascii=False)
+
+key = "B@ecf920Od8A4df7"
+key_bytes = key.encode('utf-8')
+plain_bytes = plain_text.encode('utf-8')
+cipher = AES.new(key_bytes, AES.MODE_ECB)
+padded_data = pad(plain_bytes, AES.block_size)
+ciphertext = cipher.encrypt(padded_data)
+encrypted = base64.b64encode(ciphertext).decode('utf-8')
+
+response = requests.post("https://u.shytkjgs.com/user/v3/account/login", headers=headerf, data=encrypted)
+response_data = response.json()
+Authorization = response_data['data']['token']
+
+headerx = {
+    'authorization': Authorization,
+    'platform': '1',
+    'version_name': '3.8.3.1'
+          }
+
+class Spider(Spider):
+    global xurl
+    global headerx
+    global headers
+
+    def getName(self):
+        return "首页"
+
+    def init(self, extend):
+        pass
+
+    def isVideoFormat(self, url):
+        pass
+
+    def manualVideoCheck(self):
+        pass
+
+    def extract_middle_text(self, text, start_str, end_str, pl, start_index1: str = '', end_index2: str = ''):
+        if pl == 3:
+            plx = []
+            while True:
+                start_index = text.find(start_str)
+                if start_index == -1:
+                    break
+                end_index = text.find(end_str, start_index + len(start_str))
+                if end_index == -1:
+                    break
+                middle_text = text[start_index + len(start_str):end_index]
+                plx.append(middle_text)
+                text = text.replace(start_str + middle_text + end_str, '')
+            if len(plx) > 0:
+                purl = ''
+                for i in range(len(plx)):
+                    matches = re.findall(start_index1, plx[i])
+                    output = ""
+                    for match in matches:
+                        match3 = re.search(r'(?:^|[^0-9])(\d+)(?:[^0-9]|$)', match[1])
+                        if match3:
+                            number = match3.group(1)
+                        else:
+                            number = 0
+                        if 'http' not in match[0]:
+                            output += f"#{match[1]}${number}{xurl}{match[0]}"
+                        else:
+                            output += f"#{match[1]}${number}{match[0]}"
+                    output = output[1:]
+                    purl = purl + output + "$$$"
+                purl = purl[:-3]
+                return purl
+            else:
+                return ""
+        else:
+            start_index = text.find(start_str)
+            if start_index == -1:
+                return ""
+            end_index = text.find(end_str, start_index + len(start_str))
+            if end_index == -1:
+                return ""
+
+        if pl == 0:
+            middle_text = text[start_index + len(start_str):end_index]
+            return middle_text.replace("\\", "")
+
+        if pl == 1:
+            middle_text = text[start_index + len(start_str):end_index]
+            matches = re.findall(start_index1, middle_text)
+            if matches:
+                jg = ' '.join(matches)
+                return jg
+
+        if pl == 2:
+            middle_text = text[start_index + len(start_str):end_index]
+            matches = re.findall(start_index1, middle_text)
+            if matches:
+                new_list = [f'{item}' for item in matches]
+                jg = '$$$'.join(new_list)
+                return jg
+
+    def homeContent(self, filter):
+        result = {}
+        result = {"class": [{"type_id": "1", "type_name": "剧场"},
+                            {"type_id": "3", "type_name": "新剧"},
+                            {"type_id": "2", "type_name": "热播"},
+                            {"type_id": "7", "type_name": "星选"},
+                            {"type_id": "5", "type_name": "阳光"}],
+                  }
+
+        return result
+
+    def homeVideoContent(self):
+        videos = []
+
+        url= f'{xurl}/v1/theater/home_page?theater_class_id=1&class2_id=4&page_num=1&page_size=24'
+        detail = requests.get(url=url, headers=headerx)
+        detail.encoding = "utf-8"
+        if detail.status_code == 200:
+            data = detail.json()
+
+            for vod in data['data']['list']:
+
+                name = vod['theater']['title']
+
+                id = vod['theater']['id']
+
+                pic = vod['theater']['cover_url']
+
+                remark = vod['theater']['play_amount_str']
+
+                video = {
+                    "vod_id": id,
+                    "vod_name": name,
+                    "vod_pic": pic,
+                    "vod_remarks": remark
+                        }
+                videos.append(video)
+
+        result = {'list': videos}
+        return result
+
+    def categoryContent(self, cid, pg, filter, ext):
+        result = {}
+        videos = []
+
+        url = f'{xurl}/v1/theater/home_page?theater_class_id={cid}&page_num={pg}&page_size=24'
+        detail = requests.get(url=url,headers=headerx)
+        detail.encoding = "utf-8"
+        if detail.status_code == 200:
+            data = detail.json()
+
+            for vod in data['data']['list']:
+
+                name = vod['theater']['title']
+
+                id = vod['theater']['id']
+
+                pic = vod['theater']['cover_url']
+
+                remark = vod['theater']['theme']
+
+                video = {
+                    "vod_id": id,
+                    "vod_name": name,
+                    "vod_pic": pic,
+                    "vod_remarks": remark
+                        }
+                videos.append(video)
+
+        result = {'list': videos}
+        result['page'] = pg
+        result['pagecount'] = 9999
+        result['limit'] = 90
+        result['total'] = 999999
+        return result
+
+    def detailContent(self, ids):
+        did = ids[0]
+        result = {}
+        videos = []
+        xianlu = ''
+        bofang = ''
+
+        url = f'{xurl}/v2/theater_parent/detail?theater_parent_id={did}'
+        detail = requests.get(url=url, headers=headerx)
+        detail.encoding = "utf-8"
+        if detail.status_code == 200:
+            data = detail.json()
+
+        url = 'https://fs-im-kefu.7moor-fs1.com/ly/4d2c3f00-7d4c-11e5-af15-41bf63ae4ea0/1732707176882/jiduo.txt'
+        response = requests.get(url)
+        response.encoding = 'utf-8'
+        code = response.text
+        name = self.extract_middle_text(code, "s1='", "'", 0)
+        Jumps = self.extract_middle_text(code, "s2='", "'", 0)
+
+        content = '剧情：' + data['data']['introduction']
+
+        area = data['data']['desc_tags'][0]
+
+        remarks = data['data']['filing']
+
+        # 修复剧集只有一集的问题 - 检查theaters数据是否存在且不为空
+        if 'theaters' in data['data'] and data['data']['theaters']:
+            for sou in data['data']['theaters']:
+                id = sou['son_video_url']
+                name = sou['num']
+                bofang = bofang + str(name) + '$' + id + '#'
+
+            bofang = bofang[:-1] if bofang.endswith('#') else bofang
+            xianlu = '星芽'
+        else:
+            # 如果没有theaters数据，检查是否有单个视频URL
+            if 'video_url' in data['data'] and data['data']['video_url']:
+                bofang = '1$' + data['data']['video_url']
+                xianlu = '星芽'
+            else:
+                bofang = Jumps
+                xianlu = '1'
+
+        videos.append({
+            "vod_id": did,
+            "vod_content": content,
+            "vod_remarks": remarks,
+            "vod_area": area,
+            "vod_play_from": xianlu,
+            "vod_play_url": bofang
+                     })
+
+        result['list'] = videos
+        return result
+
+    def playerContent(self, flag, id, vipFlags):
+
+        result = {}
+        result["parse"] = 0
+        result["playUrl"] = ''
+        result["url"] = id
+        result["header"] = headers
+        return result
+
+    def searchContentPage(self, key, quick, page):
+        result = {}
+        videos = []
+
+        payload = {
+            "text": key
+                  }
+
+        url = f"{xurl}/v3/search"
+        detail = requests.post(url=url, headers=headerx, json=payload)
+        if detail.status_code == 200:
+            detail.encoding = "utf-8"
+            data = detail.json()
+
+            for vod in data['data']['theater']['search_data']:
+
+                name = vod['title']
+
+                id = vod['id']
+
+                pic = vod['cover_url']
+
+                remark = vod['score_str']
+
+                video = {
+                    "vod_id": id,
+                    "vod_name": name,
+                    "vod_pic": pic,
+                    "vod_remarks": remark
+                        }
+                videos.append(video)
+
+        result['list'] = videos
+        result['page'] = page
+        result['pagecount'] = 9999
+        result['limit'] = 90
+        result['total'] = 999999
+        return result
+
+    def searchContent(self, key, quick, pg="1"):
+        return self.searchContentPage(key, quick, '1')
+
+    def localProxy(self, params):
+        if params['type'] == "m3u8":
+            return self.proxyM3u8(params)
+        elif params['type'] == "media":
+            return self.proxyMedia(params)
+        elif params['type'] == "ts":
+            return self.proxyTs(params)
+        return None

py/爱听音乐.py

@@ -0,0 +1,240 @@
+import re
+import sys
+from base64 import b64encode, b64decode
+from urllib.parse import quote, unquote
+from pyquery import PyQuery as pq
+from requests import Session, adapters
+from urllib3.util.retry import Retry
+from concurrent.futures import ThreadPoolExecutor, as_completed
+sys.path.append('..')
+from base.spider import Spider
+
+class Spider(Spider):
+    def init(self, extend=""):
+        self.host = "https://www.22a5.com"
+        self.session = Session()
+        adapter = adapters.HTTPAdapter(max_retries=Retry(total=3, backoff_factor=0.5, status_forcelist=[429, 500, 502, 503, 504]), pool_connections=20, pool_maxsize=50)
+        self.session.mount("http://", adapter)
+        self.session.mount("https://", adapter)
+        self.headers = {"User-Agent": "Mozilla/5.0 (Linux; Android 10; K) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Mobile Safari/537.36"}
+        self.session.headers.update(self.headers)
+
+    def getName(self): return "爱听音乐"
+    def isVideoFormat(self, url): return bool(re.search(r'\.(m3u8|mp4|mp3|m4a|flv)(\?|$)', url or "", re.I))
+    def manualVideoCheck(self): return False
+    def destroy(self): self.session.close()
+
+    def homeContent(self, filter):
+        classes = [{"type_name": n, "type_id": i} for n, i in [("歌手","/singerlist/index/index/index/index.html"), ("TOP榜单","/list/top.html"), ("新歌榜","/list/new.html"), ("电台","/radiolist/index.html"), ("高清MV","/mvlist/oumei.html"), ("专辑","/albumlist/index.html"), ("歌单","/playtype/index.html")]]
+        filters = {p: d for p in [c["type_id"] for c in classes if "singer" not in c["type_id"]] if (d := self._fetch_filters(p))}
+        
+        if "/radiolist/index.html" not in filters:
+            filters["/radiolist/index.html"] = [{"key": "id", "name": "分类", "value": [{"n": n, "v": v} for n,v in zip(["最新","最热","有声小说","相声","音乐","情感","国漫","影视","脱口秀","历史","儿童","教育","八卦","推理","头条"], ["index","hot","novel","xiangyi","music","emotion","game","yingshi","talkshow","history","children","education","gossip","tuili","headline"])]}]
+
+        filters["/singerlist/index/index/index/index.html"] = [
+            {"key": "area", "name": "地区", "value": [{"n": n, "v": v} for n,v in [("全部","index"),("华语","huayu"),("欧美","oumei"),("韩国","hanguo"),("日本","ribrn")]]},
+            {"key": "sex", "name": "性别", "value": [{"n": n, "v": v} for n,v in [("全部","index"),("男","male"),("女","girl"),("组合","band")]]},
+            {"key": "genre", "name": "流派", "value": [{"n": n, "v": v} for n,v in [("全部","index"),("流行","liuxing"),("电子","dianzi"),("摇滚","yaogun"),("嘻哈","xiha"),("R&B","rb"),("民谣","minyao"),("爵士","jueshi"),("古典","gudian")]]},
+            {"key": "char", "name": "字母", "value": [{"n": n, "v": v} for n,v in [("全部","index")] + [{"n": chr(i), "v": chr(i).lower()} for i in range(65, 91)]]}
+        ]
+        return {"class": classes, "filters": filters, "list": []}
+
+    def homeVideoContent(self): return {"list": []}
+
+    def categoryContent(self, tid, pg, filter, extend):
+        pg = int(pg or 1)
+        url = tid
+        if "/singerlist/" in tid:
+            p = tid.split('/')
+            if len(p) >= 6:
+                url = "/".join(p[:2] + [extend.get(k, p[i]) for i, k in enumerate(["area", "sex", "genre"], 2)] + [f"{extend.get('char', 'index')}.html"])
+        elif "id" in extend and extend["id"] not in ["index", "top"]:
+            url = tid.replace("index.html", f"{extend['id']}.html").replace("top.html", f"{extend['id']}.html")
+            if url == tid: url = f"{tid.rsplit('/', 1)[0]}/{extend['id']}.html"
+
+        if pg > 1:
+            sep = "/" if any(x in url for x in ["/singerlist/", "/radiolist/", "/mvlist/", "/playtype/", "/list/"]) else "_"
+            url = re.sub(r'(_\d+|/\d+)?\.html$', f'{sep}{pg}.html', url)
+        
+        doc = self.getpq(url)
+        return {"list": self._parse_list(doc(".play_list li, .video_list li, .pic_list li, .singer_list li, .ali li, .layui-row li, .base_l li"), tid), "page": pg, "pagecount": 9999, "limit": 90, "total": 999999}
+
+    def searchContent(self, key, quick, pg="1"):
+        return {"list": self._parse_list(self.getpq(f"/so/{quote(key)}/{pg}.html")(".base_l li, .play_list li"), "search"), "page": int(pg)}
+
+    def detailContent(self, ids):
+        url = self._abs(ids[0])
+        doc = self.getpq(url)
+        vod = {"vod_id": url, "vod_name": self._clean(doc("h1").text() or doc("title").text()), "vod_pic": self._abs(doc(".djpg img, .pic img, .djpic img").attr("src")), "vod_play_from": "爱听音乐", "vod_content": ""}
+
+        if any(x in url for x in ["/playlist/", "/album/", "/list/", "/singer/", "/special/", "/radio/", "/radiolist/"]):
+            eps = self._get_eps(doc)
+            page_urls = {self._abs(a.attr("href")) for a in doc(".page a, .dede_pages a, .pagelist a").items() if a.attr("href") and "javascript" not in a.attr("href")} - {url}
+            if page_urls:
+                with ThreadPoolExecutor(max_workers=5) as ex:
+                    for r in as_completed([ex.submit(lambda u: self._get_eps(self.getpq(u)), u) for u in sorted(page_urls, key=lambda x: int(re.search(r'[_\/](\d+)\.html', x).group(1)) if re.search(r'[_\/](\d+)\.html', x) else 0)]):
+                        eps.extend(r.result() or [])
+            if eps:
+                vod.update({"vod_play_from": "播放列表", "vod_play_url": "#".join(eps)})
+                return {"list": [vod]}
+
+        play_list = []
+        if mid := re.search(r'/(song|mp3|radio|radiolist|radioplay)/([^/]+)\.html', url):
+            lrc_url = f"{self.host}/plug/down.php?ac=music&lk=lrc&id={mid.group(2)}"
+            play_list = [f"播放${self.e64('0@@@@' + url + '|||' + lrc_url)}"]
+        
+        elif vid := re.search(r'/(video|mp4)/([^/]+)\.html', url):
+            with ThreadPoolExecutor(max_workers=3) as ex:
+                fs = {ex.submit(self._api, "/plug/down.php", {"ac": "vplay", "id": vid.group(2), "q": q}): n for n, q in [("蓝光", 1080), ("超清", 720), ("高清", 480)]}
+                play_list = [f"{fs[f]}${self.e64('0@@@@'+u)}" for f in as_completed(fs) if (u := f.result())]
+            play_list.sort(key=lambda x: {"蓝":0, "超":1, "高":2}.get(x[0], 3))
+
+        vod["vod_play_url"] = "#".join(play_list) if play_list else f"解析失败${self.e64('1@@@@'+url)}"
+        return {"list": [vod]}
+
+    def playerContent(self, flag, id, vipFlags):
+        raw = self.d64(id).split("@@@@")[-1]
+        url, subt = raw.split("|||") if "|||" in raw else (raw, "")
+        url = url.replace(r"\/", "/")
+
+        if ".html" in url and not self.isVideoFormat(url):
+            if mid := re.search(r'/(song|mp3|radio|radiolist|radioplay)/([^/]+)\.html', url):
+                if r_url := self._api("/js/play.php", method="POST", data={"id": mid.group(2), "type": "music"}, headers={"Referer": url.replace("http://","https://"), "X-Requested-With": "XMLHttpRequest"}):
+                    url = r_url if ".php" not in r_url else url
+            elif vid := re.search(r'/(video|mp4)/([^/]+)\.html', url):
+                with ThreadPoolExecutor(max_workers=3) as ex:
+                    for f in as_completed([ex.submit(self._api, "/plug/down.php", {"ac": "vplay", "id": vid.group(2), "q": q}) for q in [1080, 720, 480]]):
+                        if v_url := f.result():
+                            url = v_url; break
+        
+        result = {"parse": 0, "url": url, "header": {"User-Agent": self.headers["User-Agent"]}}
+        if "22a5.com" in url: result["header"]["Referer"] = self.host + "/"
+        
+        # OK影视3.6.5+支持LRC格式滚动歌词
+        if subt:
+            try:
+                r = self.session.get(subt, headers={"Referer": self.host + "/"}, timeout=5)
+                lrc_content = r.text
+                if lrc_content:
+                    # 过滤广告内容
+                    lrc_content = self._filter_lrc_ads(lrc_content)
+                    result["lrc"] = lrc_content
+            except:
+                pass
+            
+        return result
+
+    def _filter_lrc_ads(self, lrc_text):
+        """过滤LRC歌词中的广告内容"""
+        lines = lrc_text.splitlines()
+        filtered_lines = []
+        
+        # 广告关键词模式
+        ad_patterns = [
+            r'欢迎来访.*',
+            r'本站.*',
+            r'.*广告.*',
+            r'QQ群.*',
+            r'.*www\..*',
+            r'.*http.*',
+            r'.*\.com.*',
+            r'.*\.cn.*',
+            r'.*\.net.*',
+            r'.*音乐网.*',
+            r'.*提供.*',
+            r'.*下载.*',
+        ]
+        
+        for line in lines:
+            # 保留时间标签行，但过滤掉广告文本
+            if re.match(r'\[\d{2}:\d{2}', line):
+                # 检查是否包含广告
+                is_ad = False
+                for pattern in ad_patterns:
+                    if re.search(pattern, line, re.IGNORECASE):
+                        is_ad = True
+                        break
+                
+                if not is_ad:
+                    filtered_lines.append(line)
+            else:
+                # 非时间标签行（可能是元数据），保留
+                filtered_lines.append(line)
+        
+        return '\n'.join(filtered_lines)
+
+    def localProxy(self, param):
+        url = unquote(param.get("url", ""))
+        type_ = param.get("type")
+        
+        if type_ == "img":
+            return [200, "image/jpeg", self.session.get(url, headers={"Referer": self.host + "/"}, timeout=5).content, {}]
+        
+        elif type_ == "lrc":
+            try:
+                r = self.session.get(url, headers={"Referer": self.host + "/"}, timeout=5)
+                # 同时过滤代理中的广告
+                lrc_content = r.text
+                lrc_content = self._filter_lrc_ads(lrc_content)
+                return [200, "application/octet-stream", lrc_content.encode('utf-8'), {}]
+            except:
+                return [404, "text/plain", "Error", {}]
+                
+        return None
+
+    def _parse_list(self, items, tid=""):
+        res = []
+        for li in items.items():
+            a = li("a").eq(0)
+            if not (href := a.attr("href")) or href == "/" or any(x in href for x in ["/user/", "/login/", "javascript"]): continue
+            if not (name := self._clean(li(".name").text() or a.attr("title") or a.text())): continue
+            pic = self._abs((li("img").attr("src") or "").replace('120', '500'))
+            res.append({"vod_id": self._abs(href), "vod_name": name, "vod_pic": f"{self.getProxyUrl()}&url={pic}&type=img" if pic else "", "style": {"type": "oval" if "/singer/" in href else ("list" if any(x in tid for x in ["/list/", "/playtype/", "/albumlist/"]) else "rect"), "ratio": 1 if "/singer/" in href else 1.33}})
+        return res
+
+    def _get_eps(self, doc):
+        eps = []
+        for li in doc(".play_list li, .song_list li, .music_list li").items():
+            if not (a := li("a").eq(0)).attr("href") or not re.search(r'/(song|mp3|radio|radiolist|radioplay)/([^/]+)\.html', a.attr("href")): continue
+            full_url = self._abs(a.attr("href"))
+            
+            lrc_part = ""
+            mid = re.search(r'/(song|mp3|radio|radiolist|radioplay)/([^/]+)\.html', full_url)
+            if mid:
+                lrc_url = f"{self.host}/plug/down.php?ac=music&lk=lrc&id={mid.group(2)}"
+                lrc_part = f"|||{lrc_url}"
+            
+            eps.append(f"{self._clean(a.text() or li('.name').text())}${self.e64('0@@@@' + full_url + lrc_part)}")
+        return eps
+
+    def _clean(self, text): return re.sub(r'(爱玩音乐网|视频下载说明|视频下载地址|www\.2t58\.com|MP3免费下载|LRC歌词下载|全部歌曲|\[第\d+页\]|刷新|每日推荐|最新|热门|推荐|MV|高清|无损)', '', text or "", flags=re.I).strip()
+
+    def _fetch_filters(self, url):
+        doc, filters = self.getpq(url), []
+        for i, group in enumerate([doc(s) for s in [".ilingku_fl", ".class_list", ".screen_list", ".box_list", ".nav_list"] if doc(s)]):
+            opts, seen = [{"n": "全部", "v": "top" if "top" in url else "index"}], set()
+            for a in group("a").items():
+                if (v := (a.attr("href") or "").split("?")[0].rstrip('/').split('/')[-1].replace('.html','')) and v not in seen:
+                    opts.append({"n": a.text().strip(), "v": v}); seen.add(v)
+            if len(opts) > 1: filters.append({"key": f"id{i}" if i else "id", "name": "分类", "value": opts})
+        return filters
+
+    def _api(self, path, params=None, method="GET", headers=None, data=None):
+        try:
+            h = self.headers.copy()
+            if headers: h.update(headers)
+            r = (self.session.post if method == "POST" else self.session.get)(f"{self.host}{path}", params=params, data=data, headers=h, timeout=10, allow_redirects=False)
+            if loc := r.headers.get("Location"): return self._abs(loc.strip())
+            return self._abs(r.json().get("url", "").replace(r"\/", "/")) or (r.text.strip() if r.text.strip().startswith("http") else "")
+        except: return ""
+
+    def getpq(self, url):
+        import time
+        for _ in range(2): 
+            try: return pq(self.session.get(self._abs(url), timeout=5).text)
+            except: time.sleep(0.1)
+        return pq("<html></html>")
+
+    def _abs(self, url): return url if url.startswith("http") else (f"{self.host}{'/' if not url.startswith('/') else ''}{url}" if url else "")
+    def e64(self, text): return b64encode(text.encode("utf-8")).decode("utf-8")
+    def d64(self, text): return b64decode(text.encode("utf-8")).decode("utf-8")

py/网络直播.py

@@ -0,0 +1,767 @@
+# -*- coding: utf-8 -*-
+# by @嗷呜
+import json
+import re
+import sys
+import time
+from base64 import b64decode, b64encode
+from urllib.parse import parse_qs
+import requests
+from pyquery import PyQuery as pq
+sys.path.append('..')
+from base.spider import Spider
+from concurrent.futures import ThreadPoolExecutor
+
+
+class Spider(Spider):
+
+    def init(self, extend=""):
+        tid = 'douyin'
+        headers = self.gethr(0, tid)
+        response = requests.head(self.hosts[tid], headers=headers)
+        ttwid = response.cookies.get('ttwid')
+        headers.update({
+            'authority': self.hosts[tid].split('//')[-1],
+            'cookie': f'ttwid={ttwid}' if ttwid else ''
+        })
+        self.dyheaders = headers
+        pass
+
+    def getName(self):
+        pass
+
+    def isVideoFormat(self, url):
+        pass
+
+    def manualVideoCheck(self):
+        pass
+
+    def destroy(self):
+        pass
+
+    headers = [
+        {
+            "User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/126.0.0.0 Safari/537.36 Edg/126.0.0.0"
+        },
+        {
+            "User-Agent": "Dart/3.4 (dart:io)"
+        }
+    ]
+
+    excepturl = 'https://www.baidu.com'
+
+    hosts = {
+        "huya": ["https://www.huya.com","https://mp.huya.com"],
+        "douyin": "https://live.douyin.com",
+        "douyu": "https://www.douyu.com",
+        "wangyi": "https://cc.163.com",
+        "bili": ["https://api.live.bilibili.com", "https://api.bilibili.com"]
+    }
+
+    referers = {
+        "huya": "https://live.cdn.huya.com",
+        "douyin": "https://live.douyin.com",
+        "douyu": "https://m.douyu.com",
+        "bili": "https://live.bilibili.com"
+    }
+
+    playheaders = {
+        "wangyi": {
+            "User-Agent": "ExoPlayer",
+            "Connection": "Keep-Alive",
+            "Icy-MetaData": "1"
+        },
+        "bili": {
+            'Accept': '*/*',
+            'Icy-MetaData': '1',
+            'referer': referers['bili'],
+            'user-agent': headers[0]['User-Agent']
+        },
+        'douyin': {
+            'User-Agent': 'libmpv',
+            'Icy-MetaData': '1'
+        },
+        'huya': {
+            'User-Agent': 'ExoPlayer',
+            'Connection': 'Keep-Alive',
+            'Icy-MetaData': '1'
+        },
+        'douyu': {
+            'User-Agent': 'libmpv',
+            'Icy-MetaData': '1'
+        }
+    }
+
+    def process_bili(self):
+        try:
+            self.blfdata = self.fetch(
+                f'{self.hosts["bili"][0]}/room/v1/Area/getList?need_entrance=1&parent_id=0',
+                headers=self.gethr(0, 'bili')
+            ).json()
+            return ('bili', [{'key': 'cate', 'name': '分类',
+                              'value': [{'n': i['name'], 'v': str(i['id'])}
+                                        for i in self.blfdata['data']]}])
+        except Exception as e:
+            print(f"bili处理错误: {e}")
+            return 'bili', None
+
+    def process_douyin(self):
+        try:
+            data = self.getpq(self.hosts['douyin'], headers=self.dyheaders)('script')
+            for i in data.items():
+                if 'categoryData' in i.text():
+                    content = i.text()
+                    start = content.find('{')
+                    end = content.rfind('}') + 1
+                    if start != -1 and end != -1:
+                        json_str = content[start:end]
+                        json_str = json_str.replace('\\"', '"')
+                        try:
+                            self.dyifdata = json.loads(json_str)
+                            return ('douyin', [{'key': 'cate', 'name': '分类',
+                                                'value': [{'n': i['partition']['title'],
+                                                           'v': f"{i['partition']['id_str']}@@{i['partition']['title']}"}
+                                                          for i in self.dyifdata['categoryData']]}])
+                        except json.JSONDecodeError as e:
+                            print(f"douyin解析错误: {e}")
+            return 'douyin', None
+        except Exception as e:
+            print(f"douyin请求或处理错误: {e}")
+            return 'douyin', None
+
+    def process_douyu(self):
+        try:
+            self.dyufdata = self.fetch(
+                f'{self.referers["douyu"]}/api/cate/list',
+                headers=self.headers[1]
+            ).json()
+            return ('douyu', [{'key': 'cate', 'name': '分类',
+                               'value': [{'n': i['cate1Name'], 'v': str(i['cate1Id'])}
+                                         for i in self.dyufdata['data']['cate1Info']]}])
+        except Exception as e:
+            print(f"douyu错误: {e}")
+            return 'douyu', None
+
+    def homeContent(self, filter):
+        result = {}
+        cateManual = {
+            "虎牙": "huya",
+            "抖音": "douyin",
+            "斗鱼": "douyu",
+            "网易": "wangyi"
+        }
+        classes = []
+        filters = {
+            'huya': [{'key': 'cate', 'name': '分类',
+                      'value': [{'n': '网游', 'v': '1'}, {'n': '单机', 'v': '2'},
+                                {'n': '娱乐', 'v': '8'}, {'n': '手游', 'v': '3'}]}]
+        }
+
+        with ThreadPoolExecutor(max_workers=3) as executor:
+            futures = {
+                executor.submit(self.process_bili): 'bili',
+                executor.submit(self.process_douyin): 'douyin',
+                executor.submit(self.process_douyu): 'douyu'
+            }
+
+            for future in futures:
+                platform, filter_data = future.result()
+                if filter_data:
+                    filters[platform] = filter_data
+
+        for k in cateManual:
+            classes.append({
+                'type_name': k,
+                'type_id': cateManual[k]
+            })
+
+        result['class'] = classes
+        result['filters'] = filters
+        return result
+
+    def homeVideoContent(self):
+        pass
+
+    def categoryContent(self, tid, pg, filter, extend):
+        vdata = []
+        result = {}
+        pagecount = 9999
+        result['page'] = pg
+        result['limit'] = 90
+        result['total'] = 999999
+        if tid == 'wangyi':
+            vdata, pagecount = self.wyccContent(tid, pg, filter, extend, vdata)
+        elif 'bili' in tid:
+            vdata, pagecount = self.biliContent(tid, pg, filter, extend, vdata)
+        elif 'huya' in tid:
+            vdata, pagecount = self.huyaContent(tid, pg, filter, extend, vdata)
+        elif 'douyin' in tid:
+            vdata, pagecount = self.douyinContent(tid, pg, filter, extend, vdata)
+        elif 'douyu' in tid:
+            vdata, pagecount = self.douyuContent(tid, pg, filter, extend, vdata)
+        result['list'] = vdata
+        result['pagecount'] = pagecount
+        return result
+
+    def wyccContent(self, tid, pg, filter, extend, vdata):
+        params = {
+            'format': 'json',
+            'start': (int(pg) - 1) * 20,
+            'size': '20',
+        }
+        response = self.fetch(f'{self.hosts[tid]}/api/category/live/', params=params, headers=self.headers[0]).json()
+        for i in response['lives']:
+            if i.get('cuteid'):
+                bvdata = self.buildvod(
+                    vod_id=f"{tid}@@{i['cuteid']}",
+                    vod_name=i.get('title'),
+                    vod_pic=i.get('cover'),
+                    vod_remarks=i.get('nickname'),
+                    style={"type": "rect", "ratio": 1.33}
+                )
+                vdata.append(bvdata)
+        return vdata, 9999
+
+    def biliContent(self, tid, pg, filter, extend, vdata):
+        if extend.get('cate') and pg == '1' and 'click' not in tid:
+            for i in self.blfdata['data']:
+                if str(i['id']) == extend['cate']:
+                    for j in i['list']:
+                        v = self.buildvod(
+                            vod_id=f"click_{tid}@@{i['id']}@@{j['id']}",
+                            vod_name=j.get('name'),
+                            vod_pic=j.get('pic'),
+                            vod_tag=1,
+                            style={"type": "oval", "ratio": 1}
+                        )
+                        vdata.append(v)
+            return vdata, 1
+        else:
+            path = f'/xlive/web-interface/v1/second/getListByArea?platform=web&sort=online&page_size=30&page={pg}'
+            if 'click' in tid:
+                ids = tid.split('_')[1].split('@@')
+                tid = ids[0]
+                path = f'/xlive/web-interface/v1/second/getList?platform=web&parent_area_id={ids[1]}&area_id={ids[-1]}&sort_type=&page={pg}'
+            data = self.fetch(f'{self.hosts[tid][0]}{path}', headers=self.gethr(0, tid)).json()
+            for i in data['data']['list']:
+                if i.get('roomid'):
+                    data = self.buildvod(
+                        f"{tid}@@{i['roomid']}",
+                        i.get('title'),
+                        i.get('cover'),
+                        i.get('watched_show', {}).get('text_large'),
+                        0,
+                        i.get('uname'),
+                        style={"type": "rect", "ratio": 1.33}
+                    )
+                vdata.append(data)
+            return vdata, 9999
+
+    def huyaContent(self, tid, pg, filter, extend, vdata):
+        if extend.get('cate') and pg == '1' and 'click' not in tid:
+            id = extend.get('cate')
+            data = self.fetch(f'{self.referers[tid]}/liveconfig/game/bussLive?bussType={id}',
+                              headers=self.headers[1]).json()
+            for i in data['data']:
+                v = self.buildvod(
+                    vod_id=f"click_{tid}@@{int(i['gid'])}",
+                    vod_name=i.get('gameFullName'),
+                    vod_pic=f'https://huyaimg.msstatic.com/cdnimage/game/{int(i["gid"])}-MS.jpg',
+                    vod_tag=1,
+                    style={"type": "oval", "ratio": 1}
+                )
+                vdata.append(v)
+            return vdata, 1
+        else:
+            gid = ''
+            if 'click' in tid:
+                ids = tid.split('_')[1].split('@@')
+                tid = ids[0]
+                gid = f'&gameId={ids[1]}'
+            data = self.fetch(f'{self.hosts[tid][0]}/cache.php?m=LiveList&do=getLiveListByPage&tagAll=0{gid}&page={pg}',
+                              headers=self.headers[1]).json()
+            for i in data['data']['datas']:
+                if i.get('profileRoom'):
+                    v = self.buildvod(
+                        f"{tid}@@{i['profileRoom']}",
+                        i.get('introduction'),
+                        i.get('screenshot'),
+                        str(int(i.get('totalCount', '1')) / 10000) + '万',
+                        0,
+                        i.get('nick'),
+                        style={"type": "rect", "ratio": 1.33}
+
+                    )
+                    vdata.append(v)
+            return vdata, 9999
+
+    def douyinContent(self, tid, pg, filter, extend, vdata):
+        if extend.get('cate') and pg == '1' and 'click' not in tid:
+            ids = extend.get('cate').split('@@')
+            for i in self.dyifdata['categoryData']:
+                c = i['partition']
+                if c['id_str'] == ids[0] and c['title'] == ids[1]:
+                    vlist = i['sub_partition'].copy()
+                    vlist.insert(0, {'partition': c})
+                    for j in vlist:
+                        j = j['partition']
+                        v = self.buildvod(
+                            vod_id=f"click_{tid}@@{j['id_str']}@@{j['type']}",
+                            vod_name=j.get('title'),
+                            vod_pic='https://p3-pc-weboff.byteimg.com/tos-cn-i-9r5gewecjs/pwa_v3/512x512-1.png',
+                            vod_tag=1,
+                            style={"type": "oval", "ratio": 1}
+                        )
+                        vdata.append(v)
+            return vdata, 1
+        else:
+            path = f'/webcast/web/partition/detail/room/?aid=6383&app_name=douyin_web&live_id=1&device_platform=web&count=15&offset={(int(pg) - 1) * 15}&partition=720&partition_type=1'
+            if 'click' in tid:
+                ids = tid.split('_')[1].split('@@')
+                tid = ids[0]
+                path = f'/webcast/web/partition/detail/room/?aid=6383&app_name=douyin_web&live_id=1&device_platform=web&count=15&offset={(int(pg) - 1) * 15}&partition={ids[1]}&partition_type={ids[-1]}&req_from=2'
+            data = self.fetch(f'{self.hosts[tid]}{path}', headers=self.dyheaders).json()
+            for i in data['data']['data']:
+                v = self.buildvod(
+                    vod_id=f"{tid}@@{i['web_rid']}",
+                    vod_name=i['room'].get('title'),
+                    vod_pic=i['room']['cover'].get('url_list')[0],
+                    vod_year=i.get('user_count_str'),
+                    vod_remarks=i['room']['owner'].get('nickname'),
+                    style={"type": "rect", "ratio": 1.33}
+                )
+                vdata.append(v)
+            return vdata, 9999
+
+    def douyuContent(self, tid, pg, filter, extend, vdata):
+        if extend.get('cate') and pg == '1' and 'click' not in tid:
+            for i in self.dyufdata['data']['cate2Info']:
+                if str(i['cate1Id']) == extend['cate']:
+                    v = self.buildvod(
+                        vod_id=f"click_{tid}@@{i['cate2Id']}",
+                        vod_name=i.get('cate2Name'),
+                        vod_pic=i.get('icon'),
+                        vod_remarks=i.get('count'),
+                        vod_tag=1,
+                        style={"type": "oval", "ratio": 1}
+                    )
+                    vdata.append(v)
+            return vdata, 1
+        else:
+            path = f'/japi/weblist/apinc/allpage/6/{pg}'
+            if 'click' in tid:
+                ids = tid.split('_')[1].split('@@')
+                tid = ids[0]
+                path = f'/gapi/rkc/directory/mixList/2_{ids[1]}/{pg}'
+            url = f'{self.hosts[tid]}{path}'
+            data = self.fetch(url, headers=self.headers[1]).json()
+            for i in data['data']['rl']:
+                v = self.buildvod(
+                    vod_id=f"{tid}@@{i['rid']}",
+                    vod_name=i.get('rn'),
+                    vod_pic=i.get('rs16'),
+                    vod_year=str(int(i.get('ol', 1)) / 10000) + '万',
+                    vod_remarks=i.get('nn'),
+                    style={"type": "rect", "ratio": 1.33}
+                )
+                vdata.append(v)
+            return vdata, 9999
+
+    def detailContent(self, ids):
+        ids = ids[0].split('@@')
+        if ids[0] == 'wangyi':
+            vod = self.wyccDetail(ids)
+        elif ids[0] == 'bili':
+            vod = self.biliDetail(ids)
+        elif ids[0] == 'huya':
+            vod = self.huyaDetail(ids)
+        elif ids[0] == 'douyin':
+            vod = self.douyinDetail(ids)
+        elif ids[0] == 'douyu':
+            vod = self.douyuDetail(ids)
+        return {'list': [vod]}
+
+    def wyccDetail(self, ids):
+        try:
+            vdata = self.getpq(f'{self.hosts[ids[0]]}/{ids[1]}', self.headers[0])('script').eq(-1).text()
+
+            def get_quality_name(vbr):
+                if vbr <= 600:
+                    return "标清"
+                elif vbr <= 1000:
+                    return "高清"
+                elif vbr <= 2000:
+                    return "超清"
+                else:
+                    return "蓝光"
+
+            data = json.loads(vdata)['props']['pageProps']['roomInfoInitData']
+            name = data['live'].get('title', ids[0])
+            vod = self.buildvod(vod_name=data.get('keywords_suffix'), vod_remarks=data['live'].get('title'),
+                                vod_content=data.get('description_suffix'))
+            resolution_data = data['live']['quickplay']['resolution']
+            all_streams = {}
+            sorted_qualities = sorted(resolution_data.items(),
+                                      key=lambda x: x[1]['vbr'],
+                                      reverse=True)
+            for quality, data in sorted_qualities:
+                vbr = data['vbr']
+                quality_name = get_quality_name(vbr)
+                for cdn_name, url in data['cdn'].items():
+                    if cdn_name not in all_streams and type(url) == str and url.startswith('http'):
+                        all_streams[cdn_name] = []
+                    if isinstance(url, str) and url.startswith('http'):
+                        all_streams[cdn_name].extend([quality_name, url])
+            plists = []
+            names = []
+            for i, (cdn_name, stream_list) in enumerate(all_streams.items(), 1):
+                names.append(f'线路{i}')
+                pstr = f"{name}${ids[0]}@@{self.e64(json.dumps(stream_list))}"
+                plists.append(pstr)
+            vod['vod_play_from'] = "$$$".join(names)
+            vod['vod_play_url'] = "$$$".join(plists)
+            return vod
+        except Exception as e:
+            return self.handle_exception(e)
+
+    def biliDetail(self, ids):
+        try:
+            vdata = self.fetch(
+                f'{self.hosts[ids[0]][0]}/xlive/web-room/v1/index/getInfoByRoom?room_id={ids[1]}&wts={int(time.time())}',
+                headers=self.gethr(0, ids[0])).json()
+            v = vdata['data']['room_info']
+            vod = self.buildvod(
+                vod_name=v.get('title'),
+                type_name=v.get('parent_area_name') + '/' + v.get('area_name'),
+                vod_remarks=v.get('tags'),
+                vod_play_from=v.get('title'),
+            )
+            data = self.fetch(
+                f'{self.hosts[ids[0]][0]}/xlive/web-room/v2/index/getRoomPlayInfo?room_id={ids[1]}&protocol=0%2C1&format=0%2C1%2C2&codec=0%2C1&platform=web',
+                headers=self.gethr(0, ids[0])).json()
+            vdnams = data['data']['playurl_info']['playurl']['g_qn_desc']
+            all_accept_qns = []
+            streams = data['data']['playurl_info']['playurl']['stream']
+            for stream in streams:
+                for format_item in stream['format']:
+                    for codec in format_item['codec']:
+                        if 'accept_qn' in codec:
+                            all_accept_qns.append(codec['accept_qn'])
+            max_accept_qn = max(all_accept_qns, key=len) if all_accept_qns else []
+            quality_map = {
+                item['qn']: item['desc']
+                for item in vdnams
+            }
+            quality_names = [f"{quality_map.get(qn)}${ids[0]}@@{ids[1]}@@{qn}" for qn in max_accept_qn]
+            vod['vod_play_url'] = "#".join(quality_names)
+            return vod
+        except Exception as e:
+            return self.handle_exception(e)
+
+    def huyaDetail(self, ids):
+        try:
+            vdata = self.fetch(f'{self.hosts[ids[0]][1]}/cache.php?m=Live&do=profileRoom&roomid={ids[1]}',
+                               headers=self.headers[0]).json()
+            v = vdata['data']['liveData']
+            vod = self.buildvod(
+                vod_name=v.get('introduction'),
+                type_name=v.get('gameFullName'),
+                vod_director=v.get('nick'),
+                vod_remarks=v.get('contentIntro'),
+            )
+            data = dict(reversed(list(vdata['data']['stream'].items())))
+            names = []
+            plist = []
+
+            for stream_type, stream_data in data.items():
+                if isinstance(stream_data, dict) and 'multiLine' in stream_data and 'rateArray' in stream_data:
+                    names.append(f"线路{len(names) + 1}")
+                    qualities = sorted(
+                        stream_data['rateArray'],
+                        key=lambda x: (x['iBitRate'], x['sDisplayName']),
+                        reverse=True
+                    )
+                    cdn_urls = []
+                    for cdn in stream_data['multiLine']:
+                        quality_urls = []
+                        for quality in qualities:
+                            quality_name = quality['sDisplayName']
+                            bit_rate = quality['iBitRate']
+                            base_url = cdn['url']
+                            if bit_rate > 0:
+                                if '.m3u8' in base_url:
+                                    new_url = base_url.replace(
+                                        'ratio=2000',
+                                        f'ratio={bit_rate}'
+                                    )
+                                else:
+                                    new_url = base_url.replace(
+                                        'imgplus.flv',
+                                        f'imgplus_{bit_rate}.flv'
+                                    )
+                            else:
+                                new_url = base_url
+                            quality_urls.extend([quality_name, new_url])
+                        encoded_urls = self.e64(json.dumps(quality_urls))
+                        cdn_urls.append(f"{cdn['cdnType']}${ids[0]}@@{encoded_urls}")
+
+                    if cdn_urls:
+                        plist.append('#'.join(cdn_urls))
+            vod['vod_play_from'] = "$$$".join(names)
+            vod['vod_play_url'] = "$$$".join(plist)
+            return vod
+        except Exception as e:
+            return self.handle_exception(e)
+
+    def douyinDetail(self, ids):
+        url = f'{self.hosts[ids[0]]}/webcast/room/web/enter/?aid=6383&app_name=douyin_web&live_id=1&device_platform=web&enter_from=web_live&web_rid={ids[1]}&room_id_str=&enter_source=&Room-Enter-User-Login-Ab=0&is_need_double_stream=false&cookie_enabled=true&screen_width=1980&screen_height=1080&browser_language=zh-CN&browser_platform=Win32&browser_name=Edge&browser_version=125.0.0.0'
+        data = self.fetch(url, headers=self.dyheaders).json()
+        try:
+            vdata = data['data']['data'][0]
+            vod = self.buildvod(
+                vod_name=vdata['title'],
+                vod_remarks=vdata['user_count_str'],
+            )
+            resolution_data = vdata['stream_url']['live_core_sdk_data']['pull_data']['options']['qualities']
+            stream_json = vdata['stream_url']['live_core_sdk_data']['pull_data']['stream_data']
+            stream_json = json.loads(stream_json)
+            available_types = []
+            if any(sdk_key in stream_json['data'] and 'main' in stream_json['data'][sdk_key] for sdk_key in
+                   stream_json['data']):
+                available_types.append('main')
+            if any(sdk_key in stream_json['data'] and 'backup' in stream_json['data'][sdk_key] for sdk_key in
+                   stream_json['data']):
+                available_types.append('backup')
+            plist = []
+            for line_type in available_types:
+                format_arrays = {'flv': [], 'hls': [], 'lls': []}
+                qualities = sorted(resolution_data, key=lambda x: x['level'], reverse=True)
+                for quality in qualities:
+                    sdk_key = quality['sdk_key']
+                    if sdk_key in stream_json['data'] and line_type in stream_json['data'][sdk_key]:
+                        stream_info = stream_json['data'][sdk_key][line_type]
+                        if stream_info.get('flv'):
+                            format_arrays['flv'].extend([quality['name'], stream_info['flv']])
+                        if stream_info.get('hls'):
+                            format_arrays['hls'].extend([quality['name'], stream_info['hls']])
+                        if stream_info.get('lls'):
+                            format_arrays['lls'].extend([quality['name'], stream_info['lls']])
+                format_urls = []
+                for format_name, url_array in format_arrays.items():
+                    if url_array:
+                        encoded_urls = self.e64(json.dumps(url_array))
+                        format_urls.append(f"{format_name}${ids[0]}@@{encoded_urls}")
+
+                if format_urls:
+                    plist.append('#'.join(format_urls))
+
+            names = ['线路1', '线路2'][:len(plist)]
+            vod['vod_play_from'] = "$$$".join(names)
+            vod['vod_play_url'] = "$$$".join(plist)
+            return vod
+
+        except Exception as e:
+            return self.handle_exception(e)
+
+    def douyuDetail(self, ids):
+        headers = self.gethr(0, zr=f'{self.hosts[ids[0]]}/{ids[1]}')
+        try:
+            data = self.fetch(f'{self.hosts[ids[0]]}/betard/{ids[1]}', headers=headers).json()
+            vname = data['room']['room_name']
+            vod = self.buildvod(
+                vod_name=vname,
+                vod_remarks=data['room'].get('second_lvl_name'),
+                vod_director=data['room'].get('nickname'),
+            )
+            vdata = self.fetch(f'{self.hosts[ids[0]]}/swf_api/homeH5Enc?rids={ids[1]}', headers=headers).json()
+            json_body = vdata['data']
+            json_body = {"html": self.douyu_text(json_body[f'room{ids[1]}']), "rid": ids[1]}
+            sign = self.post('http://alive.nsapps.cn/api/AllLive/DouyuSign', json=json_body, headers=self.headers[1]).json()['data']
+            body = f'{sign}&cdn=&rate=-1&ver=Douyu_223061205&iar=1&ive=1&hevc=0&fa=0'
+            body=self.params_to_json(body)
+            nubdata = self.post(f'{self.hosts[ids[0]]}/lapi/live/getH5Play/{ids[1]}', data=body, headers=headers).json()
+            plist = []
+            names = []
+            for i,x in enumerate(nubdata['data']['cdnsWithName']):
+                names.append(f'线路{i+1}')
+                d = {'sign': sign, 'cdn': x['cdn'], 'id': ids[1]}
+                plist.append(
+                    f'{vname}${ids[0]}@@{self.e64(json.dumps(d))}@@{self.e64(json.dumps(nubdata["data"]["multirates"]))}')
+            vod['vod_play_from'] = "$$$".join(names)
+            vod['vod_play_url'] = "$$$".join(plist)
+            return vod
+        except Exception as e:
+            return self.handle_exception(e)
+
+    def douyu_text(self, text):
+        function_positions = [m.start() for m in re.finditer('function', text)]
+        total_functions = len(function_positions)
+        if total_functions % 2 == 0:
+            target_index = total_functions // 2 + 1
+        else:
+            target_index = (total_functions - 1) // 2 + 1
+        if total_functions >= target_index:
+            cut_position = function_positions[target_index - 1]
+            ctext = text[4:cut_position]
+            return re.sub(r'eval\(strc\)\([\w\d,]+\)', 'strc', ctext)
+        return text
+
+    def searchContent(self, key, quick, pg="1"):
+        pass
+
+    def playerContent(self, flag, id, vipFlags):
+        try:
+            ids = id.split('@@')
+            p = 1
+            if ids[0] in ['wangyi', 'douyin','huya']:
+                p, url = 0, json.loads(self.d64(ids[1]))
+            elif ids[0] == 'bili':
+                p, url = self.biliplay(ids)
+            elif ids[0] == 'huya':
+                p, url = 0, json.loads(self.d64(ids[1]))
+            elif ids[0] == 'douyu':
+                p, url = self.douyuplay(ids)
+            return {'parse': p, 'url': url, 'header': self.playheaders[ids[0]]}
+        except Exception as e:
+            return {'parse': 1, 'url': self.excepturl, 'header': self.headers[0]}
+
+    def biliplay(self, ids):
+        try:
+            data = self.fetch(
+                f'{self.hosts[ids[0]][0]}/xlive/web-room/v2/index/getRoomPlayInfo?room_id={ids[1]}&protocol=0,1&format=0,2&codec=0&platform=web&qn={ids[2]}',
+                headers=self.gethr(0, ids[0])).json()
+            urls = []
+            line_index = 1
+            for stream in data['data']['playurl_info']['playurl']['stream']:
+                for format_item in stream['format']:
+                    for codec in format_item['codec']:
+                        for url_info in codec['url_info']:
+                            full_url = f"{url_info['host']}/{codec['base_url'].lstrip('/')}{url_info['extra']}"
+                            urls.extend([f"线路{line_index}", full_url])
+                            line_index += 1
+            return 0, urls
+        except Exception as e:
+            return 1, self.excepturl
+
+    def douyuplay(self, ids):
+        try:
+            sdata = json.loads(self.d64(ids[1]))
+            headers = self.gethr(0, zr=f'{self.hosts[ids[0]]}/{sdata["id"]}')
+            ldata = json.loads(self.d64(ids[2]))
+            result_obj = {}
+            with ThreadPoolExecutor(max_workers=len(ldata)) as executor:
+                futures = [
+                    executor.submit(
+                        self.douyufp,
+                        sdata,
+                        quality,
+                        headers,
+                        self.hosts[ids[0]],
+                        result_obj
+                    ) for quality in ldata
+                ]
+                for future in futures:
+                    future.result()
+
+            result = []
+            for bit in sorted(result_obj.keys(), reverse=True):
+                result.extend(result_obj[bit])
+
+            if result:
+                return 0, result
+            return 1, self.excepturl
+
+        except Exception as e:
+            return 1, self.excepturl
+
+    def douyufp(self, sdata, quality, headers, host, result_obj):
+        try:
+            body = f'{sdata["sign"]}&cdn={sdata["cdn"]}&rate={quality["rate"]}'
+            body=self.params_to_json(body)
+            data = self.post(f'{host}/lapi/live/getH5Play/{sdata["id"]}',
+                             data=body, headers=headers).json()
+            if data.get('data'):
+                play_url = data['data']['rtmp_url'] + '/' + data['data']['rtmp_live']
+                bit = quality.get('bit', 0)
+                if bit not in result_obj:
+                    result_obj[bit] = []
+                result_obj[bit].extend([quality['name'], play_url])
+        except Exception as e:
+            print(f"Error fetching {quality['name']}: {str(e)}")
+
+    def localProxy(self, param):
+        pass
+
+    def e64(self, text):
+        try:
+            text_bytes = text.encode('utf-8')
+            encoded_bytes = b64encode(text_bytes)
+            return encoded_bytes.decode('utf-8')
+        except Exception as e:
+            print(f"Base64编码错误: {str(e)}")
+            return ""
+
+    def d64(self, encoded_text):
+        try:
+            encoded_bytes = encoded_text.encode('utf-8')
+            decoded_bytes = b64decode(encoded_bytes)
+            return decoded_bytes.decode('utf-8')
+        except Exception as e:
+            print(f"Base64解码错误: {str(e)}")
+            return ""
+
+    def josn_to_params(self, params, skip_empty=False):
+        query = []
+        for k, v in params.items():
+            if skip_empty and not v:
+                continue
+            query.append(f"{k}={v}")
+        return "&".join(query)
+
+    def params_to_json(self, query_string):
+        parsed_data = parse_qs(query_string)
+        result = {key: value[0] for key, value in parsed_data.items()}
+        return result
+
+    def buildvod(self, vod_id='', vod_name='', vod_pic='', vod_year='', vod_tag='', vod_remarks='', style='',
+                 type_name='', vod_area='', vod_actor='', vod_director='',
+                 vod_content='', vod_play_from='', vod_play_url=''):
+        vod = {
+            'vod_id': vod_id,
+            'vod_name': vod_name,
+            'vod_pic': vod_pic,
+            'vod_year': vod_year,
+            'vod_tag': 'folder' if vod_tag else '',
+            'vod_remarks': vod_remarks,
+            'style': style,
+            'type_name': type_name,
+            'vod_area': vod_area,
+            'vod_actor': vod_actor,
+            'vod_director': vod_director,
+            'vod_content': vod_content,
+            'vod_play_from': vod_play_from,
+            'vod_play_url': vod_play_url
+        }
+        vod = {key: value for key, value in vod.items() if value}
+        return vod
+
+    def getpq(self, url, headers=None, cookies=None):
+        data = self.fetch(url, headers=headers, cookies=cookies).text
+        try:
+            return pq(data)
+        except Exception as e:
+            print(f"解析页面错误: {str(e)}")
+            return pq(data.encode('utf-8'))
+
+    def gethr(self, index, rf='', zr=''):
+        headers = self.headers[index]
+        if zr:
+            headers['referer'] = zr
+        else:
+            headers['referer'] = f"{self.referers[rf]}/"
+        return headers
+
+    def handle_exception(self, e):
+        print(f"报错: {str(e)}")
+        return {'vod_play_from': '哎呀翻车啦', 'vod_play_url': f'翻车啦${self.excepturl}'}
+