新增移动做种微信报告

app/AutoReseed.php

@@ -1,17 +1,19 @@
 <?php
 namespace IYUU;
+
 use Curl\Curl;
 use IYUU\Client\AbstractClient;
 use IYUU\Library\IFile;
 use IYUU\Library\Oauth;
 use IYUU\Library\Table;
+
 /**
  * IYUUAutoReseed自动辅种类
  */
 class AutoReseed
 {
     // 版本号
-    const VER = '1.9.1';
+    const VER = '1.9.4';
     // RPC连接
     private static $links = [];
     // 客户端配置
@@ -54,6 +56,8 @@ class AutoReseed
         'reseedRepeat'		=>	0,		// 重复：客户端已做种
         'reseedSkip'		=>	0,		// 跳过：因未设置passkey，而跳过
         'reseedPass'		=>	0,		// 忽略：因上次成功添加、存在缓存，而跳过
+        'MoveSuccess'       =>  0,      // 移动成功
+        'MoveError'         =>  0,      // 移动失败
     );
     // 错误通知消息体
     private static $errNotify = array(
@@ -216,8 +220,6 @@ class AutoReseed
                         $errmsg = isset($result['result']) ? $result['result'] : '未知错误，请稍后重试！';
                         if (strpos($errmsg, 'http error 404: Not Found') !== false) {
                             self::sendNotify('404');
-                        } elseif (strpos($errmsg, 'http error 403: Forbidden')  !== false) {
-                            self::sendNotify('403');
                         }
                         print "-----RPC添加种子任务，失败 [{$errmsg}]" . PHP_EOL.PHP_EOL;
                     }
