WispX
138 lines
2.7 KiB
PHP
138 lines
2.7 KiB
PHP
<?php
|
||
/**
|
||
* User: Wisp X
|
||
* Date: 2018/9/29
|
||
* Time: 下午1:50
|
||
* Link: https://github.com/wisp-x
|
||
*/
|
||
|
||
namespace strategy\driver;
|
||
|
||
use Qiniu\Auth;
|
||
use Qiniu\Config;
|
||
use Qiniu\Storage\BucketManager;
|
||
use Qiniu\Storage\UploadManager;
|
||
use strategy\Driver;
|
||
|
||
/**
|
||
* 七牛云对象储存驱动
|
||
*
|
||
* Class Qiniu
|
||
* @package strategy\driver
|
||
*/
|
||
class Qiniu implements Driver
|
||
{
|
||
/**
|
||
* 当前储存策略参数
|
||
*
|
||
* @var array
|
||
*/
|
||
protected $options = [];
|
||
|
||
/**
|
||
* 错误信息
|
||
*
|
||
* @var null
|
||
*/
|
||
protected $error = null;
|
||
|
||
/**
|
||
* UploadManager实例
|
||
*
|
||
* @var null
|
||
*/
|
||
protected $uploadMgr = null;
|
||
|
||
/**
|
||
* BucketManager实例
|
||
*
|
||
* @var null
|
||
*/
|
||
protected $bucketMgr = null;
|
||
|
||
/**
|
||
* 上传凭证
|
||
*
|
||
* @var null
|
||
*/
|
||
protected $uploadToken = null;
|
||
|
||
/**
|
||
* Qiniu constructor.
|
||
*
|
||
* @param array $options
|
||
*/
|
||
public function __construct($options = [])
|
||
{
|
||
$this->options = $options;
|
||
try {
|
||
$auth = new Auth($this->options['qiniu_access_key'], $this->options['qiniu_secret_key']);
|
||
$this->uploadToken = $auth->uploadToken($this->options['qiniu_bucket']);
|
||
$config = new Config();
|
||
$this->uploadMgr = new UploadManager();
|
||
$this->bucketMgr = new BucketManager($auth, $config);
|
||
} catch (\Exception $e) {
|
||
$this->error = $e->getMessage();
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 创建一个文件
|
||
*
|
||
* @param $pathname
|
||
* @param $file
|
||
*
|
||
* @return bool
|
||
* @throws \Exception
|
||
*/
|
||
public function create($pathname, $file)
|
||
{
|
||
list($ret, $err) = $this->uploadMgr->putFile($this->uploadToken, $pathname, $file);
|
||
if (null !== $err) {
|
||
$this->error = $err;
|
||
return false;
|
||
}
|
||
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
* 删除文件
|
||
*
|
||
* @param $pathname
|
||
*
|
||
* @return bool
|
||
*/
|
||
public function delete($pathname)
|
||
{
|
||
$err = $this->bucketMgr->delete($this->options['qiniu_bucket'], $pathname);
|
||
if ($err) {
|
||
$this->error = $err;
|
||
return false;
|
||
}
|
||
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
* 删除多个文件
|
||
*
|
||
* @param array $list
|
||
* @return bool|mixed
|
||
*/
|
||
public function deletes(array $list)
|
||
{
|
||
$ops = $this->bucketMgr->buildBatchDelete($this->options['qiniu_bucket'], $list);
|
||
list($ret, $err) = $this->bucketMgr->batch($ops);
|
||
if ($err) {
|
||
$this->error = $err;
|
||
return false;
|
||
}
|
||
return true;
|
||
}
|
||
|
||
public function getError()
|
||
{
|
||
return 'Qiniu：' . $this->error;
|
||
}
|
||
} |