自建DIYP影音和TVBOX的接口PHP服务

q553909884 · 发表于 2024-1-2 11:03

我是来思考的看看

axiu0823 · 发表于 2024-1-2 15:08

自己捣鼓了写了一下，可以一键更新list表里的直播源，配合和楼主的xml2db.php用计划任务可以实现每天定时自动更新直播源和节目信息

每次更新时会删除之前会清空一次list表，把获取到的CCTV频道像CCTV-1到CCTV-17自动转成CCTV1 CCTV2，只适用于内容是以下格式
央视频道,#genre#
CCTV-1 综合,http://[2409:8087:1e03:21::2]:6060/cms001/ch00000090990000001022/index.m3u8
CCTV-2 财*,http://[2409:8087:1e03:21::2]:6060/cms001/ch00000090990000001220/index.m3u8
卫视频道,#genre#
凤凰中文,http://[2409:8087:2001:20:2800:0:df6e:eb24]:80/ott.mobaibox.com/PLTV/3/224/3221228527/index.m3u8
凤凰资讯,http://[2409:8087:2001:20:2800:0:df6e:eb27]:80/ott.mobaibox.com/PLTV/3/224/3221228524/index.m3u8
上海频道,#genre#
上海都市,http://[2409:8087:1e03:21::2]:6060/cms001/ch00000090990000001015/index.m3u8
上海新闻,http://[2409:8087:1e03:21::2]:6060/cms001/ch00000090990000001014/index.m3u8

<?php
// 数据库文件路径
$dbPath = 'channel_epg.db';
// 打开或创建SQLite数据库
$db = new SQLite3($dbPath);
// 准备创建表的SQL语句
$createTableSQL = <<<SQL
CREATE TABLE IF NOT EXISTS list (
item TEXT,
title TEXT,
epg TEXT DEFAULT '', -- epg字段默认为空字符串
url TEXT,
isdel INTEGER
);
SQL;
$db->exec($createTableSQL);
// 清空list表
$emptyTableSQL = "DELETE FROM list";
$db->exec($emptyTableSQL);
// 准备查询现有记录的SQL语句
$selectSQL = "SELECT url FROM list WHERE item = :item AND title = :title";
$selectStmt = $db->prepare($selectSQL);
// 准备更新现有记录的SQL语句
$updateSQL = "UPDATE list SET url = :new_url WHERE item = :item AND title = :title";
$updateStmt = $db->prepare($updateSQL);
// 准备插入新记录的SQL语句
$insertSQL = "INSERT INTO list (item, title, epg, url, isdel) VALUES (:item, :title, :epg, :url, :isdel)";
$insertStmt = $db->prepare($insertSQL);
// 网站数据源数组
$dataSources = [
'网址1',
'网址2'
];
// 初始化isdel计数器
$isdelCounter = 1;
foreach ($dataSources as $dataSource) {
// 获取数据
$data = file_get_contents($dataSource);
// 将数据分割成行
$lines = explode("\n", $data);
// 当前分类项目
$currentItem = '';
foreach ($lines as $line) {
$line = trim($line);
if (empty($line)) continue; // 跳过空行
if (strpos($line, '#genre#') !== false) {
// 新的分类项目
$currentItem = str_replace('#genre#', '', $line);
} else {
// 分割标题和URL
$parts = explode(',', $line, 2);
if (count($parts) == 2) {
list($title, $url) = $parts;
$title = trim($title);
$url = trim($url);
// 替换标题中的指定字符串
$title = preg_replace('/CCTV\-(\d+)\s+.*/', 'CCTV$1', $title);
$title = str_replace('CCTV-5+ 体育赛事', 'CCTV5+', $title); // 特殊处理CCTV-5+
$title = str_replace('CCTV-4K 超高清', 'CCTV4K', $title); // 替换CCTV-4K
$title = str_replace('CCTV-8K 超高清', 'CCTV8K', $title); // 替换CCTV-8K
// 绑定参数并查询现有记录
$selectStmt->bindValue(':item', $currentItem);
$selectStmt->bindValue(':title', $title);
$result = $selectStmt->execute();
$existingRecord = $result->fetchArray(SQLITE3_ASSOC);
if ($existingRecord) {
// 如果存在记录，则合并URLs
$existingUrls = explode('#', $existingRecord['url']);
if (!in_array($url, $existingUrls)) {
// 只有当URL不在现有URLs中时才合并
$newUrl = $existingRecord['url'] . '#' . $url;
$updateStmt->bindValue(':new_url', $newUrl);
$updateStmt->bindValue(':item', $currentItem);
$updateStmt->bindValue(':title', $title);
$updateStmt->execute();
}
} else {
// 如果不存在记录，则插入新记录
$insertStmt->bindValue(':item', $currentItem);
$insertStmt->bindValue(':title', $title);
$insertStmt->bindValue(':epg', ''); // epg字段为空
$insertStmt->bindValue(':url', $url);
$insertStmt->bindValue(':isdel', $isdelCounter);
$insertStmt->execute();
}
// 递增isdel计数器
$isdelCounter++;
}
}
}
}
// 关闭数据库连接
$db->close();
echo "Data processed successfully.";
?>

