f4engine/core/Library/Think/Upload/Driver/Bcsbcs.class.php

<?php
namespace Think\Upload\Driver\Bcs;

use Think\Upload\Driver\Bcs\BCS_Exception as BCS_Exception;
use Think\Upload\Driver\Bcs\BCS_MimeTypes;
use Think\Upload\Driver\Bcs\BCS_RequestCore;
use Think\Upload\Driver\Bcs\BCS_ResponseCore;

if (!defined('BCS_API_PATH')) {
    define('BCS_API_PATH', dirname(__FILE__));
}

//AK 公钥
define('BCS_AK', '');
//SK 私钥
define('BCS_SK', '');
//superfile 每个object分片后缀
define('BCS_SUPERFILE_POSTFIX', '_bcs_superfile_');
//sdk superfile分片大小 ，单位 B（字节）
define('BCS_SUPERFILE_SLICE_SIZE', 1024 * 1024);

require_once BCS_API_PATH . '/requestcore.class.php';
require_once BCS_API_PATH . '/mimetypes.class.php';
/**
 * Default BCS Exception.
 */
class BcsException extends \Exception
{
}
/**
 * BCS API
 */
class BaiduBCS
{
    /*%******************************************************************************************%*/
    // CLASS CONSTANTS
    //百度云存储默认外网域名
    const DEFAULT_URL = 'bcs.duapp.com';
    //SDK 版本
    const API_VERSION            = '2012-4-17-1.0.1.6';
    const ACL                    = 'acl';
    const BUCKET                 = 'bucket';
    const OBJECT                 = 'object';
    const HEADERS                = 'headers';
    const METHOD                 = 'method';
    const AK                     = 'ak';
    const SK                     = 'sk';
    const QUERY_STRING           = "query_string";
    const IMPORT_BCS_LOG_METHOD  = "import_bs_log_method";
    const IMPORT_BCS_PRE_FILTER  = "import_bs_pre_filter";
    const IMPORT_BCS_POST_FILTER = "import_bs_post_filter";
    /**********************************************************
     ******************* Policy Constants**********************
     **********************************************************/
    const STATEMETS = 'statements';
    //Action 用户动作
    //'*'代表所有action
    const BCS_SDK_ACL_ACTION_ALL = '*';
    //与bucket相关的action
    const BCS_SDK_ACL_ACTION_LIST_OBJECT       = 'list_object';
    const BCS_SDK_ACL_ACTION_PUT_BUCKET_POLICY = 'put_bucket_policy';
    const BCS_SDK_ACL_ACTION_GET_BUCKET_POLICY = 'get_bucket_policy';
    const BCS_SDK_ACL_ACTION_DELETE_BUCKET     = 'delete_bucket';
    //与object相关的action
    const BCS_SDK_ACL_ACTION_GET_OBJECT        = 'get_object';
    const BCS_SDK_ACL_ACTION_PUT_OBJECT        = 'put_object';
    const BCS_SDK_ACL_ACTION_DELETE_OBJECT     = 'delete_object';
    const BCS_SDK_ACL_ACTION_PUT_OBJECT_POLICY = 'put_object_policy';
    const BCS_SDK_ACL_ACTION_GET_OBJECT_POLICY = 'get_object_policy';
    static $ACL_ACTIONS                        = array(
        self::BCS_SDK_ACL_ACTION_ALL,
        self::BCS_SDK_ACL_ACTION_LIST_OBJECT,
        self::BCS_SDK_ACL_ACTION_PUT_BUCKET_POLICY,
        self::BCS_SDK_ACL_ACTION_GET_BUCKET_POLICY,
        self::BCS_SDK_ACL_ACTION_DELETE_BUCKET,
        self::BCS_SDK_ACL_ACTION_GET_OBJECT,
        self::BCS_SDK_ACL_ACTION_PUT_OBJECT,
        self::BCS_SDK_ACL_ACTION_DELETE_OBJECT,
        self::BCS_SDK_ACL_ACTION_PUT_OBJECT_POLICY,
        self::BCS_SDK_ACL_ACTION_GET_OBJECT_POLICY);
    //EFFECT:
    const BCS_SDK_ACL_EFFECT_ALLOW = "allow";
    const BCS_SDK_ACL_EFFECT_DENY  = "deny";
    static $ACL_EFFECTS            = array(
        self::BCS_SDK_ACL_EFFECT_ALLOW,
        self::BCS_SDK_ACL_EFFECT_DENY);
    //ACL_TYPE:
    //公开读权限
    const BCS_SDK_ACL_TYPE_PUBLIC_READ = "public-read";
    //公开写权限（不具备删除权限）
    const BCS_SDK_ACL_TYPE_PUBLIC_WRITE = "public-write";
    //公开读写权限（不具备删除权限）
    const BCS_SDK_ACL_TYPE_PUBLIC_READ_WRITE = "public-read-write";
    //公开所有权限
    const BCS_SDK_ACL_TYPE_PUBLIC_CONTROL = "public-control";
    //私有权限，仅bucket所有者具有所有权限
    const BCS_SDK_ACL_TYPE_PRIVATE = "private";
    //SDK中开放此上五种acl_tpe
    static $ACL_TYPES = array(
        self::BCS_SDK_ACL_TYPE_PUBLIC_READ,
        self::BCS_SDK_ACL_TYPE_PUBLIC_WRITE,
        self::BCS_SDK_ACL_TYPE_PUBLIC_READ_WRITE,
        self::BCS_SDK_ACL_TYPE_PUBLIC_CONTROL,
        self::BCS_SDK_ACL_TYPE_PRIVATE);
    /*%******************************************************************************************%*/
    // PROPERTIES
    //是否使用ssl
    protected $use_ssl = false;
    //公钥 account key
    private $ak;
    //私钥 secret key
    private $sk;
    //云存储server地址
    private $hostname;

    /**
     * 构造函数
     * @param string $ak  云存储公钥
     * @param string $sk  云存储私钥
     * @param string $hostname 云存储Api访问地址
     * @throws BCS_Exception
     */
    public function __construct($ak = null, $sk = null, $hostname = null)
    {
        //valid ak & sk
        if (!$ak && !defined('BCS_AK') && false === getenv('HTTP_BAE_ENV_AK')) {
            throw new BCS_Exception('No account key was passed into the constructor.');
        }
        if (!$sk && !defined('BCS_SK') && false === getenv('HTTP_BAE_ENV_SK')) {
            throw new BCS_Exception('No secret key was passed into the constructor.');
        }
        if ($ak && $sk) {
            $this->ak = $ak;
            $this->sk = $sk;
        } elseif (defined('BCS_AK') && defined('BCS_SK') && strlen(BCS_AK) > 0 && strlen(BCS_SK) > 0) {
            $this->ak = BCS_AK;
            $this->sk = BCS_SK;
        } elseif (false !== getenv('HTTP_BAE_ENV_AK') && false !== getenv('HTTP_BAE_ENV_SK')) {
            $this->ak = getenv('HTTP_BAE_ENV_AK');
            $this->sk = getenv('HTTP_BAE_ENV_SK');
        } else {
            throw new BCS_Exception('Construct can not get ak &sk pair, please check!');
        }
        //valid $hostname
        if (null !== $hostname) {
            $this->hostname = $hostname;
        } elseif (false !== getenv('HTTP_BAE_ENV_ADDR_BCS')) {
            $this->hostname = getenv('HTTP_BAE_ENV_ADDR_BCS');
        } else {
            $this->hostname = self::DEFAULT_URL;
        }
    }

