130 lines
4.0 KiB
PHP
130 lines
4.0 KiB
PHP
<?php
|
|
|
|
namespace core\upload\storage;
|
|
|
|
|
|
use core\exception\handler\UploadException;
|
|
use core\upload\BaseUpload;
|
|
use Qcloud\Cos\Client;
|
|
|
|
/**
|
|
*
|
|
* Cos 文件上传
|
|
* @author Mr.April
|
|
* @since 1.0
|
|
*/
|
|
class Cos extends BaseUpload
|
|
{
|
|
protected ?Client $instance = null;
|
|
|
|
/**
|
|
* 获取实例
|
|
* @return \Qcloud\Cos\Client|null
|
|
*/
|
|
public function getInstance(): ?Client
|
|
{
|
|
if (is_null($this->instance)) {
|
|
$this->instance = new Client([
|
|
'region' => $this->config['region'] ?? 'ap-shanghai',
|
|
'schema' => 'https',
|
|
'credentials' => [
|
|
'secretId' => $this->config['secretId'],
|
|
'secretKey' => $this->config['secretKey'],
|
|
],
|
|
]);
|
|
}
|
|
return $this->instance;
|
|
}
|
|
|
|
/**
|
|
* 文件上传
|
|
* @param array $options
|
|
*
|
|
* @return array
|
|
*/
|
|
public function uploadFile(array $options = []): array
|
|
{
|
|
$result = [];
|
|
$dirname = $this->config['dirname'] ?? '';
|
|
$domain = trim($this->config['domain']);
|
|
|
|
foreach ($this->files as $key => $file) {
|
|
$uniqueId = $this->getUniqueId($file->getPathname());
|
|
$saveName = $uniqueId . '.' . $file->getUploadExtension();
|
|
$object = !empty($dirname) ? $dirname . $this->dirSeparator . $saveName : $saveName;
|
|
|
|
$this->getInstance()->putObject([
|
|
'Bucket' => $this->config['bucket'],
|
|
'Key' => $object,
|
|
'Body' => fopen($file->getPathname(), 'rb'),
|
|
]);
|
|
|
|
$result[] = [
|
|
'key' => $key,
|
|
'origin_name' => $file->getUploadName(),
|
|
'save_name' => $saveName,
|
|
'save_path' => $object,
|
|
'url' => $domain . $this->dirSeparator . $object,
|
|
'unique_id' => $uniqueId,
|
|
'size' => $file->getSize(),
|
|
'mime_type' => $file->getUploadMimeType(),
|
|
'extension' => $file->getUploadExtension(),
|
|
'base_path' =>$this->dirSeparator . $object
|
|
];
|
|
}
|
|
|
|
return $result;
|
|
}
|
|
|
|
public function uploadServerFile(string $filePath): array
|
|
{
|
|
$file = new \SplFileInfo($filePath);
|
|
if (!$file->isFile()) {
|
|
throw new UploadException('请检查上传文件是否是一个有效的文件，文件不存在' . $filePath);
|
|
}
|
|
|
|
$uniqueId = $this->getUniqueId($file->getPathname());
|
|
$dirname = $this->config['dirname'] ?? '';
|
|
$object = !empty($dirname) ? $dirname . $this->dirSeparator . $uniqueId . '.' . $file->getExtension() : $uniqueId . '.' . $file->getExtension();
|
|
|
|
$this->getInstance()->putObject([
|
|
'Bucket' => $this->config['bucket'],
|
|
'Key' => $object,
|
|
'Body' => fopen($file->getPathname(), 'rb'),
|
|
]);
|
|
|
|
return [
|
|
'origin_name' => $file->getRealPath(),
|
|
'save_path' => $object,
|
|
'url' => $this->config['domain'] . $this->dirSeparator . $object,
|
|
'unique_id' => $uniqueId,
|
|
'size' => $file->getSize(),
|
|
'extension' => $file->getExtension(),
|
|
];
|
|
}
|
|
|
|
public function uploadBase64(string $base64, string $extension = 'png'): array
|
|
{
|
|
$base64 = explode(',', $base64);
|
|
$uniqueId = date('YmdHis') . uniqid();
|
|
$object = !empty($this->config['dirname']) ? $this->config['dirname'] . $this->dirSeparator . $uniqueId . '.' . $extension : $uniqueId . '.' . $extension;
|
|
|
|
$this->getInstance()->putObject([
|
|
'Bucket' => $this->config['bucket'],
|
|
'Key' => $object,
|
|
'Body' => base64_decode($base64[1]),
|
|
]);
|
|
|
|
$fileSize = strlen(base64_decode($base64[1]));
|
|
|
|
return [
|
|
'save_path' => $object,
|
|
'url' => $this->config['domain'] . $this->dirSeparator . $object,
|
|
'unique_id' => $uniqueId,
|
|
'size' => $fileSize,
|
|
'extension' => $extension,
|
|
];
|
|
}
|
|
}
|
|
|