|
|
<?php
|
|
|
namespace Qiniu\Processing;
|
|
|
|
|
|
use Qiniu\Config;
|
|
|
use Qiniu\Http\Client;
|
|
|
use Qiniu\Http\Error;
|
|
|
use Qiniu\Processing\Operation;
|
|
|
|
|
|
/**
|
|
|
* 持久化处理类,该类用于主动触发异步持久化操作.
|
|
|
*
|
|
|
* @link http://developer.qiniu.com/docs/v6/api/reference/fop/pfop/pfop.html
|
|
|
*/
|
|
|
final class PersistentFop
|
|
|
{
|
|
|
/**
|
|
|
* @var 账号管理密钥对，Auth对象
|
|
|
*/
|
|
|
private $auth;
|
|
|
|
|
|
/**
|
|
|
* @var 操作资源所在空间
|
|
|
*/
|
|
|
private $bucket;
|
|
|
|
|
|
/**
|
|
|
* @var 多媒体处理队列，详见 https://portal.qiniu.com/mps/pipeline
|
|
|
*/
|
|
|
private $pipeline;
|
|
|
|
|
|
/**
|
|
|
* @var 持久化处理结果通知URL
|
|
|
*/
|
|
|
private $notify_url;
|
|
|
|
|
|
/**
|
|
|
* @var boolean 是否强制覆盖已有的重名文件
|
|
|
*/
|
|
|
private $force;
|
|
|
|
|
|
|
|
|
public function __construct($auth, $bucket, $pipeline = null, $notify_url = null, $force = false)
|
|
|
{
|
|
|
$this->auth = $auth;
|
|
|
$this->bucket = $bucket;
|
|
|
$this->pipeline = $pipeline;
|
|
|
$this->notify_url = $notify_url;
|
|
|
$this->force = $force;
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 对资源文件进行异步持久化处理
|
|
|
*
|
|
|
* @param $key 待处理的源文件
|
|
|
* @param $fops string|array 待处理的pfop操作，多个pfop操作以array的形式传入。
|
|
|
* eg. avthumb/mp3/ab/192k, vframe/jpg/offset/7/w/480/h/360
|
|
|
*
|
|
|
* @return array 返回持久化处理的persistentId, 和返回的错误。
|
|
|
*
|
|
|
* @link http://developer.qiniu.com/docs/v6/api/reference/fop/
|
|
|
*/
|
|
|
public function execute($key, $fops)
|
|
|
{
|
|
|
if (is_array($fops)) {
|
|
|
$fops = implode(';', $fops);
|
|
|
}
|
|
|
$params = array('bucket' => $this->bucket, 'key' => $key, 'fops' => $fops);
|
|
|
\Qiniu\setWithoutEmpty($params, 'pipeline', $this->pipeline);
|
|
|
\Qiniu\setWithoutEmpty($params, 'notifyURL', $this->notify_url);
|
|
|
if ($this->force) {
|
|
|
$params['force'] = 1;
|
|
|
}
|
|
|
$data = http_build_query($params);
|
|
|
$url = 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);
|
|
|
if (!$response->ok()) {
|
|
|
return array(null, new Error($url, $response));
|
|
|
}
|
|
|
$r = $response->json();
|
|
|
$id = $r['persistentId'];
|
|
|
return array($id, null);
|
|
|
}
|
|
|
|
|
|
public static function status($id)
|
|
|
{
|
|
|
$url = Config::API_HOST . "/status/get/prefop?id=$id";
|
|
|
$response = Client::get($url);
|
|
|
if (!$response->ok()) {
|
|
|
return array(null, new Error($url, $response));
|
|
|
}
|
|
|
return array($response->json(), null);
|
|
|
}
|
|
|
}
|