    /**
     * 将消息发往Baidu BCS.
     * @param array $opt
     * @return BCS_ResponseCore
     */
    private function authenticate($opt)
    {
        //set common param into opt
        $opt[self::AK] = $this->ak;
        $opt[self::SK] = $this->sk;

        // Validate the S3 bucket name, only list_bucket didnot need validate_bucket
        if (!('/' == $opt[self::OBJECT] && '' == $opt[self::BUCKET] && 'GET' == $opt[self::METHOD] && !isset($opt[self::QUERY_STRING][self::ACL])) && !self::validateBucket($opt[self::BUCKET])) {
            throw new BCS_Exception($opt[self::BUCKET] . 'is not valid, please check!');
        }
        //Validate object
        if (isset($opt[self::OBJECT]) && !self::validateObject($opt[self::OBJECT])) {
            throw new BCS_Exception("Invalid object param[" . $opt[self::OBJECT] . "], please check.", -1);
        }
        //construct url
        $url = $this->formatUrl($opt);
        if (false === $url) {
            throw new BCS_Exception('Can not format url, please check your param!', -1);
        }
        $opt['url'] = $url;
        $this->log("[method:" . $opt[self::METHOD] . "][url:$url]", $opt);
        //build request
        $request = new BCS_RequestCore($opt['url']);
        $headers = array(
            'Content-Type' => 'application/x-www-form-urlencoded');

        $request->set_method($opt[self::METHOD]);
        //Write get_object content to fileWriteTo
        if (isset($opt['fileWriteTo'])) {
            $request->set_write_file($opt['fileWriteTo']);
        }
        // Merge the HTTP headers
        if (isset($opt[self::HEADERS])) {
            $headers = array_merge($headers, $opt[self::HEADERS]);
        }
        // Set content to Http-Body
        if (isset($opt['content'])) {
            $request->set_body($opt['content']);
        }
        // Upload file
        if (isset($opt['fileUpload'])) {
            if (!file_exists($opt['fileUpload'])) {
                throw new BCS_Exception('File[' . $opt['fileUpload'] . '] not found!', -1);
            }
            $request->set_read_file($opt['fileUpload']);
            // Determine the length to read from the file
            $length    = $request->read_stream_size; // The file size by default
            $file_size = $length;
            if (isset($opt["length"])) {
                if ($opt["length"] > $file_size) {
                    throw new BCS_Exception("Input opt[length] invalid! It can not bigger than file-size", -1);
                }
                $length = $opt['length'];
            }
            if (isset($opt['seekTo']) && !isset($opt["length"])) {
                // Read from seekTo until EOF by default, when set seekTo but not set $opt["length"]
                $length -= (integer) $opt['seekTo'];
            }
            $request->set_read_stream_size($length);
            // Attempt to guess the correct mime-type
            if ('application/x-www-form-urlencoded' === $headers['Content-Type']) {
                $extension               = explode('.', $opt['fileUpload']);
                $extension               = array_pop($extension);
                $mime_type               = BCS_MimeTypes::get_mimetype($extension);
                $headers['Content-Type'] = $mime_type;
            }
            $headers['Content-MD5'] = '';
        }
        // Handle streaming file offsets
        if (isset($opt['seekTo'])) {
            // Pass the seek position to BCS_RequestCore
            $request->set_seek_position((integer) $opt['seekTo']);
        }
        // Add headers to request and compute the string to sign
        foreach ($headers as $header_key => $header_value) {
            // Strip linebreaks from header values as they're illegal and can allow for security issues
            $header_value = str_replace(array(
                "\r",
                "\n"), '', $header_value);
            // Add the header if it has a value
            if ('' !== $header_value) {
                $request->add_header($header_key, $header_value);
            }
        }
        // Set the curl options.
        if (isset($opt['curlopts']) && count($opt['curlopts'])) {
            $request->set_curlopts($opt['curlopts']);
        }
        $request->send_request();
        require_once dirname(__FILE__) . "/requestcore.class.php";
        return new BCS_ResponseCore($request->get_response_header(), $request->get_response_body(), $request->get_response_code());
    }

    /**
     * 获取当前密钥对拥有者的bucket列表
     * @param array $opt (Optional)
     * BaiduBCS::IMPORT_BCS_LOG_METHOD - String - Optional: 支持用户传入日志处理函数，函数定义如 function f($log)
     * @throws BCS_Exception
     * @return BCS_ResponseCore
     */
    public function listBucket($opt = array())
    {
        $this->assertParameterArray($opt);
        $opt[self::BUCKET] = '';
        $opt[self::METHOD] = 'GET';
        $opt[self::OBJECT] = '/';
        $response          = $this->authenticate($opt);
        $this->log($response->isOK() ? "List bucket success!" : "List bucket failed! Response: [" . $response->body . "]", $opt);
        return $response;
    }

    /**
     * 创建 bucket
     * @param string $bucket (Required) bucket名称
     * @param string $acl (Optional)    bucket权限设置，若为null，使用server分配的默认权限
     * @param array $opt (Optional)
     * @throws BCS_Exception
     * @return BCS_ResponseCore
     */
    public function createBucket($bucket, $acl = null, $opt = array())
    {
        $this->assertParameterArray($opt);
        $opt[self::BUCKET] = $bucket;
        $opt[self::METHOD] = 'PUT';
        $opt[self::OBJECT] = '/';
        if (null !== $acl) {
            if (!in_array($acl, self::$ACL_TYPES)) {
                throw new BCS_Exception("Invalid acl_type[" . $acl . "], please check!", -1);
            }
            self::setHeaderIntoOpt("x-bs-acl", $acl, $opt);
        }
        $response = $this->authenticate($opt);
        $this->log($response->isOK() ? "Create bucket success!" : "Create bucket failed! Response: [" . $response->body . "]", $opt);
        return $response;
    }

    /**
     * 删除bucket
     * @param string $bucket (Required)
     * @param array $opt (Optional)
     * @return boolean|BCS_ResponseCore
     */
    public function deleteBucket($bucket, $opt = array())
    {
        $this->assertParameterArray($opt);
        $opt[self::BUCKET] = $bucket;
        $opt[self::METHOD] = 'DELETE';
        $opt[self::OBJECT] = '/';
        $response          = $this->authenticate($opt);
        $this->log($response->isOK() ? "Delete bucket success!" : "Delete bucket failed! Response: [" . $response->body . "]", $opt);
        return $response;
    }

