Passed
Push — master ( 103d2b...e57950 )
by xiaohui
02:15
created
sdk/Core/UploadClient.php 2 patches
Indentation   +541 added lines, -541 removed lines patch added patch discarded remove patch
@@ -11,128 +11,128 @@  discard block
 block discarded – undo
11 11
 
12 12
 class UploadClient
13 13
 {
14
-    private $upload_host;
15
-    private $ak;
16
-    private $sk;
17
-    private $type; // "CLOUD" or "TOP";
14
+	private $upload_host;
15
+	private $ak;
16
+	private $sk;
17
+	private $type; // "CLOUD" or "TOP";
18 18
 
19
-    public function __construct($ak, $sk, $type = Conf::TYPE_TOP)
20
-    {
21
-        $this->ak = $ak;
22
-        $this->sk = $sk;
23
-        $this->type = $type;
24
-        $this->upload_host = Conf::UPLOAD_HOST_MEDIA;
25
-    }
19
+	public function __construct($ak, $sk, $type = Conf::TYPE_TOP)
20
+	{
21
+		$this->ak = $ak;
22
+		$this->sk = $sk;
23
+		$this->type = $type;
24
+		$this->upload_host = Conf::UPLOAD_HOST_MEDIA;
25
+	}
26 26
 
27
-    /**
28
-     * 上传文件。根据文件大小判断是否进行分片
29
-     * @param string $filePath  文件路径
30
-     * @param UploadPolicy $uploadPolicy    上传策略
31
-     * @param UploadOption $uploadOption    上传选项
32
-     * @return array
33
-     */
34
-    public function upload($filePath, UploadPolicy $uploadPolicy, UploadOption $uploadOption = null)
35
-    {
36
-        $encodePath = iconv('UTF-8', 'GB2312', $filePath); //中文需要转换成gb2312,file_exist等函数才能识别
37
-        if (!file_exists($encodePath)) {
38
-            return $this->_errorResponse("FileNotExist", "file not exist");
39
-        }
40
-        if (empty($uploadOption)) {
41
-            $uploadOption = new UploadOption();     //如果用户没有传递UploadOption,则生成一个默认的
42
-        }
43
-        if (empty($uploadOption->name)) {
44
-            $uploadOption->name = basename($filePath);        //如果用户没有设置name属性,则使用上传时的文件名
45
-        }
46
-        // UploadPolicy 和 UploadOption检查
47
-        list($isValid, $message) = $this->checkUploadInfo($uploadPolicy, $uploadOption);
48
-        if (!$isValid) {
49
-            return $this->_errorResponse("ErrorUploadInfo", "error upload policy or option:" . $message);
50
-        }
51
-        $fileSize = filesize($encodePath);
52
-        // 文件大于设定的分片大小(默认2M),则进行分片上传uploadSuperfile()
53
-        if ($fileSize > ($uploadOption->blockSize)) {
54
-            return $this->uploadSuperFile($encodePath, $uploadPolicy, $uploadOption);
55
-        }
56
-        // 文件不大于设定的分片大小(默认2M),则直接上传uploadMiniFile()
57
-        return $this->uploadMiniFile($encodePath, $uploadPolicy, $uploadOption);
58
-    }
27
+	/**
28
+	 * 上传文件。根据文件大小判断是否进行分片
29
+	 * @param string $filePath  文件路径
30
+	 * @param UploadPolicy $uploadPolicy    上传策略
31
+	 * @param UploadOption $uploadOption    上传选项
32
+	 * @return array
33
+	 */
34
+	public function upload($filePath, UploadPolicy $uploadPolicy, UploadOption $uploadOption = null)
35
+	{
36
+		$encodePath = iconv('UTF-8', 'GB2312', $filePath); //中文需要转换成gb2312,file_exist等函数才能识别
37
+		if (!file_exists($encodePath)) {
38
+			return $this->_errorResponse("FileNotExist", "file not exist");
39
+		}
40
+		if (empty($uploadOption)) {
41
+			$uploadOption = new UploadOption();     //如果用户没有传递UploadOption,则生成一个默认的
42
+		}
43
+		if (empty($uploadOption->name)) {
44
+			$uploadOption->name = basename($filePath);        //如果用户没有设置name属性,则使用上传时的文件名
45
+		}
46
+		// UploadPolicy 和 UploadOption检查
47
+		list($isValid, $message) = $this->checkUploadInfo($uploadPolicy, $uploadOption);
48
+		if (!$isValid) {
49
+			return $this->_errorResponse("ErrorUploadInfo", "error upload policy or option:" . $message);
50
+		}
51
+		$fileSize = filesize($encodePath);
52
+		// 文件大于设定的分片大小(默认2M),则进行分片上传uploadSuperfile()
53
+		if ($fileSize > ($uploadOption->blockSize)) {
54
+			return $this->uploadSuperFile($encodePath, $uploadPolicy, $uploadOption);
55
+		}
56
+		// 文件不大于设定的分片大小(默认2M),则直接上传uploadMiniFile()
57
+		return $this->uploadMiniFile($encodePath, $uploadPolicy, $uploadOption);
58
+	}
59 59
 
60
-    /**
61
-     * 上传小文件
62
-     * @param string $filePath 文件路径
63
-     * @param UploadPolicy $uploadPolicy 上传策略
64
-     * @param UploadOption $uploadOption 上传选项
65
-     * @return array
66
-     */
67
-    protected function uploadMiniFile($filePath, UploadPolicy $uploadPolicy, UploadOption $uploadOption = null)
68
-    {
69
-        $data = file_get_contents($filePath);
70
-        $uploadOption->setContent($data);
71
-        $url = $this->upload_host . Conf::UPLOAD_API_UPLOAD;        //普通上传的API
72
-        return $this->_send_request('POST', $url, $uploadPolicy, $uploadOption);
73
-    }
60
+	/**
61
+	 * 上传小文件
62
+	 * @param string $filePath 文件路径
63
+	 * @param UploadPolicy $uploadPolicy 上传策略
64
+	 * @param UploadOption $uploadOption 上传选项
65
+	 * @return array
66
+	 */
67
+	protected function uploadMiniFile($filePath, UploadPolicy $uploadPolicy, UploadOption $uploadOption = null)
68
+	{
69
+		$data = file_get_contents($filePath);
70
+		$uploadOption->setContent($data);
71
+		$url = $this->upload_host . Conf::UPLOAD_API_UPLOAD;        //普通上传的API
72
+		return $this->_send_request('POST', $url, $uploadPolicy, $uploadOption);
73
+	}
74 74
 
75
-    /**
76
-     * 分片上传大文件
77
-     * @param string $filePath 文件路径
78
-     * @param UploadPolicy $uploadPolicy 上传策略
79
-     * @param UploadOption $uploadOption 上传选项
80
-     * @return array
81
-     */
82
-    protected function uploadSuperFile($filePath, UploadPolicy $uploadPolicy, UploadOption $uploadOption = null)
83
-    {
84
-        $fileSize = filesize($filePath);        // 文件大小
85
-        $blockSize = $uploadOption->blockSize;  // 文件分片大小
86
-        $blockNum = intval(ceil($fileSize / $blockSize)); // 文件分片后的块数
87
-        for ($i = 0; $i < $blockNum; $i++) {
88
-            $currentSize = $blockSize; // 当前文件块的大小
89
-            if (($i + 1) === $blockNum) {
90
-                $currentSize = ($fileSize - ($blockNum - 1) * $blockSize); // 计算最后一个块的大小
91
-            }
92
-            $offset = $i * $blockSize; // 当前文件块相对于文件开头的偏移量(块的起始位置)
93
-            $blockData = file_get_contents($filePath, 0, null, $offset, $currentSize); //当前文件块的数据
94
-            $uploadOption->setContent($blockData); // 设置待上传的文件块
95
-            $httpRes = null;
96
-            if (0 == $i) {
97
-                // 分片初始化阶段
98
-                $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_INIT;        //初始化分片上传的API
99
-                $uploadOption->optionType = UpOptionType::BLOCK_INIT_UPLOAD;    //初始化分片时的Option类型
100
-                $httpRes = $this->_send_request('POST', $url, $uploadPolicy, $uploadOption);
101
-                $uploadId = isset($httpRes['uploadId']) ? $httpRes['uploadId'] : null; // 分片上传ID(OSS用于区分上传的id)
102
-                $id = isset($httpRes['id']) ? $httpRes['id'] : null; // 上传唯一ID(多媒体服务用于区分上传的id)
103
-                $uploadOption->setUploadId($uploadId);
104
-                $uploadOption->setUniqueIdId($id);
105
-            } else {
106
-                // 分片上传过程中
107
-                $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_UPLOAD;      //分片上传过程中的API
108
-                $uploadOption->optionType = UpOptionType::BLOCK_RUN_UPLOAD;     //分片上传过程中的Option类型
109
-                $uploadOption->setPartNumber($i + 1);                           //
110
-                $httpRes = $this->_send_request('POST', $url, $uploadPolicy, $uploadOption);
111
-            }
112
-            // 如果分片上传失败,则取消cancel分片上传任务,然后返回错误信息
113
-            if (!$httpRes['isSuccess']) {
114
-                if ($uploadOption->checkMutipartParas()) {
115
-                    $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_CANCEL;      //取消分片任务的API
116
-                    $uploadOption->optionType = UpOptionType::BLOCK_CANCEL_UPLOAD;  //取消分片任务时的Option类型
117
-                    $this->_send_request('POST', $url, $uploadPolicy, $uploadOption); // 不判断取消分片任务返回的结果
118
-                }
119
-                return $httpRes;
120
-                //              $message = isset( $httpRes ['message'] ) ? $httpRes ['message'] : null;
121
-                //              $code = isset( $httpRes ['code'] ) ? $httpRes ['code'] : null;
122
-                //              $requestId = isset( $httpRes ['requestId'] ) ? $httpRes ['requestId'] : null;
123
-                //              return $this->_errorResponse ( $code, "fail upload block file:" . $message, $requestId );
124
-            }
125
-            // 保存 块编号partNumber 和 标记ETag,用于分片完成时的参数设置
126
-            $uploadOption->addPartNumberAndETag($httpRes['partNumber'], $httpRes['eTag']);
127
-        }
128
-        // 分片上传完成
129
-        $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_COMPLETE;            //完成分片上传任务的API
130
-        $uploadOption->optionType = UpOptionType::BLOCK_COMPLETE_UPLOAD;        //完成分片上传任务时的Option类型
131
-        $uploadOption->setMd5(md5_file($filePath));                         //文件Md5
132
-        return $this->_send_request('POST', $url, $uploadPolicy, $uploadOption);
133
-    }
75
+	/**
76
+	 * 分片上传大文件
77
+	 * @param string $filePath 文件路径
78
+	 * @param UploadPolicy $uploadPolicy 上传策略
79
+	 * @param UploadOption $uploadOption 上传选项
80
+	 * @return array
81
+	 */
82
+	protected function uploadSuperFile($filePath, UploadPolicy $uploadPolicy, UploadOption $uploadOption = null)
83
+	{
84
+		$fileSize = filesize($filePath);        // 文件大小
85
+		$blockSize = $uploadOption->blockSize;  // 文件分片大小
86
+		$blockNum = intval(ceil($fileSize / $blockSize)); // 文件分片后的块数
87
+		for ($i = 0; $i < $blockNum; $i++) {
88
+			$currentSize = $blockSize; // 当前文件块的大小
89
+			if (($i + 1) === $blockNum) {
90
+				$currentSize = ($fileSize - ($blockNum - 1) * $blockSize); // 计算最后一个块的大小
91
+			}
92
+			$offset = $i * $blockSize; // 当前文件块相对于文件开头的偏移量(块的起始位置)
93
+			$blockData = file_get_contents($filePath, 0, null, $offset, $currentSize); //当前文件块的数据
94
+			$uploadOption->setContent($blockData); // 设置待上传的文件块
95
+			$httpRes = null;
96
+			if (0 == $i) {
97
+				// 分片初始化阶段
98
+				$url = $this->upload_host . Conf::UPLOAD_API_BLOCK_INIT;        //初始化分片上传的API
99
+				$uploadOption->optionType = UpOptionType::BLOCK_INIT_UPLOAD;    //初始化分片时的Option类型
100
+				$httpRes = $this->_send_request('POST', $url, $uploadPolicy, $uploadOption);
101
+				$uploadId = isset($httpRes['uploadId']) ? $httpRes['uploadId'] : null; // 分片上传ID(OSS用于区分上传的id)
102
+				$id = isset($httpRes['id']) ? $httpRes['id'] : null; // 上传唯一ID(多媒体服务用于区分上传的id)
103
+				$uploadOption->setUploadId($uploadId);
104
+				$uploadOption->setUniqueIdId($id);
105
+			} else {
106
+				// 分片上传过程中
107
+				$url = $this->upload_host . Conf::UPLOAD_API_BLOCK_UPLOAD;      //分片上传过程中的API
108
+				$uploadOption->optionType = UpOptionType::BLOCK_RUN_UPLOAD;     //分片上传过程中的Option类型
109
+				$uploadOption->setPartNumber($i + 1);                           //
110
+				$httpRes = $this->_send_request('POST', $url, $uploadPolicy, $uploadOption);
111
+			}
112
+			// 如果分片上传失败,则取消cancel分片上传任务,然后返回错误信息
113
+			if (!$httpRes['isSuccess']) {
114
+				if ($uploadOption->checkMutipartParas()) {
115
+					$url = $this->upload_host . Conf::UPLOAD_API_BLOCK_CANCEL;      //取消分片任务的API
116
+					$uploadOption->optionType = UpOptionType::BLOCK_CANCEL_UPLOAD;  //取消分片任务时的Option类型
117
+					$this->_send_request('POST', $url, $uploadPolicy, $uploadOption); // 不判断取消分片任务返回的结果
118
+				}
119
+				return $httpRes;
120
+				//              $message = isset( $httpRes ['message'] ) ? $httpRes ['message'] : null;
121
+				//              $code = isset( $httpRes ['code'] ) ? $httpRes ['code'] : null;
122
+				//              $requestId = isset( $httpRes ['requestId'] ) ? $httpRes ['requestId'] : null;
123
+				//              return $this->_errorResponse ( $code, "fail upload block file:" . $message, $requestId );
124
+			}
125
+			// 保存 块编号partNumber 和 标记ETag,用于分片完成时的参数设置
126
+			$uploadOption->addPartNumberAndETag($httpRes['partNumber'], $httpRes['eTag']);
127
+		}
128
+		// 分片上传完成
129
+		$url = $this->upload_host . Conf::UPLOAD_API_BLOCK_COMPLETE;            //完成分片上传任务的API
130
+		$uploadOption->optionType = UpOptionType::BLOCK_COMPLETE_UPLOAD;        //完成分片上传任务时的Option类型
131
+		$uploadOption->setMd5(md5_file($filePath));                         //文件Md5
132
+		return $this->_send_request('POST', $url, $uploadPolicy, $uploadOption);
133
+	}
134 134
 
135
-    /**上传字符串/二进制数据
135
+	/**上传字符串/二进制数据
136 136
      * @param string $data
137 137
      *          文件数据
138 138
      * @param UploadPolicy $uploadPolicy
@@ -141,454 +141,454 @@  discard block
 block discarded – undo
141 141
      *          上传选项
142 142
      * @return array
143 143
      */
144
-    public function uploadData($data, UploadPolicy $uploadPolicy, UploadOption $uploadOption = null)
145
-    {
146
-        if (empty($uploadOption)) {
147
-            $uploadOption = new UploadOption();     //如果用户没有传递UploadOption,则生成一个默认的
148
-        }
149
-        // UploadPolicy 和 UploadOption检查
150
-        list($isValid, $message) = $this->checkUploadInfo($uploadPolicy, $uploadOption);
151
-        if (!$isValid) {
152
-            return $this->_errorResponse("ErrorUploadInfo", "error upload policy or option:" . $message);
153
-        }
154
-        $dataSize = strlen($data);
155
-        // 文件大于设定的分片大小(默认2M),则进行分片上传uploadSuperfile()
156
-        if ($dataSize > ($uploadOption->blockSize)) {
157
-            return $this->uploadSuperData($data, $uploadPolicy, $uploadOption);
158
-        }
159
-        // 文件不大于设定的分片大小(默认2M),则直接上传uploadMiniFile()
160
-        $uploadOption->setContent($data);
161
-        $url = $this->upload_host . Conf::UPLOAD_API_UPLOAD;        //普通上传的API
162
-        return $this->_send_request('POST', $url, $uploadPolicy, $uploadOption);
163
-    }
144
+	public function uploadData($data, UploadPolicy $uploadPolicy, UploadOption $uploadOption = null)
145
+	{
146
+		if (empty($uploadOption)) {
147
+			$uploadOption = new UploadOption();     //如果用户没有传递UploadOption,则生成一个默认的
148
+		}
149
+		// UploadPolicy 和 UploadOption检查
150
+		list($isValid, $message) = $this->checkUploadInfo($uploadPolicy, $uploadOption);
151
+		if (!$isValid) {
152
+			return $this->_errorResponse("ErrorUploadInfo", "error upload policy or option:" . $message);
153
+		}
154
+		$dataSize = strlen($data);
155
+		// 文件大于设定的分片大小(默认2M),则进行分片上传uploadSuperfile()
156
+		if ($dataSize > ($uploadOption->blockSize)) {
157
+			return $this->uploadSuperData($data, $uploadPolicy, $uploadOption);
158
+		}
159
+		// 文件不大于设定的分片大小(默认2M),则直接上传uploadMiniFile()
160
+		$uploadOption->setContent($data);
161
+		$url = $this->upload_host . Conf::UPLOAD_API_UPLOAD;        //普通上传的API
162
+		return $this->_send_request('POST', $url, $uploadPolicy, $uploadOption);
163
+	}
164 164
 
165
-    /**
166
-     * 分片上传大文件数据
167
-     * @param string $data 文件数据
168
-     * @param UploadPolicy $uploadPolicy 上传策略
169
-     * @param UploadOption $uploadOption 上传选项
170
-     * @return array
171
-     */
172
-    protected function uploadSuperData($data, UploadPolicy $uploadPolicy, UploadOption $uploadOption = null)
173
-    {
174
-        $dataSize = strlen($data);          // 文件大小
175
-        $blockSize = $uploadOption->blockSize;  // 文件分片大小
176
-        $blockNum = intval(ceil($dataSize / $blockSize)); // 文件分片后的块数
177
-        for ($i = 0; $i < $blockNum; $i++) {
178
-            $currentSize = $blockSize; // 当前文件块的大小
179
-            if (($i + 1) === $blockNum) {
180
-                $currentSize = ($dataSize - ($blockNum - 1) * $blockSize); // 计算最后一个块的大小
181
-            }
182
-            $offset = $i * $blockSize; // 当前文件块相对于文件开头的偏移量(块的起始位置)
183
-            $blockData = substr($data, $offset, $currentSize); //当前文件块的数据
184
-            $uploadOption->setContent($blockData); // 设置待上传的文件块
185
-            $httpRes = null;
186
-            if (0 == $i) {
187
-                // 分片初始化阶段
188
-                $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_INIT;        //初始化分片上传的API
189
-                $uploadOption->optionType = UpOptionType::BLOCK_INIT_UPLOAD;    //初始化分片时的Option类型
190
-                $httpRes = $this->_send_request('POST', $url, $uploadPolicy, $uploadOption);
191
-                $uploadId = isset($httpRes['uploadId']) ? $httpRes['uploadId'] : null; // 分片上传ID(OSS用于区分上传的id)
192
-                $id = isset($httpRes['id']) ? $httpRes['id'] : null; // 上传唯一ID(多媒体服务用于区分上传的id)
193
-                $uploadOption->setUploadId($uploadId);
194
-                $uploadOption->setUniqueIdId($id);
195
-            } else {
196
-                // 分片上传过程中
197
-                $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_UPLOAD;      //分片上传过程中的API
198
-                $uploadOption->optionType = UpOptionType::BLOCK_RUN_UPLOAD;     //分片上传过程中的Option类型
199
-                $uploadOption->setPartNumber($i + 1);                           //
200
-                $httpRes = $this->_send_request('POST', $url, $uploadPolicy, $uploadOption);
201
-            }
202
-            // 如果分片上传失败,则取消cancel分片上传任务,然后返回错误信息
203
-            if (!$httpRes['isSuccess']) {
204
-                if ($uploadOption->checkMutipartParas()) {
205
-                    $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_CANCEL;      //取消分片任务的API
206
-                    $uploadOption->optionType = UpOptionType::BLOCK_CANCEL_UPLOAD;  //取消分片任务时的Option类型
207
-                    $this->_send_request('POST', $url, $uploadPolicy, $uploadOption); // 不判断取消分片任务返回的结果
208
-                }
209
-                return $httpRes;
210
-            }
211
-            // 保存 块编号partNumber 和 标记ETag,用于分片完成时的参数设置
212
-            $uploadOption->addPartNumberAndETag($httpRes['partNumber'], $httpRes['eTag']);
213
-        }
214
-        // 分片上传完成
215
-        $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_COMPLETE;            //完成分片上传任务的API
216
-        $uploadOption->optionType = UpOptionType::BLOCK_COMPLETE_UPLOAD;        //完成分片上传任务时的Option类型
217
-        $uploadOption->setMd5(md5($data));                          //文件Md5
218
-        return $this->_send_request('POST', $url, $uploadPolicy, $uploadOption);
219
-    }
165
+	/**
166
+	 * 分片上传大文件数据
167
+	 * @param string $data 文件数据
168
+	 * @param UploadPolicy $uploadPolicy 上传策略
169
+	 * @param UploadOption $uploadOption 上传选项
170
+	 * @return array
171
+	 */
172
+	protected function uploadSuperData($data, UploadPolicy $uploadPolicy, UploadOption $uploadOption = null)
173
+	{
174
+		$dataSize = strlen($data);          // 文件大小
175
+		$blockSize = $uploadOption->blockSize;  // 文件分片大小
176
+		$blockNum = intval(ceil($dataSize / $blockSize)); // 文件分片后的块数
177
+		for ($i = 0; $i < $blockNum; $i++) {
178
+			$currentSize = $blockSize; // 当前文件块的大小
179
+			if (($i + 1) === $blockNum) {
180
+				$currentSize = ($dataSize - ($blockNum - 1) * $blockSize); // 计算最后一个块的大小
181
+			}
182
+			$offset = $i * $blockSize; // 当前文件块相对于文件开头的偏移量(块的起始位置)
183
+			$blockData = substr($data, $offset, $currentSize); //当前文件块的数据
184
+			$uploadOption->setContent($blockData); // 设置待上传的文件块
185
+			$httpRes = null;
186
+			if (0 == $i) {
187
+				// 分片初始化阶段
188
+				$url = $this->upload_host . Conf::UPLOAD_API_BLOCK_INIT;        //初始化分片上传的API
189
+				$uploadOption->optionType = UpOptionType::BLOCK_INIT_UPLOAD;    //初始化分片时的Option类型
190
+				$httpRes = $this->_send_request('POST', $url, $uploadPolicy, $uploadOption);
191
+				$uploadId = isset($httpRes['uploadId']) ? $httpRes['uploadId'] : null; // 分片上传ID(OSS用于区分上传的id)
192
+				$id = isset($httpRes['id']) ? $httpRes['id'] : null; // 上传唯一ID(多媒体服务用于区分上传的id)
193
+				$uploadOption->setUploadId($uploadId);
194
+				$uploadOption->setUniqueIdId($id);
195
+			} else {
196
+				// 分片上传过程中
197
+				$url = $this->upload_host . Conf::UPLOAD_API_BLOCK_UPLOAD;      //分片上传过程中的API
198
+				$uploadOption->optionType = UpOptionType::BLOCK_RUN_UPLOAD;     //分片上传过程中的Option类型
199
+				$uploadOption->setPartNumber($i + 1);                           //
200
+				$httpRes = $this->_send_request('POST', $url, $uploadPolicy, $uploadOption);
201
+			}
202
+			// 如果分片上传失败,则取消cancel分片上传任务,然后返回错误信息
203
+			if (!$httpRes['isSuccess']) {
204
+				if ($uploadOption->checkMutipartParas()) {
205
+					$url = $this->upload_host . Conf::UPLOAD_API_BLOCK_CANCEL;      //取消分片任务的API
206
+					$uploadOption->optionType = UpOptionType::BLOCK_CANCEL_UPLOAD;  //取消分片任务时的Option类型
207
+					$this->_send_request('POST', $url, $uploadPolicy, $uploadOption); // 不判断取消分片任务返回的结果
208
+				}
209
+				return $httpRes;
210
+			}
211
+			// 保存 块编号partNumber 和 标记ETag,用于分片完成时的参数设置
212
+			$uploadOption->addPartNumberAndETag($httpRes['partNumber'], $httpRes['eTag']);
213
+		}
214
+		// 分片上传完成
215
+		$url = $this->upload_host . Conf::UPLOAD_API_BLOCK_COMPLETE;            //完成分片上传任务的API
216
+		$uploadOption->optionType = UpOptionType::BLOCK_COMPLETE_UPLOAD;        //完成分片上传任务时的Option类型
217
+		$uploadOption->setMd5(md5($data));                          //文件Md5
218
+		return $this->_send_request('POST', $url, $uploadPolicy, $uploadOption);
219
+	}
220 220
 
221
-    /**
222
-     * 创建分片上传任务,指定待上传的文件。即初始化分片上传
223
-     * @param string $filePath 文件路径
224
-     * @param UploadPolicy $uploadPolicy 上传策略
225
-     * @param UploadOption $uploadOption 上传选项
226
-     * @return array 初始化分片上传的结果
227
-     */
228
-    public function multipartInit($filePath, UploadPolicy $uploadPolicy, UploadOption $uploadOption)
229
-    {
230
-        $encodePath = iconv('UTF-8', 'GB2312', $filePath); //中文需要转换成gb2312,file_exist等函数才能识别
231
-        if (!file_exists($encodePath)) {
232
-            return $this->_errorResponse("FileNotExist", "file not exist");
233
-        }
234
-        if (empty($uploadOption)) {
235
-            $uploadOption = new UploadOption();     //如果用户没有传递UploadOption,则生成一个默认的
236
-        }
237
-        if (empty($uploadOption->name)) {
238
-            $uploadOption->name = basename($filePath);        //如果用户没有设置name属性,则使用上传时的文件名
239
-        }
240
-        $blockData = file_get_contents($encodePath, 0, null, 0, $uploadOption->blockSize);
241
-        return $this->multipartInitByData($blockData, $uploadPolicy, $uploadOption);
242
-    }
221
+	/**
222
+	 * 创建分片上传任务,指定待上传的文件。即初始化分片上传
223
+	 * @param string $filePath 文件路径
224
+	 * @param UploadPolicy $uploadPolicy 上传策略
225
+	 * @param UploadOption $uploadOption 上传选项
226
+	 * @return array 初始化分片上传的结果
227
+	 */
228
+	public function multipartInit($filePath, UploadPolicy $uploadPolicy, UploadOption $uploadOption)
229
+	{
230
+		$encodePath = iconv('UTF-8', 'GB2312', $filePath); //中文需要转换成gb2312,file_exist等函数才能识别
231
+		if (!file_exists($encodePath)) {
232
+			return $this->_errorResponse("FileNotExist", "file not exist");
233
+		}
234
+		if (empty($uploadOption)) {
235
+			$uploadOption = new UploadOption();     //如果用户没有传递UploadOption,则生成一个默认的
236
+		}
237
+		if (empty($uploadOption->name)) {
238
+			$uploadOption->name = basename($filePath);        //如果用户没有设置name属性,则使用上传时的文件名
239
+		}
240
+		$blockData = file_get_contents($encodePath, 0, null, 0, $uploadOption->blockSize);
241
+		return $this->multipartInitByData($blockData, $uploadPolicy, $uploadOption);
242
+	}
243 243
 
244
-    /**
245
-     * 创建分片上传任务,指定初始化分片任务的数据,即第一块数据
246
-     * @param string $blockData 文件数据
247
-     * @param UploadPolicy $uploadPolicy 上传策略
248
-     * @param UploadOption $uploadOption 上传选项
249
-     * @return array 初始化分片上传的结果
250
-     */
251
-    public function multipartInitByData($blockData, UploadPolicy $uploadPolicy, UploadOption $uploadOption)
252
-    {
253
-        if (empty($uploadOption)) {
254
-            $uploadOption = new UploadOption();     //如果用户没有传递UploadOption,则生成一个默认的
255
-        }
256
-        // UploadPolicy 和 UploadOption检查
257
-        list($isValid, $message) = $this->checkUploadInfo($uploadPolicy, $uploadOption);
258
-        if (!$isValid) {
259
-            return $this->_errorResponse("ErrorUploadInfo", "error upload policy or option:" . $message);
260
-        }
261
-        // 数据大小不等于设定的分片大小(默认2M),则无法完成初始化
262
-        $dataSize = strlen($blockData);         // 数据文件大小
263
-        if ($dataSize != ($uploadOption->blockSize)) {
264
-            return $this->_errorResponse("MultipartInitError", "UploadOption's blockSize is not equal to data's size");
265
-        }
266
-        $uploadOption->setContent($blockData); // 设置待上传的文件块
267
-        $uploadOption->optionType = UpOptionType::BLOCK_INIT_UPLOAD;    //初始化分片时的Option类型
268
-        $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_INIT;        //初始化分片上传的API
269
-        $httpRes = $this->_send_request('POST', $url, $uploadPolicy, $uploadOption);
270
-        //若成功返回,则保存初始化成功的uploadId、id 以及 partNumber、eTag
271
-        $uploadId = isset($httpRes['uploadId']) ? $httpRes['uploadId'] : null; // 分片上传ID(OSS用于区分上传的id)
272
-        $id = isset($httpRes['id']) ? $httpRes['id'] : null; // 上传唯一ID(多媒体服务用于区分上传的id)
273
-        $uploadOption->setUploadId($uploadId);
274
-        $uploadOption->setUniqueIdId($id);
275
-        if (isset($httpRes['partNumber']) && isset($httpRes['eTag'])) {
276
-            $uploadOption->addPartNumberAndETag($httpRes['partNumber'], $httpRes['eTag']);
277
-        }
278
-        return $httpRes;
279
-    }
244
+	/**
245
+	 * 创建分片上传任务,指定初始化分片任务的数据,即第一块数据
246
+	 * @param string $blockData 文件数据
247
+	 * @param UploadPolicy $uploadPolicy 上传策略
248
+	 * @param UploadOption $uploadOption 上传选项
249
+	 * @return array 初始化分片上传的结果
250
+	 */
251
+	public function multipartInitByData($blockData, UploadPolicy $uploadPolicy, UploadOption $uploadOption)
252
+	{
253
+		if (empty($uploadOption)) {
254
+			$uploadOption = new UploadOption();     //如果用户没有传递UploadOption,则生成一个默认的
255
+		}
256
+		// UploadPolicy 和 UploadOption检查
257
+		list($isValid, $message) = $this->checkUploadInfo($uploadPolicy, $uploadOption);
258
+		if (!$isValid) {
259
+			return $this->_errorResponse("ErrorUploadInfo", "error upload policy or option:" . $message);
260
+		}
261
+		// 数据大小不等于设定的分片大小(默认2M),则无法完成初始化
262
+		$dataSize = strlen($blockData);         // 数据文件大小
263
+		if ($dataSize != ($uploadOption->blockSize)) {
264
+			return $this->_errorResponse("MultipartInitError", "UploadOption's blockSize is not equal to data's size");
265
+		}
266
+		$uploadOption->setContent($blockData); // 设置待上传的文件块
267
+		$uploadOption->optionType = UpOptionType::BLOCK_INIT_UPLOAD;    //初始化分片时的Option类型
268
+		$url = $this->upload_host . Conf::UPLOAD_API_BLOCK_INIT;        //初始化分片上传的API
269
+		$httpRes = $this->_send_request('POST', $url, $uploadPolicy, $uploadOption);
270
+		//若成功返回,则保存初始化成功的uploadId、id 以及 partNumber、eTag
271
+		$uploadId = isset($httpRes['uploadId']) ? $httpRes['uploadId'] : null; // 分片上传ID(OSS用于区分上传的id)
272
+		$id = isset($httpRes['id']) ? $httpRes['id'] : null; // 上传唯一ID(多媒体服务用于区分上传的id)
273
+		$uploadOption->setUploadId($uploadId);
274
+		$uploadOption->setUniqueIdId($id);
275
+		if (isset($httpRes['partNumber']) && isset($httpRes['eTag'])) {
276
+			$uploadOption->addPartNumberAndETag($httpRes['partNumber'], $httpRes['eTag']);
277
+		}
278
+		return $httpRes;
279
+	}
280 280
 
281
-    /**分片上传,指定待上传的文件。需要指定UploadOption中文件块编号
281
+	/**分片上传,指定待上传的文件。需要指定UploadOption中文件块编号
282 282
      * @param string $filePath 文件路径
283 283
      * @param UploadPolicy $uploadPolicy 上传策略
284 284
      * @param UploadOption $uploadOption 上传选项
285 285
      * @return array 初始化分片上传的结果
286 286
      */
287
-    public function multipartUpload($filePath, UploadPolicy $uploadPolicy, UploadOption $uploadOption)
288
-    {
289
-        $encodePath = iconv('UTF-8', 'GB2312', $filePath); //中文需要转换成gb2312,file_exist等函数才能识别
290
-        if (!file_exists($encodePath)) {
291
-            return $this->_errorResponse("FileNotExist", "file not exist");
292
-        }
293
-        $fileSize = filesize($encodePath);      // 文件大小
294
-        $blockSize = $uploadOption->blockSize;  // 文件分片大小
295
-        $blockNum = intval(ceil($fileSize / $blockSize)); // 文件分片后的块数
296
-        $currentSize = $blockSize; // 当前文件块的大小
297
-        if ($uploadOption->getPartNumber() == $blockNum) {
298
-            $currentSize = ($fileSize - ($blockNum - 1) * $blockSize); // 计算最后一个块的大小
299
-        }
300
-        $offset = ($uploadOption->getPartNumber() - 1) * $blockSize; // 当前文件块相对于文件开头的偏移量(块的起始位置)
301
-        $blockData = file_get_contents($encodePath, 0, null, $offset, $currentSize);
302
-        return $this->multipartUploadByData($blockData, $uploadPolicy, $uploadOption);
303
-    }
287
+	public function multipartUpload($filePath, UploadPolicy $uploadPolicy, UploadOption $uploadOption)
288
+	{
289
+		$encodePath = iconv('UTF-8', 'GB2312', $filePath); //中文需要转换成gb2312,file_exist等函数才能识别
290
+		if (!file_exists($encodePath)) {
291
+			return $this->_errorResponse("FileNotExist", "file not exist");
292
+		}
293
+		$fileSize = filesize($encodePath);      // 文件大小
294
+		$blockSize = $uploadOption->blockSize;  // 文件分片大小
295
+		$blockNum = intval(ceil($fileSize / $blockSize)); // 文件分片后的块数
296
+		$currentSize = $blockSize; // 当前文件块的大小
297
+		if ($uploadOption->getPartNumber() == $blockNum) {
298
+			$currentSize = ($fileSize - ($blockNum - 1) * $blockSize); // 计算最后一个块的大小
299
+		}
300
+		$offset = ($uploadOption->getPartNumber() - 1) * $blockSize; // 当前文件块相对于文件开头的偏移量(块的起始位置)
301
+		$blockData = file_get_contents($encodePath, 0, null, $offset, $currentSize);
302
+		return $this->multipartUploadByData($blockData, $uploadPolicy, $uploadOption);
303
+	}
304 304
 
305
-    /**
306
-     * 分片上传,指定待上传的数据。需要指定UploadOption中文件块编号
307
-     * @param string $filePath 文件路径
308
-     * @param UploadPolicy $uploadPolicy 上传策略
309
-     * @param UploadOption $uploadOption 上传选项
310
-     * @return array 分片上传的结果
311
-     */
312
-    public function multipartUploadByData($blockData, UploadPolicy $uploadPolicy, UploadOption $uploadOption)
313
-    {
314
-        $partNumber = $uploadOption->getPartNumber(); //php 5.3的版本使用empty()传递函数返回值会报错。所以为了兼容,增加临时变量
315
-        // 检查分片上传所需的参数是否设置正确
316
-        if (!$uploadOption->checkMutipartParas() || empty($partNumber)) {
317
-            return $this->_errorResponse("MultipartUploadError", "multipart upload's parameters(id,uploadId,partNumber) error");
318
-        }
319
-        $uploadOption->setContent($blockData); // 设置待上传的文件块
320
-        $uploadOption->optionType = UpOptionType::BLOCK_RUN_UPLOAD;     //分片上传过程中的Option类型
321
-        $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_UPLOAD;      //分片上传过程中的API
322
-        $httpRes = $this->_send_request('POST', $url, $uploadPolicy, $uploadOption);
323
-        if (isset($httpRes['partNumber']) && isset($httpRes['eTag'])) {
324
-            $uploadOption->addPartNumberAndETag($httpRes['partNumber'], $httpRes['eTag']);
325
-        }
326
-        return $httpRes;
327
-    }
305
+	/**
306
+	 * 分片上传,指定待上传的数据。需要指定UploadOption中文件块编号
307
+	 * @param string $filePath 文件路径
308
+	 * @param UploadPolicy $uploadPolicy 上传策略
309
+	 * @param UploadOption $uploadOption 上传选项
310
+	 * @return array 分片上传的结果
311
+	 */
312
+	public function multipartUploadByData($blockData, UploadPolicy $uploadPolicy, UploadOption $uploadOption)
313
+	{
314
+		$partNumber = $uploadOption->getPartNumber(); //php 5.3的版本使用empty()传递函数返回值会报错。所以为了兼容,增加临时变量
315
+		// 检查分片上传所需的参数是否设置正确
316
+		if (!$uploadOption->checkMutipartParas() || empty($partNumber)) {
317
+			return $this->_errorResponse("MultipartUploadError", "multipart upload's parameters(id,uploadId,partNumber) error");
318
+		}
319
+		$uploadOption->setContent($blockData); // 设置待上传的文件块
320
+		$uploadOption->optionType = UpOptionType::BLOCK_RUN_UPLOAD;     //分片上传过程中的Option类型
321
+		$url = $this->upload_host . Conf::UPLOAD_API_BLOCK_UPLOAD;      //分片上传过程中的API
322
+		$httpRes = $this->_send_request('POST', $url, $uploadPolicy, $uploadOption);
323
+		if (isset($httpRes['partNumber']) && isset($httpRes['eTag'])) {
324
+			$uploadOption->addPartNumberAndETag($httpRes['partNumber'], $httpRes['eTag']);
325
+		}
326
+		return $httpRes;
327
+	}
328 328
 
329
-    /**
330
-     * 完成分片上传任务。需要指定UploadOption中整个文件的md5值
331
-     * @param UploadPolicy $uploadPolicy 上传策略
332
-     * @param UploadOption $uploadOption 上传选项
333
-     * @return array 分片上传完成的结果
334
-     */
335
-    public function multipartComplete(UploadPolicy $uploadPolicy, UploadOption $uploadOption)
336
-    {
329
+	/**
330
+	 * 完成分片上传任务。需要指定UploadOption中整个文件的md5值
331
+	 * @param UploadPolicy $uploadPolicy 上传策略
332
+	 * @param UploadOption $uploadOption 上传选项
333
+	 * @return array 分片上传完成的结果
334
+	 */
335
+	public function multipartComplete(UploadPolicy $uploadPolicy, UploadOption $uploadOption)
336
+	{
337 337
  // 检查分片上传所需的参数是否设置正确
338
-        $fileMd5 = $uploadOption->getMd5(); //php 5.3的版本使用empty()传递函数返回值会报错。所以为了兼容,增加临时变量
339
-        if (!$uploadOption->checkMutipartParas() || empty($fileMd5)) {
340
-            return $this->_errorResponse("MultipartCompleteError", "multipart upload's parameters(id,uploadId,md5) error");
341
-        }
342
-        $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_COMPLETE;            //完成分片上传任务的API
343
-        $uploadOption->optionType = UpOptionType::BLOCK_COMPLETE_UPLOAD;        //完成分片上传任务时的Option类型
344
-        return $this->_send_request('POST', $url, $uploadPolicy, $uploadOption);
345
-    }
338
+		$fileMd5 = $uploadOption->getMd5(); //php 5.3的版本使用empty()传递函数返回值会报错。所以为了兼容,增加临时变量
339
+		if (!$uploadOption->checkMutipartParas() || empty($fileMd5)) {
340
+			return $this->_errorResponse("MultipartCompleteError", "multipart upload's parameters(id,uploadId,md5) error");
341
+		}
342
+		$url = $this->upload_host . Conf::UPLOAD_API_BLOCK_COMPLETE;            //完成分片上传任务的API
343
+		$uploadOption->optionType = UpOptionType::BLOCK_COMPLETE_UPLOAD;        //完成分片上传任务时的Option类型
344
+		return $this->_send_request('POST', $url, $uploadPolicy, $uploadOption);
345
+	}
346 346
 
347
-    /**
348
-     * 取消分片上传任务。需要保证UploadOption中有分片任务的uploadId和id
349
-     * @param UploadPolicy $uploadPolicy 上传策略
350
-     * @param UploadOption $uploadOption 上传选项
351
-     * @return array 分片上传完成的结果
352
-     */
353
-    public function multipartCancel(UploadPolicy $uploadPolicy, UploadOption $uploadOption)
354
-    {
355
-        if (!$uploadOption->checkMutipartParas()) {
356
-            return $this->_errorResponse("MultipartCancelError", "multipart upload's parameters(id,uploadId) error");
357
-        }
358
-        $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_CANCEL;      //取消分片任务的API
359
-        $uploadOption->optionType = UpOptionType::BLOCK_CANCEL_UPLOAD;  //取消分片任务时的Option类型
360
-        return $this->_send_request('POST', $url, $uploadPolicy, $uploadOption);
361
-    }
347
+	/**
348
+	 * 取消分片上传任务。需要保证UploadOption中有分片任务的uploadId和id
349
+	 * @param UploadPolicy $uploadPolicy 上传策略
350
+	 * @param UploadOption $uploadOption 上传选项
351
+	 * @return array 分片上传完成的结果
352
+	 */
353
+	public function multipartCancel(UploadPolicy $uploadPolicy, UploadOption $uploadOption)
354
+	{
355
+		if (!$uploadOption->checkMutipartParas()) {
356
+			return $this->_errorResponse("MultipartCancelError", "multipart upload's parameters(id,uploadId) error");
357
+		}
358
+		$url = $this->upload_host . Conf::UPLOAD_API_BLOCK_CANCEL;      //取消分片任务的API
359
+		$uploadOption->optionType = UpOptionType::BLOCK_CANCEL_UPLOAD;  //取消分片任务时的Option类型
360
+		return $this->_send_request('POST', $url, $uploadPolicy, $uploadOption);
361
+	}
362 362
 
363
-    /**
364
-     * 调用curl利用http上传数据
365
-     * @param string $method
366
-     * @param string $url
367
-     * @param UploadPolicy $uploadPolicy
368
-     * @param UploadOption $uploadOption
369
-     * @return array (isSuccess, ...)
370
-     */
371
-    protected function _send_request($method, $url, UploadPolicy $uploadPolicy, UploadOption $uploadOption)
372
-    {
373
-        $success = false;
374
-        $result = array();
375
-        /**
376
-         * @var resource $ch
377
-         */
378
-        $ch = curl_init();
379
-        try {
380
-            //构建Http请求头和请求体
381
-            $_headers = array('Expect:');
382
-            $token = $this->_getUploadToken($uploadPolicy);
383
-            array_push($_headers, "Authorization: {$token}");
384
-            array_push($_headers, "User-Agent: {$this->_getUserAgent()}");
385
-            $length = 0;
386
-            if (!empty($uploadOption)) {
387
-                list($contentType, $httpBody) = $this->BuildMultipartForm($uploadOption);
388
-                $length = @strlen($httpBody);
389
-                array_push($_headers, "Content-Type: {$contentType}");
390
-                curl_setopt($ch, CURLOPT_POSTFIELDS, $httpBody);            //请求体
391
-            }
392
-            array_push($_headers, "Content-Length: {$length}");
393
-            curl_setopt($ch, CURLOPT_HEADER, 1);                            //设置头部
394
-            curl_setopt($ch, CURLOPT_HTTPHEADER, $_headers);                //请求头
395
-            curl_setopt($ch, CURLOPT_TIMEOUT, $uploadOption->timeout);  //持续时长
396
-            curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 10);               //连接超时时长
397
-            curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1); //成功,只返回结果,不自动输出任何内容。如果失败返回FALSE
398
-            curl_setopt($ch, CURLOPT_FOLLOWLOCATION, 0);
399
-            curl_setopt($ch, CURLOPT_URL, $url);
400
-            curl_setopt($ch, CURLOPT_CUSTOMREQUEST, $method);           //自定义请求
401
-            //设置请求方式(GET或POST等)
402
-            if ($method == 'PUT' || $method == 'POST') {
403
-                curl_setopt($ch, CURLOPT_POST, 1);
404
-            } else {
405
-                curl_setopt($ch, CURLOPT_POST, 0);
406
-            }
407
-            //执行上传,然后获取服务端返回,决定是否重试
408
-            $response = curl_exec($ch);
409
-            if ($response === false && $uploadOption->httpReTry != 0) {
410
-                //如果执行curl失败,且需要重试,则进行重试
411
-                $this->recordCurlErrorLog($ch); //记录最近一次curl执行错误日志
412
-                $response = curl_exec($ch);
413
-            }
414
-            if ($response === false) {
415
-                $this->recordCurlErrorLog($ch); //记录最近一次curl执行错误日志
416
-                $result = $this->_errorResponse("curl error", "curl request failed");
417
-                $result['errno'] = curl_errno($ch); //错误码
418
-            } else {
419
-                //解析返回结果,并判断是否上传成功
420
-                $http_code = curl_getinfo($ch, CURLINFO_HTTP_CODE);
421
-                $success = ($http_code == 200) ? true : false;                  //判断是否上传成功
422
-                $resStr = explode("\r\n\r\n", $response, 2);
423
-                $resBody = isset($resStr[1]) ? $resStr[1] : '';
424
-                $resArray = json_decode($resBody, true);                        //解析得到结果
425
-                $result = (empty($resArray) ? $result : $resArray);
426
-            }
427
-        } catch (Exception $e) {
428
-            $result = $this->_errorResponse("HTTPRequestException#" . $e->getLine(), $e->getMessage());
429
-        }
363
+	/**
364
+	 * 调用curl利用http上传数据
365
+	 * @param string $method
366
+	 * @param string $url
367
+	 * @param UploadPolicy $uploadPolicy
368
+	 * @param UploadOption $uploadOption
369
+	 * @return array (isSuccess, ...)
370
+	 */
371
+	protected function _send_request($method, $url, UploadPolicy $uploadPolicy, UploadOption $uploadOption)
372
+	{
373
+		$success = false;
374
+		$result = array();
375
+		/**
376
+		 * @var resource $ch
377
+		 */
378
+		$ch = curl_init();
379
+		try {
380
+			//构建Http请求头和请求体
381
+			$_headers = array('Expect:');
382
+			$token = $this->_getUploadToken($uploadPolicy);
383
+			array_push($_headers, "Authorization: {$token}");
384
+			array_push($_headers, "User-Agent: {$this->_getUserAgent()}");
385
+			$length = 0;
386
+			if (!empty($uploadOption)) {
387
+				list($contentType, $httpBody) = $this->BuildMultipartForm($uploadOption);
388
+				$length = @strlen($httpBody);
389
+				array_push($_headers, "Content-Type: {$contentType}");
390
+				curl_setopt($ch, CURLOPT_POSTFIELDS, $httpBody);            //请求体
391
+			}
392
+			array_push($_headers, "Content-Length: {$length}");
393
+			curl_setopt($ch, CURLOPT_HEADER, 1);                            //设置头部
394
+			curl_setopt($ch, CURLOPT_HTTPHEADER, $_headers);                //请求头
395
+			curl_setopt($ch, CURLOPT_TIMEOUT, $uploadOption->timeout);  //持续时长
396
+			curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 10);               //连接超时时长
397
+			curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1); //成功,只返回结果,不自动输出任何内容。如果失败返回FALSE
398
+			curl_setopt($ch, CURLOPT_FOLLOWLOCATION, 0);
399
+			curl_setopt($ch, CURLOPT_URL, $url);
400
+			curl_setopt($ch, CURLOPT_CUSTOMREQUEST, $method);           //自定义请求
401
+			//设置请求方式(GET或POST等)
402
+			if ($method == 'PUT' || $method == 'POST') {
403
+				curl_setopt($ch, CURLOPT_POST, 1);
404
+			} else {
405
+				curl_setopt($ch, CURLOPT_POST, 0);
406
+			}
407
+			//执行上传,然后获取服务端返回,决定是否重试
408
+			$response = curl_exec($ch);
409
+			if ($response === false && $uploadOption->httpReTry != 0) {
410
+				//如果执行curl失败,且需要重试,则进行重试
411
+				$this->recordCurlErrorLog($ch); //记录最近一次curl执行错误日志
412
+				$response = curl_exec($ch);
413
+			}
414
+			if ($response === false) {
415
+				$this->recordCurlErrorLog($ch); //记录最近一次curl执行错误日志
416
+				$result = $this->_errorResponse("curl error", "curl request failed");
417
+				$result['errno'] = curl_errno($ch); //错误码
418
+			} else {
419
+				//解析返回结果,并判断是否上传成功
420
+				$http_code = curl_getinfo($ch, CURLINFO_HTTP_CODE);
421
+				$success = ($http_code == 200) ? true : false;                  //判断是否上传成功
422
+				$resStr = explode("\r\n\r\n", $response, 2);
423
+				$resBody = isset($resStr[1]) ? $resStr[1] : '';
424
+				$resArray = json_decode($resBody, true);                        //解析得到结果
425
+				$result = (empty($resArray) ? $result : $resArray);
426
+			}
427
+		} catch (Exception $e) {
428
+			$result = $this->_errorResponse("HTTPRequestException#" . $e->getLine(), $e->getMessage());
429
+		}
430 430
 
