mirror of
https://gitee.com/ledc/IYUUAutoReseed
synced 2025-04-26 12:23:24 +00:00
940 lines
42 KiB
PHP
940 lines
42 KiB
PHP
<?php
|
||
/**
|
||
* IYUUAutoReseed自动辅种
|
||
*/
|
||
namespace IYUU;
|
||
|
||
use Curl\Curl;
|
||
use IYUU\Client\AbstractClientInterface;
|
||
use IYUU\Client\qBittorrent\qBittorrent;
|
||
use IYUU\Client\Transmission\TransmissionRPC;
|
||
use IYUU\Library\IFile;
|
||
use IYUU\Library\Oauth;
|
||
use IYUU\Library\Table;
|
||
|
||
/**
|
||
* IYUUAutoReseed自动辅种类
|
||
*/
|
||
class AutoReseed
|
||
{
|
||
/**
|
||
* 版本号
|
||
* @var string
|
||
*/
|
||
const VER = '1.0.0';
|
||
/**
|
||
* RPC连接池
|
||
* @var array
|
||
*/
|
||
public static $links = [];
|
||
/**
|
||
* 客户端配置
|
||
* @var array
|
||
*/
|
||
public static $clients = [];
|
||
/**
|
||
* 不辅种的站点 'ourbits','hdchina'
|
||
* @var array
|
||
*/
|
||
public static $noReseed = [];
|
||
/**
|
||
* 不转移的站点 'hdarea','hdbd'
|
||
* @var array
|
||
*/
|
||
public static $noMove = ['hdarea'];
|
||
/**
|
||
* cookie检查
|
||
* @var array
|
||
*/
|
||
public static $cookieCheck = ['hdchina','hdcity'];
|
||
/**
|
||
* 缓存路径
|
||
* @var string
|
||
*/
|
||
public static $cacheDir = TORRENT_PATH.'cache'.DS;
|
||
public static $cacheHash = TORRENT_PATH.'cachehash'.DS;
|
||
public static $cacheMove = TORRENT_PATH.'cachemove'.DS;
|
||
/**
|
||
* API接口配置
|
||
* @var string
|
||
* @var array
|
||
*/
|
||
public static $apiUrl = 'http://api.iyuu.cn';
|
||
public static $endpoints = array(
|
||
'add' => '/api/add',
|
||
'update' => '/api/update',
|
||
'reseed' => '/api/reseed',
|
||
'infohash'=> '/api/infohash',
|
||
'sites' => '/api/sites',
|
||
'move' => '/api/move',
|
||
'login' => '/user/login',
|
||
);
|
||
/**
|
||
* curl
|
||
*/
|
||
public static $curl = null;
|
||
/**
|
||
* 退出状态码
|
||
* @var int
|
||
*/
|
||
public static $ExitCode = 0;
|
||
/**
|
||
* 客户端转移做种
|
||
* @var array
|
||
*/
|
||
public static $move = null;
|
||
/**
|
||
* 微信消息体
|
||
* @var array
|
||
*/
|
||
public static $wechatMsg = array(
|
||
'hashCount' => 0, // 提交给服务器的hash总数
|
||
'sitesCount' => 0, // 可辅种站点总数
|
||
'reseedCount' => 0, // 返回的总数据
|
||
'reseedSuccess' => 0, // 成功：辅种成功（会加入缓存，哪怕种子在校验中，下次也会过滤）
|
||
'reseedError' => 0, // 错误：辅种失败（可以重试）
|
||
'reseedRepeat' => 0, // 重复：客户端已做种
|
||
'reseedSkip' => 0, // 跳过：因未设置passkey，而跳过
|
||
'reseedPass' => 0, // 忽略：因上次成功添加、存在缓存，而跳过
|
||
);
|
||
/**
|
||
* 初始化
|
||
* @return void
|
||
*/
|
||
public static function init()
|
||
{
|
||
// 显示支持站点列表
|
||
self::ShowTableSites();
|
||
global $configALL;
|
||
self::$clients = isset($configALL['default']['clients']) && $configALL['default']['clients'] ? $configALL['default']['clients'] : array();
|
||
echo "程序正在初始化运行参数... ".PHP_EOL;
|
||
// 递归删除上次历史记录
|
||
IFile::rmdir(self::$cacheDir, true);
|
||
// 建立目录
|
||
IFile::mkdir(self::$cacheDir);
|
||
IFile::mkdir(self::$cacheHash);
|
||
IFile::mkdir(self::$cacheMove);
|
||
// 连接全局客户端
|
||
self::links();
|
||
// 合作站点自动注册鉴权
|
||
Oauth::login(self::$apiUrl . self::$endpoints['login']);
|
||
self::$curl = new Curl();
|
||
self::$curl->setOpt(CURLOPT_SSL_VERIFYPEER, false);
|
||
}
|
||
|
||
/**
|
||
* 显示支持站点列表
|
||
*/
|
||
private static function ShowTableSites()
|
||
{
|
||
$list[] = 'gitee 源码仓库：https://gitee.com/ledc/IYUUAutoReseed';
|
||
$list[] = 'github源码仓库：https://github.com/ledccn/IYUUAutoReseed';
|
||
$list[] = '教程：https://gitee.com/ledc/IYUUAutoReseed/tree/master/wiki';
|
||
$list[] = "QQ群：859882209 【IYUU自动辅种交流】".PHP_EOL;
|
||
foreach ($list as $key => $value) {
|
||
echo $value.PHP_EOL;
|
||
}
|
||
// 发起请求
|
||
echo "正在连接IYUUAutoReseed服务器，查询支持列表…… ".PHP_EOL;
|
||
$curl = new Curl();
|
||
$curl->setOpt(CURLOPT_SSL_VERIFYPEER, false); // 禁止验证证书
|
||
$curl->setOpt(CURLOPT_SSL_VERIFYHOST, false); // 不检查证书
|
||
$res = $curl->get(self::$apiUrl.self::$endpoints['sites'].'?sign='.Oauth::getSign());
|
||
$rs = json_decode($res->response, true);
|
||
$sites = isset($rs['data']['sites']) && $rs['data']['sites'] ? $rs['data']['sites'] : false;
|
||
// 数据写入本地
|
||
if ($sites) {
|
||
$json = array_column($sites, null, 'site');
|
||
ksort($json);
|
||
$json = json_encode($json, JSON_UNESCAPED_UNICODE);
|
||
$myfile = ROOT_PATH.DS.'config'.DS.'sites.json';
|
||
$file_pointer = @fopen($myfile, "w");
|
||
$worldsnum = @fwrite($file_pointer, $json);
|
||
@fclose($file_pointer);
|
||
} else {
|
||
if (isset($rs['msg']) && $rs['msg']) {
|
||
die($rs['msg']);
|
||
}
|
||
die('远端服务器无响应，请稍后再试！！！');
|
||
}
|
||
$data = [];
|
||
$i = $j = $k = 0;
|
||
foreach ($sites as $v) {
|
||
// 控制多少列
|
||
if ($i > 4) {
|
||
$k++;
|
||
$i = 0;
|
||
}
|
||
$i++;
|
||
$j++;
|
||
$data[$k][] = $j.". ".$v['site'];
|
||
}
|
||
echo "IYUUAutoReseed自动辅种脚本，目前支持以下站点：".PHP_EOL;
|
||
//输出表格
|
||
$table = new Table();
|
||
$table->setRows($data);
|
||
echo($table->render());
|
||
}
|
||
/**
|
||
* 连接远端RPC服务器
|
||
*
|
||
* @param string
|
||
* @return bool
|
||
*/
|
||
public static function links()
|
||
{
|
||
if (empty(self::$links)) {
|
||
foreach (self::$clients as $k => $v) {
|
||
// 跳过未配置的客户端
|
||
if (empty($v['username']) || empty($v['password'])) {
|
||
unset(self::$clients[$k]);
|
||
echo "clients_".$k." 用户名或密码未配置，已跳过".PHP_EOL.PHP_EOL;
|
||
continue;
|
||
}
|
||
try {
|
||
switch ($v['type']) {
|
||
case 'transmission':
|
||
$client = new TransmissionRPC($v['host'], $v['username'], $v['password']);
|
||
break;
|
||
case 'qBittorrent':
|
||
$client = new qBittorrent($v['host'], $v['username'], $v['password']);
|
||
break;
|
||
default:
|
||
echo '[Links ERROR] '.$v['type'];
|
||
exit(1);
|
||
break;
|
||
}
|
||
/** @var AbstractClientInterface $client */
|
||
self::$links[$k]['type'] = $v['type'];
|
||
self::$links[$k]['rpc'] = $client;
|
||
$result = $client->status();
|
||
print $v['type'].'：'.$v['host']." Rpc连接 [{$result}] \n";
|
||
// 检查是否转移种子的做种客户端？
|
||
if (isset($v['move']) && $v['move'] && is_null(self::$move)) {
|
||
self::$move = array($k,$v['move']);
|
||
}
|
||
} catch (\Exception $e) {
|
||
echo '[Links ERROR] ' . $e->getMessage() . PHP_EOL;
|
||
exit(1);
|
||
}
|
||
}
|
||
}
|
||
return true;
|
||
}
|
||
/**
|
||
* 从客户端获取种子的哈希列表
|
||
* @var array
|
||
*/
|
||
public static function get()
|
||
{
|
||
$hashArray = array();
|
||
foreach (self::$clients as $k => $v) {
|
||
$result = array();
|
||
$res = $info_hash = array();
|
||
$json = $sha1 = '';
|
||
try {
|
||
switch ($v['type']) {
|
||
case 'transmission':
|
||
$ids = $fields = array();
|
||
#$fields = array( "id", "status", "name", "hashString", "downloadDir", "torrentFile" );
|
||
$fields = array( "id", "status", "hashString", "downloadDir");
|
||
$result = self::$links[$k]['rpc']->get($ids, $fields);
|
||
if (empty($result->result) || $result->result != 'success') {
|
||
// 获取种子列表 失败
|
||
echo "获取种子列表失败，原因可能是transmission暂时无响应，请稍后重试！".PHP_EOL;
|
||
break;
|
||
}
|
||
if (empty($result->arguments->torrents)) {
|
||
echo "未获取到数据，请多多保种，然后重试！".PHP_EOL;
|
||
break;
|
||
}
|
||
// 对象转数组
|
||
$res = object_array($result->arguments->torrents);
|
||
// 过滤，只保留正常做种
|
||
$res = array_filter($res, "filterStatus");
|
||
if (empty($res)) {
|
||
echo "未获取到需要辅种的数据，请多多保种，然后重试！".PHP_EOL;
|
||
break;
|
||
}
|
||
// 提取数组：hashString
|
||
$info_hash = array_column($res, 'hashString');
|
||
// 升序排序
|
||
sort($info_hash);
|
||
// 微信模板消息 统计
|
||
self::$wechatMsg['hashCount'] += count($info_hash);
|
||
$json = json_encode($info_hash, JSON_UNESCAPED_UNICODE);
|
||
// 去重 应该从文件读入，防止重复提交
|
||
$sha1 = sha1($json);
|
||
if (isset($hashArray['sha1']) && (in_array($sha1, $hashArray['sha1']) != false)) {
|
||
break;
|
||
}
|
||
// 组装返回数据
|
||
$hashArray['hash']['clients_'.$k] = $json;
|
||
$hashArray['sha1'][] = $sha1;
|
||
// 变换数组：hashString为键
|
||
self::$links[$k]['hash'] = array_column($res, "downloadDir", 'hashString');
|
||
#p(self::$links[$k]['hash']);exit;
|
||
break;
|
||
case 'qBittorrent':
|
||
$result = self::$links[$k]['rpc']->torrentList();
|
||
$res = json_decode($result, true);
|
||
if (empty($res)) {
|
||
echo "未获取到数据，请多多保种，然后重试！".PHP_EOL;
|
||
break;
|
||
}
|
||
// 过滤，只保留正常做种
|
||
$res = array_filter($res, "qbfilterStatus");
|
||
if (empty($res)) {
|
||
echo "未获取到需要辅种的数据，请多多保种，然后重试！".PHP_EOL;
|
||
break;
|
||
}
|
||
// 提取数组：hashString
|
||
$info_hash = array_column($res, 'hash');
|
||
// 升序排序
|
||
sort($info_hash);
|
||
// 微信模板消息 统计
|
||
self::$wechatMsg['hashCount'] += count($info_hash);
|
||
$json = json_encode($info_hash, JSON_UNESCAPED_UNICODE);
|
||
// 去重 应该从文件读入，防止重复提交
|
||
$sha1 = sha1($json);
|
||
if (isset($hashArray['sha1']) && (in_array($sha1, $hashArray['sha1']) != false)) {
|
||
break;
|
||
}
|
||
// 组装返回数据
|
||
$hashArray['hash']['clients_'.$k] = $json;
|
||
$hashArray['sha1'][] = $sha1;
|
||
// 变换数组：hash为键
|
||
self::$links[$k]['hash'] = array_column($res, "save_path", 'hash');
|
||
#p(self::$links[$k]['hash']);exit;
|
||
break;
|
||
default:
|
||
echo '[get ERROR] '.$v['type'] . PHP_EOL;
|
||
exit(1);
|
||
break;
|
||
}
|
||
} catch (\Exception $e) {
|
||
echo '[get ERROR] ' . $e->getMessage() . PHP_EOL;
|
||
exit(1);
|
||
}
|
||
}
|
||
return $hashArray;
|
||
}
|
||
/**
|
||
* @brief 添加下载任务
|
||
* @param string $torrent 种子元数据
|
||
* @param string $save_path 保存路径
|
||
* @return bool
|
||
*/
|
||
public static function add($rpcKey, $torrent, $save_path = '', $extra_options = array())
|
||
{
|
||
try {
|
||
$is_url = false;
|
||
if ((strpos($torrent, 'http://')===0) || (strpos($torrent, 'https://')===0) || (strpos($torrent, 'magnet:?xt=urn:btih:')===0)) {
|
||
$is_url = true;
|
||
}
|
||
// 下载服务器类型
|
||
$type = self::$links[$rpcKey]['type'];
|
||
// 判断
|
||
switch ($type) {
|
||
case 'transmission':
|
||
$extra_options['paused'] = true;
|
||
if ($is_url) {
|
||
$result = self::$links[$rpcKey]['rpc']->add($torrent, $save_path, $extra_options); // 种子URL添加下载任务
|
||
} else {
|
||
$result = self::$links[$rpcKey]['rpc']->add_metainfo($torrent, $save_path, $extra_options); // 种子元数据添加下载任务
|
||
}
|
||
if (isset($result->result) && $result->result == 'success') {
|
||
$id = $name = '';
|
||
if (isset($result->arguments->torrent_duplicate)) {
|
||
$id = $result->arguments->torrent_duplicate->id;
|
||
$name = $result->arguments->torrent_duplicate->name;
|
||
} elseif (isset($result->arguments->torrent_added)) {
|
||
$id = $result->arguments->torrent_added->id;
|
||
$name = $result->arguments->torrent_added->name;
|
||
}
|
||
if ($is_url) {
|
||
print "种子：".$torrent . PHP_EOL;
|
||
}
|
||
print "名字：".$name . PHP_EOL;
|
||
print "********RPC添加下载任务成功 [{$result->result}] (id=$id)".PHP_EOL.PHP_EOL;
|
||
|
||
return true;
|
||
} else {
|
||
$errmsg = isset($result->result) ? $result->result : '未知错误，请稍后重试！';
|
||
if ($is_url) {
|
||
print "种子：".$torrent . PHP_EOL;
|
||
}
|
||
print "-----RPC添加种子任务，失败 [{$errmsg}]" . PHP_EOL.PHP_EOL;
|
||
}
|
||
break;
|
||
case 'qBittorrent':
|
||
$extra_options['paused'] = 'true';
|
||
$extra_options['autoTMM'] = 'false'; //关闭自动种子管理
|
||
if ($is_url) {
|
||
$result = self::$links[$rpcKey]['rpc']->add($torrent, $save_path, $extra_options); // 种子URL添加下载任务
|
||
} else {
|
||
$extra_options['name'] = 'torrents';
|
||
$extra_options['filename'] = rand(1, 4294967200).'.torrent';
|
||
$result = self::$links[$rpcKey]['rpc']->add_metainfo($torrent, $save_path, $extra_options); // 种子元数据添加下载任务
|
||
}
|
||
if ($is_url) {
|
||
print "种子：".$torrent.PHP_EOL;
|
||
}
|
||
if ($result === 'Ok.') {
|
||
print "********RPC添加下载任务成功 [{$result}]".PHP_EOL.PHP_EOL;
|
||
return true;
|
||
} else {
|
||
print "-----RPC添加种子任务，失败 [{$result}]".PHP_EOL.PHP_EOL;
|
||
}
|
||
break;
|
||
default:
|
||
echo '[ERROR] '.$type. PHP_EOL. PHP_EOL;
|
||
break;
|
||
}
|
||
} catch (\Exception $e) {
|
||
echo '[ERROR] ' . $e->getMessage() . PHP_EOL;
|
||
}
|
||
return false;
|
||
}
|
||
/**
|
||
* @brief 提交种子hash给远端API，用来获取辅种数据
|
||
* @param array $hashArray 种子hash数组
|
||
* @return
|
||
*/
|
||
public static function call($hashArray = array())
|
||
{
|
||
$resArray = array();
|
||
// 签名
|
||
$hashArray['sign'] = Oauth::getSign();
|
||
$hashArray['timestamp'] = time();
|
||
$hashArray['version'] = self::VER;
|
||
// 写请求日志
|
||
wlog($hashArray, 'hashString');
|
||
if (self::$move!==null) {
|
||
self::move($hashArray);
|
||
}
|
||
self::reseed($hashArray);
|
||
self::wechatMessage();
|
||
}
|
||
|
||
/**
|
||
* IYUUAutoReseed辅种
|
||
*/
|
||
public static function reseed($hashArray = array())
|
||
{
|
||
global $configALL;
|
||
$sites = array();
|
||
// 前置过滤
|
||
if (self::$move!==null && self::$move[1]==2) {
|
||
foreach ($hashArray['hash'] as $key => $json) {
|
||
if ($key != 'clients_'.self::$move[0]) {
|
||
$hashArray['hash'][$key] = '[]';
|
||
}
|
||
}
|
||
}
|
||
// 发起请求
|
||
echo "正在提交辅种信息……".PHP_EOL;
|
||
$res = self::$curl->post(self::$apiUrl . self::$endpoints['reseed'], $hashArray);
|
||
$res = json_decode($res->response, true);
|
||
$resArray = isset($res['data']) && $res['data'] ? $res['data'] : array();
|
||
// 写返回日志
|
||
wlog($res, 'reseed');
|
||
// 判断返回值
|
||
if (isset($resArray['errmsg']) && ($resArray['errmsg'] == 'ok')) {
|
||
echo "辅种信息提交成功！！！".PHP_EOL.PHP_EOL;
|
||
} else {
|
||
$errmsg = isset($res['msg']) && $res['msg'] ? $res['msg'] : '远端服务器无响应，请稍后重试！';
|
||
echo '-----辅种失败，原因：' .$errmsg.PHP_EOL.PHP_EOL;
|
||
exit(1);
|
||
}
|
||
// 可辅种站点信息
|
||
$sites = $resArray['sites'];
|
||
#p($sites);
|
||
// 支持站点数量
|
||
self::$wechatMsg['sitesCount'] = count($sites);
|
||
// 按客户端循环辅种 开始
|
||
foreach (self::$links as $k => $v) {
|
||
if (empty($resArray['clients_'.$k])) {
|
||
echo "clients_".$k."没有查询到可辅种数据".PHP_EOL.PHP_EOL;
|
||
continue;
|
||
}
|
||
$reseed = $infohash_Dir = array();
|
||
// info_hash与下载目录对应表
|
||
$infohash_Dir = self::$links[$k]['hash'];
|
||
#p($infohash_Dir);
|
||
// 当前客户端可辅种数据
|
||
$reseed = $resArray['clients_'.$k];
|
||
foreach ($reseed as $info_hash => $vv) {
|
||
// 当前种子哈希对应的目录
|
||
$downloadDir = $infohash_Dir[$info_hash];
|
||
foreach ($vv['torrent'] as $id => $value) {
|
||
$_url = $url = '';
|
||
$download_page = $details_url = '';
|
||
// 匹配的辅种数据累加
|
||
self::$wechatMsg['reseedCount']++;
|
||
// 站点id
|
||
$sitesID = $value['sid'];
|
||
// 站点名
|
||
$siteName = $sites[$sitesID]['site'];
|
||
// 页面规则
|
||
$download_page = str_replace('{}', $value['torrent_id'], $sites[$sitesID]['download_page']);
|
||
$_url = 'https://' .$sites[$sitesID]['base_url']. '/' .$download_page;
|
||
echo "clients_".$k."正在辅种... {$siteName}".PHP_EOL;
|
||
/**
|
||
* 前置检测
|
||
*/
|
||
// passkey检测
|
||
if (empty($configALL[$siteName]['passkey'])) {
|
||
echo '-------因当前' .$siteName. "站点未设置passkey，已跳过！！".PHP_EOL.PHP_EOL;
|
||
self::$wechatMsg['reseedSkip']++;
|
||
continue;
|
||
}
|
||
// cookie检测
|
||
if (in_array($siteName, self::$cookieCheck) && empty($configALL[$siteName]['cookie'])) {
|
||
echo '-------因当前' .$siteName. '站点未设置cookie，已跳过！！' .PHP_EOL.PHP_EOL;
|
||
self::$wechatMsg['reseedSkip']++;
|
||
continue;
|
||
}
|
||
// 流控检测
|
||
if (isset($configALL[$siteName]['limit'])) {
|
||
echo "-------因当前" .$siteName. "站点触发流控，已跳过！！ {$_url}".PHP_EOL.PHP_EOL;
|
||
// 流控日志
|
||
if ($siteName == 'hdchina') {
|
||
$details_page = str_replace('{}', $value['torrent_id'], 'details.php?id={}&hit=1');
|
||
$_url = 'https://' .$sites[$sitesID]['base_url']. '/' .$details_page;
|
||
}
|
||
wlog('clients_'.$k.PHP_EOL.$downloadDir.PHP_EOL."-------因当前" .$siteName. "站点触发流控，已跳过！！ {$_url}".PHP_EOL.PHP_EOL, 'reseedLimit');
|
||
self::$wechatMsg['reseedSkip']++;
|
||
continue;
|
||
}
|
||
// 重复做种检测
|
||
if (isset($value['info_hash']) && isset($infohash_Dir[$value['info_hash']])) {
|
||
echo '-------与客户端现有种子重复：'.$_url.PHP_EOL.PHP_EOL;
|
||
self::$wechatMsg['reseedRepeat']++;
|
||
continue;
|
||
}
|
||
// 历史添加检测
|
||
if (is_file(self::$cacheHash . $value['info_hash'].'.txt')) {
|
||
echo '-------当前种子上次辅种已成功添加，已跳过！ '.$_url.PHP_EOL.PHP_EOL;
|
||
self::$wechatMsg['reseedPass']++;
|
||
continue;
|
||
}
|
||
/**
|
||
* 种子URL组合方式区分
|
||
*/
|
||
$url = self::getTorrentUrl($siteName, $_url);
|
||
/**
|
||
* 检查站点是否可以辅种
|
||
*/
|
||
if ((in_array($siteName, self::$noReseed)==false)) {
|
||
/**
|
||
* 可以辅种
|
||
*/
|
||
// 特殊站点：推送给下载器种子元数据
|
||
switch ($siteName) {
|
||
case 'hdchina':
|
||
$cookie = isset($configALL[$siteName]['cookie']) ? $configALL[$siteName]['cookie'] : '';
|
||
$userAgent = $configALL['default']['userAgent'];
|
||
// 拼接URL
|
||
$details_page = str_replace('{}', $value['torrent_id'], 'details.php?id={}&hit=1');
|
||
$details_url = 'https://' .$sites[$sitesID]['base_url']. '/' .$details_page;
|
||
$details_html = download($details_url, $cookie, $userAgent);
|
||
print "种子详情页：".$details_url.PHP_EOL;
|
||
// 提取种子下载地址
|
||
$download_page = str_replace('{}', '', $sites[$sitesID]['download_page']);
|
||
$offset = strpos($details_html, $download_page);
|
||
$urlTemp = substr($details_html, $offset, 50);
|
||
// 种子地址
|
||
$_url = substr($urlTemp, 0, strpos($urlTemp, '">'));
|
||
$_url = 'https://' .$sites[$sitesID]['base_url']. '/' . $_url;
|
||
print "种子下载页：".$_url.PHP_EOL;
|
||
$url = download($_url, $cookie, $userAgent);
|
||
if (strpos($url, '系统检测到过多的种子下载请求') != false) {
|
||
echo "当前站点触发人机验证，已加入排除列表".PHP_EOL;
|
||
ff($siteName. '站点，辅种时触发人机验证！');
|
||
$configALL[$siteName]['limit'] = 1;
|
||
self::$noReseed[] = 'hdchina';
|
||
}
|
||
break;
|
||
case 'hdcity':
|
||
$cookie = isset($configALL[$siteName]['cookie']) ? $configALL[$siteName]['cookie'] : '';
|
||
$userAgent = $configALL['default']['userAgent'];
|
||
print "种子：".$_url.PHP_EOL;
|
||
if (isset($configALL[$siteName]['cuhash'])) {
|
||
// 已获取cuhash
|
||
# code...
|
||
} else {
|
||
// 获取cuhash
|
||
$html = download('https://' .$sites[$sitesID]['base_url']. '/pt', $cookie, $userAgent);
|
||
// 提取种子下载地址
|
||
$offset = strpos($html, 'cuhash=');
|
||
$len = strlen('cuhash=');
|
||
$cuhashTemp = substr($html, $offset+$len, 40);
|
||
$configALL[$siteName]['cuhash'] = substr($cuhashTemp, 0, strpos($cuhashTemp, '"'));
|
||
}
|
||
$url = $_url."&cuhash=". $configALL[$siteName]['cuhash'];
|
||
// 城市下载种子时会302转向
|
||
$url = download($url, $cookie, $userAgent);
|
||
break;
|
||
default:
|
||
// 默认站点：推送给下载器种子URL链接
|
||
break;
|
||
}
|
||
// 把拼接的种子URL，推送给下载器
|
||
$ret = false;
|
||
// 成功返回：true
|
||
$ret = self::add($k, $url, $downloadDir);
|
||
|
||
// 按站点规范日志内容
|
||
switch ($siteName) {
|
||
case 'hdchina':
|
||
$url = $details_url;
|
||
break;
|
||
case 'hdcity':
|
||
$url = $_url;
|
||
break;
|
||
default:
|
||
break;
|
||
}
|
||
// 添加成功的种子，以infohash为文件名，写入缓存
|
||
if ($ret) {
|
||
// 成功的种子
|
||
wlog($url.PHP_EOL, $value['info_hash'], self::$cacheHash);
|
||
wlog($url.PHP_EOL, 'reseedSuccess');
|
||
// 成功累加
|
||
self::$wechatMsg['reseedSuccess']++;
|
||
continue;
|
||
} else {
|
||
// 失败的种子
|
||
wlog($url.PHP_EOL, 'reseedError');
|
||
// 失败累加
|
||
self::$wechatMsg['reseedError']++;
|
||
continue;
|
||
}
|
||
} else {
|
||
/**
|
||
* 不辅种
|
||
*/
|
||
echo '-------已跳过不辅种的站点：'.$_url.PHP_EOL.PHP_EOL;
|
||
// 按站点规范日志内容
|
||
switch ($siteName) {
|
||
case 'hdchina':
|
||
$url = $details_url;
|
||
break;
|
||
case 'hdcity':
|
||
$url = $_url;
|
||
break;
|
||
default:
|
||
break;
|
||
}
|
||
// 写入日志文件，供用户手动辅种
|
||
wlog('clients_'.$k.PHP_EOL.$downloadDir.PHP_EOL.$url.PHP_EOL.$details_url.PHP_EOL.PHP_EOL, $siteName);
|
||
}
|
||
}
|
||
}
|
||
}
|
||
// 按客户端循环辅种 结束
|
||
}
|
||
/**
|
||
* IYUUAutoReseed做种客户端转移
|
||
*/
|
||
public static function move($hashArray = array())
|
||
{
|
||
global $configALL;
|
||
$sites = array();
|
||
// 前置过滤：2020年1月26日15:52:41
|
||
self::hashFilter($hashArray['hash']);
|
||
// 发起请求
|
||
echo "正在提交转移信息……".PHP_EOL;
|
||
$res = self::$curl->post(self::$apiUrl . self::$endpoints['move'], $hashArray);
|
||
$res = json_decode($res->response, true);
|
||
$resArray = isset($res['data']) && $res['data'] ? $res['data'] : array();
|
||
// 写日志
|
||
wlog($res, 'move');
|
||
// 判断返回值
|
||
if (isset($resArray['errmsg']) && ($resArray['errmsg'] == 'ok')) {
|
||
echo "转移数据返回：成功！！！".PHP_EOL.PHP_EOL;
|
||
} else {
|
||
$errmsg = isset($res['msg']) && $res['msg'] ? $res['msg'] : '远端服务器无响应，请稍后重试！';
|
||
echo '-----转移请求失败，原因：' .$errmsg.PHP_EOL.PHP_EOL;
|
||
exit(1);
|
||
}
|
||
// 可辅种站点信息
|
||
$sites = $resArray['sites'];
|
||
// 支持站点数量
|
||
#self::$wechatMsg['sitesCount'] = count($sites);
|
||
// 按客户端移动 开始
|
||
foreach (self::$links as $k => $v) {
|
||
if (self::$move!=null && self::$move[0] == $k) {
|
||
echo "clients_".$k."是目标转移客户端，避免冲突，已跳过！".PHP_EOL.PHP_EOL;
|
||
continue;
|
||
}
|
||
if (empty($resArray['clients_'.$k])) {
|
||
echo "clients_".$k."没有查询到可转移数据".PHP_EOL.PHP_EOL;
|
||
continue;
|
||
}
|
||
$infohash_Dir = $move = array();
|
||
// info_hash与下载目录对应表
|
||
$infohash_Dir = self::$links[$k]['hash'];
|
||
// 当前客户端可辅种数据
|
||
$move = $resArray['clients_'.$k];
|
||
foreach ($move as $info_hash => $value) {
|
||
$_url = $url = '';
|
||
$download_page = $details_url = '';
|
||
// 匹配的辅种数据累加
|
||
#self::$wechatMsg['reseedCount']++;
|
||
// 当前种子哈希对应的目录
|
||
$downloadDir = $infohash_Dir[$info_hash];
|
||
// 站点id
|
||
$sitesID = $value['sid'];
|
||
// 站点名
|
||
$siteName = $sites[$sitesID]['site'];
|
||
// 页面规则
|
||
$download_page = str_replace('{}', $value['torrent_id'], $sites[$sitesID]['download_page']);
|
||
$_url = 'https://' .$sites[$sitesID]['base_url']. '/' .$download_page;
|
||
echo "clients_".$k."正在转移... {$siteName}".PHP_EOL;
|
||
/**
|
||
* 前置检测
|
||
*/
|
||
// passkey检测
|
||
if (empty($configALL[$siteName]['passkey'])) {
|
||
echo '-------因当前' .$siteName. "站点未设置passkey，已跳过！！".PHP_EOL.PHP_EOL;
|
||
#self::$wechatMsg['reseedSkip']++;
|
||
continue;
|
||
}
|
||
// cookie检测
|
||
if (in_array($siteName, self::$cookieCheck) && empty($configALL[$siteName]['cookie'])) {
|
||
echo '-------因当前' .$siteName. '站点未设置cookie，已跳过！！' .PHP_EOL.PHP_EOL;
|
||
#self::$wechatMsg['reseedSkip']++;
|
||
continue;
|
||
}
|
||
// 流控检测
|
||
if (isset($configALL[$siteName]['limit'])) {
|
||
echo "-------因当前" .$siteName. "站点触发流控，已跳过！！ {$_url}".PHP_EOL.PHP_EOL;
|
||
// 流控日志
|
||
if ($siteName == 'hdchina') {
|
||
$details_page = str_replace('{}', $value['torrent_id'], 'details.php?id={}&hit=1');
|
||
$_url = 'https://' .$sites[$sitesID]['base_url']. '/' .$details_page;
|
||
}
|
||
wlog('clients_'.$k.PHP_EOL.$downloadDir.PHP_EOL."-------因当前" .$siteName. "站点触发流控，已跳过！！ {$_url}".PHP_EOL.PHP_EOL, 'MoveLimit');
|
||
#self::$wechatMsg['reseedSkip']++;
|
||
continue;
|
||
}
|
||
// 历史转移检测
|
||
if (is_file(self::$cacheMove . $info_hash.'.txt')) {
|
||
echo '-------当前种子上次已成功转移，已跳过！ '.$_url.PHP_EOL.PHP_EOL;
|
||
#self::$wechatMsg['reseedPass']++;
|
||
continue;
|
||
}
|
||
// 不转移的站点检测
|
||
if (in_array($siteName, self::$noMove)) {
|
||
echo '-------已跳过不转移的站点 ' .$siteName. '！！ ' .PHP_EOL.PHP_EOL;
|
||
#self::$wechatMsg['reseedSkip']++;
|
||
continue;
|
||
}
|
||
/**
|
||
* 种子URL组合方式区分
|
||
*/
|
||
$url = self::getTorrentUrl($siteName, $_url);
|
||
/**
|
||
* 转移核心
|
||
*/
|
||
// 特殊站点：推送给下载器种子元数据
|
||
switch ($siteName) {
|
||
case 'hdchina':
|
||
$cookie = isset($configALL[$siteName]['cookie']) ? $configALL[$siteName]['cookie'] : '';
|
||
$userAgent = $configALL['default']['userAgent'];
|
||
// 拼接URL
|
||
$details_page = str_replace('{}', $value['torrent_id'], 'details.php?id={}&hit=1');
|
||
$details_url = 'https://' .$sites[$sitesID]['base_url']. '/' .$details_page;
|
||
$details_html = download($details_url, $cookie, $userAgent);
|
||
print "种子详情页：".$details_url.PHP_EOL;
|
||
// 提取种子下载地址
|
||
$download_page = str_replace('{}', '', $sites[$sitesID]['download_page']);
|
||
$offset = strpos($details_html, $download_page);
|
||
$urlTemp = substr($details_html, $offset, 50);
|
||
// 种子地址
|
||
$_url = substr($urlTemp, 0, strpos($urlTemp, '">'));
|
||
$_url = 'https://' .$sites[$sitesID]['base_url']. '/' . $_url;
|
||
print "种子下载页：".$_url.PHP_EOL;
|
||
$url = download($_url, $cookie, $userAgent);
|
||
if (strpos($url, '系统检测到过多的种子下载请求') != false) {
|
||
echo "当前站点触发人机验证，已加入排除列表".PHP_EOL;
|
||
ff($siteName. '站点，辅种时触发人机验证！');
|
||
$configALL[$siteName]['limit'] = 1;
|
||
}
|
||
break;
|
||
case 'hdcity':
|
||
$cookie = isset($configALL[$siteName]['cookie']) ? $configALL[$siteName]['cookie'] : '';
|
||
$userAgent = $configALL['default']['userAgent'];
|
||
print "种子：".$_url.PHP_EOL;
|
||
if (isset($configALL[$siteName]['cuhash'])) {
|
||
// 已获取cuhash
|
||
# code...
|
||
} else {
|
||
// 获取cuhash
|
||
$html = download('https://' .$sites[$sitesID]['base_url']. '/pt', $cookie, $userAgent);
|
||
// 提取种子下载地址
|
||
$offset = strpos($html, 'cuhash=');
|
||
$len = strlen('cuhash=');
|
||
$cuhashTemp = substr($html, $offset+$len, 40);
|
||
$configALL[$siteName]['cuhash'] = substr($cuhashTemp, 0, strpos($cuhashTemp, '"'));
|
||
}
|
||
$url = $_url."&cuhash=". $configALL[$siteName]['cuhash'];
|
||
// 城市下载种子时会302转向
|
||
$url = download($url, $cookie, $userAgent);
|
||
break;
|
||
default:
|
||
// 默认站点：推送给下载器种子URL链接
|
||
break;
|
||
}
|
||
echo "种子URL已推送给下载器，下载器正在下载种子...".PHP_EOL;
|
||
// 实际路径与相对路径之间互转
|
||
$downloadDir = self::pathReplace($downloadDir);
|
||
if (is_null($downloadDir)) {
|
||
die("全局配置的move数组内，type配置错误，请重新配置！！！".PHP_EOL);
|
||
}
|
||
$ret = false;
|
||
// 把拼接的种子URL，推送给下载器
|
||
// 成功返回：true
|
||
$ret = self::add(self::$move[0], $url, $downloadDir);
|
||
// 按站点规范日志内容
|
||
switch ($siteName) {
|
||
case 'hdchina':
|
||
$url = $details_url;
|
||
break;
|
||
case 'hdcity':
|
||
$url = $_url;
|
||
break;
|
||
default:
|
||
break;
|
||
}
|
||
/**
|
||
* 转移成功的种子写日志
|
||
*/
|
||
if ($ret) {
|
||
// 转移成功的种子，以infohash为文件名，写入缓存
|
||
wlog($url.PHP_EOL, $info_hash, self::$cacheMove);
|
||
wlog($url.PHP_EOL, 'MoveSuccess');
|
||
// 成功累加
|
||
#self::$wechatMsg['reseedSuccess']++;
|
||
continue;
|
||
} else {
|
||
// 失败的种子
|
||
wlog($url.PHP_EOL, 'MoveError');
|
||
// 失败累加
|
||
#self::$wechatMsg['reseedError']++;
|
||
continue;
|
||
}
|
||
}
|
||
}
|
||
// 按客户端循环辅种 结束
|
||
}
|
||
/**
|
||
* 过滤已转移的种子hash
|
||
*/
|
||
public static function hashFilter(&$hash = array())
|
||
{
|
||
foreach ($hash as $client => $json) {
|
||
$data = array();
|
||
$data = json_decode($json, true);
|
||
if (empty($data)) {
|
||
continue;
|
||
}
|
||
foreach ($data as $key => $info_hash) {
|
||
if (is_file(self::$cacheMove . $info_hash.'.txt')) {
|
||
echo '-------当前种子上次已成功转移，前置过滤已跳过！ ' .PHP_EOL.PHP_EOL;
|
||
unset($data[$key]);
|
||
}
|
||
}
|
||
if ($data) {
|
||
$data = array_values($data);
|
||
}
|
||
$hash[$client] = json_encode($data, JSON_UNESCAPED_UNICODE);
|
||
}
|
||
return $hash;
|
||
}
|
||
/**
|
||
* 实际路径与相对路径之间互相转换
|
||
*/
|
||
public static function pathReplace($path = '')
|
||
{
|
||
global $configALL;
|
||
$type = $configALL['default']['move']['type'];
|
||
$pathArray = $configALL['default']['move']['path'];
|
||
switch ($type) {
|
||
case 1: // 减
|
||
foreach ($pathArray as $key => $val) {
|
||
if (strpos($path, $key)===0) {
|
||
return substr($path, strlen($key));
|
||
}
|
||
}
|
||
return $path;
|
||
break;
|
||
case 2: // 加
|
||
foreach ($pathArray as $key => $val) {
|
||
if (strpos($path, $key)===0) {
|
||
return $val . $path;
|
||
}
|
||
}
|
||
break;
|
||
case 3: // 替换
|
||
foreach ($pathArray as $key => $val) {
|
||
if (strpos($path, $key)===0) {
|
||
return $val . substr($path, strlen($key));
|
||
}
|
||
}
|
||
return $path;
|
||
break;
|
||
default:
|
||
return $path;
|
||
break;
|
||
}
|
||
return null;
|
||
}
|
||
/**
|
||
* 获取站点种子的URL
|
||
*/
|
||
public static function getTorrentUrl($site = '', $_url = '')
|
||
{
|
||
global $configALL;
|
||
switch ($site) {
|
||
case 'ttg':
|
||
$url = $_url."/". $configALL[$site]['passkey'];
|
||
break;
|
||
case 'm-team':
|
||
case 'moecat':
|
||
$ip_type = '';
|
||
if (isset($configALL[$site]['ip_type'])) {
|
||
$ip_type = $configALL[$site]['ip_type'] == 'ipv6' ? '&ipv6=1' : '';
|
||
}
|
||
$url = $_url."&passkey=". $configALL[$site]['passkey'] . $ip_type. "&https=1";
|
||
break;
|
||
case 'ccfbits':
|
||
$url = str_replace('{passkey}', $configALL[$site]['passkey'], $_url);
|
||
break;
|
||
default:
|
||
$url = $_url."&passkey=". $configALL[$site]['passkey'];
|
||
break;
|
||
}
|
||
return $url;
|
||
}
|
||
/**
|
||
* 微信模板消息拼接方法
|
||
*/
|
||
public static function wechatMessage()
|
||
{
|
||
$br = PHP_EOL;
|
||
$text = 'IYUU自动辅种-统计报表';
|
||
$desp = '总做种：'.self::$wechatMsg['hashCount'] . ' [客户端正在做种的hash总数]' .$br;
|
||
$desp .= '返回数据：'.self::$wechatMsg['reseedCount']. ' [服务器返回的可辅种数据]' .$br;
|
||
$desp .= '支持站点：'.self::$wechatMsg['sitesCount']. ' [当前支持自动辅种的站点数量]' .$br;
|
||
$desp .= '成功：'.self::$wechatMsg['reseedSuccess']. ' [辅种成功，会把hash加入缓存]' .$br;
|
||
$desp .= '失败：'.self::$wechatMsg['reseedError']. ' [下载器下载种子失败或网络超时引起，可以重试]' .$br;
|
||
$desp .= '重复：'.self::$wechatMsg['reseedRepeat']. ' [客户端已做种]' .$br;
|
||
$desp .= '跳过：'.self::$wechatMsg['reseedSkip']. ' [未设置passkey]' .$br;
|
||
$desp .= '忽略：'.self::$wechatMsg['reseedPass']. ' [成功添加存在缓存]' .$br;
|
||
return ff($text, $desp);
|
||
}
|
||
}
|