179 lines
7.4 KiB
Python
179 lines
7.4 KiB
Python
# -*- coding: utf-8 -*-
|
|
# 本资源来源于互联网公开渠道，仅可用于个人学习爬虫技术。
|
|
# 严禁将其用于任何商业用途，下载后请于 24 小时内删除，搜索结果均来自源站，本人不承担任何责任。
|
|
|
|
from Crypto.Cipher import AES
|
|
from base.spider import Spider
|
|
from urllib.parse import quote
|
|
import re,sys,json,base64,urllib3
|
|
urllib3.disable_warnings(urllib3.exceptions.InsecureRequestWarning)
|
|
sys.path.append('..')
|
|
|
|
class Spider(Spider):
|
|
host, jiexi, headers,playua,key,iv = {
|
|
'User-Agent': "okhttp/4.12.0",
|
|
'Connection': "Keep-Alive",
|
|
'Accept-Encoding': "gzip"
|
|
}, '', '', '', '',''
|
|
|
|
def init(self, extend=''):
|
|
try:
|
|
ext = json.loads(extend)
|
|
host = ext.get('host')
|
|
self.key = ext.get('key')
|
|
self.iv = ext.get('iv')
|
|
if not host.startswith('http'):
|
|
try:
|
|
hostkey = ext.get('hostkey', 'Kkebx6vFqWMCNKwmaaeGOmnZBNzbQ1Bj')
|
|
hostiv = ext.get('hostiv', 'cBqqjFQUqBeAJ61z')
|
|
host = self.decrypt(host,hostkey,hostiv)
|
|
except Exception:
|
|
self.host = ''
|
|
return
|
|
if not re.match(r'^https?://[a-zA-Z0-9-]+(\.[a-zA-Z0-9-]+)*(:\d+)?/?$', host):
|
|
headers = {'User-Agent': "XinJieApp/1.0",'Accept-Encoding': "gzip",'cache-control': "no-cache"}
|
|
host = self.fetch(host,headers=headers,verify=False).json()['server']['url']
|
|
if len(self.key) >= 16 and len(self.iv) >= 16 and host.startswith('http'): self.host = host.rstrip('/')
|
|
self.playua = ext.get('playua', 'Dalvik/2.1.0 (Linux; U; Android 15; Xiaomi 15 Pro Build/AP2A.240905.003)')
|
|
except Exception:
|
|
self.host = ''
|
|
|
|
def homeContent(self, filter):
|
|
if not self.host: return None
|
|
response = self.fetch(f'{self.host}/admin/duanjuc.php?page=1&limit=30', headers=self.headers, verify=False).json()
|
|
data = response['data']
|
|
if response.get('encrypted') == 1:
|
|
data_ = self.decrypt(response['data'])
|
|
data = json.loads(data_)['data']
|
|
classes, videos = [], []
|
|
for i in data:
|
|
if i['type_id'] != 0:
|
|
classes.append({'type_id': i['type_id'], 'type_name': i['type_name']})
|
|
for j in i['videos']:
|
|
videos.append({
|
|
'vod_id': j['vod_id'],
|
|
'vod_name': j['vod_name'],
|
|
'vod_pic': j['vod_pic'],
|
|
'vod_remarks': j['vod_remarks'],
|
|
'vod_year': j['vod_year']
|
|
})
|
|
return {'class': classes, 'list': videos}
|
|
|
|
def categoryContent(self, tid, pg, filter, extend):
|
|
if not self.host: return None
|
|
response = self.fetch(f'{self.host}/admin/duanjusy.php?limit=20&page={pg}&type_id={tid}', headers=self.headers, verify=False).json()
|
|
data = response['data']
|
|
if response.get('encrypted') == 1:
|
|
data_ = self.decrypt(response['data'])
|
|
data1 = json.loads(data_)
|
|
data = data1['data']
|
|
videos = []
|
|
for i in data:
|
|
videos.append({
|
|
'vod_id': i['vod_id'],
|
|
'vod_name': i['vod_name'],
|
|
'vod_pic': i['vod_pic'],
|
|
'vod_remarks': i['vod_remarks'],
|
|
'vod_year': i['vod_year']
|
|
})
|
|
return {'list': videos, 'pagecount': data1['pagination']['total_pages']}
|
|
|
|
def searchContent(self, key, quick, pg='1'):
|
|
if not self.host: return None
|
|
response = self.fetch(f'{self.host}/admin/duanjusy.php?suggest={key}&limit=20&page={pg}', headers=self.headers, verify=False).json()
|
|
data = response['data']
|
|
if response.get('encrypted') == 1:
|
|
data_ = self.decrypt(response['data'])
|
|
data1 = json.loads(data_)
|
|
data = data1['data']
|
|
videos = []
|
|
for i in data:
|
|
videos.append({
|
|
'vod_id': i['vod_id'],
|
|
'vod_name': i['vod_name'],
|
|
'vod_pic': i['vod_pic'],
|
|
'vod_remarks': i['vod_remarks'],
|
|
'vod_year': i['vod_year'],
|
|
'vod_content': i['vod_blurb']
|
|
})
|
|
return {'list': videos, 'pagecount': data1['pagination']['total_pages']}
|
|
|
|
def detailContent(self, ids):
|
|
response = self.fetch(f'{self.host}/admin/duanju.php?vod_id={ids[0]}', headers=self.headers, verify=False).json()
|
|
data = response['data']
|
|
if response.get('encrypted') == 1:
|
|
data_ = self.decrypt(response['data'])
|
|
data = json.loads(data_)['data']
|
|
jiexi = data.get('jiexi','')
|
|
if jiexi.startswith('http'):
|
|
self.jiexi = jiexi
|
|
play_from, play_urls = [], []
|
|
for source in data['play_sources']:
|
|
play_from.append(f"{source['name']}\u2005({source['source_key']})")
|
|
urls = source['url'].split('#')
|
|
urls2 = [ '$'.join([parts[0], f"{source['source_key']}@{parts[1]}"]) for parts in [url.split('$') for url in urls] ]
|
|
play_urls.append('#'.join(urls2))
|
|
video = {
|
|
'vod_id': data['vod_id'],
|
|
'vod_name': data['vod_name'],
|
|
'vod_pic': data['vod_pic'],
|
|
'vod_remarks': data['vod_remarks'],
|
|
'vod_year': data['vod_year'],
|
|
'vod_area': data['vod_area'],
|
|
'vod_actor': data['vod_actor'],
|
|
'vod_director': data['vod_director'],
|
|
'vod_content': data['vod_content'],
|
|
'type_name': data['vod_class'],
|
|
'vod_play_from': '$$$'.join(play_from),
|
|
'vod_play_url': '$$$'.join(play_urls)
|
|
}
|
|
return {'list': [video]}
|
|
|
|
def playerContent(self, flag, id, vipflags):
|
|
play_from, raw_url = id.split('@', 1)
|
|
if self.jiexi:
|
|
try:
|
|
headers = {'User-Agent': "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36", 'Connection': "Keep-Alive", 'Accept-Encoding': "gzip"}
|
|
response = self.fetch(f"{self.host}/admin/jiexi.php?url={quote(raw_url, safe='')}&source={play_from}", headers=headers, verify=False).json()
|
|
if response.get('encrypted') == 1:
|
|
data_ = self.decrypt(response['data'])
|
|
data = json.loads(data_)
|
|
play_url = data['url']
|
|
url = play_url if play_url.startswith('http') else id
|
|
ua = response.get('UA', self.playua)
|
|
except Exception:
|
|
url, ua = raw_url, self.playua
|
|
else:
|
|
url,ua = raw_url,self.playua
|
|
return {'jx': '0','parse': '0','url': url,'header': {'User-Agent': ua}}
|
|
|
|
def decrypt(self, str, key='', iv=''):
|
|
if not key or not iv: key, iv = self.key, self.iv
|
|
key = key.ljust(32, '0')
|
|
key_bytes = key.encode('utf-8')
|
|
iv_bytes = iv.encode('utf-8')
|
|
ciphertext = base64.b64decode(str)
|
|
cipher = AES.new(key_bytes, AES.MODE_CBC, iv_bytes)
|
|
plaintext = cipher.decrypt(ciphertext)
|
|
padding_length = plaintext[-1]
|
|
plaintext = plaintext[:-padding_length]
|
|
return plaintext.decode('utf-8')
|
|
|
|
def homeVideoContent(self):
|
|
pass
|
|
|
|
def getName(self):
|
|
pass
|
|
|
|
def isVideoFormat(self, url):
|
|
pass
|
|
|
|
def manualVideoCheck(self):
|
|
pass
|
|
|
|
def destroy(self):
|
|
pass
|
|
|
|
def localProxy(self, param):
|
|
pass
|