431
-        curl_close($ch); //PHP5.3中不支持finally关键字。因此,为了兼容,这里取消finally
432
-        if (!$success) {
433
-            throw new UploadException($result['message'], $http_code);
434
-        }
435
-        $result['isSuccess'] = $success;
436
-        return $result;
437
-    }
431
+		curl_close($ch); //PHP5.3中不支持finally关键字。因此,为了兼容,这里取消finally
432
+		if (!$success) {
433
+			throw new UploadException($result['message'], $http_code);
434
+		}
435
+		$result['isSuccess'] = $success;
436
+		return $result;
437
+	}
438 438
 
439
-    /**
440
-     * uploadPolicy和uploadOption 合法性检查
441
-     * @param UploadPolicy $uploadPolicy 上传策略
442
-     * @param UploadOption $uploadOption 上传选项
443
-     * @return array($isValid, $message)
444
-     */
445
-    protected function checkUploadInfo(UploadPolicy $uploadPolicy, UploadOption $uploadOption)
446
-    {
447
-        $isValid = true;
448
-        $message = null;
449
-        // 1:判断是否设置空间名
450
-        if (empty($uploadPolicy->bucket) && empty($uploadPolicy->namespace)) {
451
-            $isValid = false;
452
-            $message = 'namespace or bucket is empty';
453
-        } elseif (empty($uploadPolicy->name)) {
454
-            // 2:优先使用uploadPolicy中的name,如果为空,则使用uploadOption中的name
455
-            if (empty($uploadOption->name)) {
456
-                $isValid = false;
457
-                $message = "file's name is empty"; // 如果uploadPolicy和uploadOption中的文件名name都为空,则返回错误信息
458
-            }
459
-        }
460
-        if (true === $isValid) {
461
-            // 3:优先使用uploadPolicy中的dir
462
-            if (!empty($uploadPolicy->dir)) {
463
-                if (strpos($uploadPolicy->dir, '/') !== 0) {
464
-                    $uploadPolicy->dir = '/' . $uploadPolicy->dir; //如果dir不为空,且其前面没有以"/"开头,则为其添加
465
-                }
466
-            }
467
-            // 4:如果uploadPolicy中的dir为空,则使用uploadOption中的dir
468
-            if (!empty($uploadOption->dir)) {
469
-                if (strpos($uploadOption->dir, '/') !== 0) {
470
-                    $uploadOption->dir = '/' . $uploadOption->dir; //如果dir不为空,且其前面没有以"/"开头,则为其添加
471
-                }
472
-            }
473
-            // 5:判断用户设置的文件分块大小,是否在指定的范围内。如果不在,则设置为默认Conf::BLOCK_DEFF_SIZE = 2M
474
-            if (($uploadOption->blockSize > Conf::BLOCK_MAX_SIZE) || ($uploadOption->blockSize < Conf::BLOCK_MIN_SIZE)) {
475
-                $uploadOption->blockSize = Conf::BLOCK_DEFF_SIZE;
476
-            }
477
-        }
478
-        return array($isValid, $message);
479
-    }
439
+	/**
440
+	 * uploadPolicy和uploadOption 合法性检查
441
+	 * @param UploadPolicy $uploadPolicy 上传策略
442
+	 * @param UploadOption $uploadOption 上传选项
443
+	 * @return array($isValid, $message)
444
+	 */
445
+	protected function checkUploadInfo(UploadPolicy $uploadPolicy, UploadOption $uploadOption)
446
+	{
447
+		$isValid = true;
448
+		$message = null;
449
+		// 1:判断是否设置空间名
450
+		if (empty($uploadPolicy->bucket) && empty($uploadPolicy->namespace)) {
451
+			$isValid = false;
452
+			$message = 'namespace or bucket is empty';
453
+		} elseif (empty($uploadPolicy->name)) {
454
+			// 2:优先使用uploadPolicy中的name,如果为空,则使用uploadOption中的name
455
+			if (empty($uploadOption->name)) {
456
+				$isValid = false;
457
+				$message = "file's name is empty"; // 如果uploadPolicy和uploadOption中的文件名name都为空,则返回错误信息
458
+			}
459
+		}
460
+		if (true === $isValid) {
461
+			// 3:优先使用uploadPolicy中的dir
462
+			if (!empty($uploadPolicy->dir)) {
463
+				if (strpos($uploadPolicy->dir, '/') !== 0) {
464
+					$uploadPolicy->dir = '/' . $uploadPolicy->dir; //如果dir不为空,且其前面没有以"/"开头,则为其添加
465
+				}
466
+			}
467
+			// 4:如果uploadPolicy中的dir为空,则使用uploadOption中的dir
468
+			if (!empty($uploadOption->dir)) {
469
+				if (strpos($uploadOption->dir, '/') !== 0) {
470
+					$uploadOption->dir = '/' . $uploadOption->dir; //如果dir不为空,且其前面没有以"/"开头,则为其添加
471
+				}
472
+			}
473
+			// 5:判断用户设置的文件分块大小,是否在指定的范围内。如果不在,则设置为默认Conf::BLOCK_DEFF_SIZE = 2M
474
+			if (($uploadOption->blockSize > Conf::BLOCK_MAX_SIZE) || ($uploadOption->blockSize < Conf::BLOCK_MIN_SIZE)) {
475
+				$uploadOption->blockSize = Conf::BLOCK_DEFF_SIZE;
476
+			}
477
+		}
478
+		return array($isValid, $message);
479
+	}
480 480
 
