xiaohuilam / laravel-flysystem-wantu

sdk/Core/UploadClient.php

Spacing +51 added lines, -51 removed lines

@@ -38,10 +38,10 @@ 
             return $this->_errorResponse("FileNotExist", "file not exist");
         }
         if (empty($uploadOption)) {
-            $uploadOption = new UploadOption();     //如果用户没有传递UploadOption，则生成一个默认的
+            $uploadOption = new UploadOption(); //如果用户没有传递UploadOption，则生成一个默认的
         }
         if (empty($uploadOption->name)) {
-            $uploadOption->name = basename($filePath);        //如果用户没有设置name属性，则使用上传时的文件名
+            $uploadOption->name = basename($filePath); //如果用户没有设置name属性，则使用上传时的文件名
         }
         // UploadPolicy 和 UploadOption检查
         list($isValid, $message) = $this->checkUploadInfo($uploadPolicy, $uploadOption);
@@ -68,7 +68,7 @@ 
     {
         $data = file_get_contents($filePath);
         $uploadOption->setContent($data);
-        $url = $this->upload_host . Conf::UPLOAD_API_UPLOAD;        //普通上传的API
+        $url = $this->upload_host . Conf::UPLOAD_API_UPLOAD; //普通上传的API
         return $this->_send_request('POST', $url, $uploadPolicy, $uploadOption);
     }
 
@@ -81,8 +81,8 @@ 
      */
     protected function uploadSuperFile($filePath, UploadPolicy $uploadPolicy, UploadOption $uploadOption = null)
     {
-        $fileSize = filesize($filePath);        // 文件大小
-        $blockSize = $uploadOption->blockSize;  // 文件分片大小
+        $fileSize = filesize($filePath); // 文件大小
+        $blockSize = $uploadOption->blockSize; // 文件分片大小
         $blockNum = intval(ceil($fileSize / $blockSize)); // 文件分片后的块数
         for ($i = 0; $i < $blockNum; $i++) {
             $currentSize = $blockSize; // 当前文件块的大小
@@ -95,8 +95,8 @@ 
             $httpRes = null;
             if (0 == $i) {
                 // 分片初始化阶段
-                $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_INIT;        //初始化分片上传的API
-                $uploadOption->optionType = UpOptionType::BLOCK_INIT_UPLOAD;    //初始化分片时的Option类型
+                $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_INIT; //初始化分片上传的API
+                $uploadOption->optionType = UpOptionType::BLOCK_INIT_UPLOAD; //初始化分片时的Option类型
                 $httpRes = $this->_send_request('POST', $url, $uploadPolicy, $uploadOption);
                 $uploadId = isset($httpRes['uploadId']) ? $httpRes['uploadId'] : null; // 分片上传ID（OSS用于区分上传的id）
                 $id = isset($httpRes['id']) ? $httpRes['id'] : null; // 上传唯一ID（多媒体服务用于区分上传的id）
@@ -104,16 +104,16 @@ 
                 $uploadOption->setUniqueIdId($id);
             } else {
                 // 分片上传过程中
-                $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_UPLOAD;      //分片上传过程中的API
-                $uploadOption->optionType = UpOptionType::BLOCK_RUN_UPLOAD;     //分片上传过程中的Option类型
-                $uploadOption->setPartNumber($i + 1);                           //
+                $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_UPLOAD; //分片上传过程中的API
+                $uploadOption->optionType = UpOptionType::BLOCK_RUN_UPLOAD; //分片上传过程中的Option类型
+                $uploadOption->setPartNumber($i + 1); //
                 $httpRes = $this->_send_request('POST', $url, $uploadPolicy, $uploadOption);
             }
             // 如果分片上传失败，则取消cancel分片上传任务，然后返回错误信息
             if (!$httpRes['isSuccess']) {
                 if ($uploadOption->checkMutipartParas()) {
-                    $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_CANCEL;      //取消分片任务的API
-                    $uploadOption->optionType = UpOptionType::BLOCK_CANCEL_UPLOAD;  //取消分片任务时的Option类型
+                    $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_CANCEL; //取消分片任务的API
+                    $uploadOption->optionType = UpOptionType::BLOCK_CANCEL_UPLOAD; //取消分片任务时的Option类型
                     $this->_send_request('POST', $url, $uploadPolicy, $uploadOption); // 不判断取消分片任务返回的结果
                 }
                 return $httpRes;
@@ -126,9 +126,9 @@ 
             $uploadOption->addPartNumberAndETag($httpRes['partNumber'], $httpRes['eTag']);
         }
         // 分片上传完成
-        $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_COMPLETE;            //完成分片上传任务的API
-        $uploadOption->optionType = UpOptionType::BLOCK_COMPLETE_UPLOAD;        //完成分片上传任务时的Option类型
-        $uploadOption->setMd5(md5_file($filePath));                         //文件Md5
+        $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_COMPLETE; //完成分片上传任务的API
+        $uploadOption->optionType = UpOptionType::BLOCK_COMPLETE_UPLOAD; //完成分片上传任务时的Option类型
+        $uploadOption->setMd5(md5_file($filePath)); //文件Md5
         return $this->_send_request('POST', $url, $uploadPolicy, $uploadOption);
     }
 
@@ -144,7 +144,7 @@ 
     public function uploadData($data, UploadPolicy $uploadPolicy, UploadOption $uploadOption = null)
     {
         if (empty($uploadOption)) {
-            $uploadOption = new UploadOption();     //如果用户没有传递UploadOption，则生成一个默认的
+            $uploadOption = new UploadOption(); //如果用户没有传递UploadOption，则生成一个默认的
         }
         // UploadPolicy 和 UploadOption检查
         list($isValid, $message) = $this->checkUploadInfo($uploadPolicy, $uploadOption);
@@ -158,7 +158,7 @@ 
         }
         // 文件不大于设定的分片大小(默认2M)，则直接上传uploadMiniFile()
         $uploadOption->setContent($data);
-        $url = $this->upload_host . Conf::UPLOAD_API_UPLOAD;        //普通上传的API
+        $url = $this->upload_host . Conf::UPLOAD_API_UPLOAD; //普通上传的API
         return $this->_send_request('POST', $url, $uploadPolicy, $uploadOption);
     }
 