    /**
     * 设置bucket的acl，有三种模式，
     * (1).设置详细json格式的acl；
     * a. $acl 为json的array
     * b. $acl 为json的string
     * (2).通过acl_type字段进行设置
     * a. $acl 为BaiduBCS::$ACL_TYPES中的字段
     * @param string $bucket (Required)
     * @param string $acl (Required)
     * @param array $opt (Optional)
     * @return boolean|BCS_ResponseCore
     */
    public function setBucketAcl($bucket, $acl, $opt = array())
    {
        $this->assertParameterArray($opt);
        $result                  = $this->analyzeUserAcl($acl);
        $opt                     = array_merge($opt, $result);
        $opt[self::BUCKET]       = $bucket;
        $opt[self::METHOD]       = 'PUT';
        $opt[self::OBJECT]       = '/';
        $opt[self::QUERY_STRING] = array(
            self::ACL => 1);
        $response = $this->authenticate($opt);
        $this->log($response->isOK() ? "Set bucket acl success!" : "Set bucket acl failed! Response: [" . $response->body . "]", $opt);
        return $response;
    }

    /**
     * 获取bucket的acl
     * @param string $bucket (Required)
     * @param array $opt (Optional)
     * @return BCS_ResponseCore
     */
    public function getBucketAcl($bucket, $opt = array())
    {
        $this->assertParameterArray($opt);
        $opt[self::BUCKET]       = $bucket;
        $opt[self::METHOD]       = 'GET';
        $opt[self::OBJECT]       = '/';
        $opt[self::QUERY_STRING] = array(
            self::ACL => 1);
        $response = $this->authenticate($opt);
        $this->log($response->isOK() ? "Get bucket acl success!" : "Get bucket acl failed! Response: [" . $response->body . "]", $opt);
        return $response;
    }

    /**
     * 获取bucket中object列表
     * @param string $bucket (Required)
     * @param array $opt (Optional)
     * start : 主要用于翻页功能，用法同mysql中start的用法
     * limit : 主要用于翻页功能，用法同mysql中limit的用法
     * prefix: 只返回以prefix为前缀的object，此处prefix必须以'/'开头
     * @throws BCS_Exception
     * @return BCS_ResponseCore
     */
    public function listObject($bucket, $opt = array())
    {
        $this->assertParameterArray($opt);
        $opt[self::BUCKET] = $bucket;
        if (empty($opt[self::BUCKET])) {
            throw new BCS_Exception("Bucket should not be empty, please check", -1);
        }
        $opt[self::METHOD]       = 'GET';
        $opt[self::OBJECT]       = '/';
        $opt[self::QUERY_STRING] = array();
        if (isset($opt['start']) && is_int($opt['start'])) {
            $opt[self::QUERY_STRING]['start'] = $opt['start'];
        }
        if (isset($opt['limit']) && is_int($opt['limit'])) {
            $opt[self::QUERY_STRING]['limit'] = $opt['limit'];
        }
        if (isset($opt['prefix'])) {
            $opt[self::QUERY_STRING]['prefix'] = rawurlencode($opt['prefix']);
        }
        $response = $this->authenticate($opt);
        $this->log($response->isOK() ? "List object success!" : "Lit object failed! Response: [" . $response->body . "]", $opt);
        return $response;
    }

    /**
     * 以目录形式获取bucket中object列表
     * @param string $bucket (Required)
     * @param $dir (Required)
     * 目录名，格式为必须以'/'开头和结尾，默认为'/'
     * @param string $list_model (Required)
     * 目录展现形式，值可以为0,1,2，默认为2，以下对各个值的功能进行介绍：
     * 0->只返回object列表，不返回子目录列表
     * 1->只返回子目录列表，不返回object列表
     * 2->同时返回子目录列表和object列表
     * @param array $opt (Optional)
     * start : 主要用于翻页功能，用法同mysql中start的用法
     * limit : 主要用于翻页功能，用法同mysql中limit的用法
     * @throws BCS_Exception
     * @return BCS_ResponseCore
     */
    public function listObjectByDir($bucket, $dir = '/', $list_model = 2, $opt = array())
    {
        $this->assertParameterArray($opt);
        $opt[self::BUCKET] = $bucket;
        if (empty($opt[self::BUCKET])) {
            throw new BCS_Exception("Bucket should not be empty, please check", -1);
        }
        $opt[self::METHOD]       = 'GET';
        $opt[self::OBJECT]       = '/';
        $opt[self::QUERY_STRING] = array();
        if (isset($opt['start']) && is_int($opt['start'])) {
            $opt[self::QUERY_STRING]['start'] = $opt['start'];
        }
        if (isset($opt['limit']) && is_int($opt['limit'])) {
            $opt[self::QUERY_STRING]['limit'] = $opt['limit'];
        }

        $opt[self::QUERY_STRING]['prefix'] = rawurlencode($dir);
        $opt[self::QUERY_STRING]['dir']    = $list_model;

        $response = $this->authenticate($opt);
        $this->log($response->isOK() ? "List object success!" : "Lit object failed! Response: [" . $response->body . "]", $opt);
        return $response;
    }

    /**
     * 上传文件
     * @param string $bucket (Required)
     * @param string $object (Required)
     * @param string $file (Required); 需要上传的文件的文件路径
     * @param array $opt (Optional)
     * filename - Optional; 指定文件名
     * acl - Optional ; 上传文件的acl，只能使用acl_type
     * seekTo - Optional; 上传文件的偏移位置
     * length - Optional; 待上传长度
     * @return BCS_ResponseCore
     */
    public function createObject($bucket, $object, $file, $opt = array())
    {
        $this->assertParameterArray($opt);
        $opt[self::BUCKET] = $bucket;
        $opt[self::OBJECT] = $object;
        $opt['fileUpload'] = $file;
        $opt[self::METHOD] = 'PUT';
        if (isset($opt['acl'])) {
            if (in_array($opt['acl'], self::$ACL_TYPES)) {
                self::setHeaderIntoOpt("x-bs-acl", $opt['acl'], $opt);
            } else {
                throw new BCS_Exception("Invalid acl string, it should be acl_type", -1);
            }
            unset($opt['acl']);
        }
        if (isset($opt['filename'])) {
            self::setHeaderIntoOpt("Content-Disposition", 'attachment; filename=' . $opt['filename'], $opt);
        }
        $response = $this->authenticate($opt);
        $this->log($response->isOK() ? "Create object[$object] file[$file] success!" : "Create object[$object] file[$file] failed! Response: [" . $response->body . "] Logid[" . $response->header["x-bs-request-id"] . "]", $opt);
        return $response;
    }

