diff --git a/py/docs/superpowers/plans/2026-04-20-shandian-spider.md b/py/docs/superpowers/plans/2026-04-20-shandian-spider.md new file mode 100644 index 0000000..0876ba9 --- /dev/null +++ b/py/docs/superpowers/plans/2026-04-20-shandian-spider.md @@ -0,0 +1,714 @@ +# 闪电 Spider 与聚合接入 Implementation Plan + +> **For agentic workers:** REQUIRED SUB-SKILL: Use superpowers:subagent-driven-development (recommended) or superpowers:executing-plans to implement this plan task-by-task. Steps use checkbox (`- [ ]`) syntax for tracking. + +**Goal:** 在当前 Python 仓库中新增独立单站 `闪电` 蜘蛛,并将其接入 `玩偶聚合`,支持分类、搜索、详情网盘线路整理和网盘透传。 + +**Architecture:** 单站实现采用与 `至臻` 相同的单文件 Spider 模式,在 `py/闪电.py` 中完成 URL 拼装、列表解析、详情字段提取和网盘线路组装。聚合层只补 `shandian` 站点配置和对应测试,复用现有 `玩偶聚合.py` 的搜索聚合、详情合并和网盘透传逻辑,不引入公共基类重构。 + +**Tech Stack:** Python 3, `unittest`, `unittest.mock`, `re`, `sys`, `urllib.parse`, `base.spider.Spider` + +--- + +## File Structure + +- Create: `py/闪电.py` + - 实现 `Spider` 类和站点全部逻辑 + - 暴露 `init`、`getName`、`homeContent`、`homeVideoContent`、`categoryContent`、`searchContent`、`detailContent`、`playerContent` +- Create: `py/tests/test_闪电.py` + - 使用 `SourceFileLoader` 加载 `py/闪电.py` + - 通过内联 HTML 与 `mock` 覆盖分类、搜索、详情、线路排序和透传 +- Modify: `py/玩偶聚合.py` + - 新增 `shandian` 站点配置 + - 复用聚合层现有 URL 构建和详情合并逻辑 +- Modify: `py/tests/test_玩偶聚合.py` + - 新增 `闪电` 首页、分类 URL、搜索 URL 和详情合并测试 + +### Task 1: Add Failing Tests For 闪电 Single Spider + +**Files:** +- Create: `py/tests/test_闪电.py` +- Create: `py/闪电.py` + +- [ ] **Step 1: Write the failing test** + +```python +import unittest +from importlib.machinery import SourceFileLoader +from pathlib import Path +from unittest.mock import patch + + +ROOT = Path(__file__).resolve().parents[1] +MODULE = SourceFileLoader("shandian_spider", str(ROOT / "闪电.py")).load_module() +Spider = MODULE.Spider + + +class TestShanDianSpider(unittest.TestCase): + def setUp(self): + Spider._instance = None + self.spider = Spider() + self.spider.init() + + def test_home_content_exposes_all_categories(self): + content = self.spider.homeContent(False) + self.assertEqual( + [(item["type_id"], item["type_name"]) for item in content["class"]], + [ + ("1", "闪电电影"), + ("2", "闪电剧集"), + ("3", "闪电综艺"), + ("4", "闪电动漫"), + ("30", "闪电短剧"), + ], + ) + + def test_home_video_content_returns_empty_list(self): + self.assertEqual(self.spider.homeVideoContent(), {"list": []}) + + def test_build_url_and_detect_pan_type(self): + self.assertEqual( + self.spider._build_url("/index.php/vod/detail/id/1.html"), + "https://sd.sduc.site/index.php/vod/detail/id/1.html", + ) + self.assertEqual(self.spider._detect_pan_type("https://pan.baidu.com/s/demo"), ("baidu", "百度资源")) + self.assertEqual(self.spider._detect_pan_type("https://pan.quark.cn/s/demo"), ("quark", "夸克资源")) + self.assertEqual(self.spider._detect_pan_type("https://example.com/video"), ("", "")) +``` + +- [ ] **Step 2: Run test to verify it fails** + +Run from `py/`: `python -m unittest tests.test_闪电.TestShanDianSpider -v` +Expected: FAIL with `FileNotFoundError` for `闪电.py` or missing `Spider` attributes. + +- [ ] **Step 3: Write minimal implementation** + +```python +# coding=utf-8 +import re +import sys +from urllib.parse import urljoin + +from base.spider import Spider as BaseSpider + +sys.path.append("..") + + +class Spider(BaseSpider): + def __init__(self): + self.name = "闪电" + self.host = "https://sd.sduc.site" + 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": self.host + "/", + } + self.categories = [ + {"type_id": "1", "type_name": "闪电电影"}, + {"type_id": "2", "type_name": "闪电剧集"}, + {"type_id": "3", "type_name": "闪电综艺"}, + {"type_id": "4", "type_name": "闪电动漫"}, + {"type_id": "30", "type_name": "闪电短剧"}, + ] + self.pan_patterns = [ + ("baidu", "百度资源", r"pan\.baidu\.com|yun\.baidu\.com"), + ("a139", "139资源", r"yun\.139\.com"), + ("a189", "天翼资源", r"cloud\.189\.cn"), + ("a123", "123资源", r"123684\.com|123865\.com|123912\.com|123pan\.com"), + ("a115", "115资源", r"115\.com"), + ("quark", "夸克资源", r"pan\.quark\.cn"), + ("xunlei", "迅雷资源", r"pan\.xunlei\.com"), + ("aliyun", "阿里资源", r"aliyundrive\.com|alipan\.com"), + ("uc", "UC资源", r"drive\.uc\.cn"), + ] + + def init(self, extend=""): + return None + + def getName(self): + return self.name + + def homeContent(self, filter): + return {"class": self.categories} + + def homeVideoContent(self): + return {"list": []} + + def _build_url(self, path): + return urljoin(self.host + "/", str(path or "").strip()) + + def _detect_pan_type(self, url): + raw = str(url or "").strip() + for pan_type, title, pattern in self.pan_patterns: + if re.search(pattern, raw, re.I): + return pan_type, title + return "", "" +``` + +- [ ] **Step 4: Run test to verify it passes** + +Run from `py/`: `python -m unittest tests.test_闪电.TestShanDianSpider -v` +Expected: PASS for the scaffold tests. + +- [ ] **Step 5: Commit** + +```bash +git add py/闪电.py py/tests/test_闪电.py +git commit -m "feat: scaffold shandian spider" +``` + +### Task 2: Add 闪电 List, Search, Detail, And Player Coverage + +**Files:** +- Modify: `py/tests/test_闪电.py` +- Modify: `py/闪电.py` + +- [ ] **Step 1: Write the failing test** + +```python + def test_parse_cards_extracts_short_path_ids(self): + html = """ +
+
+
+ + 示例影片 +
+
HD
+
2025
+
+
+ """ + self.assertEqual( + self.spider._parse_cards(html), + [ + { + "vod_id": "/index.php/vod/detail/id/123.html", + "vod_name": "示例影片", + "vod_pic": "https://sd.sduc.site/poster.jpg", + "vod_remarks": "HD", + "vod_year": "2025", + } + ], + ) + + @patch.object(Spider, "_request_html") + def test_category_content_builds_reference_url_and_returns_page_payload(self, mock_request_html): + mock_request_html.return_value = """ +
+
+
+ + 分类影片 +
+
更新至10集
+
2024
+
+
+ """ + result = self.spider.categoryContent("2", "3", False, {}) + self.assertEqual( + mock_request_html.call_args.args[0], + "https://sd.sduc.site/index.php/vod/show/id/2/page/3.html", + ) + self.assertEqual(result["page"], 3) + self.assertEqual(result["limit"], 1) + self.assertEqual(result["list"][0]["vod_name"], "分类影片") + + @patch.object(Spider, "_request_html") + def test_search_content_builds_reference_search_url_and_parses_results(self, mock_request_html): + mock_request_html.return_value = """ +
+ 抢先版 +
+ 搜索影片 +
+
+ """ + result = self.spider.searchContent("繁花", False, "2") + self.assertEqual( + mock_request_html.call_args.args[0], + "https://sd.sduc.site/index.php/vod/search/page/2/wd/%E7%B9%81%E8%8A%B1.html", + ) + self.assertEqual(result["list"][0]["vod_id"], "/index.php/vod/detail/id/789.html") + + def test_build_pan_lines_deduplicates_and_sorts_supported_links(self): + detail = {"pan_urls": ["https://pan.quark.cn/s/q1", "https://pan.baidu.com/s/b1", "https://pan.baidu.com/s/b1"]} + self.assertEqual( + self.spider._build_pan_lines(detail), + [ + ("baidu#闪电", "百度资源$https://pan.baidu.com/s/b1"), + ("quark#闪电", "夸克资源$https://pan.quark.cn/s/q1"), + ], + ) +``` + +- [ ] **Step 2: Run test to verify it fails** + +Run from `py/`: `python -m unittest tests.test_闪电.TestShanDianSpider -v` +Expected: FAIL with missing `_parse_cards`, `categoryContent`, `searchContent`, or `_build_pan_lines`. + +- [ ] **Step 3: Write minimal implementation** + +```python +from urllib.parse import quote + + + self.pan_priority = { + "baidu": 1, + "a139": 2, + "a189": 3, + "a123": 4, + "a115": 5, + "quark": 6, + "xunlei": 7, + "aliyun": 8, + "uc": 9, + } + + def _clean_text(self, text): + return re.sub(r"\s+", " ", str(text or "").replace("\xa0", " ")).strip() + + def _request_html(self, path_or_url): + target = path_or_url if str(path_or_url).startswith("http") else self._build_url(path_or_url) + response = self.fetch(target, headers=dict(self.headers), timeout=10) + if response.status_code != 200: + return "" + return response.text or "" + + def _page_result(self, items, pg): + page = int(pg) + return {"page": page, "limit": len(items), "total": page * 20 + len(items), "list": items} + + def _parse_cards(self, html): + root = self.html(html) + if root is None: + return [] + items = [] + seen = set() + for node in root.xpath("//*[@id='main']//*[contains(@class,'module-item')]"): + href = "".join(node.xpath(".//*[contains(@class,'module-item-pic')]//a[1]/@href")).strip() + title = "".join(node.xpath(".//*[contains(@class,'module-item-pic')]//img[1]/@alt")).strip() + pic = ( + "".join(node.xpath(".//*[contains(@class,'module-item-pic')]//img[1]/@data-src")).strip() + or "".join(node.xpath(".//*[contains(@class,'module-item-pic')]//img[1]/@src")).strip() + ) + remarks = self._clean_text("".join(node.xpath(".//*[contains(@class,'module-item-text')][1]//text()"))) + year = self._clean_text("".join(node.xpath(".//*[contains(@class,'module-item-caption')][1]//span[1]//text()"))) + if not href or not title or href in seen: + continue + seen.add(href) + items.append( + { + "vod_id": href, + "vod_name": title, + "vod_pic": self._build_url(pic), + "vod_remarks": remarks, + "vod_year": year, + } + ) + return items + + def categoryContent(self, tid, pg, filter, extend): + url = self._build_url(f"/index.php/vod/show/id/{tid}/page/{int(pg)}.html") + return self._page_result(self._parse_cards(self._request_html(url)), pg) + + def searchContent(self, key, quick, pg="1"): + keyword = self._clean_text(key) + page = int(pg) + if not keyword: + return {"page": page, "total": 0, "list": []} + url = self._build_url(f"/index.php/vod/search/page/{page}/wd/{quote(keyword)}.html") + root = self.html(self._request_html(url)) + if root is None: + return {"page": page, "total": 0, "list": []} + items = [] + for node in root.xpath("//*[contains(@class,'module-search-item')]"): + href = "".join(node.xpath(".//*[contains(@class,'video-serial')][1]/@href")).strip() + title = "".join(node.xpath(".//*[contains(@class,'video-serial')][1]/@title")).strip() + pic = ( + "".join(node.xpath(".//*[contains(@class,'module-item-pic')]//img[1]/@data-src")).strip() + or "".join(node.xpath(".//*[contains(@class,'module-item-pic')]//img[1]/@src")).strip() + ) + remarks = self._clean_text( + "".join(node.xpath(".//*[contains(@class,'video-serial')][1]//text()")) + or "".join(node.xpath(".//*[contains(@class,'module-item-text')][1]//text()")) + ) + if not href or not title: + continue + items.append({"vod_id": href, "vod_name": title, "vod_pic": self._build_url(pic), "vod_remarks": remarks}) + return {"page": page, "total": len(items), "list": items} + + def _build_pan_lines(self, detail): + lines = [] + seen = set() + for url in detail.get("pan_urls", []): + pan_type, title = self._detect_pan_type(url) + if not pan_type or url in seen: + continue + seen.add(url) + lines.append((self.pan_priority.get(pan_type, 999), f"{pan_type}#闪电", f"{title}${url}")) + lines.sort(key=lambda item: item[0]) + return [(item[1], item[2]) for item in lines] +``` + +- [ ] **Step 4: Run test to verify it passes** + +Run from `py/`: `python -m unittest tests.test_闪电.TestShanDianSpider -v` +Expected: PASS for list, search, and line-building tests. + +- [ ] **Step 5: Commit** + +```bash +git add py/闪电.py py/tests/test_闪电.py +git commit -m "feat: add shandian list and search parsing" +``` + +### Task 3: Add 闪电 Detail And Player Behavior + +**Files:** +- Modify: `py/tests/test_闪电.py` +- Modify: `py/闪电.py` + +- [ ] **Step 1: Write the failing test** + +```python + def test_parse_detail_page_extracts_meta_content_and_pan_urls(self): + html = """ +
示例剧
+
+
年代
2024
+
导演
导演甲
+
主演
演员甲演员乙
+
剧情