481
-    /**
482
-     * 构建Http请求的Body
483
-     * @param UploadOption $uploadOption
484
-     * @return array (contentType,httpBody)
485
-     */
486
-    protected function BuildMultipartForm(UploadOption $uploadOption)
487
-    {
488
-        $bodyArray = array();
489
-        $mimeBoundary = md5(microtime());
490
-        $paraArray = $uploadOption->getParaArray();
491
-        foreach ($paraArray as $name => $val) {
492
-            if ($name != 'content') {
493
-                array_push($bodyArray, '--' . $mimeBoundary);
494
-                array_push($bodyArray, "Content-Disposition: form-data; name=\"$name\"");
495
-                array_push($bodyArray, 'Content-Type: text/plain; charset=UTF-8');
496
-                array_push($bodyArray, '');
497
-                array_push($bodyArray, $val);
498
-            }
499
-        }
500
-        if (isset($paraArray['content'])) {
501
-            array_push($bodyArray, '--' . $mimeBoundary);
502
-            $fileName = empty($uploadOption->name) ? "temp" : $uploadOption->name;
503
-            array_push($bodyArray, "Content-Disposition: form-data; name=\"content\"; filename=\"{$fileName}\"");
504
-            array_push($bodyArray, "Content-Type: application/octet-stream");
505
-            array_push($bodyArray, '');
506
-            array_push($bodyArray, $paraArray['content']);
507
-        }
481
+	/**
482
+	 * 构建Http请求的Body
483
+	 * @param UploadOption $uploadOption
484
+	 * @return array (contentType,httpBody)
485
+	 */
486
+	protected function BuildMultipartForm(UploadOption $uploadOption)
487
+	{
488
+		$bodyArray = array();
489
+		$mimeBoundary = md5(microtime());
490
+		$paraArray = $uploadOption->getParaArray();
491
+		foreach ($paraArray as $name => $val) {
492
+			if ($name != 'content') {
493
+				array_push($bodyArray, '--' . $mimeBoundary);
494
+				array_push($bodyArray, "Content-Disposition: form-data; name=\"$name\"");
495
+				array_push($bodyArray, 'Content-Type: text/plain; charset=UTF-8');
496
+				array_push($bodyArray, '');
497
+				array_push($bodyArray, $val);
498
+			}
499
+		}
500
+		if (isset($paraArray['content'])) {
501
+			array_push($bodyArray, '--' . $mimeBoundary);
502
+			$fileName = empty($uploadOption->name) ? "temp" : $uploadOption->name;
503
+			array_push($bodyArray, "Content-Disposition: form-data; name=\"content\"; filename=\"{$fileName}\"");
504
+			array_push($bodyArray, "Content-Type: application/octet-stream");
505
+			array_push($bodyArray, '');
506
+			array_push($bodyArray, $paraArray['content']);
507
+		}
508 508
 
509
-        array_push($bodyArray, '--' . $mimeBoundary . '--');
510
-        array_push($bodyArray, '');
509
+		array_push($bodyArray, '--' . $mimeBoundary . '--');
510
+		array_push($bodyArray, '');
511 511
 
512
-        $httpBody = implode("\r\n", $bodyArray);
513
-        $contentType = 'multipart/form-data; boundary=' . $mimeBoundary;
514
-        return array(
515
-            $contentType,
516
-            $httpBody
517
-        );
518
-    }
512
+		$httpBody = implode("\r\n", $bodyArray);
513
+		$contentType = 'multipart/form-data; boundary=' . $mimeBoundary;
514
+		return array(
515
+			$contentType,
516
+			$httpBody
517
+		);
518
+	}
519 519
 
