From 7c6c76b80bb2b700dde3838e02606408a91d53a3 Mon Sep 17 00:00:00 2001
From: dong <dong@noreply@lihaso.ch>
Date: Fri, 2 Jan 2026 03:32:24 +0100
Subject: [PATCH] =?UTF-8?q?=E4=B8=8A=E4=BC=A0=E6=96=87=E4=BB=B6=E8=87=B3?=
 =?UTF-8?q?=20lib?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 lib/51吸瓜动态版.py | 405 ++++++++++++++++++++++++++++++++++++++++++++
 lib/51大赛.py       | 390 ++++++++++++++++++++++++++++++++++++++++++
 lib/51爆料.py       | 392 ++++++++++++++++++++++++++++++++++++++++++
 lib/51视频.py       | 390 ++++++++++++++++++++++++++++++++++++++++++
 lib/51黑料网.py     | 389 ++++++++++++++++++++++++++++++++++++++++++
 5 files changed, 1966 insertions(+)
 create mode 100644 lib/51吸瓜动态版.py
 create mode 100644 lib/51大赛.py
 create mode 100644 lib/51爆料.py
 create mode 100644 lib/51视频.py
 create mode 100644 lib/51黑料网.py

diff --git a/lib/51吸瓜动态版.py b/lib/51吸瓜动态版.py
new file mode 100644
index 0000000..b72b4e7
--- /dev/null
+++ b/lib/51吸瓜动态版.py
@@ -0,0 +1,405 @@
+# -*- coding: utf-8 -*-
+# 🌈 Love 
+import json
+import random
+import re
+import sys
+import threading
+import time
+from base64 import b64decode, b64encode
+from urllib.parse import urlparse
+
+import requests
+from Crypto.Cipher import AES
+from Crypto.Util.Padding import unpad
+from pyquery import PyQuery as pq
+sys.path.append('..')
+from base.spider import Spider
+
+
+class Spider(Spider):
+
+    def init(self, extend=""):
+        try:self.proxies = json.loads(extend)
+        except:self.proxies = {}
+        self.headers = {
+            'User-Agent': 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/134.0.0.0 Safari/537.36',
+            'Accept': 'text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3;q=0.7',
+            'Accept-Language': 'zh-CN,zh;q=0.9',
+            'Connection': 'keep-alive',
+            'Cache-Control': 'no-cache',
+        }
+        # Use working dynamic URLs directly
+        self.host = self.get_working_host()
+        self.headers.update({'Origin': self.host, 'Referer': f"{self.host}/"})
+        self.log(f"使用站点: {self.host}")
+        print(f"使用站点: {self.host}")
+        pass
+
+    def getName(self):
+        return "🌈 51吸瓜"
+
+    def isVideoFormat(self, url):
+        # Treat direct media formats as playable without parsing
+        return any(ext in (url or '') for ext in ['.m3u8', '.mp4', '.ts'])
+
+    def manualVideoCheck(self):
+        return False
+
+    def destroy(self):
+        pass
+
+    def homeContent(self, filter):
+        try:
+            response = requests.get(self.host, headers=self.headers, proxies=self.proxies, timeout=15)
+            if response.status_code != 200:
+                return {'class': [], 'list': []}
+                
+            data = self.getpq(response.text)
+            result = {}
+            classes = []
+            
+            # Try to get categories from different possible locations
+            category_selectors = [
+                '.category-list ul li',
+                '.nav-menu li',
+                '.menu li',
+                'nav ul li'
+            ]
+            
+            for selector in category_selectors:
+                for k in data(selector).items():
+                    link = k('a')
+                    href = (link.attr('href') or '').strip()
+                    name = (link.text() or '').strip()
+                    # Skip placeholder or invalid entries
+                    if not href or href == '#' or not name:
+                        continue
+                    classes.append({
+                        'type_name': name,
+                        'type_id': href
+                    })
+                if classes:
+                    break
+            
+            # If no categories found, create some default ones
+            if not classes:
+                classes = [
+                    {'type_name': '首页', 'type_id': '/'},
+                    {'type_name': '最新', 'type_id': '/latest/'},
+                    {'type_name': '热门', 'type_id': '/hot/'}
+                ]
+            
+            result['class'] = classes
+            result['list'] = self.getlist(data('#index article a'))
+            return result
+            
+        except Exception as e:
+            print(f"homeContent error: {e}")
+            return {'class': [], 'list': []}
+
+    def homeVideoContent(self):
+        try:
+            response = requests.get(self.host, headers=self.headers, proxies=self.proxies, timeout=15)
+            if response.status_code != 200:
+                return {'list': []}
+            data = self.getpq(response.text)
+            return {'list': self.getlist(data('#index article a, #archive article a'))}
+        except Exception as e:
+            print(f"homeVideoContent error: {e}")
+            return {'list': []}
+
+    def categoryContent(self, tid, pg, filter, extend):
+        try:
+            if '@folder' in tid:
+                id = tid.replace('@folder', '')
+                videos = self.getfod(id)
+            else:
+                # Build URL properly
+                if tid.startswith('/'):
+                    if pg and pg != '1':
+                        url = f"{self.host}{tid}page/{pg}/"
+                    else:
+                        url = f"{self.host}{tid}"
+                else:
+                    url = f"{self.host}/{tid}"
+                    
+                response = requests.get(url, headers=self.headers, proxies=self.proxies, timeout=15)
+                if response.status_code != 200:
+                    return {'list': [], 'page': pg, 'pagecount': 1, 'limit': 90, 'total': 0}
+                    
+                data = self.getpq(response.text)
+                videos = self.getlist(data('#archive article a, #index article a'), tid)
+                
+            result = {}
+            result['list'] = videos
+            result['page'] = pg
+            result['pagecount'] = 1 if '@folder' in tid else 99999
+            result['limit'] = 90
+            result['total'] = 999999
+            return result
+            
+        except Exception as e:
+            print(f"categoryContent error: {e}")
+            return {'list': [], 'page': pg, 'pagecount': 1, 'limit': 90, 'total': 0}
+
+    def detailContent(self, ids):
+        try:
+            url = f"{self.host}{ids[0]}" if not ids[0].startswith('http') else ids[0]
+            response = requests.get(url, headers=self.headers, proxies=self.proxies, timeout=15)
+            
+            if response.status_code != 200:
+                return {'list': [{'vod_play_from': '51吸瓜', 'vod_play_url': f'页面加载失败${url}'}]}
+                
+            data = self.getpq(response.text)
+            vod = {'vod_play_from': '51吸瓜'}
+            
+            # Get content/description
+            try:
+                clist = []
+                if data('.tags .keywords a'):
+                    for k in data('.tags .keywords a').items():
+                        title = k.text()
+                        href = k.attr('href')
+                        if title and href:
+                            clist.append('[a=cr:' + json.dumps({'id': href, 'name': title}) + '/]' + title + '[/a]')
+                vod['vod_content'] = ' '.join(clist) if clist else data('.post-title').text()
+            except:
+                vod['vod_content'] = data('.post-title').text() or '51吸瓜视频'
+            
+            # Get video URLs (build episode list when multiple players exist)
+            try:
+                plist = []
+                used_names = set()
+                if data('.dplayer'):
+                    for c, k in enumerate(data('.dplayer').items(), start=1):
+                        config_attr = k.attr('data-config')
+                        if config_attr:
+                            try:
+                                config = json.loads(config_attr)
+                                video_url = config.get('video', {}).get('url', '')
+                                # Determine a readable episode name from nearby headings if present
+                                ep_name = ''
+                                try:
+                                    parent = k.parents().eq(0)
+                                    # search up to a few ancestors for a heading text
+                                    for _ in range(3):
+                                        if not parent: break
+                                        heading = parent.find('h2, h3, h4').eq(0).text() or ''
+                                        heading = heading.strip()
+                                        if heading:
+                                            ep_name = heading
+                                            break
+                                        parent = parent.parents().eq(0)
+                                except Exception:
+                                    ep_name = ''
+                                base_name = ep_name if ep_name else f"视频{c}"
+                                name = base_name
+                                count = 2
+                                # Ensure the name is unique
+                                while name in used_names:
+                                    name = f"{base_name} {count}"
+                                    count += 1
+                                used_names.add(name)
+                                if video_url:
+                                    self.log(f"解析到视频: {name} -> {video_url}")
+                                    print(f"解析到视频: {name} -> {video_url}")
+                                    plist.append(f"{name}${video_url}")
+                            except:
+                                continue
+                
+                if plist:
+                    self.log(f"拼装播放列表，共{len(plist)}个")
+                    print(f"拼装播放列表，共{len(plist)}个")
+                    vod['vod_play_url'] = '#'.join(plist)
+                else:
+                    vod['vod_play_url'] = f"未找到视频源${url}"
+                    
+            except Exception as e:
+                vod['vod_play_url'] = f"视频解析失败${url}"
+                
+            return {'list': [vod]}
+            
+        except Exception as e:
+            print(f"detailContent error: {e}")
+            return {'list': [{'vod_play_from': '51吸瓜', 'vod_play_url': f'详情页加载失败${ids[0] if ids else ""}'}]}
+
+    def searchContent(self, key, quick, pg="1"):
+        try:
+            url = f"{self.host}/search/{key}/{pg}" if pg != "1" else f"{self.host}/search/{key}/"
+            response = requests.get(url, headers=self.headers, proxies=self.proxies, timeout=15)
+            
+            if response.status_code != 200:
+                return {'list': [], 'page': pg}
+                
+            data = self.getpq(response.text)
+            videos = self.getlist(data('#archive article a, #index article a'))
+            return {'list': videos, 'page': pg}
+            
+        except Exception as e:
+            print(f"searchContent error: {e}")
+            return {'list': [], 'page': pg}
+
+    def playerContent(self, flag, id, vipFlags):
+        url = id
+        p = 1
+        if self.isVideoFormat(url):
+            # m3u8/mp4 direct play; when using proxy setting, wrap to proxy for m3u8
+            if '.m3u8' in url:
+                url = self.proxy(url)
+            p = 0
+        self.log(f"播放请求: parse={p}, url={url}")
+        print(f"播放请求: parse={p}, url={url}")
+        return {'parse': p, 'url': url, 'header': self.headers}
+
+    def localProxy(self, param):
+        if param.get('type') == 'img':
+            res=requests.get(param['url'], headers=self.headers, proxies=self.proxies, timeout=10)
+            return [200,res.headers.get('Content-Type'),self.aesimg(res.content)]
+        elif param.get('type') == 'm3u8':return self.m3Proxy(param['url'])
+        else:return self.tsProxy(param['url'])
+
+    def proxy(self, data, type='m3u8'):
+        if data and len(self.proxies):return f"{self.getProxyUrl()}&url={self.e64(data)}&type={type}"
+        else:return data
+
+    def m3Proxy(self, url):
+        url=self.d64(url)
+        ydata = requests.get(url, headers=self.headers, proxies=self.proxies, allow_redirects=False)
+        data = ydata.content.decode('utf-8')
+        if ydata.headers.get('Location'):
+            url = ydata.headers['Location']
+            data = requests.get(url, headers=self.headers, proxies=self.proxies).content.decode('utf-8')
+        lines = data.strip().split('\n')
+        last_r = url[:url.rfind('/')]
+        parsed_url = urlparse(url)
+        durl = parsed_url.scheme + "://" + parsed_url.netloc
+        iskey=True
+        for index, string in enumerate(lines):
+            if iskey and 'URI' in string:
+                pattern = r'URI="([^"]*)"'
+                match = re.search(pattern, string)
+                if match:
+                    lines[index] = re.sub(pattern, f'URI="{self.proxy(match.group(1), "mkey")}"', string)
+                    iskey=False
+                    continue
+            if '#EXT' not in string:
+                if 'http' not in string:
+                    domain = last_r if string.count('/') < 2 else durl
+                    string = domain + ('' if string.startswith('/') else '/') + string
+                lines[index] = self.proxy(string, string.split('.')[-1].split('?')[0])
+        data = '\n'.join(lines)
+        return [200, "application/vnd.apple.mpegur", data]
+
+    def tsProxy(self, url):
+        url = self.d64(url)
+        data = requests.get(url, headers=self.headers, proxies=self.proxies, stream=True)
+        return [200, data.headers['Content-Type'], data.content]
+
+    def e64(self, text):
+        try:
+            text_bytes = text.encode('utf-8')
+            encoded_bytes = b64encode(text_bytes)
+            return encoded_bytes.decode('utf-8')
+        except Exception as e:
+            print(f"Base64编码错误: {str(e)}")
+            return ""
+
+    def d64(self, encoded_text):
+        try:
+            encoded_bytes = encoded_text.encode('utf-8')
+            decoded_bytes = b64decode(encoded_bytes)
+            return decoded_bytes.decode('utf-8')
+        except Exception as e:
+            print(f"Base64解码错误: {str(e)}")
+            return ""
+
+    def get_working_host(self):
+        """Get working host from known dynamic URLs"""
+        # Known working URLs from the dynamic gateway
+        dynamic_urls = [
+            'https://artist.vgwtswi.xyz',
+            'https://ability.vgwtswi.xyz', 
+            'https://am.vgwtswi.xyz',
+            'https://51cg1.com'
+        ]
+        
+        # Test each URL to find a working one
+        for url in dynamic_urls:
+            try:
+                response = requests.get(url, headers=self.headers, proxies=self.proxies, timeout=10)
+                if response.status_code == 200:
+                    # Verify it has the expected content structure
+                    data = self.getpq(response.text)
+                    articles = data('#index article a')
+                    if len(articles) > 0:
+                        self.log(f"选用可用站点: {url}")
+                        print(f"选用可用站点: {url}")
+                        return url
+            except Exception as e:
+                continue
+        
+        # Fallback to first URL if none work (better than crashing)
+        self.log(f"未检测到可用站点，回退: {dynamic_urls[0]}")
+        print(f"未检测到可用站点，回退: {dynamic_urls[0]}")
+        return dynamic_urls[0]
+
+
+    def getlist(self, data, tid=''):
+        videos = []
+        l = '/mrdg' in tid
+        for k in data.items():
+            a = k.attr('href')
+            b = k('h2').text()
+            # Some pages might not include datePublished; use a fallback
+            c = k('span[itemprop="datePublished"]').text() or k('.post-meta, .entry-meta, time').text()
+            if a and b:
+                videos.append({
+                    'vod_id': f"{a}{'@folder' if l else ''}",
+                    'vod_name': b.replace('\n', ' '),
+                    'vod_pic': self.getimg(k('script').text()),
+                    'vod_remarks': c or '',
+                    'vod_tag': 'folder' if l else '',
+                    'style': {"type": "rect", "ratio": 1.33}
+                })
+        return videos
+
+    def getfod(self, id):
+        url = f"{self.host}{id}"
+        data = self.getpq(requests.get(url, headers=self.headers, proxies=self.proxies).text)
+        vdata=data('.post-content[itemprop="articleBody"]')
+        r=['.txt-apps','.line','blockquote','.tags','.content-tabs']
+        for i in r:vdata.remove(i)
+        p=vdata('p')
+        videos=[]
+        for i,x in enumerate(vdata('h2').items()):
+            c=i*2
+            videos.append({
+                'vod_id': p.eq(c)('a').attr('href'),
+                'vod_name': p.eq(c).text(),
+                'vod_pic': f"{self.getProxyUrl()}&url={p.eq(c+1)('img').attr('data-xkrkllgl')}&type=img",
+                'vod_remarks':x.text()
+                })
+        return videos
+
+    def getimg(self, text):
+        match = re.search(r"loadBannerDirect\('([^']+)'", text)
+        if match:
+            url = match.group(1)
+            return f"{self.getProxyUrl()}&url={url}&type=img"
+        else:
+            return ''
+
+    def aesimg(self, word):
+        key = b'f5d965df75336270'
+        iv = b'97b60394abc2fbe1'
+        cipher = AES.new(key, AES.MODE_CBC, iv)
+        decrypted = unpad(cipher.decrypt(word), AES.block_size)
+        return decrypted
+
+    def getpq(self, data):
+        try:
+            return pq(data)
+        except Exception as e:
+            print(f"{str(e)}")
+            return pq(data.encode('utf-8'))
diff --git a/lib/51大赛.py b/lib/51大赛.py
new file mode 100644
index 0000000..dc131a0
--- /dev/null
+++ b/lib/51大赛.py
@@ -0,0 +1,390 @@
+import json
+import re
+import sys
+import hashlib
+from base64 import b64decode, b64encode
+from urllib.parse import urlparse
+
+import requests
+from Crypto.Cipher import AES
+from Crypto.Util.Padding import unpad
+from pyquery import PyQuery as pq
+sys.path.append('..')
+from base.spider import Spider as BaseSpider
+
+img_cache = {}
+
+class Spider(BaseSpider):
+
+    def init(self, extend=""):
+        try:
+            self.proxies = json.loads(extend)
+        except:
+            self.proxies = {}
+        self.headers = {
+            'User-Agent': 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36',
+            'Accept': 'text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,image/apng,*/*;q=0.8',
+            'Accept-Language': 'zh-CN,zh;q=0.9',
+            'Connection': 'keep-alive',
+            'Cache-Control': 'no-cache',
+        }
+        self.host = self.get_working_host()
+        self.headers.update({'Origin': self.host, 'Referer': f"{self.host}/"})
+        print(f"使用站点: {self.host}")
+
+    def getName(self):
+        return "🌈 51大赛|终极完美版"
+
+    def isVideoFormat(self, url):
+        return any(ext in (url or '') for ext in ['.m3u8', '.mp4', '.ts'])
+
+    def manualVideoCheck(self):
+        return False
+
+    def destroy(self):
+        global img_cache
+        img_cache.clear()
+
+    def get_working_host(self):
+        dynamic_urls = [
+            'https://jbgcz2.dzebypd.xyz/',
+            'https://jbgcz3.dzebypd.xyz/'
+        ]
+        for url in dynamic_urls:
+            try:
+                response = requests.get(url, headers=self.headers, proxies=self.proxies, timeout=10)
+                if response.status_code == 200:
+                    return url
+            except Exception:
+                continue
+        return dynamic_urls[0]
+
+    def homeContent(self, filter):
+        try:
+            response = requests.get(self.host, headers=self.headers, proxies=self.proxies, timeout=15)
+            if response.status_code != 200: return {'class': [], 'list': []}
+            data = self.getpq(response.text)
+            
+            classes = []
+            category_selectors = ['.category-list ul li', '.nav-menu li', '.menu li', 'nav ul li']
+            for selector in category_selectors:
+                for k in data(selector).items():
+                    link = k('a')
+                    href = (link.attr('href') or '').strip()
+                    name = (link.text() or '').strip()
+                    if not href or href == '#' or not name: continue
+                    classes.append({'type_name': name, 'type_id': href})
+                if classes: break
+            
+            if not classes:
+                classes = [{'type_name': '最新', 'type_id': '/latest/'}, {'type_name': '热门', 'type_id': '/hot/'}]
+            
+            return {'class': classes, 'list': self.getlist(data('#index article, article'))}
+        except Exception as e:
+            return {'class': [], 'list': []}
+
+    def homeVideoContent(self):
+        try:
+            response = requests.get(self.host, headers=self.headers, proxies=self.proxies, timeout=15)
+            if response.status_code != 200: return {'list': []}
+            data = self.getpq(response.text)
+            return {'list': self.getlist(data('#index article, article'))}
+        except Exception as e:
+            return {'list': []}
+
+    def categoryContent(self, tid, pg, filter, extend):
+        try:
+            if '@folder' in tid:
+                v = self.getfod(tid.replace('@folder', ''))
+                return {'list': v, 'page': 1, 'pagecount': 1, 'limit': 90, 'total': len(v)}
+            
+            pg = int(pg) if pg else 1
+            
+            if tid.startswith('http'):
+                base_url = tid.rstrip('/')
+            else:
+                path = tid if tid.startswith('/') else f"/{tid}"
+                base_url = f"{self.host}{path}".rstrip('/')
+            
+            if pg == 1:
+                url = f"{base_url}/"
+            else:
+                url = f"{base_url}/{pg}/"
+                
+            response = requests.get(url, headers=self.headers, proxies=self.proxies, timeout=15)
+            if response.status_code != 200: return {'list': [], 'page': pg, 'pagecount': 9999, 'limit': 90, 'total': 0}
+                
+            data = self.getpq(response.text)
+            videos = self.getlist(data('#archive article, #index article, article'), tid)
+            
+            return {'list': videos, 'page': pg, 'pagecount': 9999, 'limit': 90, 'total': 999999}
+        except Exception as e:
+            return {'list': [], 'page': pg, 'pagecount': 9999, 'limit': 90, 'total': 0}
+
+    def detailContent(self, ids):
+        try:
+            url = ids[0] if ids[0].startswith('http') else f"{self.host}{ids[0]}"
+            response = requests.get(url, headers=self.headers, proxies=self.proxies, timeout=15)
+            data = self.getpq(response.text)
+            
+            plist = []
+            used_names = set()
+            if data('.dplayer'):
+                for c, k in enumerate(data('.dplayer').items(), start=1):
+                    try:
+                        config_attr = k.attr('data-config')
+                        if config_attr:
+                            config = json.loads(config_attr)
+                            video_url = config.get('video', {}).get('url', '')
+                            
+                            if video_url:
+                                ep_name = ''
+                                parent = k.parents().eq(0)
+                                for _ in range(4):
+                                    if not parent: break
+                                    heading = parent.find('h2, h3, h4').eq(0).text().strip()
+                                    if heading:
+                                        ep_name = heading
+                                        break
+                                    parent = parent.parents().eq(0)
+                                
+                                base_name = ep_name if ep_name else f"视频{c}"
+                                name = base_name
+                                count = 2
+                                while name in used_names:
+                                    name = f"{base_name} {count}"
+                                    count += 1
+                                used_names.add(name)
+                                
+                                plist.append(f"{name}${video_url}")
+                    except: continue
+            
+            if not plist:
+                content_area = data('.post-content, article')
+                for i, link in enumerate(content_area('a').items(), start=1):
+                    link_text = link.text().strip()
+                    link_href = link.attr('href')
+                    
+                    if link_href and any(kw in link_text for kw in ['点击观看', '观看', '播放', '视频', '第一弹', '第二弹', '第三弹', '第四弹', '第五弹', '第六弹', '第七弹', '第八弹', '第九弹', '第十弹']):
+                        ep_name = link_text.replace('点击观看：', '').replace('点击观看', '').strip()
+                        if not ep_name: ep_name = f"视频{i}"
+                        
+                        if not link_href.startswith('http'):
+                            link_href = f"{self.host}{link_href}" if link_href.startswith('/') else f"{self.host}/{link_href}"
+                        
+                        plist.append(f"{ep_name}${link_href}")
+            
+            play_url = '#'.join(plist) if plist else f"未找到视频源${url}"
+            
+            vod_content = ''
+            try:
+                tags = []
+                seen_names = set()
+                seen_ids = set()
+                
+                tag_links = data('.tags a, .keywords a, .post-tags a')
+                
+                candidates = []
+                for k in tag_links.items():
+                    title = k.text().strip()
+                    href = k.attr('href')
+                    if title and href:
+                        candidates.append({'name': title, 'id': href})
+                
+                candidates.sort(key=lambda x: len(x['name']), reverse=True)
+                
+                for item in candidates:
+                    name = item['name']
+                    id_ = item['id']
+                    
+                    if id_ in seen_ids: continue
+                    
+                    is_duplicate = False
+                    for seen in seen_names:
+                        if name in seen:
+                            is_duplicate = True
+                            break
+                    
+                    if not is_duplicate:
+                        target = json.dumps({'id': id_, 'name': name})
+                        tags.append(f'[a=cr:{target}/]{name}[/a]')
+                        seen_names.add(name)
+                        seen_ids.add(id_)
+                
+                if tags:
+                    vod_content = ' '.join(tags)
+                else:
+                    vod_content = data('.post-title').text()
+            except Exception:
+                vod_content = '获取标签失败'
+
+            if not vod_content:
+                vod_content = data('h1').text() or '51大赛'
+
+            return {'list': [{'vod_play_from': '51大赛', 'vod_play_url': play_url, 'vod_content': vod_content}]}
+        except:
+            return {'list': [{'vod_play_from': '51大赛', 'vod_play_url': '获取失败'}]}
+
+    def searchContent(self, key, quick, pg="1"):
+        try:
+            pg = int(pg) if pg else 1
+            
+            if pg == 1:
+                url = f"{self.host}/search/{key}/"
+            else:
+                url = f"{self.host}/search/{key}/{pg}/"
+            
+            response = requests.get(url, headers=self.headers, proxies=self.proxies, timeout=15)
+            return {'list': self.getlist(self.getpq(response.text)('article')), 'page': pg, 'pagecount': 9999}
+        except:
+            return {'list': [], 'page': pg, 'pagecount': 9999}
+
+    def playerContent(self, flag, id, vipFlags):
+        parse = 0 if self.isVideoFormat(id) else 1
+        url = self.proxy(id) if '.m3u8' in id else id
+        return {'parse': parse, 'url': url, 'header': self.headers}
+
+    def localProxy(self, param):
+        try:
+            type_ = param.get('type')
+            url = param.get('url')
+            if type_ == 'cache':
+                key = param.get('key')
+                if content := img_cache.get(key):
+                    return [200, 'image/jpeg', content]
+                return [404, 'text/plain', b'Expired']
+            elif type_ == 'img':
+                real_url = self.d64(url) if not url.startswith('http') else url
+                res = requests.get(real_url, headers=self.headers, proxies=self.proxies, timeout=10)
+                content = self.aesimg(res.content)
+                return [200, 'image/jpeg', content]
+            elif type_ == 'm3u8':
+                return self.m3Proxy(url)
+            else:
+                return self.tsProxy(url)
+        except:
+            return [404, 'text/plain', b'']
+
+    def proxy(self, data, type='m3u8'):
+        if data and self.proxies: return f"{self.getProxyUrl()}&url={self.e64(data)}&type={type}"
+        return data
+
+    def m3Proxy(self, url):
+        url = self.d64(url)
+        res = requests.get(url, headers=self.headers, proxies=self.proxies)
+        data = res.text
+        base = res.url.rsplit('/', 1)[0]
+        lines = []
+        for line in data.split('\n'):
+            if '#EXT' not in line and line.strip():
+                if not line.startswith('http'):
+                    line = f"{base}/{line}"
+                lines.append(self.proxy(line, 'ts'))
+            else:
+                lines.append(line)
+        return [200, "application/vnd.apple.mpegurl", '\n'.join(lines)]
+
+    def tsProxy(self, url):
+        return [200, 'video/mp2t', requests.get(self.d64(url), headers=self.headers, proxies=self.proxies).content]
+
+    def e64(self, text):
+        return b64encode(str(text).encode()).decode()
+
+    def d64(self, text):
+        return b64decode(str(text).encode()).decode()
+
+    def aesimg(self, data):
+        if len(data) < 16: return data
+        keys = [(b'f5d965df75336270', b'97b60394abc2fbe1'), (b'75336270f5d965df', b'abc2fbe197b60394')]
+        for k, v in keys:
+            try:
+                dec = unpad(AES.new(k, AES.MODE_CBC, v).decrypt(data), 16)
+                if dec.startswith(b'\xff\xd8') or dec.startswith(b'\x89PNG'): return dec
+            except: pass
+            try:
+                dec = unpad(AES.new(k, AES.MODE_ECB).decrypt(data), 16)
+                if dec.startswith(b'\xff\xd8'): return dec
+            except: pass
+        return data
+
+    def getlist(self, data, tid=''):
+        videos = []
+        is_folder = '/mrdg' in (tid or '')
+        for k in data.items():
+            card_html = k.outer_html() if hasattr(k, 'outer_html') else str(k)
+            a = k if k.is_('a') else k('a').eq(0)
+            href = a.attr('href')
+            title = k('h2').text() or k('.entry-title').text() or k('.post-title').text()
+            if not title and k.is_('a'): title = k.text()
+            
+            if href and title:
+                img = self.getimg(k('script').text(), k, card_html)
+                videos.append({
+                    'vod_id': f"{href}{'@folder' if is_folder else ''}",
+                    'vod_name': title.strip(),
+                    'vod_pic': img,
+                    'vod_remarks': k('time').text() or '',
+                    'vod_tag': 'folder' if is_folder else '',
+                    'style': {"type": "rect", "ratio": 1.33}
+                })
+        return videos
+
+    def getfod(self, id):
+        url = f"{self.host}{id}"
+        data = self.getpq(requests.get(url, headers=self.headers, proxies=self.proxies).text)
+        videos = []
+        for i, h2 in enumerate(data('.post-content h2').items()):
+            p_txt = data('.post-content p').eq(i * 2)
+            p_img = data('.post-content p').eq(i * 2 + 1)
+            p_html = p_img.outer_html() if hasattr(p_img, 'outer_html') else str(p_img)
+            videos.append({
+                'vod_id': p_txt('a').attr('href'),
+                'vod_name': p_txt.text().strip(),
+                'vod_pic': self.getimg('', p_img, p_html),
+                'vod_remarks': h2.text().strip()
+            })
+        return videos
+
+    def getimg(self, text, elem=None, html_content=None):
+        if m := re.search(r"loadBannerDirect\('([^']+)'", text or ''):
+            return self._proc_url(m.group(1))
+        
+        if html_content is None and elem is not None:
+             html_content = elem.outer_html() if hasattr(elem, 'outer_html') else str(elem)
+        if not html_content: return ''
+
+        html_content = html_content.replace('&quot;', '"').replace('&apos;', "'").replace('&amp;', '&')
+
+        if 'data:image' in html_content:
+            m = re.search(r'(data:image/[a-zA-Z0-9+/=;,]+)', html_content)
+            if m: return self._proc_url(m.group(1))
+
+        m = re.search(r'(https?://[^"\'\s)]+\.(?:jpg|png|jpeg|webp))', html_content, re.I)
+        if m: return self._proc_url(m.group(1))
+            
+        if 'url(' in html_content:
+            m = re.search(r'url\s*\(\s*[\'"]?([^"\'\)]+)[\'"]?\s*\)', html_content, re.I)
+            if m: return self._proc_url(m.group(1))
+            
+        return ''
+
+    def _proc_url(self, url):
+        if not url: return ''
+        url = url.strip('\'" ')
+        if url.startswith('data:'):
+            try:
+                _, b64_str = url.split(',', 1)
+                raw = b64decode(b64_str)
+                if not (raw.startswith(b'\xff\xd8') or raw.startswith(b'\x89PNG') or raw.startswith(b'GIF8')):
+                    raw = self.aesimg(raw)
+                key = hashlib.md5(raw).hexdigest()
+                img_cache[key] = raw
+                return f"{self.getProxyUrl()}&type=cache&key={key}"
+            except: return ""
+        if not url.startswith('http'):
+            url = f"{self.host}{url}" if url.startswith('/') else f"{self.host}/{url}"
+        return f"{self.getProxyUrl()}&url={self.e64(url)}&type=img"
+
+    def getpq(self, data):
+        try: return pq(data)
+        except: return pq(data.encode('utf-8'))
diff --git a/lib/51爆料.py b/lib/51爆料.py
new file mode 100644
index 0000000..66d50c6
--- /dev/null
+++ b/lib/51爆料.py
@@ -0,0 +1,392 @@
+import json
+import re
+import sys
+import hashlib
+from base64 import b64decode, b64encode
+from urllib.parse import urlparse
+
+import requests
+from Crypto.Cipher import AES
+from Crypto.Util.Padding import unpad
+from pyquery import PyQuery as pq
+sys.path.append('..')
+from base.spider import Spider as BaseSpider
+
+img_cache = {}
+
+class Spider(BaseSpider):
+
+    def init(self, extend=""):
+        try:
+            self.proxies = json.loads(extend)
+        except:
+            self.proxies = {}
+        self.headers = {
+            'User-Agent': 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36',
+            'Accept': 'text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,image/apng,*/*;q=0.8',
+            'Accept-Language': 'zh-CN,zh;q=0.9',
+            'Connection': 'keep-alive',
+            'Cache-Control': 'no-cache',
+        }
+        self.host = self.get_working_host()
+        self.headers.update({'Origin': self.host, 'Referer': f"{self.host}/"})
+        print(f"使用站点: {self.host}")
+
+    def getName(self):
+        return "🌈 51爆料|终极完美版"
+
+    def isVideoFormat(self, url):
+        return any(ext in (url or '') for ext in ['.m3u8', '.mp4', '.ts'])
+
+    def manualVideoCheck(self):
+        return False
+
+    def destroy(self):
+        global img_cache
+        img_cache.clear()
+
+    def get_working_host(self):
+        dynamic_urls = [ 
+            'https://across.iofjyyi.com/',
+            'https://admit.iofjyyi.com/',
+            'https://www.51baoliao01.com/',
+            'https://allow.iofjyyi.com/'
+        ]
+        for url in dynamic_urls:
+            try:
+                response = requests.get(url, headers=self.headers, proxies=self.proxies, timeout=10)
+                if response.status_code == 200:
+                    return url
+            except Exception:
+                continue
+        return dynamic_urls[0]
+
+    def homeContent(self, filter):
+        try:
+            response = requests.get(self.host, headers=self.headers, proxies=self.proxies, timeout=15)
+            if response.status_code != 200: return {'class': [], 'list': []}
+            data = self.getpq(response.text)
+            
+            classes = []
+            category_selectors = ['.category-list ul li', '.nav-menu li', '.menu li', 'nav ul li']
+            for selector in category_selectors:
+                for k in data(selector).items():
+                    link = k('a')
+                    href = (link.attr('href') or '').strip()
+                    name = (link.text() or '').strip()
+                    if not href or href == '#' or not name: continue
+                    classes.append({'type_name': name, 'type_id': href})
+                if classes: break
+            
+            if not classes:
+                classes = [{'type_name': '最新', 'type_id': '/latest/'}, {'type_name': '热门', 'type_id': '/hot/'}]
+            
+            return {'class': classes, 'list': self.getlist(data('#index article, article'))}
+        except Exception as e:
+            return {'class': [], 'list': []}
+
+    def homeVideoContent(self):
+        try:
+            response = requests.get(self.host, headers=self.headers, proxies=self.proxies, timeout=15)
+            if response.status_code != 200: return {'list': []}
+            data = self.getpq(response.text)
+            return {'list': self.getlist(data('#index article, article'))}
+        except Exception as e:
+            return {'list': []}
+
+    def categoryContent(self, tid, pg, filter, extend):
+        try:
+            if '@folder' in tid:
+                v = self.getfod(tid.replace('@folder', ''))
+                return {'list': v, 'page': 1, 'pagecount': 1, 'limit': 90, 'total': len(v)}
+            
+            pg = int(pg) if pg else 1
+            
+            if tid.startswith('http'):
+                base_url = tid.rstrip('/')
+            else:
+                path = tid if tid.startswith('/') else f"/{tid}"
+                base_url = f"{self.host}{path}".rstrip('/')
+            
+            if pg == 1:
+                url = f"{base_url}/"
+            else:
+                url = f"{base_url}/{pg}/"
+                
+            response = requests.get(url, headers=self.headers, proxies=self.proxies, timeout=15)
+            if response.status_code != 200: return {'list': [], 'page': pg, 'pagecount': 9999, 'limit': 90, 'total': 0}
+                
+            data = self.getpq(response.text)
+            videos = self.getlist(data('#archive article, #index article, article'), tid)
+            
+            return {'list': videos, 'page': pg, 'pagecount': 9999, 'limit': 90, 'total': 999999}
+        except Exception as e:
+            return {'list': [], 'page': pg, 'pagecount': 9999, 'limit': 90, 'total': 0}
+
+    def detailContent(self, ids):
+        try:
+            url = ids[0] if ids[0].startswith('http') else f"{self.host}{ids[0]}"
+            response = requests.get(url, headers=self.headers, proxies=self.proxies, timeout=15)
+            data = self.getpq(response.text)
+            
+            plist = []
+            used_names = set()
+            if data('.dplayer'):
+                for c, k in enumerate(data('.dplayer').items(), start=1):
+                    try:
+                        config_attr = k.attr('data-config')
+                        if config_attr:
+                            config = json.loads(config_attr)
+                            video_url = config.get('video', {}).get('url', '')
+                            
+                            if video_url:
+                                ep_name = ''
+                                parent = k.parents().eq(0)
+                                for _ in range(4):
+                                    if not parent: break
+                                    heading = parent.find('h2, h3, h4').eq(0).text().strip()
+                                    if heading:
+                                        ep_name = heading
+                                        break
+                                    parent = parent.parents().eq(0)
+                                
+                                base_name = ep_name if ep_name else f"视频{c}"
+                                name = base_name
+                                count = 2
+                                while name in used_names:
+                                    name = f"{base_name} {count}"
+                                    count += 1
+                                used_names.add(name)
+                                
+                                plist.append(f"{name}${video_url}")
+                    except: continue
+            
+            if not plist:
+                content_area = data('.post-content, article')
+                for i, link in enumerate(content_area('a').items(), start=1):
+                    link_text = link.text().strip()
+                    link_href = link.attr('href')
+                    
+                    if link_href and any(kw in link_text for kw in ['点击观看', '观看', '播放', '视频', '第一弹', '第二弹', '第三弹', '第四弹', '第五弹', '第六弹', '第七弹', '第八弹', '第九弹', '第十弹']):
+                        ep_name = link_text.replace('点击观看：', '').replace('点击观看', '').strip()
+                        if not ep_name: ep_name = f"视频{i}"
+                        
+                        if not link_href.startswith('http'):
+                            link_href = f"{self.host}{link_href}" if link_href.startswith('/') else f"{self.host}/{link_href}"
+                        
+                        plist.append(f"{ep_name}${link_href}")
+            
+            play_url = '#'.join(plist) if plist else f"未找到视频源${url}"
+            
+            vod_content = ''
+            try:
+                tags = []
+                seen_names = set()
+                seen_ids = set()
+                
+                tag_links = data('.tags a, .keywords a, .post-tags a')
+                
+                candidates = []
+                for k in tag_links.items():
+                    title = k.text().strip()
+                    href = k.attr('href')
+                    if title and href:
+                        candidates.append({'name': title, 'id': href})
+                
+                candidates.sort(key=lambda x: len(x['name']), reverse=True)
+                
+                for item in candidates:
+                    name = item['name']
+                    id_ = item['id']
+                    
+                    if id_ in seen_ids: continue
+                    
+                    is_duplicate = False
+                    for seen in seen_names:
+                        if name in seen:
+                            is_duplicate = True
+                            break
+                    
+                    if not is_duplicate:
+                        target = json.dumps({'id': id_, 'name': name})
+                        tags.append(f'[a=cr:{target}/]{name}[/a]')
+                        seen_names.add(name)
+                        seen_ids.add(id_)
+                
+                if tags:
+                    vod_content = ' '.join(tags)
+                else:
+                    vod_content = data('.post-title').text()
+            except Exception:
+                vod_content = '获取标签失败'
+
+            if not vod_content:
+                vod_content = data('h1').text() or '51爆料'
+
+            return {'list': [{'vod_play_from': '51爆料', 'vod_play_url': play_url, 'vod_content': vod_content}]}
+        except:
+            return {'list': [{'vod_play_from': '51爆料', 'vod_play_url': '获取失败'}]}
+
+    def searchContent(self, key, quick, pg="1"):
+        try:
+            pg = int(pg) if pg else 1
+            
+            if pg == 1:
+                url = f"{self.host}/search/{key}/"
+            else:
+                url = f"{self.host}/search/{key}/{pg}/"
+            
+            response = requests.get(url, headers=self.headers, proxies=self.proxies, timeout=15)
+            return {'list': self.getlist(self.getpq(response.text)('article')), 'page': pg, 'pagecount': 9999}
+        except:
+            return {'list': [], 'page': pg, 'pagecount': 9999}
+
+    def playerContent(self, flag, id, vipFlags):
+        parse = 0 if self.isVideoFormat(id) else 1
+        url = self.proxy(id) if '.m3u8' in id else id
+        return {'parse': parse, 'url': url, 'header': self.headers}
+
+    def localProxy(self, param):
+        try:
+            type_ = param.get('type')
+            url = param.get('url')
+            if type_ == 'cache':
+                key = param.get('key')
+                if content := img_cache.get(key):
+                    return [200, 'image/jpeg', content]
+                return [404, 'text/plain', b'Expired']
+            elif type_ == 'img':
+                real_url = self.d64(url) if not url.startswith('http') else url
+                res = requests.get(real_url, headers=self.headers, proxies=self.proxies, timeout=10)
+                content = self.aesimg(res.content)
+                return [200, 'image/jpeg', content]
+            elif type_ == 'm3u8':
+                return self.m3Proxy(url)
+            else:
+                return self.tsProxy(url)
+        except:
+            return [404, 'text/plain', b'']
+
+    def proxy(self, data, type='m3u8'):
+        if data and self.proxies: return f"{self.getProxyUrl()}&url={self.e64(data)}&type={type}"
+        return data
+
+    def m3Proxy(self, url):
+        url = self.d64(url)
+        res = requests.get(url, headers=self.headers, proxies=self.proxies)
+        data = res.text
+        base = res.url.rsplit('/', 1)[0]
+        lines = []
+        for line in data.split('\n'):
+            if '#EXT' not in line and line.strip():
+                if not line.startswith('http'):
+                    line = f"{base}/{line}"
+                lines.append(self.proxy(line, 'ts'))
+            else:
+                lines.append(line)
+        return [200, "application/vnd.apple.mpegurl", '\n'.join(lines)]
+
+    def tsProxy(self, url):
+        return [200, 'video/mp2t', requests.get(self.d64(url), headers=self.headers, proxies=self.proxies).content]
+
+    def e64(self, text):
+        return b64encode(str(text).encode()).decode()
+
+    def d64(self, text):
+        return b64decode(str(text).encode()).decode()
+
+    def aesimg(self, data):
+        if len(data) < 16: return data
+        keys = [(b'f5d965df75336270', b'97b60394abc2fbe1'), (b'75336270f5d965df', b'abc2fbe197b60394')]
+        for k, v in keys:
+            try:
+                dec = unpad(AES.new(k, AES.MODE_CBC, v).decrypt(data), 16)
+                if dec.startswith(b'\xff\xd8') or dec.startswith(b'\x89PNG'): return dec
+            except: pass
+            try:
+                dec = unpad(AES.new(k, AES.MODE_ECB).decrypt(data), 16)
+                if dec.startswith(b'\xff\xd8'): return dec
+            except: pass
+        return data
+
+    def getlist(self, data, tid=''):
+        videos = []
+        is_folder = '/mrdg' in (tid or '')
+        for k in data.items():
+            card_html = k.outer_html() if hasattr(k, 'outer_html') else str(k)
+            a = k if k.is_('a') else k('a').eq(0)
+            href = a.attr('href')
+            title = k('h2').text() or k('.entry-title').text() or k('.post-title').text()
+            if not title and k.is_('a'): title = k.text()
+            
+            if href and title:
+                img = self.getimg(k('script').text(), k, card_html)
+                videos.append({
+                    'vod_id': f"{href}{'@folder' if is_folder else ''}",
+                    'vod_name': title.strip(),
+                    'vod_pic': img,
+                    'vod_remarks': k('time').text() or '',
+                    'vod_tag': 'folder' if is_folder else '',
+                    'style': {"type": "rect", "ratio": 1.33}
+                })
+        return videos
+
+    def getfod(self, id):
+        url = f"{self.host}{id}"
+        data = self.getpq(requests.get(url, headers=self.headers, proxies=self.proxies).text)
+        videos = []
+        for i, h2 in enumerate(data('.post-content h2').items()):
+            p_txt = data('.post-content p').eq(i * 2)
+            p_img = data('.post-content p').eq(i * 2 + 1)
+            p_html = p_img.outer_html() if hasattr(p_img, 'outer_html') else str(p_img)
+            videos.append({
+                'vod_id': p_txt('a').attr('href'),
+                'vod_name': p_txt.text().strip(),
+                'vod_pic': self.getimg('', p_img, p_html),
+                'vod_remarks': h2.text().strip()
+            })
+        return videos
+
+    def getimg(self, text, elem=None, html_content=None):
+        if m := re.search(r"loadBannerDirect\('([^']+)'", text or ''):
+            return self._proc_url(m.group(1))
+        
+        if html_content is None and elem is not None:
+             html_content = elem.outer_html() if hasattr(elem, 'outer_html') else str(elem)
+        if not html_content: return ''
+
+        html_content = html_content.replace('&quot;', '"').replace('&apos;', "'").replace('&amp;', '&')
+
+        if 'data:image' in html_content:
+            m = re.search(r'(data:image/[a-zA-Z0-9+/=;,]+)', html_content)
+            if m: return self._proc_url(m.group(1))
+
+        m = re.search(r'(https?://[^"\'\s)]+\.(?:jpg|png|jpeg|webp))', html_content, re.I)
+        if m: return self._proc_url(m.group(1))
+            
+        if 'url(' in html_content:
+            m = re.search(r'url\s*\(\s*[\'"]?([^"\'\)]+)[\'"]?\s*\)', html_content, re.I)
+            if m: return self._proc_url(m.group(1))
+            
+        return ''
+
+    def _proc_url(self, url):
+        if not url: return ''
+        url = url.strip('\'" ')
+        if url.startswith('data:'):
+            try:
+                _, b64_str = url.split(',', 1)
+                raw = b64decode(b64_str)
+                if not (raw.startswith(b'\xff\xd8') or raw.startswith(b'\x89PNG') or raw.startswith(b'GIF8')):
+                    raw = self.aesimg(raw)
+                key = hashlib.md5(raw).hexdigest()
+                img_cache[key] = raw
+                return f"{self.getProxyUrl()}&type=cache&key={key}"
+            except: return ""
+        if not url.startswith('http'):
+            url = f"{self.host}{url}" if url.startswith('/') else f"{self.host}/{url}"
+        return f"{self.getProxyUrl()}&url={self.e64(url)}&type=img"
+
+    def getpq(self, data):
+        try: return pq(data)
+        except: return pq(data.encode('utf-8'))
diff --git a/lib/51视频.py b/lib/51视频.py
new file mode 100644
index 0000000..7d37c65
--- /dev/null
+++ b/lib/51视频.py
@@ -0,0 +1,390 @@
+import json
+import re
+import sys
+import hashlib
+from base64 import b64decode, b64encode
+from urllib.parse import urlparse
+
+import requests
+from Crypto.Cipher import AES
+from Crypto.Util.Padding import unpad
+from pyquery import PyQuery as pq
+sys.path.append('..')
+from base.spider import Spider as BaseSpider
+
+img_cache = {}
+
+class Spider(BaseSpider):
+
+    def init(self, extend=""):
+        try:
+            self.proxies = json.loads(extend)
+        except:
+            self.proxies = {}
+        self.headers = {
+            'User-Agent': 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36',
+            'Accept': 'text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,image/apng,*/*;q=0.8',
+            'Accept-Language': 'zh-CN,zh;q=0.9',
+            'Connection': 'keep-alive',
+            'Cache-Control': 'no-cache',
+        }
+        self.host = self.get_working_host()
+        self.headers.update({'Origin': self.host, 'Referer': f"{self.host}/"})
+        print(f"使用站点: {self.host}")
+
+    def getName(self):
+        return "🌈 51视频|终极完美版"
+
+    def isVideoFormat(self, url):
+        return any(ext in (url or '') for ext in ['.m3u8', '.mp4', '.ts'])
+
+    def manualVideoCheck(self):
+        return False
+
+    def destroy(self):
+        global img_cache
+        img_cache.clear()
+
+    def get_working_host(self):
+        dynamic_urls = [
+            'https://able.jbezfkd.cc/',
+            'https://back.jbezfkd.cc/'
+        ]
+        for url in dynamic_urls:
+            try:
+                response = requests.get(url, headers=self.headers, proxies=self.proxies, timeout=10)
+                if response.status_code == 200:
+                    return url
+            except Exception:
+                continue
+        return dynamic_urls[0]
+
+    def homeContent(self, filter):
+        try:
+            response = requests.get(self.host, headers=self.headers, proxies=self.proxies, timeout=15)
+            if response.status_code != 200: return {'class': [], 'list': []}
+            data = self.getpq(response.text)
+            
+            classes = []
+            category_selectors = ['.category-list ul li', '.nav-menu li', '.menu li', 'nav ul li']
+            for selector in category_selectors:
+                for k in data(selector).items():
+                    link = k('a')
+                    href = (link.attr('href') or '').strip()
+                    name = (link.text() or '').strip()
+                    if not href or href == '#' or not name: continue
+                    classes.append({'type_name': name, 'type_id': href})
+                if classes: break
+            
+            if not classes:
+                classes = [{'type_name': '最新', 'type_id': '/latest/'}, {'type_name': '热门', 'type_id': '/hot/'}]
+            
+            return {'class': classes, 'list': self.getlist(data('#index article, article'))}
+        except Exception as e:
+            return {'class': [], 'list': []}
+
+    def homeVideoContent(self):
+        try:
+            response = requests.get(self.host, headers=self.headers, proxies=self.proxies, timeout=15)
+            if response.status_code != 200: return {'list': []}
+            data = self.getpq(response.text)
+            return {'list': self.getlist(data('#index article, article'))}
+        except Exception as e:
+            return {'list': []}
+
+    def categoryContent(self, tid, pg, filter, extend):
+        try:
+            if '@folder' in tid:
+                v = self.getfod(tid.replace('@folder', ''))
+                return {'list': v, 'page': 1, 'pagecount': 1, 'limit': 90, 'total': len(v)}
+            
+            pg = int(pg) if pg else 1
+            
+            if tid.startswith('http'):
+                base_url = tid.rstrip('/')
+            else:
+                path = tid if tid.startswith('/') else f"/{tid}"
+                base_url = f"{self.host}{path}".rstrip('/')
+            
+            if pg == 1:
+                url = f"{base_url}/"
+            else:
+                url = f"{base_url}/{pg}/"
+                
+            response = requests.get(url, headers=self.headers, proxies=self.proxies, timeout=15)
+            if response.status_code != 200: return {'list': [], 'page': pg, 'pagecount': 9999, 'limit': 90, 'total': 0}
+                
+            data = self.getpq(response.text)
+            videos = self.getlist(data('#archive article, #index article, article'), tid)
+            
+            return {'list': videos, 'page': pg, 'pagecount': 9999, 'limit': 90, 'total': 999999}
+        except Exception as e:
+            return {'list': [], 'page': pg, 'pagecount': 9999, 'limit': 90, 'total': 0}
+
+    def detailContent(self, ids):
+        try:
+            url = ids[0] if ids[0].startswith('http') else f"{self.host}{ids[0]}"
+            response = requests.get(url, headers=self.headers, proxies=self.proxies, timeout=15)
+            data = self.getpq(response.text)
+            
+            plist = []
+            used_names = set()
+            if data('.dplayer'):
+                for c, k in enumerate(data('.dplayer').items(), start=1):
+                    try:
+                        config_attr = k.attr('data-config')
+                        if config_attr:
+                            config = json.loads(config_attr)
+                            video_url = config.get('video', {}).get('url', '')
+                            
+                            if video_url:
+                                ep_name = ''
+                                parent = k.parents().eq(0)
+                                for _ in range(4):
+                                    if not parent: break
+                                    heading = parent.find('h2, h3, h4').eq(0).text().strip()
+                                    if heading:
+                                        ep_name = heading
+                                        break
+                                    parent = parent.parents().eq(0)
+                                
+                                base_name = ep_name if ep_name else f"视频{c}"
+                                name = base_name
+                                count = 2
+                                while name in used_names:
+                                    name = f"{base_name} {count}"
+                                    count += 1
+                                used_names.add(name)
+                                
+                                plist.append(f"{name}${video_url}")
+                    except: continue
+            
+            if not plist:
+                content_area = data('.post-content, article')
+                for i, link in enumerate(content_area('a').items(), start=1):
+                    link_text = link.text().strip()
+                    link_href = link.attr('href')
+                    
+                    if link_href and any(kw in link_text for kw in ['点击观看', '观看', '播放', '视频', '第一弹', '第二弹', '第三弹', '第四弹', '第五弹', '第六弹', '第七弹', '第八弹', '第九弹', '第十弹']):
+                        ep_name = link_text.replace('点击观看：', '').replace('点击观看', '').strip()
+                        if not ep_name: ep_name = f"视频{i}"
+                        
+                        if not link_href.startswith('http'):
+                            link_href = f"{self.host}{link_href}" if link_href.startswith('/') else f"{self.host}/{link_href}"
+                        
+                        plist.append(f"{ep_name}${link_href}")
+            
+            play_url = '#'.join(plist) if plist else f"未找到视频源${url}"
+            
+            vod_content = ''
+            try:
+                tags = []
+                seen_names = set()
+                seen_ids = set()
+                
+                tag_links = data('.tags a, .keywords a, .post-tags a')
+                
+                candidates = []
+                for k in tag_links.items():
+                    title = k.text().strip()
+                    href = k.attr('href')
+                    if title and href:
+                        candidates.append({'name': title, 'id': href})
+                
+                candidates.sort(key=lambda x: len(x['name']), reverse=True)
+                
+                for item in candidates:
+                    name = item['name']
+                    id_ = item['id']
+                    
+                    if id_ in seen_ids: continue
+                    
+                    is_duplicate = False
+                    for seen in seen_names:
+                        if name in seen:
+                            is_duplicate = True
+                            break
+                    
+                    if not is_duplicate:
+                        target = json.dumps({'id': id_, 'name': name})
+                        tags.append(f'[a=cr:{target}/]{name}[/a]')
+                        seen_names.add(name)
+                        seen_ids.add(id_)
+                
+                if tags:
+                    vod_content = ' '.join(tags)
+                else:
+                    vod_content = data('.post-title').text()
+            except Exception:
+                vod_content = '获取标签失败'
+
+            if not vod_content:
+                vod_content = data('h1').text() or '51视频'
+
+            return {'list': [{'vod_play_from': '51视频', 'vod_play_url': play_url, 'vod_content': vod_content}]}
+        except:
+            return {'list': [{'vod_play_from': '51视频', 'vod_play_url': '获取失败'}]}
+
+    def searchContent(self, key, quick, pg="1"):
+        try:
+            pg = int(pg) if pg else 1
+            
+            if pg == 1:
+                url = f"{self.host}/search/{key}/"
+            else:
+                url = f"{self.host}/search/{key}/{pg}/"
+            
+            response = requests.get(url, headers=self.headers, proxies=self.proxies, timeout=15)
+            return {'list': self.getlist(self.getpq(response.text)('article')), 'page': pg, 'pagecount': 9999}
+        except:
+            return {'list': [], 'page': pg, 'pagecount': 9999}
+
+    def playerContent(self, flag, id, vipFlags):
+        parse = 0 if self.isVideoFormat(id) else 1
+        url = self.proxy(id) if '.m3u8' in id else id
+        return {'parse': parse, 'url': url, 'header': self.headers}
+
+    def localProxy(self, param):
+        try:
+            type_ = param.get('type')
+            url = param.get('url')
+            if type_ == 'cache':
+                key = param.get('key')
+                if content := img_cache.get(key):
+                    return [200, 'image/jpeg', content]
+                return [404, 'text/plain', b'Expired']
+            elif type_ == 'img':
+                real_url = self.d64(url) if not url.startswith('http') else url
+                res = requests.get(real_url, headers=self.headers, proxies=self.proxies, timeout=10)
+                content = self.aesimg(res.content)
+                return [200, 'image/jpeg', content]
+            elif type_ == 'm3u8':
+                return self.m3Proxy(url)
+            else:
+                return self.tsProxy(url)
+        except:
+            return [404, 'text/plain', b'']
+
+    def proxy(self, data, type='m3u8'):
+        if data and self.proxies: return f"{self.getProxyUrl()}&url={self.e64(data)}&type={type}"
+        return data
+
+    def m3Proxy(self, url):
+        url = self.d64(url)
+        res = requests.get(url, headers=self.headers, proxies=self.proxies)
+        data = res.text
+        base = res.url.rsplit('/', 1)[0]
+        lines = []
+        for line in data.split('\n'):
+            if '#EXT' not in line and line.strip():
+                if not line.startswith('http'):
+                    line = f"{base}/{line}"
+                lines.append(self.proxy(line, 'ts'))
+            else:
+                lines.append(line)
+        return [200, "application/vnd.apple.mpegurl", '\n'.join(lines)]
+
+    def tsProxy(self, url):
+        return [200, 'video/mp2t', requests.get(self.d64(url), headers=self.headers, proxies=self.proxies).content]
+
+    def e64(self, text):
+        return b64encode(str(text).encode()).decode()
+
+    def d64(self, text):
+        return b64decode(str(text).encode()).decode()
+
+    def aesimg(self, data):
+        if len(data) < 16: return data
+        keys = [(b'f5d965df75336270', b'97b60394abc2fbe1'), (b'75336270f5d965df', b'abc2fbe197b60394')]
+        for k, v in keys:
+            try:
+                dec = unpad(AES.new(k, AES.MODE_CBC, v).decrypt(data), 16)
+                if dec.startswith(b'\xff\xd8') or dec.startswith(b'\x89PNG'): return dec
+            except: pass
+            try:
+                dec = unpad(AES.new(k, AES.MODE_ECB).decrypt(data), 16)
+                if dec.startswith(b'\xff\xd8'): return dec
+            except: pass
+        return data
+
+    def getlist(self, data, tid=''):
+        videos = []
+        is_folder = '/mrdg' in (tid or '')
+        for k in data.items():
+            card_html = k.outer_html() if hasattr(k, 'outer_html') else str(k)
+            a = k if k.is_('a') else k('a').eq(0)
+            href = a.attr('href')
+            title = k('h2').text() or k('.entry-title').text() or k('.post-title').text()
+            if not title and k.is_('a'): title = k.text()
+            
+            if href and title:
+                img = self.getimg(k('script').text(), k, card_html)
+                videos.append({
+                    'vod_id': f"{href}{'@folder' if is_folder else ''}",
+                    'vod_name': title.strip(),
+                    'vod_pic': img,
+                    'vod_remarks': k('time').text() or '',
+                    'vod_tag': 'folder' if is_folder else '',
+                    'style': {"type": "rect", "ratio": 1.33}
+                })
+        return videos
+
+    def getfod(self, id):
+        url = f"{self.host}{id}"
+        data = self.getpq(requests.get(url, headers=self.headers, proxies=self.proxies).text)
+        videos = []
+        for i, h2 in enumerate(data('.post-content h2').items()):
+            p_txt = data('.post-content p').eq(i * 2)
+            p_img = data('.post-content p').eq(i * 2 + 1)
+            p_html = p_img.outer_html() if hasattr(p_img, 'outer_html') else str(p_img)
+            videos.append({
+                'vod_id': p_txt('a').attr('href'),
+                'vod_name': p_txt.text().strip(),
+                'vod_pic': self.getimg('', p_img, p_html),
+                'vod_remarks': h2.text().strip()
+            })
+        return videos
+
+    def getimg(self, text, elem=None, html_content=None):
+        if m := re.search(r"loadBannerDirect\('([^']+)'", text or ''):
+            return self._proc_url(m.group(1))
+        
+        if html_content is None and elem is not None:
+             html_content = elem.outer_html() if hasattr(elem, 'outer_html') else str(elem)
+        if not html_content: return ''
+
+        html_content = html_content.replace('&quot;', '"').replace('&apos;', "'").replace('&amp;', '&')
+
+        if 'data:image' in html_content:
+            m = re.search(r'(data:image/[a-zA-Z0-9+/=;,]+)', html_content)
+            if m: return self._proc_url(m.group(1))
+
+        m = re.search(r'(https?://[^"\'\s)]+\.(?:jpg|png|jpeg|webp))', html_content, re.I)
+        if m: return self._proc_url(m.group(1))
+            
+        if 'url(' in html_content:
+            m = re.search(r'url\s*\(\s*[\'"]?([^"\'\)]+)[\'"]?\s*\)', html_content, re.I)
+            if m: return self._proc_url(m.group(1))
+            
+        return ''
+
+    def _proc_url(self, url):
+        if not url: return ''
+        url = url.strip('\'" ')
+        if url.startswith('data:'):
+            try:
+                _, b64_str = url.split(',', 1)
+                raw = b64decode(b64_str)
+                if not (raw.startswith(b'\xff\xd8') or raw.startswith(b'\x89PNG') or raw.startswith(b'GIF8')):
+                    raw = self.aesimg(raw)
+                key = hashlib.md5(raw).hexdigest()
+                img_cache[key] = raw
+                return f"{self.getProxyUrl()}&type=cache&key={key}"
+            except: return ""
+        if not url.startswith('http'):
+            url = f"{self.host}{url}" if url.startswith('/') else f"{self.host}/{url}"
+        return f"{self.getProxyUrl()}&url={self.e64(url)}&type=img"
+
+    def getpq(self, data):
+        try: return pq(data)
+        except: return pq(data.encode('utf-8'))
diff --git a/lib/51黑料网.py b/lib/51黑料网.py
new file mode 100644
index 0000000..90e696a
--- /dev/null
+++ b/lib/51黑料网.py
@@ -0,0 +1,389 @@
+import json
+import re
+import sys
+import hashlib
+from base64 import b64decode, b64encode
+from urllib.parse import urlparse
+
+import requests
+from Crypto.Cipher import AES
+from Crypto.Util.Padding import unpad
+from pyquery import PyQuery as pq
+sys.path.append('..')
+from base.spider import Spider as BaseSpider
+
+img_cache = {}
+
+class Spider(BaseSpider):
+
+    def init(self, extend=""):
+        try:
+            self.proxies = json.loads(extend)
+        except:
+            self.proxies = {}
+        self.headers = {
+            'User-Agent': 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36',
+            'Accept': 'text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,image/apng,*/*;q=0.8',
+            'Accept-Language': 'zh-CN,zh;q=0.9',
+            'Connection': 'keep-alive',
+            'Cache-Control': 'no-cache',
+        }
+        self.host = self.get_working_host()
+        self.headers.update({'Origin': self.host, 'Referer': f"{self.host}/"})
+        print(f"使用站点: {self.host}")
+
+    def getName(self):
+        return "🌈 51黑料网|终极完美版"
+
+    def isVideoFormat(self, url):
+        return any(ext in (url or '') for ext in ['.m3u8', '.mp4', '.ts'])
+
+    def manualVideoCheck(self):
+        return False
+
+    def destroy(self):
+        global img_cache
+        img_cache.clear()
+
+    def get_working_host(self):
+        dynamic_urls = [
+            'https://a.wdbvcy.cc'
+        ]
+        for url in dynamic_urls:
+            try:
+                response = requests.get(url, headers=self.headers, proxies=self.proxies, timeout=10)
+                if response.status_code == 200:
+                    return url
+            except Exception:
+                continue
+        return dynamic_urls[0]
+
+    def homeContent(self, filter):
+        try:
+            response = requests.get(self.host, headers=self.headers, proxies=self.proxies, timeout=15)
+            if response.status_code != 200: return {'class': [], 'list': []}
+            data = self.getpq(response.text)
+            
+            classes = []
+            category_selectors = ['.category-list ul li', '.nav-menu li', '.menu li', 'nav ul li']
+            for selector in category_selectors:
+                for k in data(selector).items():
+                    link = k('a')
+                    href = (link.attr('href') or '').strip()
+                    name = (link.text() or '').strip()
+                    if not href or href == '#' or not name: continue
+                    classes.append({'type_name': name, 'type_id': href})
+                if classes: break
+            
+            if not classes:
+                classes = [{'type_name': '最新', 'type_id': '/latest/'}, {'type_name': '热门', 'type_id': '/hot/'}]
+            
+            return {'class': classes, 'list': self.getlist(data('#index article, article'))}
+        except Exception as e:
+            return {'class': [], 'list': []}
+
+    def homeVideoContent(self):
+        try:
+            response = requests.get(self.host, headers=self.headers, proxies=self.proxies, timeout=15)
+            if response.status_code != 200: return {'list': []}
+            data = self.getpq(response.text)
+            return {'list': self.getlist(data('#index article, article'))}
+        except Exception as e:
+            return {'list': []}
+
+    def categoryContent(self, tid, pg, filter, extend):
+        try:
+            if '@folder' in tid:
+                v = self.getfod(tid.replace('@folder', ''))
+                return {'list': v, 'page': 1, 'pagecount': 1, 'limit': 90, 'total': len(v)}
+            
+            pg = int(pg) if pg else 1
+            
+            if tid.startswith('http'):
+                base_url = tid.rstrip('/')
+            else:
+                path = tid if tid.startswith('/') else f"/{tid}"
+                base_url = f"{self.host}{path}".rstrip('/')
+            
+            if pg == 1:
+                url = f"{base_url}/"
+            else:
+                url = f"{base_url}/{pg}/"
+                
+            response = requests.get(url, headers=self.headers, proxies=self.proxies, timeout=15)
+            if response.status_code != 200: return {'list': [], 'page': pg, 'pagecount': 9999, 'limit': 90, 'total': 0}
+                
+            data = self.getpq(response.text)
+            videos = self.getlist(data('#archive article, #index article, article'), tid)
+            
+            return {'list': videos, 'page': pg, 'pagecount': 9999, 'limit': 90, 'total': 999999}
+        except Exception as e:
+            return {'list': [], 'page': pg, 'pagecount': 9999, 'limit': 90, 'total': 0}
+
+    def detailContent(self, ids):
+        try:
+            url = ids[0] if ids[0].startswith('http') else f"{self.host}{ids[0]}"
+            response = requests.get(url, headers=self.headers, proxies=self.proxies, timeout=15)
+            data = self.getpq(response.text)
+            
+            plist = []
+            used_names = set()
+            if data('.dplayer'):
+                for c, k in enumerate(data('.dplayer').items(), start=1):
+                    try:
+                        config_attr = k.attr('data-config')
+                        if config_attr:
+                            config = json.loads(config_attr)
+                            video_url = config.get('video', {}).get('url', '')
+                            
+                            if video_url:
+                                ep_name = ''
+                                parent = k.parents().eq(0)
+                                for _ in range(4):
+                                    if not parent: break
+                                    heading = parent.find('h2, h3, h4').eq(0).text().strip()
+                                    if heading:
+                                        ep_name = heading
+                                        break
+                                    parent = parent.parents().eq(0)
+                                
+                                base_name = ep_name if ep_name else f"视频{c}"
+                                name = base_name
+                                count = 2
+                                while name in used_names:
+                                    name = f"{base_name} {count}"
+                                    count += 1
+                                used_names.add(name)
+                                
+                                plist.append(f"{name}${video_url}")
+                    except: continue
+            
+            if not plist:
+                content_area = data('.post-content, article')
+                for i, link in enumerate(content_area('a').items(), start=1):
+                    link_text = link.text().strip()
+                    link_href = link.attr('href')
+                    
+                    if link_href and any(kw in link_text for kw in ['点击观看', '观看', '播放', '视频', '第一弹', '第二弹', '第三弹', '第四弹', '第五弹', '第六弹', '第七弹', '第八弹', '第九弹', '第十弹']):
+                        ep_name = link_text.replace('点击观看：', '').replace('点击观看', '').strip()
+                        if not ep_name: ep_name = f"视频{i}"
+                        
+                        if not link_href.startswith('http'):
+                            link_href = f"{self.host}{link_href}" if link_href.startswith('/') else f"{self.host}/{link_href}"
+                        
+                        plist.append(f"{ep_name}${link_href}")
+            
+            play_url = '#'.join(plist) if plist else f"未找到视频源${url}"
+            
+            vod_content = ''
+            try:
+                tags = []
+                seen_names = set()
+                seen_ids = set()
+                
+                tag_links = data('.tags a, .keywords a, .post-tags a')
+                
+                candidates = []
+                for k in tag_links.items():
+                    title = k.text().strip()
+                    href = k.attr('href')
+                    if title and href:
+                        candidates.append({'name': title, 'id': href})
+                
+                candidates.sort(key=lambda x: len(x['name']), reverse=True)
+                
+                for item in candidates:
+                    name = item['name']
+                    id_ = item['id']
+                    
+                    if id_ in seen_ids: continue
+                    
+                    is_duplicate = False
+                    for seen in seen_names:
+                        if name in seen:
+                            is_duplicate = True
+                            break
+                    
+                    if not is_duplicate:
+                        target = json.dumps({'id': id_, 'name': name})
+                        tags.append(f'[a=cr:{target}/]{name}[/a]')
+                        seen_names.add(name)
+                        seen_ids.add(id_)
+                
+                if tags:
+                    vod_content = ' '.join(tags)
+                else:
+                    vod_content = data('.post-title').text()
+            except Exception:
+                vod_content = '获取标签失败'
+
+            if not vod_content:
+                vod_content = data('h1').text() or '爱优腾'
+
+            return {'list': [{'vod_play_from': '91吃瓜中心', 'vod_play_url': play_url, 'vod_content': vod_content}]}
+        except:
+            return {'list': [{'vod_play_from': '91吃瓜中心', 'vod_play_url': '获取失败'}]}
+
+    def searchContent(self, key, quick, pg="1"):
+        try:
+            pg = int(pg) if pg else 1
+            
+            if pg == 1:
+                url = f"{self.host}/search/{key}/"
+            else:
+                url = f"{self.host}/search/{key}/{pg}/"
+            
+            response = requests.get(url, headers=self.headers, proxies=self.proxies, timeout=15)
+            return {'list': self.getlist(self.getpq(response.text)('article')), 'page': pg, 'pagecount': 9999}
+        except:
+            return {'list': [], 'page': pg, 'pagecount': 9999}
+
+    def playerContent(self, flag, id, vipFlags):
+        parse = 0 if self.isVideoFormat(id) else 1
+        url = self.proxy(id) if '.m3u8' in id else id
+        return {'parse': parse, 'url': url, 'header': self.headers}
+
+    def localProxy(self, param):
+        try:
+            type_ = param.get('type')
+            url = param.get('url')
+            if type_ == 'cache':
+                key = param.get('key')
+                if content := img_cache.get(key):
+                    return [200, 'image/jpeg', content]
+                return [404, 'text/plain', b'Expired']
+            elif type_ == 'img':
+                real_url = self.d64(url) if not url.startswith('http') else url
+                res = requests.get(real_url, headers=self.headers, proxies=self.proxies, timeout=10)
+                content = self.aesimg(res.content)
+                return [200, 'image/jpeg', content]
+            elif type_ == 'm3u8':
+                return self.m3Proxy(url)
+            else:
+                return self.tsProxy(url)
+        except:
+            return [404, 'text/plain', b'']
+
+    def proxy(self, data, type='m3u8'):
+        if data and self.proxies: return f"{self.getProxyUrl()}&url={self.e64(data)}&type={type}"
+        return data
+
+    def m3Proxy(self, url):
+        url = self.d64(url)
+        res = requests.get(url, headers=self.headers, proxies=self.proxies)
+        data = res.text
+        base = res.url.rsplit('/', 1)[0]
+        lines = []
+        for line in data.split('\n'):
+            if '#EXT' not in line and line.strip():
+                if not line.startswith('http'):
+                    line = f"{base}/{line}"
+                lines.append(self.proxy(line, 'ts'))
+            else:
+                lines.append(line)
+        return [200, "application/vnd.apple.mpegurl", '\n'.join(lines)]
+
+    def tsProxy(self, url):
+        return [200, 'video/mp2t', requests.get(self.d64(url), headers=self.headers, proxies=self.proxies).content]
+
+    def e64(self, text):
+        return b64encode(str(text).encode()).decode()
+
+    def d64(self, text):
+        return b64decode(str(text).encode()).decode()
+
+    def aesimg(self, data):
+        if len(data) < 16: return data
+        keys = [(b'f5d965df75336270', b'97b60394abc2fbe1'), (b'75336270f5d965df', b'abc2fbe197b60394')]
+        for k, v in keys:
+            try:
+                dec = unpad(AES.new(k, AES.MODE_CBC, v).decrypt(data), 16)
+                if dec.startswith(b'\xff\xd8') or dec.startswith(b'\x89PNG'): return dec
+            except: pass
+            try:
+                dec = unpad(AES.new(k, AES.MODE_ECB).decrypt(data), 16)
+                if dec.startswith(b'\xff\xd8'): return dec
+            except: pass
+        return data
+
+    def getlist(self, data, tid=''):
+        videos = []
+        is_folder = '/mrdg' in (tid or '')
+        for k in data.items():
+            card_html = k.outer_html() if hasattr(k, 'outer_html') else str(k)
+            a = k if k.is_('a') else k('a').eq(0)
+            href = a.attr('href')
+            title = k('h2').text() or k('.entry-title').text() or k('.post-title').text()
+            if not title and k.is_('a'): title = k.text()
+            
+            if href and title:
+                img = self.getimg(k('script').text(), k, card_html)
+                videos.append({
+                    'vod_id': f"{href}{'@folder' if is_folder else ''}",
+                    'vod_name': title.strip(),
+                    'vod_pic': img,
+                    'vod_remarks': k('time').text() or '',
+                    'vod_tag': 'folder' if is_folder else '',
+                    'style': {"type": "rect", "ratio": 1.33}
+                })
+        return videos
+
+    def getfod(self, id):
+        url = f"{self.host}{id}"
+        data = self.getpq(requests.get(url, headers=self.headers, proxies=self.proxies).text)
+        videos = []
+        for i, h2 in enumerate(data('.post-content h2').items()):
+            p_txt = data('.post-content p').eq(i * 2)
+            p_img = data('.post-content p').eq(i * 2 + 1)
+            p_html = p_img.outer_html() if hasattr(p_img, 'outer_html') else str(p_img)
+            videos.append({
+                'vod_id': p_txt('a').attr('href'),
+                'vod_name': p_txt.text().strip(),
+                'vod_pic': self.getimg('', p_img, p_html),
+                'vod_remarks': h2.text().strip()
+            })
+        return videos
+
+    def getimg(self, text, elem=None, html_content=None):
+        if m := re.search(r"loadBannerDirect\('([^']+)'", text or ''):
+            return self._proc_url(m.group(1))
+        
+        if html_content is None and elem is not None:
+             html_content = elem.outer_html() if hasattr(elem, 'outer_html') else str(elem)
+        if not html_content: return ''
+
+        html_content = html_content.replace('&quot;', '"').replace('&apos;', "'").replace('&amp;', '&')
+
+        if 'data:image' in html_content:
+            m = re.search(r'(data:image/[a-zA-Z0-9+/=;,]+)', html_content)
+            if m: return self._proc_url(m.group(1))
+
+        m = re.search(r'(https?://[^"\'\s)]+\.(?:jpg|png|jpeg|webp))', html_content, re.I)
+        if m: return self._proc_url(m.group(1))
+            
+        if 'url(' in html_content:
+            m = re.search(r'url\s*\(\s*[\'"]?([^"\'\)]+)[\'"]?\s*\)', html_content, re.I)
+            if m: return self._proc_url(m.group(1))
+            
+        return ''
+
+    def _proc_url(self, url):
+        if not url: return ''
+        url = url.strip('\'" ')
+        if url.startswith('data:'):
+            try:
+                _, b64_str = url.split(',', 1)
+                raw = b64decode(b64_str)
+                if not (raw.startswith(b'\xff\xd8') or raw.startswith(b'\x89PNG') or raw.startswith(b'GIF8')):
+                    raw = self.aesimg(raw)
+                key = hashlib.md5(raw).hexdigest()
+                img_cache[key] = raw
+                return f"{self.getProxyUrl()}&type=cache&key={key}"
+            except: return ""
+        if not url.startswith('http'):
+            url = f"{self.host}{url}" if url.startswith('/') else f"{self.host}/{url}"
+        return f"{self.getProxyUrl()}&url={self.e64(url)}&type=img"
+
+    def getpq(self, data):
+        try: return pq(data)
+        except: return pq(data.encode('utf-8'))