95 lines
2.9 KiB
PHP
95 lines
2.9 KiB
PHP
|
<?php
|
|||
|
|
|
|||
|
|
namespace Qiniu\Processing;
|
|||
|
|
|
|||
|
|
use Qiniu\Config;
|
|||
|
|
use Qiniu\Http\Error;
|
|||
|
|
use Qiniu\Http\Client;
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 持久化处理类,该类用于主动触发异步持久化操作.
|
|||
|
|
*
|
|||
|
|
* @link http://developer.qiniu.com/docs/v6/api/reference/fop/pfop/pfop.html
|
|||
|
|
*/
|
|||
|
|
final class PersistentFop
|
|||
|
|
{
|
|||
|
|
/**
|
|||
|
|
* @var 账号管理密钥对，Auth对象
|
|||
|
|
*/
|
|||
|
|
private $auth;
|
|||
|
|
|
|||
|
|
/*
|
|||
|
|
* @var 配置对象，Config 对象
|
|||
|
|
* */
|
|||
|
|
private $config;
|
|||
|
|
|
|||
|
|
|
|||
|
|
public function __construct($auth, $config = null)
|
|||
|
|
{
|
|||
|
|
$this->auth = $auth;
|
|||
|
|
if ($config == null) {
|
|||
|
|
$this->config = new Config();
|
|||
|
|
} else {
|
|||
|
|
$this->config = $config;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 对资源文件进行异步持久化处理
|
|||
|
|
* @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);
|
|||
|
|
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);
|
|||
|
|
if (!$response->ok()) {
|
|||
|
|
return array(null, new Error($url, $response));
|
|||
|
|
}
|
|||
|
|
return array($response->json(), null);
|
|||
|
|
}
|
|||
|
|
}
|