mirror of
https://github.com/ls125781003/tvboxtg.git
synced 2025-10-30 21:32:23 +00:00
302 lines
13 KiB
Python
302 lines
13 KiB
Python
# -*- coding: utf-8 -*-
|
|
# by @嗷呜
|
|
import json
|
|
import sys
|
|
import time
|
|
from concurrent.futures import ThreadPoolExecutor, as_completed
|
|
from urllib.parse import quote
|
|
from Crypto.Hash import MD5
|
|
import requests
|
|
sys.path.append('..')
|
|
from base.spider import Spider
|
|
|
|
|
|
class Spider(Spider):
|
|
|
|
def init(self, extend=""):
|
|
self.session = requests.Session()
|
|
self.session.headers.update(self.headers)
|
|
self.session.cookies.update(self.cookie)
|
|
self.get_ctoken()
|
|
pass
|
|
|
|
def getName(self):
|
|
pass
|
|
|
|
def isVideoFormat(self, url):
|
|
pass
|
|
|
|
def manualVideoCheck(self):
|
|
pass
|
|
|
|
def destroy(self):
|
|
pass
|
|
|
|
host='https://www.youku.com'
|
|
|
|
shost='https://search.youku.com'
|
|
|
|
h5host='https://acs.youku.com'
|
|
|
|
ihost='https://v.youku.com'
|
|
|
|
headers = {
|
|
'User-Agent': 'Mozilla/5.0 (; Windows 10.0.26100.3194_64 ) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/93.0.4577.82 Electron/14.2.0 Safari/537.36 Node/14.17.0 YoukuDesktop/9.2.60 UOSYouku (2.0.1)-Electron(UTDID ZYmGMAAAACkDAMU8hbiMmYdd;CHANNEL official;ZREAL 0;BTYPE TM2013;BRAND TIMI;BUILDVER 9.2.60.1001)',
|
|
'Referer': f'{host}/'
|
|
}
|
|
|
|
cookie={
|
|
"__ysuid": "17416134165380iB",
|
|
"__aysid": "1741613416541WbD",
|
|
"xlly_s": "1",
|
|
"isI18n": "false",
|
|
"cna": "bNdVIKmmsHgCAXW9W6yrQ1/s",
|
|
"__ayft": "1741672162330",
|
|
"__arpvid": "1741672162331FBKgrn-1741672162342",
|
|
"__ayscnt": "1",
|
|
"__aypstp": "1",
|
|
"__ayspstp": "3",
|
|
"tfstk": "gZbiib4JpG-6DqW-B98_2rwPuFrd1fTXQt3vHEp4YpJIBA3OgrWcwOi90RTOo9XVQ5tAM5NcK_CP6Ep97K2ce1XDc59v3KXAgGFLyzC11ET2n8U8yoyib67M3xL25e8gS8pbyzC1_ET4e8URWTsSnHv2uh8VTeJBgEuN3d-ELQAWuKWV36PHGpJ2uEWVTxvicLX1ewyUXYSekxMf-CxMEqpnoqVvshvP_pABOwvXjL5wKqeulm52np_zpkfCDGW9Ot4uKFIRwZtP7vP9_gfAr3KEpDWXSIfWRay-DHIc_Z-hAzkD1i5Ooi5LZ0O5YO_1mUc476YMI3R6xzucUnRlNe_zemKdm172xMwr2L7CTgIkbvndhFAVh3_YFV9Ng__52U4SQKIdZZjc4diE4EUxlFrfKmiXbBOHeP72v7sAahuTtWm78hRB1yV3tmg9bBOEhWVnq5KwOBL5."
|
|
}
|
|
|
|
def homeContent(self, filter):
|
|
result = {}
|
|
categories = ["电视剧", "电影", "综艺", "动漫", "少儿", "纪录片", "文化", "亲子", "教育", "搞笑", "生活",
|
|
"体育", "音乐", "游戏"]
|
|
classes = [{'type_name': category, 'type_id': category} for category in categories]
|
|
filters = {}
|
|
self.typeid = {}
|
|
with ThreadPoolExecutor(max_workers=len(categories)) as executor:
|
|
tasks = {
|
|
executor.submit(self.cf, {'type': category}, True): category
|
|
for category in categories
|
|
}
|
|
|
|
for future in as_completed(tasks):
|
|
try:
|
|
category = tasks[future]
|
|
session, ft = future.result()
|
|
filters[category] = ft
|
|
self.typeid[category] = session
|
|
except Exception as e:
|
|
print(f"处理分类 {tasks[future]} 时出错: {str(e)}")
|
|
|
|
result['class'] = classes
|
|
result['filters'] = filters
|
|
return result
|
|
|
|
def homeVideoContent(self):
|
|
try:
|
|
vlist = []
|
|
params={"ms_codes":"2019061000","params":"{\"debug\":0,\"gray\":0,\"pageNo\":1,\"utdid\":\"ZYmGMAAAACkDAMU8hbiMmYdd\",\"userId\":\"\",\"bizKey\":\"YOUKU_WEB\",\"appPackageKey\":\"com.youku.YouKu\",\"showNodeList\":0,\"reqSubNode\":0,\"nodeKey\":\"WEBHOME\",\"bizContext\":\"{\\\"spmA\\\":\\\"a2hja\\\"}\"}","system_info":"{\"device\":\"pcweb\",\"os\":\"pcweb\",\"ver\":\"1.0.0.0\",\"userAgent\":\"Mozilla/5.0 (; Windows 10.0.26100.3194_64 ) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/93.0.4577.82 Electron/14.2.0 Safari/537.36 Node/14.17.0 YoukuDesktop/9.2.60 UOSYouku (2.0.1)-Electron(UTDID ZYmGMAAAACkDAMU8hbiMmYdd;CHANNEL official;ZREAL 0;BTYPE TM2013;BRAND TIMI;BUILDVER 9.2.60.1001)\",\"guid\":\"1590141704165YXe\",\"appPackageKey\":\"com.youku.pcweb\",\"young\":0,\"brand\":\"\",\"network\":\"\",\"ouid\":\"\",\"idfa\":\"\",\"scale\":\"\",\"operator\":\"\",\"resolution\":\"\",\"pid\":\"\",\"childGender\":0,\"zx\":0}"}
|
|
data=self.getdata(f'{self.h5host}/h5/mtop.youku.columbus.home.query/1.0/',params)
|
|
okey=list(data['data'].keys())[0]
|
|
for i in data['data'][okey]['data']['nodes'][0]['nodes'][-1]['nodes'][0]['nodes']:
|
|
if i.get('nodes') and i['nodes'][0].get('data'):
|
|
i=i['nodes'][0]['data']
|
|
if i.get('assignId'):
|
|
vlist.append({
|
|
'vod_id': i['assignId'],
|
|
'vod_name': i.get('title'),
|
|
'vod_pic': i.get('vImg') or i.get('img'),
|
|
'vod_year': i.get('mark',{}).get('data',{}).get('text'),
|
|
'vod_remarks': i.get('summary')
|
|
})
|
|
return {'list': vlist}
|
|
except Exception as e:
|
|
print(f"处理主页视频数据时出错: {str(e)}")
|
|
return {'list': []}
|
|
|
|
def categoryContent(self, tid, pg, filter, extend):
|
|
result = {}
|
|
vlist = []
|
|
result['page'] = pg
|
|
result['limit'] = 90
|
|
result['total'] = 999999
|
|
pagecount = 9999
|
|
params = {'type': tid}
|
|
id = self.typeid[tid]
|
|
params.update(extend)
|
|
if pg == '1':
|
|
id=self.cf(params)
|
|
data=self.session.get(f'{self.host}/category/data?session={id}¶ms={quote(json.dumps(params))}&pageNo={pg}').json()
|
|
try:
|
|
data=data['data']['filterData']
|
|
for i in data['listData']:
|
|
if i.get('videoLink') and 's=' in i['videoLink']:
|
|
vlist.append({
|
|
'vod_id': i.get('videoLink').split('s=')[-1],
|
|
'vod_name': i.get('title'),
|
|
'vod_pic': i.get('img'),
|
|
'vod_year': i.get('rightTagText'),
|
|
'vod_remarks': i.get('summary')
|
|
})
|
|
self.typeid[tid]=quote(json.dumps(data['session']))
|
|
except:
|
|
pagecount=pg
|
|
result['list'] = vlist
|
|
result['pagecount'] = pagecount
|
|
return result
|
|
|
|
def detailContent(self, ids):
|
|
try:
|
|
data=self.session.get(f'{self.ihost}/v_getvideo_info/?showId={ids[0]}').json()
|
|
v=data['data']
|
|
vod = {
|
|
'type_name': v.get('showVideotype'),
|
|
'vod_year': v.get('lastUpdate'),
|
|
'vod_remarks': v.get('rc_title'),
|
|
'vod_actor': v.get('_personNameStr'),
|
|
'vod_content': v.get('showdesc'),
|
|
'vod_play_from': '优酷',
|
|
'vod_play_url': ''
|
|
}
|
|
params={"biz":"new_detail_web2","videoId":v.get('vid'),"scene":"web_page","componentVersion":"3","ip":data.get('ip'),"debug":0,"utdid":"ZYmGMAAAACkDAMU8hbiMmYdd","userId":0,"platform":"pc","nextSession":"","gray":0,"source":"pcNoPrev","showId":ids[0]}
|
|
sdata,index=self.getinfo(params)
|
|
pdata=sdata['nodes']
|
|
if index > len(pdata):
|
|
batch_size = len(pdata)
|
|
total_batches = ((index + batch_size - 1) // batch_size) - 1
|
|
ssj = json.loads(sdata['data']['session'])
|
|
with ThreadPoolExecutor(max_workers=total_batches) as executor:
|
|
futures = []
|
|
for batch in range(total_batches):
|
|
start = batch_size + 1 + (batch * batch_size)
|
|
end = start + batch_size - 1
|
|
next_session = ssj.copy()
|
|
next_session.update({
|
|
"itemStartStage": start,
|
|
"itemEndStage": min(end, index)
|
|
})
|
|
current_params = params.copy()
|
|
current_params['nextSession'] = json.dumps(next_session)
|
|
futures.append((start, executor.submit(self.getvinfo, current_params)))
|
|
futures.sort(key=lambda x: x[0])
|
|
|
|
for _, future in futures:
|
|
try:
|
|
result = future.result()
|
|
pdata.extend(result['nodes'])
|
|
except Exception as e:
|
|
print(f"Error fetching data: {str(e)}")
|
|
vod['vod_play_url'] = '#'.join([f"{i['data'].get('title')}${i['data']['action'].get('value')}" for i in pdata])
|
|
return {'list': [vod]}
|
|
except Exception as e:
|
|
print(e)
|
|
return {'list': [{'vod_play_from': '哎呀翻车啦', 'vod_play_url': f'呜呜呜${self.host}'}]}
|
|
|
|
def searchContent(self, key, quick, pg="1"):
|
|
data=self.session.get(f'{self.shost}/api/search?pg={pg}&keyword={key}').json()
|
|
vlist = []
|
|
for i in data['pageComponentList']:
|
|
if i.get('commonData') and (i['commonData'].get('showId') or i['commonData'].get('realShowId')):
|
|
i=i['commonData']
|
|
vlist.append({
|
|
'vod_id': i.get('showId') or i.get('realShowId'),
|
|
'vod_name': i['titleDTO'].get('displayName'),
|
|
'vod_pic': i['posterDTO'].get('vThumbUrl'),
|
|
'vod_year': i.get('feature'),
|
|
'vod_remarks': i.get('updateNotice')
|
|
})
|
|
return {'list': vlist, 'page': pg}
|
|
|
|
def playerContent(self, flag, id, vipFlags):
|
|
return {'jx':1,'parse': 1, 'url': f"{self.ihost}/video?vid={id}", 'header': ''}
|
|
|
|
def localProxy(self, param):
|
|
pass
|
|
|
|
def cf(self,params,b=False):
|
|
response = self.session.get(f'{self.host}/category/data?params={quote(json.dumps(params))}&optionRefresh=1&pageNo=1').json()
|
|
data=response['data']['filterData']
|
|
session=quote(json.dumps(data['session']))
|
|
if b:
|
|
return session,self.get_filter_data(data['filter']['filterData'][1:])
|
|
return session
|
|
|
|
def process_key(self, key):
|
|
if '_' not in key:
|
|
return key
|
|
parts = key.split('_')
|
|
result = parts[0]
|
|
for part in parts[1:]:
|
|
if part:
|
|
result += part[0].upper() + part[1:]
|
|
return result
|
|
|
|
def get_filter_data(self, data):
|
|
result = []
|
|
try:
|
|
for item in data:
|
|
if not item.get('subFilter'):
|
|
continue
|
|
first_sub = item['subFilter'][0]
|
|
if not first_sub.get('filterType'):
|
|
continue
|
|
filter_item = {
|
|
'key': self.process_key(first_sub['filterType']),
|
|
'name': first_sub['title'],
|
|
'value': []
|
|
}
|
|
for sub in item['subFilter']:
|
|
if 'value' in sub:
|
|
filter_item['value'].append({
|
|
'n': sub['title'],
|
|
'v': sub['value']
|
|
})
|
|
if filter_item['value']:
|
|
result.append(filter_item)
|
|
|
|
except Exception as e:
|
|
print(f"处理筛选数据时出错: {str(e)}")
|
|
|
|
return result
|
|
|
|
def get_ctoken(self):
|
|
data=self.session.get(f'{self.h5host}/h5/mtop.ykrec.recommendservice.recommend/1.0/?jsv=2.6.1&appKey=24679788')
|
|
|
|
def md5(self,t,text):
|
|
h = MD5.new()
|
|
token=self.session.cookies.get('_m_h5_tk').split('_')[0]
|
|
data=f"{token}&{t}&24679788&{text}"
|
|
h.update(data.encode('utf-8'))
|
|
return h.hexdigest()
|
|
|
|
def getdata(self, url, params, recursion_count=0, max_recursion=3):
|
|
data = json.dumps(params)
|
|
t = int(time.time() * 1000)
|
|
jsdata = {
|
|
'appKey': '24679788',
|
|
't': t,
|
|
'sign': self.md5(t, data),
|
|
'data': data
|
|
}
|
|
response = self.session.get(url, params=jsdata)
|
|
if '令牌过期' in response.text:
|
|
if recursion_count >= max_recursion:
|
|
raise Exception("达到最大递归次数，无法继续请求")
|
|
self.get_ctoken()
|
|
return self.getdata(url, params, recursion_count + 1, max_recursion)
|
|
else:
|
|
return response.json()
|
|
|
|
def getvinfo(self,params):
|
|
body = {
|
|
"ms_codes": "2019030100",
|
|
"params": json.dumps(params),
|
|
"system_info": "{\"os\":\"iku\",\"device\":\"iku\",\"ver\":\"9.2.9\",\"appPackageKey\":\"com.youku.iku\",\"appPackageId\":\"pcweb\"}"
|
|
}
|
|
data = self.getdata(f'{self.h5host}/h5/mtop.youku.columbus.gateway.new.execute/1.0/', body)
|
|
okey = list(data['data'].keys())[0]
|
|
i = data['data'][okey]['data']
|
|
return i
|
|
|
|
def getinfo(self,params):
|
|
i = self.getvinfo(params)
|
|
jdata=i['nodes'][0]['nodes'][3]
|
|
info=i['data']['extra']['episodeTotal']
|
|
if i['data']['extra']['showCategory'] in ['电影','游戏']:
|
|
jdata = i['nodes'][0]['nodes'][4]
|
|
return jdata,info
|
|
|