@@ -420,7 +422,7 @@ class AutoReseed
                                 if ($lastTime) {
                                     $interval = time() - $lastTime;   // 间隔时间
                                     if ($interval < $limitRule['sleep']) {
-                                        $t = $limitRule['sleep'] - $interval +  mt_rand(1,5);
+                                        $t = $limitRule['sleep'] - $interval +  mt_rand(1, 5);
                                         do {
                                             echo microtime(true)." 为账号安全，辅种进程休眠 {$t} 秒后继续...".PHP_EOL;
                                             sleep(1);
@@ -450,6 +452,7 @@ class AutoReseed
                             print "种子详情页：".$details_url.PHP_EOL;
                             $details_html = download($details_url, $cookie, $userAgent);
                             if (empty($details_html)) {
+                                ff($siteName. '站点，cookie已过期，请更新后重新辅种！');
                                 echo 'cookie已过期，请更新后重新辅种！已加入排除列表'.PHP_EOL;
                                 $t = 30;
                                 do {
@@ -462,14 +465,16 @@ class AutoReseed
                             }
                             if (strpos($details_html, '没有该ID的种子') != false) {
                                 echo '种子已被删除！'.PHP_EOL;
-                                self::sendNotify('404');                                
+                                self::sendNotify('404');
                                 $reseedPass = true;
                                 break;
-                            }                            
+                            }
                             // 提取种子下载地址
                             $offset = strpos($details_html, str_replace('{hash}', '', $sites[$sid]['download_page']));
                             if ($offset === false) {
+                                ff($siteName. '站点，cookie已过期，请更新后重新辅种！');
                                 echo 'cookie已过期，请更新后重新辅种！'.PHP_EOL;
+                                $configALL[$siteName]['cookie'] = '';
                                 $reseedPass = true;
                                 break;
                             }
@@ -517,6 +522,13 @@ class AutoReseed
                                 $html = download($protocol .$sites[$sid]['base_url']. '/pt', $cookie, $userAgent);
                                 // 提取种子下载地址
                                 $offset = strpos($html, 'cuhash=');
+                                if ($offset === false) {
+                                    ff($siteName. '站点，cookie已过期，请更新后重新辅种！');
+                                    echo 'cookie已过期，请更新后重新辅种！'.PHP_EOL;
+                                    $configALL[$siteName]['cookie'] = '';
+                                    $reseedPass = true;
+                                    break;
+                                }
                                 $len = strlen('cuhash=');
                                 $cuhashTemp = substr($html, $offset+$len, 40);
                                 $configALL[$siteName]['cuhash'] = substr($cuhashTemp, 0, strpos($cuhashTemp, '"'));
@@ -615,7 +627,7 @@ class AutoReseed
                 continue;
             }
             //遍历当前客户端种子
-            foreach ($infohash_Dir as $info_hash => $downloadDir) {                
+            foreach ($infohash_Dir as $info_hash => $downloadDir) {
                 // 调用路径过滤
                 if (self::pathFilter($downloadDir)) {
                     continue;
@@ -623,7 +635,7 @@ class AutoReseed
                 // 做种实际路径与相对路径之间互转
                 echo '转换前：'.$downloadDir.PHP_EOL;
                 $downloadDir = self::pathReplace($downloadDir);
-                echo '转换后：'.$downloadDir.PHP_EOL;                
+                echo '转换后：'.$downloadDir.PHP_EOL;
                 if (is_null($downloadDir)) {
                     echo 'IYUU自动转移做种客户端--使用教程 https://www.iyuu.cn/archives/351/'.PHP_EOL;
                     die("全局配置的move数组内，路径转换参数配置错误，请重新配置！！！".PHP_EOL);
@@ -692,9 +704,11 @@ class AutoReseed
                     // 转移成功的种子，以infohash为文件名，写入缓存
                     wlog($log, $info_hash, self::$cacheMove);
                     wlog($log, 'MoveSuccess'.$k);
+                    self::$wechatMsg['MoveSuccess']++;
                 } else {
                     // 失败的种子
                     wlog($log, 'MoveError'.$k);
+                    self::$wechatMsg['MoveError']++;
                 }
             }
         }
@@ -720,7 +734,7 @@ class AutoReseed
         global $configALL;
         $type = $configALL['default']['move']['type'];
         $pathArray = $configALL['default']['move']['path'];
-        $path = rtrim($path, DIRECTORY_SEPARATOR);      // 提高Windows转移兼容性        
+        $path = rtrim($path, DIRECTORY_SEPARATOR);      // 提高Windows转移兼容性
         switch ($type) {
             case 1:         // 减
                 foreach ($pathArray as $key => $val) {
@@ -757,13 +771,12 @@ class AutoReseed
     {
         global $configALL;
         $path = rtrim($path, DIRECTORY_SEPARATOR);      // 提高Windows转移兼容性
-        // 转移过滤器、选择器 David/2020年7月11日        
+        // 转移过滤器、选择器 David/2020年7月11日
         $path_filter = isset($configALL['default']['move']['path_filter']) && !empty($configALL['default']['move']['path_filter']) ? $configALL['default']['move']['path_filter'] : null;
         $path_selector = isset($configALL['default']['move']['path_selector']) && !empty($configALL['default']['move']['path_selector']) ? $configALL['default']['move']['path_selector'] : null;
         if (\is_null($path_filter) && \is_null($path_selector)) {
             return false;
-        }
-        elseif (\is_null($path_filter)) {
+        } elseif (\is_null($path_filter)) {
             //选择器
             if (\is_array($path_selector)) {
                 foreach ($path_selector as $pathName) {
@@ -774,8 +787,7 @@ class AutoReseed
                 echo '已跳过！转移选择器未匹配到：'.$path.PHP_EOL;
                 return true;
             }
-        }
-        elseif (\is_null($path_selector)) {
+        } elseif (\is_null($path_selector)) {
             //过滤器
             if (\is_array($path_filter)) {
                 foreach ($path_filter as $pathName) {
@@ -812,18 +824,18 @@ class AutoReseed
     /**
      * 获取站点种子的URL
      * @param string $site
-     * @param string $_url
+     * @param string $url
      * @return string
      */
-    private static function getTorrentUrl($site = '', $_url = '')
+    private static function getTorrentUrl($site = '', $url = '')
     {
         global $configALL;
         // 兼容旧配置
         if (isset($configALL[$site]['passkey']) && $configALL[$site]['passkey']) {
-            if (!isset($configALL[$site]['url_replace'])) {
+            if (empty($configALL[$site]['url_replace'])) {
                 $configALL[$site]['url_replace'] = array('{passkey}' => $configALL[$site]['passkey']);
             }
-            if (!isset($configALL[$site]['url_join'])) {
+            if (empty($configALL[$site]['url_join'])) {
                 $configALL[$site]['url_join'] = array();
                 if (in_array($site, array('m-team','mocat','hdbd'))) {
                     if (isset($configALL[$site]['ip_type'])) {
@@ -835,11 +847,11 @@ class AutoReseed
         }
         // 通用操作：替换
         if (isset($configALL[$site]['url_replace']) && $configALL[$site]['url_replace']) {
-            $url = strtr($_url, $configALL[$site]['url_replace']);
+            $url = strtr($url, $configALL[$site]['url_replace']);
         }
         // 通用操作：拼接
         if (isset($configALL[$site]['url_join']) && $configALL[$site]['url_join']) {
-            $url = $url.(strpos($url, '?') === false ? '?' : '&').implode('&',$configALL[$site]['url_join']);
+            $url = $url.(strpos($url, '?') === false ? '?' : '&').implode('&', $configALL[$site]['url_join']);
         }
         return $url;
     }
@@ -853,14 +865,21 @@ class AutoReseed
         $desp = '### 版本号：'. self::VER . $br;
         $desp .= '**支持站点：'.self::$wechatMsg['sitesCount']. '**  [当前支持自动辅种的站点数量]' .$br;
         $desp .= '**总做种：'.self::$wechatMsg['hashCount'] . '**  [客户端做种的hash总数]' .$br;
-        $desp .= '**返回数据：'.self::$wechatMsg['reseedCount']. '**  [服务器返回的可辅种数据]' .$br;        
-        $desp .= '**成功：'.self::$wechatMsg['reseedSuccess']. '**  [辅种成功，会把hash加入缓存]' .$br;
+        $desp .= '**返回数据：'.self::$wechatMsg['reseedCount']. '**  [服务器返回的可辅种数据]' .$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;
-        $desp .= $br.'**如需重新辅种，请删除 ./torrent/cachehash 内的所有辅种缓存。**'.$br;
-        $desp .= '*此消息将在3天后过期*。';
+        $desp .= '**如需重新辅种，请删除 ./torrent/cachehash 辅种缓存。**'.$br;
+        // 移动做种
+        if (self::$wechatMsg['MoveSuccess'] || self::$wechatMsg['MoveError']) {
+            $desp .= $br.'----------'.$br;
+            $desp .= '**移动成功：'.self::$wechatMsg['MoveSuccess']. '**  [会把hash加入移动缓存]' .$br;
+            $desp .= '**移动失败：'.self::$wechatMsg['MoveError']. '**  [解决错误提示，可以重试]' .$br;
+            $desp .= '**如需重新移动，请删除 ./torrent/cachemove 移动缓存。**'.$br;
+        }        
+        $desp .= $br.'*此消息将在3天后过期*。';
         return ff($text, $desp);
     }
     /**

app/Library/IFile.php

@@ -1,5 +1,6 @@
 <?php
 namespace IYUU\Library;
+
 /**
  * @class IFile
  * @brief IFile 文件处理类

app/Library/Oauth.php

@@ -1,6 +1,8 @@
 <?php
 namespace IYUU\Library;
+
 use Curl\Curl;
+
 /**
  * IYUU用户注册、认证
  */

app/Library/Table.php

@@ -1,5 +1,6 @@
 <?php
 namespace IYUU\Library;
+
 /**
  * Created by PhpStorm.
  * User: 大卫

app/helper.php

@@ -1,6 +1,7 @@
 <?php
 use IYUU\Library\IFile;
 use IYUU\Library\Table;
+
 /**
  * 调试函数
  * @param $data

iyuu.php

@@ -26,6 +26,7 @@
 require_once __DIR__ . '/init.php';
 echo '当前脚本路径：'.__FILE__.PHP_EOL;
 use IYUU\AutoReseed;
+
 AutoReseed::init();
 AutoReseed::call();
 exit(0);

wiki/公告栏.md

@@ -1,5 +1,24 @@
 # 公告栏
 
+### 2020年7月13日08:00:00
+
+【更新提醒】v1.9.1
+
+优化：App.Api.Sites接口请求时携带版本号（版本为空或低于v1.9.1会返回旧数据）；
+
+新增：异步间隔流控算法，适用所有站点；各站独立、执行时间最优；
+
+【升级方法】
+
+1.异步间隔流控使用方法：参考v1.9.1版本的config.sample.php[第242-245行]，把他复制到你想应用流控的站点配置项内；解释：count表示每次辅种的最大数量，sleep表示当前站点每次下载种子最小间隔多少秒。
+
+2.url_replace和url_join是为了最大化兼容未来各种类型站点提前准备的，可以自定义URL；
+
+解释：url_replace是替换下载链接时使用，让下载链接支持替换任意参数。举例：'url_replace'=>array('{passkey}'=>'123456789'), 下载链接https://pt.baidu.com/download.php?id={}&passkey={passkey}，替换后变为https://pt.baidu.com/download.php?id={}&passkey=123456789
+
+解释：url_join是拼接下载链接是使用，让下载链接支持任意自定义参数。举例：
+'url_join' => array('ipv6=1','https=1'), 下载链接https://pt.baidu.com/download.php?id={}&passkey=123456789，拼接后变为https://pt.baidu.com/download.php?id={}&passkey=123456789&ipv6=1&https=1
+
 ### 2020年7月12日19:34:03
 
 【新增功能】v1.9.0