510 lines
16 KiB
PHP
510 lines
16 KiB
PHP
<?php
|
|
|
|
namespace crmeb\services\upload\storage;
|
|
|
|
use crmeb\exceptions\AdminException;
|
|
use crmeb\services\upload\extend\obs\Client as TyClient;
|
|
use crmeb\services\upload\BaseUpload;
|
|
use DateTimeInterface;
|
|
use GuzzleHttp\Psr7\Utils;
|
|
use think\exception\ValidateException;
|
|
|
|
class Ctoss extends BaseUpload
|
|
{
|
|
/**
|
|
* accessKey
|
|
* @var mixed
|
|
*/
|
|
protected $accessKey;
|
|
|
|
/**
|
|
* secretKey
|
|
* @var mixed
|
|
*/
|
|
protected $secretKey;
|
|
|
|
/**
|
|
* 句柄
|
|
* @var TyClient
|
|
*/
|
|
protected $handle;
|
|
|
|
/**
|
|
* 空间域名 Domain
|
|
* @var mixed
|
|
*/
|
|
protected $uploadUrl;
|
|
|
|
/**
|
|
* 存储空间名称 公开空间
|
|
* @var mixed
|
|
*/
|
|
protected $storageName;
|
|
|
|
/**
|
|
* COS使用 所属地域
|
|
* @var mixed|null
|
|
*/
|
|
protected $storageRegion;
|
|
|
|
|
|
/**
|
|
* 水印位置
|
|
* @var string[]
|
|
*/
|
|
protected $position = [
|
|
'1' => 'tl',//：左上
|
|
'2' => 'top',//：中上
|
|
'3' => 'tr',//：右上
|
|
'4' => 'left',//：左中
|
|
'5' => 'center',//：中部
|
|
'6' => 'right',//：右中
|
|
'7' => 'bl',//：左下
|
|
'8' => 'bottom',//：中下
|
|
'9' => 'br',//：右下
|
|
];
|
|
|
|
/**
|
|
* @var string
|
|
*/
|
|
protected $cdn;
|
|
|
|
public function move(string $file = 'file', bool $isStream = false, string $fileContent = null)
|
|
{
|
|
if (!$isStream) {
|
|
$fileHandle = app()->request->file($file);
|
|
if (!$fileHandle) {
|
|
return $this->setError('上传的文件不存在');
|
|
}
|
|
if ($this->validate) {
|
|
try {
|
|
validate([$file => $this->validate])->check([$fileHandle]);
|
|
} catch (ValidateException $e) {
|
|
return $this->setError($e->getMessage());
|
|
}
|
|
}
|
|
$key = $this->saveFileName($fileHandle->getRealPath(), $fileHandle->getOriginalExtension());
|
|
|
|
$body = fopen($fileHandle->getRealPath(), 'rb');
|
|
$body = (string)Utils::streamFor($body);
|
|
} else {
|
|
$key = $file;
|
|
$body = $fileContent;
|
|
}
|
|
$key = $this->getUploadPath($key);
|
|
|
|
try {
|
|
$uploadInfo = $this->app()->putObject($key, $body, 'application/octet-stream');
|
|
$this->fileInfo->uploadInfo = $uploadInfo;
|
|
$this->fileInfo->realName = $fileHandle->getOriginalName();
|
|
$this->fileInfo->filePath = ($this->cdn ?: $this->uploadUrl) . '/' . $key;
|
|
$this->fileInfo->fileName = $key;
|
|
$this->fileInfo->filePathWater = $this->water($this->fileInfo->filePath);
|
|
$this->authThumb && $this->thumb($this->fileInfo->filePath);
|
|
return $this->fileInfo;
|
|
} catch (\Throwable $e) {
|
|
return $this->setError($e->getMessage());
|
|
}
|
|
}
|
|
|
|
public function stream($fileContent, string $key = null)
|
|
{
|
|
if (!$key) {
|
|
$key = $this->saveFileName();
|
|
}
|
|
return $this->move($key, true, $fileContent);
|
|
}
|
|
|
|
public function delete(string $filePath)
|
|
{
|
|
try {
|
|
return $this->app()->deleteObject($filePath);
|
|
} catch (\Exception $e) {
|
|
return $this->setError($e->getMessage());
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 初始化
|
|
* @param array $config
|
|
* @return mixed|void
|
|
*/
|
|
public function initialize(array $config)
|
|
{
|
|
parent::initialize($config);
|
|
$this->accessKey = $config['accessKey'] ?? null;
|
|
$this->secretKey = $config['secretKey'] ?? null;
|
|
$this->uploadUrl = $this->checkUploadUrl($config['uploadUrl'] ?? '');
|
|
$this->storageName = $config['storageName'] ?? null;
|
|
$this->storageRegion = $config['storageRegion'] ?? null;
|
|
$this->cdn = $config['cdn'] ?? null;
|
|
$this->waterConfig['watermark_text_font'] = 'simfang仿宋.ttf';
|
|
}
|
|
|
|
/**
|
|
* 实例化cos
|
|
* @return TyClient
|
|
*/
|
|
protected function app()
|
|
{
|
|
$this->handle = new TyClient([
|
|
'accessKey' => $this->accessKey,
|
|
'secretKey' => $this->secretKey,
|
|
'region' => $this->storageRegion ?: 'cn-qhxn1',
|
|
'bucket' => $this->storageName,
|
|
'uploadUrl' => $this->uploadUrl,
|
|
'type' => 'ty'
|
|
]);
|
|
return $this->handle;
|
|
}
|
|
|
|
public function listbuckets(string $region = null, bool $line = false, bool $shared = false)
|
|
{
|
|
try {
|
|
$res = $this->app()->listBuckets();
|
|
return $res['Buckets']['Bucket'] ?? [];
|
|
} catch (\Throwable $e) {
|
|
return [];
|
|
}
|
|
}
|
|
|
|
public function createBucket(string $name, string $region, string $acl = TyClient::DEFAULT_OBS_ACL)
|
|
{
|
|
$regionData = $this->getRegion();
|
|
$regionData = array_column($regionData, 'value');
|
|
if (!in_array($region, $regionData)) {
|
|
return $this->setError('COS:无效的区域!');
|
|
}
|
|
$this->storageRegion = $region;
|
|
$app = $this->app();
|
|
//创建桶
|
|
try {
|
|
$app->createBucket($name, $region, $acl);
|
|
$data = [
|
|
'Statement' => [
|
|
'Sid' => '公共读' . $name,
|
|
'Effect' => 'Allow',
|
|
'Principal' => [
|
|
'ID' => ['*']
|
|
],
|
|
'Action' => ['HeadBucket', 'GetBucketLocation', 'ListBucketVersions', 'GetObject', 'RestoreObject', 'GetObjectVersion'],
|
|
'Resource' => [$name, $name . '/*']
|
|
]
|
|
];
|
|
|
|
$app->putPolicy($name, $region, $data);
|
|
} catch (\Throwable $e) {
|
|
return $this->setError('COS:' . $e->getMessage());
|
|
}
|
|
return true;
|
|
}
|
|
|
|
public function getRegion()
|
|
{
|
|
return [
|
|
[
|
|
'value' => 'cn-gz1',
|
|
'label' => '贵州'
|
|
],
|
|
[
|
|
'value' => 'cn-fz1',
|
|
'label' => '福州'
|
|
],
|
|
[
|
|
'value' => 'cn-hz1',
|
|
'label' => '杭州'
|
|
],
|
|
[
|
|
'value' => 'cn-sz1',
|
|
'label' => '深圳'
|
|
],
|
|
[
|
|
'value' => 'cn-gdgz1',
|
|
'label' => '广州'
|
|
],
|
|
[
|
|
'value' => 'cn-jssz1',
|
|
'label' => '苏州'
|
|
],
|
|
[
|
|
'value' => 'cn-sh1',
|
|
'label' => '上海'
|
|
],
|
|
[
|
|
'value' => 'cn-ahwh1',
|
|
'label' => '芜湖'
|
|
],
|
|
[
|
|
'value' => 'cn-bj1',
|
|
'label' => '北京'
|
|
],
|
|
[
|
|
'value' => 'cn-sccd1',
|
|
'label' => '成都'
|
|
],
|
|
[
|
|
'value' => 'cn-hazz1',
|
|
'label' => '郑州'
|
|
],
|
|
[
|
|
'value' => 'cn-hncs1',
|
|
'label' => '长沙'
|
|
],
|
|
[
|
|
'value' => 'cn-gxnn1',
|
|
'label' => '南宁'
|
|
],
|
|
[
|
|
'value' => 'cn-jxnc1',
|
|
'label' => '南昌'
|
|
],
|
|
[
|
|
'value' => 'cn-sdqd1',
|
|
'label' => '青岛'
|
|
],
|
|
[
|
|
'value' => 'cn-snxy1',
|
|
'label' => '咸阳'
|
|
],
|
|
[
|
|
'value' => 'cn-xjcj1',
|
|
'label' => '新疆'
|
|
],
|
|
[
|
|
'value' => 'cn-ynkm1',
|
|
'label' => '昆明'
|
|
],
|
|
[
|
|
'value' => 'cn-hihk1',
|
|
'label' => '海口'
|
|
],
|
|
[
|
|
'value' => 'cn-hbwh1',
|
|
'label' => '武汉'
|
|
],
|
|
[
|
|
'value' => 'cn-cq1',
|
|
'label' => '重庆'
|
|
],
|
|
[
|
|
'value' => 'cn-qhxn1',
|
|
'label' => '西宁'
|
|
],
|
|
[
|
|
'value' => 'cn-gslz1',
|
|
'label' => '兰州'
|
|
],
|
|
[
|
|
'value' => 'cn-nxyc1',
|
|
'label' => '银川'
|
|
],
|
|
[
|
|
'value' => 'cn-sxty1',
|
|
'label' => '太原'
|
|
],
|
|
[
|
|
'value' => 'cn-hesjz1',
|
|
'label' => '石家庄'
|
|
],
|
|
[
|
|
'value' => 'cn-tj1',
|
|
'label' => '天津'
|
|
],
|
|
[
|
|
'value' => 'cn-jlcc1',
|
|
'label' => '长春'
|
|
],
|
|
[
|
|
'value' => 'cn-hlhrb1',
|
|
'label' => '哈尔滨'
|
|
],
|
|
[
|
|
'value' => 'cn-nmhh1',
|
|
'label' => '内蒙古'
|
|
],
|
|
[
|
|
'value' => 'cn-lnsy1',
|
|
'label' => '沈阳'
|
|
],
|
|
[
|
|
'value' => 'cn-north1',
|
|
'label' => '华北'
|
|
]
|
|
];
|
|
}
|
|
|
|
public function deleteBucket(string $name, string $region = '')
|
|
{
|
|
try {
|
|
$this->app()->deleteBucket($name, $region);
|
|
return true;
|
|
} catch (\Throwable $e) {
|
|
return $this->setError($e->getMessage());
|
|
}
|
|
}
|
|
|
|
public function getDomian($name, $region)
|
|
{
|
|
try {
|
|
$res = $this->app()->getBucketDomain($name, $region);
|
|
if ($res) {
|
|
$domainRules = $res->toArray()['ListBucketCustomDomainsResult'];
|
|
return array_column($domainRules, 'DomainName');
|
|
} else {
|
|
return [];
|
|
}
|
|
|
|
} catch (\Throwable $e) {
|
|
}
|
|
return [];
|
|
}
|
|
|
|
public function bindDomian(string $name, string $domain, string $region = null)
|
|
{
|
|
$parseDomin = parse_url($domain);
|
|
try {
|
|
$this->app()->putBucketDomain($name, $region, [
|
|
'domainname' => $parseDomin['host'],
|
|
]);
|
|
return true;
|
|
} catch (\Throwable $e) {
|
|
return $this->setError($e->getMessage());
|
|
}
|
|
}
|
|
|
|
public function setBucketCors(string $name, string $region)
|
|
{
|
|
try {
|
|
$this->app()->putBucketCors($name, $region, [
|
|
'AllowedHeader' => ['*'],
|
|
'AllowedMethod' => ['PUT', 'GET', 'POST', 'DELETE', 'HEAD'],
|
|
'AllowedOrigin' => ['*'],
|
|
'ExposeHeader' => ['ETag'],
|
|
'MaxAgeSeconds' => 0
|
|
]);
|
|
return true;
|
|
} catch (\Throwable $e) {
|
|
return $this->setError($e->getMessage());
|
|
}
|
|
}
|
|
|
|
/**
|
|
* @param string $callbackUrl
|
|
* @param string $dir
|
|
* @return array
|
|
* @throws \Exception
|
|
* @author 吴汐
|
|
* @email 442384644@qq.com
|
|
* @date 2023/06/19
|
|
*/
|
|
public function getTempKeys($callbackUrl = '', $dir = '')
|
|
{
|
|
// TODO: Implement getTempKeys() method.
|
|
$base64CallbackBody = base64_encode(json_encode([
|
|
'callbackUrl' => $callbackUrl,
|
|
'callbackBody' => 'filename=${object}&size=${size}&mimeType=${mimeType}&height=${imageInfo.height}&width=${imageInfo.width}',
|
|
'callbackBodyType' => "application/x-www-form-urlencoded"
|
|
]));
|
|
|
|
$policy = json_encode([
|
|
'expiration' => $this->gmtIso8601(time() + 300),
|
|
'conditions' =>
|
|
[
|
|
[0 => 'content-length-range', 1 => 0, 2 => 1048576000],
|
|
['bucket' => $this->storageName],
|
|
[0 => 'starts-with', 1 => '$key', 2 => $dir],
|
|
]
|
|
]);
|
|
$base64Policy = base64_encode($policy);
|
|
$signature = base64_encode(hash_hmac('sha1', $base64Policy, $this->secretKey, true));
|
|
return [
|
|
'accessid' => $this->accessKey,
|
|
'host' => $this->uploadUrl,
|
|
'policy' => $base64Policy,
|
|
'signature' => $signature,
|
|
'expire' => time() + 30,
|
|
'callback' => $base64CallbackBody,
|
|
'cdn' => $this->cdn,
|
|
'type' => 'OBS'
|
|
];
|
|
}
|
|
|
|
/**
|
|
* 获取ISO时间格式
|
|
* @param $time
|
|
* @return string
|
|
* @throws \Exception
|
|
*/
|
|
protected function gmtIso8601($time): string
|
|
{
|
|
$dtStr = date("c", $time);
|
|
$myDateTime = new \DateTime($dtStr);
|
|
$expiration = $myDateTime->format(DateTimeInterface::ISO8601);
|
|
$pos = strpos($expiration, '+');
|
|
$expiration = substr($expiration, 0, $pos);
|
|
return $expiration . "Z";
|
|
}
|
|
|
|
public function thumb(string $filePath = '', string $fileName = '', string $type = 'all')
|
|
{
|
|
$filePath = $this->getFilePath($filePath);
|
|
$data = ['big' => $filePath, 'mid' => $filePath, 'small' => $filePath];
|
|
$this->fileInfo->filePathBig = $this->fileInfo->filePathMid = $this->fileInfo->filePathSmall = $this->fileInfo->filePathWater = $filePath;
|
|
if ($filePath) {
|
|
$config = $this->thumbConfig;
|
|
foreach ($this->thumb as $v) {
|
|
if ($type == 'all' || $type == $v) {
|
|
$height = 'thumb_' . $v . '_height';
|
|
$width = 'thumb_' . $v . '_width';
|
|
$key = 'filePath' . ucfirst($v);
|
|
if (isset($config[$height]) && isset($config[$width]) && $config[$height] && $config[$width]) {
|
|
$this->fileInfo->$key = $filePath . '?x-oss-process=image/resize,h_' . $config[$height] . ',w_' . $config[$width];
|
|
$this->fileInfo->$key = $this->water($this->fileInfo->$key);
|
|
$data[$v] = $this->fileInfo->$key;
|
|
} else {
|
|
$this->fileInfo->$key = $this->water($this->fileInfo->$key);
|
|
$data[$v] = $this->fileInfo->$key;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
return $data;
|
|
}
|
|
|
|
|
|
/**
|
|
* 水印
|
|
* @param string $filePath
|
|
* @return mixed|string
|
|
*/
|
|
public function water(string $filePath = '')
|
|
{
|
|
$filePath = $this->getFilePath($filePath);
|
|
$waterConfig = $this->waterConfig;
|
|
$waterPath = $filePath;
|
|
if ($waterConfig['image_watermark_status'] && $filePath) {
|
|
if (strpos($filePath, '?x-oss-process') === false) {
|
|
$filePath .= '&x-oss-process=image';
|
|
}
|
|
switch ($waterConfig['watermark_type']) {
|
|
case 1://图片
|
|
if (!$waterConfig['watermark_image']) {
|
|
throw new AdminException(400722);
|
|
}
|
|
$waterFileName = substr(parse_url($waterConfig['watermark_image'],PHP_URL_PATH), 1);
|
|
$waterPath = $filePath .= '/watermark,image_' . base64_encode($waterFileName) . ',t_' . $waterConfig['watermark_opacity'] . ',g_' . ($this->position[$waterConfig['watermark_position']] ?? 'nw') . ',x_' . $waterConfig['watermark_x'] . ',y_' . $waterConfig['watermark_y'];
|
|
break;
|
|
case 2://文字
|
|
if (!$waterConfig['watermark_text']) {
|
|
throw new AdminException(400723);
|
|
}
|
|
$waterConfig['watermark_text_color'] = str_replace('#', '', $waterConfig['watermark_text_color']);
|
|
$waterPath = $filePath .= '/watermark,text_' . base64_encode($waterConfig['watermark_text']) . ',color_' . $waterConfig['watermark_text_color'] . ',size_' . $waterConfig['watermark_text_size'] . ',g_' . ($this->position[$waterConfig['watermark_position']] ?? 'nw') . ',x_' . $waterConfig['watermark_x'] . ',y_' . $waterConfig['watermark_y'];
|
|
break;
|
|
}
|
|
}
|
|
return $waterPath;
|
|
}
|
|
|
|
}
|