复制代码

lineagetmy · 发表于 2024-1-2 15:22

感谢分享~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

jjxyfzhy · 发表于 2024-1-2 15:36

谢谢分享，思考一下

caesarm · 发表于 2024-1-2 15:38

真的假的,不过还是先谢了

pantong1995 · 发表于 2024-1-2 15:49

思考一下，感谢分享

qslfz · 发表于 2024-1-2 15:57

感谢楼主分享好资源。

aming.ou · 发表于 2024-1-2 17:12

axiu0823 发表于 2024-1-2 15:08
自己捣鼓了写了一下，可以一键更新list表里的直播源，配合和楼主的xml2db.php用计划任务可以实现每天定时自 ...

建议先自动获取直播源写入临时表 tmp_list, 当确认获取成功后，再清空list表旧数据，用truncate table list; 会比delete更优化，然后 insert or ignore into list select * from tmp_list;

wyhbjs · 发表于 2024-1-2 18:05

可控硅管钢结构贵航股份

famofamo · 发表于 2024-1-2 18:57

谢谢分享自建DIYP影音和TVBOX的接口PHP服务

藿藿藿 · 发表于 2024-1-2 19:45

收藏收藏。思考思考。

axiu0823 · 发表于 2024-1-2 19:49

本帖最后由 axiu0823 于 2024-1-2 20:03 编辑

aming.ou 发表于 2024-1-2 17:12
建议先自动获取直播源写入临时表 tmp_list, 当确认获取成功后，再清空list表旧数据，用truncate table li ...

主打一个听劝，然后我又有优化了一下对title进行格式化的函数，用起来没问题
我现在遇到的问题就是，我也不知道那个memcache缓存功能有没有开到，反正epg.php里的我是$iscache = true也没报错，应该就是开到了吧，在浏览器打开/www/diyp/epg.php没报错
还有一个问题就是，我不能直接在数据库里创建tmp_list表，会报错，我只能在xml2db.php里的初始化数据库那段加上tmp_list表的初始化代码，然后用xml2db.php初始化数据库才能把tmp_list表弄出来

