<?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 = '0.2.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://pt.iyuu.cn';
    public static $endpoints = array(
        'add'    => '/api/add',
        'update' => '/api/update',
        'reseed' => '/api/reseed',
        'move'   => '/api/move',
        'login'  => '/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->post(self::$apiUrl);
        $sites = json_decode($res->response, true);
        // 数据写入本地
        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 {
            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['timestamp'] = time();
        $hashArray['sign'] = Oauth::getSign();
        $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);
        $resArray = json_decode($res->response, true);
        // 写返回日志
        wlog($resArray, 'reseed');
        // 判断返回值
        if (isset($resArray['errmsg']) && ($resArray['errmsg'] == 'ok')) {
            echo "辅种信息提交成功！！！".PHP_EOL.PHP_EOL;
        } else {
            $errmsg = isset($resArray['errmsg']) ? $resArray['errmsg'] : '远端服务器无响应，请稍后重试！';
            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);
        $resArray = json_decode($res->response, true);
        // 写日志
        wlog($resArray, 'move');
        // 判断返回值
        if (isset($resArray['errmsg']) && ($resArray['errmsg'] == 'ok')) {
            echo "转移数据返回：成功！！！".PHP_EOL.PHP_EOL;
        } else {
            $errmsg = isset($resArray['errmsg']) ? $resArray['errmsg'] : '远端服务器无响应，请稍后重试！';
            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);
    }
}