    /**
     * 上传文件
     * @param string $bucket (Required)
     * @param string $object (Required)
     * @param string $file (Required); 需要上传的文件的文件路径
     * @param array $opt (Optional)
     * filename - Optional; 指定文件名
     * acl - Optional ; 上传文件的acl，只能使用acl_type
     * @return BCS_ResponseCore
     */
    public function createObjectByContent($bucket, $object, $content, $opt = array())
    {
        $this->assertParameterArray($opt);
        $opt[self::BUCKET] = $bucket;
        $opt[self::OBJECT] = $object;
        $opt[self::METHOD] = 'PUT';
        if (null !== $content && is_string($content)) {
            $opt['content'] = $content;
        } else {
            throw new BCS_Exception("Invalid object content, please check.", -1);
        }
        if (isset($opt['acl'])) {
            if (in_array($opt['acl'], self::$ACL_TYPES)) {
                self::setHeaderIntoOpt("x-bs-acl", $opt['acl'], $opt);
            } else {
                throw new BCS_Exception("Invalid acl string, it should be acl_type", -1);
            }
            unset($opt['acl']);
        }
        if (isset($opt['filename'])) {
            self::setHeaderIntoOpt("Content-Disposition", 'attachment; filename=' . $opt['filename'], $opt);
        }
        $response = $this->authenticate($opt);
        $this->log($response->isOK() ? "Create object[$object] success!" : "Create object[$object] failed! Response: [" . $response->body . "] Logid[" . $response->header["x-bs-request-id"] . "]", $opt);
        return $response;
    }

    /**
     * 通过superfile的方式上传文件
     * @param string $bucket (Required)
     * @param string $object (Required)
     * @param string $file (Required); 需要上传的文件的文件路径
     * @param array $opt (Optional)
     * filename - Optional; 指定文件名
     * sub_object_size - Optional; 指定子文件的划分大小，单位B，建议以256KB为单位进行子object划分，默认为1MB进行划分
     * @return BCS_ResponseCore
     */
    public function createObjectSuperfile($bucket, $object, $file, $opt = array())
    {
        if (isset($opt['length']) || isset($opt['seekTo'])) {
            throw new BCS_Exception("Temporary unsupport opt of length and seekTo of superfile.", -1);
        }
        //$opt array
        $this->assertParameterArray($opt);
        $opt[self::BUCKET] = $bucket;
        $opt['fileUpload'] = $file;
        $opt[self::METHOD] = 'PUT';
        if (isset($opt['acl'])) {
            if (in_array($opt['acl'], self::$ACL_TYPES)) {
                self::setHeaderIntoOpt("x-bs-acl", $opt['acl'], $opt);
            } else {
                throw new BCS_Exception("Invalid acl string, it should be acl_type", -1);
            }
            unset($opt['acl']);
        }
        //切片上传
        if (!file_exists($opt['fileUpload'])) {
            throw new BCS_Exception('File not found!', -1);
        }
        $fileSize        = filesize($opt['fileUpload']);
        $sub_object_size = 1024 * 1024; //default 1MB
        if (defined("BCS_SUPERFILE_SLICE_SIZE")) {
            $sub_object_size = BCS_SUPERFILE_SLICE_SIZE;
        }
        if (isset($opt["sub_object_size"])) {
            if (is_int($opt["sub_object_size"]) && $opt["sub_object_size"] > 0) {
                $sub_object_size = $opt["sub_object_size"];
            } else {
                throw new BCS_Exception("Param [sub_object_size] invalid ,please check!", -1);
            }
        }
        $sliceNum = intval(ceil($fileSize / $sub_object_size));
        $this->log("File[" . $opt['fileUpload'] . "], size=[$fileSize], sub_object_size=[$sub_object_size], sub_object_num=[$sliceNum]", $opt);
        $object_list = array(
            'object_list' => array());
        for ($i = 0; $i < $sliceNum; $i++) {
            //send slice
            $opt['seekTo'] = $i * $sub_object_size;

            if (($i + 1) === $sliceNum) {
                //last sub object
                $opt['length'] = (0 === $fileSize % $sub_object_size) ? $sub_object_size : $fileSize % $sub_object_size;
            } else {
                $opt['length'] = $sub_object_size;
            }
            $opt[self::OBJECT]                               = $object . BCS_SUPERFILE_POSTFIX . $i;
            $object_list['object_list']['part_' . $i]        = array();
            $object_list['object_list']['part_' . $i]['url'] = 'bs://' . $bucket . $opt[self::OBJECT];
            $this->log("Begin to upload Sub-object[" . $opt[self::OBJECT] . "][$i/$sliceNum][seekto:" . $opt['seekTo'] . "][Length:" . $opt['length'] . "]", $opt);
            $response = $this->createObject($bucket, $opt[self::OBJECT], $file, $opt);
            if ($response->isOK()) {
                $this->log("Sub-object upload[" . $opt[self::OBJECT] . "][$i/$sliceNum][seekto:" . $opt['seekTo'] . "][Length:" . $opt['length'] . "]success! ", $opt);
                $object_list['object_list']['part_' . $i]['etag'] = $response->header['Content-MD5'];
                continue;
            } else {
                $this->log("Sub-object upload[" . $opt[self::OBJECT] . "][$i/$sliceNum] failed! ", $opt);
                return $response;
            }
        }
        //将子文件分片的列表构造成 superfile
        unset($opt['fileUpload']);
        unset($opt['length']);
        unset($opt['seekTo']);
        $opt['content']          = self::arrayToJson($object_list);
        $opt[self::QUERY_STRING] = array(
            "superfile" => 1);
        $opt[self::OBJECT] = $object;
        if (isset($opt['filename'])) {
            self::setHeaderIntoOpt("Content-Disposition", 'attachment; filename=' . $opt['filename'], $opt);
        }
        $response = $this->authenticate($opt);
        $this->log($response->isOK() ? "Create object-superfile success!" : "Create object-superfile failed! Response: [" . $response->body . "]", $opt);
        return $response;
    }