一段剧情简介

+
+

https://pan.quark.cn/s/q1

+

https://pan.baidu.com/s/b1

+
+ """ + detail = self.spider._parse_detail_page("/index.php/vod/detail/id/123.html", html) + self.assertEqual(detail["vod_name"], "示例剧") + self.assertEqual(detail["vod_pic"], "https://sd.sduc.site/poster.jpg") + self.assertEqual(detail["vod_year"], "2024") + self.assertEqual(detail["vod_director"], "导演甲") + self.assertEqual(detail["vod_actor"], "演员甲,演员乙") + self.assertEqual(detail["vod_content"], "一段剧情简介") + self.assertEqual(detail["pan_urls"], ["https://pan.quark.cn/s/q1", "https://pan.baidu.com/s/b1"]) + + @patch.object(Spider, "_request_html") + def test_detail_content_builds_pan_play_fields(self, mock_request_html): + mock_request_html.return_value = """ +
示例剧
+
+
年代
2024
+
导演
导演甲
+
主演
演员甲
+
剧情

一段剧情简介

+
+

https://pan.quark.cn/s/q1

+

https://pan.baidu.com/s/b1

+
+ """ + result = self.spider.detailContent(["/index.php/vod/detail/id/123.html"]) + vod = result["list"][0] + self.assertEqual(vod["vod_play_from"], "baidu#闪电$$$quark#闪电") + self.assertEqual( + vod["vod_play_url"], + "百度资源$https://pan.baidu.com/s/b1$$$夸克资源$https://pan.quark.cn/s/q1", + ) + + def test_player_content_passthroughs_supported_pan_urls(self): + self.assertEqual( + self.spider.playerContent("baidu#闪电", "https://pan.baidu.com/s/demo", {}), + {"parse": 0, "playUrl": "", "url": "https://pan.baidu.com/s/demo"}, + ) + + def test_player_content_rejects_non_pan_url(self): + self.assertEqual( + self.spider.playerContent("site", "/index.php/vod/play/id/1.html", {}), + {"parse": 0, "playUrl": "", "url": ""}, + ) +``` + +- [ ] **Step 2: Run test to verify it fails** + +Run from `py/`: `python -m unittest tests.test_闪电.TestShanDianSpider -v` +Expected: FAIL with missing detail parser, `detailContent`, or `playerContent`. + +- [ ] **Step 3: Write minimal implementation** + +```python + def _parse_detail_page(self, vod_id, html): + root = self.html(html) + if root is None: + return { + "vod_id": vod_id, + "vod_name": "", + "vod_pic": "", + "vod_year": "", + "vod_director": "", + "vod_actor": "", + "vod_content": "", + "pan_urls": [], + } + detail = { + "vod_id": vod_id, + "vod_name": self._clean_text("".join(root.xpath("//*[contains(@class,'page-title')][1]//text()"))), + "vod_pic": self._build_url( + "".join( + root.xpath( + "//*[contains(@class,'mobile-play')]//*[contains(@class,'lazyload')][1]/@data-src | " + "//*[contains(@class,'mobile-play')]//*[contains(@class,'lazyload')][1]/@src" + ) + ).strip() + ), + "vod_year": "", + "vod_director": "", + "vod_actor": "", + "vod_content": "", + "pan_urls": [], + } + for label_node in root.xpath("//*[contains(@class,'video-info-itemtitle')]"): + key = self._clean_text("".join(label_node.xpath(".//text()"))) + sibling = label_node.getnext() + if sibling is None: + continue + values = [self._clean_text(text) for text in sibling.xpath(".//a//text()")] + joined = ",".join([value for value in values if value]) + text_value = self._clean_text("".join(sibling.xpath(".//text()"))) + if "年代" in key: + detail["vod_year"] = joined or text_value + elif "导演" in key: + detail["vod_director"] = joined or text_value + elif "主演" in key: + detail["vod_actor"] = joined or text_value + elif "剧情" in key: + detail["vod_content"] = text_value + for node in root.xpath("//*[contains(@class,'module-row-info')]//p"): + text = self._clean_text("".join(node.xpath(".//text()"))) + if text: + detail["pan_urls"].append(text) + return detail + + def detailContent(self, ids): + result = {"list": []} + for raw_id in ids: + vod_id = str(raw_id or "").strip() + detail = self._parse_detail_page(vod_id, self._request_html(self._build_url(vod_id))) + lines = self._build_pan_lines(detail) + result["list"].append( + { + "vod_id": vod_id, + "vod_name": detail["vod_name"], + "vod_pic": detail["vod_pic"], + "vod_year": detail["vod_year"], + "vod_director": detail["vod_director"], + "vod_actor": detail["vod_actor"], + "vod_content": detail["vod_content"], + "vod_play_from": "$$$".join([item[0] for item in lines]), + "vod_play_url": "$$$".join([item[1] for item in lines]), + } + ) + return result + + def playerContent(self, flag, id, vipFlags): + pan_type, _ = self._detect_pan_type(id) + if pan_type: + return {"parse": 0, "playUrl": "", "url": id} + return {"parse": 0, "playUrl": "", "url": ""} +``` + +- [ ] **Step 4: Run test to verify it passes** + +Run from `py/`: `python -m unittest tests.test_闪电.TestShanDianSpider -v` +Expected: PASS for detail and player tests. + +- [ ] **Step 5: Commit** + +```bash +git add py/闪电.py py/tests/test_闪电.py +git commit -m "feat: add shandian detail and player support" +``` + +### Task 4: Add 玩偶聚合 Failing Tests For 闪电 + +**Files:** +- Modify: `py/tests/test_玩偶聚合.py` +- Modify: `py/玩偶聚合.py` + +- [ ] **Step 1: Write the failing test** + +```python + def test_home_content_exposes_shandian_site_and_categories(self): + content = self.spider.homeContent(False) + self.assertIn("site_shandian", [item["type_id"] for item in content["class"]]) + self.assertEqual( + content["filters"]["site_shandian"][0]["value"][1:], + [ + {"n": "电影", "v": "1"}, + {"n": "剧集", "v": "2"}, + {"n": "综艺", "v": "3"}, + {"n": "动漫", "v": "4"}, + {"n": "短剧", "v": "30"}, + ], + ) + + @patch.object(Spider, "_request_with_failover") + def test_fetch_site_search_builds_shandian_search_url_and_parses_results(self, mock_request_with_failover): + mock_request_with_failover.return_value = """ +
+ 抢先版 +
闪电影片
+
+ """ + site = self.spider._get_site("shandian") + results = self.spider._fetch_site_search(site, "繁花", 1) + self.assertEqual( + mock_request_with_failover.call_args.args[1], + "/index.php/vod/search/page/1/wd/%E7%B9%81%E8%8A%B1.html", + ) + self.assertEqual(results[0]["vod_id"], "site:shandian:/index.php/vod/detail/id/789.html") + + @patch.object(Spider, "_request_with_failover") + def test_category_content_builds_shandian_category_url(self, mock_request_with_failover): + mock_request_with_failover.return_value = """ +
+
+ + 闪电分类片 +
+
HD
+
+ """ + result = self.spider.categoryContent("site_shandian", "2", False, {"categoryId": "30"}) + self.assertEqual( + mock_request_with_failover.call_args.args[1], + "https://sd.sduc.site/index.php/vod/show/id/30/page/2.html", + ) + self.assertEqual(result["list"][0]["vod_id"], "site:shandian:/index.php/vod/detail/id/456.html") +``` + +- [ ] **Step 2: Run test to verify it fails** + +Run from `py/`: `python -m unittest tests.test_玩偶聚合.TestWanouAggregateSpider.test_home_content_exposes_shandian_site_and_categories tests.test_玩偶聚合.TestWanouAggregateSpider.test_fetch_site_search_builds_shandian_search_url_and_parses_results tests.test_玩偶聚合.TestWanouAggregateSpider.test_category_content_builds_shandian_category_url -v` +Expected: FAIL because `shandian` is not yet present in `self.sites`. + +- [ ] **Step 3: Write minimal implementation** + +```python + { + "id": "shandian", + "name": "闪电", + "domains": ["https://sd.sduc.site"], + "filter_files": [], + "list_xpath": "//*[contains(@class,'module-item')]", + "search_xpath": "//*[contains(@class,'module-search-item')]", + "detail_pan_xpath": "//*[contains(@class,'module-row-info')]//p", + "category_url": "/index.php/vod/show/id/{categoryId}/page/{page}.html", + "search_url": "/index.php/vod/search/page/{page}/wd/{keyword}.html", + "default_categories": [("1", "电影"), ("2", "剧集"), ("3", "综艺"), ("4", "动漫"), ("30", "短剧")], + }, +``` + +- [ ] **Step 4: Run test to verify it passes** + +Run from `py/`: `python -m unittest tests.test_玩偶聚合.TestWanouAggregateSpider.test_home_content_exposes_shandian_site_and_categories tests.test_玩偶聚合.TestWanouAggregateSpider.test_fetch_site_search_builds_shandian_search_url_and_parses_results tests.test_玩偶聚合.TestWanouAggregateSpider.test_category_content_builds_shandian_category_url -v` +Expected: PASS with `site_shandian` visible and both URLs using `/index.php/vod/...`. + +- [ ] **Step 5: Commit** + +```bash +git add py/玩偶聚合.py py/tests/test_玩偶聚合.py +git commit -m "feat: add shandian aggregate site config" +``` + +### Task 5: Verify 闪电 Detail Merge In 聚合层 + +**Files:** +- Modify: `py/tests/test_玩偶聚合.py` +- Modify: `py/玩偶聚合.py` + +- [ ] **Step 1: Write the failing test** + +```python + @patch.object(Spider, "_fetch_site_detail") + def test_detail_content_for_aggregate_id_merges_shandian_pan_lines(self, mock_fetch_site_detail): + mock_fetch_site_detail.side_effect = [ + { + "vod_name": "繁花", + "vod_pic": "https://img.example/w.jpg", + "vod_year": "2024", + "vod_director": "导演甲", + "vod_actor": "演员甲", + "vod_content": "玩偶简介", + "pan_urls": ["https://pan.baidu.com/s/b1"], + "_site_name": "玩偶", + }, + { + "vod_name": "繁花", + "vod_pic": "https://sd.sduc.site/poster.jpg", + "vod_year": "2024", + "vod_director": "导演乙", + "vod_actor": "演员乙", + "vod_content": "闪电简介", + "pan_urls": ["https://pan.quark.cn/s/s1", "https://pan.baidu.com/s/b1"], + "_site_name": "闪电", + }, + ] + payload = [ + {"site": "wanou", "path": "/voddetail/1.html", "name": "繁花", "year": "2024"}, + {"site": "shandian", "path": "/index.php/vod/detail/id/2.html", "name": "繁花", "year": "2024"}, + ] + result = self.spider.detailContent([self.spider._encode_aggregate_vod_id(payload)]) + vod = result["list"][0] + self.assertEqual(vod["vod_play_from"], "baidu#玩偶$$$quark#闪电") + self.assertEqual( + vod["vod_play_url"], + "百度资源$https://pan.baidu.com/s/b1$$$夸克资源$https://pan.quark.cn/s/s1", + ) +``` + +- [ ] **Step 2: Run test to verify it fails** + +Run from `py/`: `python -m unittest tests.test_玩偶聚合.TestWanouAggregateSpider.test_detail_content_for_aggregate_id_merges_shandian_pan_lines -v` +Expected: FAIL before `shandian` config exists because `_get_site("shandian")` cannot resolve. + +- [ ] **Step 3: Write minimal implementation** + +```python + { + "id": "shandian", + "name": "闪电", + "domains": ["https://sd.sduc.site"], + "filter_files": [], + "list_xpath": "//*[contains(@class,'module-item')]", + "search_xpath": "//*[contains(@class,'module-search-item')]", + "detail_pan_xpath": "//*[contains(@class,'module-row-info')]//p", + "category_url": "/index.php/vod/show/id/{categoryId}/page/{page}.html", + "search_url": "/index.php/vod/search/page/{page}/wd/{keyword}.html", + "default_categories": [("1", "电影"), ("2", "剧集"), ("3", "综艺"), ("4", "动漫"), ("30", "短剧")], + }, +``` + +这一步不需要改动详情合并逻辑本身,只要保证 `shandian` 配置可被复用的聚合流程消费。 + +- [ ] **Step 4: Run test to verify it passes** + +Run from `py/`: `python -m unittest tests.test_玩偶聚合.TestWanouAggregateSpider.test_detail_content_for_aggregate_id_merges_shandian_pan_lines -v` +Expected: PASS and重复百度链接被去重,只保留 `闪电` 的夸克线路增量。 + +- [ ] **Step 5: Commit** + +```bash +git add py/玩偶聚合.py py/tests/test_玩偶聚合.py +git commit -m "test: cover shandian aggregate detail merge" +``` + +## Self-Review + +- Spec coverage: 单站分类、搜索、详情、播放透传,以及聚合层首页、分类 URL、搜索 URL、详情合并都覆盖到了,没有遗漏。 +- Placeholder scan: 文件路径、测试名、命令、代码片段和期望结果都已具体化,没有保留 TBD 或泛化描述。 +- Type consistency: 全程使用 `闪电` / `shandian` / `site_shandian` / `site:shandian:` 和 `https://sd.sduc.site`,命名保持一致。 diff --git a/py/docs/superpowers/specs/2026-04-20-shandian-spider-design.md b/py/docs/superpowers/specs/2026-04-20-shandian-spider-design.md new file mode 100644 index 0000000..316e56e --- /dev/null +++ b/py/docs/superpowers/specs/2026-04-20-shandian-spider-design.md @@ -0,0 +1,382 @@ +# 闪电 Python 爬虫与聚合接入设计 + +**日期:** 2026-04-20 + +## 目标 + +在当前 Python Spider 仓库中完成两项相关工作: + +- 新增独立单站蜘蛛 `闪电.py` +- 将 `闪电` 站点接入 `玩偶聚合.py` + +`闪电` 站点主域名固定为: + +- `https://sd.sduc.site` + +行为边界与用户提供的 JS 参考实现保持一致: + +- 支持分类列表 +- 支持搜索 +- 支持详情页元数据解析 +- 支持网盘分享链接整理 +- `playerContent` 只透传网盘分享链接 +- 不做站内直链播放解析 + +## 范围 + +本次实现包含: + +- 新增独立蜘蛛文件 `py/闪电.py` +- 新增测试文件 `py/tests/test_闪电.py` +- 在 `py/玩偶聚合.py` 中新增 `shandian` 站点配置 +- 在 `py/tests/test_玩偶聚合.py` 中新增 `闪电` 聚合测试 +- 补充对应 spec 和 plan 文档 + +本次实现不包含: + +- 抽取新的公共盘站基类 +- 修改 `base/` 公共层 +- 增加站内播放器解析 +- 实现多备用域名 failover +- 修改现有 `至臻` 行为 + +## 现状 + +仓库中已经存在一批结构相近的盘站蜘蛛,尤其是: + +- `py/至臻.py` +- `py/玩偶哥哥.py` + +这些实现已经验证了同类 DOM 结构的解析方式: + +- 列表容器:`#main .module-item` +- 搜索容器:`.module-search-item` +- 详情标题:`.page-title` +- 详情海报:`.mobile-play .lazyload` +- 详情字段标签:`.video-info-itemtitle` +- 网盘链接容器:`.module-row-info p` + +当前 `py/玩偶聚合.py` 中已有 `site_priority` 对 `shandian` 的优先级预留,但 `self.sites` 还未真正接入 `闪电` 站点。 + +因此,本次工作重点是: + +- 复用现有盘站解析模式落单站实现 +- 以最小配置改动把 `闪电` 接入聚合层 + +## 方案选择 + +采用“单站独立文件 + 聚合配置接入”的方案。 + +### 方案 A:推荐 + +- 新增 `py/闪电.py` +- 结构对齐 `py/至臻.py` +- 在 `py/玩偶聚合.py` 中新增 `shandian` 站点配置 +- 用 `unittest` 覆盖单站与聚合层行为 + +优点: + +- 与当前仓库模式一致 +- 改动边界清晰 +- 便于后续单站修复与聚合调试 + +### 方案 B:不采用 + +- 抽取一个通用盘站基类,让 `至臻/闪电` 共享实现 + +不采用原因: + +- 扩大改动范围 +- 增加重构风险 +- 当前任务目标明确,不需要提前抽象 + +## 独立单站蜘蛛设计 + +### 文件 + +- `py/闪电.py` +- `py/tests/test_闪电.py` + +### Spider 对外行为 + +#### `homeContent` + +返回固定 5 个分类: + +- `1 -> 闪电电影` +- `2 -> 闪电剧集` +- `3 -> 闪电综艺` +- `4 -> 闪电动漫` +- `30 -> 闪电短剧` + +不返回筛选项。 + +#### `homeVideoContent` + +返回: + +```python +{"list": []} +``` + +#### `categoryContent` + +分类 URL: + +- `/index.php/vod/show/id/{tid}/page/{page}.html` + +解析字段: + +- `vod_id` +- `vod_name` +- `vod_pic` +- `vod_remarks` +- `vod_year` + +结果结构包含: + +- `page` +- `limit` +- `total` +- `list` + +不返回 `pagecount`。 + +#### `searchContent` + +搜索 URL: + +- `/index.php/vod/search/page/{page}/wd/{keyword}.html` + +空关键词直接返回空列表。 + +结果字段: + +- `vod_id` +- `vod_name` +- `vod_pic` +- `vod_remarks` + +#### `detailContent` + +详情页提取: + +- `vod_id` +- `vod_name` +- `vod_pic` +- `vod_year` +- `vod_director` +- `vod_actor` +- `vod_content` +- `vod_play_from` +- `vod_play_url` + +只整理网盘线路,不解析站内直链播放页。 + +#### `playerContent` + +已识别网盘分享链接时返回: + +```python +{"parse": 0, "playUrl": "", "url": id} +``` + +非网盘链接返回: + +```python +{"parse": 0, "playUrl": "", "url": ""} +``` + +### URL 与 ID 设计 + +独立单站的 `vod_id` 保持站内短路径,例如: + +- `/index.php/vod/detail/id/123.html` + +详情请求时再与主域名拼接。 + +### 解析策略 + +#### 列表页 + +容器: + +- `#main .module-item` + +提取: + +- 链接:`.module-item-pic a[href]` +- 标题:`.module-item-pic img[alt]` +- 海报:`.module-item-pic img[data-src|src]` +- 备注:`.module-item-text` +- 年份:`.module-item-caption span:first-child` + +#### 搜索页 + +容器: + +- `.module-search-item` + +提取: + +- 链接:`.video-serial[href]` +- 标题:`.video-serial[title]` +- 海报:`.module-item-pic img[data-src|src]` +- 备注:`.video-serial` 文本,缺失时回退 `.module-item-text` + +#### 详情页 + +字段来源: + +- 标题:`.page-title` +- 海报:`.mobile-play .lazyload[data-src|src]` +- 标签区:`.video-info-itemtitle` 与相邻节点 +- 网盘链接:`.module-row-info p` + +字段映射: + +- `年代` -> `vod_year` +- `导演` -> `vod_director` +- `主演` -> `vod_actor` +- `剧情` -> `vod_content` + +### 网盘线路规则 + +支持识别: + +- 百度 +- 139 +- 天翼 +- 123 +- 115 +- 夸克 +- 迅雷 +- 阿里 +- UC + +优先级沿用当前仓库同类盘站: + +1. 百度 +2. 139 +3. 天翼 +4. 123 +5. 115 +6. 夸克 +7. 迅雷 +8. 阿里 +9. UC + +输出规则: + +- `vod_play_from` 使用 `{pan_type}#闪电` +- `vod_play_url` 使用 `{标题}${分享链接}` +- 重复链接去重 +- 非支持网盘链接忽略 + +## 聚合接入设计 + +### 修改文件 + +- `py/玩偶聚合.py` +- `py/tests/test_玩偶聚合.py` + +### 新增站点配置 + +在 `self.sites` 中新增: + +- `id`: `shandian` +- `name`: `闪电` +- `domains`: `["https://sd.sduc.site"]` +- `filter_files`: `[]` +- `list_xpath`: `//*[contains(@class,'module-item')]` +- `search_xpath`: `//*[contains(@class,'module-search-item')]` +- `detail_pan_xpath`: `//*[contains(@class,'module-row-info')]//p` +- `category_url`: `/index.php/vod/show/id/{categoryId}/page/{page}.html` +- `search_url`: `/index.php/vod/search/page/{page}/wd/{keyword}.html` +- `default_categories`: `[("1","电影"),("2","剧集"),("3","综艺"),("4","动漫"),("30","短剧")]` + +这里不配置 `category_url_with_filters`,因为用户给出的参考实现只确认了基础分类分页 URL。 + +### 首页行为 + +`homeContent(False)` 中应新增: + +- `type_id = site_shandian` +- `type_name = 闪电` + +`filters["site_shandian"]` 的首个筛选组应为 `categoryId`,分类值映射到 5 个默认分类。 + +### 分类行为 + +`categoryContent("site_shandian", pg, ..., extend)` 应使用: + +- `extend["categoryId"]` 指定分类 +- 默认值为 `1` +- URL:`https://sd.sduc.site/index.php/vod/show/id//page/.html` + +返回结果中的 `vod_id` 应编码为: + +- `site:shandian:` + +### 搜索行为 + +`_fetch_site_search` 应使用: + +- `/index.php/vod/search/page/{page}/wd/{keyword}.html` + +结果进入现有 `_aggregate_search_results`。 + +站点优先级不调整,沿用当前 `site_priority` 中 `shandian` 的位置。 + +### 详情行为 + +聚合详情不改结构,只保证: + +- `_get_site("shandian")` 能找到配置 +- `_fetch_site_detail` 能正确请求并解析 `闪电` 详情页 +- `detailContent` 合并 `闪电` 网盘线路时遵守现有去重与排序规则 + +## 测试策略 + +### 单站测试 + +新增 `py/tests/test_闪电.py`,至少覆盖: + +- 固定分类 +- 空首页 +- URL 构建 +- 网盘识别 +- 分类列表解析 +- 分类 URL 构造 +- 搜索 URL 构造与解析 +- 空关键词回退 +- 详情元数据提取 +- 网盘线路去重和排序 +- `detailContent` +- `playerContent` + +### 聚合测试 + +在 `py/tests/test_玩偶聚合.py` 中新增至少以下场景: + +- 首页暴露 `site_shandian` +- `site_shandian` 分类组正确 +- `闪电` 搜索 URL 构造与编码 +- `闪电` 分类 URL 构造 +- 聚合详情能合并 `闪电` 的网盘线路 + +## 风险 + +- `闪电` 的 URL 规则与旧 `/vodshow/...` 模板不同,若误复用旧模板会导致聚合接入无效 +- `default_categories` 顺序和 ID 若写错,会让 UI 展示与真实站点不一致 +- 若只补聚合配置、不补单站测试,后续修站时很难快速定位问题 + +## 验收标准 + +满足以下条件即可认为完成: + +- `py/闪电.py` 实现独立 Spider +- `py/tests/test_闪电.py` 覆盖核心行为 +- `py/玩偶聚合.py` 接入 `shandian` +- `py/tests/test_玩偶聚合.py` 覆盖 `闪电` 聚合行为 +- `python -m unittest tests.test_闪电 tests.test_玩偶聚合 -v` 通过 diff --git a/py/tests/test_玩偶聚合.py b/py/tests/test_玩偶聚合.py index a542d57..68fdb01 100644 --- a/py/tests/test_玩偶聚合.py +++ b/py/tests/test_玩偶聚合.py @@ -45,6 +45,21 @@ class TestWanouAggregateSpider(unittest.TestCase): ], ) + def test_home_content_exposes_shandian_site_and_categories(self): + content = self.spider.homeContent(False) + type_ids = [item["type_id"] for item in content["class"]] + self.assertIn("site_shandian", type_ids) + self.assertEqual( + content["filters"]["site_shandian"][0]["value"][1:], + [ + {"n": "电影", "v": "1"}, + {"n": "剧集", "v": "2"}, + {"n": "综艺", "v": "3"}, + {"n": "动漫", "v": "4"}, + {"n": "短剧", "v": "30"}, + ], + ) + @patch.object( Spider, "_load_local_filter_groups", @@ -372,6 +387,33 @@ class TestWanouAggregateSpider(unittest.TestCase): }, ) + @patch.object(Spider, "_request_with_failover") + def test_fetch_site_search_builds_shandian_search_url_and_parses_results(self, mock_request_with_failover): + mock_request_with_failover.return_value = """ +
+ 抢先版 +
闪电影片
+
+ """ + site = self.spider._get_site("shandian") + results = self.spider._fetch_site_search(site, "繁花", 1) + self.assertEqual( + mock_request_with_failover.call_args.args[1], + "/index.php/vod/search/page/1/wd/%E7%B9%81%E8%8A%B1.html", + ) + self.assertEqual( + results[0], + { + "vod_id": "site:shandian:/index.php/vod/detail/id/789.html", + "vod_name": "闪电影片", + "vod_pic": "https://sd.sduc.site/search.jpg", + "vod_remarks": "", + "vod_year": "", + "_site": "shandian", + "_detail_path": "/index.php/vod/detail/id/789.html", + }, + ) + @patch.object(Spider, "_fetch_site_search") def test_search_content_skips_site_errors(self, mock_fetch_site_search): mock_fetch_site_search.side_effect = [ @@ -454,3 +496,57 @@ class TestWanouAggregateSpider(unittest.TestCase): "http://www.miqk.cc/index.php/vod/show/id/24/page/2.html", ) self.assertEqual(result["list"][0]["vod_id"], "site:zhizhen:/index.php/vod/detail/id/456.html") + + @patch.object(Spider, "_request_with_failover") + def test_category_content_builds_shandian_category_url(self, mock_request_with_failover): + mock_request_with_failover.return_value = """ +
+
+ + 闪电分类片 +
+
HD
+
+ """ + result = self.spider.categoryContent("site_shandian", "2", False, {"categoryId": "30"}) + self.assertEqual( + mock_request_with_failover.call_args.args[1], + "https://sd.sduc.site/index.php/vod/show/id/30/page/2.html", + ) + self.assertEqual(result["list"][0]["vod_id"], "site:shandian:/index.php/vod/detail/id/456.html") + + @patch.object(Spider, "_fetch_site_detail") + def test_detail_content_for_aggregate_id_merges_shandian_pan_lines(self, mock_fetch_site_detail): + mock_fetch_site_detail.side_effect = [ + { + "vod_name": "繁花", + "vod_pic": "https://img.example/w.jpg", + "vod_year": "2024", + "vod_director": "导演甲", + "vod_actor": "演员甲", + "vod_content": "玩偶简介", + "pan_urls": ["https://pan.baidu.com/s/b1"], + "_site_name": "玩偶", + }, + { + "vod_name": "繁花", + "vod_pic": "https://sd.sduc.site/poster.jpg", + "vod_year": "2024", + "vod_director": "导演乙", + "vod_actor": "演员乙", + "vod_content": "闪电简介", + "pan_urls": ["https://pan.quark.cn/s/s1", "https://pan.baidu.com/s/b1"], + "_site_name": "闪电", + }, + ] + payload = [ + {"site": "wanou", "path": "/voddetail/1.html", "name": "繁花", "year": "2024"}, + {"site": "shandian", "path": "/index.php/vod/detail/id/2.html", "name": "繁花", "year": "2024"}, + ] + result = self.spider.detailContent([self.spider._encode_aggregate_vod_id(payload)]) + vod = result["list"][0] + self.assertEqual(vod["vod_play_from"], "baidu#玩偶$$$quark#闪电") + self.assertEqual( + vod["vod_play_url"], + "百度资源$https://pan.baidu.com/s/b1$$$夸克资源$https://pan.quark.cn/s/s1", + ) diff --git a/py/tests/test_闪电.py b/py/tests/test_闪电.py new file mode 100644 index 0000000..df74fcd --- /dev/null +++ b/py/tests/test_闪电.py @@ -0,0 +1,197 @@ +import unittest +from importlib.machinery import SourceFileLoader +from pathlib import Path +from unittest.mock import patch + + +ROOT = Path(__file__).resolve().parents[1] +MODULE = SourceFileLoader("shandian_spider", str(ROOT / "闪电.py")).load_module() +Spider = MODULE.Spider + + +class TestShanDianSpider(unittest.TestCase): + def setUp(self): + Spider._instance = None + self.spider = Spider() + self.spider.init() + + def test_home_content_exposes_all_categories(self): + content = self.spider.homeContent(False) + self.assertEqual( + [(item["type_id"], item["type_name"]) for item in content["class"]], + [ + ("1", "闪电电影"), + ("2", "闪电剧集"), + ("3", "闪电综艺"), + ("4", "闪电动漫"), + ("30", "闪电短剧"), + ], + ) + + def test_home_video_content_returns_empty_list(self): + self.assertEqual(self.spider.homeVideoContent(), {"list": []}) + + def test_build_url_and_detect_pan_type(self): + self.assertEqual( + self.spider._build_url("/index.php/vod/detail/id/1.html"), + "https://sd.sduc.site/index.php/vod/detail/id/1.html", + ) + self.assertEqual(self.spider._detect_pan_type("https://pan.baidu.com/s/demo"), ("baidu", "百度资源")) + self.assertEqual(self.spider._detect_pan_type("https://pan.quark.cn/s/demo"), ("quark", "夸克资源")) + self.assertEqual(self.spider._detect_pan_type("https://example.com/video"), ("", "")) + + def test_parse_cards_extracts_short_path_ids(self): + html = """ +
+
+
+ + 示例影片 +
+
HD
+
2025
+
+
+ """ + self.assertEqual( + self.spider._parse_cards(html), + [ + { + "vod_id": "/index.php/vod/detail/id/123.html", + "vod_name": "示例影片", + "vod_pic": "https://sd.sduc.site/poster.jpg", + "vod_remarks": "HD", + "vod_year": "2025", + } + ], + ) + + @patch.object(Spider, "_request_html") + def test_category_content_builds_reference_url_and_returns_page_payload(self, mock_request_html): + mock_request_html.return_value = """ +
+
+
+ + 分类影片 +
+
更新至10集
+
2024
+
+
+ """ + result = self.spider.categoryContent("2", "3", False, {}) + self.assertEqual( + mock_request_html.call_args.args[0], + "https://sd.sduc.site/index.php/vod/show/id/2/page/3.html", + ) + self.assertEqual(result["page"], 3) + self.assertEqual(result["limit"], 1) + self.assertEqual(result["list"][0]["vod_name"], "分类影片") + self.assertNotIn("pagecount", result) + + @patch.object(Spider, "_request_html") + def test_search_content_builds_reference_search_url_and_parses_results(self, mock_request_html): + mock_request_html.return_value = """ +
+ 抢先版 +
+ 搜索影片 +
+
+ """ + result = self.spider.searchContent("繁花", False, "2") + self.assertEqual( + mock_request_html.call_args.args[0], + "https://sd.sduc.site/index.php/vod/search/page/2/wd/%E7%B9%81%E8%8A%B1.html", + ) + self.assertEqual( + result["list"][0], + { + "vod_id": "/index.php/vod/detail/id/789.html", + "vod_name": "搜索影片", + "vod_pic": "https://sd.sduc.site/search.jpg", + "vod_remarks": "抢先版", + }, + ) + + def test_search_content_returns_empty_list_for_blank_keyword(self): + self.assertEqual(self.spider.searchContent("", False, "1"), {"page": 1, "total": 0, "list": []}) + + def test_build_pan_lines_deduplicates_and_sorts_supported_links(self): + detail = { + "pan_urls": [ + "https://pan.quark.cn/s/q1", + "https://pan.baidu.com/s/b1", + "https://pan.baidu.com/s/b1", + "https://example.com/ignored", + ] + } + self.assertEqual( + self.spider._build_pan_lines(detail), + [ + ("baidu#闪电", "百度资源$https://pan.baidu.com/s/b1"), + ("quark#闪电", "夸克资源$https://pan.quark.cn/s/q1"), + ], + ) + + def test_parse_detail_page_extracts_meta_content_and_pan_urls(self): + html = """ +
示例剧
+
+
年代
2024
+
导演
导演甲
+
主演
演员甲演员乙
+
剧情

