From 5baa1f5c7fe11346f37275715e0b5e3c045aa587 Mon Sep 17 00:00:00 2001
From: XC-Pro <19840+xc-pro@noreply.example.org>
Date: Fri, 14 Aug 2026 11:25:26 +0200
Subject: [PATCH] =?UTF-8?q?=E4=B8=8A=E4=BC=A0=E6=96=87=E4=BB=B6=E8=87=B3?=
 =?UTF-8?q?=E3=80=8Cpy=E3=80=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 py/企鹅.py     | 519 +++++++++++++++++++++++++++++++++++++++++++++++++
 py/农民影视.py | 278 ++++++++++++++++++++++++++
 py/奈飞.py     | 373 +++++++++++++++++++++++++++++++++++
 py/漫闪.jar    | Bin 0 -> 14822 bytes
 py/热播.py     | 184 ++++++++++++++++++
 5 files changed, 1354 insertions(+)
 create mode 100644 py/企鹅.py
 create mode 100644 py/农民影视.py
 create mode 100644 py/奈飞.py
 create mode 100644 py/漫闪.jar
 create mode 100644 py/热播.py

diff --git a/py/企鹅.py b/py/企鹅.py
new file mode 100644
index 0000000..c7b0d42
--- /dev/null
+++ b/py/企鹅.py
@@ -0,0 +1,519 @@
+# coding=utf-8
+#!/usr/bin/python
+# 精彩
+import json
+import sys
+import uuid
+import copy
+import traceback
+sys.path.append('..')
+from base.spider import Spider
+from pyquery import PyQuery as pq
+from concurrent.futures import ThreadPoolExecutor, as_completed
+
+
+class Spider(Spider):
+
+    def init(self, extend=""):
+        self.dbody = {
+            "page_params": {
+                "channel_id": "",
+                "filter_params": "sort=75",
+                "page_type": "channel_operation",
+                "page_id": "channel_list_second_page"
+            }
+        }
+        self.body = self.dbody
+        pass
+
+    def getName(self):
+        return "腾讯视频"
+
+    def isVideoFormat(self, url):
+        pass
+
+    def manualVideoCheck(self):
+        pass
+
+    def destroy(self):
+        pass
+
+    host = 'https://v.qq.com'
+    apihost = 'https://pbaccess.video.qq.com'
+
+    headers = {
+        'User-Agent': 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/109.0.5410.0 Safari/537.36',
+        'origin': host,
+        'referer': f'{host}/'
+    }
+
+    def homeContent(self, filter):
+        cdata = {
+            "电视剧": "100113",
+            "电影": "100173",
+            "综艺": "100109",
+            "纪录片": "100105",
+            "动漫": "100119",
+            "少儿": "100150",
+            "短剧": "110755"
+        }
+        result = {}
+        classes = []
+        filters = {}
+        for k in cdata:
+            classes.append({
+                'type_name': k,
+                'type_id': cdata[k]
+            })
+        
+        # 修复：添加异常处理
+        with ThreadPoolExecutor(max_workers=len(classes)) as executor:
+            futures = {executor.submit(self.get_filter_data, item['type_id']): item['type_id'] for item in classes}
+            for future in as_completed(futures):
+                cid = futures[future]
+                try:
+                    _, data = future.result()
+                    if not data.get('data', {}).get('module_list_datas'):
+                        continue
+                    filter_dict = {}
+                    try:
+                        # 安全获取嵌套数据
+                        module_list = data['data']['module_list_datas']
+                        if not module_list:
+                            continue
+                        last_module = module_list[-1]
+                        if not last_module.get('module_datas'):
+                            continue
+                        module_datas = last_module['module_datas']
+                        if not module_datas:
+                            continue
+                        item_lists = module_datas[-1].get('item_data_lists', {}).get('item_datas', [])
+                        
+                        for item in item_lists:
+                            if not item.get('item_params', {}).get('index_item_key'):
+                                continue
+                            params = item['item_params']
+                            filter_key = params['index_item_key']
+                            if filter_key not in filter_dict:
+                                filter_dict[filter_key] = {
+                                    'key': filter_key,
+                                    'name': params.get('index_name', ''),
+                                    'value': []
+                                }
+                            filter_dict[filter_key]['value'].append({
+                                'n': params.get('option_name', ''),
+                                'v': params.get('option_value', '')
+                            })
+                    except (IndexError, KeyError, TypeError) as e:
+                        print(f"处理分类 {cid} 筛选数据时出错: {str(e)}")
+                        continue
+                    filters[cid] = list(filter_dict.values())
+                except Exception as e:
+                    print(f"获取分类 {cid} 筛选失败: {str(e)}")
+                    continue
+                    
+        result['class'] = classes
+        result['filters'] = filters
+        return result
+
+    def homeVideoContent(self):
+        vlist = []
+        try:
+            data = self.gethtml(self.host)
+            its = data('script')
+            s = None
+            for it in its.items():
+                text = it.text()
+                if text and 'window.__INITIAL_STATE__' in text:
+                    s = text
+                    break
+            if s:
+                index = s.find('=')
+                if index != -1:
+                    json_str = s[index + 1:].strip()
+                    try:
+                        sd = json.loads(json_str)
+                    except json.JSONDecodeError as e:
+                        print(f"JSON解析错误: {str(e)}")
+                        return {'list': []}
+                        
+                    channels_map = sd.get('storeModulesData', {}).get('channelsModulesMap', {})
+                    choice_data = channels_map.get('choice', {})
+                    if choice_data and choice_data.get('cardListData'):
+                        for its in choice_data['cardListData']:
+                            if its and its.get('children_list', {}).get('list', {}).get('cards'):
+                                for it in its['children_list']['list']['cards']:
+                                    if it and it.get('params'):
+                                        p = it['params']
+                                        # 安全解析JSON标签
+                                        tag = {}
+                                        try:
+                                            tag_str = p.get('uni_imgtag') or p.get('imgtag', '{}')
+                                            if tag_str:
+                                                tag = json.loads(tag_str)
+                                        except (json.JSONDecodeError, TypeError):
+                                            tag = {}
+                                            
+                                        id = it.get('id') or p.get('cid')
+                                        name = p.get('mz_title') or p.get('title')
+                                        if name and id and 'http' not in str(id):
+                                            vlist.append({
+                                                'vod_id': id,
+                                                'vod_name': name,
+                                                'vod_pic': p.get('image_url'),
+                                                'vod_year': tag.get('tag_2', {}).get('text', ''),
+                                                'vod_remarks': tag.get('tag_4', {}).get('text', '')
+                                            })
+        except Exception as e:
+            print(f"首页内容获取失败: {str(e)}")
+            traceback.print_exc()
+            
+        return {'list': vlist}
+
+    def categoryContent(self, tid, pg, filter, extend):
+        result = {}
+        params = {
+            "sort": extend.get('sort', '75'),
+            "attr": extend.get('attr', '-1'),
+            "itype": extend.get('itype', '-1'),
+            "ipay": extend.get('ipay', '-1'),
+            "iarea": extend.get('iarea', '-1'),
+            "iyear": extend.get('iyear', '-1'),
+            "theater": extend.get('theater', '-1'),
+            "award": extend.get('award', '-1'),
+            "recommend": extend.get('recommend', '-1')
+        }
+        if pg == '1':
+            self.body = self.dbody.copy()
+        self.body['page_params']['channel_id'] = tid
+        self.body['page_params']['filter_params'] = self.josn_to_params(params)
+        
+        try:
+            response = self.post(
+                f'{self.apihost}/trpc.universal_backend_service.page_server_rpc.PageServer/GetPageData?video_appid=1000005&vplatform=2&vversion_name=8.9.10&new_mark_label_enabled=1',
+                json=self.body, headers=self.headers)
+            data = response.json()
+        except Exception as e:
+            print(f"分类请求失败: {str(e)}")
+            return {'list': [], 'page': pg, 'pagecount': 0, 'limit': 90, 'total': 0}
+            
+        ndata = data.get('data', {})
+        if not ndata:
+            return {'list': [], 'page': pg, 'pagecount': 0, 'limit': 90, 'total': 0}
+            
+        if ndata.get('has_next_page'):
+            result['pagecount'] = 9999
+            self.body['page_context'] = ndata.get('next_page_context', '')
+        else:
+            result['pagecount'] = int(pg)
+            
+        vlist = []
+        try:
+            # 安全获取列表数据
+            module_list = ndata.get('module_list_datas', [])
+            if module_list and module_list[-1].get('module_datas'):
+                item_datas = module_list[-1]['module_datas'][-1].get('item_data_lists', {}).get('item_datas', [])
+                for its in item_datas:
+                    id = its.get('item_params', {}).get('cid')
+                    if id:
+                        p = its['item_params']
+                        tag = {}
+                        try:
+                            tag_str = p.get('uni_imgtag') or p.get('imgtag', '{}')
+                            if tag_str:
+                                tag = json.loads(tag_str)
+                        except (json.JSONDecodeError, TypeError):
+                            tag = {}
+                            
+                        name = p.get('mz_title') or p.get('title')
+                        pic = p.get('new_pic_hz') or p.get('new_pic_vt')
+                        vlist.append({
+                            'vod_id': id,
+                            'vod_name': name,
+                            'vod_pic': pic,
+                            'vod_year': tag.get('tag_2', {}).get('text', ''),
+                            'vod_remarks': tag.get('tag_4', {}).get('text', '')
+                        })
+        except (IndexError, KeyError, TypeError) as e:
+            print(f"解析分类数据失败: {str(e)}")
+            
+        result['list'] = vlist
+        result['page'] = pg
+        result['limit'] = 90
+        result['total'] = 999999
+        return result
+
+    def detailContent(self, ids):
+        if not ids:
+            return self.handle_exception(None, "Empty ids")
+            
+        vbody = {
+            "page_params": {
+                "req_from": "web",
+                "cid": ids[0],
+                "vid": "",
+                "lid": "",
+                "page_type": "detail_operation",
+                "page_id": "detail_page_introduction"
+            },
+            "has_cache": 1
+        }
+
+        body = {
+            "page_params": {
+                "req_from": "web_vsite",
+                "page_id": "vsite_episode_list",
+                "page_type": "detail_operation",
+                "id_type": "1",
+                "page_size": "",
+                "cid": ids[0],
+                "vid": "",
+                "lid": "",
+                "page_num": "",
+                "page_context": "",
+                "detail_page_type": "1"
+            },
+            "has_cache": 1
+        }
+
+        vdata = {}
+        data = {}
+        
+        # 修复：添加异常处理
+        with ThreadPoolExecutor(max_workers=2) as executor:
+            future_detail = executor.submit(self.get_vdata, vbody)
+            future_episodes = executor.submit(self.get_vdata, body)
+            
+            try:
+                vdata = future_detail.result()
+            except Exception as e:
+                print(f"获取详情失败: {str(e)}")
+                
+            try:
+                data = future_episodes.result()
+            except Exception as e:
+                print(f"获取剧集失败: {str(e)}")
+
+        pdata = self.process_tabs(data, body, ids)
+        if not pdata:
+            return self.handle_exception(None, "No pdata available")
+
+        try:
+            # 安全获取演员列表
+            actors = []
+            try:
+                star_list = vdata.get('data', {}).get('module_list_datas', [{}])[0].get('module_datas', [{}])[0].get('item_data_lists', {}).get('item_datas', [{}])[0].get('sub_items', {}).get('star_list', {}).get('item_datas', [])
+                actors = [star.get('item_params', {}).get('name', '') for star in star_list if star.get('item_params', {}).get('name')]
+            except (IndexError, KeyError, AttributeError):
+                pass
+                
+            names = ['腾讯视频', '预告片']
+            plist, ylist = self.process_pdata(pdata, ids)
+            if not plist:
+                names = [n for n in names if n != '腾讯视频']
+            if not ylist:
+                names = [n for n in names if n != '预告片']
+                
+            vod = self.build_vod(vdata, actors, plist, ylist, names)
+            return {'list': [vod]}
+        except Exception as e:
+            return self.handle_exception(e, "Error processing detail")
+
+    def searchContent(self, key, quick, pg="1"):
+        body = {
+            "version": "24072901", 
+            "clientType": 1, 
+            "filterValue": "", 
+            "uuid": str(uuid.uuid4()), 
+            "retry": 0,
+            "query": key, 
+            "pagenum": int(pg) - 1, 
+            "pagesize": 30, 
+            "queryFrom": 0, 
+            "searchDatakey": "",
+            "transInfo": "", 
+            "isneedQc": True, 
+            "preQid": "", 
+            "adClientInfo": "",
+            "extraInfo": {"isNewMarkLabel": "1", "multi_terminal_pc": "1"}
+        }
+        
+        try:
+            response = self.post(
+                f'{self.apihost}/trpc.videosearch.mobile_search.MultiTerminalSearch/MbSearch?vplatform=2',
+                json=body, headers=self.headers)
+            data = response.json()
+        except Exception as e:
+            print(f"搜索请求失败: {str(e)}")
+            return {'list': [], 'page': pg}
+            
+        vlist = []
+        try:
+            area_box_list = data.get('data', {}).get('areaBoxList', [])
+            if area_box_list:
+                for k in area_box_list[-1].get('itemList', []):
+                    if k.get('doc', {}).get('id'):
+                        img_tag = k.get('videoInfo', {}).get('imgTag', '{}')
+                        tag = {}
+                        if isinstance(img_tag, str):
+                            try:
+                                tag = json.loads(img_tag)
+                            except json.JSONDecodeError:
+                                tag = {}
+                                
+                        pic = k.get('videoInfo', {}).get('imgUrl', '')
+                        vlist.append({
+                            'vod_id': k['doc']['id'],
+                            'vod_name': k.get('videoInfo', {}).get('title', ''),
+                            'vod_pic': pic,
+                            'vod_year': tag.get('tag_2', {}).get('text', ''),
+                            'vod_remarks': tag.get('tag_4', {}).get('text', '')
+                        })
+        except (IndexError, KeyError, TypeError) as e:
+            print(f"解析搜索结果失败: {str(e)}")
+            
+        return {'list': vlist, 'page': pg}
+
+    def playerContent(self, flag, id, vipFlags):
+        ids = id.split('@')
+        if len(ids) < 2:
+            return {'parse': 0, 'url': '', 'header': ''}
+        url = f"{self.host}/x/cover/{ids[0]}/{ids[1]}.html"
+        parse_url = f"https://jx.xmflv.com/?url={url}"
+        return {'parse': 1, 'url': parse_url, 'header': ''}
+        
+    def localProxy(self, param):
+        pass
+
+    def gethtml(self, url):
+        try:
+            rsp = self.fetch(url, headers=self.headers)
+            text = self.cleanText(rsp.text)
+            # 修复：确保传入字符串给PyQuery
+            return pq(text)
+        except Exception as e:
+            print(f"获取HTML失败 {url}: {str(e)}")
+            # 返回空的PyQuery对象避免崩溃
+            return pq('<html></html>')
+
+    def get_filter_data(self, cid):
+        try:
+            hbody = self.dbody.copy()
+            hbody['page_params']['channel_id'] = cid
+            response = self.post(
+                f'{self.apihost}/trpc.universal_backend_service.page_server_rpc.PageServer/GetPageData?video_appid=1000005&vplatform=2&vversion_name=8.9.10&new_mark_label_enabled=1',
+                json=hbody, headers=self.headers)
+            return cid, response.json()
+        except Exception as e:
+            print(f"获取筛选数据失败 {cid}: {str(e)}")
+            return cid, {}
+
+    def get_vdata(self, body):
+        try:
+            vdata = self.post(
+                f'{self.apihost}/trpc.universal_backend_service.page_server_rpc.PageServer/GetPageData?video_appid=3000010&vplatform=2&vversion_name=8.2.96',
+                json=body, headers=self.headers
+            ).json()
+            return vdata
+        except Exception as e:
+            print(f"Error in get_vdata: {str(e)}")
+            return {'data': {'module_list_datas': []}}
+
+    def process_pdata(self, pdata, ids):
+        plist = []
+        ylist = []
+        if not pdata:
+            return plist, ylist
+            
+        for k in pdata:
+            if k.get('item_id'):
+                try:
+                    title = k.get('item_params', {}).get('union_title', '')
+                    pid = f"{title}${ids[0]}@{k['item_id']}"
+                    if '预告' in title:
+                        ylist.append(pid)
+                    else:
+                        plist.append(pid)
+                except Exception as e:
+                    continue
+        return plist, ylist
+
+    def build_vod(self, vdata, actors, plist, ylist, names):
+        try:
+            d = vdata['data']['module_list_datas'][0]['module_datas'][0]['item_data_lists']['item_datas'][0]['item_params']
+        except (KeyError, IndexError):
+            d = {}
+            
+        urls = []
+        if plist:
+            urls.append('#'.join(plist))
+        if ylist:
+            urls.append('#'.join(ylist))
+            
+        vod = {
+            'type_name': d.get('sub_genre', ''),
+            'vod_name': d.get('title', ''),
+            'vod_year': d.get('year', ''),
+            'vod_area': d.get('area_name', ''),
+            'vod_remarks': d.get('holly_online_time', '') or d.get('hotval', ''),
+            'vod_actor': ','.join(actors) if actors else '',
+            'vod_content': d.get('cover_description', ''),
+            'vod_play_from': '$$$'.join(names) if names else '',
+            'vod_play_url': '$$$'.join(urls) if urls else ''
+        }
+        return vod
+
+    def handle_exception(self, e, message):
+        if e:
+            print(f"{message}: {str(e)}")
+            traceback.print_exc()
+        return {'list': [{'vod_play_from': '哎呀翻车啦', 'vod_play_url': '翻车啦#555'}]}
+
+    def process_tabs(self, data, body, ids):
+        try:
+            pdata = data['data']['module_list_datas'][-1]['module_datas'][-1]['item_data_lists']['item_datas']
+            tabs = data['data']['module_list_datas'][-1]['module_datas'][-1]['module_params'].get('tabs')
+            
+            if tabs:
+                try:
+                    tabs = json.loads(tabs)
+                except json.JSONDecodeError:
+                    tabs = []
+                    
+                if len(tabs) > 1:
+                    remaining_tabs = tabs[1:]
+                    task_queue = []
+                    for tab in remaining_tabs:
+                        nbody = copy.deepcopy(body)
+                        nbody['page_params']['page_context'] = tab.get('page_context', '')
+                        task_queue.append(nbody)
+                        
+                    with ThreadPoolExecutor(max_workers=min(10, len(task_queue))) as executor:
+                        future_map = {executor.submit(self.get_vdata, task): idx for idx, task in enumerate(task_queue)}
+                        results = [None] * len(task_queue)
+                        for future in as_completed(future_map.keys()):
+                            idx = future_map[future]
+                            try:
+                                results[idx] = future.result()
+                            except Exception as e:
+                                print(f"获取标签页 {idx} 失败: {str(e)}")
+                                
+                        for result in results:
+                            if result and isinstance(result, dict):
+                                try:
+                                    page_data = result['data']['module_list_datas'][-1]['module_datas'][-1]['item_data_lists']['item_datas']
+                                    pdata.extend(page_data)
+                                except (KeyError, IndexError, TypeError):
+                                    continue
+            return pdata
+        except Exception as e:
+            print(f"Error processing episodes: {str(e)}")
+            return []
+
+    def josn_to_params(self, params, skip_empty=False):
+        query = []
+        for k, v in params.items():
+            if skip_empty and not v:
+                continue
+            query.append(f"{k}={v}")
+        return "&".join(query)
diff --git a/py/农民影视.py b/py/农民影视.py
new file mode 100644
index 0000000..f47e87d
--- /dev/null
+++ b/py/农民影视.py
@@ -0,0 +1,278 @@
+# -*- coding: utf-8 -*-
+# by @嗷呜
+import concurrent.futures
+import json
+import re
+import sys
+import time
+from base64 import b64decode, b64encode
+import requests
+from pyquery import PyQuery as pq
+sys.path.append('..')
+from base.spider import Spider
+
+
+class Spider(Spider):
+
+    def init(self, extend=""):
+        self.host = "https://vip.wwgz.cn:5200"
+        self.headers = {
+            'User-Agent': 'Mozilla/5.0 (Linux; Android 10; K) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/130.0.0.0 Safari/537.36',
+            'Referer': self.host + '/',
+            'Accept': 'text/html'
+        }
+        self.cateConfig = {
+            "12": [{"key": "cateId", "name": "类型", "value": [{"n": "国产剧", "v": "12"}]}],
+            "4": [{"key": "cateId", "name": "类型", "value": [{"n": "动漫", "v": "4"}]}],
+            "1": [{"key": "cateId", "name": "类型", "value": [{"n": "电影", "v": "1"}]}],
+            "2": [{"key": "cateId", "name": "类型", "value": [{"n": "电视剧", "v": "2"}]}],
+            "3": [{"key": "cateId", "name": "类型", "value": [{"n": "综艺", "v": "3"}]}],
+            "26": [{"key": "cateId", "name": "类型", "value": [{"n": "短剧", "v": "26"}]}]
+        }
+        self.filterConfig = {}
+
+    def getName(self):
+        return "农民影视"
+
+    def isVideoFormat(self, url):
+        pass
+
+    def manualVideoCheck(self):
+        pass
+
+    def destroy(self):
+        pass
+
+    def homeContent(self, filter):
+        result = {}
+        classes = [
+            {'type_name': '国产剧', 'type_id': '12'},
+            {'type_name': '动漫', 'type_id': '4'},
+            {'type_name': '电影', 'type_id': '1'},
+            {'type_name': '电视剧', 'type_id': '2'},
+            {'type_name': '综艺', 'type_id': '3'},
+            {'type_name': '短剧', 'type_id': '26'}
+        ]
+        try:
+            data = self.fetch(self.host, headers=self.headers).text
+            doc = pq(data)
+            videos = []
+            # 修改选择器并添加去重逻辑
+            seen_ids = set()  # 用于记录已处理的影片ID
+            for item in doc('.globalPicList li:has(img)').items():
+                vod_id = self.host + item('a').attr('href')
+                if vod_id not in seen_ids:  # 检查是否已处理过
+                    seen_ids.add(vod_id)  # 记录已处理的ID
+                    pic_url = item('img').attr('data-echo') or item('img').attr('data-src') or item('img').attr('src')
+                    # 替换图片域名
+                    if pic_url and 'pic.lzzypic.com' in pic_url:
+                        pic_url = pic_url.replace('https://pic.lzzypic.com', 'https://img.lzzyimg.com')
+                    videos.append({
+                        'vod_id': vod_id,
+                        'vod_name': item('.sTit').text(),
+                        'vod_pic': pic_url,
+                        'vod_remarks': item('.sBottom').text()
+                    })
+            result['class'] = classes
+            result['filters'] = self.cateConfig
+            result['list'] = videos
+        except Exception as e:
+            print(f"首页数据获取失败: {str(e)}")
+            result['class'] = classes
+            result['filters'] = self.cateConfig
+            result['list'] = []
+        return result
+
+    def homeVideoContent(self):
+        pass
+
+    def categoryContent(self, tid, pg, filter, extend):
+        result = {}
+        try:
+            if tid == "4-dm":
+                # 处理大陆人气动漫分类
+                url = "https://www.wwgz.cn/vod-list-id-4-pg-{}-order--by-hits-class-0-year-0-letter--area-大陆-lang-.html".format(pg)
+            else:
+                cateId = tid
+                url = f"{self.host}/vod-list-id-{cateId}-pg-{pg}.html"
+                
+            data = self.fetch(url, headers=self.headers).text
+            doc = pq(data)
+            
+            videos = []
+            for item in doc('.globalPicList li').items():
+                pic_url = item('img').attr('data-echo') or item('img').attr('data-src') or item('img').attr('src')
+                # 替换图片域名
+                if pic_url and 'pic.lzzypic.com' in pic_url:
+                    pic_url = pic_url.replace('https://pic.lzzypic.com', 'https://img.lzzyimg.com')
+                videos.append({
+                    'vod_id': self.host + item('a').attr('href'),
+                    'vod_name': item('.sTit').text(),
+                    'vod_pic': pic_url,
+                    'vod_remarks': item('.sBottom').text()
+                })
+            
+            result['list'] = videos
+            result['page'] = pg
+            result['pagecount'] = 9999
+            result['limit'] = 90
+            result['total'] = 999999
+        except Exception as e:
+            print(f"分类数据获取失败: {str(e)}")
+            result['list'] = []
+            result['page'] = pg
+            result['pagecount'] = 1
+            result['limit'] = 90
+            result['total'] = 0
+        return result
+
+    def detailContent(self, ids):
+        result = {}
+        try:
+            url = ids[0]
+            data = self.fetch(url, headers=self.headers).text
+            doc = pq(data)
+            
+            # 获取播放线路和剧集
+            play_from = []
+            play_url = []
+            
+            tab_box = doc('#leftTabBox')
+            if tab_box:
+                for tab in tab_box('ul li').items():
+                    play_from.append(tab.text())
+                
+                play_lists = []
+                for num_list in tab_box('.numList').items():
+                    episodes = []
+                    # 修改这里：将items()转换为列表后反转顺序
+                    for ep in list(num_list('li').items())[::-1]:  # 反转列表顺序
+                        episodes.append(f"{ep('a').text()}${self.host}{ep('a').attr('href')}")
+                    play_lists.append('#'.join(episodes))
+                
+                play_url = play_lists
+            
+            # 获取详情信息
+            vod = {
+                'vod_name': doc('h1 a').text(),
+                'vod_year': doc('span:contains("年代：")').text().replace('年代：', ''),
+                'vod_area': '',
+                'vod_actor': doc('.sDes:contains("主演:")').text().replace('主演:', ''),
+                'vod_director': '',
+                'vod_content': doc('.detail-con p').text().replace('简介:', ''),
+                'vod_play_from': '$$$'.join(play_from),
+                'vod_play_url': '$$$'.join(play_url)
+            }
+            result['list'] = [vod]
+        except Exception as e:
+            print(f"详情数据获取失败: {str(e)}")
+            result['list'] = []
+        return result
+
+    def searchContent(self, key, quick, pg="1"):
+        result = {}
+        try:
+            url = f"{self.host}/index.php?m=vod-search"
+            data = {'wd': key}
+            headers = {
+                'User-Agent': self.headers['User-Agent'],
+                'Referer': self.host + '/'
+            }
+            html = self.post(url, data=data, headers=headers).text
+            doc = pq(html)
+            
+            videos = []
+            for item in doc('#data_list li').items():
+                pic_url = item('.lazyload').attr('data-src')
+                # 替换图片域名
+                if pic_url and 'pic.lzzypic.com' in pic_url:
+                    pic_url = pic_url.replace('https://pic.lzzypic.com', 'https://img.lzzyimg.com')
+                videos.append({
+                    'vod_id': self.host + item('a').attr('href'),
+                    'vod_name': item('.sTit').text(),
+                    'vod_pic': pic_url,
+                    'vod_remarks': item('.sDes').eq(-1).text()
+                })
+            
+            result['list'] = videos
+            result['page'] = pg
+        except Exception as e:
+            print(f"搜索数据获取失败: {str(e)}")
+            result['list'] = []
+            result['page'] = pg
+        return result
+
+    def playerContent(self, flag, id, vipFlags):
+        result = {}
+        try:
+            if '@' in id:
+                ids = id.split('@')
+                if not ids[0]:
+                    raise Exception('未找到播放地址')
+                
+                js_url = f"{self.host}/player/{ids[0]}.js"
+                js_data = self.fetch(js_url, headers=self.headers).text
+                jxurl = re.search(r'http.*?url=', js_data).group()
+                
+                data = self.fetch(f"{jxurl}{ids[1]}", headers=self.headers).text
+                matches = re.findall(r'http.*?url=', data)
+                
+                if matches:
+                    url = []
+                    for i, x in enumerate(matches):
+                        js = {'jx': x, 'id': ids[1]}
+                        purl = f"{self.getProxyUrl()}&wdict={self.e64(json.dumps(js))}"
+                        url.extend([f'线路{i + 1}', purl])
+                else:
+                    url = re.search(r"url='(.*?)'", data).group(1)
+                
+                if not url:
+                    raise Exception('未找到播放地址')
+                
+                p = 0
+            else:
+                p, url = 1, id
+            
+            result['parse'] = p
+            result['url'] = url
+            result['header'] = self.headers
+        except Exception as e:
+            print(f"播放数据获取失败: {str(e)}")
+            result['parse'] = 1
+            result['url'] = id
+            result['header'] = self.headers
+        return result
+
+    def localProxy(self, param):
+        try:
+            wdict = json.loads(self.d64(param['wdict']))
+            url = f"{wdict['jx']}{wdict['id']}"
+            data = self.fetch(url, headers=self.headers).text
+            doc = pq(data)
+            html = doc('script').eq(-1).text()
+            url = re.search(r'src="(.*?)"', html).group(1)
+            return [302, 'text/html', None, {'Location': url}]
+        except Exception as e:
+            print(f"代理处理失败: {str(e)}")
+            return [500, 'text/plain', str(e).encode('utf-8')]
+
+    def liveContent(self, url):
+        pass
+
+    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 ""
\ No newline at end of file
diff --git a/py/奈飞.py b/py/奈飞.py
new file mode 100644
index 0000000..29edab7
--- /dev/null
+++ b/py/奈飞.py
@@ -0,0 +1,373 @@
+# -*- coding: utf-8 -*-
+"""
+奈飞影视 - naifei.im
+"""
+import re
+import json
+import sys
+import time
+from urllib.parse import quote, urljoin
+from base.spider import Spider
+
+
+class Spider(Spider):
+    def __init__(self):
+        super(Spider, self).__init__()
+        self.host = "https://naifei.im"
+        self.name = "奈飞影视"
+        self.headers = {
+            'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/131.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,en;q=0.8',
+            'Accept-Encoding': 'gzip, deflate, br',
+            'Connection': 'keep-alive',
+            'Upgrade-Insecure-Requests': '1',
+            'Sec-Fetch-Dest': 'document',
+            'Sec-Fetch-Mode': 'navigate',
+            'Sec-Fetch-Site': 'none',
+            'Sec-Fetch-User': '?1',
+            'Cache-Control': 'max-age=0',
+            'Referer': self.host
+        }
+        self.categories = {
+            '1': '电影',
+            '2': '剧集',
+            '3': '综艺',
+            '4': '动漫',
+            '5': '短剧'
+        }
+        self._detail_cache = {}
+
+    def getName(self):
+        return "奈飞影视"
+
+    def init(self, extend=""):
+        pass
+
+    def homeContent(self, filter):
+        classes = [
+            {"type_id": "1", "type_name": "电影"},
+            {"type_id": "2", "type_name": "剧集"},
+            {"type_id": "3", "type_name": "综艺"},
+            {"type_id": "4", "type_name": "动漫"},
+            {"type_id": "5", "type_name": "短剧"},
+        ]
+        return {'class': classes, 'filters': {}, 'list': []}
+
+    def homeVideoContent(self):
+        try:
+            videos = self._fetch_home()
+            return {'list': videos}
+        except Exception as e:
+            print(f'[{self.name}] 首页爬取失败: {e}')
+            return {'list': []}
+
+    def categoryContent(self, tid, pg, filter, extend):
+        try:
+            page = int(pg) if pg and str(pg).isdigit() else 1
+            videos = self._fetch_category(tid, page)
+            return {
+                'page': page,
+                'pagecount': 9999,
+                'limit': 20,
+                'total': 99999,
+                'list': videos
+            }
+        except Exception as e:
+            print(f'[{self.name}] 分类爬取失败: {e}')
+            return {'page': int(pg), 'pagecount': 0, 'limit': 20, 'total': 0, 'list': []}
+
+    def detailContent(self, ids):
+        try:
+            vod_id = ids[0] if isinstance(ids, list) else ids
+            detail = self._fetch_detail(vod_id)
+            if detail:
+                return {'list': [detail]}
+            return {'list': []}
+        except Exception as e:
+            print(f'[{self.name}] 详情爬取失败: {e}')
+            return {'list': []}
+
+    def playerContent(self, flag, id, vipFlags):
+        try:
+            play_url = ''
+            if id and id.startswith('http'):
+                play_url = id
+            elif '$' in str(id):
+                parts = str(id).split('$', 1)
+                if len(parts) == 2:
+                    play_url = parts[1]
+            else:
+                play_url = id
+
+            # 如果是网页链接，需要解析获取真实播放地址
+            if play_url and 'naifei.im' in play_url:
+                real_url = self._parse_play_url(play_url)
+                if real_url:
+                    play_url = real_url
+
+            return {
+                'parse': 0,
+                'playUrl': '',
+                'url': play_url,
+            }
+        except Exception as e:
+            print(f'[{self.name}] 播放失败: {e}')
+            return {
+                'parse': 1,
+                'playUrl': '',
+                'url': str(id),
+            }
+
+    def _parse_play_url(self, url):
+        """解析播放页面获取真实播放地址"""
+        import re
+        
+        html = self._fetch_page(url)
+        if not html:
+            return None
+        
+        # 直接提取url字段
+        url_match = re.search(r'"url"\s*:\s*"(https?:[^"]+)"', html)
+        if url_match:
+            video_url = url_match.group(1).replace('\\/', '/')
+            if video_url and video_url.startswith('http'):
+                return video_url
+        
+        # 备用：直接匹配m3u8地址
+        m3u8_match = re.search(r'(https?://[^\s"\'\\]+\.m3u8[^\s"\'\\]*)', html)
+        if m3u8_match:
+            return m3u8_match.group(1).replace('\\/', '/')
+        
+        return None
+
+    def searchContent(self, key, quick, pg="1"):
+        try:
+            page = int(pg) if pg and str(pg).isdigit() else 1
+            videos = self._fetch_search(key, page)
+            return {'list': videos}
+        except Exception as e:
+            print(f'[{self.name}] 搜索失败: {e}')
+            return {'list': []}
+
+    def _fetch_page(self, url, retries=2):
+        """获取页面内容"""
+        import requests
+        session = requests.Session()
+        session.headers.update(self.headers)
+        
+        for attempt in range(retries + 1):
+            try:
+                resp = session.get(url, timeout=15)
+                
+                if resp.status_code == 403:
+                    redirect_match = re.search(r'window\.location\.href\s*=\s*"([^"]+)"', resp.text)
+                    if redirect_match:
+                        redirect_path = redirect_match.group(1)
+                        if redirect_path.startswith('/'):
+                            new_url = self.host + redirect_path
+                        else:
+                            new_url = redirect_path
+                        resp = session.get(new_url, timeout=15)
+                    elif attempt < retries:
+                        time.sleep(1)
+                        session.get(self.host, timeout=10)
+                        continue
+                
+                resp.raise_for_status()
+                resp.encoding = 'utf-8'
+                return resp.text
+            except Exception as e:
+                if attempt < retries:
+                    time.sleep(1)
+                    continue
+                print(f'[{self.name}] 请求失败: {url}, 错误: {e}')
+                return ''
+        return ''
+
+    def _fetch_home(self):
+        """获取首页视频"""
+        from bs4 import BeautifulSoup
+        
+        html = self._fetch_page(self.host)
+        if not html:
+            return []
+        
+        soup = BeautifulSoup(html, 'html.parser')
+        videos = []
+        
+        items_containers = soup.find_all('div', class_='module-items')
+        for container in items_containers:
+            items = container.find_all('a', class_='module-poster-item')
+            for item in items[:20]:
+                vod = self._parse_video_item(item)
+                if vod:
+                    videos.append(vod)
+        
+        return videos[:50]
+
+    def _fetch_category(self, tid, page=1):
+        """获取分类视频"""
+        from bs4 import BeautifulSoup
+        
+        if page <= 1:
+            url = f"{self.host}/vodtype/{tid}.html"
+        else:
+            url = f"{self.host}/vodtype/{tid}-{page}.html"
+        
+        html = self._fetch_page(url)
+        if not html:
+            return []
+        
+        soup = BeautifulSoup(html, 'html.parser')
+        videos = []
+        
+        items = soup.find_all('a', class_='module-poster-item')
+        for item in items:
+            vod = self._parse_video_item(item)
+            if vod:
+                videos.append(vod)
+        
+        return videos
+
+    def _fetch_detail(self, vid):
+        """获取视频详情"""
+        from bs4 import BeautifulSoup
+        
+        if vid in self._detail_cache:
+            return self._detail_cache[vid]
+        
+        url = f"{self.host}/voddetail/{vid}.html"
+        html = self._fetch_page(url)
+        if not html:
+            return None
+        
+        soup = BeautifulSoup(html, 'html.parser')
+        
+        result = {"vod_id": vid}
+        
+        title = soup.find('h1', class_='video-info-heading')
+        result['vod_name'] = title.text.strip() if title else ''
+        
+        cover = soup.find('img', class_='lazy lazyload')
+        if cover:
+            pic = cover.get('data-original', '') or cover.get('src', '')
+            if pic and pic.startswith('//'):
+                pic = 'https:' + pic
+            result['vod_pic'] = pic
+        else:
+            result['vod_pic'] = ''
+        
+        info_items = soup.find_all('li', class_='list-item')
+        for item in info_items:
+            text = item.text.strip()
+            if '主演' in text:
+                result['vod_actor'] = text.split('：', 1)[-1] if '：' in text else ''
+            elif '导演' in text:
+                result['vod_director'] = text.split('：', 1)[-1] if '：' in text else ''
+            elif '地区' in text or '语言' in text:
+                result['vod_area'] = text.split('：', 1)[-1] if '：' in text else ''
+            elif '年份' in text:
+                result['vod_year'] = text.split('：', 1)[-1] if '：' in text else ''
+            elif '更新' in text or '集数' in text:
+                result['vod_remarks'] = text.split('：', 1)[-1] if '：' in text else ''
+        
+        desc = soup.find('div', class_='video-info-content')
+        result['vod_content'] = desc.text.strip() if desc else ''
+        
+        episodes = []
+        episode_list = soup.find('div', class_='module-play-list')
+        if episode_list:
+            ep_items = episode_list.find_all('a')
+            for ep in ep_items:
+                ep_link = ep.get('href', '')
+                ep_title = ep.text.strip()
+                if ep_title and ep_link:
+                    full_url = urljoin(self.host, ep_link) if ep_link.startswith('/') else ep_link
+                    episodes.append(f'{ep_title}${full_url}')
+        
+        if episodes:
+            result['vod_play_from'] = '奈飞影视'
+            result['vod_play_url'] = '#'.join(episodes)
+        else:
+            result['vod_play_from'] = ''
+            result['vod_play_url'] = ''
+        
+        self._detail_cache[vid] = result
+        return result
+
+    def _fetch_search(self, keyword, page=1):
+        """搜索视频"""
+        import json
+        
+        url = f"{self.host}/index.php/ajax/suggest?mid=1&limit=20&wd={quote(keyword)}"
+        html = self._fetch_page(url)
+        if not html:
+            return []
+        
+        videos = []
+        try:
+            data = json.loads(html)
+            if data.get('code') == 1 and data.get('list'):
+                for item in data['list']:
+                    vod = self._parse_search_item(item)
+                    if vod:
+                        videos.append(vod)
+        except Exception as e:
+            print(f'[{self.name}] 解析搜索结果失败: {e}')
+        
+        return videos
+
+    def _parse_search_item(self, item):
+        """解析搜索结果项"""
+        try:
+            vid = str(item.get('id', ''))
+            name = item.get('name', '')
+            if not vid or not name:
+                return None
+            
+            pic = item.get('pic', '')
+            if pic and pic.startswith('//'):
+                pic = 'https:' + pic
+            
+            return {
+                'vod_id': vid,
+                'vod_name': name,
+                'vod_pic': pic,
+                'vod_remarks': '',
+            }
+        except Exception as e:
+            return None
+
+    def _parse_video_item(self, item):
+        """解析视频项"""
+        try:
+            link = item.get('href', '')
+            title = item.get('title', '')
+            
+            img = item.find('img')
+            cover = ''
+            if img:
+                cover = img.get('data-original', '') or img.get('src', '')
+                if cover and cover.startswith('//'):
+                    cover = 'https:' + cover
+            
+            note = item.find('div', class_='module-item-note')
+            quality = note.text.strip() if note else ''
+            
+            vid = ''
+            match = re.search(r'/voddetail/(\d+)\.html', link)
+            if match:
+                vid = match.group(1)
+            
+            if not vid or not title:
+                return None
+            
+            return {
+                'vod_id': vid,
+                'vod_name': title,
+                'vod_pic': cover,
+                'vod_remarks': quality,
+            }
+        except Exception as e:
+            return None
diff --git a/py/漫闪.jar b/py/漫闪.jar
new file mode 100644
index 0000000000000000000000000000000000000000..fac69514fc3269bf8e0938973c00eb9e3850d646
GIT binary patch
literal 14822
zcmZ|01yCG8*QkxVgy0_B-JRf0kl-5J-95Nla7%D^Nzf&@yL(tzV1ZrS;phEt)%U$s
zx9*vmnx5&?=k%QE?y2tT=Zi8t0vZeq3JlBw-<1)}e+eoK0*tDx_GdOlH93ygaTu5{
z@2Yq(C@3iZmnz<SvHww3{j8=aC#$8+t}1t>Iys@D%*H;4sm#VaJvq~&$+^h0d*IHl
zq{^zOI_Fj0s>ul#cSKCWXd6MFahUPL{?h%z9roQ5GK%uErl{b%U4i%W|Lqz5J=em~
z+{44lgWb}~w;%{LaB->a?N8s1%WdRX1TDAY0D}3fq_+afoWkly+|M6108VMd3bZ+j
z)*mJ7(BgK#J80PbI*&2%sY5TGU+$f^KeL}`X`gAQH8b20S2i@=(0$wSfD~93w+9u4
z{Pmgc0iA=k1E&An-Q|5ycl6HsI$cti<!E1q4tY9w5ZH8EE2X3`e%ZD%me7A#u1EK-
zqdB1|o~o(-UK(Pe{(<~sTnN@I=o5)$Z@MkLZFtcUIXh1h3af#R!eTR7Ys^tBeQ`yo
zO_*+21Dp$t1X3^-8DcQ}GuAx~6bCA>OBq^6d;{wTKro|sMdKu8L|zZ|2x|l21NZ={
z0CIq{8HX!nBc(5#FNq*RH*6rGFY-OISz+vBn5G#;BZ4iQ4!kiyZdYmd3Qz!`*bO$L
zgfc=Apsdi3t{?81p_sdzP<p7?uG6kWSP^U=LJ~YB3`1xioE-WvS^_*;SS)~d*V2r5
z7WEY79H|!x!{b$_SSze0G}w#~3J1l4N&q5SVh-VL-klJbaX>#p30%qUNk0r4eTAQr
z#CD}~Wr2Qjh4DrArMx%&<btSyr-$GPW4CMnuFDE_G9!ZKtKuQ4Ax|SdhB}0Cz^TK!
zzzhK7Lj&mM@P3l$!R4cS!e+q+gu1}=A;+!9*oR$(sshdc`v610hh0Z`F-bm7N<B1Q
zc$Uzw07QWBCrn4AdW3pJZ@41lb65&Q3gkkhLS!tM=ywA<aJ}f=n9pQHaKV_*u!6A9
z@E=w`@dHqO!#;h0D~G``LwYxbH5fJ#S_k0Y_1?w$Phj6;B?@JJkIzb|1O76~2ZZWS
zVKc5-xK?;VIB@7hs1tzgy*kdj!Mpmqh`V2RNdcq)ja~R%b-+mIol)_HBo`-PCE_w1
z*H6+_6eILaxJ|@OWKk?pOfncO`1g;E5R4cI^Nh$jExi*)ZAS0~P8;3}KyAj<NM?)7
zjxZ1K-c{SB+V$Jz+wB5$y<5fx?7%?mi^nAK7~$We4x=1qZ6@SO;mS3OZiKjrB?>2s
zB#PLL(2W#GdJhZL+SLUh11Li!;3#3gVWuL!zbYp&3VchbkR)9rj3BulMlBLMoN%bu
ze;SAxLnE>;iZ6oiM_<_YhCvTy*<Ask?pgqv2%O*;V0psUB=NtXv%-*sS^vb>!!*LE
zh1UdFo1wenx-vjNyoZSdDhyTK9RWN6io$ju^cp1b8!_|{J>jxo^1|u>Si9C{gpJ6*
z|I<<_-t7xRkvK5|Ve(-H5oLmRY0c0$;TaJR;co!M0B$p(S*(0?Ba~X?dBDMY47_)h
z0l~XMyAFVkFiKbn_+a#Bd{-ls0>pd-71(lE<xqYzTvy!P?igF<Mi@QBTI6=vJ6Lr%
z4$il4qr6dGuo&=t@UIxp@QprZDge=4PctT0*c2G+0g7qF6PQZb@0~Q2+}}Hky`9vX
z4p2728xv3`;yIThm_EhCb0SC)q8fkl44WnUWpIM<4@QNj-*UnKC;AZ*J1jqpm?TFE
zf@bNdk3<R*Hvoo7q!(v(@Rsy9-fxWGWcOsQi0?fBzY%d2%?Q&Gz8<k1UL+J8MjA>Q
zmKT~AW*BN1wh=Z1-xVqn))l%1APnVz3kdB2SO6vfHGucw0M^t-0{$KeN(m5X6OFu8
zJv@e5D974+-U~%Ic-@;}y?I4|z|cJ9rF^2!LPX&}glB*9Lw_}RJ}(NHG4$?eNt#OR
z`?_f!6VRS(7?ww2N__>aC$}ryUgS@$us(3}g6As|x%e+IsId(L{585qXzyY|d+lF-
z^HAq0vG8-YbB$g{n@ltV8!4u`Y56+y^2_9<GQeeik2xai7)p&Wy|{-jbd#U#+JZHL
z<Gi#d9x*e&HznlcG=U14tO_B7oAA0fi6A_N4hZd4d=M{q!s`C5k{INl<X8c|;6G_>
zbL7o0SRgiV-h5+pMe!pDpN7K%ySd%Vcb+l{St+|8c2Gx42-sjQ9xnDt&X8Y$JudSz
zd3<bulOh%kSXbFQOF??I8~>p5`QCZ%j|)F|w#)OM$;7LlX7d-EJ=D6Ugx{#i#Vc3f
zqeE&y9r`ma%I&AkbIqG5kUbu+mt-*K%3B1MNGeE?{7}eWDH?uPqHZAlL-6P53YzD9
ztgG%o*=S`zh)Fad5NH|&<q__tW(YJ<%RWe-3UR|K8Yw)udJNHs?sC7x`1G8Hb@eFv
zbD(HqY{36epFEhSV%pH-@s9|@TaT&|q|NpZ`J#E@o#W~_stu^;E6B8VAo_;FZpmY%
zasXQ(G0Jr18NZWan}fy9v#)m10_bWu?Qgr_CEN&)j97FPcZ^x6UR~Zn=k)WA_a*%B
zt)UcY&Fb|4xXfE?r@i2=%EDW>+^Vy%AZa|iUL&~$%sT7TfNbQtcTp%DVk$-g15(s4
zFxM!{-)a{ANKi1Ry<B{sIq2>b=a8E|2+V~@_e|b_FCK4vUplwkh&Zm)|3btSrLRBO
z5@*cQ4BlFcZ;f0<<0ME2@RzD1v<+~-rDjhTC&wPFE2Woq8`u?>GY6MvUJ)Bir?=)0
zT(c+=I`|c-grv3VPXv``J~0`b$G2{l@EXrc3F~X|VLN$Nmug)H%3KGkEMIYH&B({+
zV>7U>3Z<1F8}(4Ir+RjlvTubDiuZ7vD5TSVeb|Bq(~mt&l$ehC#g6?(KIjB?=d<mL
z*N!S`ZWAgAt4-MC*N2dG=L^t^$&cHRbu;mCfRz3uEL=@L=u_nH)Y<9HD+#^2%>ob7
zZpYk`rPZtHR43e$!<WQVE4>NOmekU}oYiJ7s)Cf!C{^ZzJ2gRFu)NqNq;~?9Pvj9_
zwLRgDX|lcNgML0hAG0MW9-`>lj;Q+=>FvS}34e-Dn^uCEzJn?&l{n^aB0mXbl^%G0
zJfbyzvmCXGG!ss8#yw45t&-DZC}6Xbyc}5N@JbW54Kv%3zUd<>tSAQa7RdBvw#En3
z9MjFuF-OVUqvCfc=F%3GepgFfob?o&!Wr+K$?&8eqMMp6OT)7DM>S@*!!f2hR?H=s
z=U23`HBi`~EBG|RWqcRVN%7_>oYBi*7hB%KS5RVCRbDNzps~~TlR;XokKvYbdEDRH
ztl~{=UWXY+MR%6|*S{>(UP_iy>V9!K*eQZjt=9Rs4_X`ts0S7iv_0AWbYexC-(N77
zX0$5fmM4DOziCfN;9mq1H<ZhM4@#4|bRbFb{D??*Gw-Vy#QS-^#WuW@P%Al!fvzX?
zk+;tj`p2qyQQbrG?ei(9^oS#Ex(u#V*WOR(U+ZONsr@T+)4T}X&>y%~w8B{!+qP-b
z#Po#Xt!qO?P<qPogQmK+MOhKUYL<aIj^fo3Mt^WGvxGXRX70k^lq_k5%Jf%xI^vU2
z^){mL8=SF=*!l|=SAo3M_cL2^<4;v-F5&eZpR-(M4@f=zl6+8ZSL_+t?8Ji98p(|%
zF~6T#7f$w}y!a>?$Y>#K94#CN+103*JbZttzOocirdsJ!T>o^?iFccH1Le*?7wl2I
zt5BQ?z&){enk!wg!nHSGK9*YRvo7e<2e~X?IuG~e(BrXXES3(X@y~x$%o_L4O%2E?
zP3JQ%2RqGckHtd#B3lhlK%d*)1QVu@wA~1srb)#%T>Vk!i=-Z31;Ih3$lAhBo!BRV
z(O!PZNgj{k!a+FWZ&_*}54~O7o1$b-n)-jeGYX)hpK5m@a*v=d;<XDSL2_?*)IBN{
zgi<bRoR6mcpI^g%jQCFaz(yv#;BhN6T4rdDdP_u}+AiR@Z?is5Jhv{Ld(p$A0=>KJ
zjp+}Br0TI_w47T4jH&L1sDU|59^0UcPU%8Y+0lRwm5_DtjZAlirs=)^y5blhF(q_G
zWJx6cGN=p0FwimAg_40uKTsskc%&Q!fx&#BEVEo=f2?BwhDb(kZuZ7+zWVneA0Nbl
z;|!8s^=Cz?-Xfb{TFy*F7ED)rzAK}+Z-CGEbDjcS>pwp^r@C}~)h;-b45>eST`g|6
z+$A8cZo4>23(FI<PQC|enC_Y@i1F4Z*nd%f|1~^DixKw{zecQR?7J#X>nBy><Fz!x
z3tGYY)sZM4h)q>DAy*FMejan>Snggy6FNx+!>uBAe04}HXG^yW9xq?g>nn@FmwB=Q
zWFBrX8Fkm=S1FtKZzlOi7o=gvGX~3EbBqB#PTCD3k>cCRm^3VzOXNI`FVB7p7|cx~
zc?4jtVQWD-#+uoc1iRbqY6jJ-S9YY7RY>LX2J0{V^-WULeu{GzNQvV*d0DV;_8RQa
z+6%-|_iAw_ZyeK?o`&*YKBk3%8^85zzqTP>-^h2D^UQp*nUzE8By~DS#Y^8X+<#dZ
z8FQ_`puF&Rdgw(tEC~-j@_IT90<Df1F@LKJPRhhyPqQMeoB~I-3jB4j?ZDvzfyF1|
zb#E*yP8E|+pS;|Me>23&ck{Eie5}fv#U68TuZ5dmOL+WR8+VB*Fu%~4B2R|3$9p+y
zhn{9WGs2uNo0BX(jJ@PY+8;TTnz2Y}J79kq_j8RIWAOsz6#d%+S$vGBzKErZw;n^u
zHqmwZ$|<@4AOw}bqtMK+X6J)nk-lMF0SM%cGwIMqN-bEo6s2Aup$;wVCHV7jK8A1*
zP%(k?t!ppbm?P7BsI-myJR{ha@E<|oLeRhJSZtzaKeD1)O2_-5wQsSVC1?-lgjAO?
zDfe`q0BaoXqK{PI4WfQo!M@JApKO+IDN<OrC^qpZf2Q&Hmfhog7kdF}tytf73S>N3
z8;0hEm;SBdEjYM37WZ@Y9pjT-jpj=T^aLlpXa}EPT!Iplu!^EDUz`>xDdZ{5tPm?`
zIXq`Y`Y!%X2+H+ir&~$<3=J!AAS)lYW50$xHQqaGu&BhzS#GzP#Hl6SYtIDE;^>a)
zNI;>WEK3mqAz@MHRxPHD2TVV)F(gXz-+=hX;F!msHGxx%Z{+&D`q#)hmq~!mCscp@
z%Z@mbWMrNfr-V&Rbo-J(2p5n2!b3NAkpQrO!Cp)-);IUdia=_X2ZH3B$r{dM5(DwQ
zdLff~Ap_7)0qFO`xXHqqL8*YvY=GgiMA`4P<%58kGR5ITaSfO5lgwynF#p0H$G~>L
zme$tLERD%{$IW<ZTMK(rkjZs4r2iPJ3%10u+Il;h=s4NZzYbBAVI9KB*%{P2bAqk1
zdjrN=Q|X_Vq%a(;_ofSUG%O+O!0fCL)=D<m4xQPLJYS8_?r7OQ{uyY~w5hS7v7bC<
z?pyEzOX!H?i0r-TU8=rvOa)@?_wy#Igta4W`s=&m8uLJKZ?yb*?V6^XsW@8dnl9n_
zYrm!^DOIN-w7w;M<x4(F)mnIdf*<ua=7$#gfOHDLs-W)b)O<9ZH|Wn5!V~NrqaTFO
zKZN)(b6Ng`qIH>*D>ucLsJSQpg&)2v?Ovt!5W}j6Udb9_`9RS|(2SwEn2IHV8gMrB
zr<5oFkA(>!u;af)g0(p4MMPue_gcY+H_(L{XNO)>foPj*9_ypRbyL;e!6H#k$n2a{
zD~X(pLRB0Rqc=1g?l7lQShkFINBvuSs~~za(B=GxiM$Ns7>ca{9X^o9Pi~I1HXbZH
z8eCB6%$mt#7<Gf=R{1e0b#47{SVihPxPa<uDGk>rfbB5fp($d)J~NoittQP`0XrAr
zIP23jzL0|h&<N1yiaqw@DItZFN48qM)K|ePCiqy{k1raeGAe}rhZ4`vIa9ZHn`2^$
z%#jngSw$)Gq+-jGtlUpSf=sNRGEF-=JOEOH1oxZBpn$1qDTe(25O+c>(bR0v^<6&0
z=P0ul37wspnWMy8n*5bk4ipa<9j@6`%NOnzpWMO6$(tA8S2)J1a;d+G42;6)af%EK
zDZd3FROv;}s6Q+R|B*Ia^Z%y%%DZ<H$=b$}qYEDBY${GlX;VA@t8=U@%5YaG>wM2Z
zFl~@LreFOR3*W;luEqZeVJy+2FVd)D;$iK~401{f<tUfm?OOWH>TX2Zmb7|C?f=6g
z{}iCIQOy+<;D>SR-7j`5t8O2-<j$ey4S=&)x@2$g5>5q8r0wJlH2AES5->G-#LZkN
z?l@3R&*oo-g$G3;cxTQR=5qtVBP!p@gK+u`1fcD<f6R<e1X}(`7waurV9P4l(Wb5c
z3urVQ5?-XNH!nEQ;#x)@tnrm8x)RR)7cWf9@N7K!Nt6M4sMp>845hm4R>HnACWSod
ze%_%IS02Cd3jei|QB_o138Eb_pU9fXAo-Xs!>MN!$nSaKdCyUoiArgWh^WF5+j6BU
z@HK0u_}{+_1rB;O%x`y&zmOIj)cAf;s<c;79mDb~K|YYIv-0i}ZQ$>YioLZ2KO~?(
zQA365iY~8nLBTpFuNPvy(&y1pHRX%^pBzcoNS~k8CIS=0$HOU0N?A%(^wAc)V%nPe
z{Rx`vR@u}vsSfjm0$HM64xmm#freN+sRJF!P`}%V#TNUW^-8p-b`1FJQ&cG)sma78
ze67Ubhs_y__Mjm(<P9{Zkh1Wl$n1Rg=A0WM@(DIrw$lMW8r%Cu549M_9KM-#CQ|lR
zash~UcKdC`@1nZ}s@iapBMkhI4{po5T5}wk1ta);=*E;GMrv4uMGNTU-%Wb2GnSAY
z(5INL-Pt-GM-{f#{GSGDY>@+s^sb^OUtQxY@VGJtRc)h)wf98|=EE3P1scoXXBtZ-
zDZkY?G&E(=I7wWcYMprvX0H5TfX!>IPE-g=usX^<VJtTS=llwk@0m>hTsR_xZO=G8
zZuGcPfET2-Vq4Q;<$$42++US=6om7%l3A#$>?WOApdBNjdOEFTcRe^~9<FZYlJ>~{
zd7Qx|OUQJDm`7^u{u8hMa=@X-w;WN1v>!s#v4?)R5BYjgv+@;CA)I4DI;6^B>_n?=
zWepz7;wWgF0&33eflj0-BtxI-N_()k!GiDg0&h}1$|dXJ@DrVB1ugt@H=zfv?Kc<L
z3Yk+>o}Ir;O&SFs^|LCqs1*~RKiX%bv2~>H^Dj3zF=|-+1@mM{_61^cyJ^d+cm)rf
zuDb?{$QSIamzijTI@+^^`^<L`+KcN^s<iT})ISEs?Z47xL~&7m2xMkScS@AsOj-ZF
z-&QWGCF)m6MHwhg$%Yg{|M$DxgbK}V95p|meC>s4>QzcgQQ*WI8~H!tegkQ-=rZIR
zwqA|DMkMn^s5vc-!6sQR39FeJ(OZ#Uy_@sFiSDXH_pJ`tLd8S_A-j{r`Khc=NM7qe
zA--oXb|!h7@L{bI0CQF_uAKQ3kWsMEBQtVnyuNTUd#S{oFc;szMy|lXG`E&RRrni`
zV8z>Ih{ISJ?SU!^yBA7Xxv#bV8s#Q?M0Y?BittfHw-$l6S))nY976buh(M06YCiWx
zHIr#0{k)8FVcTM|^a=1Hdt;1u>e~KoI!*k!xa{P?X4F1vq~sZ?SGF!~TM7W2K{AX!
zE(vt&`9VwTjD+}viVxdBT#S7nBs(5BxNy*dOlxBiux5s?FBmZTHTx!LX>H&~E(paj
z@iur$^fWh!dPW<9k^jqalUn&PMaJgX2WQu<B$C6Hl6yt?hr`qstYM0a3G<WT1rz4B
zdG$i0(weIIm-dJkbFE9MLrc4XG%K*B=**W}@Y_mOyB%d=$Z|q{mUXN~gTOcDv7GE^
zsbhSgVM^Ui+O@iBJOp`L#?<}l#Ye3->rJ+o5(Er*H3jCSOd%JwC`3gbXB0Ml_CwnF
zT>s^&DK`kGFquzzNrbng&|PNn(>3FKcod^G$1G;iuTHnfYd8=X*TmCpwA}$HI?~}!
zHNvV9F2-06zRGX$H!NdqAu6;;<T3U4$vZRA6@KR3qVJI-yg2?+0NgHR^BioJxh5Qg
z-rbjv>sV-6A)PkrFnY8DtGLH?x)m``9HG92qPlCP9KC8g$<6Az`(fueca7|X8LKxh
z*>)z19h!+<n(HzGeux_~RL9b%#w2{hWApTvN_qB+=H$U@2KC%_=nwVLFU<APb@DF?
z>-+OrIrf#UoU+NbA*t&fx!U^&PmzSbbs*X<T+2GM8^LXKe$~@eqdc&$1{%xbhNr~Y
zz$VHB!u387qX1h#!Di&CL$9o9v`dB~W9b%hH@lxO93&p^lB{Hx^1*sP^!OH-7hTni
zRl**S8o>e<Yh0OCFd_87)Gh29jyEu_j&ji`RE}z@HbS`@=c!78D9Fy{ZE-uxGfMlQ
zk!31wk=xvjT)Brh5|r2s?Ed}t&l^n#pToK2XHSOX><&lVu3{Zl9uLr07Qu!JXy2CO
zJ&oi3oc2M!umL4wU;o!a0rM7(_M?OFOO9iwa@kJ9g6ZtBy3ImeOxd!~wRQ0$5Zw;7
zyE5OStU{CZLin`X1It&sa6#yBa#-!F-CjJfKqZloWg_5<nU!DBN9LKMsmYJg1NfJh
z+lJ~p5q-R89>pDxB2)(deD10DwFCBdD+=kAGasdg*@Opc9$h>KLAd>qa~4$lI%5(;
z1JB6EF;m0O$juC9<_D<au@d#SH@dz^M)NI^NT$`>9q35ki-%D|_8pPw;<}NZ6Y-hx
zxSKT9ph{JZs~r7Gc7yu;&tJB~zbb&S-?oUD5?gZE6TcK1Z)rihP5)^3ED)rT(278)
z_Ty(|PJWoyu?_L^Sf0Y(ov6EQ(1I+Nk7fZ;j^rRI3owd=<vBjzFoJDopYlZSmu(vm
zmAD11iNl`{MX~n}F&3?voi=+q<B2J5*y~9_)n@_yJ#Si@U4R#yptJyn-!8#%Pl&D(
zk9a-;zZsg1@__62LJS*Mq)Yi*_2<!YA>Qb{;V2qSdTKlfeW~+oyBBe8+GGeLyFLV6
zYr-V3%t@Req_MCHO9VcfBH(ZHxew_sXx<iI4+p}(<Vz?f5$20d?N#h;&HfsKO`1yQ
z>I-B?u%H2D6um%Oc!IGWEkbt|c6~6FuDh?E(x074`*a5&0v95wlyE!LH%3`!*nNg$
zkS}6Y3n3NYm=you<*E(R3ah^m)@QtX7fpzcPO85^t=f}}Xj0L!|EkSl3)sLI8C)9g
z`Gy7?O!1a^PTDsy2r+N=KJ-yjr@O(T?(oT8>{7Tp^8fC?nbDaHN%g<Gk`;?$7dubC
zS-tnWU-2Y=o>u0lx{E(N98G%~V>mE{iS{gbE@bR08He;tQ+cV6LfD}`iY80$r?dM-
z6;^Kfi%&oEL3WtI(Ox<A;T!utTz>dLKdr_fwij`~HShAQW+eLNxHl_C_<mab(V5w?
z6f2TgzG<EcQn-uX+5hLG|Ih=-$h|BW*4XVT-3~ao+gbI7inKm=XTAVLjR|M&yxv#i
zv9|an7V@jEpe^5m#b1LoA$dWclZy_<!D(J8v-`Vugimm%Zq21DQHXMt&c%XA>X;_d
zrn@ZM)=9DY7Vhi7YJJ>x3qnEnZh4ausz;t@nKXvulzaAPwfjqy24mJr^2#QmGD^F2
zABPs;7$dDW%B>`t+15jlVDFT_+9NsD0CHVT_gCLLY7|rcPen>@2|=;nPyZ;kf3W~9
z7^SJN*%}vYp_Te*M`ZrM2c@rUTxvJCEV%M}TKhE<Y;Q#UXi0If&n5e1TF;fY41R7=
zOY%W~-s=1KG`>H#UsX($`%oEJi2H+L!LuC_uOp>SP7#D=)rvNOa@dwecdxHAYK!-$
zP()%RSFRrgG~N=Z!~21o9j{YO1HNvBGMgc&N0bGH7GBp4qfp4P;ihyqy#=WE@GoMt
zorLR>aYG4z{&z+sZ;vA#YPiEcuA*{J7sQQ*Q{ozpbHp1JKiS)Q06%_9mO9;c2$~~G
z!G}Oy0BF?^D8x^_sBa|sl*X7;+2TvIT(j-@W%l2~eQWhm(F3pAC9n9SN(LlFBtkfG
z17U`7Mzv7&tl;zt?xtR(8<DA>xR`?H6NIHH^RH(Ums+9Dz&r@U(uJ|f;qthFr!mP|
zCrh@elVs>fD9b}FtL%P~bh6NI$!_I+a=7$*BO7QMv(S^cT=G)sg@DHSh<iTqR)-Bu
zyne-0UQ@~uh|BM>AL|)+d3Y-0FkcAlEpahSm3LwZU)-kn`P!~EmV21twPvMuvroa)
zr-NXNX&s!1FJmm&k^nS+3F;lKSQ_><a3J_3PgU1MIA;%1Y+dFvFMWYg67(Xz&6|FZ
z7M~7BY`vV>XUZ06;FLUjGnRCsB+%T5r8aoTO0Rq=L2Vt=|L#8bmt=AFRYKv7W&X`X
z=Il)}H;BL1WO3~^8tz8{3>z16-Tm7!(Q?d(IxdEJgAH1sW<|iw{^S@>&a^<qr!9J)
z<B9{$jAat@MIKeq*tqs%#2G$b<rjC1!_sCotZ#k7aK(bZD?7Oq^Blhhn%Z6nkJ$h0
zX%98sR=|=Y`@HULV(LqE_7kq+^Uz9%CYA7)^Y%aBEnHi0;tM8djubW7W@BP3%E}YW
z<E-8@!T>2d_qPUzg+CQTo<`l|TG!?0Qq~FEoI5sgu>5?wGm1pbdsP0OJac;<uB|5X
z%;g=?{ve%U=&f6dOzN9w2|uB4A6|cJV#e>G6dGLZI?b7-<=3y-?chJa#Iz@v8Ow#A
z9~J}};JI%tNzqS~PC8xIx)jSu4F_2o^SK?w)zB|b_t-0ejP$P6CprRUdV_@~PNLZq
z2eF*?T+>Tt-15BoZXV@C47WY+t$e9W^7g-h#lc|GvuFC?!mZSjtYxK_CsRGKj1v<+
zS4^-+!p|S~Jt<OlpASc&7{_8ee;-sbYneuzMyhJ$CPN7TYG`Dd9sGL@<34}V-Uq|}
zuI?1-M(M!x2a*h$G6`2KWrWTfwrUIj$>f<swjw&NAT|*ZYH7a^#wE%jvM{HG_h<%1
zmV4WR%F`;S@Y%QsE`gc)N7BJYJ}Hn`g!m|x0hF?edglLY@wKfOiN=U&$4=vdd(ed>
zb_IGinUJEFmu`XPUQ3*35vcGSA?MM!m}I$66djMYtC$@A%FG#2I!@27(`hg39fHFY
z!b=H`yviTsUU-hZ462~Ey+pabV(sVWW`&fQ0El}2YH%(cM$4N4zHh5PwksOU8iXxm
z{{CX=@{=r$v~;(Wr2mPE-G#;;vvv|9gSl6OGmYbn`J3v(WAbxbtN%;bpG#DQjr_6J
zRW{ourtZk>F!u^O4h)oPk9E6-V{AP>4UkEN1R$W*tz#r1SlhYt#p@7P+gW(ai(Udb
zFngM*P^!(E!q@o;F8}ZEc6al2P>U*7(J-VEiiIDk9m=;vD2~fQ4_B~G=-lrQoPW9O
zB6qF{I?%pu`Z43tA7g>EoE@DnizIY)2E5O|Npb2<&yUnQyCXUOBqa9GIww{TB(TrA
z$E#tnX4MMA0#s^mi@Kb~cu`vm8D|K>&zvGt4=A8Na}$PtMzHMYPS2&$5^<crYwn|Q
z!tX9_hFx9%An`}*ZZ1aGkcuP=my#r_rz|r7qs>f>ByMkQ`F<DPOhRUgD>!Kl&4-CL
zSn_!rE2rPCE^^Ri-Ru~2Fs^)3059Y}LccRW)FxE&%CHj`l~6QpqMqKv+;M$YG3K)1
z)<7~Dcx7^YH`-;G9}!+mv`r8ox<5Bhz|~`3)-3>h(yIuRSATKcSVyP3m0I$U^ZgZd
zDFq*;TMvratB8pekA##=j@D`K2x*+y{t!?SOw3GezTgiUnUF9p4XnDota5Ka9u^P4
zflQf)Fo%A*XT7a}Yit~Y^3UEX`Qn5j17q$@)aIh^Q9pWLD_)vR|9GlU+a5*@+8^$4
zk%F)UKYk>bqsl*)FC4Ti>LDwS8;(su^)#Tlmi|1LODmR>;;Ui_LFT#CPrWu*DXd}6
zMP0jWnLfQYi1n=UY3Yc|{>2?{RT=bYP<PdfjemKIrL4Rw$_GxTVt$K!7W5#Pq4W3O
z%Bu89zNCGf^~xd9+m5AaNd4kUAkV;h!H#?0pn4^+v-)R_+%0k4qdxW7$V};B))nSd
zNK-3KgObR{e4U9MT}GqNJg1l4RvcKhKh09kU`}Jl47O>LiCf#UEiKqtll0LW8fTyH
z_bZh>PV;Ay0!OVXJqkQZv7fJ+Ud;<~!7B-cfKHs-1&J%{f=iztePj9}->lC51U?07
z?kErky+uB}><J$St=U}%BrUm9j(%1BqU6ID8@`7{17|0}!S=C1QkF7JK$8#J?Tc9b
zv@ZPTq>-eqDzj*vKy`qkt#bPDW`tZvre4j;&h#%@+$-TzP&(&#M;Gi-F)f)WSal7u
zQdFQ92{gN7`J4;gD3anca*-7qx$X7+ZMOJ~2>-wlc2T?+kb<yDSBl+KMztMg<G#y}
zKJf%wz092kCP*m#mI!vG-^TI*O?}p_4Oe*H8gaC#-x^y=4*lBWPVD(y)N!W}rn?VR
zr&R*EAGK2%WLH%nG2UO@jQ}}@gB*L#JXK`Y7WC8gx-0H3NgW!$D1UhU*cThsb5wTw
zPm$<_#r;}qO2^%QB)vrZ#3>J_xP4TH7~;ZGQJ7=G<6lgc=?JR>r5JF>f8;tbJuyM{
zY&Z*3zxGMShfehB=Sw_xSpLolmYmDlrRvNn!XgXJM@9${pg);Roca+g{-iAx%#a-<
z`dSb19Hjho02ZS<7JS$e#wFPCUK%`@(pB9=2-H7~)_vcWQ~W;rF)*MxeeZ>jTHWyE
zkL-x5e(QhP3)y`x_z5B3l%puGkJ2;y4b0207wc1JHqo0@t`a*cztOWcY}v6jN=y4u
zW1TvKXxx1uKXb5(XgZl|B!rtF%r<gAMgBtBzQ)ToXOK6`MlX_{#0CjC$&m74Egoxn
ziF0W(JSAka$-|Z!VJMP!|C&WLeT#Ch*r@g)nAKsJ89Rrk0JVd^v)`V?*Msgnc9VJY
zWz*~57j64Vi~FpT7pTP4Ow#KD;jS-^xw3c`G%Q{(_KzUX^PpZh_Z_MO$1ES2a(|>w
zW$oBlpU;y;gePL{wfPTN?3K?Hqt4x}CMRotVIKzDlht?jo9MxN8;Gjs#-H7;XT(`f
z#)2rOgPPnRqx?}k3)NIhB4s7z&^)Ko!ns1`s`Mval8?A7gM&hP7q_VbW+Zx9we`h=
zSPg6eB40jzn)w7=`)V64+EprV?XwQvV{w|Ac{JNNbW_jL5FCIQ|1MKeA9LLDZDjG^
zv`I#~A&xCNn|OlnyKE&tacspYZ2vdY+EOTj7*wC;kau&$`r5q!4KZE3?`y!LinV%O
z$_wr@NVpTY;*>4yQ)Yz<^sRIo582%3=?bt!>*gQ25R|>v+vN2nFN)+sMlW}86z;#=
zw_F6i*;nbv!rngw>#HMvkIa{DKOvk7&iLbZL!V(f+cK3myL^j0r1+{jRnk{_5YkzW
zQ`gec{!4Ep-m5!9d#X;@S%Goq1j7j(p$Z}tLq?RVwy<Y+|JAdswES6);In}G>>0i?
zWwkF*w{7B=fs>8kCfr2vCCBVBI?(4UeuM0lfu*0b#M8_3LuW5yr}LrJM4NqHujq()
z_2YD=)${r`acOT6lV#sma#b3?ieqv25Ccnts~ECzD={PG{TK{G+O{u$#pjVaOliRy
z7t~wUskJWM&MjY7`XPmt7dpwKd42HbDHgaiUId8=EqV)@Id`na<v;8qj8dnyMR9T@
zy7G5Vgls&^HAy>hZ-BX}YPHIxxX1p@Gek${h!eS7L^TW>3H_exVzG=lbNV&VxlNVg
zh(X8ZspC4bTB`f|r1_(V3oRQ}h5$QL;kF0OOJ;w6(XTsy!d!3h4lK2QX#I9K`Kk}v
z^eSir+dHrb|MLK4e$D(k%<>IC1AIs?EX+Ar%@c-+SD2@u?d>@{QDgt_;9@#yJ@@3K
z*;ij*-pNYVYN#`gxtTLc)1Ce3^jOUsJ74Y=F)q%ZTdjuXs<l(!a?gToO|8a3Ze{2g
zxKB}LF?JJ6yyb@Rc&&0L`EPQtjB$QevOX$9pIAojyD>a`P|ibHSx;5sR;<v)qM1Ca
zPzBGDq0%97{D!TlxDufNJFBsqwT0nLoSx`*ff4q3T)C^Tn_{uYCmi{oA)KkipPq;d
z3SxU<FPVe`=zM6Ui&LKytALW!LY!T6sYVjBvb~N*)>JP1>%n%W-%k_Wrx`;uSjD~=
z2vu~8k|ojz_K6^Rwf&eZi{BV)uk8tv&6dH<QB_s7<TYR6ZR1UiOs4-hWyx<rooLNU
zRXdj{2cs`EWeeMfxMnCApp4#3wJOz4K#YWp6A=HL+Qi3gmpI;JjR`UtKy~>2kB_&G
zE;FG*YwKcOjW149EH@)orP{`V+E^Y}Tx8-fOgJuq)?C)<G>Kup%qcbu7Db4shiy(M
zTWwLJU!kx+?7VP3vPtEeGd|&goxzUSEZ?feIx*>Lw$#h<YB@!HNpj8OsVH%d&N_**
zb?3J+VYIg^Q5N5f74w)kUU_T+J-gE#o8$XCec`vD%=^BXwD;ul(i||;x7NnuE^1zn
zJBK6&)3YM2%xMdp-UQ2Z!Nis|$Um&qrB#N`L9URWsy4#zq;!jk)rwh)+q5m5`*?hP
z5DqUyj3&p;%Vyf0;{$I%G%#IP?;0W2o;iyWBI{#HEnYr3*koscepoX|aaungS*5N1
z9rRF2W^JL%x;4DPzZSc9cu;;l$eoi~sH8IuQ-08x=kNa!Y$4|K!IYXo*?B`%?*Qya
z9wpJQQi1&RQ`kKY(cQhZGz~oBZeRg#?1eYE#|kk!(~{r!@MS?xAJdap|K_NMQkDnK
zgEDRZ?LVjZqdIKa$IFv)L_XmF`EImtQ3hvXpKj0gV<0N$`16R8AuhZz6JAc~d|GVS
zyw#UBP_1MCwmNk*Sz8G2O@4-IQA|g|WKI$&la(mFnX%uR<3;iIU#T^ig1*T}nCpg^
zR)E<+eyB)oAfNu1`@XQcwWSVEZCWQXJ6oj2o-uFcTJEUjH!yB|=dW92xy&|g1NUUs
zfB3rcvO>?p+Um(9^R_hH=K8D)OC;bYmBa6+waV7GnOcsYGAMG)$DEGUoD~M;?H^7{
z`6)uoR5TBH1ks!0Kf7rbG!+iURMKHPshH-IDM&N!4>wB;>2XF~R8i!6s4W!ZAkqjm
z5~sKr<R<E=CmXoWg`}C&3UXh*IZPw+?zecbZznuN25x*jPTZ<x|NACvYHevA$UTzw
zxy<Cv>he36M@H1^>f}aW3(G|;v5q3kH~8!~pkAu+@|JF=r|Lo+7m3!?iuLNK@)MF~
zS>jeu^SGVGT28MFgLN5C0TF=2MLNMtg}JBqIt?R1#$)5M1!!>iIPBVjHs)xoty;Le
zXtkAHGk+rFilv*<_RY^wM4u&#BN|+sPZ50!7~RSwQSqVA^t_`TwKw&f{uWqo(v<Bu
zi*kdLa!c3ZK>MdMY7=Dn@p#RqHoALs$Q&Q9W>gOm*#`gllLdZv_SY%bpvkXO4j&>(
zTjInh1ON8BL2Ym^*8~AM29`+P@j7)>plUwV{9lo8?nSVa^0jmpXHw0}>=7$=Aocs)
zVFO=nhdq@#r}Eu(^}OU~BNH8Ni){Tm(cm*1Hz!bqx`f172+T~toGj;F>`m2m8KJQZ
zwOqR%0|9Z4tL#`<awd_HddF=F`$<x|*z!u2!Y~ue`odOKf`~e9!H)^WejoDeg4FnM
zdQiEe$}q@Pl&hkHqlsb!zWLjzY;pKs@+)DHk8K_`%!fKU(=|ye!w$^VxL=p>FJ$B&
zHdi;@o4p1*_rrldN*j3Kk&GfR*62`aKF@0@@l_Olj~k~Mc6{*boc?OcpJ%l8VOfJg
z|BILya8fB^*h+dGL<<kXF=SAOOV>tHj#Guf@2ATxF)9`sr^}@&5OM$XD><vMz~`GI
zOh!qyo)5Qlp(6@uSbCZ6`9jy%9GUS6Ik!^#p*ToXA7zDWcXxSnF^!IRhp>r`v3^T^
zxrd1?wT@0+Wt9P819Jl{3k7LRsu=qjf#1Ja6`M}OPB>sZ!>ql!x6HKf_a!x4dVY3H
zbiu9T2qT1ZU!QU<Vp;BgOzwkP%AM&=6qnWEDn4<^+_apX5xkK=-Bz(O9TK4?O>U4B
zJK6WwC~<n-;s%j$72Elea7V;1@^5Cf4AQW&dCLr1$1*hCZXdy;P4!*Kag5T-ozAS{
zBc0lhwR#+B%jx8Xyoq#X_3{U5fvi7RsAEznN?R8;3&>1v?<HR~3Pma10^Ni$BWsu0
zN3zV>KOWO<#ZvH2UEn=VpbC+sh;kQ(IYCrhEA;wPNwqhe+{ZYd*m$w}jfyn6XUoKi
zPGo45(|8=H+>JqIdC*mzA%7%XOT!{H%-hs9irj1&!W`o!3?Zl+ftr{lByEdMUAI~w
zwEzSouhXxrZYAUw$UijK+Wl=ipZhs;rsDglTN`$T_N0{mK>oBPQ>-(0;}v;I;J2$w
zFUt#!9HT9L_4L!NvBWCOFP&RCLp?$8ded7uEl7SWUJj73K{{Igls~ZCZoB)N+QMqZ
z(Whc3qxLuNyX9{Hd|##UdVoh?y<;c0SFHm*8T#j$rD?~MF5yt<aq}`gUDO7blJsGH
z$e37>QmJX$!k(EbYcy7pPOHRK7GV57%THoHc&adIxl>h_aeM-a7mAC76lPE}EVQ3b
zaLSXNs9+Yi!znoOQ-)YiJcX_0&5OD>-!w&!$V&eHnuXDXob>oFM<~3&^47~It*e2-
zyUM^CxbI3`P{2^bkwGD;s#%n+$4&b<w%qrNrx0OJkvgm=&U?Sg<kn@B{z)=Zn+hw4
zXCTbPGOAwYQyY%`=Q+A9yBLZpTLPAq1_<e2@K3srZb=pu7|o|Zey`G{X(}Eu6x=i_
zQ+ga_AMZrgnuJYtR_A2{rt1~><>DU(5WMjO=X5$(b*(%d`X9q%DG~!+p9p3MFh+l$
zCT$D$Yhd9yno=hY9U@}4cXCAy!L{WclaR$!@YBsGIZ+!TRZRN>0V=n&NScbi-+;3#
z{O>FWfm2SQ3|xAC>bGgY7cSx$s>4hfCe8rs#*(ZoF<UtfOiQvDFUeHZU2v2pN~4HA
z;j(k^%Pv6pmemZ;UqrGK*$hb(zABZ6P2NB=k8`0Gm=CXCW*2sy7G!22Z-3?Jjv>j?
zwC6PzYIOZACE@exNx#~uI(^<pa?A0crc_7L10;8a?^`GT0+O}uTukwO$z($C)u$^A
zkv6O#Mw~{3OvnJHaK|h$vUvd(;K682SfdAqae9u`3>n!!#Itl*R$%;cnK?~2jmCLd
zEq520)t+)w)F{0Vram_{d&R#An)zk9!-k%pw0}vYB3s#FCi|Y_SVlb_6vpxK{)qk!
z;O6e@rsZxHvU22|@tqDwjhp0PiTx>%`j9$`?|Gb|TVMM}bRGx136qCNp>14BTRhp}
zX=HsjUNfU090o5DmnHMl)y87V%Xt*zwpajc*7lJO=csC}srP*JIj%ZQp_AUwk^Gu!
z900WZLQKTx!F;H#Q*1XgN9aNnd@)qQvCZ2J9@{H092gJxV!EC6+DJC;vpBjEz$9Od
zWR(^%^?zH>8_mhPe<g3gB=<#$9VrUQbQG2)xPR&Aum%%vKOJ4Hcw?UZ3Ampomp2VI
z$rz)r{!xP5-q#04A1Mmd{HnY>mqjV)4Zi(_TqORwDb5{LA9VlXKvBLWg{Z_l&O8Ct
z&={b+y0>5t(Y}($57EAqM-2IKg>1v#aDdIOF-<rAM@A@%5%lrEs5oEwhexbCyT&lx
z_-`5FEXMthRz}4M%0Jv<x&Qx%<CVI1&PUTd(kl=S;?BK2i!Kv(A@7-eB8{<G+!<_g
z-)>9W4Tq85?gmTSoupq`ChVWv_Z;fkgkIO{MvdGZ-<;C?1_tC!*9_fHJ1c~o?k@^P
z8oIiGF9C&OkMnhO1G*C4r_&osQSCdguY?p##J$dUbMPx!7+c*zN0~NCQ61aD-3QZY
zdk)S-y^ry9(jB6{&tVSANn220lP(3DP%nh<e66Xjq4#Y_R|6z1Z`wmR<U+iCr7|`b
zen%1VuPW`Ap%0eJnyLFKphUW1vtLYZ#E)pidyD6JbAk?HdNn>9ubXAYp1jr40K9Ln
zh<5hdU43Pv8>#nuz7H}~ih}gG*v{;0=i>Jl>LyXFCZ}RhKD&=Wji0vrK&g(vA%^!7
z%%pyfZ%w)`%Q&)0XOH8vEb2Bal25|eQbwpeU*OZbZWWnKpPuKkAhcZug7T)_7xyd;
z39O{h!eC<08J0@o>oQPM?=u?lfWVHp=Pp4xHf7(j&L!r~>piqycjxW7W<UT!>c5w>
z-*85>9WVpIJ{NrjqC+6R?e3>5k{}^w_veNhyY)fM#d|%50J@6e590(eu<4KE7YrR#
zH@jIoeP9jl+1uGIfi#>C9l7a7vh~H{&%H*TiKSZckJ{fcQCAMQ$%H{f<>ZqEY2@rm
z%$bbtHKF=Irp}V1lsF=kUVejebpZj@CRXx-w2j5-Ci3PuXK7ETIlPK3keA8_i;&3C
zg}%SuTLj?F?A6X8;qGl$u}yZP5kjK+0SA?po}0fn?9e%(a&YHR6nOUIfLCCd>r1=p
zZ!F`Z(SR!>EwVy~m}Gm|?PT`G!SD*y3$t)4igRw~jepO!RdiT<G2H_m5vu|1ACPC>
zfrb%2^*{dcUervRhW-%_J{+#7IZ_DD=;#j|%{M0CKiY2FYGi~FqkVj=;x{hBkN&h?
z&8utCX?SQT&(koF5^-(>RXIocZvjt2Uezjz)WMBKMVhiwEu7o9y69ofr=4;!-~q_Z
z{yrCRpmA_-y!u@LY2*_E^6NH-GYTcihjW1jyz`OvP!CHMac^w2mH0fW1eS;=><xgR
zFS$5HHx4C)`l=_7ONy3!ohjm`$sY-ch5guD6*7O#rE0ox-B|A8@K{(LvbcDp-Ky~R
zB3L{J`E(JGm^`#}$59wx1GyzjNIskp4*=SfH-sP+y~zRdE;LLsXLf%13DmzXUnh&x
zh+#bQ*Z20h@iK@#)niG(zXliu-9>I3^jQQ`i$D4>%V3GoF7Eh%n%CY+B1f`bLJaQL
ztZv`z_dtKv-Wno{+^pYb2yk?Ec>cY03}LYNL3cWEVQ;!K-_(k5bet~Uz~3U50>Gm3
zqD1x4Z?8pcwU2`#pc#xxQC8Ccy|$4Mh7?n!J<;coiD!xbK!-l$V*UT24u4qx2Rej>
zLxcH$vyt!Q;eW~h;E(@@l!S%DgZW=p^1oTe|FDw(D=hEH|0()k<m7*x|F?zzuGoK=
f$N!bG_vC*OkYAJ$k^Ykj|9-T;UrB`ibNBxN^b#1h

literal 0
HcmV?d00001

diff --git a/py/热播.py b/py/热播.py
new file mode 100644
index 0000000..1ac101f
--- /dev/null
+++ b/py/热播.py
@@ -0,0 +1,184 @@
+# -*- coding: utf-8 -*-
+# by @嗷呜
+import json
+import sys
+import time
+import requests
+from base64 import b64decode, b64encode
+from Crypto.Hash import MD5
+from pyquery import PyQuery as pq
+sys.path.append('..')
+from base.spider import Spider
+
+class Spider(Spider):
+
+    def init(self, extend=""):
+        pass
+
+    def getName(self):
+        pass
+
+    def isVideoFormat(self, url):
+        pass
+
+    def manualVideoCheck(self):
+        pass
+
+    def destroy(self):
+        pass
+
+    host='http://v.rbotv.cn'
+
+    headers = {
+        'User-Agent': 'okhttp-okgo/jeasonlzy',
+        'Accept-Language': 'zh-CN,zh;q=0.8'
+    }
+
+    def homeContent(self, filter):
+        data=requests.post(f'{self.host}/v3/type/top_type',headers=self.headers,files=self.getfiles({'': (None, '')})).json()
+        result = {}
+        classes = []
+        filters = {}
+        for k in data['data']['list']:
+            classes.append({
+                'type_name': k['type_name'],
+                'type_id': k['type_id']
+            })
+            fts = []
+            for i,x in k.items():
+                if isinstance(x, list) and len(x)>2:
+                    fts.append({
+                        'name': i,
+                        'key': i,
+                        'value': [{'n': j, 'v': j} for j in x if j and j!= '全部']
+                    })
+            if len(fts):filters[k['type_id']] = fts
+        result['class'] = classes
+        result['filters'] = filters
+        return result
+
+    def homeVideoContent(self):
+        data=requests.post(f'{self.host}/v3/type/tj_vod',headers=self.headers,files=self.getfiles({'': (None, '')})).json()
+        return {'list':self.getv(data['data']['cai']+data['data']['loop'])}
+
+    def categoryContent(self, tid, pg, filter, extend):
+        files = {
+            'type_id': (None, tid),
+            'limit': (None, '12'),
+            'page': (None, pg)
+        }
+        for k,v in extend.items():
+            if k=='extend':k='class'
+            files[k] = (None, v)
+        data=requests.post(f'{self.host}/v3/home/type_search',headers=self.headers,files=self.getfiles(files)).json()
+        result = {}
+        result['list'] = self.getv(data['data']['list'])
+        result['page'] = pg
+        result['pagecount'] = 9999
+        result['limit'] = 90
+        result['total'] = 999999
+        return result
+
+    def detailContent(self, ids):
+        data=requests.post(f'{self.host}/v3/home/vod_details',headers=self.headers,files=self.getfiles({'vod_id': (None, ids[0])})).json()
+        v=data['data']
+        vod = {
+            'vod_name': v.get('vod_name'),
+            'type_name': v.get('type_name'),
+            'vod_year': v.get('vod_year'),
+            'vod_area': v.get('vod_area'),
+            'vod_remarks': v.get('vod_remarks'),
+            'vod_actor': v.get('vod_actor'),
+            'vod_director': v.get('vod_director'),
+            'vod_content': pq(pq(v.get('vod_content','无') or '无').text()).text()
+        }
+        n,p=[],[]
+        for o,i in enumerate(v['vod_play_list']):
+            n.append(f"线路{o+1}({i.get('flag')})")
+            c=[]
+            for j in i.get('urls'):
+                d={'url':j.get('url'),'p':i.get('parse_urls'),'r':i.get('referer'),'u':i.get('ua')}
+                c.append(f"{j.get('name')}${self.e64(json.dumps(d))}")
+            p.append('#'.join(c))
+        vod.update({'vod_play_from':'$$$'.join(n),'vod_play_url':'$$$'.join(p)})
+        return {'list':[vod]}
+
+    def searchContent(self, key, quick, pg="1"):
+        files = {
+            'limit': (None, '12'),
+            'page': (None, pg),
+            'keyword': (None, key),
+        }
+        data=requests.post(f'{self.host}/v3/home/search',headers=self.headers,files=self.getfiles(files)).json()
+        return {'list':self.getv(data['data']['list']),'page':pg}
+
+    def playerContent(self, flag, id, vipFlags):
+        ids=json.loads(self.d64(id))
+        url=ids['url']
+        if isinstance(ids['p'],list) and len(ids['p']):
+            url=[]
+            for i,x in enumerate(ids['p']):
+                up={'url':ids['url'],'p':x,'r':ids['r'],'u':ids['u']}
+                url.extend([f"解析{i+1}",f"{self.getProxyUrl()}&data={self.e64(json.dumps(up))}"])
+        h={}
+        if ids.get('r'):
+            h['Referer'] = ids['r']
+        if ids.get('u'):
+            h['User-Agent'] = ids['u']
+        return  {'parse': 0, 'url': url, 'header': h}
+
+    def localProxy(self, param):
+        data=json.loads(self.d64(param['data']))
+        h = {}
+        if data.get('r'):
+            h['Referer'] = data['r']
+        if data.get('u'):
+            h['User-Agent'] = data['u']
+        res=self.fetch(f"{data['p']}{data['url']}",headers=h).json()
+        url=res.get('url') or res['data'].get('url')
+        return [302,'video/MP2T',None,{'Location':url}]
+
+    def liveContent(self, url):
+        pass
+
+    def getfiles(self, p=None):
+        if p is None:p = {}
+        t=str(int(time.time()))
+        h = MD5.new()
+        h.update(f"7gp0bnd2sr85ydii2j32pcypscoc4w6c7g5spl{t}".encode('utf-8'))
+        s = h.hexdigest()
+        files = {
+            'sign': (None, s),
+            'timestamp': (None, t)
+        }
+        p.update(files)
+        return p
+
+    def getv(self,data):
+        videos = []
+        for i in data:
+            if i.get('vod_id') and str(i['vod_id']) != '0':
+                videos.append({
+                    'vod_id': i['vod_id'],
+                    'vod_name': i.get('vod_name'),
+                    'vod_pic': i.get('vod_pic') or i.get('vod_pic_thumb'),
+                    'vod_year': i.get('tag'),
+                    'vod_remarks': i.get('vod_remarks')
+                })
+        return videos
+
+    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:
+            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:
+            return ""