<div class="quote"><blockquote><div class="quote"><blockquote><div class="quote"><blockquote><?php
// 数据库文件路径
$dbPath = 'channel_epg.db';
// 打开或创建SQLite数据库
$db = new SQLite3($dbPath);
// 准备查询现有记录的SQL语句
$selectSql = "SELECT url FROM tmp_list WHERE title = :title";
$selectStmt = $db->prepare($selectSql);
// 准备更新记录的SQL语句
$updateSql = "UPDATE tmp_list SET url = :new_url WHERE title = :title";
$updateStmt = $db->prepare($updateSql);
// 准备插入新记录的SQL语句
$insertTmpSql = "INSERT INTO tmp_list (item, title, epg, url, isdel) VALUES (:item, :title, :epg, :url, :isdel)";
$insertTmpStmt = $db->prepare($insertTmpSql);
// 网站数据源URL数组
$dataSources = [
'https://fanmingming.com/txt?url=https://live.fanmingming.com/tv/m3u/ipv6.m3u',
'https://iptv.b2og.com/txt/ycl_iptv.txt'
];
// 对title进行格式化的函数
function formatTitle($title) {
// 替换CCTV-数字及可能跟随的非数字字符，如字母或加号
return preg_replace('/CCTV-(\d+[A-Za-z+]*)\s*\S*/', 'CCTV$1', $title);
}
// 初始化isdel计数器
$isdelCounter = 1;
// 开始处理数据源
foreach ($dataSources as $dataSource) {
// 获取数据
$data = file_get_contents($dataSource);
if ($data === false) {
echo "Error: Unable to fetch data from $dataSource.\n";
continue;
}
// 将数据分割成行
$lines = explode("\n", $data);
// 当前分类项目
$currentItem = '';
foreach ($lines as $line) {
$line = trim($line);
if (empty($line)) continue;
if (strpos($line, '#genre#') !== false) {
// 提取item
list($currentItem, ) = explode(',', $line);
$currentItem = trim(str_replace('#genre#', '', $currentItem));
} else {
// 分割标题和URL
list($title, $url) = explode(',', $line, 2);
$title = trim($title);
$url = trim($url);
// 格式化title
$title = formatTitle($title);
// 检查数据库中是否存在相同的title
$selectStmt->bindValue(':title', $title);
$result = $selectStmt->execute();
$existingRecord = $result->fetchArray(SQLITE3_ASSOC);
if ($existingRecord) {
// 如果存在相同的title，则合并URL
$newUrl = $existingRecord['url'] . '#' . $url;
$updateStmt->bindValue(':new_url', $newUrl);
$updateStmt->bindValue(':title', $title);
$updateStmt->execute();
} else {
// 如果不存在相同的title，则插入新记录
$insertTmpStmt->bindValue(':item', $currentItem);
$insertTmpStmt->bindValue(':title', $title);
$insertTmpStmt->bindValue(':epg', ''); // EPG默认为空
$insertTmpStmt->bindValue(':url', $url);
$insertTmpStmt->bindValue(':isdel', $isdelCounter);
$insertTmpStmt->execute();
// 递增isdel计数器
$isdelCounter++;
}
}
}
}
// 数据处理完成，开始转移数据到list表
// 开始一个事务，确保数据的一致性
$db->exec('BEGIN TRANSACTION;');
try {
// 清空list表
$db->exec("DELETE FROM list");
// 将tmp_list表的内容插入到list表中，忽略重复的记录
$db->exec("INSERT OR IGNORE INTO list SELECT * FROM tmp_list");
// 清空tmp_list表
$db->exec("DELETE FROM tmp_list");
// 提交事务
$db->exec('COMMIT;');
echo "Data has been successfully transferred from tmp_list to list and tmp_list is cleared.\n";
} catch (Exception $e) {
// 如果有任何错误，回滚事务
$db->exec('ROLLBACK;');
echo "An error occurred: " . $e->getMessage() . "\n";
}
// 关闭数据库连接
$db->close();

复制代码

sdhzzsy · 发表于 2024-1-2 20:11

啊，是个好东西呀

aming.ou · 发表于 2024-1-2 20:24

本帖最后由 aming.ou 于 2024-1-3 09:47 编辑

axiu0823 发表于 2024-1-2 19:49
主打一个听劝，然后我又有优化了一下对title进行格式化的函数，用起来没问题
我现在遇到的问题就是，我也 ...

用phpstudy切换了几个php版本环境进行channel.php中创建tmp_list表，都可以成功创建。
CREATE TABLE 'tmp_list' (item text, title text, epg text, url text, isdel integer null default 120)

另外， memcache缓存，需要安装memcached服务，然后php.ini中也要加载extension=memcache; 这样$iscache = true;才会真正起作用。
至于epg.php中就算设置了$iscache = true;也不报错，是因为代码中做了容错判断。
其实epg.php中增加了一个参数$isw = false; 就算没有缓存服务，由于没有写epg请求日志，所以也可以非常快，每秒钟可以接受20次左右的请求。

热爱无线 · 发表于 2024-1-2 20:59

影音和TVBOX的频道接

账号		自动登录	找回密码
密码			立即注册

[网络视频应用推荐使用疑问] 自建DIYP影音和TVBOX的接口PHP服务

点评

点评

本帖子中包含更多资源

点评

本帖子中包含更多资源

欢迎大家光临恩山无线论坛 /1

[网络视频应用推荐 使用 疑问] 自建DIYP影音和TVBOX的接口PHP服务

点评

点评

本帖子中包含更多资源

点评

本帖子中包含更多资源

欢迎大家光临恩山无线论坛 /1

[网络视频应用推荐使用疑问] 自建DIYP影音和TVBOX的接口PHP服务