auth = $auth; if ($config == null) { $this->config = new Config(); } else { $this->config = $config; } $this->proxy = new Proxy($proxy, $proxy_auth, $proxy_user_password); } /** * 对资源文件进行异步持久化处理 * @param string $bucket 资源所在空间 * @param string $key 待处理的源文件 * @param string $fops string|array 待处理的pfop操作,多个pfop操作以array的形式传入。 * eg. avthumb/mp3/ab/192k, vframe/jpg/offset/7/w/480/h/360 * @param string $pipeline 资源处理队列 * @param string $notify_url 处理结果通知地址 * @param bool $force 是否强制执行一次新的指令 * * * @return array 返回持久化处理的persistentId, 和返回的错误。 * * @link http://developer.qiniu.com/docs/v6/api/reference/fop/ */ public function execute($bucket, $key, $fops, $pipeline = null, $notify_url = null, $force = false) { if (is_array($fops)) { $fops = implode(';', $fops); } $params = array('bucket' => $bucket, 'key' => $key, 'fops' => $fops); \Qiniu\setWithoutEmpty($params, 'pipeline', $pipeline); \Qiniu\setWithoutEmpty($params, 'notifyURL', $notify_url); if ($force) { $params['force'] = 1; } $data = http_build_query($params); $scheme = "http://"; if ($this->config->useHTTPS === true) { $scheme = "https://"; } $url = $scheme . Config::API_HOST . '/pfop/'; $headers = $this->auth->authorization($url, $data, 'application/x-www-form-urlencoded'); $headers['Content-Type'] = 'application/x-www-form-urlencoded'; $response = Client::post($url, $data, $headers, $this->proxy->makeReqOpt()); if (!$response->ok()) { return array(null, new Error($url, $response)); } $r = $response->json(); $id = $r['persistentId']; return array($id, null); } public function status($id) { $scheme = "http://"; if ($this->config->useHTTPS === true) { $scheme = "https://"; } $url = $scheme . Config::API_HOST . "/status/get/prefop?id=$id"; $response = Client::get($url, array(), $this->proxy->makeReqOpt()); if (!$response->ok()) { return array(null, new Error($url, $response)); } return array($response->json(), null); } }