@@ -171,8 +171,8 @@ 
      */
     protected function uploadSuperData($data, UploadPolicy $uploadPolicy, UploadOption $uploadOption = null)
     {
-        $dataSize = strlen($data);          // 文件大小
-        $blockSize = $uploadOption->blockSize;  // 文件分片大小
+        $dataSize = strlen($data); // 文件大小
+        $blockSize = $uploadOption->blockSize; // 文件分片大小
         $blockNum = intval(ceil($dataSize / $blockSize)); // 文件分片后的块数
         for ($i = 0; $i < $blockNum; $i++) {
             $currentSize = $blockSize; // 当前文件块的大小
@@ -185,8 +185,8 @@ 
             $httpRes = null;
             if (0 == $i) {
                 // 分片初始化阶段
-                $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_INIT;        //初始化分片上传的API
-                $uploadOption->optionType = UpOptionType::BLOCK_INIT_UPLOAD;    //初始化分片时的Option类型
+                $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_INIT; //初始化分片上传的API
+                $uploadOption->optionType = UpOptionType::BLOCK_INIT_UPLOAD; //初始化分片时的Option类型
                 $httpRes = $this->_send_request('POST', $url, $uploadPolicy, $uploadOption);
                 $uploadId = isset($httpRes['uploadId']) ? $httpRes['uploadId'] : null; // 分片上传ID（OSS用于区分上传的id）
                 $id = isset($httpRes['id']) ? $httpRes['id'] : null; // 上传唯一ID（多媒体服务用于区分上传的id）
@@ -194,16 +194,16 @@ 
                 $uploadOption->setUniqueIdId($id);
             } else {
                 // 分片上传过程中
-                $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_UPLOAD;      //分片上传过程中的API
-                $uploadOption->optionType = UpOptionType::BLOCK_RUN_UPLOAD;     //分片上传过程中的Option类型
-                $uploadOption->setPartNumber($i + 1);                           //
+                $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_UPLOAD; //分片上传过程中的API
+                $uploadOption->optionType = UpOptionType::BLOCK_RUN_UPLOAD; //分片上传过程中的Option类型
+                $uploadOption->setPartNumber($i + 1); //
                 $httpRes = $this->_send_request('POST', $url, $uploadPolicy, $uploadOption);
             }
             // 如果分片上传失败，则取消cancel分片上传任务，然后返回错误信息
             if (!$httpRes['isSuccess']) {
                 if ($uploadOption->checkMutipartParas()) {
-                    $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_CANCEL;      //取消分片任务的API
-                    $uploadOption->optionType = UpOptionType::BLOCK_CANCEL_UPLOAD;  //取消分片任务时的Option类型
+                    $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_CANCEL; //取消分片任务的API
+                    $uploadOption->optionType = UpOptionType::BLOCK_CANCEL_UPLOAD; //取消分片任务时的Option类型
                     $this->_send_request('POST', $url, $uploadPolicy, $uploadOption); // 不判断取消分片任务返回的结果
                 }
                 return $httpRes;
@@ -212,9 +212,9 @@ 
             $uploadOption->addPartNumberAndETag($httpRes['partNumber'], $httpRes['eTag']);
         }
         // 分片上传完成
-        $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_COMPLETE;            //完成分片上传任务的API
-        $uploadOption->optionType = UpOptionType::BLOCK_COMPLETE_UPLOAD;        //完成分片上传任务时的Option类型
-        $uploadOption->setMd5(md5($data));                          //文件Md5
+        $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_COMPLETE; //完成分片上传任务的API
+        $uploadOption->optionType = UpOptionType::BLOCK_COMPLETE_UPLOAD; //完成分片上传任务时的Option类型
+        $uploadOption->setMd5(md5($data)); //文件Md5
         return $this->_send_request('POST', $url, $uploadPolicy, $uploadOption);
     }
 
@@ -232,10 +232,10 @@ 
             return $this->_errorResponse("FileNotExist", "file not exist");
         }
         if (empty($uploadOption)) {
-            $uploadOption = new UploadOption();     //如果用户没有传递UploadOption，则生成一个默认的
+            $uploadOption = new UploadOption(); //如果用户没有传递UploadOption，则生成一个默认的
         }
         if (empty($uploadOption->name)) {
-            $uploadOption->name = basename($filePath);        //如果用户没有设置name属性，则使用上传时的文件名
+            $uploadOption->name = basename($filePath); //如果用户没有设置name属性，则使用上传时的文件名
         }
         $blockData = file_get_contents($encodePath, 0, null, 0, $uploadOption->blockSize);
         return $this->multipartInitByData($blockData, $uploadPolicy, $uploadOption);