520
-    /**
521
-     * UserAgent用户代理
522
-     */
523
-    protected function _getUserAgent()
524
-    {
525
-        if ($this->type == "TOP") {
526
-            return "ALIMEDIASDK_PHP_TAE/" . Conf::SDK_VERSION;
527
-        } else {
528
-            return "ALIMEDIASDK_PHP_CLOUD/" . Conf::SDK_VERSION;
529
-        }
530
-    }
520
+	/**
521
+	 * UserAgent用户代理
522
+	 */
523
+	protected function _getUserAgent()
524
+	{
525
+		if ($this->type == "TOP") {
526
+			return "ALIMEDIASDK_PHP_TAE/" . Conf::SDK_VERSION;
527
+		} else {
528
+			return "ALIMEDIASDK_PHP_CLOUD/" . Conf::SDK_VERSION;
529
+		}
530
+	}
531 531
 
532
-    public function getUploadToken(UploadPolicy $uploadPolicy)
533
-    {
534
-        return $this->_getUploadToken($uploadPolicy);
535
-    }
532
+	public function getUploadToken(UploadPolicy $uploadPolicy)
533
+	{
534
+		return $this->_getUploadToken($uploadPolicy);
535
+	}
536 536
 
537
-    /**
538
-     * 生成上传凭证
539
-     * @param UploadPolicy $uploadPolicy
540
-     * @return string 上传时的凭证token
541
-     */
542
-    protected function _getUploadToken(UploadPolicy $uploadPolicy)
543
-    {
544
-        $encodedPolicy = EncodeUtils::encodeWithURLSafeBase64(json_encode($uploadPolicy->toArray()));
545
-        $signed = hash_hmac('sha1', $encodedPolicy, $this->sk);
546
-        $tempStr = $this->ak . ":" . $encodedPolicy . ":" . $signed;
547
-        $token = "UPLOAD_AK_" . $this->type . " " . EncodeUtils::encodeWithURLSafeBase64($tempStr);
537
+	/**
538
+	 * 生成上传凭证
539
+	 * @param UploadPolicy $uploadPolicy
540
+	 * @return string 上传时的凭证token
541
+	 */
542
+	protected function _getUploadToken(UploadPolicy $uploadPolicy)
543
+	{
544
+		$encodedPolicy = EncodeUtils::encodeWithURLSafeBase64(json_encode($uploadPolicy->toArray()));
545
+		$signed = hash_hmac('sha1', $encodedPolicy, $this->sk);
546
+		$tempStr = $this->ak . ":" . $encodedPolicy . ":" . $signed;
547
+		$token = "UPLOAD_AK_" . $this->type . " " . EncodeUtils::encodeWithURLSafeBase64($tempStr);
548 548
 
549
-        return $token;
550
-    }
549
+		return $token;
550
+	}
551 551
 
