refactor: 七牛云上传
This commit is contained in:
295
extend/filesystem/adapter/QiniuAdapter.php
Normal file
295
extend/filesystem/adapter/QiniuAdapter.php
Normal file
@@ -0,0 +1,295 @@
|
||||
<?php
|
||||
namespace filesystem\adapter;
|
||||
|
||||
use League\Flysystem\Config;
|
||||
use League\Flysystem\FilesystemAdapter;
|
||||
use League\Flysystem\FileAttributes;
|
||||
use League\Flysystem\UnableToCopyFile;
|
||||
use League\Flysystem\UnableToDeleteFile;
|
||||
use League\Flysystem\UnableToMoveFile;
|
||||
use League\Flysystem\UnableToReadFile;
|
||||
use League\Flysystem\UnableToRetrieveMetadata;
|
||||
use League\Flysystem\UnableToSetVisibility;
|
||||
use League\Flysystem\UnableToWriteFile;
|
||||
use Qiniu\Auth;
|
||||
use Qiniu\Storage\UploadManager;
|
||||
use Qiniu\Storage\BucketManager;
|
||||
|
||||
class QiniuAdapter implements FilesystemAdapter
|
||||
{
|
||||
protected ?Auth $authMgr;
|
||||
protected ?UploadManager $uploadMgr;
|
||||
protected ?BucketManager $bucketMgr;
|
||||
|
||||
public function __construct(protected string $access_key, protected string $secret_key, protected string $bucket, protected string $base_url, protected string $path)
|
||||
{
|
||||
}
|
||||
|
||||
private function getAuthMgr(): Auth
|
||||
{
|
||||
return $this->authMgr ?? new Auth($this->access_key, $this->secret_key);
|
||||
}
|
||||
|
||||
private function getUploadMgr(): UploadManager
|
||||
{
|
||||
return $this->uploadMgr ?? new UploadManager();
|
||||
}
|
||||
|
||||
private function getBucketMgr(): BucketManager
|
||||
{
|
||||
return $this->bucketMgr ?? new BucketManager($this->authMgr);
|
||||
}
|
||||
|
||||
private function getPathPrefix(): string
|
||||
{
|
||||
$path = ltrim($this->path, '\\/');
|
||||
if ($path !== '' && !str_ends_with($path, '/')) {
|
||||
$path = $path . '/';
|
||||
}
|
||||
|
||||
return $path;
|
||||
}
|
||||
|
||||
private function applyPathPrefix(string $path): string
|
||||
{
|
||||
$path = ltrim($path, '\\/');
|
||||
return $this->getPathPrefix() . $path;
|
||||
}
|
||||
|
||||
private static function parseUrl($url): array
|
||||
{
|
||||
$result = [];
|
||||
|
||||
// Build arrays of values we need to decode before parsing
|
||||
$entities = [
|
||||
'%21',
|
||||
'%2A',
|
||||
'%27',
|
||||
'%28',
|
||||
'%29',
|
||||
'%3B',
|
||||
'%3A',
|
||||
'%40',
|
||||
'%26',
|
||||
'%3D',
|
||||
'%24',
|
||||
'%2C',
|
||||
'%2F',
|
||||
'%3F',
|
||||
'%23',
|
||||
'%5B',
|
||||
'%5D',
|
||||
'%5C'
|
||||
];
|
||||
$replacements = ['!', '*', "'", '(', ')', ';', ':', '@', '&', '=', '$', ',', '/', '?', '#', '[', ']', '/'];
|
||||
|
||||
// Create encoded URL with special URL characters decoded so it can be parsed
|
||||
// All other characters will be encoded
|
||||
$encodedURL = str_replace($entities, $replacements, urlencode($url));
|
||||
|
||||
// Parse the encoded URL
|
||||
$encodedParts = parse_url($encodedURL);
|
||||
|
||||
// Now, decode each value of the resulting array
|
||||
if ($encodedParts) {
|
||||
foreach ($encodedParts as $key => $value) {
|
||||
$result[$key] = urldecode(str_replace($replacements, $entities, $value));
|
||||
}
|
||||
}
|
||||
|
||||
return $result;
|
||||
}
|
||||
|
||||
private function normalizeHost($domain): string
|
||||
{
|
||||
if (0 !== stripos($domain, 'https://') && 0 !== stripos($domain, 'http://')) {
|
||||
$domain = "http://{$domain}";
|
||||
}
|
||||
|
||||
return rtrim($domain, '/') . '/';
|
||||
}
|
||||
|
||||
private function getUrl(string $path): string
|
||||
{
|
||||
$segments = $this->parseUrl($path);
|
||||
$query = empty($segments['query']) ? '' : '?' . $segments['query'];
|
||||
|
||||
return $this->normalizeHost($this->base_url) . ltrim(implode('/', array_map('rawurlencode', explode('/', $segments['path']))), '/') . $query;
|
||||
}
|
||||
|
||||
private function privateDownloadUrl(string $path, int $expires = 3600): string
|
||||
{
|
||||
return $this->getAuthMgr()->privateDownloadUrl($this->getUrl($path), $expires);
|
||||
}
|
||||
|
||||
private function getMetadata($path): FileAttributes|array
|
||||
{
|
||||
$result = $this->getBucketMgr()->stat($this->bucket, $path);
|
||||
$result[0]['key'] = $path;
|
||||
|
||||
return $this->normalizeFileInfo($result[0]);
|
||||
}
|
||||
|
||||
private function normalizeFileInfo(array $stats): FileAttributes
|
||||
{
|
||||
return new FileAttributes(
|
||||
$stats['key'],
|
||||
$stats['fsize'] ?? null,
|
||||
null,
|
||||
isset($stats['putTime']) ? floor($stats['putTime'] / 10000000) : null,
|
||||
$stats['mimeType'] ?? null
|
||||
);
|
||||
}
|
||||
|
||||
public function fileExists(string $path): bool
|
||||
{
|
||||
[, $error] = $this->getBucketMgr()->stat($this->bucket, $this->applyPathPrefix($path));
|
||||
return is_null($error);
|
||||
}
|
||||
|
||||
public function directoryExists(string $path): bool
|
||||
{
|
||||
return $this->fileExists($path);
|
||||
}
|
||||
|
||||
public function write(string $path, string $contents, Config $config): void
|
||||
{
|
||||
$mime = $config->get('mime', 'application/octet-stream');
|
||||
|
||||
/**
|
||||
* @var Error|null $error
|
||||
*/
|
||||
[, $error] = $this->getUploadMgr()->put(
|
||||
$this->getAuthMgr()->uploadToken($this->bucket),
|
||||
$this->applyPathPrefix($path),
|
||||
$contents,
|
||||
null,
|
||||
$mime,
|
||||
$path
|
||||
);
|
||||
|
||||
if ($error) {
|
||||
throw UnableToWriteFile::atLocation($path, $error->message());
|
||||
}
|
||||
}
|
||||
|
||||
public function writeStream(string $path, $resource, Config $config): void
|
||||
{
|
||||
$data = '';
|
||||
|
||||
while (!feof($resource)) {
|
||||
$data .= fread($resource, 1024);
|
||||
}
|
||||
|
||||
$this->write($path, $data, $config);
|
||||
}
|
||||
|
||||
public function read(string $path): string
|
||||
{
|
||||
try {
|
||||
$result = file_get_contents($this->privateDownloadUrl($path));
|
||||
} catch (\Exception $th) {
|
||||
throw UnableToReadFile::fromLocation($path);
|
||||
}
|
||||
|
||||
if (false === $result) {
|
||||
throw UnableToReadFile::fromLocation($path);
|
||||
}
|
||||
|
||||
return $result;
|
||||
}
|
||||
|
||||
public function readStream(string $path)
|
||||
{
|
||||
if (ini_get('allow_url_fopen')) {
|
||||
if ($result = fopen($this->privateDownloadUrl($path), 'r')) {
|
||||
return $result;
|
||||
}
|
||||
}
|
||||
|
||||
throw UnableToReadFile::fromLocation($path);
|
||||
}
|
||||
|
||||
public function delete(string $path): void
|
||||
{
|
||||
[, $error] = $this->getBucketMgr()->delete($this->bucket, $this->applyPathPrefix($path));
|
||||
if (!is_null($error)) {
|
||||
throw UnableToDeleteFile::atLocation($path);
|
||||
}
|
||||
}
|
||||
|
||||
public function deleteDirectory(string $path): void
|
||||
{
|
||||
$this->delete($path);
|
||||
}
|
||||
|
||||
public function createDirectory(string $path, Config $config): void
|
||||
{
|
||||
}
|
||||
|
||||
public function setVisibility(string $path, string $visibility): void
|
||||
{
|
||||
throw UnableToSetVisibility::atLocation($path);
|
||||
}
|
||||
|
||||
public function visibility(string $path): FileAttributes
|
||||
{
|
||||
throw UnableToRetrieveMetadata::visibility($path);
|
||||
}
|
||||
|
||||
public function mimeType(string $path): FileAttributes
|
||||
{
|
||||
$meta = $this->getMetadata($path);
|
||||
|
||||
if ($meta->mimeType() === null) {
|
||||
throw UnableToRetrieveMetadata::mimeType($path);
|
||||
}
|
||||
|
||||
return $meta;
|
||||
}
|
||||
|
||||
public function lastModified(string $path): FileAttributes
|
||||
{
|
||||
$meta = $this->getMetadata($path);
|
||||
|
||||
if ($meta->lastModified() === null) {
|
||||
throw UnableToRetrieveMetadata::lastModified($path);
|
||||
}
|
||||
return $meta;
|
||||
}
|
||||
|
||||
public function fileSize(string $path): FileAttributes
|
||||
{
|
||||
$meta = $this->getMetadata($path);
|
||||
|
||||
if ($meta->fileSize() === null) {
|
||||
throw UnableToRetrieveMetadata::fileSize($path);
|
||||
}
|
||||
return $meta;
|
||||
}
|
||||
|
||||
public function listContents(string $path, bool $deep): iterable
|
||||
{
|
||||
$result = $this->getBucketMgr()->listFiles($this->bucket, $path);
|
||||
|
||||
foreach ($result[0]['items'] ?? [] as $files) {
|
||||
yield $this->normalizeFileInfo($files);
|
||||
}
|
||||
}
|
||||
|
||||
public function move(string $source, string $destination, Config $config): void
|
||||
{
|
||||
[, $error] = $this->getBucketMgr()->rename($this->bucket, $source, $destination);
|
||||
if (!is_null($error)) {
|
||||
throw UnableToMoveFile::fromLocationTo($source, $destination);
|
||||
}
|
||||
}
|
||||
|
||||
public function copy(string $source, string $destination, Config $config): void
|
||||
{
|
||||
[, $error] = $this->getBucketMgr()->copy($this->bucket, $source, $this->bucket, $destination);
|
||||
if (!is_null($error)) {
|
||||
throw UnableToCopyFile::fromLocationTo($source, $destination);
|
||||
}
|
||||
}
|
||||
}
|
||||
56
extend/filesystem/driver/Qiniu.php
Normal file
56
extend/filesystem/driver/Qiniu.php
Normal file
@@ -0,0 +1,56 @@
|
||||
<?php
|
||||
namespace filesystem\driver;
|
||||
|
||||
use Closure;
|
||||
use filesystem\adapter\QiniuAdapter;
|
||||
use League\Flysystem\FilesystemAdapter;
|
||||
|
||||
class Qiniu extends \think\filesystem\Driver
|
||||
{
|
||||
protected function createAdapter(): FilesystemAdapter
|
||||
{
|
||||
return new QiniuAdapter(
|
||||
$this->config['access_key'],
|
||||
$this->config['secret_key'],
|
||||
$this->config['bucket'],
|
||||
$this->config['base_url'],
|
||||
$this->config['path_prefix']
|
||||
);
|
||||
}
|
||||
|
||||
/**
|
||||
* 保存文件
|
||||
* @param string $path 路径
|
||||
* @param \think\File $file 文件
|
||||
* @param null|string|\Closure $rule 文件名规则
|
||||
* @param array $options 参数
|
||||
* @return bool|string
|
||||
*/
|
||||
public function putFile(string $path, \think\File $file, $rule = null, array $options = [])
|
||||
{
|
||||
if (!empty($this->config['filename_generator']) && $this->config['filename_generator'] instanceof Closure) {
|
||||
$rule = $this->config['filename_generator']($file, $rule);
|
||||
}
|
||||
|
||||
return $this->putFileAs($path, $file, $file->hashName($rule), $options);
|
||||
}
|
||||
|
||||
public function url(string $path): string
|
||||
{
|
||||
if (str_starts_with($path, 'http://') || str_starts_with($path, 'https://')) {
|
||||
return $path;
|
||||
}
|
||||
if (!str_starts_with($path, $this->config['path_prefix'])) {
|
||||
$path = $this->config['path_prefix'] . '/' . $path;
|
||||
}
|
||||
return $this->concatPathToUrl($this->config['base_url'], $path);
|
||||
}
|
||||
|
||||
public function path(string $path): string
|
||||
{
|
||||
if (!str_starts_with($path, $this->config['path_prefix'])) {
|
||||
$path = $this->config['path_prefix'] . '/' . $path;
|
||||
}
|
||||
return $path;
|
||||
}
|
||||
}
|
||||
@@ -1,157 +0,0 @@
|
||||
<?php
|
||||
namespace uploader;
|
||||
|
||||
use Qiniu\Auth;
|
||||
use Qiniu\Storage\UploadManager;
|
||||
use Qiniu\Storage\BucketManager;
|
||||
|
||||
class QiniuUploader
|
||||
{
|
||||
private $bucket = 'orico-opd';
|
||||
private $accessKey = 'dOsTum4a5qvhPTBbZRPX0pIOU7PZWRX7htKjztms';
|
||||
private $secretKey = 'KFxsGbnErkALFfeGdMa8QWTdodJbamMX0iznLe-q';
|
||||
|
||||
private $rule = [
|
||||
'fileSize' => 1024 * 1024 * 5, // 默认最大上传5M
|
||||
'fileExt' => 'jpeg,jpg,png', // 默认上传文件后缀
|
||||
'fileMime' => 'image/jpeg,image/png,image/gif' // 默认上传文件mime
|
||||
];
|
||||
|
||||
private $dir = true;
|
||||
private $originalName = false;
|
||||
private $pathPrefix = '';
|
||||
private $fileNamePrefix = 'orico';
|
||||
|
||||
static public $domain = 'http://opdfile.f2b211.com/';
|
||||
|
||||
public function __construct($conf = [])
|
||||
{
|
||||
if (!empty($conf['bucket'])) {
|
||||
$this->bucket = $conf['bucket'];
|
||||
}
|
||||
if (!empty($conf['accessKey'])) {
|
||||
$this->accessKey = $conf['accessKey'];
|
||||
}
|
||||
if (!empty($conf['secretKey'])) {
|
||||
$this->secretKey = $conf['secretKey'];
|
||||
}
|
||||
if (!empty($conf['pathPrefix'])) {
|
||||
$this->pathPrefix = trim($conf['pathPrefix'], '/');
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 生成随机字符串
|
||||
*/
|
||||
private function random($length, $type = "string", $convert = "0")
|
||||
{
|
||||
$conf = [
|
||||
'number' => '0123456789',
|
||||
'string' => 'abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ',
|
||||
'all' => 'abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789='
|
||||
];
|
||||
$string = $conf[$type];
|
||||
if (!$string) {
|
||||
$string = $conf['string'];
|
||||
}
|
||||
$strlen = strlen($string) - 1;
|
||||
$char = '';
|
||||
for ($i = 0; $i < $length; $i++) {
|
||||
$char .= $string[mt_rand(0, $strlen)];
|
||||
}
|
||||
if ($convert > 0) {
|
||||
$res = strtoupper($char);
|
||||
} elseif ($convert == 0) {
|
||||
$res = $char;
|
||||
} elseif ($convert < 0) {
|
||||
$res = strtolower($char);
|
||||
}
|
||||
return $res;
|
||||
}
|
||||
|
||||
/**
|
||||
* 组装文件名
|
||||
*/
|
||||
private function buildFileName()
|
||||
{
|
||||
return $this->fileNamePrefix . time() . substr(time(), -5) . substr(microtime(), 2, 3) . $this->random(8);
|
||||
}
|
||||
|
||||
/**
|
||||
* 上传验证规则
|
||||
*/
|
||||
public function validate($rule)
|
||||
{
|
||||
$this->rule = $rule;
|
||||
}
|
||||
|
||||
/**
|
||||
* 上传文件到七牛云
|
||||
*/
|
||||
public function uploadFile($name)
|
||||
{
|
||||
// 构建鉴权对象
|
||||
$auth = new Auth($this->accessKey, $this->secretKey);
|
||||
|
||||
// 生成上传 Token
|
||||
$token = $auth->uploadToken($this->bucket);
|
||||
|
||||
// 初始化 UploadManager 对象并进行文件的上传。
|
||||
$uploadMgr = new UploadManager();
|
||||
|
||||
$file = request()->file($name);
|
||||
|
||||
$aspectRatio = [];
|
||||
if (!empty($this->rule['aspectRatio'])) {
|
||||
$aspectRatio = $this->rule['aspectRatio'];
|
||||
unset($this->rule['aspectRatio']);
|
||||
}
|
||||
$validate = validate([$name => $this->rule]);
|
||||
if (!$validate->check([$name => $file])) {
|
||||
throw new \Exception($validate->getError());
|
||||
}
|
||||
|
||||
$fileName = $file->getOriginalName(); // 文件原名
|
||||
if (!$this->originalName) {
|
||||
$fileName = $this->buildFileName() . '.' . $file->extension();
|
||||
if (!$this->dir && !empty($this->pathPrefix)) {
|
||||
$fileName = $this->pathPrefix . '/' . $fileName;
|
||||
}
|
||||
}
|
||||
if ($this->dir) {
|
||||
$fileName = date('Y') . '/' . date('m') . '/' . date('d') . '/' . $fileName;
|
||||
if (!empty($this->pathPrefix)) {
|
||||
$fileName = $this->pathPrefix . '/' . $fileName;
|
||||
}
|
||||
}
|
||||
$filePath = $file->getPathname(); // 临时路径
|
||||
if (!empty($aspectRatio)) { // 验证图片宽高
|
||||
list($width, $height, $type, $attr) = getimagesize($file);
|
||||
if ($width != $aspectRatio['width'] || $height != $aspectRatio['height']) {
|
||||
throw new \Exception('图片宽高不符合');
|
||||
}
|
||||
}
|
||||
$fileType = $file->getOriginalMime();
|
||||
list($ret, $err) = $uploadMgr->putFile($token, $fileName, $filePath, null, $fileType, false);
|
||||
|
||||
if ($err !== null) {
|
||||
throw new \Exception($err);
|
||||
} else {
|
||||
return ['hash' => $ret['hash'], 'filename' => $ret['key'], 'remote_url' => self::$domain . $ret['key']];
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* 上传文件到七牛云
|
||||
*/
|
||||
public function deleteFile($name)
|
||||
{
|
||||
// 构建鉴权对象
|
||||
$auth = new Auth($this->accessKey, $this->secretKey);
|
||||
// 初始化 BucketManager 对象并进行文件的删除。
|
||||
$bucketManager = new BucketManager($auth);
|
||||
$ret = $bucketManager->delete($this->bucket, $name);
|
||||
return $ret;
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user