]*href="([^"]*/vod/play/id/%s/sid/(\d+)/nid/(\d+)\.html)"[^>]*>([^<]*)'
% re.escape(str(vid)), html_text, re.I):
ephref = m.group(1)
sid = m.group(2)
nid = m.group(3)
eptxt = _clean(m.group(4)).strip() or ("第%s集" % nid)
if eptxt in ("立即播放", "立即观看"):
eptxt = "第%s集" % nid
eps.append((sid, eptxt, ephref))
# 去重保序（同一 href 只留一次）
seen = set()
ep_list = []
for sid, eptxt, ephref in eps:
if ephref in seen:
continue
seen.add(ephref)
ep_list.append((sid, eptxt, ephref))
# 每个播放列表块提取自身的线路名
def _line_name_for_sid(sid):
# 从 stui-vodlist__head 块找标题；若找不到再退回通用的第一条线路名
for block in re.finditer(
r'\s*(?:]*>\s*)?'
r']*>([\s\S]*?)', html_text, re.I):
label = _clean(re.sub(r'<[^>]+>', '', block.group(1)))
if label:
return label
return ""
default_name = ""
fm = re.search(r']*class="title"[^>]*>\s*]*>\s*([^<]+?)\s*', html_text)
if fm:
default_name = _clean(fm.group(1))
if not default_name:
default_name = _line_name_for_sid(None)
if not default_name:
default_name = "dadim3u8"
# 线路内排序：nid 数字升序
bysid = {}
for sid, eptxt, ephref in ep_list:
bysid.setdefault(sid, []).append((eptxt, ephref))
for sid in bysid:
def _nid_key(item):
nn = re.search(r'/nid/(\d+)\.html', item[1])
try:
return int(nn.group(1))
except (ValueError, TypeError, AttributeError):
return 0
bysid[sid].sort(key=_nid_key)
line_labels = []
play_lines = []
for sid in bysid:
parts = ["%s$%s" % (eptxt, ephref) for eptxt, ephref in bysid[sid]]
play_lines.append("#".join(parts))
line_labels.append(default_name)
if not play_lines:
return {"vod_id": vid, "vod_name": vod_name, "vod_pic": vod_pic,
"vod_content": vod_content, "vod_play_from": "", "vod_play_url": ""}
play_from = "$$$".join(line_labels)
play_url = "$$$".join(play_lines)
return {"vod_id": vid, "vod_name": vod_name, "vod_pic": vod_pic,
"vod_content": vod_content,
"vod_play_from": play_from, "vod_play_url": play_url}
return {"vod_id": vid, "vod_name": vod_name, "vod_pic": vod_pic,
"vod_content": vod_content,
"vod_play_from": play_from, "vod_play_url": play_url}
# ── 搜索 ──
def searchContent(self, key, quick, pg="1"):
try:
pg = int(pg)
except (ValueError, TypeError):
pg = 1
try:
resp = self._request(self.host + "/index.php/vod/search.html", method="POST",
data={"wd": key}, referer=self.host + "/")
html_text = self._decrypt_page(resp.text if resp else "")
vods = self._fetch_cards(html_text)
return {"list": vods, "page": pg, "pagecount": 1, "limit": 12, "total": 0}
except Exception as e:
print(f"[{self.name}] 搜索失败: {e}")
return {"list": [], "page": pg, "pagecount": 1, "limit": 12, "total": 0}
# ── 播放 ──
def playerContent(self, flag, id, vipFlags=None):
# id 形如 /jpsn/index.php/vod/play/id/{vid}/sid/{sid}/nid/{nid}.html
url = _fix_url(id, self.host)
html_text = self._decrypt_page(self._fetch(url))
play_url = ""
headers = dict(self.headers)
m = re.search(r'var\s+player_aaaa\s*=\s*(\{.*?\})\s*', html_text, re.S | re.I)
if not m:
m = re.search(r'var\s+player_aaaa\s*=\s*(\{.*?\})', html_text, re.S | re.I)
if m:
try:
cfg = json.loads(m.group(1))
play_url = str(cfg.get("url") or "").strip()
enc = int(cfg.get("encrypt") or 0)
if enc != 0:
print(f"[{self.name}] 播放地址需解密(encrypt={enc})，暂不解码")
play_url = ""
from_server = str(cfg.get("from") or "")
if from_server:
headers["Referer"] = self.host + "/"
except (ValueError, TypeError) as e:
print(f"[{self.name}] player_aaaa 解析失败: {e}")
play_url = ""
if not play_url:
# 兜底：页面内直接找 m3u8/mp4
m2 = re.search(r'(https?://[^"\'\s<>]+\.(?:m3u8|mp4|flv|mpd))', html_text)
if m2:
play_url = m2.group(1)
if not play_url:
return {"parse": 0, "url": "", "header": {}}
return {"parse": 0, "url": play_url, "header": headers}
def localProxy(self, param):
# 图片防盗链代理
_p = param if isinstance(param, dict) else {}
url = unquote(_p.get("url", "")) or ""
if not url:
return [404, "text/plain", b""]
try:
_h = {"User-Agent": self.headers.get("User-Agent", _UA),
"Referer": _p.get("referer", self.host + "/")}
_sess = self.s if self.s else requests
_r = _sess.get(url, headers=_h, timeout=self.timeout, verify=self.verify)
_ct = _r.headers.get("Content-Type", "image/jpeg")
return [200, _ct, _r.content, {"Access-Control-Allow-Origin": "*"}]
except (OSError, ValueError, AttributeError, TypeError):
gif = base64.b64decode("R0lGODlhAQABAIAAAAAAAP///yH5BAEAAAAALAAAAAABAAEAAAIBRAA7")
return [200, "image/gif", gif]
# ── 纯 Python AES-128-CBC 回退实现（零第三方依赖，经 FIPS-197 + pycryptodome 双验证）──
_SBOX = [
0x63,0x7c,0x77,0x7b,0xf2,0x6b,0x6f,0xc5,0x30,0x01,0x67,0x2b,0xfe,0xd7,0xab,0x76,
0xca,0x82,0xc9,0x7d,0xfa,0x59,0x47,0xf0,0xad,0xd4,0xa2,0xaf,0x9c,0xa4,0x72,0xc0,
0xb7,0xfd,0x93,0x26,0x36,0x3f,0xf7,0xcc,0x34,0xa5,0xe5,0xf1,0x71,0xd8,0x31,0x15,
0x04,0xc7,0x23,0xc3,0x18,0x96,0x05,0x9a,0x07,0x12,0x80,0xe2,0xeb,0x27,0xb2,0x75,
0x09,0x83,0x2c,0x1a,0x1b,0x6e,0x5a,0xa0,0x52,0x3b,0xd6,0xb3,0x29,0xe3,0x2f,0x84,
0x53,0xd1,0x00,0xed,0x20,0xfc,0xb1,0x5b,0x6a,0xcb,0xbe,0x39,0x4a,0x4c,0x58,0xcf,
0xd0,0xef,0xaa,0xfb,0x43,0x4d,0x33,0x85,0x45,0xf9,0x02,0x7f,0x50,0x3c,0x9f,0xa8,
0x51,0xa3,0x40,0x8f,0x92,0x9d,0x38,0xf5,0xbc,0xb6,0xda,0x21,0x10,0xff,0xf3,0xd2,
0xcd,0x0c,0x13,0xec,0x5f,0x97,0x44,0x17,0xc4,0xa7,0x7e,0x3d,0x64,0x5d,0x19,0x73,
0x60,0x81,0x4f,0xdc,0x22,0x2a,0x90,0x88,0x46,0xee,0xb8,0x14,0xde,0x5e,0x0b,0xdb,
0xe0,0x32,0x3a,0x0a,0x49,0x06,0x24,0x5c,0xc2,0xd3,0xac,0x62,0x91,0x95,0xe4,0x79,
0xe7,0xc8,0x37,0x6d,0x8d,0xd5,0x4e,0xa9,0x6c,0x56,0xf4,0xea,0x65,0x7a,0xae,0x08,
0xba,0x78,0x25,0x2e,0x1c,0xa6,0xb4,0xc6,0xe8,0xdd,0x74,0x1f,0x4b,0xbd,0x8b,0x8a,
0x70,0x3e,0xb5,0x66,0x48,0x03,0xf6,0x0e,0x61,0x35,0x57,0xb9,0x86,0xc1,0x1d,0x9e,
0xe1,0xf8,0x98,0x11,0x69,0xd9,0x8e,0x94,0x9b,0x1e,0x87,0xe9,0xce,0x55,0x28,0xdf,
0x8c,0xa1,0x89,0x0d,0xbf,0xe6,0x42,0x68,0x41,0x99,0x2d,0x0f,0xb0,0x54,0xbb,0x16,
]
_INV_SBOX = [0] * 256
for _i in range(256):
_INV_SBOX[_SBOX[_i]] = _i
def _gmul(a, b):
p = 0
for _ in range(8):
if b & 1:
p ^= a
hi = a & 0x80
a = (a << 1) & 0xFF
if hi:
a ^= 0x1B
b >>= 1
return p
def _aes_expand_key(key):
w = [int.from_bytes(key[i:i+4], 'big') for i in range(0, 16, 4)]
rcon = [0x01, 0x02, 0x04, 0x08, 0x10, 0x20, 0x40, 0x80, 0x1b, 0x36]
for i in range(4, 44):
tmp = w[i-1]
if i % 4 == 0:
tmp = ((_SBOX[(tmp >> 24) & 0xFF] << 24) |
(_SBOX[(tmp >> 16) & 0xFF] << 16) |
(_SBOX[(tmp >> 8) & 0xFF] << 8) | _SBOX[tmp & 0xFF])
tmp = ((tmp << 8) | (tmp >> 24)) & 0xFFFFFFFF
tmp ^= (rcon[i // 4 - 1] << 24)
w.append(w[i-4] ^ tmp)
return [ww.to_bytes(4, 'big') for ww in w] # 44 个 4 字节字
def _add_round_key(state, rk):
for c in range(4):
for r in range(4):
state[c][r] ^= rk[c][r]
def _sub_bytes(state):
for c in range(4):
for r in range(4):
state[c][r] = _SBOX[state[c][r]]
def _inv_sub_bytes(state):
for c in range(4):
for r in range(4):
state[c][r] = _INV_SBOX[state[c][r]]
def _shift_rows(state):
for r in range(1, 4):
s0 = state[0][r]; s1 = state[1][r]; s2 = state[2][r]; s3 = state[3][r]
state[0][r] = [s0, s1, s2, s3][(0 + r) % 4]
state[1][r] = [s0, s1, s2, s3][(1 + r) % 4]
state[2][r] = [s0, s1, s2, s3][(2 + r) % 4]
state[3][r] = [s0, s1, s2, s3][(3 + r) % 4]
def _inv_shift_rows(state):
for r in range(1, 4):
s0 = state[0][r]; s1 = state[1][r]; s2 = state[2][r]; s3 = state[3][r]
state[0][r] = [s0, s1, s2, s3][(0 - r) % 4]
state[1][r] = [s0, s1, s2, s3][(1 - r) % 4]
state[2][r] = [s0, s1, s2, s3][(2 - r) % 4]
state[3][r] = [s0, s1, s2, s3][(3 - r) % 4]
def _mix_columns(state):
for c in range(4):
s0, s1, s2, s3 = state[c][0], state[c][1], state[c][2], state[c][3]
state[c][0] = _gmul(s0, 2) ^ _gmul(s1, 3) ^ s2 ^ s3
state[c][1] = s0 ^ _gmul(s1, 2) ^ _gmul(s2, 3) ^ s3
state[c][2] = s0 ^ s1 ^ _gmul(s2, 2) ^ _gmul(s3, 3)
state[c][3] = _gmul(s0, 3) ^ s1 ^ s2 ^ _gmul(s3, 2)
def _inv_mix_columns(state):
for c in range(4):
s0, s1, s2, s3 = state[c][0], state[c][1], state[c][2], state[c][3]
state[c][0] = _gmul(s0, 14) ^ _gmul(s1, 11) ^ _gmul(s2, 13) ^ _gmul(s3, 9)
state[c][1] = _gmul(s0, 9) ^ _gmul(s1, 14) ^ _gmul(s2, 11) ^ _gmul(s3, 13)
state[c][2] = _gmul(s0, 13) ^ _gmul(s1, 9) ^ _gmul(s2, 14) ^ _gmul(s3, 11)
state[c][3] = _gmul(s0, 11) ^ _gmul(s1, 13) ^ _gmul(s2, 9) ^ _gmul(s3, 14)
def _encrypt_block(block, rk):
state = [[block[c*4 + r] for r in range(4)] for c in range(4)]
_add_round_key(state, rk[:4])
for rnd in range(1, 10):
_sub_bytes(state); _shift_rows(state); _mix_columns(state)
_add_round_key(state, rk[rnd*4:rnd*4+4])
_sub_bytes(state); _shift_rows(state)
_add_round_key(state, rk[40:44])
return b"".join(state[c][r].to_bytes(1, 'big') for c in range(4) for r in range(4))
def _decrypt_block(block, rk):
state = [[block[c*4 + r] for r in range(4)] for c in range(4)]
_add_round_key(state, rk[40:44])
for rnd in range(9, 0, -1):
_inv_shift_rows(state); _inv_sub_bytes(state)
_add_round_key(state, rk[rnd*4:rnd*4+4])
_inv_mix_columns(state)
_inv_shift_rows(state); _inv_sub_bytes(state)
_add_round_key(state, rk[:4])
return b"".join(state[c][r].to_bytes(1, 'big') for c in range(4) for r in range(4))
def _pure_aes(ct):
"""AES-128-CBC 解密（Key/IV 为此站点固定值），返回去掉 PKCS7 的明文。"""
if len(ct) % 16 != 0:
raise ValueError("ciphertext length")
rk = _aes_expand_key(_JPSN_KEY)
prev = _JPSN_IV
out = b""
for i in range(0, len(ct), 16):
blk = ct[i:i+16]
d = _decrypt_block(blk, rk)
out += bytes(a ^ b for a, b in zip(d, prev))
prev = blk
if out:
pad = out[-1]
if 1 <= pad <= 16 and out[-pad:] == bytes([pad]) * pad:
out = out[:-pad]
return out