@@ -251,7 +251,7 @@ 
     public function multipartInitByData($blockData, UploadPolicy $uploadPolicy, UploadOption $uploadOption)
     {
         if (empty($uploadOption)) {
-            $uploadOption = new UploadOption();     //如果用户没有传递UploadOption，则生成一个默认的
+            $uploadOption = new UploadOption(); //如果用户没有传递UploadOption，则生成一个默认的
         }
         // UploadPolicy 和 UploadOption检查
         list($isValid, $message) = $this->checkUploadInfo($uploadPolicy, $uploadOption);
@@ -259,13 +259,13 @@ 
             return $this->_errorResponse("ErrorUploadInfo", "error upload policy or option:" . $message);
         }
         // 数据大小不等于设定的分片大小(默认2M)，则无法完成初始化
-        $dataSize = strlen($blockData);         // 数据文件大小
+        $dataSize = strlen($blockData); // 数据文件大小
         if ($dataSize != ($uploadOption->blockSize)) {
             return $this->_errorResponse("MultipartInitError", "UploadOption's blockSize is not equal to data's size");
         }
         $uploadOption->setContent($blockData); // 设置待上传的文件块
-        $uploadOption->optionType = UpOptionType::BLOCK_INIT_UPLOAD;    //初始化分片时的Option类型
-        $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_INIT;        //初始化分片上传的API
+        $uploadOption->optionType = UpOptionType::BLOCK_INIT_UPLOAD; //初始化分片时的Option类型
+        $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_INIT; //初始化分片上传的API
         $httpRes = $this->_send_request('POST', $url, $uploadPolicy, $uploadOption);
         //若成功返回，则保存初始化成功的uploadId、id 以及 partNumber、eTag
         $uploadId = isset($httpRes['uploadId']) ? $httpRes['uploadId'] : null; // 分片上传ID（OSS用于区分上传的id）
@@ -290,8 +290,8 @@ 
         if (!file_exists($encodePath)) {
             return $this->_errorResponse("FileNotExist", "file not exist");
         }
-        $fileSize = filesize($encodePath);      // 文件大小
-        $blockSize = $uploadOption->blockSize;  // 文件分片大小
+        $fileSize = filesize($encodePath); // 文件大小
+        $blockSize = $uploadOption->blockSize; // 文件分片大小
         $blockNum = intval(ceil($fileSize / $blockSize)); // 文件分片后的块数
         $currentSize = $blockSize; // 当前文件块的大小
         if ($uploadOption->getPartNumber() == $blockNum) {
@@ -317,8 +317,8 @@ 
             return $this->_errorResponse("MultipartUploadError", "multipart upload's parameters(id,uploadId,partNumber) error");
         }
         $uploadOption->setContent($blockData); // 设置待上传的文件块
