station-test-api/extend/catcher/CatchUpload.php

<?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));
        }
    }
}