]+src="([^"]+)"', html, re.S)
if m:
vod['vod_pic'] = m.group(1)
# 详情信息（多个 ，一个 p 可含多个 label:value）
info = {}
for mm in re.finditer(r'
]*>(.*?)
', html, re.S):
phtml = mm.group(1)
# 按 label span 切分：parts[0]前缀, [1]label, [2]值, [3]label, [4]值...
parts = re.split(r'([^<]*)', phtml)
for i in range(1, len(parts), 2):
label = parts[i].strip().rstrip('：:')
if label not in ('分类', '地区', '年份', '主演', '导演'):
continue
valhtml = parts[i + 1] if i + 1 < len(parts) else ''
value = ' '.join(re.findall(r'<(?:a|span)[^>]*>([^<]{1,60})', valhtml))
value = re.sub(r'\s+', ' ', value).strip()
if value:
info[label] = value
vod['vod_year'] = info.get('年份', '')
vod['vod_area'] = info.get('地区', '')
vod['vod_director'] = info.get('导演', '')
vod['vod_actor'] = info.get('主演', '')
vod['type_name'] = info.get('分类', '')
cm = re.search(r'class="detail-content[^"]*"[^>]*>(.*?)]+>', '', cm.group(1))).strip() if cm else ''
# 播放列表（多线路）
play_from, play_url = [], []
for pid, name in re.findall(r'href="#(playlist\d+)"[^>]*>([^<]*)', html):
bm = re.search(r'id="%s"[^>]*>(.*?)' % re.escape(pid), html, re.S)
if not bm:
continue
eps = []
for href, ep in re.findall(r']+href="(/play/[^"]+)"[^>]*>([^<]*)', bm.group(1)):
if href:
eps.append(f'{ep.strip()}${self.host}{href}')
if eps:
play_from.append(name)
play_url.append('#'.join(eps))
if not play_url:
return {'list': []}
vod['vod_play_from'] = '$$$'.join(play_from)
vod['vod_play_url'] = '$$$'.join(play_url)
return {'list': [vod]}
# ------------------------------------------------------------------ #
# 搜索
# ------------------------------------------------------------------ #
def searchContent(self, key, quick, pg="1"):
result = {'list': []}
try:
url = f'{self.host}/search/{quote(str(key))}-------------.html'
resp = self.session.get(url, headers={'Referer': self.host + '/'}, timeout=self.timeout)
resp.encoding = 'utf-8'
result['list'] = self._parse_videos(resp.text)
except:
pass
return result
# ------------------------------------------------------------------ #
# 播放（smart-play 解密链）
# ------------------------------------------------------------------ #
@staticmethod
def _decrypt_aes(data_b64, key_hex, iv_hex):
if AES is None:
return ''
cipher = AES.new(key_hex.encode(), AES.MODE_CBC, iv_hex.encode())
pt = cipher.decrypt(base64.b64decode(data_b64))
pad = pt[-1]
if 1 <= pad <= 16:
pt = pt[:-pad]
return pt.decode('utf-8', 'ignore')
def _resolve_play(self, play_url):
"""/play/xxx.html -> 真实播放地址"""
h = {'Referer': self.host + '/'}
# 1) 播放页
resp = self._safe_get(play_url, h)
if not resp:
return ''
html = resp.text
i = html.find('player_aaaa=')
if i < 0:
return ''
start = html.find('{', i)
if start < 0:
return ''
depth = 0; j = start
while j < len(html):
if html[j] == '{': depth += 1
elif html[j] == '}':
depth -= 1
if depth == 0: break
j += 1
try:
p = json.loads(html[start:j + 1])
except:
return ''
enc_url = p.get('url', '')
if not enc_url:
return ''
# 2) artplayer 页（取 vkey/code/timestamp）
art = self._safe_get(f'{self.host}/static/player/artplayer/?url={enc_url}', {'Referer': play_url})
if not art:
return ''
ah = art.text
vkey = re.search(r'const playPageUrl\s*=\s*"([^"]+)"', ah)
code = re.search(r'const secretKeySeed\s*=\s*"([^"]+)"', ah)
ts = re.search(r'const timestamp\s*=\s*"([^"]+)"', ah)
if not (vkey and code and ts):
return ''
vkey, code, ts = vkey.group(1), code.group(1), ts.group(1)
# 3) smart-play 校验接口
t = int(time.time())
sig = hashlib.md5(str(t).encode()).hexdigest()
try:
r = self.session.post(_API_URL, json={'vkey': vkey, 'code': code, 't': t, 'signature': sig},
headers={'Referer': art.url, 'Origin': self.host,
'Content-Type': 'application/json'}, timeout=self.timeout)
enc = r.json().get('url', '')
except:
return ''
# 4) AES 解密
md = hashlib.md5((ts + _SALT).encode()).hexdigest()
real = self._decrypt_aes(enc, md[16:32], md[0:16])
if real.startswith('http'):
return real
return ''
def playerContent(self, flag, id, vipFlags):
h = {'User-Agent': self.header['User-Agent'], 'Referer': self.host + '/'}
real = self._resolve_play(id)
if real:
return {'parse': 0, 'url': real, 'header': h, 'playUrl': ''}
return {'parse': 1, 'url': id, 'header': h, 'playUrl': ''}
def fetch(self, url):
try:
resp = self.session.get(url, timeout=self.timeout)
resp.encoding = 'utf-8'
return resp.text if resp.status_code == 200 else None
except:
return None
def localProxy(self, param):
return None