mirror of
https://github.com/ls125781003/tvboxtg.git
synced 2025-10-26 19:32:38 +00:00
更新潇洒线路
v05.28
This commit is contained in:
Liu
146
潇洒/PY/嗨皮影视.py
146
潇洒/PY/嗨皮影视.py
@@ -1,146 +0,0 @@
|
|||||||
# -*- coding: utf-8 -*-
|
|
||||||
# by @嗷呜
|
|
||||||
import sys
|
|
||||||
sys.path.append('..')
|
|
||||||
from base.spider import Spider
|
|
||||||
import requests
|
|
||||||
|
|
||||||
|
|
||||||
class Spider(Spider):
|
|
||||||
|
|
||||||
def init(self, extend=""):
|
|
||||||
pass
|
|
||||||
|
|
||||||
def getName(self):
|
|
||||||
return "hitv"
|
|
||||||
|
|
||||||
def isVideoFormat(self, url):
|
|
||||||
pass
|
|
||||||
|
|
||||||
def manualVideoCheck(self):
|
|
||||||
pass
|
|
||||||
|
|
||||||
def destroy(self):
|
|
||||||
pass
|
|
||||||
|
|
||||||
def homeContent(self, filter):
|
|
||||||
result = {}
|
|
||||||
cateManual = {
|
|
||||||
# "直播": "live",
|
|
||||||
'排行榜': 'rank',
|
|
||||||
"电影": "1",
|
|
||||||
"剧集": "2",
|
|
||||||
"综艺": "3",
|
|
||||||
"动画": "4",
|
|
||||||
"短片": "5"
|
|
||||||
}
|
|
||||||
classes = []
|
|
||||||
for k in cateManual:
|
|
||||||
classes.append({
|
|
||||||
'type_name': k,
|
|
||||||
'type_id': cateManual[k]
|
|
||||||
})
|
|
||||||
result['class'] = classes
|
|
||||||
return result
|
|
||||||
|
|
||||||
host = "https://wys.upfuhn.com"
|
|
||||||
headers = {
|
|
||||||
"User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) "
|
|
||||||
"Chrome/80.0.3987.149 Safari/537.36"
|
|
||||||
}
|
|
||||||
|
|
||||||
def list(self, list):
|
|
||||||
videos = []
|
|
||||||
for it in list:
|
|
||||||
videos.append({
|
|
||||||
"vod_id": it['video_site_id'],
|
|
||||||
"vod_name": it['video_name'],
|
|
||||||
"vod_pic": it['video_horizontal_url'] or it['video_vertical_url'],
|
|
||||||
"vod_remarks": it['newest_series_num'],
|
|
||||||
"vod_year": it['years'],
|
|
||||||
})
|
|
||||||
return videos
|
|
||||||
|
|
||||||
def homeVideoContent(self):
|
|
||||||
url = f'{self.host}/v1/ys_video_sites/hot?t=1'
|
|
||||||
data = requests.get(url, headers=self.headers).json()
|
|
||||||
videos = self.list(data['data']['data'])
|
|
||||||
result = {'list': videos}
|
|
||||||
return result
|
|
||||||
|
|
||||||
def categoryContent(self, tid, pg, filter, extend):
|
|
||||||
path = f'/v1/ys_video_sites?t={tid}&s_t=0&a&y&o=0&ps=21&pn={pg}'
|
|
||||||
rank = False
|
|
||||||
if tid == 'rank':
|
|
||||||
if pg == 1:
|
|
||||||
path = f'/v1/ys_video_sites/ranking'
|
|
||||||
rank = True
|
|
||||||
else:
|
|
||||||
path = ''
|
|
||||||
# elif tid == 'live' and pg == 1:
|
|
||||||
# path = f'/v1/ys_live_tvs'
|
|
||||||
videos = []
|
|
||||||
result = {}
|
|
||||||
try:
|
|
||||||
data = requests.get(self.host + path, headers=self.headers).json()
|
|
||||||
if rank:
|
|
||||||
for video in data['data']:
|
|
||||||
videos.extend(data['data'][video])
|
|
||||||
else:
|
|
||||||
videos = data['data']['data']
|
|
||||||
result = {}
|
|
||||||
result['list'] = self.list(videos)
|
|
||||||
result['page'] = pg
|
|
||||||
result['pagecount'] = 9999
|
|
||||||
result['limit'] = 90
|
|
||||||
result['total'] = 999999
|
|
||||||
except:
|
|
||||||
result['list'] = []
|
|
||||||
return result
|
|
||||||
|
|
||||||
def detailContent(self, ids):
|
|
||||||
tid = ids[0]
|
|
||||||
url = f'{self.host}/v1/ys_video_series/by_vid/{tid}'
|
|
||||||
data = requests.get(url, headers=self.headers).json()
|
|
||||||
data1 = data['data']['ys_video_site']
|
|
||||||
urls = []
|
|
||||||
for it in data['data']['data']:
|
|
||||||
urls.append(it['series_num'] + '$' + it['video_url'])
|
|
||||||
vod = {
|
|
||||||
'vod_name': data1['video_name'],
|
|
||||||
'type_name': data1['tag'],
|
|
||||||
'vod_year': data1['years'],
|
|
||||||
'vod_area': data1['area'],
|
|
||||||
'vod_director': data1['main_actor'],
|
|
||||||
'vod_content': data1['video_desc'],
|
|
||||||
'vod_play_from': '嗨皮在线',
|
|
||||||
'vod_play_url': '#'.join(urls),
|
|
||||||
}
|
|
||||||
result = {
|
|
||||||
'list': [
|
|
||||||
vod
|
|
||||||
]
|
|
||||||
}
|
|
||||||
return result
|
|
||||||
|
|
||||||
def searchContent(self, key, quick, pg=1):
|
|
||||||
url = f'{self.host}/v1/ys_video_sites/search?s={key}&o=0&ps=200&pn={pg}'
|
|
||||||
data = requests.get(url, headers=self.headers).json()
|
|
||||||
videos = data['data']['video_sites']
|
|
||||||
if data['data']['first_video_series'] is not None:
|
|
||||||
videos = [data['data']['first_video_series']] + videos
|
|
||||||
result = {}
|
|
||||||
result['list'] = self.list(videos)
|
|
||||||
result['page'] = pg
|
|
||||||
return result
|
|
||||||
|
|
||||||
def playerContent(self, flag, id, vipFlags):
|
|
||||||
result = {
|
|
||||||
'url': id,
|
|
||||||
'parse': 0,
|
|
||||||
'header': self.headers
|
|
||||||
}
|
|
||||||
return result
|
|
||||||
|
|
||||||
def localProxy(self, param):
|
|
||||||
pass
|
|
||||||
68
潇洒/api.json
68
潇洒/api.json
@@ -91,6 +91,48 @@
|
|||||||
"searchable": 1,
|
"searchable": 1,
|
||||||
"quickSearch": 1
|
"quickSearch": 1
|
||||||
},
|
},
|
||||||
|
{
|
||||||
|
"key": "橘猫",
|
||||||
|
"name": "橘猫｜APP",
|
||||||
|
"type": 3,
|
||||||
|
"quickSearch": 1,
|
||||||
|
"api": "csp_AppGet",
|
||||||
|
"ext": {
|
||||||
|
"url": "https://appcms.jm4k.top",
|
||||||
|
"dataKey": "KPEkKAESYi38CQdn",
|
||||||
|
"dataIv": "KPEkKAESYi38CQdn",
|
||||||
|
"deviceId": "",
|
||||||
|
"version": "119"
|
||||||
|
}
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"key": "忍者",
|
||||||
|
"name": "忍者｜APP",
|
||||||
|
"type": 3,
|
||||||
|
"quickSearch": 1,
|
||||||
|
"api": "csp_AppGet",
|
||||||
|
"ext": {
|
||||||
|
"url": "https://mfxs123.sbs",
|
||||||
|
"dataKey": "1234567887654321",
|
||||||
|
"dataIv": "1234567887654321",
|
||||||
|
"deviceId": "",
|
||||||
|
"version": ""
|
||||||
|
}
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"key": "晴天",
|
||||||
|
"name": "晴天｜APP",
|
||||||
|
"type": 3,
|
||||||
|
"quickSearch": 1,
|
||||||
|
"api": "csp_AppGet",
|
||||||
|
"ext": {
|
||||||
|
"url": "https://qjappcms.sun4k.top",
|
||||||
|
"dataKey": "sBxqXVF5pAHbGzrH",
|
||||||
|
"dataIv": "sBxqXVF5pAHbGzrH",
|
||||||
|
"deviceId": "",
|
||||||
|
"version": "119"
|
||||||
|
}
|
||||||
|
},
|
||||||
{
|
{
|
||||||
"key": "再看",
|
"key": "再看",
|
||||||
"name": "再看｜APP",
|
"name": "再看｜APP",
|
||||||
@@ -745,17 +787,6 @@
|
|||||||
"quickSearch": 0,
|
"quickSearch": 0,
|
||||||
"filterable": 0
|
"filterable": 0
|
||||||
},
|
},
|
||||||
{
|
|
||||||
"key": "河马短剧",
|
|
||||||
"name": "河马｜短剧",
|
|
||||||
"type": 3,
|
|
||||||
"api": "./py/河马短剧.py",
|
|
||||||
"searchable": 1,
|
|
||||||
"changeable": 1,
|
|
||||||
"quickSearch": 1,
|
|
||||||
"filterable": 1,
|
|
||||||
"playerType": 2
|
|
||||||
},
|
|
||||||
{
|
{
|
||||||
"key": "偷乐短剧",
|
"key": "偷乐短剧",
|
||||||
"name": "偷乐｜短剧",
|
"name": "偷乐｜短剧",
|
||||||
@@ -857,17 +888,6 @@
|
|||||||
"filterable": 1,
|
"filterable": 1,
|
||||||
"playerType": 2
|
"playerType": 2
|
||||||
},
|
},
|
||||||
{
|
|
||||||
"key": "嗨皮影视",
|
|
||||||
"name": "嗨皮｜影视",
|
|
||||||
"type": 3,
|
|
||||||
"api": "./py/嗨皮影视.py",
|
|
||||||
"searchable": 1,
|
|
||||||
"changeable": 1,
|
|
||||||
"quickSearch": 1,
|
|
||||||
"filterable": 1,
|
|
||||||
"playerType": 2
|
|
||||||
},
|
|
||||||
{
|
{
|
||||||
"key": "快看",
|
"key": "快看",
|
||||||
"name": "快看｜影视",
|
"name": "快看｜影视",
|
||||||
@@ -2204,7 +2224,7 @@
|
|||||||
{
|
{
|
||||||
"name": "AI直播",
|
"name": "AI直播",
|
||||||
"type": 0,
|
"type": 0,
|
||||||
"url": "https://gh-proxy.com/https://raw.githubusercontent.com/PizazzGY/TV/master/output/user_result.txt",
|
"url": "https://wget.la/https://raw.githubusercontent.com/PizazzGY/TV/master/output/user_result.txt",
|
||||||
"epg": "http://cdn.1678520.xyz/epg/?ch={name}&date={date}",
|
"epg": "http://cdn.1678520.xyz/epg/?ch={name}&date={date}",
|
||||||
"playerType": 1,
|
"playerType": 1,
|
||||||
"timeout": 10
|
"timeout": 10
|
||||||
@@ -2277,7 +2297,7 @@
|
|||||||
{
|
{
|
||||||
"name": "APTV",
|
"name": "APTV",
|
||||||
"type": 0,
|
"type": 0,
|
||||||
"url": "https://gh-proxy.com/https://github.com/Kimentanm/aptv/raw/master/m3u/iptv.m3u",
|
"url": "https://wget.la/https://github.com/Kimentanm/aptv/raw/master/m3u/iptv.m3u",
|
||||||
"epg": "http://epg.51zmt.top:8000/api/diyp/?ch={name}&date={date}",
|
"epg": "http://epg.51zmt.top:8000/api/diyp/?ch={name}&date={date}",
|
||||||
"logo": "https://epg.iill.top/logo/{name}.png",
|
"logo": "https://epg.iill.top/logo/{name}.png",
|
||||||
"ua": "okhttp/3.15,AptvPlayer/1.4.0",
|
"ua": "okhttp/3.15,AptvPlayer/1.4.0",
|
||||||
|
|||||||
581
潇洒/py/河马短剧.py
581
潇洒/py/河马短剧.py
@@ -1,581 +0,0 @@
|
|||||||
# -*- coding: utf-8 -*-
|
|
||||||
import requests
|
|
||||||
import re
|
|
||||||
import json
|
|
||||||
import traceback
|
|
||||||
import sys
|
|
||||||
|
|
||||||
sys.path.append('../../')
|
|
||||||
try:
|
|
||||||
from base.spider import Spider
|
|
||||||
except ImportError:
|
|
||||||
# 定义一个基础接口类，用于本地测试
|
|
||||||
class Spider:
|
|
||||||
def init(self, extend=""):
|
|
||||||
pass
|
|
||||||
|
|
||||||
class Spider(Spider):
|
|
||||||
def __init__(self):
|
|
||||||
self.siteUrl = "https://www.kuaikaw.cn"
|
|
||||||
self.nextData = None # 缓存NEXT_DATA数据
|
|
||||||
self.cateManual = {
|
|
||||||
"甜宠": "462",
|
|
||||||
"古装仙侠": "1102",
|
|
||||||
"现代言情": "1145",
|
|
||||||
"青春": "1170",
|
|
||||||
"豪门恩怨": "585",
|
|
||||||
"逆袭": "417-464",
|
|
||||||
"重生": "439-465",
|
|
||||||
"系统": "1159",
|
|
||||||
"总裁": "1147",
|
|
||||||
"职场商战": "943"
|
|
||||||
}
|
|
||||||
|
|
||||||
def getName(self):
|
|
||||||
# 返回爬虫名称
|
|
||||||
return "河马短剧"
|
|
||||||
|
|
||||||
def init(self, extend=""):
|
|
||||||
return
|
|
||||||
|
|
||||||
def fetch(self, url, headers=None):
|
|
||||||
"""统一的网络请求接口"""
|
|
||||||
if headers is None:
|
|
||||||
headers = {
|
|
||||||
"User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36 Edg/120.0.0.0",
|
|
||||||
"Referer": self.siteUrl,
|
|
||||||
"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"
|
|
||||||
}
|
|
||||||
|
|
||||||
try:
|
|
||||||
response = requests.get(url, headers=headers, timeout=10, allow_redirects=True)
|
|
||||||
response.raise_for_status()
|
|
||||||
return response
|
|
||||||
except Exception as e:
|
|
||||||
print(f"请求异常: {url}, 错误: {str(e)}")
|
|
||||||
return None
|
|
||||||
|
|
||||||
def isVideoFormat(self, url):
|
|
||||||
# 检查是否为视频格式
|
|
||||||
video_formats = ['.mp4', '.mkv', '.avi', '.wmv', '.m3u8', '.flv', '.rmvb']
|
|
||||||
for format in video_formats:
|
|
||||||
if format in url.lower():
|
|
||||||
return True
|
|
||||||
return False
|
|
||||||
|
|
||||||
def manualVideoCheck(self):
|
|
||||||
# 不需要手动检查
|
|
||||||
return False
|
|
||||||
|
|
||||||
def homeContent(self, filter):
|
|
||||||
"""获取首页分类及筛选"""
|
|
||||||
result = {}
|
|
||||||
# 分类列表，使用已初始化的cateManual
|
|
||||||
classes = []
|
|
||||||
for k in self.cateManual:
|
|
||||||
classes.append({
|
|
||||||
'type_name': k,
|
|
||||||
'type_id': self.cateManual[k]
|
|
||||||
})
|
|
||||||
result['class'] = classes
|
|
||||||
# 获取首页推荐视频
|
|
||||||
try:
|
|
||||||
result['list'] = self.homeVideoContent()['list']
|
|
||||||
except:
|
|
||||||
result['list'] = []
|
|
||||||
|
|
||||||
return result
|
|
||||||
|
|
||||||
def homeVideoContent(self):
|
|
||||||
"""获取首页推荐视频内容"""
|
|
||||||
videos = []
|
|
||||||
try:
|
|
||||||
response = self.fetch(self.siteUrl)
|
|
||||||
html_content = response.text
|
|
||||||
# 提取NEXT_DATA JSON数据
|
|
||||||
next_data_pattern = r'<script id="__NEXT_DATA__" type="application/json">(.*?)</script>'
|
|
||||||
next_data_match = re.search(next_data_pattern, html_content, re.DOTALL)
|
|
||||||
if next_data_match:
|
|
||||||
next_data_json = json.loads(next_data_match.group(1))
|
|
||||||
page_props = next_data_json.get("props", {}).get("pageProps", {})
|
|
||||||
# 获取轮播图数据 - 这些通常是推荐内容
|
|
||||||
if "bannerList" in page_props and isinstance(page_props["bannerList"], list):
|
|
||||||
banner_list = page_props["bannerList"]
|
|
||||||
for banner in banner_list:
|
|
||||||
book_id = banner.get("bookId", "")
|
|
||||||
book_name = banner.get("bookName", "")
|
|
||||||
cover_url = banner.get("coverWap", banner.get("wapUrl", ""))
|
|
||||||
# 获取状态和章节数
|
|
||||||
status = banner.get("statusDesc", "")
|
|
||||||
total_chapters = banner.get("totalChapterNum", "")
|
|
||||||
if book_id and book_name:
|
|
||||||
videos.append({
|
|
||||||
"vod_id": f"/drama/{book_id}",
|
|
||||||
"vod_name": book_name,
|
|
||||||
"vod_pic": cover_url,
|
|
||||||
"vod_remarks": f"{status} {total_chapters}集" if total_chapters else status
|
|
||||||
})
|
|
||||||
|
|
||||||
# SEO分类下的推荐
|
|
||||||
if "seoColumnVos" in page_props and isinstance(page_props["seoColumnVos"], list):
|
|
||||||
for column in page_props["seoColumnVos"]:
|
|
||||||
book_infos = column.get("bookInfos", [])
|
|
||||||
for book in book_infos:
|
|
||||||
book_id = book.get("bookId", "")
|
|
||||||
book_name = book.get("bookName", "")
|
|
||||||
cover_url = book.get("coverWap", "")
|
|
||||||
status = book.get("statusDesc", "")
|
|
||||||
total_chapters = book.get("totalChapterNum", "")
|
|
||||||
|
|
||||||
if book_id and book_name:
|
|
||||||
videos.append({
|
|
||||||
"vod_id": f"/drama/{book_id}",
|
|
||||||
"vod_name": book_name,
|
|
||||||
"vod_pic": cover_url,
|
|
||||||
"vod_remarks": f"{status} {total_chapters}集" if total_chapters else status
|
|
||||||
})
|
|
||||||
|
|
||||||
# # 去重
|
|
||||||
# seen = set()
|
|
||||||
# unique_videos = []
|
|
||||||
# for video in videos:
|
|
||||||
# if video["vod_id"] not in seen:
|
|
||||||
# seen.add(video["vod_id"])
|
|
||||||
# unique_videos.append(video)
|
|
||||||
# videos = unique_videos
|
|
||||||
|
|
||||||
except Exception as e:
|
|
||||||
print(f"获取首页推荐内容出错: {e}")
|
|
||||||
|
|
||||||
result = {
|
|
||||||
"list": videos
|
|
||||||
}
|
|
||||||
return result
|
|
||||||
|
|
||||||
def categoryContent(self, tid, pg, filter, extend):
|
|
||||||
"""获取分类内容"""
|
|
||||||
result = {}
|
|
||||||
videos = []
|
|
||||||
url = f"{self.siteUrl}/browse/{tid}/{pg}"
|
|
||||||
response = self.fetch(url)
|
|
||||||
html_content = response.text
|
|
||||||
# 提取NEXT_DATA JSON数据
|
|
||||||
next_data_pattern = r'<script id="__NEXT_DATA__" type="application/json">(.*?)</script>'
|
|
||||||
next_data_match = re.search(next_data_pattern, html_content, re.DOTALL)
|
|
||||||
if next_data_match:
|
|
||||||
next_data_json = json.loads(next_data_match.group(1))
|
|
||||||
page_props = next_data_json.get("props", {}).get("pageProps", {})
|
|
||||||
# 获取总页数和当前页
|
|
||||||
current_page = page_props.get("page", 1)
|
|
||||||
total_pages = page_props.get("pages", 1)
|
|
||||||
# 获取书籍列表
|
|
||||||
book_list = page_props.get("bookList", [])
|
|
||||||
# 转换为通用格式
|
|
||||||
for book in book_list:
|
|
||||||
book_id = book.get("bookId", "")
|
|
||||||
book_name = book.get("bookName", "")
|
|
||||||
cover_url = book.get("coverWap", "")
|
|
||||||
status_desc = book.get("statusDesc", "")
|
|
||||||
total_chapters = book.get("totalChapterNum", "")
|
|
||||||
if book_id and book_name:
|
|
||||||
videos.append({
|
|
||||||
"vod_id": f"/drama/{book_id}",
|
|
||||||
"vod_name": book_name,
|
|
||||||
"vod_pic": cover_url,
|
|
||||||
"vod_remarks": f"{status_desc} {total_chapters}集" if total_chapters else status_desc
|
|
||||||
})
|
|
||||||
# 构建返回结果
|
|
||||||
result = {
|
|
||||||
"list": videos,
|
|
||||||
"page": int(current_page),
|
|
||||||
"pagecount": total_pages,
|
|
||||||
"limit": len(videos),
|
|
||||||
"total": total_pages * len(videos) if videos else 0
|
|
||||||
}
|
|
||||||
return result
|
|
||||||
|
|
||||||
def switch(self, key, pg):
|
|
||||||
# 搜索功能
|
|
||||||
search_results = []
|
|
||||||
# 获取第一页结果，并检查总页数
|
|
||||||
url = f"{self.siteUrl}/search?searchValue={key}&page={pg}"
|
|
||||||
response = self.fetch(url)
|
|
||||||
html_content = response.text
|
|
||||||
# 提取NEXT_DATA JSON数据
|
|
||||||
next_data_pattern = r'<script id="__NEXT_DATA__" type="application/json">(.*?)</script>'
|
|
||||||
next_data_match = re.search(next_data_pattern, html_content, re.DOTALL)
|
|
||||||
if next_data_match:
|
|
||||||
next_data_json = json.loads(next_data_match.group(1))
|
|
||||||
page_props = next_data_json.get("props", {}).get("pageProps", {})
|
|
||||||
# 获取总页数
|
|
||||||
total_pages = page_props.get("pages", 1)
|
|
||||||
# 处理所有页的数据
|
|
||||||
all_book_list = []
|
|
||||||
# 添加第一页的书籍列表
|
|
||||||
book_list = page_props.get("bookList", [])
|
|
||||||
all_book_list.extend(book_list)
|
|
||||||
# 如果有多页，获取其他页的数据
|
|
||||||
if total_pages > 1 : # quick模式只获取第一页
|
|
||||||
for page in range(2, total_pages + 1):
|
|
||||||
next_page_url = f"{self.siteUrl}/search?searchValue={key}&page={page}"
|
|
||||||
next_page_response = self.fetch(next_page_url)
|
|
||||||
next_page_html = next_page_response.text
|
|
||||||
next_page_match = re.search(next_data_pattern, next_page_html, re.DOTALL)
|
|
||||||
if next_page_match:
|
|
||||||
next_page_json = json.loads(next_page_match.group(1))
|
|
||||||
next_page_props = next_page_json.get("props", {}).get("pageProps", {})
|
|
||||||
next_page_books = next_page_props.get("bookList", [])
|
|
||||||
all_book_list.extend(next_page_books)
|
|
||||||
# 转换为统一的搜索结果格式
|
|
||||||
for book in all_book_list:
|
|
||||||
book_id = book.get("bookId", "")
|
|
||||||
book_name = book.get("bookName", "")
|
|
||||||
cover_url = book.get("coverWap", "")
|
|
||||||
total_chapters = book.get("totalChapterNum", "0")
|
|
||||||
status_desc = book.get("statusDesc", "")
|
|
||||||
# 构建视频项
|
|
||||||
vod = {
|
|
||||||
"vod_id": f"/drama/{book_id}",
|
|
||||||
"vod_name": book_name,
|
|
||||||
"vod_pic": cover_url,
|
|
||||||
"vod_remarks": f"{status_desc} {total_chapters}集"
|
|
||||||
}
|
|
||||||
search_results.append(vod)
|
|
||||||
result = {
|
|
||||||
"list": search_results,
|
|
||||||
"page": pg
|
|
||||||
}
|
|
||||||
return result
|
|
||||||
|
|
||||||
def searchContent(self, key, quick, pg=1):
|
|
||||||
result = self.switch(key, pg=pg)
|
|
||||||
result['page'] = pg
|
|
||||||
return result
|
|
||||||
|
|
||||||
def searchContentPage(self, key, quick, pg=1):
|
|
||||||
return self.searchContent(key, quick, pg)
|
|
||||||
|
|
||||||
def detailContent(self, ids):
|
|
||||||
# 获取剧集信息
|
|
||||||
vod_id = ids[0]
|
|
||||||
episode_id = None
|
|
||||||
chapter_id = None
|
|
||||||
|
|
||||||
if not vod_id.startswith('/drama/'):
|
|
||||||
if vod_id.startswith('/episode/'):
|
|
||||||
episode_info = vod_id.replace('/episode/', '').split('/')
|
|
||||||
if len(episode_info) >= 2:
|
|
||||||
episode_id = episode_info[0]
|
|
||||||
chapter_id = episode_info[1]
|
|
||||||
vod_id = f'/drama/{episode_id}'
|
|
||||||
else:
|
|
||||||
vod_id = '/drama/' + vod_id
|
|
||||||
|
|
||||||
drama_url = self.siteUrl + vod_id
|
|
||||||
print(f"请求URL: {drama_url}")
|
|
||||||
|
|
||||||
headers = {
|
|
||||||
"User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36 Edg/120.0.0.0",
|
|
||||||
"Referer": self.siteUrl,
|
|
||||||
"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"
|
|
||||||
}
|
|
||||||
|
|
||||||
rsp = self.fetch(drama_url, headers=headers)
|
|
||||||
if not rsp or rsp.status_code != 200:
|
|
||||||
print(f"请求失败，状态码: {getattr(rsp, 'status_code', 'N/A')}")
|
|
||||||
return {}
|
|
||||||
|
|
||||||
html = rsp.text
|
|
||||||
next_data_match = re.search(r'<script id="__NEXT_DATA__" type="application/json">(.*?)</script>', html, re.DOTALL)
|
|
||||||
|
|
||||||
if not next_data_match:
|
|
||||||
print("未找到NEXT_DATA内容")
|
|
||||||
return {}
|
|
||||||
|
|
||||||
try:
|
|
||||||
next_data = json.loads(next_data_match.group(1))
|
|
||||||
page_props = next_data.get("props", {}).get("pageProps", {})
|
|
||||||
print(f"找到页面属性，包含 {len(page_props.keys())} 个键")
|
|
||||||
|
|
||||||
book_info = page_props.get("bookInfoVo", {})
|
|
||||||
chapter_list = page_props.get("chapterList", [])
|
|
||||||
|
|
||||||
title = book_info.get("title", "")
|
|
||||||
sub_title = f"{book_info.get('totalChapterNum', '')}集"
|
|
||||||
|
|
||||||
categories = []
|
|
||||||
for category in book_info.get("categoryList", []):
|
|
||||||
categories.append(category.get("name", ""))
|
|
||||||
|
|
||||||
vod_content = book_info.get("introduction", "")
|
|
||||||
|
|
||||||
vod = {
|
|
||||||
"vod_id": vod_id,
|
|
||||||
"vod_name": title,
|
|
||||||
"vod_pic": book_info.get("coverWap", ""),
|
|
||||||
"type_name": ",".join(categories),
|
|
||||||
"vod_year": "",
|
|
||||||
"vod_area": book_info.get("countryName", ""),
|
|
||||||
"vod_remarks": sub_title,
|
|
||||||
"vod_actor": ", ".join([p.get("name", "") for p in book_info.get("performerList", [])]),
|
|
||||||
"vod_director": "",
|
|
||||||
"vod_content": vod_content
|
|
||||||
}
|
|
||||||
|
|
||||||
# 处理播放列表
|
|
||||||
play_url_list = []
|
|
||||||
episodes = []
|
|
||||||
|
|
||||||
if chapter_list:
|
|
||||||
print(f"找到 {len(chapter_list)} 个章节")
|
|
||||||
|
|
||||||
# 先检查是否有可以直接使用的MP4链接作为模板
|
|
||||||
mp4_template = None
|
|
||||||
first_mp4_chapter_id = None
|
|
||||||
|
|
||||||
# 先搜索第一个章节的MP4链接
|
|
||||||
# 为提高成功率，尝试直接请求第一个章节的播放页
|
|
||||||
if chapter_list and len(chapter_list) > 0:
|
|
||||||
first_chapter = chapter_list[0]
|
|
||||||
first_chapter_id = first_chapter.get("chapterId", "")
|
|
||||||
drama_id_clean = vod_id.replace('/drama/', '')
|
|
||||||
|
|
||||||
if first_chapter_id and drama_id_clean:
|
|
||||||
first_episode_url = f"{self.siteUrl}/episode/{drama_id_clean}/{first_chapter_id}"
|
|
||||||
print(f"请求第一集播放页: {first_episode_url}")
|
|
||||||
|
|
||||||
first_rsp = self.fetch(first_episode_url, headers=headers)
|
|
||||||
if first_rsp and first_rsp.status_code == 200:
|
|
||||||
first_html = first_rsp.text
|
|
||||||
# 直接从HTML提取MP4链接
|
|
||||||
mp4_pattern = r'(https?://[^"\']+\.mp4)'
|
|
||||||
mp4_matches = re.findall(mp4_pattern, first_html)
|
|
||||||
if mp4_matches:
|
|
||||||
mp4_template = mp4_matches[0]
|
|
||||||
first_mp4_chapter_id = first_chapter_id
|
|
||||||
print(f"找到MP4链接模板: {mp4_template}")
|
|
||||||
print(f"模板对应的章节ID: {first_mp4_chapter_id}")
|
|
||||||
|
|
||||||
# 如果未找到模板，再检查章节对象中是否有MP4链接
|
|
||||||
if not mp4_template:
|
|
||||||
for chapter in chapter_list[:5]: # 只检查前5个章节以提高效率
|
|
||||||
if "chapterVideoVo" in chapter and chapter["chapterVideoVo"]:
|
|
||||||
chapter_video = chapter["chapterVideoVo"]
|
|
||||||
mp4_url = chapter_video.get("mp4", "") or chapter_video.get("mp4720p", "") or chapter_video.get("vodMp4Url", "")
|
|
||||||
if mp4_url and ".mp4" in mp4_url:
|
|
||||||
mp4_template = mp4_url
|
|
||||||
first_mp4_chapter_id = chapter.get("chapterId", "")
|
|
||||||
print(f"从chapterVideoVo找到MP4链接模板: {mp4_template}")
|
|
||||||
print(f"模板对应的章节ID: {first_mp4_chapter_id}")
|
|
||||||
break
|
|
||||||
|
|
||||||
# 遍历所有章节处理播放信息
|
|
||||||
for chapter in chapter_list:
|
|
||||||
chapter_id = chapter.get("chapterId", "")
|
|
||||||
chapter_name = chapter.get("chapterName", "")
|
|
||||||
|
|
||||||
# 1. 如果章节自身有MP4链接，直接使用
|
|
||||||
if "chapterVideoVo" in chapter and chapter["chapterVideoVo"]:
|
|
||||||
chapter_video = chapter["chapterVideoVo"]
|
|
||||||
mp4_url = chapter_video.get("mp4", "") or chapter_video.get("mp4720p", "") or chapter_video.get("vodMp4Url", "")
|
|
||||||
if mp4_url and ".mp4" in mp4_url:
|
|
||||||
episodes.append(f"{chapter_name}${mp4_url}")
|
|
||||||
continue
|
|
||||||
|
|
||||||
# 2. 如果有MP4模板，尝试替换章节ID构建MP4链接
|
|
||||||
if mp4_template and first_mp4_chapter_id and chapter_id:
|
|
||||||
# 替换模板中的章节ID部分
|
|
||||||
if first_mp4_chapter_id in mp4_template:
|
|
||||||
new_mp4_url = mp4_template.replace(first_mp4_chapter_id, chapter_id)
|
|
||||||
episodes.append(f"{chapter_name}${new_mp4_url}")
|
|
||||||
continue
|
|
||||||
|
|
||||||
# 3. 如果上述方法都不可行，回退到使用chapter_id构建中间URL
|
|
||||||
if chapter_id and chapter_name:
|
|
||||||
url = f"{vod_id}${chapter_id}${chapter_name}"
|
|
||||||
episodes.append(f"{chapter_name}${url}")
|
|
||||||
|
|
||||||
if not episodes and vod_id:
|
|
||||||
# 尝试构造默认的集数
|
|
||||||
total_chapters = int(book_info.get("totalChapterNum", "0"))
|
|
||||||
if total_chapters > 0:
|
|
||||||
print(f"尝试构造 {total_chapters} 个默认集数")
|
|
||||||
|
|
||||||
# 如果知道章节ID的模式，可以构造
|
|
||||||
if chapter_id and episode_id:
|
|
||||||
for i in range(1, total_chapters + 1):
|
|
||||||
chapter_name = f"第{i}集"
|
|
||||||
url = f"{vod_id}${chapter_id}${chapter_name}"
|
|
||||||
episodes.append(f"{chapter_name}${url}")
|
|
||||||
else:
|
|
||||||
# 使用普通的构造方式
|
|
||||||
for i in range(1, total_chapters + 1):
|
|
||||||
chapter_name = f"第{i}集"
|
|
||||||
url = f"{vod_id}${chapter_name}"
|
|
||||||
episodes.append(f"{chapter_name}${url}")
|
|
||||||
|
|
||||||
if episodes:
|
|
||||||
play_url_list.append("#".join(episodes))
|
|
||||||
vod['vod_play_from'] = '河马剧场'
|
|
||||||
vod['vod_play_url'] = '$$$'.join(play_url_list)
|
|
||||||
|
|
||||||
result = {
|
|
||||||
'list': [vod]
|
|
||||||
}
|
|
||||||
return result
|
|
||||||
except Exception as e:
|
|
||||||
print(f"解析详情页失败: {str(e)}")
|
|
||||||
print(traceback.format_exc())
|
|
||||||
return {}
|
|
||||||
|
|
||||||
def playerContent(self, flag, id, vipFlags):
|
|
||||||
result = {}
|
|
||||||
print(f"调用playerContent: flag={flag}, id={id}")
|
|
||||||
|
|
||||||
headers = {
|
|
||||||
"User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36 Edg/120.0.0.0",
|
|
||||||
"Referer": self.siteUrl,
|
|
||||||
"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"
|
|
||||||
}
|
|
||||||
|
|
||||||
# 解析id参数
|
|
||||||
parts = id.split('$')
|
|
||||||
drama_id = None
|
|
||||||
chapter_id = None
|
|
||||||
|
|
||||||
if len(parts) >= 2:
|
|
||||||
drama_id = parts[0]
|
|
||||||
chapter_id = parts[1]
|
|
||||||
chapter_name = parts[2] if len(parts) > 2 else "第一集"
|
|
||||||
print(f"解析参数: drama_id={drama_id}, chapter_id={chapter_id}")
|
|
||||||
else:
|
|
||||||
# 处理旧数据格式
|
|
||||||
print(f"使用原始URL格式: {id}")
|
|
||||||
result["parse"] = 0
|
|
||||||
result["url"] = id
|
|
||||||
result["header"] = json.dumps(headers)
|
|
||||||
return result
|
|
||||||
|
|
||||||
# 直接检查chapter_id是否包含http（可能已经是视频链接）
|
|
||||||
if 'http' in chapter_id and '.mp4' in chapter_id:
|
|
||||||
print(f"已经是MP4链接: {chapter_id}")
|
|
||||||
result["parse"] = 0
|
|
||||||
result["url"] = chapter_id
|
|
||||||
result["header"] = json.dumps(headers)
|
|
||||||
return result
|
|
||||||
|
|
||||||
# 构建episode页面URL
|
|
||||||
drama_id_clean = drama_id.replace('/drama/', '')
|
|
||||||
episode_url = f"{self.siteUrl}/episode/{drama_id_clean}/{chapter_id}"
|
|
||||||
print(f"请求episode页面: {episode_url}")
|
|
||||||
|
|
||||||
try:
|
|
||||||
rsp = self.fetch(episode_url, headers=headers)
|
|
||||||
if not rsp or rsp.status_code != 200:
|
|
||||||
print(f"请求失败，状态码: {getattr(rsp, 'status_code', 'N/A')}")
|
|
||||||
result["parse"] = 0
|
|
||||||
result["url"] = id
|
|
||||||
result["header"] = json.dumps(headers)
|
|
||||||
return result
|
|
||||||
|
|
||||||
html = rsp.text
|
|
||||||
print(f"获取页面大小: {len(html)} 字节")
|
|
||||||
|
|
||||||
# 尝试从NEXT_DATA提取视频链接
|
|
||||||
mp4_url = None
|
|
||||||
|
|
||||||
# 方法1: 从NEXT_DATA提取
|
|
||||||
next_data_match = re.search(r'<script id="__NEXT_DATA__" type="application/json">(.*?)</script>', html, re.DOTALL)
|
|
||||||
if next_data_match:
|
|
||||||
try:
|
|
||||||
print("找到NEXT_DATA")
|
|
||||||
next_data = json.loads(next_data_match.group(1))
|
|
||||||
page_props = next_data.get("props", {}).get("pageProps", {})
|
|
||||||
|
|
||||||
# 从chapterList中查找当前章节
|
|
||||||
chapter_list = page_props.get("chapterList", [])
|
|
||||||
print(f"找到章节列表，长度: {len(chapter_list)}")
|
|
||||||
|
|
||||||
for chapter in chapter_list:
|
|
||||||
if chapter.get("chapterId") == chapter_id:
|
|
||||||
print(f"找到匹配的章节: {chapter.get('chapterName')}")
|
|
||||||
chapter_video = chapter.get("chapterVideoVo", {})
|
|
||||||
mp4_url = chapter_video.get("mp4", "") or chapter_video.get("mp4720p", "") or chapter_video.get("vodMp4Url", "")
|
|
||||||
if mp4_url:
|
|
||||||
print(f"从chapterList找到MP4链接: {mp4_url}")
|
|
||||||
break
|
|
||||||
|
|
||||||
# 如果未找到，尝试从当前章节获取
|
|
||||||
if not mp4_url:
|
|
||||||
current_chapter = page_props.get("chapterInfo", {})
|
|
||||||
if current_chapter:
|
|
||||||
print("找到当前章节信息")
|
|
||||||
chapter_video = current_chapter.get("chapterVideoVo", {})
|
|
||||||
mp4_url = chapter_video.get("mp4", "") or chapter_video.get("mp4720p", "") or chapter_video.get("vodMp4Url", "")
|
|
||||||
if mp4_url:
|
|
||||||
print(f"从chapterInfo找到MP4链接: {mp4_url}")
|
|
||||||
except Exception as e:
|
|
||||||
print(f"解析NEXT_DATA失败: {str(e)}")
|
|
||||||
print(traceback.format_exc())
|
|
||||||
|
|
||||||
# 方法2: 直接从HTML中提取MP4链接
|
|
||||||
if not mp4_url:
|
|
||||||
mp4_pattern = r'(https?://[^"\']+\.mp4)'
|
|
||||||
mp4_matches = re.findall(mp4_pattern, html)
|
|
||||||
if mp4_matches:
|
|
||||||
# 查找含有chapter_id的链接
|
|
||||||
matched_mp4 = False
|
|
||||||
for url in mp4_matches:
|
|
||||||
if chapter_id in url:
|
|
||||||
mp4_url = url
|
|
||||||
matched_mp4 = True
|
|
||||||
print(f"从HTML直接提取章节MP4链接: {mp4_url}")
|
|
||||||
break
|
|
||||||
|
|
||||||
# 如果没找到包含chapter_id的链接，使用第一个
|
|
||||||
if not matched_mp4 and mp4_matches:
|
|
||||||
mp4_url = mp4_matches[0]
|
|
||||||
print(f"从HTML直接提取MP4链接: {mp4_url}")
|
|
||||||
|
|
||||||
if mp4_url and ".mp4" in mp4_url:
|
|
||||||
print(f"最终找到的MP4链接: {mp4_url}")
|
|
||||||
result["parse"] = 0
|
|
||||||
result["url"] = mp4_url
|
|
||||||
result["header"] = json.dumps(headers)
|
|
||||||
return result
|
|
||||||
else:
|
|
||||||
print(f"未找到有效的MP4链接，尝试再次解析页面内容")
|
|
||||||
# 再尝试一次从HTML中广泛搜索所有可能的MP4链接
|
|
||||||
all_mp4_pattern = r'(https?://[^"\']+\.mp4)'
|
|
||||||
all_mp4_matches = re.findall(all_mp4_pattern, html)
|
|
||||||
if all_mp4_matches:
|
|
||||||
mp4_url = all_mp4_matches[0]
|
|
||||||
print(f"从HTML广泛搜索找到MP4链接: {mp4_url}")
|
|
||||||
result["parse"] = 0
|
|
||||||
result["url"] = mp4_url
|
|
||||||
result["header"] = json.dumps(headers)
|
|
||||||
return result
|
|
||||||
|
|
||||||
print(f"未找到视频链接，返回原episode URL: {episode_url}")
|
|
||||||
result["parse"] = 0
|
|
||||||
result["url"] = episode_url
|
|
||||||
result["header"] = json.dumps(headers)
|
|
||||||
return result
|
|
||||||
except Exception as e:
|
|
||||||
print(f"请求或解析失败: {str(e)}")
|
|
||||||
print(traceback.format_exc())
|
|
||||||
result["parse"] = 0
|
|
||||||
result["url"] = id
|
|
||||||
result["header"] = json.dumps(headers)
|
|
||||||
return result
|
|
||||||
|
|
||||||
def localProxy(self, param):
|
|
||||||
# 本地代理处理，此处简单返回传入的参数
|
|
||||||
return [200, "video/MP2T", {}, param]
|
|
||||||
|
|
||||||
def destroy(self):
|
|
||||||
# 资源回收
|
|
||||||
pass
|
|
||||||
BIN
潇洒/spider.jar
BIN
潇洒/spider.jar
Binary file not shown.
Reference in New Issue
Block a user