✨ 支持多种文件检查策略

Author: Mxmilu666

README.md

@@ -61,12 +61,12 @@ $config=[
     ],
     "file"=> [
         "cache_dir"=> "./cache",//缓存文件夹
-        "check"=> "hash",//检查文件策略(hash:检查文件hash size:检查文件大小 exists:检查文件是否存在)
+        "check"=> "size",//检查文件策略(hash:检查文件hash size:检查文件大小 exists:检查文件是否存在)
     ],
     "advanced"=> [
         "keepalive"=> 60,//keepalive时间,秒为单位(不建议调整)
         "MaxConcurrent"=> 30,//下载使用的线程
-        "Debug"=> true,//Debug开关
+        "Debug"=> false,//Debug开关
     ],
 ];
 ```

config.php

@@ -10,7 +10,7 @@
     ],
     "file"=> [
         "cache_dir"=> "./cache",//缓存文件夹
-        "check"=> "hash",//检查文件策略(hash:检查文件hash size:检查文件大小 exists:检查文件是否存在)
+        "check"=> "size",//检查文件策略(hash:检查文件hash size:检查文件大小 exists:检查文件是否存在)
     ],
     "advanced"=> [
         "keepalive"=> 60,//keepalive时间,秒为单位(不建议调整)

inc/cluster.php

@@ -243,10 +243,10 @@ class FilesCheck {
 
     public function __construct($filesList) {
         $this->filesList = $filesList;
-        mlog("检查策略:hash");
     }
 
     public function FilesCheckerhash() {
+        mlog("检查策略:hash");
         $bar = new CliProgressBar(count($this->filesList));
         $bar->setDetails("[FileCheck]");
         $bar->display();
@@ -282,4 +282,67 @@ public function FilesCheckerhash() {
         return $this->Missfile;
     }
 
+    public function FilesCheckersize() {
+        mlog("检查策略:size");
+        $bar = new CliProgressBar(count($this->filesList));
+        $bar->setDetails("[FileCheck]");
+        $bar->display();
+        foreach ($this->filesList as $file) {
+            global $shouldExit;
+            global $DOWNLOAD_DIR;
+            if ($shouldExit) {
+                return;
+                break;
+            }
+            if (!file_exists($DOWNLOAD_DIR.'/'.substr($file->hash, 0, 2).'/'.$file->hash)){
+                $this->Missfile[] = new BMCLAPIFile(
+                    $file->path,
+                    $file->hash,
+                    $file->size,
+                    $file->mtime
+                );
+            }
+            else{
+                if (filesize($DOWNLOAD_DIR.'/'.substr($file->hash, 0, 2).'/'.$file->hash) != $file->size) {
+                    $this->Missfile[] = new BMCLAPIFile(
+                        $file->path,
+                        $file->hash,
+                        $file->size,
+                        $file->mtime
+                    );
+                }
+            }
+        $bar->progress();
+        }
+        $bar->display();
+        $bar->end();
+        return $this->Missfile;
+    }
+
+    public function FilesCheckerexists() {
+        mlog("检查策略:exists");
+        $bar = new CliProgressBar(count($this->filesList));
+        $bar->setDetails("[FileCheck]");
+        $bar->display();
+        foreach ($this->filesList as $file) {
+            global $shouldExit;
+            global $DOWNLOAD_DIR;
+            if ($shouldExit) {
+                return;
+                break;
+            }
+            if (!file_exists($DOWNLOAD_DIR.'/'.substr($file->hash, 0, 2).'/'.$file->hash)){
+                $this->Missfile[] = new BMCLAPIFile(
+                    $file->path,
+                    $file->hash,
+                    $file->size,
+                    $file->mtime
+                );
+            }
+        $bar->progress();
+        }
+        $bar->display();
+        $bar->end();
+        return $this->Missfile;
+    }
 }

inc/socketio.php

@@ -13,6 +13,7 @@ public function __construct($url,$token,$kattl) {
         $this->url = $url;
         $this->token = $token;
         $this->kattl = $kattl;
+        $katimeid = 0;
     }
     public function connect() {
         $this->client = $client = new Client($this->url, 443, true);
@@ -56,6 +57,7 @@ public function connect() {
             }
             if ($code[0] == '430'){
                 $jsondata = json_decode(substr($data, strlen($code[0])),true);
+                print_r($jsondata);
                 if (isset($jsondata[0][1]['cert'])){
                     $this->certdata = $jsondata;
                 }

main.php

@@ -59,14 +59,30 @@ function registerSigintHandler() {
     $cluster = new cluster($tokendata['token'],VERSION);
     $files = $cluster->getFileList();
     $FilesCheck = new FilesCheck($files);
-    $Missfile = $FilesCheck->FilesCheckerhash();
+    if ($config['file']['check'] == "hash"){
+        $Missfile = $FilesCheck->FilesCheckerhash();
+    }
+    elseif($config['file']['check'] == "size"){
+        $Missfile = $FilesCheck->FilesCheckersize();
+    }
+    elseif($config['file']['check'] == "exists"){
+        $Missfile = $FilesCheck->FilesCheckerexists();
+    }
     if (is_array($Missfile)){
         mlog("缺失/损坏".count($Missfile)."个文件");
         while(is_array($Missfile)){
             $download = new download($Missfile,$config['advanced']['MaxConcurrent']);
             $download->downloadFiles();
             $FilesCheck = new FilesCheck($Missfile);
-            $Missfile = $FilesCheck->FilesCheckerhash();
+            if ($config['file']['check'] == "hash"){
+                $Missfile = $FilesCheck->FilesCheckerhash();
+            }
+            elseif($config['file']['check'] == "size"){
+                $Missfile = $FilesCheck->FilesCheckersize();
+            }
+            elseif($config['file']['check'] == "exists"){
+                $Missfile = $FilesCheck->FilesCheckerexists();
+            }
             if (is_array($Missfile)){
                 //mlog("缺失/损坏".count($Missfile)."个文件");
             }