-        $uploadOption->optionType = UpOptionType::BLOCK_RUN_UPLOAD;     //分片上传过程中的Option类型
-        $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_UPLOAD;      //分片上传过程中的API
+        $uploadOption->optionType = UpOptionType::BLOCK_RUN_UPLOAD; //分片上传过程中的Option类型
+        $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_UPLOAD; //分片上传过程中的API
         $httpRes = $this->_send_request('POST', $url, $uploadPolicy, $uploadOption);
         if (isset($httpRes['partNumber']) && isset($httpRes['eTag'])) {
             $uploadOption->addPartNumberAndETag($httpRes['partNumber'], $httpRes['eTag']);
@@ -339,8 +339,8 @@ 
         if (!$uploadOption->checkMutipartParas() || empty($fileMd5)) {
             return $this->_errorResponse("MultipartCompleteError", "multipart upload's parameters(id,uploadId,md5) error");
         }
-        $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_COMPLETE;            //完成分片上传任务的API
-        $uploadOption->optionType = UpOptionType::BLOCK_COMPLETE_UPLOAD;        //完成分片上传任务时的Option类型
+        $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_COMPLETE; //完成分片上传任务的API
+        $uploadOption->optionType = UpOptionType::BLOCK_COMPLETE_UPLOAD; //完成分片上传任务时的Option类型
         return $this->_send_request('POST', $url, $uploadPolicy, $uploadOption);
     }
 
@@ -355,8 +355,8 @@ 
         if (!$uploadOption->checkMutipartParas()) {
             return $this->_errorResponse("MultipartCancelError", "multipart upload's parameters(id,uploadId) error");
         }
-        $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_CANCEL;      //取消分片任务的API
-        $uploadOption->optionType = UpOptionType::BLOCK_CANCEL_UPLOAD;  //取消分片任务时的Option类型
+        $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_CANCEL; //取消分片任务的API
+        $uploadOption->optionType = UpOptionType::BLOCK_CANCEL_UPLOAD; //取消分片任务时的Option类型
         return $this->_send_request('POST', $url, $uploadPolicy, $uploadOption);
     }
 
@@ -387,17 +387,17 @@ 
                 list($contentType, $httpBody) = $this->BuildMultipartForm($uploadOption);
                 $length = @strlen($httpBody);
                 array_push($_headers, "Content-Type: {$contentType}");
-                curl_setopt($ch, CURLOPT_POSTFIELDS, $httpBody);            //请求体
+                curl_setopt($ch, CURLOPT_POSTFIELDS, $httpBody); //请求体
             }
             array_push($_headers, "Content-Length: {$length}");
-            curl_setopt($ch, CURLOPT_HEADER, 1);                            //设置头部
-            curl_setopt($ch, CURLOPT_HTTPHEADER, $_headers);                //请求头
-            curl_setopt($ch, CURLOPT_TIMEOUT, $uploadOption->timeout);  //持续时长
-            curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 10);               //连接超时时长
+            curl_setopt($ch, CURLOPT_HEADER, 1); //设置头部
+            curl_setopt($ch, CURLOPT_HTTPHEADER, $_headers); //请求头
+            curl_setopt($ch, CURLOPT_TIMEOUT, $uploadOption->timeout); //持续时长
+            curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 10); //连接超时时长
             curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1); //成功，只返回结果，不自动输出任何内容。如果失败返回FALSE
             curl_setopt($ch, CURLOPT_FOLLOWLOCATION, 0);
             curl_setopt($ch, CURLOPT_URL, $url);
-            curl_setopt($ch, CURLOPT_CUSTOMREQUEST, $method);           //自定义请求
+            curl_setopt($ch, CURLOPT_CUSTOMREQUEST, $method); //自定义请求
             //设置请求方式(GET或POST等)
             if ($method == 'PUT' || $method == 'POST') {
                 curl_setopt($ch, CURLOPT_POST, 1);
@@ -418,10 +418,10 @@ 
             } else {
                 //解析返回结果，并判断是否上传成功
                 $http_code = curl_getinfo($ch, CURLINFO_HTTP_CODE);
-                $success = ($http_code == 200) ? true : false;                  //判断是否上传成功
+                $success = ($http_code == 200) ? true : false; //判断是否上传成功
                 $resStr = explode("\r\n\r\n", $response, 2);
                 $resBody = isset($resStr[1]) ? $resStr[1] : '';
-                $resArray = json_decode($resBody, true);                        //解析得到结果
+                $resArray = json_decode($resBody, true); //解析得到结果
                 $result = (empty($resArray) ? $result : $resArray);
             }
         } catch (Exception $e) {