    /**
     * 将目录中的所有文件进行上传，每个文件为单独object，object命名方式下详：
     * 如有 /home/worker/a/b/c.txt  需上传目录为$dir=/home/worker/a
     * object命令方式为
     * 1. object默认命名方式为 “子目录名 +文件名”，如上述文件c.txt，默认为 '/b/c.txt'
     * 2. 增强命名模式，在$opt中有可选参数进行配置
     * 举例说明 ：prefix . has_sub_directory?"/b":"" . '/c.txt'
     * @param string $bucket (Required)
     * @param string $dir (Required)
     * @param array $opt(Optional)
     * string prefix 文件object前缀
     * boolean has_sub_directory(default=true)   object命名中是否携带文件的子目录结构，若置为false，请确认待上传的目录和所有子目录中没有重名文件，否则会产生object覆盖问题
     * BaiduBCS::IMPORT_BCS_PRE_FILTER   用户可自定义上传文件前的操作函数
     * 1. 函数参数列表顺序需为 ($bucket,$object,$file,&$opt)，注意$opt为upload_directory函数传入的$opt的拷贝，只对当前object生效
     * 2. 函数返回值必须为boolean，当true该文件进行上传，若false跳过上传
     * 3. 如果函数返回false，将不会进行post_filter的调用
     * BaiduBCS::IMPORT_BCS_POST_FILTER  用户可自定义上传文件后的操作函数
     * 1. 函数参数列表顺序需为 ($bucket,$object,$file,&$opt,$response)，注意$opt为upload_directory函数传入的$opt的拷贝，只对当前object生效
     * 2. 函数返回值无要求
     * string seek_object 用户断点续传，需要为object名称，如果该object在目录中不存在，抛出异常，若存在则将该object和此后的object进行上传
     * string seek_object_id 作用同seek_object，只需要传入上传过程中日志中展示的[a/b]中object序号即可，注意object序号是以1开始计算的
     * @return array  数组形式的上传结果
     * 'success' => int  上传成功的文件数目
     * 'skipped' => int  被跳过的文件
     * 'failed' => array()   上传失败的文件
     *
     */
    public function uploadDirectory($bucket, $dir, $opt = array())
    {
        $this->assertParameterArray($opt);
        if (!is_dir($dir)) {
            throw new BCS_Exception("$dir is not a dir!", -1);
        }
        $result = array(
            "success" => 0,
            "failed"  => array(),
            "skipped" => 0);
        $prefix = "";
        if (isset($opt['prefix'])) {
            $prefix = $opt['prefix'];
        }
        $has_sub_directory = true;
        if (isset($opt['has_sub_directory']) && is_bool($opt['has_sub_directory'])) {
            $has_sub_directory = $opt['has_sub_directory'];
        }
        //获取文件树和构造object名
        $file_tree = self::getFiletree($dir);
        $objects   = array();
        foreach ($file_tree as $file) {
            $object                     = true == $has_sub_directory ? substr($file, strlen($dir)) : "/" . basename($file);
            $objects[$prefix . $object] = $file;
        }
        $objectCount       = count($objects);
        $before_upload_log = "Upload directory: bucket[$bucket] upload_dir[$dir] file_sum[$objectCount]";
        if (isset($opt["seek_object_id"])) {
            $before_upload_log .= " seek_object_id[" . $opt["seek_object_id"] . "/$objectCount]";
        }
        if (isset($opt["seek_object"])) {
            $before_upload_log .= " seek_object[" . $opt["seek_object"] . "]";
        }
        $this->log($before_upload_log, $opt);
        //查看是否需要查询断点，进行断点续传
        if (isset($opt["seek_object_id"]) && isset($opt["seek_object"])) {
            throw new BCS_Exception("Can not set see_object_id and seek_object at the same time!", -1);
        }

        $num = 1;
        if (isset($opt["seek_object"])) {
            if (isset($objects[$opt["seek_object"]])) {
                foreach ($objects as $object => $file) {
                    if ($object != $opt["seek_object"]) {
                        //当非断点文件，该object已完成上传
                        $this->log("Seeking[" . $opt["seek_object"] . "]. Skip id[$num/$objectCount]object[$object]file[$file].", $opt);
                        //$result ['skipped'] [] = "[$num/$objectCount]  " . $file;
                        $result['skipped']++;
                        unset($objects[$object]);
                    } else {
                        //当找到断点文件，停止循环，从断点文件重新上传
                        //当非断点文件，该object已完成上传
                        $this->log("Found seek id[$num/$objectCount]object[$object]file[$file], begin from here.", $opt);
                        break;
                    }
                    $num++;
                }
            } else {
                throw new BCS_Exception("Can not find you seek object, please check!", -1);
            }
        }
        if (isset($opt["seek_object_id"])) {
            if (is_int($opt["seek_object_id"]) && $opt["seek_object_id"] <= $objectCount) {
                foreach ($objects as $object => $file) {
                    if ($num < $opt["seek_object_id"]) {
                        $this->log("Seeking object of [" . $opt["seek_object_id"] . "/$objectCount]. Skip  id[$num/$objectCount]object[$object]file[$file].", $opt);
                        //$result ['skipped'] [] = "[$num/$objectCount]  " . $file;
                        $result['skipped']++;
                        unset($objects[$object]);
                    } else {
                        break;
                    }
                    $num++;
                }
            } else {
                throw new BCS_Exception("Param seek_object_id not valid, please check!", -1);
            }
        }
        //上传objects
        $objectCount = count($objects);
        foreach ($objects as $object => $file) {
            $tmp_opt = array_merge($opt);
            if (isset($opt[self::IMPORT_BCS_PRE_FILTER]) && function_exists($opt[self::IMPORT_BCS_PRE_FILTER])) {
                $bolRes = $opt[self::IMPORT_BCS_PRE_FILTER]($bucket, $object, $file, $tmp_opt);
                if (true !== $bolRes) {
                    $this->log("User pre_filter_function return un-true. Skip id[$num/$objectCount]object[$object]file[$file].", $opt);
                    //$result ['skipped'] [] = "id[$num/$objectCount]object[$object]file[$file]";
                    $result['skipped']++;
                    $num++;
                    continue;
                }
            }
            try {
                $response = $this->createObject($bucket, $object, $file, $tmp_opt);
            } catch (Exception $e) {
                $this->log($e->getMessage(), $opt);
                $this->log("Upload Failed id[$num/$objectCount]object[$object]file[$file].", $opt);
                $num++;
                continue;
            }
            if ($response->isOK()) {
                $result["success"]++;
                $this->log("Upload Success id[$num/$objectCount]object[$object]file[$file].", $opt);
            } else {
                $result["failed"][] = "id[$num/$objectCount]object[$object]file[$file]";
                $this->log("Upload Failed id[$num/$objectCount]object[$object]file[$file].", $opt);
            }
            if (isset($opt[self::IMPORT_BCS_POST_FILTER]) && function_exists($opt[self::IMPORT_BCS_POST_FILTER])) {
                $opt[self::IMPORT_BCS_POST_FILTER]($bucket, $object, $file, $tmp_opt, $response);
            }
            $num++;
        }
        //打印日志并返回结果数组
        $result_str = "\r\n\r\nUpload $dir to $bucket finished!\r\n";
        $result_str .= "**********************************************************\r\n";
        $result_str .= "**********************Result Summary**********************\r\n";
        $result_str .= "**********************************************************\r\n";
        $result_str .= "Upload directory :  [$dir]\r\n";
        $result_str .= "File num :  [$objectCount]\r\n";
        $result_str .= "Success: \r\n\tNum: " . $result["success"] . "\r\n";
        $result_str .= "Skipped:\r\n\tNum:" . $result["skipped"] . "\r\n";
        //        foreach ( $result ["skipped"] as $skip ) {
        //            $result_str .= "\t$skip\r\n";
        //        }
        $result_str .= "Failed:\r\n\tNum:" . count($result["failed"]) . "\r\n";
        foreach ($result["failed"] as $fail) {
            $result_str .= "\t$fail\r\n";
        }
        if (isset($opt[self::IMPORT_BCS_LOG_METHOD])) {
            $this->log($result_str, $opt);
        } else {
            echo $result_str;
        }
        return $result;
    }

