<?php
declare(strict_types=1);
namespace catcher;
use catchAdmin\system\model\Attachments;
use catchAdmin\system\model\Config;
use catcher\exceptions\FailedException;
use catcher\exceptions\ValidateFailedException;
use think\exception\ValidateException;
use think\facade\Filesystem;
use think\file\UploadedFile;
class CatchUpload
{
/**
* 阿里云
*/
public const OSS = 'oss';
/**
* 腾讯云
*/
public const QCLOUD = 'qcloud';
/**
* 七牛
*/
public const QIQNIU = 'qiniu';
/**
* 驱动
*
* @var string
*/
protected $driver;
/**
* 本地
*/
public const LOCAL = 'local';
/**
* path
*
* @var string
*/
protected $path = '';
public function __construct()
{
$this->initDriver();
}
/**
* upload files
*
* @param UploadedFile $file
* @param null|string|\Closure $rule 文件名规则
* @param array $options 参数
* @return string
* @author JaguarJack
* @email njphper@gmail.com
* @time 2020/1/25
*/
public function upload(UploadedFile $file,$rule = null,array $options = []): string
{
$this->initUploadConfig();
$path = Filesystem::disk($this->getDriver())->putFile($this->getPath(), $file,$rule,$options);
if ($path) {
$url = self::getCloudDomain($this->getDriver()) . '/' . $this->getLocalPath($path);
event('attachment', [
'path' => $path,
'url' => $url,
'driver' => $this->getDriver(),
'file' => $file,
]);
return $url;
}
throw new FailedException('Upload Failed, Try Again!');
}
/**
* 本地路径
*
* @time 2020年09月07日
* @param $path
* @return string
*/
protected function getLocalPath($path)
{
if ($this->getDriver() === self::LOCAL) {
$path = str_replace(root_path('public'), '', \config('filesystem.disks.local.root')) . DIRECTORY_SEPARATOR .$path;
return str_replace('\\', '/', $path);
}
return $path;
}
/**
* 多文件上传
*
* @author JaguarJack
* @email njphper@gmail.com
* @time 2020/2/1
* @param $attachments
* @param null|string|\Closure $rule 文件名规则
* @param array $options 参数
* @return array|string
*/
public function multiUpload($attachments,$rule = null,array $options = [])
{
if (!is_array($attachments)) {
return $this->upload($attachments,$rule,$options);
}
$paths = [];
foreach ($attachments as $attachment) {
$paths[] = $this->upload($attachment,$rule,$options);
}
return $paths;
}
/**
* get upload driver
*
* @author JaguarJack
* @email njphper@gmail.com
* @time 2020/1/25
* @return string
*/
protected function getDriver(): string
{
if ($this->driver) {
return $this->driver;
}
return \config('filesystem.default');
}
/**
* set driver
*
* @author JaguarJack
* @email njphper@gmail.com
* @time 2020/1/25
* @param $driver
* @throws \Exception
* @return $this
*/
public function setDriver($driver): self
{
if (!in_array($driver, [self::OSS, self::QCLOUD, self::QIQNIU, self::LOCAL])) {
throw new \Exception(sprintf('Upload Driver [%s] Not Supported', $driver));
}
$this->driver = $driver;
return $this;
}
/**
*
* @author JaguarJack
* @email njphper@gmail.com
* @time 2020/1/25
* @return string
*/
protected function getPath()
{
return $this->path;
}
/**
*
* @author JaguarJack
* @email njphper@gmail.com
* @time 2020/1/25
* @param string $path
* @return $this
*/
public function setPath(string $path)
{
$this->path = $path;
return $this;
}
/**
*
* @time 2020年01月25日
* @param UploadedFile $file
* @return array
*/
protected function data(UploadedFile $file)
{
return [
'file_size' => $file->getSize(),
'mime_type' => $file->getMime(),
'file_ext' => $file->getOriginalExtension(),
'filename' => $file->getOriginalName(),
'driver' => $this->getDriver(),
];
}
/**
* 验证图片
*
* @author JaguarJack
* @email njphper@gmail.com
* @time 2020/2/1
* @param array $images
* @return $this
*/
public function checkImages(array $images)
{
try {
validate(['image' => config('catch.upload.image')])->check($images);
} catch (ValidateException $e) {
throw new ValidateFailedException($e->getMessage());
}
return $this;
}
/**
* 验证文件
*
* @author JaguarJack
* @email njphper@gmail.com
* @time 2020/2/1
* @param array $files
* @return $this
*/
public function checkFiles(array $files)
{
try {
validate(['file' => config('catch.upload.file')])->check($files);
} catch (ValidateException $e) {
throw new ValidateFailedException($e->getMessage());
}
return $this;
}
/**
* 验证文件是否存在
*
* @author JaguarJack
* @email njphper@gmail.com
* @time 2020/2/1
* @param $path
* @return $this
*/
public function checkFilesExists($path)
{
$driver = \config('filesystem.disks.' . $this->getDriver());
if($driver['type']=='local'){
$url=$driver['root'].'\\'.$path;
return file_exists($url);
}else{
$url = self::getCloudDomain($this->getDriver()) . '/' . $this->getLocalPath($path);
$file_exists = (@file_get_contents($url)) ? true : false;
return $file_exists;
}
return false;
}
/**
* 初始化配置
*
* @time 2020年06月01日
* @return void
*/
protected function initUploadConfig()
{
$configModel = app(Config::class);
$upload = $configModel->where('key', 'upload')->find();
if ($upload) {
$disk = app()->config->get('filesystem.disks');
$uploadConfigs = $configModel->getConfig($upload->component);
if (!empty($uploadConfigs)) {
// 读取上传可配置数据
foreach ($uploadConfigs as $key => &$config) {
// $disk[$key]['type'] = $key;
// 腾讯云配置处理
if (strtolower($key) == 'qcloud') {
$config['credentials'] = [
'appId' => $config['app_id'] ?? '',
'secretKey' => $config['secret_key'] ?? '',
'secretId' => $config['secret_id'] ?? '',
];
$readFromCdn = $config['read_from_cdn'] ?? 0;
$config['read_from_cdn'] = intval($readFromCdn) == 1;
}
// OSS 配置
if (strtolower($key) == 'oss') {
$isCname = $config['is_cname'] ?? 0;
$config['is_cname'] = intval($isCname) == 1;
}
}
// 合并数组
array_walk($disk, function (&$item, $key) use ($uploadConfigs) {
if (!in_array($key, ['public', 'local'])) {
if ($uploadConfigs[$key] ?? false) {
foreach ($uploadConfigs[$key] as $k => $value) {
$item[$k] = $value;
}
}
}
});
// 重新分配配置
app()->config->set([
'disks' => $disk,
], 'filesystem');
}
}
}
/**
* 初始化
*
* @time 2020年09月07日
* @return $this
*/
protected function initDriver()
{
if ($driver = Utils::config('site.upload')) {
$this->driver = $driver;
}
return $this;
}
/**
* 获取云存储的域名
*
* @time 2020年01月25日
* @param $driver
* @return string
*/
public static function getCloudDomain($driver): ?string
{
$driver = \config('filesystem.disks.' . $driver);
switch ($driver['type']) {
case CatchUpload::QIQNIU:
case CatchUpload::LOCAL:
return $driver['domain'];
case CatchUpload::OSS:
return $driver['end_point'];
case CatchUpload::QCLOUD:
return $driver['cdn'];
default:
throw new FailedException(sprintf('Driver [%s] Not Supported.', $driver));
}
}
}