#coding=utf-8 #!/usr/bin/python import sys sys.path.append('..') from base.spider import Spider import json class Spider(Spider): def getName(self): return "虎牙" def init(self,extend=""): pass def isVideoFormat(self,url): pass def manualVideoCheck(self): pass def homeContent(self,filter): result = {} cateManual = { "音乐": "音乐", "一起看": "一起看", "三国杀": "三国杀", "网游竞技": "网游竞技" } classes = [] for k in cateManual: classes.append({ 'type_name': k, 'type_id': cateManual[k] }) result['class'] = classes if (filter): result['filters'] = self.config['filter'] return result def homeVideoContent(self): result = {} return result def categoryContent(self,tid,pg,filter,extend): result = {} url = 'http://live.yj1211.work/api/live/getRecommendByPlatformArea?platform=huya&size=20&area={0}&page={1}'.format(tid, pg) rsp = self.fetch(url) content = rsp.text jo = json.loads(content) videos = [] vodList = jo['data'] for vod in vodList: aid = (vod['roomId']).strip() title = vod['roomName'].strip() img = vod['roomPic'].strip() remark = (vod['ownerName']).strip() videos.append({ "vod_id": aid, "vod_name": title, "vod_pic": img, "vod_remarks": remark }) result['list'] = videos result['page'] = pg result['pagecount'] = 9999 result['limit'] = 90 result['total'] = 999999 return result def detailContent(self,array): aid = array[0] url = "http://live.yj1211.work/api/live/getRoomInfo?platform=huya&roomId={0}".format(aid) rsp = self.fetch(url) jRoot = json.loads(rsp.text) jo = jRoot['data'] title = jo['roomName'] pic = jo['roomPic'] desc = str(jo['online']) dire = jo['ownerName'] typeName = jo['categoryName'] remark = jo['categoryName'] vod = { "vod_id": aid, "vod_name": title, "vod_pic": pic, "type_name": typeName, "vod_year": "", "vod_area": "", "vod_remarks": remark, "vod_actor": '在线人数:' + desc, "vod_director": dire, "vod_content": "" } playUrl = '原画' + '${0}#'.format(aid) vod['vod_play_from'] = '虎牙直播' vod['vod_play_url'] = playUrl result = { 'list': [ vod ] } return result def searchContent(self,key,quick): result = {} return result def playerContent(self,flag,id,vipFlags): result = {} url = 'https://mp.huya.com/cache.php?m=Live&do=profileRoom&roomid={0}'.format(id) rsp = self.fetch(url) jRoot = json.loads(rsp.text) if jRoot['data']['liveStatus'] != 'ON': return {} jo = jRoot['data'] ja = jo['stream']['baseSteamInfoList'][0]['sStreamName'] url = 'http://txtest-xp2p.p2p.huya.com/src/' + ja + '.xs?ratio=4000' result["parse"] = 0 result["playUrl"] = '' result["url"] = url result["header"] = { "User-Agent": "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/100.0.4896.127 Safari/537.36" } result["contentType"] = 'video/x-flv' return result config = { "player": {}, "filter": {} } header = {} config = { "player": {}, "filter": {} } header = {} def localProxy(self,param): action = { 'url':'', 'header':'', 'param':'', 'type':'string', 'after':'' } return [200, "video/MP2T", action, ""]