    /**
     * 通过此方法以拷贝的方式创建object，object来源为$source
     * @param array $source (Required)  object 来源
     * bucket(Required)
     * object(Required)
     * @param array $dest (Required)    待拷贝的目标object
     * bucket(Required)
     * object(Required)
     * @param array $opt (Optional)
     * source_tag 指定拷贝对象的版本号
     * @throws BCS_Exception
     * @return BCS_ResponseCore
     */
    public function copyObject($source, $dest, $opt = array())
    {
        $this->assertParameterArray($opt);
        //valid source and dest
        if (empty($source) || !is_array($source) || !isset($source[self::BUCKET]) || !isset($source[self::OBJECT])) {
            throw new BCS_Exception('$source invalid, please check!', -1);
        }
        if (empty($dest) || !is_array($dest) || !isset($dest[self::BUCKET]) || !isset($dest[self::OBJECT]) || !self::validateBucket($dest[self::BUCKET]) || !self::validateObject($dest[self::OBJECT])) {
            throw new BCS_Exception('$dest invalid, please check!', -1);
        }
        $opt[self::BUCKET] = $dest[self::BUCKET];
        $opt[self::OBJECT] = $dest[self::OBJECT];
        $opt[self::METHOD] = 'PUT';
        self::setHeaderIntoOpt('x-bs-copy-source', 'bs://' . $source[self::BUCKET] . $source[self::OBJECT], $opt);
        if (isset($opt['source_tag'])) {
            self::setHeaderIntoOpt('x-bs-copy-source-tag', $opt['source_tag'], $opt);
        }
        $response = $this->authenticate($opt);
        $this->log($response->isOK() ? "Copy object success!" : "Copy object failed! Response: [" . $response->body . "]", $opt);
        return $response;
    }

    /**
     * 设置object的meta信息
     * @param string $bucket (Required)
     * @param string $object (Required)
     * @param array $opt (Optional)
     * 目前支持的meta信息如下：
     * Content-Type
     * Cache-Control
     * Content-Disposition
     * Content-Encoding
     * Content-MD5
     * Expires
     * @return BCS_ResponseCore
     */
    public function setObjectMeta($bucket, $object, $meta, $opt = array())
    {
        $this->assertParameterArray($opt);
        $this->assertParameterArray($meta);
        $opt[self::BUCKET] = $bucket;
        $opt[self::OBJECT] = $object;
        $opt[self::METHOD] = 'PUT';
        //利用copy_object接口来设置meta信息
        $source = "bs://$bucket$object";
        if (empty($meta)) {
            throw new BCS_Exception('$meta can not be empty! And $meta must be array.', -1);
        }
        foreach ($meta as $header => $value) {
            self::setHeaderIntoOpt($header, $value, $opt);
        }
        $source = array(
            self::BUCKET => $bucket,
            self::OBJECT => $object);
        $response = $this->copyObject($source, $source, $opt);
        $this->log($response->isOK() ? "Set object meta success!" : "Set object meta failed! Response: [" . $response->body . "]", $opt);
        return $response;
    }

    /**
     * 获取object的acl
     * @param string $bucket (Required)
     * @param string $object (Required)
     * @param array $opt (Optional)
     * @throws BCS_Exception
     * @return BCS_ResponseCore
     */
    public function getObjectAcl($bucket, $object, $opt = array())
    {
        $this->assertParameterArray($opt);
        $opt[self::BUCKET]       = $bucket;
        $opt[self::METHOD]       = 'GET';
        $opt[self::OBJECT]       = $object;
        $opt[self::QUERY_STRING] = array(
            self::ACL => 1);
        $response = $this->authenticate($opt);
        $this->log($response->isOK() ? "Get object acl success!" : "Get object acl failed! Response: [" . $response->body . "]", $opt);
        return $response;
    }

    /**
     * 设置object的acl，有三种模式，
     * (1).设置详细json格式的acl；
     * a. $acl 为json的array
     * b. $acl 为json的string
     * (2).通过acl_type字段进行设置
     * a. $acl 为BaiduBCS::$ACL_ACTIONS中的字段
     * @param string $bucket (Required)
     * @param string $object (Required)
     * @param string|array $acl (Required)
     * @param array $opt (Optional)
     * @return BCS_ResponseCore
     */
    public function setObjectAcl($bucket, $object, $acl, $opt = array())
    {
        $this->assertParameterArray($opt);
        //analyze acl
        $result                  = $this->analyzeUserAcl($acl);
        $opt                     = array_merge($opt, $result);
        $opt[self::BUCKET]       = $bucket;
        $opt[self::METHOD]       = 'PUT';
        $opt[self::OBJECT]       = $object;
        $opt[self::QUERY_STRING] = array(
            self::ACL => 1);
        $response = $this->authenticate($opt);
        $this->log($response->isOK() ? "Set object acl success!" : "Set object acl failed! Response: [" . $response->body . "]", $opt);
        return $response;
    }

    /**
     * 删除object
     * @param string $bucket (Required)
     * @param string $object (Required)
     * @param array $opt (Optional)
     * @throws BCS_Exception
     * @return BCS_ResponseCore
     */
    public function deleteObject($bucket, $object, $opt = array())
    {
        $this->assertParameterArray($opt);
        $opt[self::BUCKET] = $bucket;
        $opt[self::METHOD] = 'DELETE';
        $opt[self::OBJECT] = $object;
        $response          = $this->authenticate($opt);
        $this->log($response->isOK() ? "Delete object success!" : "Delete object failed! Response: [" . $response->body . "]", $opt);
        return $response;
    }

    /**
     * 判断object是否存在
     * @param string $bucket (Required)
     * @param string $object (Required)
     * @param array $opt (Optional)
     * @throws BCS_Exception
     * @return boolean true|boolean false|BCS_ResponseCore
     * true：object存在
     * false：不存在
     * BCS_ResponseCore其他错误
     */
    public function isObjectExist($bucket, $object, $opt = array())
    {
        $this->assertParameterArray($opt);
        $opt[self::BUCKET] = $bucket;
        $opt[self::METHOD] = 'HEAD';
        $opt[self::OBJECT] = $object;
        $response          = $this->getObjectInfo($bucket, $object, $opt);
        if ($response->isOK()) {
            return true;
        } elseif (404 === $response->status) {
            return false;
        }
        return $response;
    }

