Ru/c/PY1/七哥大洋马.py

# 七哥
import sys
import time
import json
import re
import urllib.parse
from base64 import b64decode, b64encode
sys.path.append('..')
from base.spider import Spider

class Spider(Spider):
    def init(self, extend=""):
        self.host = "https://beeg.com"
        self.api_host = "https://store.externulls.com"
        self.video_host = "https://video.externulls.com"
        self.headers = {
            'User-Agent': 'Mozilla/5.0 (Linux; Android 10; Pixel 4) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/86.0.4240.198 Mobile Safari/537.36',
            'Referer': self.host + '/',
            'Origin': self.host,
            'Accept-Language': 'zh-CN,zh;q=0.9,en;q=0.8'
        }
        self.timeout = 15
        self.retries = 2

    def getName(self):
        return "Beeg"

    def isVideoFormat(self, url): 
        return True

    def manualVideoCheck(self): 
        return False

    def destroy(self): 
        pass

    def homeContent(self, filter):
        result = {}
        classes = [
            {"type_id": "latest", "type_name": "Latest Updates"},
            {"type_id": "channels", "type_name": "Channels"},
            {"type_id": "pornstars", "type_name": "Pornstars"},
            {"type_id": "categories", "type_name": "Categories"}
        ]
        result['class'] = classes
        return result

    def homeVideoContent(self):
        return self.categoryContent("latest", 1, None, {})

    def categoryContent(self, tid, pg, filter, extend):
        result = {}
        videos = []
        limit = 48
        offset = (int(pg) - 1) * limit
        
        if tid == "latest":
            url = f"{self.api_host}/facts/tag?id=27173&limit={limit}&offset={offset}"
            videos = self._fetch_video_list(url)
        elif tid.startswith(self.api_host) or "/facts/tag" in tid:
            if tid.startswith("http"):
                url = tid
            else:
                url = f"{self.api_host}/facts/tag?slug={tid}&limit={limit}&offset={offset}"
            url = re.sub(r"offset=\d+", f"offset={offset}", url)
            videos = self._fetch_video_list(url)
        elif tid in ["channels", "pornstars", "categories"]:
            url = f"{self.api_host}/tag/facts/tags?get_original=true&slug=index"
            videos = self._fetch_section_list(url, tid)
            
        result['list'] = videos
        result['page'] = pg
        result['pagecount'] = 9999
        result['limit'] = limit
        result['total'] = 999999
        return result

    def searchContent(self, key, quick, pg="1"):
        return {'list': []}

    def detailContent(self, ids):
        result = {}
        url = ids[0]
        video_id = url.rstrip('/').split('/')[-1]
        
        api_url = f"{self.api_host}/facts/file/{video_id}"
        
        title = f"Beeg Video {video_id}"
        pic = f"https://thumbs.externulls.com/videos/{video_id}/0.webp?size=480x270"
        desc = ""
        
        try:
            r = self.fetch(api_url, headers=self.headers)
            data = json.loads(r.text)
            
            file_data = data.get('file', {}).get('data', [])
            if file_data:
                title = file_data[0].get('cd_value', title)
            
            tags = data.get('tags', [])
            for tag in tags:
                tag_data = tag.get('data', [])
                if tag_data and tag_data[0].get('td_column') == 'tg_caption':
                    desc = tag_data[0].get('td_value', '')
                    break
        except: pass
            
        play_url = f"播放${self.e64(video_id)}"
        
        vod = {
            "vod_id": url,
            "vod_name": title,
            "vod_pic": pic,
            "vod_remarks": "",
            "vod_content": desc,
            "vod_play_from": "Beeg",
            "vod_play_url": play_url
        }
        result['list'] = [vod]
        return result

    def playerContent(self, flag, id, vipFlags):
        result = {}
        try:
            video_id = self.d64(id)
            api_url = f"{self.api_host}/facts/file/{video_id}"
            r = self.fetch(api_url, headers=self.headers)
            data = json.loads(r.text)
            
            final_url = None
            file_obj = data.get('file', {})
            
            # 1. 优先检查 hls_resources (用户指定的真实播放源)
            hls_res = file_obj.get('hls_resources', {})
            # 寻找 fl_cdn_xxx，按清晰度排序
            max_res = 0
            path = ""
            for k, v in hls_res.items():
                if k.startswith('fl_cdn_'):
                    # 排除 multi，只找数字清晰度
                    if 'multi' in k: continue
                    try:
                        res = int(k.replace('fl_cdn_', ''))
                        if res > max_res:
                            max_res = res
                            path = v
                    except: pass
            
            if path:
                final_url = f"{self.video_host}/{path}"
            
            # 2. 备选：qualities.h264
            if not final_url:
                qualities = file_obj.get('qualities', {}).get('h264', [])
                if qualities:
                    qualities.sort(key=lambda x: int(x.get('quality', 0)), reverse=True)
                    p = qualities[0].get('url')
                    if p: final_url = f"{self.video_host}/{p}"

            # 3. 备选：resources (旧版兼容)
            if not final_url:
                resources = file_obj.get('resources', {})
                for k, v in resources.items():
                    if k.startswith('fl_cdn_'):
                        final_url = f"{self.video_host}/{v}"
                        break

            if final_url:
                # 确保地址格式正确
                if final_url.startswith('https://video.externulls.com//'):
                    final_url = final_url.replace('.com//', '.com/')
                    
                result["parse"] = 0
                result["url"] = final_url
                result["header"] = {
                    'User-Agent': self.headers['User-Agent'],
                    'Referer': 'https://beeg.com/',
                    'Origin': 'https://beeg.com'
                }
            else:
                result["parse"] = 1
                result["url"] = f"https://beeg.com/{video_id}"
                result["header"] = self.headers

        except Exception as e:
            result["parse"] = 1
            result["url"] = f"https://beeg.com/{self.d64(id)}" if id else ""
            result["header"] = self.headers
            
        return result

    def _fetch_video_list(self, url):
        videos = []
        try:
            r = self.fetch(url, headers=self.headers)
            data = json.loads(r.text)
            items = data if isinstance(data, list) else []
            
            for elem in items:
                try:
                    file_info = elem.get("file", {})
                    video_id = file_info.get("id")
                    if not video_id: continue
                    
                    title = str(video_id)
                    file_data = file_info.get("data", [])
                    if file_data and len(file_data) > 0:
                        val = file_data[0].get("cd_value")
                        if val: title = val
                    
                    thumbnail = f"https://thumbs.externulls.com/videos/{video_id}/0.webp?size=480x270"
                    duration = str(file_info.get("fl_duration", ""))
                    
                    videos.append({
                        "vod_id": f"{self.host}/{video_id}",
                        "vod_name": title,
                        "vod_pic": thumbnail,
                        "vod_remarks": duration
                    })
                except: continue
        except: pass
        return videos

    def _fetch_section_list(self, url, section_type):
        videos = []
        try:
            r = self.fetch(url, headers=self.headers)
            data = json.loads(r.text)
            
            target_key = ""
            if section_type == "categories": target_key = "other"
            elif section_type == "channels": target_key = "productions"
            elif section_type == "pornstars": target_key = "human"
            
            items = data.get(target_key, [])
            
            for elem in items:
                try:
                    title = elem.get("tg_name", "")
                    slug = elem.get("tg_slug", "")
                    
                    thumbnail = ""
                    thumbs = elem.get("thumbs", [])
                    if thumbs:
                        thumb_id = thumbs[-1].get("id", "")
                        if thumb_id:
                            thumbnail = f"https://thumbs.externulls.com/photos/{thumb_id}/to.webp"
                    
                    vod_id = f"{self.api_host}/facts/tag?slug={slug}&limit=48&offset=0"
                    
                    videos.append({
                        "vod_id": vod_id,
                        "vod_name": title,
                        "vod_pic": thumbnail,
                        "vod_tag": "folder",
                        "vod_remarks": "分类"
                    })
                except: continue
        except: pass
        return videos

    def e64(self, text):
        return b64encode(text.encode()).decode()

    def d64(self, encoded_text):
        return b64decode(encoded_text.encode()).decode()

    def fetch(self, url, params=None, headers=None, timeout=None):
        import requests, ssl
        try: ssl._create_default_https_context = ssl._create_unverified_context
        except: pass
        if headers is None: headers = self.headers
        if timeout is None: timeout = self.timeout
        for _ in range(self.retries + 1):
            try:
                resp = requests.get(url, params=params, headers=headers, timeout=timeout, verify=False)
                resp.encoding = 'utf-8'
                return resp
            except: time.sleep(1)
        raise Exception("Fetch failed")