From 5afe60c3cfad6b8d4410cbd92907259a04c5953e Mon Sep 17 00:00:00 2001 From: qist <87984115@qq.com> Date: Thu, 21 May 2026 17:46:31 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E5=8E=82=E9=95=BF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .gitignore | 3 +- py/czzyv.py | 349 +++++++++++++++++++++++++++++++++++++++++++++ tools/dianshi.json | 5 +- 3 files changed, 354 insertions(+), 3 deletions(-) create mode 100644 py/czzyv.py diff --git a/.gitignore b/.gitignore index 2d427e35..5f65de81 100644 --- a/.gitignore +++ b/.gitignore @@ -7,4 +7,5 @@ jsm_with_app_sites.json dianshi_merged.json jsm_merged.json tvbox_cleaned.json -tools/fan.txt \ No newline at end of file +tools/fan.txt +py/__pycache__/ \ No newline at end of file diff --git a/py/czzyv.py b/py/czzyv.py new file mode 100644 index 00000000..30d6ba44 --- /dev/null +++ b/py/czzyv.py @@ -0,0 +1,349 @@ +""" +czzyv.com - 厂长资源 +""" + +import re +import time +from urllib.parse import urljoin, quote, unquote, urlparse, parse_qs + +import requests +from bs4 import BeautifulSoup + +from base.spider import Spider + + +class Spider(Spider): + def __init__(self): + self.host = "https://czzyv.com" + self.timeout = 20 + self.headers = { + "User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/136.0.0.0 Safari/537.36", + "Referer": "https://czzyv.com/", + "Accept": "text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,*/*;q=0.8", + "Accept-Language": "zh-CN,zh;q=0.9", + } + self.session = None + self._text_cache = {} + self._text_cache_ttl = 300 + self._api_base = "" + self._use_api = False + + self._class_map = [ + ("最新电影", "/zuixindianying"), + ("豆瓣Top250", "/dbtop250"), + ("国产剧", "/gcj"), + ("美剧", "/meijutt"), + ("韩剧", "/hanjutv"), + ("日剧", "/riju"), + ("番剧", "/fanju"), + ("剧场版", "/dongmanjuchangban"), + ("海外剧", "/haiwaijuqita"), + ] + + def getName(self): + return "厂长资源" + + def init(self, extend=""): + if extend: + self.host = extend.strip().rstrip("/") + self.headers["Referer"] = self.host + "/" + self.headers["Origin"] = self.host + self.session = requests.Session() + self.session.headers.update(self.headers) + self._detect_api() + self._warmup() + + def isVideoFormat(self, url): + pass + + def manualVideoCheck(self): + pass + + def destroy(self): + pass + + def _detect_api(self): + candidates = [ + "/api.php/provide/vod?ac=list", + "/api.php/provide/vod/?ac=list", + "/index.php/api/vod?ac=list", + ] + for p in candidates: + url = urljoin(self.host + "/", p.lstrip("/")) + try: + r = self.session.get(url, timeout=self.timeout, allow_redirects=True) + ct = (r.headers.get("Content-Type") or "").lower() + if r.status_code == 200 and (("json" in ct) or ("xml" in ct) or r.text.strip().startswith(("{", "<"))): + self._api_base = url.split("?", 1)[0] + self._use_api = True + return + except Exception: + continue + self._api_base = "" + self._use_api = False + + def _warmup(self): + try: + self.session.get(self.host + "/", timeout=self.timeout, allow_redirects=True) + except Exception: + pass + + def _fetch_text(self, url): + now = time.time() + cached = self._text_cache.get(url) + if cached and cached[0] > now: + return cached[1] + + try: + r = None + for _ in range(3): + try: + r = self.session.get(url, timeout=self.timeout, allow_redirects=True) + break + except Exception: + time.sleep(1) + if not r or r.status_code != 200: + return "" + r.encoding = "utf-8" + text = r.text or "" + if text: + self._text_cache[url] = (now + self._text_cache_ttl, text) + return text + except Exception: + return "" + + def _abs(self, href): + return urljoin(self.host + "/", href or "") + + def _parse_pagecount(self, html, current_pg): + m = re.findall(r"/page/(\d+)", html or "") + nums = [int(x) for x in m if x.isdigit()] + if nums: + return max(max(nums), current_pg) + return 999 + + def _parse_vod_list(self, html): + soup = BeautifulSoup(html or "", "html.parser") + vods = [] + for li in soup.select("div.bt_img ul li"): + a = None + for x in li.select("a[href]"): + href = x.get("href") or "" + if "/movie/" in href and ".html" in href: + a = x + break + if not a: + continue + href = a.get("href") or "" + href = self._abs(href) + mid = "" + mm = re.search(r"/movie/(\d+)\.html", href) + if mm: + mid = mm.group(1) + if not mid: + continue + + img = li.select_one("img") + pic = "" + name = "" + if img: + name = (img.get("alt") or "").strip() + pic = ( + (img.get("data-original") or "") + or (img.get("data-src") or "") + or (img.get("data-lazy-src") or "") + or (img.get("src") or "") + ).strip() + if not name: + h3a = li.select_one("h3 a") or li.select_one("a") + name = (h3a.get_text(strip=True) if h3a else "").strip() + if pic.endswith("/blank.gif") and img and img.get("data-original"): + pic = (img.get("data-original") or "").strip() + + qb = li.select_one(".hdinfo .qb") or li.select_one(".hdinfo") + rating = li.select_one(".rating") + remark = (qb.get_text(" ", strip=True) if qb else "").strip() + score = (rating.get_text(" ", strip=True) if rating else "").strip() + if remark and score and score not in remark: + remark = f"{remark} {score}" + elif not remark: + remark = score + + vods.append( + { + "vod_id": mid, + "vod_name": name or mid, + "vod_pic": pic, + "vod_remarks": remark, + } + ) + + seen = set() + unique = [] + for v in vods: + if v["vod_id"] in seen: + continue + seen.add(v["vod_id"]) + unique.append(v) + return unique + + def homeContent(self, filter): + result = {"class": [], "list": []} + for name, path in self._class_map: + result["class"].append({"type_name": name, "type_id": path}) + + if self._use_api: + return result + + html = self._fetch_text(self.host + "/") + result["list"] = self._parse_vod_list(html)[:24] + return result + + def homeVideoContent(self): + return {} + + def categoryContent(self, tid, pg, filter, extend): + pg = int(pg or 1) + result = {"list": [], "page": pg, "pagecount": 999, "limit": 24, "total": 0} + + if self._use_api: + return result + + if tid.startswith("http"): + base = tid + else: + base = self._abs(tid) + + if pg > 1: + if base.endswith("/"): + url = base + f"page/{pg}" + else: + url = base + f"/page/{pg}" + else: + url = base + + html = self._fetch_text(url) + result["list"] = self._parse_vod_list(html) + result["pagecount"] = self._parse_pagecount(html, pg) + result["total"] = result["pagecount"] * result["limit"] + return result + + def detailContent(self, ids): + if not ids or not ids[0]: + return {"list": []} + vid = ids[0] + if vid.startswith("http"): + url = vid + else: + url = f"{self.host}/movie/{vid}.html" + + html = self._fetch_text(url) + soup = BeautifulSoup(html or "", "html.parser") + + h1 = soup.select_one("h1") + name = (h1.get_text(" ", strip=True) if h1 else "").strip() + + img = soup.select_one(".dyimg img") or soup.select_one(".movimg img") or soup.select_one("img") + pic = "" + if img: + pic = ( + (img.get("data-original") or "") + or (img.get("data-src") or "") + or (img.get("data-lazy-src") or "") + or (img.get("src") or "") + ).strip() + + desc = "" + desc_div = soup.select_one("div.yp_context") + if desc_div: + desc = desc_div.get_text("\n", strip=True) + + text_lines = [x.strip() for x in soup.get_text("\n", strip=True).split("\n") if x.strip()] + + def pick(prefix): + for line in text_lines: + if line.startswith(prefix): + return line.split("：", 1)[-1].strip() + return "" + + actor = pick("主演：") + director = pick("导演：") + + play_items = [] + for a in soup.select('a[href*="/v_play/"]'): + t = a.get_text(" ", strip=True).strip() + href = a.get("href") or "" + if not href: + continue + href = self._abs(href) + if t: + play_items.append(f"{t}${href}") + + if not play_items: + play_items.append(f"播放${url}") + + return { + "list": [ + { + "vod_id": vid, + "vod_name": name or vid, + "vod_pic": pic, + "vod_remarks": "", + "vod_year": "", + "type_name": "", + "vod_content": desc, + "vod_actor": actor, + "vod_director": director, + "vod_play_from": "厂长资源", + "vod_play_url": "#".join(play_items), + } + ] + } + + def searchContent(self, key, quick, pg="1"): + if not key: + return {"list": []} + if self._use_api: + return {"list": []} + pg = str(pg or "1") + url = f"{self.host}/boss1O1?q={quote(key)}" + if pg != "1": + url += f"&page={quote(pg)}" + html = self._fetch_text(url) + return {"list": self._parse_vod_list(html)} + + def playerContent(self, flag, id, vipFlags): + h = {"User-Agent": self.headers.get("User-Agent", ""), "Referer": self.host + "/"} + + if not id: + return {"parse": 1, "url": "", "header": h, "playUrl": ""} + + if isinstance(id, str) and (".m3u8" in id or ".mp4" in id) and id.startswith("http"): + return {"parse": 0, "url": id, "header": h, "playUrl": ""} + + play_url = id if id.startswith("http") else self._abs(id) + if "/v_play/" not in play_url: + return {"parse": 1, "url": play_url, "header": h, "playUrl": ""} + + html = self._fetch_text(play_url) + soup = BeautifulSoup(html or "", "html.parser") + + iframe = soup.select_one("iframe.viframe") or soup.find("iframe") + if iframe: + src = (iframe.get("src") or "").strip() + if src: + qs = parse_qs(urlparse(src).query) + raw = (qs.get("url") or [""])[0] + raw = unquote(raw).strip() + if raw.startswith("http"): + return {"parse": 0, "url": raw, "header": h, "playUrl": ""} + return {"parse": 1, "url": src, "header": h, "playUrl": ""} + + m = re.findall(r'https?://[^\s"\']+?\.(?:m3u8|mp4)(?:\?[^\s"\']*)?', html or "") + if m: + return {"parse": 0, "url": m[0], "header": h, "playUrl": ""} + + return {"parse": 1, "url": play_url, "header": h, "playUrl": ""} + + def localProxy(self, param): + return None diff --git a/tools/dianshi.json b/tools/dianshi.json index b47a5eb4..da231bef 100644 --- a/tools/dianshi.json +++ b/tools/dianshi.json @@ -13,8 +13,9 @@ {"key":"闪雷","name":"闪雷┃MP4","type":3,"api":"./lib/drpy2.min.js","ext":"./js/678.js","header":{"User-Agent":"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/136.0.0.0 Safari/537.36 Edg/136.0.0.0"}}, {"key":"fyyy","name":"飞宇影院","type":3,"api":"csp_XBPQ","searchable":1,"quickSearch":1,"filterable":1,"changeable":1,"ext":{"分类url":"http://ntfeiyu.com/nt/{cateId}/area/{area}/by/{by}/class/{class}/lang/{lang}/page/{catePg}/year/{year}.html","分类":"电影$1#电视剧$2#综艺$3#动漫$4"},"header":{"User-Agent":"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/136.0.0.0 Safari/537.36 Edg/136.0.0.0"}}, {"key":"cupfox_in","name":"茶杯狐┃cupfox.in","type":3,"api":"./lib/drpy2.min.js","ext":"./js/茶杯狐.js","searchable":1,"quickSearch":1,"filterable":0,"changeable":1,"header":{"User-Agent":"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/136.0.0.0 Safari/537.36 Edg/136.0.0.0"}}, -{"key": "libvio","name": "libvio｜影视","type": 3,"api": "./py/libvio.py","searchable": 1,"quickSearch": 1,"filterable": 0,"changeable": 1}, -{"key":"italkbbtv","name":"ITalkBB｜外","type":3,"api":"./py/ITalkBBTV.py","searchable":1,"quickSearch":1,"filterable":0,"changeable":1}, +{"key": "czzyv","name": "厂长 | 影视","type": 3,"api": "./py/czzyv.py","searchable": 1,"quickSearch": 1,"filterable": 0,"changeable": 1}, +{"key": "libvio","name": "libvio | 影视","type": 3,"api": "./py/libvio.py","searchable": 1,"quickSearch": 1,"filterable": 0,"changeable": 1}, +{"key":"italkbbtv","name":"ITalkBB | 外","type":3,"api":"./py/ITalkBBTV.py","searchable":1,"quickSearch":1,"filterable":0,"changeable":1}, {"key":"qiletv","name":"奇乐影视","type":3,"api":"csp_XBPQ","searchable":1,"quickSearch":1,"filterable":1,"changeable":1,"ext":"./json/奇乐.json","header":{"User-Agent":"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/136.0.0.0 Safari/537.36 Edg/136.0.0.0"}},