    /**
     * 获取文件信息，发送的为HTTP HEAD请求，文件信息都在http response的header中，不会提取文件的内容
     * @param string $bucket (Required)
     * @param string $object (Required)
     * @param array $opt (Optional)
     * @throws BCS_Exception
     * @return array BCS_ResponseCore
     */
    public function getObjectInfo($bucket, $object, $opt = array())
    {
        $this->assertParameterArray($opt);
        $opt[self::BUCKET] = $bucket;
        $opt[self::METHOD] = 'HEAD';
        $opt[self::OBJECT] = $object;
        $response          = $this->authenticate($opt);
        $this->log($response->isOK() ? "Get object info success!" : "Get object info failed! Response: [" . $response->body . "]", $opt);
        return $response;
    }

    /**
     * 下载object
     * @param string $bucket (Required)
     * @param string $object (Required)
     * @param array $opt (Optional)
     * fileWriteTo   (Optional)直接将请求结果写入该文件，如果fileWriteTo文件存在，sdk进行重命名再存储
     * @throws BCS_Exception
     * @return BCS_ResponseCore
     */
    public function getObject($bucket, $object, $opt = array())
    {
        $this->assertParameterArray($opt);
        //若fileWriteTo待写入的文件已经存在，需要进行重命名
        if (isset($opt["fileWriteTo"]) && file_exists($opt["fileWriteTo"])) {
            $original_file_write_to = $opt["fileWriteTo"];
            $arr                    = explode(DIRECTORY_SEPARATOR, $opt["fileWriteTo"]);
            $file_name              = $arr[count($arr) - 1];
            $num                    = 1;
            while (file_exists($opt["fileWriteTo"])) {
                $new_name_arr = explode(".", $file_name);
                if (count($new_name_arr) > 1) {
                    $new_name_arr[count($new_name_arr) - 2] .= " ($num)";
                } else {
                    $new_name_arr[0] .= " ($num)";
                }
                $arr[count($arr) - 1] = implode(".", $new_name_arr);
                $opt["fileWriteTo"]   = implode(DIRECTORY_SEPARATOR, $arr);
                $num++;
            }
            $this->log("[$original_file_write_to] already exist, rename it to [" . $opt["fileWriteTo"] . "]", $opt);
        }
        $opt[self::BUCKET] = $bucket;
        $opt[self::METHOD] = 'GET';
        $opt[self::OBJECT] = $object;
        $response          = $this->authenticate($opt);
        $this->log($response->isOK() ? "Get object success!" : "Get object failed! Response: [" . $response->body . "]", $opt);
        if (!$response->isOK() && isset($opt["fileWriteTo"])) {
            unlink($opt["fileWriteTo"]);
        }
        return $response;
    }

    /**
     * 生成签名链接
     */
    private function generateUserUrl($method, $bucket, $object, $opt = array())
    {
        $opt[self::AK]           = $this->ak;
        $opt[self::SK]           = $this->sk;
        $opt[self::BUCKET]       = $bucket;
        $opt[self::METHOD]       = $method;
        $opt[self::OBJECT]       = $object;
        $opt[self::QUERY_STRING] = array();
        if (isset($opt["time"])) {
            $opt[self::QUERY_STRING]["time"] = $opt["time"];
        }
        if (isset($opt["size"])) {
            $opt[self::QUERY_STRING]["size"] = $opt["size"];
        }
        return $this->formatUrl($opt);
    }

    /**
     * 生成get_object的url
     * @param string $bucket (Required)
     * @param string $object (Required)
     * return false| string url
     */
    public function generateGetObjectUrl($bucket, $object, $opt = array())
    {
        $this->assertParameterArray($opt);
        return $this->generateUserUrl("GET", $bucket, $object, $opt);
    }

    /**
     * 生成put_object的url
     * @param string $bucket (Required)
     * @param string $object (Required)
     * return false| string url
     */
    public function generatePutObjectUrl($bucket, $object, $opt = array())
    {
        $this->assertParameterArray($opt);
        return $this->generateUserUrl("PUT", $bucket, $object, $opt);
    }

    /**
     * 生成post_object的url
     * @param string $bucket (Required)
     * @param string $object (Required)
     * return false| string url
     */
    public function generatePostObjectUrl($bucket, $object, $opt = array())
    {
        $this->assertParameterArray($opt);
        return $this->generateUserUrl("POST", $bucket, $object, $opt);
    }

    /**
     * 生成delete_object的url
     * @param string $bucket (Required)
     * @param string $object (Required)
     * return false| string url
     */
    public function generateDeleteObjectUrl($bucket, $object, $opt = array())
    {
        $this->assertParameterArray($opt);
        return $this->generateUserUrl("DELETE", $bucket, $object, $opt);
    }

    /**
     * 生成head_object的url
     * @param string $bucket (Required)
     * @param string $object (Required)
     * return false| string url
     */
    public function generateHeadObjectUrl($bucket, $object, $opt = array())
    {
        $this->assertParameterArray($opt);
        return $this->generateUserUrl("HEAD", $bucket, $object, $opt);
    }

    /**
     * @return the $use_ssl
     */
    public function getuseSsl()
    {
        return $this->use_ssl;
    }

    /**
     * @param boolean $use_ssl
     */
    public function setuseSsl($use_ssl)
    {
        $this->use_ssl = $use_ssl;
    }

    /**
     * 校验bucket是否合法，bucket规范
     * 1. 由小写字母，数字和横线'-'组成，长度为6~63位
     * 2. 不能以数字作为Bucket开头
     * 3. 不能以'-'作为Bucket的开头或者结尾
     * @param string $bucket
     * @return boolean
     */
    public static function validateBucket($bucket)
    {
        //bucket 正则
        $pattern1 = '/^[a-z][-a-z0-9]{4,61}[a-z0-9]$/';
        if (!preg_match($pattern1, $bucket)) {
            return false;
        }
        return true;
    }

    /**
     * 校验object是否合法，object命名规范
     * 1. object必须以'/'开头
     * @param string $object
     * @return boolean
     */
    public static function validateObject($object)
    {
        $pattern = '/^\//';
        if (empty($object) || !preg_match($pattern, $object)) {
            return false;
        }
        return true;
    }

    /**
     * 将常用set http-header的动作抽离出来
     * @param string $header
     * @param string $value
     * @param array $opt
     * @throws BCS_Exception
     * @return void
     */
    private static function setHeaderIntoOpt($header, $value, &$opt)
    {
        if (isset($opt[self::HEADERS])) {
            if (!is_array($opt[self::HEADERS])) {
                trigger_error('Invalid $opt[\'headers\'], please check.');
                throw new BCS_Exception('Invalid $opt[\'headers\'], please check.', -1);
            }
        } else {
            $opt[self::HEADERS] = array();
        }
        $opt[self::HEADERS][$header] = $value;
    }