552
-    /**
553
-     * 反馈错误信息
554
-     */
555
-    protected function _errorResponse($code = "UnknownError", $message = "unkonown error", $requestId = null)
556
-    {
557
-        return array(
558
-            "isSuccess" => false,
559
-            "code" => $code,
560
-            "message" => $message,
561
-            "requestId" => $requestId
562
-        );
563
-    }
552
+	/**
553
+	 * 反馈错误信息
554
+	 */
555
+	protected function _errorResponse($code = "UnknownError", $message = "unkonown error", $requestId = null)
556
+	{
557
+		return array(
558
+			"isSuccess" => false,
559
+			"code" => $code,
560
+			"message" => $message,
561
+			"requestId" => $requestId
562
+		);
563
+	}
564 564
 
565
-    /**
566
-     * 记录curl错误日志
567
-     * @param curl-handle $ch curl句柄
568
-     */
569
-    protected function recordCurlErrorLog($ch)
570
-    {
571
-        if (AlibabaImage::$RUN_LEVEL == Conf::RUN_LEVEL_DEBUG) {
572
-            $errno = curl_errno($ch); //错误码
573
-            $info  = curl_getinfo($ch); //curl连接资源句柄的信息
574
-            $info['errno'] = $errno; //添加到连接句柄信息中
575
-            $content = date("Y-m-d H:i:s") . json_encode($info) . "\n";
576
-            $logPath = dirname(__FILE__) . "/" . Conf::CURL_ERR_LOG;
577
-            $this->putContentToFile($content, $logPath);
578
-        }
579
-    }
565
+	/**
566
+	 * 记录curl错误日志
567
+	 * @param curl-handle $ch curl句柄
568
+	 */
569
+	protected function recordCurlErrorLog($ch)
570
+	{
571
+		if (AlibabaImage::$RUN_LEVEL == Conf::RUN_LEVEL_DEBUG) {
572
+			$errno = curl_errno($ch); //错误码
573
+			$info  = curl_getinfo($ch); //curl连接资源句柄的信息
574
+			$info['errno'] = $errno; //添加到连接句柄信息中
575
+			$content = date("Y-m-d H:i:s") . json_encode($info) . "\n";
576
+			$logPath = dirname(__FILE__) . "/" . Conf::CURL_ERR_LOG;
577
+			$this->putContentToFile($content, $logPath);
578
+		}
579
+	}
580 580
 
