123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269 |
- # coding=utf-8
- # !/usr/bin/python
- import sys
- import requests
- from bs4 import BeautifulSoup
- import re
- import base64
- from base.spider import Spider
- import random
- sys.path.append('..')
- xurl = "https://heiliaowang-44.buzz"
- headerx = {
- 'User-Agent': 'Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/50.0.2661.87 Safari/537.36',
- }
- class Spider(Spider):
- global xurl
- global headerx
- def getName(self):
- return "首页"
- def init(self, extend):
- pass
- def isVideoFormat(self, url):
- pass
- def manualVideoCheck(self):
- pass
- def homeContent(self, filter):
- res = requests.get(xurl, headers=headerx)
- res.encoding = "utf-8"
- doc = BeautifulSoup(res.text, "html.parser")
- sourcediv = doc.find('div', class_='nav')
- vod = sourcediv.find_all('dd')
- string_list = ["首页", "激情图漫", "激情小说",
- "情色小说", "随机推荐", "顶级资源"]
- result = {}
- result['class'] = []
- result['class'].append({'type_id': "/type/328", 'type_name': "国产视频"})
- result['class'].append({'type_id': "/type/329", 'type_name': "中文字幕"})
- result['class'].append({'type_id': "/type/331", 'type_name': "日本有码"})
- result['class'].append({'type_id': "/type/332", 'type_name': "日本无码"})
- result['class'].append({'type_id': "/type/333", 'type_name': "欧美无码"})
- result['class'].append({'type_id': "/type/334", 'type_name': "强奸乱轮"})
- result['class'].append({'type_id': "/type/335", 'type_name': "制服诱惑"})
- result['class'].append({'type_id': "/type/336", 'type_name': "直播主播"})
- result['class'].append({'type_id': "/type/338", 'type_name': "明星换脸"})
- result['class'].append({'type_id': "/type/339", 'type_name': "抖阴视频"})
- result['class'].append({'type_id': "/type/340", 'type_name': "女优明星"})
- result['class'].append({'type_id': "/type/343", 'type_name': "网爆门"})
- result['class'].append({'type_id': "/type/345", 'type_name': "伦理三级"})
- result['class'].append({'type_id': "/type/346", 'type_name': "AV解说"})
- result['class'].append({'type_id': "/type/347", 'type_name': "SM调教"})
- result['class'].append({'type_id': "/type/348", 'type_name': "萝莉少女"})
- result['class'].append({'type_id': "/type/349", 'type_name': "极品媚黑"})
- result['class'].append({'type_id': "/type/350", 'type_name': "女同性恋"})
- result['class'].append({'type_id': "/type/351", 'type_name': "玩偶姐姐"})
- result['class'].append({'type_id': "/type/353", 'type_name': "人妖系列"})
- result['class'].append({'type_id': "/type/373", 'type_name': "韩国主播"})
- result['class'].append({'type_id': "/type/378", 'type_name': "VR视角"})
- for item in vod:
- name = item.find('a').text
- if name in string_list:
- continue
- id = item.find('a')['href']
- id = id.replace(".html", "")
- result['class'].append({'type_id': id, 'type_name': name})
- return result
- def homeVideoContent(self):
- videos = []
- try:
- res = requests.get(xurl, headers=headerx)
- res.encoding = "utf-8"
- doc = BeautifulSoup(res.text, "html.parser")
- sourcediv = doc.find_all('div', class_='pic')
- for vod in sourcediv:
- ul_elements = vod.find_all('ul')
- for item in ul_elements:
- name = item.select_one("li a")['title']
- pic = item.select_one("li a img")["data-src"]
- remark = item.select_one("li a span").text
- id = item.select_one("li a")['href']
- video = {
- "vod_id": id,
- "vod_name": name,
- "vod_pic": pic,
- "vod_remarks": remark
- }
- videos.append(video)
- except:
- pass
- result = {'list': videos}
- return result
- def categoryContent(self, cid, pg, filter, ext):
- result = {}
- videos = []
- if not pg:
- pg = 1
- url = xurl + cid + "/" + str(pg) + ".html"
- detail = requests.get(url=url, headers=headerx)
- detail.encoding = "utf-8"
- doc = BeautifulSoup(detail.text, "html.parser")
- sourcediv = doc.find_all('div', class_='pic')
- for vod in sourcediv:
- ul_elements = vod.find_all('ul')
- for item in ul_elements:
- name = item.select_one("li a")['title']
- pic = item.select_one("li a img")["src"]
- remark = item.select_one("li a span").text
- id = item.select_one("li a")['href']
- video = {
- "vod_id": id,
- "vod_name": name,
- "vod_pic": pic,
- "vod_remarks": remark
- }
- videos.append(video)
- result['list'] = videos
- result['page'] = pg
- result['pagecount'] = 9999
- result['limit'] = 90
- result['total'] = 999999
- return result
- def detailContent(self, ids):
- did = ids[0]
- videos = []
- result = {}
- res = requests.get(url=xurl + did, headers=headerx)
- res.encoding = "utf-8"
- doc = BeautifulSoup(res.text, "html.parser")
- sourcediv = doc.find('div', style='padding-bottom: 10px;')
- vod = sourcediv.find_all('a')
- play_from = ""
- play_url = ""
- for item in vod:
- play_from = play_from + item.text + "$$$"
- play_url = play_url + item['href'] + "$$$"
- while play_url[-1] == "#" or play_url[-1] == "$":
- play_url = play_url[:-1]
- while play_from[-1] == "#" or play_from[-1] == "$":
- play_from = play_from[:-1]
- source_match = re.search(r"<title>(.*?)的播放地址", res.text)
- if source_match:
- tx = source_match.group(1)
- videos.append({
- "vod_id": did,
- "vod_name": tx,
- "vod_pic": "",
- "type_name": "ぃぅおか🍬 คิดถึง",
- "vod_year": "",
- "vod_area": "",
- "vod_remarks": "",
- "vod_actor": "",
- "vod_director": "",
- "vod_content": "",
- "vod_play_from": play_from,
- "vod_play_url": play_url
- })
- result['list'] = videos
- return result
- def playerContent(self, flag, id, vipFlags):
- result = {}
- res = requests.get(url=xurl + id, headers=headerx)
- res.encoding = "utf-8"
- if '"rid"' in res.text:
- decoded_str = ''
- while not decoded_str:
- source_match3 = re.search(r'"rid" : "(.*?)"', res.text)
- if source_match3:
- id = source_match3.group(1)
- data = "rid=" + id
- header = {
- "User-Agent": "Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/50.0.2661.87 Safari/537.36",
- 'Content-Type': 'application/x-www-form-urlencoded; charset=UTF-8'
- }
- res2 = requests.post(url="https://heiliaowang-44.buzz/fetchPlayUrl3", headers=header, data=data)
- source_match4 = re.search(r'"returnData"\s*:\s*"([^"]+)"', res2.text)
- if source_match4:
- decoded_str = source_match4.group(1)
- else:
- source_match = re.search(r"http:(.*?)\.m3u8", res.text)
- decoded_str = ""
- if source_match:
- str3 = source_match.group(1)
- if "aHR0c" in str3:
- padding_needed = len(str3) % 4
- if padding_needed:
- str3 += '=' * (4 - padding_needed)
- decoded_str = base64.b64decode(str3).decode("utf-8")
- if not decoded_str:
- source_match2 = re.search(r"'(.*?)\.m3u8';", res.text)
- if source_match2:
- decoded_str = source_match2.group(1) + ".m3u8"
- result["parse"] = 0
- result["playUrl"] = ''
- result["url"] = decoded_str
- result["header"] = headerx
- return result
- def searchContent(self, key, quick):
- return self.searchContentPage(key, quick, '1')
- def searchContentPage(self, key, quick, page):
- result = {}
- videos = []
- if not page:
- page = 1
- url = xurl +"/search/"+ key +"/n/" + str(page)+".html"
- detail = requests.get(url=url, headers=headerx)
- detail.encoding = "utf-8"
- doc = BeautifulSoup(detail.text, "html.parser")
- sourcediv = doc.find_all('div', class_='pic')
- for vod in sourcediv:
- ul_elements = vod.find_all('ul')
- for item in ul_elements:
- name = item.select_one("li a")['title']
- pic = item.select_one("li a img")["src"]
- remark = item.select_one("li a span").text
- id = item.select_one("li a")['href']
- video = {
- "vod_id": id,
- "vod_name": name,
- "vod_pic": pic,
- "vod_remarks": remark
- }
- videos.append(video)
- result['list'] = videos
- result['page'] = page
- result['pagecount'] = 9999
- result['limit'] = 90
- result['total'] = 999999
- return result
- def localProxy(self, params):
- if params['type'] == "m3u8":
- return self.proxyM3u8(params)
- elif params['type'] == "media":
- return self.proxyMedia(params)
- elif params['type'] == "ts":
- return self.proxyTs(params)
- return None
|