tken/addons/qiniu/library/Qiniu/Storage/FormUploader.php

<?php

namespace Qiniu\Storage;

use Qiniu\Config;
use Qiniu\Http\Client;
use Qiniu\Http\Error;

final class FormUploader
{

    /**
     * 上传二进制流到七牛, 内部使用
     *
     * @param string   $upToken 上传凭证
     * @param string   $key     上传文件名
     * @param resource $data    上传二进制流
     * @param Config   $config  上传配置
     * @param array    $params  自定义变量，规格参考 http://developer.qiniu.com/docs/v6/api/overview/up/response/vars.html#xvar
     * @param string   $mime    上传数据的mimeType
     *
     * @return array    包含已上传文件的信息，类似：
     *                                                  [
     *                                                  "hash" => "<Hash string>",
     *                                                  "key" => "<Key string>"
     *                                                  ]
     */
    public static function put($upToken, $key, $data, $config, $params, $mime, $fname)
    {
        $fields = array('token' => $upToken);
        if ($key === null) {
        } else {
            $fields['key'] = $key;
        }

        //enable crc32 check by default
        $fields['crc32'] = \Qiniu\crc32_data($data);

        if ($params) {
            foreach ($params as $k => $v) {
                $fields[$k] = $v;
            }
        }

        list($accessKey, $bucket, $err) = \Qiniu\explodeUpToken($upToken);
        if ($err != null) {
            return array(null, $err);
        }

        $upHost = $config->getUpHost($accessKey, $bucket);

        $response = Client::multipartPost($upHost, $fields, 'file', $fname, $data, $mime);
        if (!$response->ok()) {
            return array(null, new Error($upHost, $response));
        }
        return array($response->json(), null);
    }

    /**
     * 上传文件到七牛，内部使用
     *
     * @param string $upToken  上传凭证
     * @param string $key      上传文件名
     * @param string $filePath 上传文件的路径
     * @param Config $config   上传配置
     * @param array  $params   自定义变量，规格参考 http://developer.qiniu.com/docs/v6/api/overview/up/response/vars.html#xvar
     * @param string $mime     上传数据的mimeType
     *
     * @return array    包含已上传文件的信息，类似：
     *                                                  [
     *                                                  "hash" => "<Hash string>",
     *                                                  "key" => "<Key string>"
     *                                                  ]
     */
    public static function putFile($upToken, $key, $filePath, $config, $params, $mime)
    {
        $fields = array('token' => $upToken, 'file' => self::createFile($filePath, $mime));
        if ($key !== null) {
            $fields['key'] = $key;
        }

        $fields['crc32'] = \Qiniu\crc32_file($filePath);

        if ($params) {
            foreach ($params as $k => $v) {
                $fields[$k] = $v;
            }
        }
        $fields['key'] = $key;
        $headers = array('Content-Type' => 'multipart/form-data');

        list($accessKey, $bucket, $err) = \Qiniu\explodeUpToken($upToken);
        if ($err != null) {
            return array(null, $err);
        }

        $upHost = $config->getUpHost($accessKey, $bucket);

        $response = Client::post($upHost, $fields, $headers);
        if (!$response->ok()) {
            return array(null, new Error($upHost, $response));
        }
        return array($response->json(), null);
    }

    private static function createFile($filename, $mime)
    {
        // PHP 5.5 introduced a CurlFile object that deprecates the old @filename syntax
        // See: https://wiki.php.net/rfc/curl-file-upload
        if (function_exists('curl_file_create')) {
            return curl_file_create($filename, $mime);
        }

        // Use the old style if using an older version of PHP
        $value = "@{$filename}";
        if (!empty($mime)) {
            $value .= ';type=' . $mime;
        }

        return $value;
    }
}