    /**
     * 使用特定function对数组中所有元素做处理
     * @param string    &$array        要处理的字符串
     * @param string    $function    要执行的函数
     * @param boolean   $apply_to_keys_also     是否也应用到key上
     */
    private static function arrayRecursive(&$array, $function, $apply_to_keys_also = false)
    {
        foreach ($array as $key => $value) {
            if (is_array($value)) {
                self::arrayRecursive($array[$key], $function, $apply_to_keys_also);
            } else {
                $array[$key] = $function($value);
            }

            if ($apply_to_keys_also && is_string($key)) {
                $new_key = $function($key);
                if ($new_key != $key) {
                    $array[$new_key] = $array[$key];
                    unset($array[$key]);
                }
            }
        }
    }

    /**
     * 由数组构造json字符串，增加了一些特殊处理以支持特殊字符和不同编码的中文
     * @param array $array
     */
    private static function arrayToJson($array)
    {
        if (!is_array($array)) {
            throw new BCS_Exception("Param must be array in function array_to_json()", -1);
        }
        self::arrayRecursive($array, 'addslashes', false);
        self::arrayRecursive($array, 'rawurlencode', false);
        return rawurldecode(json_encode($array));
    }

    /**
     * 根据用户传入的acl，进行相应的处理
     * (1).设置详细json格式的acl；
     * a. $acl 为json的array
     * b. $acl 为json的string
     * (2).通过acl_type字段进行设置
     * @param string|array $acl
     * @throws BCS_Exception
     * @return array
     */
    private function analyzeUserAcl($acl)
    {
        $result = array();
        if (is_array($acl)) {
            //(1).a
            $result['content'] = $this->checkUserAcl($acl);
        } else if (is_string($acl)) {
            if (in_array($acl, self::$ACL_TYPES)) {
                //(2).a
                $result["headers"] = array(
                    "x-bs-acl" => $acl);
            } else {
                //(1).b
                $result['content'] = $acl;
            }
        } else {
            throw new BCS_Exception("Invalid acl.", -1);
        }
        return $result;
    }

    /**
     * 生成签名
     * @param array $opt
     * @return boolean|string
     */
    private function formatSignature($opt)
    {
        $flags   = "";
        $content = '';
        if (!isset($opt[self::AK]) || !isset($opt[self::SK])) {
            trigger_error('ak or sk is not in the array when create factor!');
            return false;
        }
        if (isset($opt[self::BUCKET]) && isset($opt[self::METHOD]) && isset($opt[self::OBJECT])) {
            $flags .= 'MBO';
            $content .= "Method=" . $opt[self::METHOD] . "\n"; //method
            $content .= "Bucket=" . $opt[self::BUCKET] . "\n"; //bucket
            $content .= "Object=" . self::trimUrl($opt[self::OBJECT]) . "\n"; //object
        } else {
            trigger_error('bucket、method and object cann`t be NULL!');
            return false;
        }
        if (isset($opt['ip'])) {
            $flags .= 'I';
            $content .= "Ip=" . $opt['ip'] . "\n";
        }
        if (isset($opt['time'])) {
            $flags .= 'T';
            $content .= "Time=" . $opt['time'] . "\n";
        }
        if (isset($opt['size'])) {
            $flags .= 'S';
            $content .= "Size=" . $opt['size'] . "\n";
        }
        $content = $flags . "\n" . $content;
        $sign    = base64_encode(hash_hmac('sha1', $content, $opt[self::SK], true));
        return 'sign=' . $flags . ':' . $opt[self::AK] . ':' . urlencode($sign);
    }

    /**
     * 检查用户输入的acl array是否合法，并转为json
     * @param array $acl
     * @throws BCS_Exception
     * @return string acl-json
     */
    private function checkUserAcl($acl)
    {
        if (!is_array($acl)) {
            throw new BCS_Exception("Invalid acl array");
        }
        foreach ($acl['statements'] as $key => $statement) {
            // user resource action effect must in statement
            if (!isset($statement['user']) || !isset($statement['resource']) || !isset($statement['action']) || !isset($statement['effect'])) {
                throw new BCS_Exception('Param miss: format acl error, please check your param!');
            }
            if (!is_array($statement['user']) || !is_array($statement['resource'])) {
                throw new BCS_Exception('Param error: user or resource must be array, please check your param!');
            }
            if (!is_array($statement['action']) || !count(array_diff($statement['action'], self::$ACL_ACTIONS)) == 0) {
                throw new BCS_Exception('Param error: action, please check your param!');
            }
            if (!in_array($statement['effect'], self::$ACL_EFFECTS)) {
                throw new BCS_Exception('Param error: effect, please check your param!');
            }
            if (isset($statement['time'])) {
                if (!is_array($statement['time'])) {
                    throw new BCS_Exception('Param error: time, please check your param!');
                }
            }
        }

        return self::arrayToJson($acl);
    }

    /**
     * 构造url
     * @param array $opt
     * @return boolean|string
     */
    private function formatUrl($opt)
    {
        $sign = $this->formatSignature($opt);
        if (false === $sign) {
            trigger_error("Format signature failed, please check!");
            return false;
        }
        $opt['sign'] = $sign;
        $url         = "";
        $url .= $this->use_ssl ? 'https://' : 'http://';
        $url .= $this->hostname;
        $url .= '/' . $opt[self::BUCKET];
        if (isset($opt[self::OBJECT]) && '/' !== $opt[self::OBJECT]) {
            $url .= "/" . rawurlencode($opt[self::OBJECT]);
        }
        $url .= '?' . $sign;
        if (isset($opt[self::QUERY_STRING])) {
            foreach ($opt[self::QUERY_STRING] as $key => $value) {
                $url .= '&' . $key . '=' . $value;
            }
        }
        return $url;
    }

    /**
     * 将url中 '//' 替换为  '/'
     * @param $url
     * @return string
     */
    public static function trimUrl($url)
    {
        $result = str_replace("//", "/", $url);
        while ($result !== $url) {
            $url    = $result;
            $result = str_replace("//", "/", $url);
        }
        return $result;
    }

    /**
     * 获取传入目录的文件列表
     * @param string $dir 文件目录
     * @return array 文件树
     */
    public static function getFiletree($dir, $file_prefix = "/*")
    {
        $tree = array();
        foreach (glob($dir . $file_prefix) as $single) {
            if (is_dir($single)) {
                $tree = array_merge($tree, self::getFiletree($single));
            } else {
                $tree[] = $single;
            }
        }
        return $tree;
    }

    /**
     * 内置的日志函数，可以根据用户传入的log函数，进行日志输出
     * @param string $log
     * @param array $opt
     */
    public function log($log, $opt)
    {
        if (isset($opt[self::IMPORT_BCS_LOG_METHOD]) && function_exists($opt[self::IMPORT_BCS_LOG_METHOD])) {
            $opt[self::IMPORT_BCS_LOG_METHOD]($log);
        } else {
            trigger_error($log);
        }
    }

    /**
     * make sure $opt is an array
     * @param $opt
     */
    private function assertParameterArray($opt)
    {
        if (!is_array($opt)) {
            throw new BCS_Exception('Parameter must be array, please check!', -1);
        }
    }
}