581
-    /**
582
-     * 将信息追加写到文件
583
-     * @param string $message 日志内容。
584
-     * @return void
585
-     */
586
-    protected function putContentToFile($content, $filepath)
587
-    {
588
-        if (!file_exists($filepath)) {
589
-            $handle = fopen($filepath, 'w');
590
-            fclose($handle);
591
-        }
592
-        file_put_contents($filepath, $content, FILE_APPEND);
593
-    }
581
+	/**
582
+	 * 将信息追加写到文件
583
+	 * @param string $message 日志内容。
584
+	 * @return void
585
+	 */
586
+	protected function putContentToFile($content, $filepath)
587
+	{
588
+		if (!file_exists($filepath)) {
589
+			$handle = fopen($filepath, 'w');
590
+			fclose($handle);
591
+		}
592
+		file_put_contents($filepath, $content, FILE_APPEND);
593
+	}
594 594
 }
Please login to merge, or discard this patch.
Spacing   +51 added lines, -51 removed lines patch added patch discarded remove patch
@@ -38,10 +38,10 @@  discard block
 block discarded – undo
38 38
             return $this->_errorResponse("FileNotExist", "file not exist");
39 39
         }
40 40
         if (empty($uploadOption)) {
41
-            $uploadOption = new UploadOption();     //如果用户没有传递UploadOption,则生成一个默认的
41
+            $uploadOption = new UploadOption(); //如果用户没有传递UploadOption,则生成一个默认的
42 42
         }