一段剧情简介

+
+

https://pan.quark.cn/s/q1

+

https://pan.baidu.com/s/b1

+
+ """ + detail = self.spider._parse_detail_page("/index.php/vod/detail/id/123.html", html) + self.assertEqual(detail["vod_name"], "示例剧") + self.assertEqual(detail["vod_pic"], "https://sd.sduc.site/poster.jpg") + self.assertEqual(detail["vod_year"], "2024") + self.assertEqual(detail["vod_director"], "导演甲") + self.assertEqual(detail["vod_actor"], "演员甲,演员乙") + self.assertEqual(detail["vod_content"], "一段剧情简介") + self.assertEqual(detail["pan_urls"], ["https://pan.quark.cn/s/q1", "https://pan.baidu.com/s/b1"]) + + @patch.object(Spider, "_request_html") + def test_detail_content_builds_pan_play_fields(self, mock_request_html): + mock_request_html.return_value = """ +
示例剧
+
+
年代
2024
+
导演
导演甲
+
主演
演员甲
+
剧情

一段剧情简介

+
+

https://pan.quark.cn/s/q1

+

https://pan.baidu.com/s/b1

+
+ """ + result = self.spider.detailContent(["/index.php/vod/detail/id/123.html"]) + vod = result["list"][0] + self.assertEqual(vod["vod_name"], "示例剧") + self.assertEqual(vod["vod_play_from"], "baidu#闪电$$$quark#闪电") + self.assertEqual( + vod["vod_play_url"], + "百度资源$https://pan.baidu.com/s/b1$$$夸克资源$https://pan.quark.cn/s/q1", + ) + + def test_player_content_passthroughs_supported_pan_urls(self): + self.assertEqual( + self.spider.playerContent("baidu#闪电", "https://pan.baidu.com/s/demo", {}), + {"parse": 0, "playUrl": "", "url": "https://pan.baidu.com/s/demo"}, + ) + + def test_player_content_rejects_non_pan_url(self): + self.assertEqual( + self.spider.playerContent("site", "/index.php/vod/play/id/1.html", {}), + {"parse": 0, "playUrl": "", "url": ""}, + ) + + +if __name__ == "__main__": + unittest.main() diff --git a/py/玩偶聚合.py b/py/玩偶聚合.py index 9e9cb0f..41d4c15 100644 --- a/py/玩偶聚合.py +++ b/py/玩偶聚合.py @@ -102,6 +102,24 @@ class Spider(BaseSpider): ("26", "严选"), ], }, + { + "id": "shandian", + "name": "闪电", + "domains": ["https://sd.sduc.site"], + "filter_files": [], + "list_xpath": "//*[contains(@class,'module-item')]", + "search_xpath": "//*[contains(@class,'module-search-item')]", + "detail_pan_xpath": "//*[contains(@class,'module-row-info')]//p", + "category_url": "/index.php/vod/show/id/{categoryId}/page/{page}.html", + "search_url": "/index.php/vod/search/page/{page}/wd/{keyword}.html", + "default_categories": [ + ("1", "电影"), + ("2", "剧集"), + ("3", "综艺"), + ("4", "动漫"), + ("30", "短剧"), + ], + }, ] def init(self, extend=""): diff --git a/py/闪电.py b/py/闪电.py new file mode 100644 index 0000000..e60d9ed --- /dev/null +++ b/py/闪电.py @@ -0,0 +1,250 @@ +# coding=utf-8 +import re +import sys +from urllib.parse import quote, urljoin + +from base.spider import Spider as BaseSpider + +sys.path.append("..") + + +class Spider(BaseSpider): + def __init__(self): + self.name = "闪电" + self.host = "https://sd.sduc.site" + 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": self.host + "/", + } + self.categories = [ + {"type_id": "1", "type_name": "闪电电影"}, + {"type_id": "2", "type_name": "闪电剧集"}, + {"type_id": "3", "type_name": "闪电综艺"}, + {"type_id": "4", "type_name": "闪电动漫"}, + {"type_id": "30", "type_name": "闪电短剧"}, + ] + self.pan_patterns = [ + ("baidu", "百度资源", r"pan\.baidu\.com|yun\.baidu\.com"), + ("a139", "139资源", r"yun\.139\.com"), + ("a189", "天翼资源", r"cloud\.189\.cn"), + ("a123", "123资源", r"123684\.com|123865\.com|123912\.com|123pan\.com"), + ("a115", "115资源", r"115\.com"), + ("quark", "夸克资源", r"pan\.quark\.cn"), + ("xunlei", "迅雷资源", r"pan\.xunlei\.com"), + ("aliyun", "阿里资源", r"aliyundrive\.com|alipan\.com"), + ("uc", "UC资源", r"drive\.uc\.cn"), + ] + self.pan_priority = { + "baidu": 1, + "a139": 2, + "a189": 3, + "a123": 4, + "a115": 5, + "quark": 6, + "xunlei": 7, + "aliyun": 8, + "uc": 9, + } + + def init(self, extend=""): + return None + + def getName(self): + return self.name + + def homeContent(self, filter): + return {"class": self.categories} + + def homeVideoContent(self): + return {"list": []} + + def _build_url(self, path): + return urljoin(self.host + "/", str(path or "").strip()) + + def _clean_text(self, text): + return re.sub(r"\s+", " ", str(text or "").replace("\xa0", " ")).strip() + + def _detect_pan_type(self, url): + raw = str(url or "").strip() + for pan_type, title, pattern in self.pan_patterns: + if re.search(pattern, raw, re.I): + return pan_type, title + return "", "" + + def _request_html(self, path_or_url): + target = path_or_url if str(path_or_url).startswith("http") else self._build_url(path_or_url) + response = self.fetch(target, headers=dict(self.headers), timeout=10) + if response.status_code != 200: + return "" + return response.text or "" + + def _page_result(self, items, pg): + page = int(pg) + return {"page": page, "limit": len(items), "total": page * 20 + len(items), "list": items} + + def _parse_cards(self, html): + root = self.html(html) + if root is None: + return [] + + items = [] + seen = set() + for node in root.xpath("//*[@id='main']//*[contains(@class,'module-item')]"): + href = "".join(node.xpath(".//*[contains(@class,'module-item-pic')]//a[1]/@href")).strip() + title = "".join(node.xpath(".//*[contains(@class,'module-item-pic')]//img[1]/@alt")).strip() + pic = ( + "".join(node.xpath(".//*[contains(@class,'module-item-pic')]//img[1]/@data-src")).strip() + or "".join(node.xpath(".//*[contains(@class,'module-item-pic')]//img[1]/@src")).strip() + ) + remarks = self._clean_text("".join(node.xpath(".//*[contains(@class,'module-item-text')][1]//text()"))) + year = self._clean_text("".join(node.xpath(".//*[contains(@class,'module-item-caption')][1]//span[1]//text()"))) + if not href or not title or href in seen: + continue + seen.add(href) + items.append( + { + "vod_id": href, + "vod_name": title, + "vod_pic": self._build_url(pic), + "vod_remarks": remarks, + "vod_year": year, + } + ) + return items + + def categoryContent(self, tid, pg, filter, extend): + url = self._build_url(f"/index.php/vod/show/id/{tid}/page/{int(pg)}.html") + return self._page_result(self._parse_cards(self._request_html(url)), pg) + + def searchContent(self, key, quick, pg="1"): + keyword = self._clean_text(key) + page = int(pg) + if not keyword: + return {"page": page, "total": 0, "list": []} + + url = self._build_url(f"/index.php/vod/search/page/{page}/wd/{quote(keyword)}.html") + root = self.html(self._request_html(url)) + if root is None: + return {"page": page, "total": 0, "list": []} + + items = [] + for node in root.xpath("//*[contains(@class,'module-search-item')]"): + href = "".join(node.xpath(".//*[contains(@class,'video-serial')][1]/@href")).strip() + title = "".join(node.xpath(".//*[contains(@class,'video-serial')][1]/@title")).strip() + pic = ( + "".join(node.xpath(".//*[contains(@class,'module-item-pic')]//img[1]/@data-src")).strip() + or "".join(node.xpath(".//*[contains(@class,'module-item-pic')]//img[1]/@src")).strip() + ) + remarks = self._clean_text( + "".join(node.xpath(".//*[contains(@class,'video-serial')][1]//text()")) + or "".join(node.xpath(".//*[contains(@class,'module-item-text')][1]//text()")) + ) + if not href or not title: + continue + items.append( + { + "vod_id": href, + "vod_name": title, + "vod_pic": self._build_url(pic), + "vod_remarks": remarks, + } + ) + return {"page": page, "total": len(items), "list": items} + + def _parse_detail_page(self, vod_id, html): + root = self.html(html) + if root is None: + return { + "vod_id": vod_id, + "vod_name": "", + "vod_pic": "", + "vod_year": "", + "vod_director": "", + "vod_actor": "", + "vod_content": "", + "pan_urls": [], + } + + detail = { + "vod_id": vod_id, + "vod_name": self._clean_text("".join(root.xpath("//*[contains(@class,'page-title')][1]//text()"))), + "vod_pic": self._build_url( + "".join( + root.xpath( + "//*[contains(@class,'mobile-play')]//*[contains(@class,'lazyload')][1]/@data-src | " + "//*[contains(@class,'mobile-play')]//*[contains(@class,'lazyload')][1]/@src" + ) + ).strip() + ), + "vod_year": "", + "vod_director": "", + "vod_actor": "", + "vod_content": "", + "pan_urls": [], + } + + for label_node in root.xpath("//*[contains(@class,'video-info-itemtitle')]"): + key = self._clean_text("".join(label_node.xpath(".//text()"))) + sibling = label_node.getnext() + if sibling is None: + continue + values = [self._clean_text(text) for text in sibling.xpath(".//a//text()")] + joined = ",".join([value for value in values if value]) + text_value = self._clean_text("".join(sibling.xpath(".//text()"))) + if "年代" in key: + detail["vod_year"] = joined or text_value + elif "导演" in key: + detail["vod_director"] = joined or text_value + elif "主演" in key: + detail["vod_actor"] = joined or text_value + elif "剧情" in key: + detail["vod_content"] = text_value + + for node in root.xpath("//*[contains(@class,'module-row-info')]//p"): + text = self._clean_text("".join(node.xpath(".//text()"))) + if text: + detail["pan_urls"].append(text) + return detail + + def _build_pan_lines(self, detail): + lines = [] + seen = set() + for url in detail.get("pan_urls", []): + pan_type, title = self._detect_pan_type(url) + if not pan_type or url in seen: + continue + seen.add(url) + lines.append((self.pan_priority.get(pan_type, 999), f"{pan_type}#闪电", f"{title}${url}")) + lines.sort(key=lambda item: item[0]) + return [(item[1], item[2]) for item in lines] + + def detailContent(self, ids): + result = {"list": []} + for raw_id in ids: + vod_id = str(raw_id or "").strip() + detail = self._parse_detail_page(vod_id, self._request_html(self._build_url(vod_id))) + lines = self._build_pan_lines(detail) + result["list"].append( + { + "vod_id": vod_id, + "vod_name": detail["vod_name"], + "vod_pic": detail["vod_pic"], + "vod_year": detail["vod_year"], + "vod_director": detail["vod_director"], + "vod_actor": detail["vod_actor"], + "vod_content": detail["vod_content"], + "vod_play_from": "$$$".join([item[0] for item in lines]), + "vod_play_url": "$$$".join([item[1] for item in lines]), + } + ) + return result + + def playerContent(self, flag, id, vipFlags): + pan_type, _ = self._detect_pan_type(id) + if pan_type: + return {"parse": 0, "playUrl": "", "url": id} + return {"parse": 0, "playUrl": "", "url": ""}