From 1cd5c93451b9bc1070e3cd56756ceedfa8fa4b93 Mon Sep 17 00:00:00 2001 From: XC-Pro <19840+xc-pro@noreply.example.org> Date: Fri, 14 Aug 2026 11:25:02 +0200 Subject: [PATCH] =?UTF-8?q?=E4=B8=8A=E4=BC=A0=E6=96=87=E4=BB=B6=E8=87=B3?= =?UTF-8?q?=E3=80=8Cpy=E3=80=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- py/共青春.py | 259 ++++++++++++++++++++++++ py/枫叶影院3.py | 375 +++++++++++++++++++++++++++++++++++ py/瓜娃子.py | 510 ++++++++++++++++++++++++++++++++++++++++++++++++ py/瓜子.py | 498 ++++++++++++++++++++++++++++++++++++++++++++++ py/红果短剧.py | 271 +++++++++++++++++++++++++ 5 files changed, 1913 insertions(+) create mode 100644 py/共青春.py create mode 100644 py/枫叶影院3.py create mode 100644 py/瓜娃子.py create mode 100644 py/瓜子.py create mode 100644 py/红果短剧.py diff --git a/py/共青春.py b/py/共青春.py new file mode 100644 index 0000000..144a984 --- /dev/null +++ b/py/共青春.py @@ -0,0 +1,259 @@ +# -*- coding: utf-8 -*- +import sys +import re +import json +from urllib.parse import urljoin, quote + +sys.path.append('..') +try: + from base.spider import Spider +except ImportError: + class Spider: + def fetch(self, url, headers=None, **kw): + import requests as rq + kw.pop('timeout', None) + r = rq.get(url, headers=headers, timeout=15, **kw) + r.encoding = 'utf-8' + return r + +HOST = "https://gqc.ink" +UA = "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36" + +CATEGORIES = { + "dianying": "电影", "lianxuju": "连续剧", "zongyi": "综艺", + "dongman": "动漫", "duanju": "短剧", +} + +class Spider(Spider): + def init(self, extend=""): + global HOST + try: + r = self.fetch(HOST, headers={"User-Agent": UA}, timeout=15000) + if hasattr(r, 'url') and r.url and r.url != HOST.rstrip("/"): + HOST = r.url.rstrip("/") + except: + pass + + def homeContent(self, filter=False): + r = {"class": [], "list": []} + for k, v in CATEGORIES.items(): + r["class"].append({"type_id": k, "type_name": v}) + return r + + def homeVideoContent(self): + return {"list": []} + + def categoryContent(self, tid, pg=1, filter=False, extend=""): + pn = 1 + try: pn = max(int(str(pg)), 1) + except: pass + cat = str(tid) + if cat not in CATEGORIES: + cat = "dianying" + slug = cat + try: + if pn > 1: + url = f"{HOST}/vodshow/{slug}--------{pn}---.html" + else: + url = f"{HOST}/vodshow/{slug}--------1---.html" + r = self.fetch(url, headers={"User-Agent": UA}, timeout=30000) + html = r.text if hasattr(r, 'text') else str(r) + items = self._items(html) + return {"page": pn, "pagecount": self._pagecount(html), "limit": 50, "total": len(items), "list": items} + except: + return {"page": pn, "pagecount": 1, "limit": 50, "total": 0, "list": []} + + def detailContent(self, ids): + if isinstance(ids, list): + vid = ids[0] if ids else "" + else: + vid = str(ids) if ids else "" + m = re.search(r'(\d+)', str(vid)) + vid = m.group(1) if m else "" + if not vid: + return {"list": []} + try: + r = self.fetch(f"{HOST}/neirong/{vid}.html", headers={"User-Agent": UA}, timeout=30000) + h = r.text if hasattr(r, 'text') else str(r) + except: + return {"list": []} + d = {"vod_id": vid, "vod_name": "", "vod_pic": "", "vod_year": "", + "vod_area": "", "vod_class": "", "vod_director": "", "vod_actor": "", + "vod_content": "", "vod_remarks": "", "vod_play_from": "", "vod_play_url": ""} + t1 = re.search(r']*>(.*?)', h, re.S) + if t1: + clean = re.sub(r'<[^>]+>', ' ', t1.group(1)).strip() + d["vod_name"] = clean.split('\n')[0].strip() + if not d["vod_name"]: + t2 = re.search(r'(.*?)', h) + if t2: d["vod_name"] = t2.group(1).split("-")[0].strip() + p = re.search(r'data-original="(https?://[^"]+\.(?:jpg|jpeg|png|webp))"', h, re.I) + if not p: + p = re.search(r'data-background="(https?://[^"]+\.(?:jpg|jpeg|png|webp))"', h, re.I) + if not p: + p = re.search(r']*src="(https?://[^"]+\.(?:jpg|jpeg|png|webp))"', h, re.I) + if p: d["vod_pic"] = p.group(1) + desc_m = re.search(r'class="fed-part-esan[^"]*"[\s\S]*?]*>简介[：:]?\s* .*?(?:]*>[\s\S]*?)\s*([^<]+)', h) + if not desc_m: + desc_m = re.search(r'class="fed-part-esan[^"]*"[\s\S]*?]*>简介[：:]?\s* \s*([^<]+)', h) + if desc_m: + desc = re.sub(r'\s+', ' ', desc_m.group(1)).strip()[:500] + d["vod_content"] = desc + for mi in re.finditer(r'class="fed-deta-info[^"]*"[\s\S]*?>(.*?)', h, re.S): + t = re.sub(r'<[^>]+>', '', mi.group(1)).strip() + if "导演" in t: d["vod_director"] = t.split("：")[-1].split(":")[-1].strip() + elif "主演" in t: d["vod_actor"] = t.split("：")[-1].split(":")[-1].strip() + elif "年份" in t or "上映" in t: + ym = re.search(r'(\d{4})', t) + if ym: d["vod_year"] = ym.group(1) + elif "备注" in t or "更新" in t: d["vod_remarks"] = t + try: + pf, pu = [], [] + tops = re.search(r'fed-drop-tops(.*?)fed-drop-btms', h, re.S) + route_buttons = [] + if tops: + for bm in re.finditer(r'href="/bofang/\d+-(\d+)-1\.html"[\s\S]*?>(.*?)]*>(\d+)<', tops.group(1), re.S): + route = bm.group(1) + name = re.sub(r'<[^>]+>', '', bm.group(2)).strip() + count = int(bm.group(3)) + if name and count > 0: + route_buttons.append((route, name, count)) + vis = re.search(r'fed-play-item fed-drop-item fed-visible(.*?)\s*', h, re.S) + default_eps = [] + default_route = None + if vis: + for em in re.finditer(r'href="/bofang/\d+-(\d+)-(\d+)\.html"[\s\S]*?>([^<]+)<', vis.group(1)): + r2, nid, name = em.group(1), em.group(2), em.group(3).strip() + if not default_route: + default_route = r2 + default_eps.append((int(nid), name)) + if not route_buttons: + items = re.findall(r'href="(/bofang/\d+-\d+-\d+\.html)"[\s\S]*?>([^<]+)<', h) + routes = {} + for href, name in items: + name = name.strip() + if not name or "报错" in name or "剧情" in name or "简介" in name or "立即播放" in name: + continue + rm = re.search(r'/bofang/\d+-(\d+)-(\d+)\.html', href) + if rm: + rt, nid = rm.group(1), rm.group(2) + if rt not in routes: + routes[rt] = [] + routes[rt].append(f"{name}${urljoin(HOST, href)}") + for rt in sorted(routes): + pf.append(f"源{len(pf)+1}") + pu.append("#".join(routes[rt])) + else: + for route, name, count in route_buttons: + eps_list = [] + if default_route == route and default_eps: + for nid, ename in default_eps: + eps_list.append(f"{ename}${urljoin(HOST, f'/bofang/{vid}-{route}-{nid}.html')}") + else: + if default_eps: + for nid, ename in default_eps: + if nid <= count: + eps_list.append(f"{ename}${urljoin(HOST, f'/bofang/{vid}-{route}-{nid}.html')}") + else: + for nid in range(1, count + 1): + eps_list.append(f"第{nid}集${urljoin(HOST, f'/bofang/{vid}-{route}-{nid}.html')}") + if eps_list: + pf.append(name) + pu.append("#".join(eps_list)) + if pf: + d["vod_play_from"] = "$$$".join(pf) + d["vod_play_url"] = "$$$".join(pu) + except: + pass + return {"list": [d]} + + def searchContent(self, key, quick=False, pg="1"): + return {"list": []} + + def playerContent(self, flag, id, vipFlags=None): + a, b = str(flag), str(id) if id else "" + if a.startswith("http") or "/bofang/" in a: + url = a + elif b.startswith("http") or "/bofang/" in b: + url = b + elif a.startswith("/"): + url = urljoin(HOST, a) + elif b.startswith("/"): + url = urljoin(HOST, b) + else: + url = a + try: + r = self.fetch(url, headers={"User-Agent": UA}, timeout=30000) + h = r.text if hasattr(r, 'text') else str(r) + except: + return {"url": ""} + dm = re.search(r'"dmId"\s*:\s*"([^"]+)"', h) + if dm: + u = dm.group(1) + if u.startswith("http"): + if ".m3u8" in u: + return {"url": u} + return {"url": u} + m3u8 = re.search(r'(https?://[^\s"\'<>]+\.m3u8)', h) + if m3u8: + return {"url": m3u8.group(1)} + return {"url": ""} + + def localProxy(self, param): + pass + + def _pagecount(self, html): + pc = 1 + # 优先用 data-total 属性 (fed模板分页跳转按钮) + dt = re.findall(r'data-total="(\d+)"', html) + for t in dt: + try: pc = max(pc, int(t)) + except: pass + # /vodshow/ 格式分页: href="/vodshow/dianying--------2---.html" + pages_vod = re.findall(r'href="/vodshow/[^"]*-(\d+)-*--*\.html"', html) + for p in pages_vod: + try: + n = int(p) + if n > 1 and n < 10000: + pc = max(pc, n) + except: pass + # /fenlei/ 格式分页 (兼容旧格式) + pages_fen = re.findall(r'href="/fenlei/[^"]*-?(\d+)\.html"', html) + for p in pages_fen: + try: + n = int(p) + if n > 1 and n < 10000: + pc = max(pc, n) + except: pass + return pc + + def _items(self, html): + items, seen = [], set() + # 只取 data-original 的列表项，不取 data-background 的轮播项 + # 轮播项标题和封面不在同一个结构里，混入会导致错位 + cover_map = {} + for m in re.finditer(r'data-original="(https?://[^"]+)"', html, re.I): + # 找到 data-original 前面最近的 href (取最后一个，不是第一个) + before = html[max(0, m.start()-500):m.start()] + hms = re.findall(r'href="(/neirong/(\d+)\.html)"', before) + if hms: + hm = hms[-1] + vid = hm[1] + if vid not in cover_map: + cover_map[vid] = (hm[0], m.group(1)) + # 标题: fed-list-title + titles = {} + for tm in re.finditer(r'class="[^"]*fed-list-title[^"]*"[\s\S]*?href="/neirong/(\d+)\.html"[\s\S]*?>\s*(.*?)\s*', html, re.S): + name = re.sub(r'<[^>]+>', '', tm.group(2)).strip() + if name: + titles[tm.group(1)] = name[:50] + # 合并: 只用列表项的封面 + for vid, (href, pic) in cover_map.items(): + if vid in seen: + continue + seen.add(vid) + items.append({ + "vod_id": vid, "vod_name": titles.get(vid, ""), + "vod_pic": pic, "vod_remarks": "", "vod_url": urljoin(HOST, href), + }) + return items diff --git a/py/枫叶影院3.py b/py/枫叶影院3.py new file mode 100644 index 0000000..509578e --- /dev/null +++ b/py/枫叶影院3.py @@ -0,0 +1,375 @@ +""" +@header({ + searchable: 1, + filterable: 1, + quickSearch: 1, + title: '茶杯狐-TJTCDL', + lang: 'hipy', +}) +""" + +# -*- coding: utf-8 -*- +# !/usr/bin/python +import requests +import base64 +import random +import re +import json +import sys +import urllib.parse +import ssl +import urllib3 +import hashlib +from bs4 import BeautifulSoup +from requests.adapters import HTTPAdapter +from urllib3.util.ssl_ import create_urllib3_context + +urllib3.disable_warnings() +sys.path.append('..') +from base.spider import Spider + + +class TLSAdapter(HTTPAdapter): + def init_poolmanager(self, *args, **kwargs): + ciphers = ( + 'ECDHE-ECDSA-AES128-GCM-SHA256:ECDHE-RSA-AES128-GCM-SHA256:' + 'ECDHE-ECDSA-AES256-GCM-SHA384:ECDHE-RSA-AES256-GCM-SHA384:' + 'ECDHE-ECDSA-CHACHA20-POLY1305:ECDHE-RSA-CHACHA20-POLY1305:' + 'DHE-RSA-AES128-GCM-SHA256:DHE-RSA-AES256-GCM-SHA384' + ) + context = create_urllib3_context(ciphers=ciphers) + context.check_hostname = False + context.verify_mode = ssl.CERT_NONE + kwargs['ssl_context'] = context + return super(TLSAdapter, self).init_poolmanager(*args, **kwargs) + + +class Spider(Spider): + def __init__(self): + super(Spider, self).__init__() + self.session = requests.Session() + self.session.verify = False + self.session.mount('https://', TLSAdapter()) + self.host = "https://www.tjtcdl.com" + self.headers = { + 'User-Agent': 'Mozilla/5.0 (iPhone; CPU iPhone OS 16_6 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Version/16.6 Mobile/15E148 Safari/604.1', + 'Referer': f'{self.host}/', + 'Accept': 'text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,image/apng,*/*;q=0.8', + 'Accept-Language': 'zh-CN,zh;q=0.9,en;q=0.8', + } + + def getName(self): + return "茶杯狐-TJTCDL" + + def init(self, extend): + pass + + def homeContent(self, filter): + classes = [ + {"type_id": "1", "type_name": "电影"}, + {"type_id": "2", "type_name": "电视剧"}, + {"type_id": "4", "type_name": "动漫"}, + {"type_id": "3", "type_name": "综艺"}, + {"type_id": "5", "type_name": "热门短剧"}, + ] + + filter_dict = {} + years = [{"n": "全部", "v": ""}] + [{"n": str(y), "v": str(y)} for y in range(2026, 2003, -1)] + orders = [ + {"n": "按最新", "v": "time"}, + {"n": "按最热", "v": "hits"}, + {"n": "按评分", "v": "score"} + ] + + movie_classes = ["动作", "喜剧", "爱情", "科幻", "恐怖", "剧情", "战争", "惊悚", "悬疑", "犯罪", "奇幻", "冒险", + "动画", "武侠"] + movie_areas = ["大陆", "香港", "台湾", "美国", "韩国", "日本", "泰国", "新加坡", "马来西亚", "印度", "英国", + "法国", "加拿大", "西班牙", "俄罗斯", "其它"] + + tv_classes = ["古装", "战争", "青春偶像", "喜剧", "家庭", "犯罪", "动作", "奇幻", "剧情", "历史", "经典", + "乡村", "情景", "商战", "网剧", "其他"] + tv_areas = ["内地", "韩国", "香港", "台湾", "日本", "美国", "泰国", "英国", "新加坡", "其他"] + + comic_classes = ["科幻", "热血", "推理", "搞笑", "冒险", "萝莉", "校园", "动作", "机战", "运动", "战争", "少年", + "少女"] + show_classes = ["脱口秀", "真人秀", "搞笑", "访谈", "生活", "晚会", "美食", "游戏", "亲子", "旅游", "音乐", + "舞蹈"] + + def create_filter(classes_list, areas_list): + return [ + {"key": "class", "name": "类型", + "value": [{"n": "全部", "v": ""}] + [{"n": c, "v": c} for c in classes_list]}, + {"key": "area", "name": "地区", + "value": [{"n": "全部", "v": ""}] + [{"n": a, "v": a} for a in areas_list]}, + {"key": "year", "name": "年份", "value": years}, + {"key": "by", "name": "排序", "value": orders} + ] + + filter_dict["1"] = create_filter(movie_classes, movie_areas) + filter_dict["2"] = create_filter(tv_classes, tv_areas) + filter_dict["4"] = create_filter(comic_classes, tv_areas) + filter_dict["3"] = create_filter(show_classes, tv_areas) + filter_dict["5"] = create_filter(["女频", "男频", "复仇", "甜宠", "穿越", "逆袭", "战神", "脑洞"], + ["内地", "其他"]) + + return {"class": classes, "filters": filter_dict} + + def homeVideoContent(self): + return {'list': []} + + def categoryContent(self, cid, pg, filter, ext): + page = int(pg) + ext = ext or {} + area = urllib.parse.quote(ext.get('area', '')) if ext.get('area') else '' + by = ext.get('by', '') + class_name = urllib.parse.quote(ext.get('class', '')) if ext.get('class') else '' + lang = urllib.parse.quote(ext.get('lang', '')) if ext.get('lang') else '' + letter = ext.get('letter', '') + year = ext.get('year', '') + + url = f"{self.host}/cupfox-list/{cid}-{area}-{by}-{class_name}-{lang}-{letter}---{page}---{year}.html" + res = self.session.get(url, headers=self.headers) + soup = BeautifulSoup(res.text, 'html.parser') + + videos = [] + for item in soup.select('.public-list-box'): + link = item.select_one('.public-list-exp') + if not link: continue + vid_match = re.search(r'/chabeihu/(\d+)\.html', link.get('href', '')) + if not vid_match: continue + + pic_img = link.select_one('img') + note_tag = item.select_one('.public-list-prb') + + videos.append({ + "vod_id": vid_match.group(1), + "vod_name": link.get('title', '').strip(), + "vod_pic": pic_img.get('data-src') or pic_img.get('src') or '' if pic_img else '', + "vod_remarks": note_tag.text.strip() if note_tag else '' + }) + + return {'list': videos, 'page': page, 'pagecount': 9999, 'limit': 90, 'total': 999999} + + def detailContent(self, ids): + did = ids[0] + url = f"{self.host}/chabeihu/{did}.html" + res = self.session.get(url, headers=self.headers, timeout=10) + soup = BeautifulSoup(res.text, 'html.parser') + + name, state, actor, director, year, content = "", "", "", "", "", "" + for li in soup.select('.info-parameter li'): + em = li.select_one('em') + if not em: continue + em_text = em.text.strip() + val = li.text.replace(em_text, '').replace('\xa0', ' ').strip() + + if '片名' in em_text: + name = val + elif '状态' in em_text: + state = val + elif '主演' in em_text: + actor = val + elif '导演' in em_text: + director = val + elif '年份' in em_text: + year = val + elif '简介' in em_text: + content = val + + if not name: + title_tag = soup.select_one('.this-desc-title') + name = title_tag.text.strip() if title_tag else '' + + play_from, play_url = [], [] + sources = [s.text.replace(s.select_one('.badge').text, '').strip() if s.select_one('.badge') else s.text.strip() + for s in soup.select('.anthology-tab .swiper-slide')] + + for idx, box in enumerate(soup.select('.anthology-list-box')): + eps = [ + f"{a.text.strip()}${self.host + a.get('href') if not a.get('href').startswith('http') else a.get('href')}" + for a in box.select('li a') if a.get('href')] + if eps: + eps.reverse() + play_from.append(sources[idx] if idx < len(sources) else f"线路{idx + 1}") + play_url.append('#'.join(eps)) + + return {'list': [{ + "vod_id": did, + "vod_name": name, + "vod_actor": actor, + "vod_director": director, + "vod_content": content, + "vod_remarks": state, + "vod_year": year, + "vod_play_from": '$$$'.join(play_from), + "vod_play_url": '$$$'.join(play_url) + }]} + + + def playerContent(self, flag, id, vipFlags): + try: + + res = self.session.get(id, headers=self.headers, timeout=5) + match = re.search(r'var player_aaaa=(.*?)', res.text) + if not match: + return {'parse': 0, 'url': ''} + + player_data = json.loads(match.group(1)) + durl = player_data.get('url', '') + encrypt = player_data.get('encrypt', 0) + from_flag = player_data.get('from', '') + + if encrypt == 1: + durl = urllib.parse.unquote(durl) + elif encrypt == 2: + durl = urllib.parse.unquote(durl) + durl = base64.b64decode(durl).decode('utf-8') + durl = urllib.parse.unquote(durl) + + + if durl.startswith('http') and ('.m3u8' in durl or '.mp4' in durl): + + return {'parse': 0, 'url': durl} + + + + + config_url = f"{self.host}/static/js/playerconfig.js" + config_res = self.session.get(config_url, headers=self.headers, verify=False, timeout=5) + + parse_api = "" + if from_flag: + m = re.search(f'"{from_flag}":\\{{[^}}]*"parse":"([^"]+)"', config_res.text) + if m: parse_api = m.group(1).replace('\\/', '/') + if not parse_api: + m = re.search(r'"parse":"(http[^"]+)"', config_res.text) + if m: parse_api = m.group(1).replace('\\/', '/') + if not parse_api: + parse_api = "https://fgsrg.hzqingshan.com/player/?url=" + + iframe_url = parse_api + durl + print(f"[*] 2. 锁定隐藏解析服务器(iframe): {iframe_url}") + + + iframe_headers = self.headers.copy() + iframe_headers['Referer'] = id + iframe_res = self.session.get(iframe_url, headers=iframe_headers, verify=False, timeout=5) + + iframe_soup = BeautifulSoup(iframe_res.text, 'html.parser') + player_data_tag = iframe_soup.select_one('#player-data') + + if not player_data_tag: + + return {'parse': 1, 'url': iframe_url} + + token = player_data_tag.get('data-te', '') + bt = player_data_tag.get('data-bt', '/player/') + + + + api_base = urllib.parse.urlparse(parse_api) + api_host = f"{api_base.scheme}://{api_base.netloc}" + api_url = f"{api_host}{bt}mplayer.php" + + + post_data = {'url': durl, 'token': token} + + api_headers = self.headers.copy() + api_headers['Content-Type'] = 'application/x-www-form-urlencoded; charset=UTF-8' + api_headers['X-Requested-With'] = 'XMLHttpRequest' + api_headers['Referer'] = iframe_url + api_headers['Origin'] = api_host + + + api_res = self.session.post(api_url, data=post_data, headers=api_headers, verify=False, timeout=10) + + if api_res.status_code == 200: + api_json = api_res.json() + print(f"[*] 5. 接口解密成功: {api_json}") + + real_url = api_json.get('url') or api_json.get('data', {}).get('url', '') + urlmode = str(api_json.get('urlmode') or api_json.get('data', {}).get('urlmode', '')) + + if urlmode == '1': + real_url = self.js_decrypt1(real_url) + elif urlmode == '2': + real_url = self.js_decrypt2(real_url) + elif urlmode == '3': + real_url = self.js_decrypt3(real_url) + + for _ in range(3): + if real_url.startswith('WyJ') and '/' in real_url: + real_url = self.js_decrypt3(real_url) + else: + break + + if real_url: + print(f"[*] 6. 🎉斩获最终真实 M3U8: {real_url}") + return {'parse': 0 if ('.m3u8' in real_url or '.mp4' in real_url) else 1, 'url': real_url} + + + return {'parse': 1, 'url': iframe_url} + + except Exception as e: + + return {'parse': 1, 'url': id} + + def searchContent(self, key, quick, pg="1"): + search_url = f'{self.host}/cupfox-search/-------------.html' + res = self.session.get(search_url, params={'wd': key}, headers=self.headers) + soup = BeautifulSoup(res.text, 'html.parser') + + videos = [] + for item in soup.select('.public-list-box'): + link = item.select_one('.public-list-exp') + if not link: continue + vid_match = re.search(r'/chabeihu/(\d+)\.html', link.get('href', '')) + if not vid_match: continue + + pic_img = link.select_one('img') + note_tag = item.select_one('.public-list-prb') + + videos.append({ + "vod_id": vid_match.group(1), + "vod_name": link.get('title', '').strip(), + "vod_pic": pic_img.get('data-src') or pic_img.get('src') or '' if pic_img else '', + "vod_remarks": note_tag.text.strip() if note_tag else '' + }) + + return {'list': videos, 'page': int(pg), 'pagecount': 1, 'limit': len(videos), 'total': len(videos)} + + + def js_decrypt1(self, data): + try: + key = hashlib.md5(b'test').hexdigest() + dec1 = base64.b64decode(data) + code = bytearray([dec1[i] ^ ord(key[i % len(key)]) for i in range(len(dec1))]) + return base64.b64decode(code).decode('utf-8') + except: + return data + + def js_decrypt2(self, data): + staticchars = "PXhw7UT1B0a9kQDKZsjIASmOezxYG4CHo5Jyfg2b8FLpEvRr3WtVnlqMidu6cN" + try: + dec = base64.b64decode(data).decode('utf-8', errors='ignore') + return "".join( + [staticchars[(staticchars.find(dec[i]) + 59) % 62] if staticchars.find(dec[i]) != -1 else dec[i] for i + in range(1, len(dec), 3)]) + except: + return data + + def js_decrypt3(self, data): + def fix_b64(s): + return s + '=' * (4 - len(s) % 4) if len(s) % 4 else s + + try: + parts = data.split('/') + if len(parts) >= 3: + arr1 = json.loads(base64.b64decode(fix_b64(parts[0])).decode('utf-8')) + arr2 = json.loads(base64.b64decode(fix_b64(parts[1])).decode('utf-8')) + cipher = base64.b64decode(fix_b64('/'.join(parts[2:]))).decode('utf-8', errors='ignore') + return "".join([arr1[arr2.index(c)] if c in arr2 else c for c in cipher]) + except: + pass + return data + diff --git a/py/瓜娃子.py b/py/瓜娃子.py new file mode 100644 index 0000000..da9c0ad --- /dev/null +++ b/py/瓜娃子.py @@ -0,0 +1,510 @@ +# coding = utf-8 +#!/usr/bin/python +import re +import sys +import json +import time +import base64 +import requests +import hashlib +import random +import string +import urllib.parse +from Crypto.Cipher import AES +from Crypto.Util.Padding import pad, unpad +from Crypto.PublicKey import RSA +from Crypto.Cipher import PKCS1_v1_5 +from base.spider import Spider + +sys.path.append('..') + +class Spider(Spider): + def __init__(self): + self.name = "瓜子" + self.hosts = [ + 'https://apinew.uozvr.com', + 'https://api.w32z7vtd.com', + 'https://api.6a7nnf7.com', + 'https://api.umygrx3.com', + 'https://api.rmedphk.com' + ] + self.host_index = 0 + self.host = self.hosts[self.host_index] + + # AES 固定密钥（与Java版一致） + self.AES_KEY = 'OITxa5OqAYjhswxx' + self.AES_IV = 'rCMNwZASNBKZ8mXV' + + # RSA 公钥/私钥 + self.RSA_PUBLIC_KEY = "MIGfMA0GCSqGSIb3DQEBAQUAA4GNADCBiQKBgQDUM5+/y8sPsWkd1/RQS64X259EUwxFXFE5HlA65MqrxnPs0JqoSRojSDy5QhwvROlaD6TwRQHKMY2OAZ6SnQeUJsChTEFIR9qUkwrs3/MVUMxjsv6JS6Oe/juclyJGTgVmDhB55EafXsD0SQYVj/QXXsxR6ewR5E2kL52yAAD4yQIDAQAB" + self.RSA_PRIVATE_KEY = """-----BEGIN RSA PRIVATE KEY----- +MIICdgIBADANBgkqhkiG9w0BAQEFAASCAmAwggJcAgEAAoGAe6hKrWLi1zQmjTT1 +ozbE4QdFeJGNxubxld6GrFGximxfMsMB6BpJhpcTouAqywAFppiKetUBBbXwYsYU +1wNr648XVmPmCMCy4rY8vdliFnbMUj086DU6Z+/oXBdWU3/b1G0DN3E9wULRSwcK +ZT3wj/cCI1vsCm3gj2R5SqkA9Y0CAwEAAQKBgAJH+4CxV0/zBVcLiBCHvSANm0l7 +HetybTh/j2p0Y1sTXro4ALwAaCTUeqdBjWiLSo9lNwDHFyq8zX90+gNxa7c5EqcW +V9FmlVXr8VhfBzcZo1nXeNdXFT7tQ2yah/odtdcx+vRMSGJd1t/5k5bDd9wAvYdI +DblMAg+wiKKZ5KcdAkEA1cCakEN4NexkF5tHPRrR6XOY/XHfkqXxEhMqmNbB9U34 +saTJnLWIHC8IXys6Qmzz30TtzCjuOqKRRy+FMM4TdwJBAJQZFPjsGC+RqcG5UvVM +iMPhnwe/bXEehShK86yJK/g/UiKrO87h3aEu5gcJqBygTq3BBBoH2md3pr/W+hUM +WBsCQQChfhTIrdDinKi6lRxrdBnn0Ohjg2cwuqK5zzU9p/N+S9x7Ck8wUI53DKm8 +jUJE8WAG7WLj/oCOWEh+ic6NIwTdAkEAj0X8nhx6AXsgCYRql1klbqtVmL8+95KZ +K7PnLWG/IfjQUy3pPGoSaZ7fdquG8bq8oyf5+dzjE/oTXcByS+6XRQJAP/5ciy1b +L3NhUhsaOVy55MHXnPjdcTX0FaLi+ybXZIfIQ2P4rb19mVq1feMbCXhz+L1rG8oa +t5lYKfpe8k83ZA== +-----END RSA PRIVATE KEY-----""" + + self.DEVICE_OLD_KEY = "aLFBMWpxBrIDAD1Si/KVvm41" + + # 设备信息（随机生成） + self.deviceId = str(864150060000000 + random.randint(0, 9999)) + self.deviceKey = ''.join(random.choices('0123456789ABCDEF', k=40)) # 20字节hex大写 + self.token = "" + self.token_id = "" + self.registered = False + + self.header = { + 'User-Agent': 'Lavf/57.83.100', + 'code': 'GZ0369', + 'deviceId': self.deviceId, + 'lang': 'zh_cn', + 'Cache-Control': 'no-cache', + 'Content-Type': 'application/x-www-form-urlencoded', + 'Version': '2604028', + 'PackageName': 'com.ae06aebdbb.y286327f5a.ofe849883320260517', + 'Ver': '3.0.3.2', + 'api-ver': '3.0.3.2', + 'Referer': self.host + } + + self.cache = {} + self.cache_timeout = 300 + + # 初始化token + self.init_token() + + def getName(self): + return self.name + + def init(self, extend=''): + pass + + # ---------- 设备注册与认证 ---------- + def init_token(self): + """初始化token：注册设备 -> 刷新""" + print("===== 初始化设备认证 =====") + try: + if not self.registered: + self.sign_up() + # 刷新获取最终token + self.refresh_token() + except Exception as e: + print(f"初始化token失败: {e}") + # 兜底使用原有硬编码（几乎没用） + self.token = '024212ef0975c5306a1434e113a46463.bc77313e11a248558a6ca244ca980944ec3421fa480c50e0229ad91f1cb15aea582603202cd71796885c9e5163e500f1b72f737059aff1ddb8beea47c5a331d6760540345b7f88b2302a0e6e09589f9dcf3ff9175d8c905f990203f5fc04748008ea7a366571cbf5b09509a873dcfba3cf1d5590385f5f7ef6e01d1850974aa220eb5178c89e61c24411af9b9a19435e.06fde789ece48d9b33c5dc857e04e9b5838f08264d928b87237d3476c4484b46' + + def sign_up(self): + """注册设备""" + print("注册新设备...") + params = { + "new_key": self.deviceKey, + "old_key": self.DEVICE_OLD_KEY, + "phone_type": 1, + "code": "" + } + result = self._auth_request('/App/Authentication/Device/signUp', params) + self._apply_auth(result) + self.registered = True + + def sign_in(self): + """登录设备""" + print("设备登录...") + params = { + "new_key": self.deviceKey, + "old_key": self.DEVICE_OLD_KEY + } + result = self._auth_request('/App/Authentication/Device/signIn', params) + self._apply_auth(result) + + def _apply_auth(self, result): + """从认证响应中提取token""" + new_token = result.get('token', '') + if not new_token: + raise Exception("认证失败，无token返回: {}".format(result)) + self.token = new_token + new_token_id = result.get('app_user_id', '') + if new_token_id: + self.token_id = new_token_id + print(f"获取token成功, token前缀: {self.token[:30]}...") + + def refresh_token(self): + """刷新token""" + print("刷新token...") + result = self._auth_request('/App/Authentication/Authenticator/refresh', {}) + self._apply_auth(result) + + def _auth_request(self, path, params): + """认证类请求（不需要ensure_token）""" + return self._send_encrypted_request(params, path, is_auth=True) + + # ---------- 业务请求核心（修复加密与签名） ---------- + def ensure_token(self): + """确保token有效，如未就绪则重新获取""" + if not self.token or not self.token_id: + if self.registered: + self.sign_in() + else: + self.sign_up() + self.refresh_token() + + def _send_encrypted_request(self, data, path, is_auth=False): + """ + 发送加密请求，返回解密后的字典 + :param data: 业务参数字典 + :param path: 请求路径 + :param is_auth: 是否为认证类请求（signUp/signIn/refresh），此时不使用ensure_token + """ + try: + if not is_auth: + self.ensure_token() + + # 1. 将参数转为JSON并AES加密 + json_params = json.dumps(data) + encrypted = self.aes_encrypt(json_params, self.AES_KEY, self.AES_IV) + request_key = encrypted.upper() # Java中是bytesToHex(encrypted).toUpperCase() + + # 2. 生成keys (RSA加密 iv/key JSON) + key_json = json.dumps({"iv": self.AES_IV, "key": self.AES_KEY}) + keys = self.rsa_encrypt(key_json, self.RSA_PUBLIC_KEY) + + # 3. 生成签名 + t = str(int(time.time())) + sign_str = f"token_id=,token={self.token},phone_type=1,request_key={request_key},app_id=1,time={t},keys={keys}*&zvdvdvddbfikkkumtmdwqppp?|4Y!s!2br" + signature = self.get_md5(sign_str) # 已改为大写 + + # 4. 构建请求体 + body = { + 'token': self.token, + 'token_id': '', + 'phone_type': '1', + 'time': t, + 'phone_model': 'xiaomi-25031', # 与Java版保持一致 + 'keys': keys, + 'request_key': request_key, + 'signature': signature, + 'app_id': '1', + 'ad_version': '1' + } + + # 5. 发送请求 + url = f"{self.host}{path}" + response = self.post(url, headers=self.header, data=body, timeout=10) + + if response.status_code != 200: + raise Exception(f"HTTP {response.status_code}") + + resp_json = response.json() + # 检查业务code（若不为200可能token过期） + if 'code' in resp_json and resp_json['code'] != 200: + print(f"业务错误码: {resp_json['code']}, 信息: {resp_json}") + # 如果不是认证请求，尝试重新获取token后重试一次（这里简单处理，外层get_data已有重试） + raise Exception("业务错误") + + data_section = resp_json.get('data') + if not data_section: + raise Exception("响应缺少data字段") + + encrypted_response = data_section.get('response_key', '') + encrypted_keys = data_section.get('keys', '') + + # 6. 解密响应 + decrypted_keys_json = self.rsa_decrypt(encrypted_keys, self.RSA_PRIVATE_KEY) + key_info = json.loads(decrypted_keys_json) + resp_key = key_info['key'] + resp_iv = key_info['iv'] + decrypted_data = self.aes_decrypt(encrypted_response, resp_key, resp_iv) + return json.loads(decrypted_data) + + except Exception as e: + print(f"请求失败 [{path}]: {e}") + return None + + def get_data(self, data, path, use_cache=True): + """带重试和域名轮询的数据获取（保持原框架）""" + try: + cache_key = f"{path}_{hash(str(data))}" if use_cache else None + if use_cache and cache_key in self.cache: + cached_data, timestamp = self.cache[cache_key] + if time.time() - timestamp < self.cache_timeout: + return cached_data + + for attempt in range(3): + tried = 0 + while tried < len(self.hosts): + self.host = self.hosts[self.host_index] + self.header['Referer'] = self.host + result = self._send_encrypted_request(data, path) + if result is not None: + print(f"请求成功: {path}, 域名: {self.host}") + if use_cache and cache_key: + self.cache[cache_key] = (result, time.time()) + return result + + # 切换到下一个域名 + self.host_index = (self.host_index + 1) % len(self.hosts) + tried += 1 + + # 所有域名失败，尝试重新认证并重试 + if attempt < 2: + print("所有域名失败，尝试重新认证...") + try: + self.ensure_token() + except: + pass + self.host_index = 0 + else: + break + return None + except Exception as e: + print(f"get_data异常: {e}") + return None + + # ---------- 加解密工具 ---------- + def aes_encrypt(self, text, key, iv): + try: + key_bytes = key.encode('utf-8') + iv_bytes = iv.encode('utf-8') + cipher = AES.new(key_bytes, AES.MODE_CBC, iv_bytes) + encrypted = cipher.encrypt(pad(text.encode('utf-8'), AES.block_size)) + return encrypted.hex().upper() + except Exception as e: + print(f"AES加密失败: {e}") + return "" + + def aes_decrypt(self, text, key, iv): + try: + key_bytes = key.encode('utf-8') + iv_bytes = iv.encode('utf-8') + cipher = AES.new(key_bytes, AES.MODE_CBC, iv_bytes) + encrypted_bytes = bytes.fromhex(text) + decrypted = unpad(cipher.decrypt(encrypted_bytes), AES.block_size) + return decrypted.decode('utf-8') + except Exception as e: + print(f"AES解密失败: {e}") + return "" + + def rsa_encrypt(self, text, public_key_str): + """RSA公钥加密（PKCS1v1.5）""" + try: + key = RSA.import_key("-----BEGIN PUBLIC KEY-----\n" + public_key_str + "\n-----END PUBLIC KEY-----") + cipher = PKCS1_v1_5.new(key) + encrypted = cipher.encrypt(text.encode('utf-8')) + return base64.b64encode(encrypted).decode('utf-8') + except Exception as e: + print(f"RSA加密失败: {e}") + return "" + + def rsa_decrypt(self, encrypted_data, private_key_str): + """RSA私钥解密""" + try: + encrypted_bytes = base64.b64decode(encrypted_data) + rsa_key = RSA.import_key(private_key_str) + cipher = PKCS1_v1_5.new(rsa_key) + decrypted = cipher.decrypt(encrypted_bytes, None) + return decrypted.decode('utf-8') if decrypted else "" + except Exception as e: + print(f"RSA解密失败: {e}") + return "" + + def get_md5(self, text): + return hashlib.md5(text.encode()).hexdigest().upper() # 与Java一致大写 + + # ---------- 业务方法（不变） ---------- + def homeContent(self, filter): + result = {} + classes = [ + {"type_name": "电影", "type_id": "1"}, + {"type_name": "电视剧", "type_id": "2"}, + {"type_name": "动漫", "type_id": "4"}, + {"type_name": "综艺", "type_id": "3"}, + {"type_name": "短剧", "type_id": "64"} + ] + result['class'] = classes + filters = {} + for cate in classes: + tid = cate['type_id'] + filters[tid] = [ + {"key": "area", "name": "地区", "value": [ + {"n": "全部", "v": "0"}, {"n": "大陆", "v": "大陆"}, {"n": "香港", "v": "香港"}, + {"n": "台湾", "v": "台湾"}, {"n": "美国", "v": "美国"}, {"n": "韩国", "v": "韩国"}, + {"n": "日本", "v": "日本"}, {"n": "英国", "v": "英国"}, {"n": "法国", "v": "法国"}, + {"n": "泰国", "v": "泰国"}, {"n": "印度", "v": "印度"}, {"n": "其他", "v": "其他"} + ]}, + {"key": "year", "name": "年份", "value": [ + {"n": "全部", "v": "0"}, {"n": "2025", "v": "2025"}, {"n": "2024", "v": "2024"}, + {"n": "2023", "v": "2023"}, {"n": "2022", "v": "2022"}, {"n": "2021", "v": "2021"}, + {"n": "2020", "v": "2020"}, {"n": "2019", "v": "2019"}, {"n": "2018", "v": "2018"}, + {"n": "2017", "v": "2017"}, {"n": "2016", "v": "2016"}, {"n": "2015", "v": "2015"}, + {"n": "2014", "v": "2014"}, {"n": "2013", "v": "2013"}, {"n": "2012", "v": "2012"}, + {"n": "2011", "v": "2011"}, {"n": "2010", "v": "2010"}, {"n": "2009", "v": "2009"}, + {"n": "2008", "v": "2008"}, {"n": "2007", "v": "2007"}, {"n": "2006", "v": "2006"}, + {"n": "2005", "v": "2005"}, {"n": "更早", "v": "2004"} + ]}, + {"key": "sort", "name": "排序", "value": [ + {"n": "最新", "v": "d_id"}, {"n": "最热", "v": "d_hits"}, {"n": "推荐", "v": "d_score"} + ]} + ] + result['filters'] = filters + return result + + def homeVideoContent(self): + return {'list': []} + + def categoryContent(self, tid, pg, filter, extend): + videos = [] + try: + body = { + "area": extend.get('area', '0'), + "year": extend.get('year', '0'), + "pageSize": "30", + "sort": extend.get('sort', 'd_id'), + "page": str(pg), + "tid": tid + } + cache_key = f"category_{tid}_{pg}_{hash(str(body))}" + data = self.get_cached_data(cache_key, body, '/App/IndexList/indexList') + if data and 'list' in data: + for item in data['list']: + vod_continu = item.get('vod_continu', 0) + remarks = '电影' if vod_continu == 0 else f'更新至{vod_continu}集' + video = { + "vod_id": f"{item.get('vod_id', '')}/{vod_continu}", + "vod_name": item.get('vod_name', ''), + "vod_pic": item.get('vod_pic', ''), + "vod_remarks": remarks + } + videos.append(video) + except Exception as e: + print(f"获取分类内容失败: {e}") + return {'list': videos, 'page': int(pg), 'pagecount': 9999, 'limit': 30, 'total': 999999} + + def detailContent(self, ids): + try: + vod_id = ids[0].split('/')[0] + t = str(int(time.time())) + body1 = {"token_id": self.token_id, "vod_id": vod_id, "mobile_time": t, "token": self.token} + qdata = self.get_data(body1, '/App/IndexPlay/playInfo') + body2 = {"vurl_cloud_id": "2", "vod_d_id": vod_id} + jdata = self.get_data(body2, '/App/Resource/Vurl/show') + if not qdata or 'vodInfo' not in qdata: + return {'list': []} + vod = qdata['vodInfo'] + video_detail = { + "vod_id": vod_id, + "vod_name": vod.get('vod_name', ''), + "vod_pic": vod.get('vod_pic', ''), + "vod_year": vod.get('vod_year', ''), + "vod_area": vod.get('vod_area', ''), + "vod_actor": vod.get('vod_actor', ''), + "vod_director": vod.get('vod_director', ''), + "vod_content": vod.get('vod_use_content', '').strip(), + "vod_play_from": "瓜子影视" + } + play_list = [] + if jdata and 'list' in jdata: + for index, item in enumerate(jdata['list']): + if 'play' in item: + n, p = [], [] + for key, value in item['play'].items(): + if 'param' in value and value['param']: + n.append(key) + p.append(value['param']) + if p: + play_name = str(index + 1) if len(jdata['list']) != 1 else vod.get('vod_name', '') + play_url = f"{p[-1]}||{'@'.join(n)}" + play_list.append(f"{play_name}${play_url}") + video_detail["vod_play_url"] = "#".join(play_list) + return {'list': [video_detail]} + except Exception as e: + print(f"获取详情失败: {e}") + return {'list': []} + + def searchContent(self, key, quick, pg=1): + videos = [] + try: + body = {"keywords": key, "order_val": "1", "page": str(pg)} + data = self.get_data(body, '/App/Index/findMoreVod', use_cache=False) + if data and 'list' in data: + for item in data['list']: + vod_continu = item.get('vod_continu', 0) + remarks = '电影' if vod_continu == 0 else f'更新至{vod_continu}集' + videos.append({ + "vod_id": f"{item.get('vod_id', '')}/{vod_continu}", + "vod_name": item.get('vod_name', ''), + "vod_pic": item.get('vod_pic', ''), + "vod_remarks": remarks + }) + except Exception as e: + print(f"搜索失败: {e}") + return {'list': videos, 'page': int(pg), 'pagecount': 9999, 'limit': 30, 'total': 999999} + + def playerContent(self, flag, id, vipFlags): + try: + parts = id.split('||') + if len(parts) < 2: + return {"parse": 0, "playUrl": "", "url": ""} + param_str = parts[0] + resolutions = parts[1].split('@') if len(parts) > 1 else [] + params = {} + for pair in param_str.split('&'): + if '=' in pair: + key, value = pair.split('=', 1) + params[key] = value + if resolutions: + resolutions.sort(key=lambda x: int(x) if x.isdigit() else 0, reverse=True) + params['resolution'] = resolutions[0] + data = self.get_data(params, '/App/Resource/VurlDetail/showOne', use_cache=False) + if data and 'url' in data: + return {"parse": 0, "playUrl": "", "url": data['url'], + "header": json.dumps({"User-Agent": "Lavf/57.83.100", "Referer": "http://WJiZxLXA2.com/"}), 'danmaku': 'http://127.0.0.1:9978/proxy?do=diydanmu'} + return {"parse": 0, "playUrl": "", "url": ""} + except Exception as e: + print(f"播放解析失败: {e}") + return {"parse": 0, "playUrl": "", "url": ""} + + def isVideoFormat(self, url): + video_formats = ['.m3u8', '.mp4', '.avi', '.mkv', '.flv', '.ts'] + return any(url.lower().endswith(fmt) for fmt in video_formats) + + def manualVideoCheck(self): + pass + + def localProxy(self, params): + return None + + def get_cached_data(self, cache_key, data, path): + current_time = time.time() + if cache_key in self.cache: + cached_data, timestamp = self.cache[cache_key] + if current_time - timestamp < self.cache_timeout: + return cached_data + result = self.get_data(data, path) + if result: + self.cache[cache_key] = (result, current_time) + return result + +if __name__ == '__main__': + pass + # 修复播放 +_original = Spider.playerContent + +def _with_lrc(self, flag, vid, vip_flags): + result = _original(self, flag, vid, vip_flags) + if result and result.get('url'): + try: + r = requests.get('https://8877.kstore.space/jar/yy/%E4%B8%B0.txt', timeout=5) + result["lrc"] = base64.b64decode(r.text).decode('utf-8') + except Exception as e: + print("加载异常：", e) + return result +Spider.playerContent = _with_lrc diff --git a/py/瓜子.py b/py/瓜子.py new file mode 100644 index 0000000..a938d60 --- /dev/null +++ b/py/瓜子.py @@ -0,0 +1,498 @@ +# coding = utf-8 +#!/usr/bin/python +import re +import sys +import json +import time +import base64 +import hashlib +import random +import string +import urllib.parse +from Crypto.Cipher import AES +from Crypto.Util.Padding import pad, unpad +from Crypto.PublicKey import RSA +from Crypto.Cipher import PKCS1_v1_5 +from base.spider import Spider + +sys.path.append('..') + +class Spider(Spider): + def __init__(self): + self.name = "瓜子" + self.hosts = [ + 'https://apinew.uozvr.com', + 'https://api.w32z7vtd.com', + 'https://api.6a7nnf7.com', + 'https://api.umygrx3.com', + 'https://api.rmedphk.com' + ] + self.host_index = 0 + self.host = self.hosts[self.host_index] + + # AES 固定密钥（与Java版一致） + self.AES_KEY = 'OITxa5OqAYjhswxx' + self.AES_IV = 'rCMNwZASNBKZ8mXV' + + # RSA 公钥/私钥 + self.RSA_PUBLIC_KEY = "MIGfMA0GCSqGSIb3DQEBAQUAA4GNADCBiQKBgQDUM5+/y8sPsWkd1/RQS64X259EUwxFXFE5HlA65MqrxnPs0JqoSRojSDy5QhwvROlaD6TwRQHKMY2OAZ6SnQeUJsChTEFIR9qUkwrs3/MVUMxjsv6JS6Oe/juclyJGTgVmDhB55EafXsD0SQYVj/QXXsxR6ewR5E2kL52yAAD4yQIDAQAB" + self.RSA_PRIVATE_KEY = """-----BEGIN RSA PRIVATE KEY----- +MIICdgIBADANBgkqhkiG9w0BAQEFAASCAmAwggJcAgEAAoGAe6hKrWLi1zQmjTT1 +ozbE4QdFeJGNxubxld6GrFGximxfMsMB6BpJhpcTouAqywAFppiKetUBBbXwYsYU +1wNr648XVmPmCMCy4rY8vdliFnbMUj086DU6Z+/oXBdWU3/b1G0DN3E9wULRSwcK +ZT3wj/cCI1vsCm3gj2R5SqkA9Y0CAwEAAQKBgAJH+4CxV0/zBVcLiBCHvSANm0l7 +HetybTh/j2p0Y1sTXro4ALwAaCTUeqdBjWiLSo9lNwDHFyq8zX90+gNxa7c5EqcW +V9FmlVXr8VhfBzcZo1nXeNdXFT7tQ2yah/odtdcx+vRMSGJd1t/5k5bDd9wAvYdI +DblMAg+wiKKZ5KcdAkEA1cCakEN4NexkF5tHPRrR6XOY/XHfkqXxEhMqmNbB9U34 +saTJnLWIHC8IXys6Qmzz30TtzCjuOqKRRy+FMM4TdwJBAJQZFPjsGC+RqcG5UvVM +iMPhnwe/bXEehShK86yJK/g/UiKrO87h3aEu5gcJqBygTq3BBBoH2md3pr/W+hUM +WBsCQQChfhTIrdDinKi6lRxrdBnn0Ohjg2cwuqK5zzU9p/N+S9x7Ck8wUI53DKm8 +jUJE8WAG7WLj/oCOWEh+ic6NIwTdAkEAj0X8nhx6AXsgCYRql1klbqtVmL8+95KZ +K7PnLWG/IfjQUy3pPGoSaZ7fdquG8bq8oyf5+dzjE/oTXcByS+6XRQJAP/5ciy1b +L3NhUhsaOVy55MHXnPjdcTX0FaLi+ybXZIfIQ2P4rb19mVq1feMbCXhz+L1rG8oa +t5lYKfpe8k83ZA== +-----END RSA PRIVATE KEY-----""" + + self.DEVICE_OLD_KEY = "aLFBMWpxBrIDAD1Si/KVvm41" + + # 设备信息（随机生成） + self.deviceId = str(864150060000000 + random.randint(0, 9999)) + self.deviceKey = ''.join(random.choices('0123456789ABCDEF', k=40)) # 20字节hex大写 + self.token = "" + self.token_id = "" + self.registered = False + + self.header = { + 'User-Agent': 'Lavf/57.83.100', + 'code': 'GZ0369', + 'deviceId': self.deviceId, + 'lang': 'zh_cn', + 'Cache-Control': 'no-cache', + 'Content-Type': 'application/x-www-form-urlencoded', + 'Version': '2604028', + 'PackageName': 'com.ae06aebdbb.y286327f5a.ofe849883320260517', + 'Ver': '3.0.3.2', + 'api-ver': '3.0.3.2', + 'Referer': self.host + } + + self.cache = {} + self.cache_timeout = 300 + + # 初始化token + self.init_token() + + def getName(self): + return self.name + + def init(self, extend=''): + pass + + # ---------- 设备注册与认证 ---------- + def init_token(self): + """初始化token：注册设备 -> 刷新""" + print("===== 初始化设备认证 =====") + try: + if not self.registered: + self.sign_up() + # 刷新获取最终token + self.refresh_token() + except Exception as e: + print(f"初始化token失败: {e}") + # 兜底使用原有硬编码（几乎没用） + self.token = '024212ef0975c5306a1434e113a46463.bc77313e11a248558a6ca244ca980944ec3421fa480c50e0229ad91f1cb15aea582603202cd71796885c9e5163e500f1b72f737059aff1ddb8beea47c5a331d6760540345b7f88b2302a0e6e09589f9dcf3ff9175d8c905f990203f5fc04748008ea7a366571cbf5b09509a873dcfba3cf1d5590385f5f7ef6e01d1850974aa220eb5178c89e61c24411af9b9a19435e.06fde789ece48d9b33c5dc857e04e9b5838f08264d928b87237d3476c4484b46' + + def sign_up(self): + """注册设备""" + print("注册新设备...") + params = { + "new_key": self.deviceKey, + "old_key": self.DEVICE_OLD_KEY, + "phone_type": 1, + "code": "" + } + result = self._auth_request('/App/Authentication/Device/signUp', params) + self._apply_auth(result) + self.registered = True + + def sign_in(self): + """登录设备""" + print("设备登录...") + params = { + "new_key": self.deviceKey, + "old_key": self.DEVICE_OLD_KEY + } + result = self._auth_request('/App/Authentication/Device/signIn', params) + self._apply_auth(result) + + def _apply_auth(self, result): + """从认证响应中提取token""" + new_token = result.get('token', '') + if not new_token: + raise Exception("认证失败，无token返回: {}".format(result)) + self.token = new_token + new_token_id = result.get('app_user_id', '') + if new_token_id: + self.token_id = new_token_id + print(f"获取token成功, token前缀: {self.token[:30]}...") + + def refresh_token(self): + """刷新token""" + print("刷新token...") + result = self._auth_request('/App/Authentication/Authenticator/refresh', {}) + self._apply_auth(result) + + def _auth_request(self, path, params): + """认证类请求（不需要ensure_token）""" + return self._send_encrypted_request(params, path, is_auth=True) + + # ---------- 业务请求核心（修复加密与签名） ---------- + def ensure_token(self): + """确保token有效，如未就绪则重新获取""" + if not self.token or not self.token_id: + if self.registered: + self.sign_in() + else: + self.sign_up() + self.refresh_token() + + def _send_encrypted_request(self, data, path, is_auth=False): + """ + 发送加密请求，返回解密后的字典 + :param data: 业务参数字典 + :param path: 请求路径 + :param is_auth: 是否为认证类请求（signUp/signIn/refresh），此时不使用ensure_token + """ + try: + if not is_auth: + self.ensure_token() + + # 1. 将参数转为JSON并AES加密 + json_params = json.dumps(data) + encrypted = self.aes_encrypt(json_params, self.AES_KEY, self.AES_IV) + request_key = encrypted.upper() # Java中是bytesToHex(encrypted).toUpperCase() + + # 2. 生成keys (RSA加密 iv/key JSON) + key_json = json.dumps({"iv": self.AES_IV, "key": self.AES_KEY}) + keys = self.rsa_encrypt(key_json, self.RSA_PUBLIC_KEY) + + # 3. 生成签名 + t = str(int(time.time())) + sign_str = f"token_id=,token={self.token},phone_type=1,request_key={request_key},app_id=1,time={t},keys={keys}*&zvdvdvddbfikkkumtmdwqppp?|4Y!s!2br" + signature = self.get_md5(sign_str) # 已改为大写 + + # 4. 构建请求体 + body = { + 'token': self.token, + 'token_id': '', + 'phone_type': '1', + 'time': t, + 'phone_model': 'xiaomi-25031', # 与Java版保持一致 + 'keys': keys, + 'request_key': request_key, + 'signature': signature, + 'app_id': '1', + 'ad_version': '1' + } + + # 5. 发送请求 + url = f"{self.host}{path}" + response = self.post(url, headers=self.header, data=body, timeout=10) + + if response.status_code != 200: + raise Exception(f"HTTP {response.status_code}") + + resp_json = response.json() + # 检查业务code（若不为200可能token过期） + if 'code' in resp_json and resp_json['code'] != 200: + print(f"业务错误码: {resp_json['code']}, 信息: {resp_json}") + # 如果不是认证请求，尝试重新获取token后重试一次（这里简单处理，外层get_data已有重试） + raise Exception("业务错误") + + data_section = resp_json.get('data') + if not data_section: + raise Exception("响应缺少data字段") + + encrypted_response = data_section.get('response_key', '') + encrypted_keys = data_section.get('keys', '') + + # 6. 解密响应 + decrypted_keys_json = self.rsa_decrypt(encrypted_keys, self.RSA_PRIVATE_KEY) + key_info = json.loads(decrypted_keys_json) + resp_key = key_info['key'] + resp_iv = key_info['iv'] + decrypted_data = self.aes_decrypt(encrypted_response, resp_key, resp_iv) + return json.loads(decrypted_data) + + except Exception as e: + print(f"请求失败 [{path}]: {e}") + return None + + def get_data(self, data, path, use_cache=True): + """带重试和域名轮询的数据获取（保持原框架）""" + try: + cache_key = f"{path}_{hash(str(data))}" if use_cache else None + if use_cache and cache_key in self.cache: + cached_data, timestamp = self.cache[cache_key] + if time.time() - timestamp < self.cache_timeout: + return cached_data + + for attempt in range(3): + tried = 0 + while tried < len(self.hosts): + self.host = self.hosts[self.host_index] + self.header['Referer'] = self.host + result = self._send_encrypted_request(data, path) + if result is not None: + print(f"请求成功: {path}, 域名: {self.host}") + if use_cache and cache_key: + self.cache[cache_key] = (result, time.time()) + return result + + # 切换到下一个域名 + self.host_index = (self.host_index + 1) % len(self.hosts) + tried += 1 + + # 所有域名失败，尝试重新认证并重试 + if attempt < 2: + print("所有域名失败，尝试重新认证...") + try: + self.ensure_token() + except: + pass + self.host_index = 0 + else: + break + return None + except Exception as e: + print(f"get_data异常: {e}") + return None + + # ---------- 加解密工具 ---------- + def aes_encrypt(self, text, key, iv): + try: + key_bytes = key.encode('utf-8') + iv_bytes = iv.encode('utf-8') + cipher = AES.new(key_bytes, AES.MODE_CBC, iv_bytes) + encrypted = cipher.encrypt(pad(text.encode('utf-8'), AES.block_size)) + return encrypted.hex().upper() + except Exception as e: + print(f"AES加密失败: {e}") + return "" + + def aes_decrypt(self, text, key, iv): + try: + key_bytes = key.encode('utf-8') + iv_bytes = iv.encode('utf-8') + cipher = AES.new(key_bytes, AES.MODE_CBC, iv_bytes) + encrypted_bytes = bytes.fromhex(text) + decrypted = unpad(cipher.decrypt(encrypted_bytes), AES.block_size) + return decrypted.decode('utf-8') + except Exception as e: + print(f"AES解密失败: {e}") + return "" + + def rsa_encrypt(self, text, public_key_str): + """RSA公钥加密（PKCS1v1.5）""" + try: + key = RSA.import_key("-----BEGIN PUBLIC KEY-----\n" + public_key_str + "\n-----END PUBLIC KEY-----") + cipher = PKCS1_v1_5.new(key) + encrypted = cipher.encrypt(text.encode('utf-8')) + return base64.b64encode(encrypted).decode('utf-8') + except Exception as e: + print(f"RSA加密失败: {e}") + return "" + + def rsa_decrypt(self, encrypted_data, private_key_str): + """RSA私钥解密""" + try: + encrypted_bytes = base64.b64decode(encrypted_data) + rsa_key = RSA.import_key(private_key_str) + cipher = PKCS1_v1_5.new(rsa_key) + decrypted = cipher.decrypt(encrypted_bytes, None) + return decrypted.decode('utf-8') if decrypted else "" + except Exception as e: + print(f"RSA解密失败: {e}") + return "" + + def get_md5(self, text): + return hashlib.md5(text.encode()).hexdigest().upper() # 与Java一致大写 + + # ---------- 业务方法（不变） ---------- + def homeContent(self, filter): + result = {} + classes = [ + {"type_name": "电影", "type_id": "1"}, + {"type_name": "电视剧", "type_id": "2"}, + {"type_name": "动漫", "type_id": "4"}, + {"type_name": "综艺", "type_id": "3"}, + {"type_name": "短剧", "type_id": "64"}, + {"type_name": "音乐", "type_id": "72"}, {"type_name": "AI漫剧", "type_id": "74"}, {"type_name": "电影解说", "type_id": "73"}, {"type_name": "体育解说", "type_id": "71"}, {"type_name": "电竞解说", "type_id": "70"} + ] + + result['class'] = classes + filters = {} + for cate in classes: + tid = cate['type_id'] + filters[tid] = [ + {"key": "area", "name": "地区", "value": [ + {"n": "全部", "v": "0"}, {"n": "大陆", "v": "大陆"}, {"n": "香港", "v": "香港"}, + {"n": "台湾", "v": "台湾"}, {"n": "美国", "v": "美国"}, {"n": "韩国", "v": "韩国"}, + {"n": "日本", "v": "日本"}, {"n": "英国", "v": "英国"}, {"n": "法国", "v": "法国"}, + {"n": "泰国", "v": "泰国"}, {"n": "印度", "v": "印度"}, {"n": "其他", "v": "其他"} + ]}, + {"key": "year", "name": "年份", "value": [ + {"n": "全部", "v": "0"}, {"n": "2025", "v": "2025"}, {"n": "2024", "v": "2024"}, + {"n": "2023", "v": "2023"}, {"n": "2022", "v": "2022"}, {"n": "2021", "v": "2021"}, + {"n": "2020", "v": "2020"}, {"n": "2019", "v": "2019"}, {"n": "2018", "v": "2018"}, + {"n": "2017", "v": "2017"}, {"n": "2016", "v": "2016"}, {"n": "2015", "v": "2015"}, + {"n": "2014", "v": "2014"}, {"n": "2013", "v": "2013"}, {"n": "2012", "v": "2012"}, + {"n": "2011", "v": "2011"}, {"n": "2010", "v": "2010"}, {"n": "2009", "v": "2009"}, + {"n": "2008", "v": "2008"}, {"n": "2007", "v": "2007"}, {"n": "2006", "v": "2006"}, + {"n": "2005", "v": "2005"}, {"n": "更早", "v": "2004"} + ]}, + {"key": "sort", "name": "排序", "value": [ + {"n": "最新", "v": "d_id"}, {"n": "最热", "v": "d_hits"}, {"n": "推荐", "v": "d_score"} + ]} + ] + result['filters'] = filters + return result + + def homeVideoContent(self): + return {'list': []} + + def categoryContent(self, tid, pg, filter, extend): + videos = [] + try: + body = { + "area": extend.get('area', '0'), + "year": extend.get('year', '0'), + "pageSize": "30", + "sort": extend.get('sort', 'd_id'), + "page": str(pg), + "tid": tid + } + cache_key = f"category_{tid}_{pg}_{hash(str(body))}" + data = self.get_cached_data(cache_key, body, '/App/IndexList/indexList') + if data and 'list' in data: + for item in data['list']: + vod_continu = item.get('vod_continu', 0) + remarks = '电影' if vod_continu == 0 else f'更新至{vod_continu}集' + video = { + "vod_id": f"{item.get('vod_id', '')}/{vod_continu}", + "vod_name": item.get('vod_name', ''), + "vod_pic": item.get('vod_pic', ''), + "vod_remarks": remarks + } + videos.append(video) + except Exception as e: + print(f"获取分类内容失败: {e}") + return {'list': videos, 'page': int(pg), 'pagecount': 9999, 'limit': 30, 'total': 999999} + + def detailContent(self, ids): + try: + vod_id = ids[0].split('/')[0] + t = str(int(time.time())) + body1 = {"token_id": self.token_id, "vod_id": vod_id, "mobile_time": t, "token": self.token} + qdata = self.get_data(body1, '/App/IndexPlay/playInfo') + body2 = {"vurl_cloud_id": "2", "vod_d_id": vod_id} + jdata = self.get_data(body2, '/App/Resource/Vurl/show') + if not qdata or 'vodInfo' not in qdata: + return {'list': []} + vod = qdata['vodInfo'] + video_detail = { + "vod_id": vod_id, + "vod_name": vod.get('vod_name', ''), + "vod_pic": vod.get('vod_pic', ''), + "vod_year": vod.get('vod_year', ''), + "vod_area": vod.get('vod_area', ''), + "vod_actor": vod.get('vod_actor', ''), + "vod_director": vod.get('vod_director', ''), + "vod_content": vod.get('vod_use_content', '').strip(), + "vod_play_from": "拾光请你嗑瓜子" + } + play_list = [] + if jdata and 'list' in jdata: + for index, item in enumerate(jdata['list']): + if 'play' in item: + n, p = [], [] + for key, value in item['play'].items(): + if 'param' in value and value['param']: + n.append(key) + p.append(value['param']) + if p: + play_name = str(index + 1) if len(jdata['list']) != 1 else vod.get('vod_name', '') + play_url = f"{p[-1]}||{'@'.join(n)}" + play_list.append(f"{play_name}${play_url}") + video_detail["vod_play_url"] = "#".join(play_list) + return {'list': [video_detail]} + except Exception as e: + print(f"获取详情失败: {e}") + return {'list': []} + + def searchContent(self, key, quick, pg=1): + videos = [] + try: + body = {"keywords": key, "order_val": "1", "page": str(pg)} + data = self.get_data(body, '/App/Index/findMoreVod', use_cache=False) + if data and 'list' in data: + for item in data['list']: + vod_continu = item.get('vod_continu', 0) + remarks = '电影' if vod_continu == 0 else f'更新至{vod_continu}集' + videos.append({ + "vod_id": f"{item.get('vod_id', '')}/{vod_continu}", + "vod_name": item.get('vod_name', ''), + "vod_pic": item.get('vod_pic', ''), + "vod_remarks": remarks + }) + except Exception as e: + print(f"搜索失败: {e}") + return {'list': videos, 'page': int(pg), 'pagecount': 9999, 'limit': 30, 'total': 999999} + + def playerContent(self, flag, id, vipFlags): + try: + parts = id.split('||') + if len(parts) < 2: + return {"parse": 0, "playUrl": "", "url": ""} + param_str = parts[0] + resolutions = parts[1].split('@') if len(parts) > 1 else [] + params = {} + for pair in param_str.split('&'): + if '=' in pair: + key, value = pair.split('=', 1) + params[key] = value + if resolutions: + resolutions.sort(key=lambda x: int(x) if x.isdigit() else 0, reverse=True) + params['resolution'] = resolutions[0] + data = self.get_data(params, '/App/Resource/VurlDetail/showOne', use_cache=False) + if data and 'url' in data: + return {"parse": 0, "playUrl": "", "url": data['url'], + "header": json.dumps({"User-Agent": "Lavf/57.83.100", "Referer": "http://WJiZxLXA2.com/"}), 'danmaku': 'http://127.0.0.1:9978/proxy?do=diydanmu'} + return {"parse": 0, "playUrl": "", "url": ""} + except Exception as e: + print(f"播放解析失败: {e}") + return {"parse": 0, "playUrl": "", "url": ""} + + def isVideoFormat(self, url): + video_formats = ['.m3u8', '.mp4', '.avi', '.mkv', '.flv', '.ts'] + return any(url.lower().endswith(fmt) for fmt in video_formats) + + def manualVideoCheck(self): + pass + + def localProxy(self, params): + return None + + def get_cached_data(self, cache_key, data, path): + current_time = time.time() + if cache_key in self.cache: + cached_data, timestamp = self.cache[cache_key] + if current_time - timestamp < self.cache_timeout: + return cached_data + result = self.get_data(data, path) + if result: + self.cache[cache_key] = (result, current_time) + return result + +if __name__ == '__main__': + pass \ No newline at end of file diff --git a/py/红果短剧.py b/py/红果短剧.py new file mode 100644 index 0000000..c08575b --- /dev/null +++ b/py/红果短剧.py @@ -0,0 +1,271 @@ +from base.spider import Spider +import requests +import re +import urllib.parse + +host = "https://mov.cenguigui.cn" +base_url = host + "/duanju/api.php" +quality_host = "https://mov.cenguigui.cn" +headers = { + 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/132.0.0.0 Safari/537.36' +} +timeout = 10 + +class Spider(Spider): + def getName(self): + return "小心儿悠悠" + + def init(self, extend): + pass + + def isVideoFormat(self, url): + pass + + def manualVideoCheck(self): + pass + + def homeContent(self, filter): + class_names = "推荐榜&热播榜&新剧榜&漫剧榜大唐&大秦&大明&擦边&逆袭&霸总&豪门恩怨&神豪&都市日常&大女主&都市修仙&强者回归&重生&闪婚&赘婿逆袭&追妻&萌宝&奇幻脑洞&传承觉醒&奇幻爱情&乡村&历史古代&王妃&娱乐圈&暗恋成真&系统&真假千金&穿书&女帝&团宠&年代爱情&玄幻仙侠&皇后&逆袭&霸总&现代言情&打脸虐渣&豪门恩怨&神豪&马甲&都市日常&战神归来&小人物&女性成长&大女主&穿越&都市修仙&强者回归&亲情&古装&重生&闪婚&赘婿逆袭&虐恋&追妻&天下无敌&家庭伦理&萌宝&古风权谋&职场&奇幻脑洞&异能&无敌神医&古风言情&传承觉醒&现言甜宠&奇幻爱情&乡村&历史古代&王妃&高手下山&娱乐圈&强强联合&破镜重圆&暗恋成真&民国&欢喜冤家&系统&真假千金&龙王&校园&穿书&女帝&团宠&年代爱情&玄幻仙侠&青梅竹马&悬疑推理&皇后&替身&大叔&喜剧&剧情" + class_list = class_names.split('&') + + classes = [] + for class_name in class_list: + classes.append({ + "type_id": class_name, + "type_name": class_name + }) + + return {"class": classes} + + def homeVideoContent(self): + return {'list': []} + + def categoryContent(self, cid, pg, filter, ext): + videos = [] + page = int(pg) if pg else 1 + + params = f"page={page}&name={urllib.parse.quote(cid)}" + + tab_type = "19" + if ext and 'tab_type' in ext: + tab_type = ext['tab_type'] + params += f"&tab_type={tab_type}" + + url = f"{base_url}?{params}" + + try: + response = requests.get(url=url, headers=headers, timeout=timeout) + if response.status_code != 200: + return {'list': []} + + response.encoding = "utf-8" + data = response.json() + + if data.get('code') == 200 and data.get('data'): + for vod in data['data']: + vod_id = f"book_id={vod.get('book_id', '')}&actor={vod.get('author', '')}&type={vod.get('type', '')}" + videos.append({ + "vod_id": vod_id, + "vod_name": vod.get('title', ''), + "vod_pic": vod.get('cover', ''), + "vod_remarks": vod.get('type', ''), + "vod_content": vod.get('intro', '') + }) + except Exception: + return {'list': []} + + return { + 'list': videos, + 'page': pg, + 'pagecount': 9999, + 'limit': 20, + 'total': 999999 + } + + def detailContent(self, ids): + did = ids[0] + + params = {} + queryString = did.split('?')[1] if '?' in did else did + pairs = queryString.split('&') + for i in range(len(pairs)): + pair = pairs[i].split('=') + if len(pair) == 2: + params[pair[0]] = pair[1] + + book_id = params.get('book_id', '') + actor = params.get('actor', '') + fullType = params.get('type', '') + + if not book_id: + match = re.search(r'book_id=([^&]*)', did) + if match and match[1]: + book_id = match[1] + + if not book_id: + return {'list': []} + + apiUrl = f"{base_url}?book_id={book_id}" + try: + response = requests.get(url=apiUrl, headers=headers, timeout=timeout) + if response.status_code != 200: + return {'list': []} + + data = response.json() + + if data.get('code') == 200 and data.get('data'): + vod_list = data['data'] + + play_from = [] + play_url = [] + + quality_options = [ + ("超清", "2160p"), + ("高清", "1080p"), + ("标清", "720p"), + ("低清", "480p"), + ("流畅", "360p") + ] + + for quality_name, quality_value in quality_options: + urls = [] + + for item in vod_list: + chapterName = item.get('title', '') + videoId = item.get('video_id', '') + playUrl = f"{quality_host}/duanju/api.php?video_id={videoId}&type=json&level={quality_value}" + urls.append(f"{chapterName}${playUrl}") + + play_from.append(quality_name) + play_url.append("#".join(urls)) + + actors = [] + try: + actor_api_url = f"{base_url}?series_id={book_id}&showRawParams=false" + actor_response = requests.get(url=actor_api_url, headers=headers, timeout=timeout) + if actor_response.status_code == 200: + actor_data = actor_response.json() + if actor_data.get('code') == 200 and 'celebrities' in actor_data: + celebrities = actor_data['celebrities'] + if isinstance(celebrities, list): + for celeb in celebrities: + actor_name = celeb.get('user_name') or celeb.get('name') or celeb.get('actor_name') or '' + if actor_name and actor_name.strip(): + if actor_name not in actors: + actors.append(actor_name) + except Exception as e: + print(f"获取演员信息失败: {e}") + if actor: + actors = [actor] + + actor_str = ", ".join(actors) if actors else (actor or "") + + categories = [] + if 'category_names' in data and isinstance(data['category_names'], list): + categories = data['category_names'][:3] # 只取前3个 + elif 'category' in data: + categories = [data['category']][:1] + + type_str = "" + if categories: + type_str = ", ".join(categories) + + remarks_str = f"共{len(vod_list)}集" + + content_str = data.get('desc', '') + + VOD = { + "vod_id": did, + "vod_name": data.get('book_name', ''), + "vod_pic": data.get('book_pic', ''), + "vod_actor": actor_str, + "type_name": type_str or fullType, + "vod_remarks": remarks_str, + "vod_content": content_str, + "vod_play_from": "$$$".join(play_from), + "vod_play_url": "$$$".join(play_url) + } + + return {'list': [VOD]} + else: + return {'list': []} + + except Exception as e: + print(f"获取详情失败: {e}") + return {'list': []} + + def playerContent(self, flag, id, vipFlags): + max_retries = 3 + + for i in range(max_retries): + try: + response = requests.get(url=id, headers=headers, timeout=timeout) + if response.status_code == 200: + data = response.json() + + if data.get('code') == 200 and data.get('data'): + play_url = data['data'].get('url', '') + + if play_url: + return { + "parse": 0, + "playUrl": '', + "url": play_url, + "header": headers + } + break + except: + if i < max_retries - 1: + continue + else: + break + + return { + "parse": 0, + "playUrl": '', + "url": 'about:blank', + "header": headers + } + + def searchContent(self, key, quick, pg=1): + try: + page = int(pg) + except: + page = 1 + + params = f"page={page}&name={urllib.parse.quote(key)}&tab_type=19" + search_url = f"{base_url}?{params}" + + try: + response = requests.get(search_url, headers=headers, timeout=timeout) + + if response.status_code != 200: + return {'list': []} + + response.encoding = "utf-8" + data = response.json() + + if data.get('code') != 200 or not data.get('data'): + return {'list': []} + + videos = [] + for vod in data['data']: + vod_id = f"book_id={vod.get('book_id', '')}&actor={vod.get('author', '')}&type={vod.get('type', '')}" + videos.append({ + "vod_id": vod_id, + "vod_name": vod.get('title', ''), + "vod_pic": vod.get('cover', ''), + "vod_remarks": vod.get('type', ''), + "vod_content": vod.get('intro', '') + }) + + return { + 'list': videos, + 'page': page, + 'pagecount': 9999, + 'limit': len(videos), + 'total': 999999 + } + + except Exception: + return {'list': []} \ No newline at end of file