43 43
         if (empty($uploadOption->name)) {
44
-            $uploadOption->name = basename($filePath);        //如果用户没有设置name属性,则使用上传时的文件名
44
+            $uploadOption->name = basename($filePath); //如果用户没有设置name属性,则使用上传时的文件名
45 45
         }
46 46
         // UploadPolicy 和 UploadOption检查
47 47
         list($isValid, $message) = $this->checkUploadInfo($uploadPolicy, $uploadOption);
@@ -68,7 +68,7 @@  discard block
 block discarded – undo
68 68
     {
69 69
         $data = file_get_contents($filePath);
70 70
         $uploadOption->setContent($data);
71
-        $url = $this->upload_host . Conf::UPLOAD_API_UPLOAD;        //普通上传的API
71
+        $url = $this->upload_host . Conf::UPLOAD_API_UPLOAD; //普通上传的API
72 72
         return $this->_send_request('POST', $url, $uploadPolicy, $uploadOption);
73 73
     }
74 74
 
@@ -81,8 +81,8 @@  discard block
 block discarded – undo
81 81
      */
82 82
     protected function uploadSuperFile($filePath, UploadPolicy $uploadPolicy, UploadOption $uploadOption = null)
83 83
     {
84
-        $fileSize = filesize($filePath);        // 文件大小
85
-        $blockSize = $uploadOption->blockSize;  // 文件分片大小
84
+        $fileSize = filesize($filePath); // 文件大小
85
+        $blockSize = $uploadOption->blockSize; // 文件分片大小
86 86
         $blockNum = intval(ceil($fileSize / $blockSize)); // 文件分片后的块数
87 87
         for ($i = 0; $i < $blockNum; $i++) {
88 88
             $currentSize = $blockSize; // 当前文件块的大小
@@ -95,8 +95,8 @@  discard block
 block discarded – undo
95 95
             $httpRes = null;
96 96
             if (0 == $i) {
97 97
                 // 分片初始化阶段
98
-                $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_INIT;        //初始化分片上传的API
99
-                $uploadOption->optionType = UpOptionType::BLOCK_INIT_UPLOAD;    //初始化分片时的Option类型
98
+                $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_INIT; //初始化分片上传的API
99
+                $uploadOption->optionType = UpOptionType::BLOCK_INIT_UPLOAD; //初始化分片时的Option类型
100 100
                 $httpRes = $this->_send_request('POST', $url, $uploadPolicy, $uploadOption);
101 101
                 $uploadId = isset($httpRes['uploadId']) ? $httpRes['uploadId'] : null; // 分片上传ID(OSS用于区分上传的id)
102 102
                 $id = isset($httpRes['id']) ? $httpRes['id'] : null; // 上传唯一ID(多媒体服务用于区分上传的id)
@@ -104,16 +104,16 @@  discard block
 block discarded – undo
104 104
                 $uploadOption->setUniqueIdId($id);
105 105
             } else {
106 106
                 // 分片上传过程中
107
-                $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_UPLOAD;      //分片上传过程中的API
108
-                $uploadOption->optionType = UpOptionType::BLOCK_RUN_UPLOAD;     //分片上传过程中的Option类型
109
-                $uploadOption->setPartNumber($i + 1);                           //
107
+                $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_UPLOAD; //分片上传过程中的API
108
+                $uploadOption->optionType = UpOptionType::BLOCK_RUN_UPLOAD; //分片上传过程中的Option类型
109
+                $uploadOption->setPartNumber($i + 1); //
110 110
                 $httpRes = $this->_send_request('POST', $url, $uploadPolicy, $uploadOption);
111 111
             }
112 112
             // 如果分片上传失败,则取消cancel分片上传任务,然后返回错误信息
113 113
             if (!$httpRes['isSuccess']) {
114 114
                 if ($uploadOption->checkMutipartParas()) {
115
-                    $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_CANCEL;      //取消分片任务的API
116
-                    $uploadOption->optionType = UpOptionType::BLOCK_CANCEL_UPLOAD;  //取消分片任务时的Option类型
115
+                    $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_CANCEL; //取消分片任务的API
116
+                    $uploadOption->optionType = UpOptionType::BLOCK_CANCEL_UPLOAD; //取消分片任务时的Option类型
117 117
                     $this->_send_request('POST', $url, $uploadPolicy, $uploadOption); // 不判断取消分片任务返回的结果
118 118
                 }
119 119
                 return $httpRes;
@@ -126,9 +126,9 @@  discard block
 block discarded – undo
126 126
             $uploadOption->addPartNumberAndETag($httpRes['partNumber'], $httpRes['eTag']);
127 127
         }
128 128
         // 分片上传完成
129
-        $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_COMPLETE;            //完成分片上传任务的API
130
-        $uploadOption->optionType = UpOptionType::BLOCK_COMPLETE_UPLOAD;        //完成分片上传任务时的Option类型
131
-        $uploadOption->setMd5(md5_file($filePath));                         //文件Md5
129
+        $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_COMPLETE; //完成分片上传任务的API
130
+        $uploadOption->optionType = UpOptionType::BLOCK_COMPLETE_UPLOAD; //完成分片上传任务时的Option类型
131
+        $uploadOption->setMd5(md5_file($filePath)); //文件Md5
132 132
         return $this->_send_request('POST', $url, $uploadPolicy, $uploadOption);
133 133
     }
134 134
 
@@ -144,7 +144,7 @@  discard block
 block discarded – undo
144 144
     public function uploadData($data, UploadPolicy $uploadPolicy, UploadOption $uploadOption = null)
145 145
     {
146 146
         if (empty($uploadOption)) {
147
-            $uploadOption = new UploadOption();     //如果用户没有传递UploadOption,则生成一个默认的
147
+            $uploadOption = new UploadOption(); //如果用户没有传递UploadOption,则生成一个默认的
148 148
         }
149 149
         // UploadPolicy 和 UploadOption检查
150 150
         list($isValid, $message) = $this->checkUploadInfo($uploadPolicy, $uploadOption);
@@ -158,7 +158,7 @@  discard block
 block discarded – undo
158 158
         }
159 159
         // 文件不大于设定的分片大小(默认2M),则直接上传uploadMiniFile()
160 160
         $uploadOption->setContent($data);
161
-        $url = $this->upload_host . Conf::UPLOAD_API_UPLOAD;        //普通上传的API
161
+        $url = $this->upload_host . Conf::UPLOAD_API_UPLOAD; //普通上传的API
162 162
         return $this->_send_request('POST', $url, $uploadPolicy, $uploadOption);
163 163
     }
164 164
 
@@ -171,8 +171,8 @@  discard block
 block discarded – undo
171 171
      */
172 172
     protected function uploadSuperData($data, UploadPolicy $uploadPolicy, UploadOption $uploadOption = null)
173 173
     {
174
-        $dataSize = strlen($data);          // 文件大小
175
-        $blockSize = $uploadOption->blockSize;  // 文件分片大小
174
+        $dataSize = strlen($data); // 文件大小
175
+        $blockSize = $uploadOption->blockSize; // 文件分片大小
176 176
         $blockNum = intval(ceil($dataSize / $blockSize)); // 文件分片后的块数
177 177
         for ($i = 0; $i < $blockNum; $i++) {
178 178
             $currentSize = $blockSize; // 当前文件块的大小
@@ -185,8 +185,8 @@  discard block
 block discarded – undo
185 185
             $httpRes = null;
186 186
             if (0 == $i) {
187 187
                 // 分片初始化阶段
188
-                $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_INIT;        //初始化分片上传的API
189
-                $uploadOption->optionType = UpOptionType::BLOCK_INIT_UPLOAD;    //初始化分片时的Option类型
188
+                $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_INIT; //初始化分片上传的API
189
+                $uploadOption->optionType = UpOptionType::BLOCK_INIT_UPLOAD; //初始化分片时的Option类型
190 190
                 $httpRes = $this->_send_request('POST', $url, $uploadPolicy, $uploadOption);
191 191
                 $uploadId = isset($httpRes['uploadId']) ? $httpRes['uploadId'] : null; // 分片上传ID(OSS用于区分上传的id)
192 192
                 $id = isset($httpRes['id']) ? $httpRes['id'] : null; // 上传唯一ID(多媒体服务用于区分上传的id)
@@ -194,16 +194,16 @@  discard block
 block discarded – undo
194 194
                 $uploadOption->setUniqueIdId($id);
195 195
             } else {
196 196
                 // 分片上传过程中
197
-                $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_UPLOAD;      //分片上传过程中的API
198
-                $uploadOption->optionType = UpOptionType::BLOCK_RUN_UPLOAD;     //分片上传过程中的Option类型
199
-                $uploadOption->setPartNumber($i + 1);                           //
197
+                $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_UPLOAD; //分片上传过程中的API
198
+                $uploadOption->optionType = UpOptionType::BLOCK_RUN_UPLOAD; //分片上传过程中的Option类型
199
+                $uploadOption->setPartNumber($i + 1); //
200 200
                 $httpRes = $this->_send_request('POST', $url, $uploadPolicy, $uploadOption);
201 201
             }
202 202
             // 如果分片上传失败,则取消cancel分片上传任务,然后返回错误信息
203 203
             if (!$httpRes['isSuccess']) {
204 204
                 if ($uploadOption->checkMutipartParas()) {
205
-                    $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_CANCEL;      //取消分片任务的API
206
-                    $uploadOption->optionType = UpOptionType::BLOCK_CANCEL_UPLOAD;  //取消分片任务时的Option类型
205
+                    $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_CANCEL; //取消分片任务的API
206
+                    $uploadOption->optionType = UpOptionType::BLOCK_CANCEL_UPLOAD; //取消分片任务时的Option类型
207 207
                     $this->_send_request('POST', $url, $uploadPolicy, $uploadOption); // 不判断取消分片任务返回的结果
208 208
                 }
209 209
                 return $httpRes;
@@ -212,9 +212,9 @@  discard block
 block discarded – undo
212 212
             $uploadOption->addPartNumberAndETag($httpRes['partNumber'], $httpRes['eTag']);
213 213
         }
214 214
         // 分片上传完成
215
-        $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_COMPLETE;            //完成分片上传任务的API
216
-        $uploadOption->optionType = UpOptionType::BLOCK_COMPLETE_UPLOAD;        //完成分片上传任务时的Option类型
217
-        $uploadOption->setMd5(md5($data));                          //文件Md5
215
+        $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_COMPLETE; //完成分片上传任务的API
216
+        $uploadOption->optionType = UpOptionType::BLOCK_COMPLETE_UPLOAD; //完成分片上传任务时的Option类型
217
+        $uploadOption->setMd5(md5($data)); //文件Md5
218 218
         return $this->_send_request('POST', $url, $uploadPolicy, $uploadOption);
219 219
     }
220 220
 
@@ -232,10 +232,10 @@  discard block
 block discarded – undo
232 232
             return $this->_errorResponse("FileNotExist", "file not exist");
233 233
         }
