From 7e161af3d41858af3444addb2c64654f7108373f Mon Sep 17 00:00:00 2001 From: gyjune Date: Tue, 24 Mar 2026 06:47:45 +0100 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=8C/=E3=80=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- sdtv.py | 190 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 190 insertions(+) create mode 100644 sdtv.py diff --git a/sdtv.py b/sdtv.py new file mode 100644 index 0000000..3613863 --- /dev/null +++ b/sdtv.py @@ -0,0 +1,190 @@ +# -*- coding: utf-8 -*- +import base64 +import sys +import time +import json +import requests +import re +from datetime import datetime, timedelta +sys.path.append('..') +from base.spider import Spider + + +class Spider(Spider): + + def getName(self): + return "山东电视台" + + def init(self, extend): + self.extend = extend + try: + self.extendDict = json.loads(extend) + except: + self.extendDict = {} + + proxy = self.extendDict.get('proxy', None) + if proxy is None: + self.is_proxy = False + else: + self.proxy = proxy + self.is_proxy = True + pass + + def getDependence(self): + return [] + + def isVideoFormat(self, url): + pass + + def manualVideoCheck(self): + pass + + def _get_stream_by_orgid(self, orgid): + """根据orgid获取该电视台的所有频道流""" + api_url = f"https://app.litenews.cn/v1/app/play/tv/live?_orgid_={orgid}" + + headers = { + 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36', + 'Referer': 'https://app.litenews.cn/', + 'Accept': 'application/json, text/plain, */*' + } + + try: + if self.is_proxy: + response = requests.get(api_url, headers=headers, timeout=10, proxies=self.proxy) + else: + response = requests.get(api_url, headers=headers, timeout=10) + + if response.status_code != 200: + return [] + + text = response.text.strip() + if text.startswith('\ufeff'): + text = text[1:] + + data = json.loads(text) + + # 检查返回码 + if data.get("code") != 1: + return [] + + # 返回data数组 + return data.get("data", []) + except Exception: + return [] + + def _fetch_all_channels(self): + """获取所有山东电视台频道数据""" + # 从之前测试成功的orgid列表 + orgid_list = [ + 171, 303, 85, 261, 257, 97, 195, 537, 29, 163, 237, 269, 153, + 403, 227, 221, 305, 173, 295, 253, 45, 1, 71, 133, 125, 175, + 189, 255, 57, 239, 109, 165, 55, 17, 61, 23, 203, 75, 101, + 243, 233, 103, 37, 207, 211, 169, 277, 11, 193, 19, 33, 235, + 27, 135, 273, 13, 73, 117, 231, 31, 265, 65, 183, 81, 191, + 113, 201, 167, 147, 145, 159, 289, 187, 293, 51, 59, 213, 77, 91 + ] + + all_channels = [] + + for orgid in orgid_list: + channels = self._get_stream_by_orgid(orgid) + if channels: + all_channels.extend(channels) + time.sleep(0.1) + + return all_channels + + def liveContent(self, url): + """主入口方法，返回M3U内容""" + # 获取所有频道数据 + channels = self._fetch_all_channels() + + if not channels: + return "#EXTM3U\n# 错误：无法获取直播数据" + + # 生成M3U内容（严格按照模板格式） + m3u_content = ['#EXTM3U'] + + for channel in channels: + channel_name = channel.get("name", "未知频道") + channel_url = channel.get("stream", "") + + if channel_url: + # 严格按照模板格式：EXTINF行 + URL行 + # 格式：#EXTINF:-1 tvg-name="频道名称" group-title="山东电视台",频道名称 + extinf = f'#EXTINF:-1 tvg-name="{channel_name}" group-title="山东电视台",{channel_name}' + m3u_content.extend([extinf, channel_url]) + + return '\n'.join(m3u_content) + + def homeContent(self, filter): + return {} + + def homeVideoContent(self): + return {} + + def categoryContent(self, cid, page, filter, ext): + return {} + + def detailContent(self, did): + return {} + + def searchContent(self, key, quick, page='1'): + return {} + + def searchContentPage(self, keywords, quick, page): + return {} + + def playerContent(self, flag, pid, vipFlags): + return {} + + def localProxy(self, params): + if params['type'] == "m3u8": + return self.proxyM3u8(params) + if params['type'] == "ts": + return self.get_ts(params) + return [302, "text/plain", None, {'Location': 'https://sf1-cdn-tos.huoshanstatic.com/obj/media-fe/xgplayer_doc_video/mp4/xgplayer-demo-720p.mp4'}] + + def proxyM3u8(self, params): + pid = params['pid'] + info = pid.split(',') + if len(info) >= 3: + a = info[0] + b = info[1] + c = info[2] + timestamp = int(time.time() / 4 - 355017625) + t = timestamp * 4 + m3u8_text = f'#EXTM3U\n#EXT-X-VERSION:3\n#EXT-X-TARGETDURATION:4\n#EXT-X-MEDIA-SEQUENCE:{timestamp}\n' + for i in range(10): + url = f'https://ntd-tgc.cdn.hinet.net/live/pool/{a}/litv-pc/{a}-avc1_6000000={b}-mp4a_134000_zho={c}-begin={t}0000000-dur=40000000-seq={timestamp}.ts' + if self.is_proxy: + url = f'http://127.0.0.1:9978/proxy?do=py&type=ts&url={self.b64encode(url)}' + + m3u8_text += f'#EXTINF:4,\n{url}\n' + timestamp += 1 + t += 4 + return [200, "application/vnd.apple.mpegurl", m3u8_text] + return [200, "application/vnd.apple.mpegurl", "#EXTM3U\n# 错误：无效的代理参数"] + + def get_ts(self, params): + url = self.b64decode(params['url']) + headers = {'User-Agent': 'Mozilla/5.0'} + if self.is_proxy: + response = requests.get(url, headers=headers, stream=True, proxies=self.proxy) + else: + response = requests.get(url, headers=headers, stream=True) + return [206, "application/octet-stream", response.content] + + def destroy(self): + return '正在Destroy' + + def b64encode(self, data): + return base64.b64encode(data.encode('utf-8')).decode('utf-8') + + def b64decode(self, data): + return base64.b64decode(data.encode('utf-8')).decode('utf-8') + + +if __name__ == '__main__': + pass \ No newline at end of file