234 234
         if (empty($uploadOption)) {
235
-            $uploadOption = new UploadOption();     //如果用户没有传递UploadOption,则生成一个默认的
235
+            $uploadOption = new UploadOption(); //如果用户没有传递UploadOption,则生成一个默认的
236 236
         }
237 237
         if (empty($uploadOption->name)) {
238
-            $uploadOption->name = basename($filePath);        //如果用户没有设置name属性,则使用上传时的文件名
238
+            $uploadOption->name = basename($filePath); //如果用户没有设置name属性,则使用上传时的文件名
239 239
         }
240 240
         $blockData = file_get_contents($encodePath, 0, null, 0, $uploadOption->blockSize);
241 241
         return $this->multipartInitByData($blockData, $uploadPolicy, $uploadOption);
@@ -251,7 +251,7 @@  discard block
 block discarded – undo
251 251
     public function multipartInitByData($blockData, UploadPolicy $uploadPolicy, UploadOption $uploadOption)
252 252
     {
253 253
         if (empty($uploadOption)) {
254
-            $uploadOption = new UploadOption();     //如果用户没有传递UploadOption,则生成一个默认的
254
+            $uploadOption = new UploadOption(); //如果用户没有传递UploadOption,则生成一个默认的
255 255
         }
256 256
         // UploadPolicy 和 UploadOption检查
257 257
         list($isValid, $message) = $this->checkUploadInfo($uploadPolicy, $uploadOption);
@@ -259,13 +259,13 @@  discard block
 block discarded – undo
259 259
             return $this->_errorResponse("ErrorUploadInfo", "error upload policy or option:" . $message);
260 260
         }
261 261
         // 数据大小不等于设定的分片大小(默认2M),则无法完成初始化
262
-        $dataSize = strlen($blockData);         // 数据文件大小
262
+        $dataSize = strlen($blockData); // 数据文件大小
263 263
         if ($dataSize != ($uploadOption->blockSize)) {
264 264
             return $this->_errorResponse("MultipartInitError", "UploadOption's blockSize is not equal to data's size");
265 265
         }
266 266
         $uploadOption->setContent($blockData); // 设置待上传的文件块
267
-        $uploadOption->optionType = UpOptionType::BLOCK_INIT_UPLOAD;    //初始化分片时的Option类型
268
-        $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_INIT;        //初始化分片上传的API
267
+        $uploadOption->optionType = UpOptionType::BLOCK_INIT_UPLOAD; //初始化分片时的Option类型
268
+        $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_INIT; //初始化分片上传的API
269 269
         $httpRes = $this->_send_request('POST', $url, $uploadPolicy, $uploadOption);
270 270
         //若成功返回,则保存初始化成功的uploadId、id 以及 partNumber、eTag
271 271
         $uploadId = isset($httpRes['uploadId']) ? $httpRes['uploadId'] : null; // 分片上传ID(OSS用于区分上传的id)
@@ -290,8 +290,8 @@  discard block
 block discarded – undo
290 290
         if (!file_exists($encodePath)) {
291 291
             return $this->_errorResponse("FileNotExist", "file not exist");
292 292
         }
293
-        $fileSize = filesize($encodePath);      // 文件大小
294
-        $blockSize = $uploadOption->blockSize;  // 文件分片大小
293
+        $fileSize = filesize($encodePath); // 文件大小
294
+        $blockSize = $uploadOption->blockSize; // 文件分片大小
295 295
         $blockNum = intval(ceil($fileSize / $blockSize)); // 文件分片后的块数
296 296
         $currentSize = $blockSize; // 当前文件块的大小
297 297
         if ($uploadOption->getPartNumber() == $blockNum) {
@@ -317,8 +317,8 @@  discard block
 block discarded – undo
317 317
             return $this->_errorResponse("MultipartUploadError", "multipart upload's parameters(id,uploadId,partNumber) error");
318 318
         }
319 319
         $uploadOption->setContent($blockData); // 设置待上传的文件块
320
-        $uploadOption->optionType = UpOptionType::BLOCK_RUN_UPLOAD;     //分片上传过程中的Option类型
321
-        $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_UPLOAD;      //分片上传过程中的API
320
+        $uploadOption->optionType = UpOptionType::BLOCK_RUN_UPLOAD; //分片上传过程中的Option类型
321
+        $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_UPLOAD; //分片上传过程中的API
322 322
         $httpRes = $this->_send_request('POST', $url, $uploadPolicy, $uploadOption);
323 323
         if (isset($httpRes['partNumber']) && isset($httpRes['eTag'])) {
324 324
             $uploadOption->addPartNumberAndETag($httpRes['partNumber'], $httpRes['eTag']);
@@ -339,8 +339,8 @@  discard block
 block discarded – undo
339 339
         if (!$uploadOption->checkMutipartParas() || empty($fileMd5)) {
340 340
             return $this->_errorResponse("MultipartCompleteError", "multipart upload's parameters(id,uploadId,md5) error");
341 341
         }
342
-        $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_COMPLETE;            //完成分片上传任务的API
343
-        $uploadOption->optionType = UpOptionType::BLOCK_COMPLETE_UPLOAD;        //完成分片上传任务时的Option类型
342
+        $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_COMPLETE; //完成分片上传任务的API
343
+        $uploadOption->optionType = UpOptionType::BLOCK_COMPLETE_UPLOAD; //完成分片上传任务时的Option类型
344 344
         return $this->_send_request('POST', $url, $uploadPolicy, $uploadOption);
345 345
     }
346 346
 
@@ -355,8 +355,8 @@  discard block
 block discarded – undo
355 355
         if (!$uploadOption->checkMutipartParas()) {
356 356
             return $this->_errorResponse("MultipartCancelError", "multipart upload's parameters(id,uploadId) error");
357 357
         }
358
-        $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_CANCEL;      //取消分片任务的API
359
-        $uploadOption->optionType = UpOptionType::BLOCK_CANCEL_UPLOAD;  //取消分片任务时的Option类型
358
+        $url = $this->upload_host . Conf::UPLOAD_API_BLOCK_CANCEL; //取消分片任务的API
359
+        $uploadOption->optionType = UpOptionType::BLOCK_CANCEL_UPLOAD; //取消分片任务时的Option类型
360 360
         return $this->_send_request('POST', $url, $uploadPolicy, $uploadOption);
361 361
     }
362 362
 
@@ -387,17 +387,17 @@  discard block
 block discarded – undo
387 387
                 list($contentType, $httpBody) = $this->BuildMultipartForm($uploadOption);
388 388
                 $length = @strlen($httpBody);
389 389
                 array_push($_headers, "Content-Type: {$contentType}");
390
-                curl_setopt($ch, CURLOPT_POSTFIELDS, $httpBody);            //请求体
390
+                curl_setopt($ch, CURLOPT_POSTFIELDS, $httpBody); //请求体
391 391
             }
392 392
             array_push($_headers, "Content-Length: {$length}");
393
-            curl_setopt($ch, CURLOPT_HEADER, 1);                            //设置头部
394
-            curl_setopt($ch, CURLOPT_HTTPHEADER, $_headers);                //请求头
395
-            curl_setopt($ch, CURLOPT_TIMEOUT, $uploadOption->timeout);  //持续时长
396
-            curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 10);               //连接超时时长
393
+            curl_setopt($ch, CURLOPT_HEADER, 1); //设置头部
394
+            curl_setopt($ch, CURLOPT_HTTPHEADER, $_headers); //请求头
395
+            curl_setopt($ch, CURLOPT_TIMEOUT, $uploadOption->timeout); //持续时长
396
+            curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 10); //连接超时时长
397 397
             curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1); //成功,只返回结果,不自动输出任何内容。如果失败返回FALSE
398 398
             curl_setopt($ch, CURLOPT_FOLLOWLOCATION, 0);
399 399
             curl_setopt($ch, CURLOPT_URL, $url);
400
-            curl_setopt($ch, CURLOPT_CUSTOMREQUEST, $method);           //自定义请求
400
+            curl_setopt($ch, CURLOPT_CUSTOMREQUEST, $method); //自定义请求
401 401
             //设置请求方式(GET或POST等)
402 402
             if ($method == 'PUT' || $method == 'POST') {
403 403
                 curl_setopt($ch, CURLOPT_POST, 1);
@@ -418,10 +418,10 @@  discard block
 block discarded – undo
418 418
             } else {
419 419
                 //解析返回结果,并判断是否上传成功
420 420
                 $http_code = curl_getinfo($ch, CURLINFO_HTTP_CODE);
421
-                $success = ($http_code == 200) ? true : false;                  //判断是否上传成功
421
+                $success = ($http_code == 200) ? true : false; //判断是否上传成功
422 422
                 $resStr = explode("\r\n\r\n", $response, 2);
423 423
                 $resBody = isset($resStr[1]) ? $resStr[1] : '';
424
-                $resArray = json_decode($resBody, true);                        //解析得到结果
424
+                $resArray = json_decode($resBody, true); //解析得到结果
425 425
                 $result = (empty($resArray) ? $result : $resArray);
426 426
             }
427 427
         } catch (Exception $e) {
Please login to merge, or discard this patch.