alioss

addons/alioss/.addonrc

@@ -0,0 +1 @@
+{"files":["public\\assets\\addons\\alioss\\js\\spark.js"]}

addons/alioss/Alioss.php

@@ -0,0 +1,140 @@
+<?php
+
+namespace addons\alioss;
+
+use think\Addons;
+
+/**
+ * 阿里云OSS上传插件
+ */
+class Alioss extends Addons
+{
+
+    /**
+     * 插件安装方法
+     * @return bool
+     */
+    public function install()
+    {
+        return true;
+    }
+
+    /**
+     * 插件卸载方法
+     * @return bool
+     */
+    public function uninstall()
+    {
+        return true;
+    }
+
+    /**
+     * 加载配置
+     */
+    public function uploadConfigInit(&$upload)
+    {
+        $config = $this->getConfig();
+        if ($config['uploadmode'] === 'client')
+        {
+            $upload = [
+                'cdnurl'    => $config['cdnurl'],
+                'uploadurl' => 'http://' . $config['bucket'] . '.' . $config['endpoint'],
+                'bucket'    => $config['bucket'],
+                'maxsize'   => $config['maxsize'],
+                'mimetype'  => $config['mimetype'],
+                'multipart' => [],
+                'multiple'  => $config['multiple'] ? true : false,
+                'storage'   => 'alioss',
+                'chunking'  => (bool)($config['chunking']??false)
+            ];
+        }
+        else
+        {
+            $upload = array_merge($upload, [
+                'maxsize'  => $config['maxsize'],
+                'mimetype' => $config['mimetype'],
+                'multiple' => $config['multiple'] ? true : false,
+            ]);
+        }
+    }
+
+    /**
+     * 上传成功后
+     */
+    public function uploadAfter($attachment)
+    {
+        $config = $this->getConfig();
+        if ($config['uploadmode'] === 'server')
+        {
+            $file = ROOT_PATH . 'public' . str_replace('/', DIRECTORY_SEPARATOR, $attachment->url);
+
+            $name = basename($file);
+            $md5 = md5_file($file);
+
+            $auth = new \addons\alioss\library\Auth();
+            $params = $auth->params($name, $md5, false);
+            $multipart = [
+                [
+                    'name'     => 'key',
+                    'contents' => $params['key'],
+                ],
+                [
+                    'name'     => 'success_action_status',
+                    'contents' => 200,
+                ],
+                [
+                    'name'     => 'OSSAccessKeyId',
+                    'contents' => $params['id'],
+                ],
+                [
+                    'name'     => 'policy',
+                    'contents' => $params['policy'],
+                ],
+                [
+                    'name'     => 'Signature',
+                    'contents' => $params['signature'],
+                ],
+                [
+                    'name'     => 'file',
+                    'contents' => fopen($file, 'r'),
+                ],
+            ];
+            try
+            {
+                $uploadurl = 'http://' . $config['bucket'] . '.' . $config['endpoint'];
+
+                $client = new \GuzzleHttp\Client();
+//                $res = $client->request('POST', $uploadurl, [
+//                    'multipart' => $multipart,
+//                    'headers'   => ['Accept-Encoding' => 'gzip'],
+//                ]);
+                
+                $multipartStream = new \GuzzleHttp\Psr7\MultipartStream($multipart);
+                $boundary = $multipartStream->getBoundary();
+                $body = (string) $multipartStream;
+                //默认的request方法会添加Content-Length字段，但Alioss不识别，所以需要移除
+                $body = preg_replace('/Content\-Length:\s(\d+)[\r\n]+Content\-Type/i', "Content-Type", $body);
+                $params = [
+                    'headers' => [
+                        'Connection'   => 'close',
+                        'Content-Type' => 'multipart/form-data; boundary=' . $boundary,
+                    ],
+                    'body'    => $body,
+                ];
+
+                $res = $client->request('POST', $uploadurl, $params);
+                $code = $res->getStatusCode();
+                //成功不做任何操作
+            }
+            catch (\GuzzleHttp\Exception\ClientException $e)
+            {
+                $attachment->delete();
+                //echo $e->getRequest()->getBody();
+                unlink($file);
+                echo json_encode(['code' => 0, 'msg' => '无法上传到远程服务器，错误:' . $e->getMessage()]);
+                exit;
+            }
+        }
+    }
+
+}

addons/alioss/bootstrap.js

@@ -0,0 +1,82 @@
+//如果开启了alioss客户端上传模式
+if (typeof Config.upload.storage !== 'undefined' && Config.upload.storage === 'alioss') {
+    require(['upload', '../addons/alioss/js/spark'], function (Upload, SparkMD5) {
+        var _onFileAdded = Upload.events.onFileAdded;
+        var _onUploadResponse = Upload.events.onUploadResponse;
+        var _process = function (up, file) {
+            (function (up, file) {
+                var blob = file.getNative();
+                var loadedBytes = file.loaded;
+                var chunkSize = 2097152;
+                var chunkBlob = blob.slice(loadedBytes, loadedBytes + chunkSize);
+                var reader = new FileReader();
+                reader.addEventListener('loadend', function (e) {
+                    var spark = new SparkMD5.ArrayBuffer();
+                    spark.append(e.target.result);
+                    var md5 = spark.end();
+                    Fast.api.ajax({
+                        url: "/addons/alioss/index/params",
+                        data: {method: 'POST', md5: md5, name: file.name, type: file.type, size: file.size},
+                    }, function (data) {
+                        file.md5 = md5;
+                        file.status = 1;
+                        file.key = data.key;
+                        file.OSSAccessKeyId = data.id;
+                        file.policy = data.policy;
+                        file.signature = data.signature;
+                        up.start();
+                        return false;
+                    });
+                    return;
+                });
+                reader.readAsArrayBuffer(chunkBlob);
+            })(up, file);
+        };
+        Upload.events.onFileAdded = function (up, files) {
+            return _onFileAdded.call(this, up, files);
+        };
+        Upload.events.onBeforeUpload = function (up, file) {
+            if (typeof file.md5 === 'undefined') {
+                up.stop();
+                _process(up, file);
+            } else {
+                up.settings.headers = up.settings.headers || {};
+                up.settings.multipart_params.key = file.key;
+                up.settings.multipart_params.OSSAccessKeyId = file.OSSAccessKeyId;
+                up.settings.multipart_params.success_action_status = 200;
+                if (typeof file.callback !== 'undefined') {
+                    up.settings.multipart_params.callback = file.callback;
+                }
+                up.settings.multipart_params.policy = file.policy;
+                up.settings.multipart_params.signature = file.signature;
+                //up.settings.send_file_name = false;
+            }
+        };
+        Upload.events.onUploadResponse = function (response, info, up, file) {
+            try {
+                var ret = {};
+                if (info.status === 200) {
+                    var url = '/' + file.key;
+                    Fast.api.ajax({
+                        url: "/addons/alioss/index/notify",
+                        data: {method: 'POST', name: file.name, url: url, md5: file.md5, size: file.size, type: file.type, policy: file.policy, signature: file.signature}
+                    }, function () {
+                        return false;
+                    });
+                    ret.code = 1;
+                    ret.data = {
+                        url: url
+                    };
+                } else {
+                    ret.code = 0;
+                    ret.msg = info.response;
+                }
+                return _onUploadResponse.call(this, JSON.stringify(ret));
+
+            } catch (e) {
+            }
+            return _onUploadResponse.call(this, response);
+
+        };
+    });
+}

addons/alioss/config.php

@@ -0,0 +1,151 @@
+<?php
+
+return [
+    [
+        'name' => 'app_id',
+        'title' => 'app_id',
+        'type' => 'string',
+        'content' => [],
+        'value' => 'asdasd',
+        'rule' => 'required',
+        'msg' => '',
+        'tip' => '',
+        'ok' => '',
+        'extend' => '',
+    ],
+    [
+        'name' => 'app_key',
+        'title' => 'app_key',
+        'type' => 'string',
+        'content' => [],
+        'value' => 'asdasda',
+        'rule' => 'required',
+        'msg' => '',
+        'tip' => '',
+        'ok' => '',
+        'extend' => '',
+    ],
+    [
+        'name' => 'bucket',
+        'title' => 'Bucket',
+        'type' => 'string',
+        'content' => [],
+        'value' => 'dasdasda',
+        'rule' => 'required',
+        'msg' => '',
+        'tip' => '阿里云OSS的空间名',
+        'ok' => '',
+        'extend' => '',
+    ],
+    [
+        'name' => 'endpoint',
+        'title' => 'EndPoint',
+        'type' => 'string',
+        'content' => [],
+        'value' => 'oss-cn-shenzhen.aliyuncs.com',
+        'rule' => 'required',
+        'msg' => '',
+        'tip' => '如果是服务器中转模式，可填写内网域名',
+        'ok' => '',
+        'extend' => '',
+    ],
+    [
+        'name' => 'cdnurl',
+        'title' => 'CDN地址',
+        'type' => 'string',
+        'content' => [],
+        'value' => 'http://yourbucket.oss-cn-shenzhen.aliyuncs.com',
+        'rule' => 'required',
+        'msg' => '',
+        'tip' => '如果你启用了CDN，请填写CDN地址',
+        'ok' => '',
+        'extend' => '',
+    ],
+    6 => [
+        'name' => 'uploadmode',
+        'title' => '上传模式',
+        'type' => 'select',
+        'content' => [
+            'client' => '客户端直传(速度快,无备份)',
+            'server' => '服务器中转(占用服务器带宽,有备份)',
+        ],
+        'value' => 'client',
+        'rule' => '',
+        'msg' => '',
+        'tip' => '',
+        'ok' => '',
+        'extend' => '',
+    ],
+    [
+        'name' => 'savekey',
+        'title' => '保存文件名',
+        'type' => 'string',
+        'content' => [],
+        'value' => '/uploads/{year}{mon}{day}/{filemd5}{.suffix}',
+        'rule' => 'required',
+        'msg' => '',
+        'tip' => '',
+        'ok' => '',
+        'extend' => '',
+    ],
+    [
+        'name' => 'expire',
+        'title' => '上传有效时长',
+        'type' => 'string',
+        'content' => [],
+        'value' => '600',
+        'rule' => 'required',
+        'msg' => '',
+        'tip' => '',
+        'ok' => '',
+        'extend' => '',
+    ],
+    [
+        'name' => 'maxsize',
+        'title' => '最大可上传',
+        'type' => 'string',
+        'content' => [],
+        'value' => '10M',
+        'rule' => 'required',
+        'msg' => '',
+        'tip' => '',
+        'ok' => '',
+        'extend' => '',
+    ],
+    [
+        'name' => 'mimetype',
+        'title' => '可上传后缀格式',
+        'type' => 'string',
+        'content' => [],
+        'value' => '*',
+        'rule' => 'required',
+        'msg' => '',
+        'tip' => '',
+        'ok' => '',
+        'extend' => '',
+    ],
+    [
+        'name' => 'multiple',
+        'title' => '多文件上传',
+        'type' => 'bool',
+        'content' => [],
+        'value' => '0',
+        'rule' => 'required',
+        'msg' => '',
+        'tip' => '',
+        'ok' => '',
+        'extend' => '',
+    ],
+    [
+        'name' => 'chunking',
+        'title' => '分片上传',
+        'type' => 'bool',
+        'content' => [],
+        'value' => '0',
+        'rule' => 'required',
+        'msg' => '',
+        'tip' => '',
+        'ok' => '',
+        'extend' => '',
+    ],
+];

addons/alioss/controller/Index.php

@@ -0,0 +1,69 @@
+<?php
+
+namespace addons\alioss\controller;
+
+use app\common\model\Attachment;
+use think\addons\Controller;
+
+/**
+ * Ucloud
+ *
+ */
+class Index extends Controller
+{
+
+    public function index()
+    {
+        $this->error("当前插件暂无前台页面");
+    }
+
+    public function params()
+    {
+        $name = $this->request->post('name');
+        $md5 = $this->request->post('md5');
+        $auth = new \addons\alioss\library\Auth();
+        $params = $auth->params($name, $md5);
+        $this->success('', null, $params);
+        return;
+    }
+
+    public function notify()
+    {
+        $size = $this->request->post('size');
+        $name = $this->request->post('name');
+        $md5 = $this->request->post('md5');
+        $type = $this->request->post('type');
+        $signature = $this->request->post('signature');
+        $policy = $this->request->post('policy');
+        $url = $this->request->post('url');
+        $suffix = substr($name, stripos($name, '.') + 1);
+        $auth = new \addons\alioss\library\Auth();
+        if ($auth->check($signature, $policy))
+        {
+            $attachment = Attachment::getBySha1($md5);
+            if (!$attachment)
+            {
+                $params = array(
+                    'filesize'    => $size,
+                    'imagewidth'  => 0,
+                    'imageheight' => 0,
+                    'imagetype'   => $suffix,
+                    'imageframes' => 0,
+                    'mimetype'    => $type,
+                    'url'         => $url,
+                    'uploadtime'  => time(),
+                    'storage'     => 'alioss',
+                    'sha1'        => $md5,
+                );
+                Attachment::create($params);
+            }
+            $this->success();
+        }
+        else
+        {
+            $this->error(__('You have no permission'));
+        }
+        return;
+    }
+
+}

addons/alioss/info.ini

@@ -0,0 +1,8 @@
+name = alioss
+title = 阿里OSS上传
+intro = 使用阿里OSS存储，上传时直传阿里云OSS
+author = Karson
+website = http://www.fastadmin.net
+version = 1.0.0
+state = 1
+url = /addons/alioss

addons/alioss/install.sql

@@ -0,0 +1 @@
+ALTER TABLE `__PREFIX__attachment` MODIFY COLUMN `storage` enum('local','upyun','qiniu','ucloud','alioss') CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL DEFAULT 'local' COMMENT '存储位置' AFTER `uploadtime`;

addons/alioss/library/Auth.php

@@ -0,0 +1,78 @@
+<?php
+
+namespace addons\alioss\library;
+
+class Auth
+{
+
+    public function __construct()
+    {
+        
+    }
+
+    public function params($name, $md5, $callback = true)
+    {
+        $config = get_addon_config('alioss');
+        $callback_param = array(
+            'callbackUrl'      => isset($config['notifyurl']) ? $config['notifyurl'] : '',
+            'callbackBody'     => 'filename=${object}&size=${size}&mimeType=${mimeType}&height=${imageInfo.height}&width=${imageInfo.width}',
+            'callbackBodyType' => "application/x-www-form-urlencoded"
+        );
+
+        $base64_callback_body = base64_encode(json_encode($callback_param));
+
+        $now = time();
+        $end = $now + $config['expire']; //设置该policy超时时间是10s. 即这个policy过了这个有效时间，将不能访问
+        $expiration = $this->gmt_iso8601($end);
+
+        preg_match('/(\d+)(\w+)/', $config['maxsize'], $matches);
+        $type = strtolower($matches[2]);
+        $typeDict = ['b' => 0, 'k' => 1, 'kb' => 1, 'm' => 2, 'mb' => 2, 'gb' => 3, 'g' => 3];
+        $size = (int) $config['maxsize'] * pow(1024, isset($typeDict[$type]) ? $typeDict[$type] : 0);
+
+        //最大文件大小.用户可以自己设置
+        $condition = array(0 => 'content-length-range', 1 => 0, 2 => $size);
+        $conditions[] = $condition;
+
+        //表示用户上传的数据,必须是以$dir开始, 不然上传会失败,这一步不是必须项,只是为了安全起见,防止用户通过policy上传到别人的目录
+        //$start = array(0 => 'starts-with', 1 => '$key', 2 => $dir);
+        //$conditions[] = $start;
+
+        $arr = array('expiration' => $expiration, 'conditions' => $conditions);
+
+        $policy = base64_encode(json_encode($arr));
+        $signature = base64_encode(hash_hmac('sha1', $policy, $config['app_key'], true));
+
+        $suffix = substr($name, stripos($name, '.') + 1);
+        $search = ['{year}', '{mon}', '{month}', '{day}', '{filemd5}', '{suffix}', '{.suffix}'];
+        $replace = [date("Y"), date("m"), date("m"), date("d"), $md5, $suffix, '.' . $suffix];
+        $key = ltrim(str_replace($search, $replace, $config['savekey']), '/');
+
+        $response = array();
+        $response['id'] = $config['app_id'];
+        $response['key'] = $key;
+        $response['policy'] = $policy;
+        $response['signature'] = $signature;
+        $response['expire'] = $end;
+        $response['callback'] = '';
+        return $response;
+    }
+
+    public function check($signature, $policy)
+    {
+        $config = get_addon_config('alioss');
+        $sign = base64_encode(hash_hmac('sha1', $policy, $config['app_key'], true));
+        return $signature == $sign;
+    }
+
+    private function gmt_iso8601($time)
+    {
+        $dtStr = date("c", $time);
+        $mydatetime = new \DateTime($dtStr);
+        $expiration = $mydatetime->format(\DateTime::ISO8601);
+        $pos = strpos($expiration, '+');
+        $expiration = substr($expiration, 0, $pos);
+        return $expiration . "Z";
+    }
+
+}

application/extra/addons.php

@@ -3,6 +3,12 @@
 return [
     'autoload' => false,
     'hooks' => [
+        'upload_config_init' => [
+            'alioss',
+        ],
+        'upload_after' => [
+            'alioss',
+        ],
         'sms_send' => [
             'aliyunsms',
         ],

public/assets/js/addons.js

@@ -1,5 +1,87 @@
 define([], function () {
-    require.config({
+    //如果开启了alioss客户端上传模式
+if (typeof Config.upload.storage !== 'undefined' && Config.upload.storage === 'alioss') {
+    require(['upload', '../addons/alioss/js/spark'], function (Upload, SparkMD5) {
+        var _onFileAdded = Upload.events.onFileAdded;
+        var _onUploadResponse = Upload.events.onUploadResponse;
+        var _process = function (up, file) {
+            (function (up, file) {
+                var blob = file.getNative();
+                var loadedBytes = file.loaded;
+                var chunkSize = 2097152;
+                var chunkBlob = blob.slice(loadedBytes, loadedBytes + chunkSize);
+                var reader = new FileReader();
+                reader.addEventListener('loadend', function (e) {
+                    var spark = new SparkMD5.ArrayBuffer();
+                    spark.append(e.target.result);
+                    var md5 = spark.end();
+                    Fast.api.ajax({
+                        url: "/addons/alioss/index/params",
+                        data: {method: 'POST', md5: md5, name: file.name, type: file.type, size: file.size},
+                    }, function (data) {
+                        file.md5 = md5;
+                        file.status = 1;
+                        file.key = data.key;
+                        file.OSSAccessKeyId = data.id;
+                        file.policy = data.policy;
+                        file.signature = data.signature;
+                        up.start();
+                        return false;
+                    });
+                    return;
+                });
+                reader.readAsArrayBuffer(chunkBlob);
+            })(up, file);
+        };
+        Upload.events.onFileAdded = function (up, files) {
+            return _onFileAdded.call(this, up, files);
+        };
+        Upload.events.onBeforeUpload = function (up, file) {
+            if (typeof file.md5 === 'undefined') {
+                up.stop();
+                _process(up, file);
+            } else {
+                up.settings.headers = up.settings.headers || {};
+                up.settings.multipart_params.key = file.key;
+                up.settings.multipart_params.OSSAccessKeyId = file.OSSAccessKeyId;
+                up.settings.multipart_params.success_action_status = 200;
+                if (typeof file.callback !== 'undefined') {
+                    up.settings.multipart_params.callback = file.callback;
+                }
+                up.settings.multipart_params.policy = file.policy;
+                up.settings.multipart_params.signature = file.signature;
+                //up.settings.send_file_name = false;
+            }
+        };
+        Upload.events.onUploadResponse = function (response, info, up, file) {
+            try {
+                var ret = {};
+                if (info.status === 200) {
+                    var url = '/' + file.key;
+                    Fast.api.ajax({
+                        url: "/addons/alioss/index/notify",
+                        data: {method: 'POST', name: file.name, url: url, md5: file.md5, size: file.size, type: file.type, policy: file.policy, signature: file.signature}
+                    }, function () {
+                        return false;
+                    });
+                    ret.code = 1;
+                    ret.data = {
+                        url: url
+                    };
+                } else {
+                    ret.code = 0;
+                    ret.msg = info.response;
+                }
+                return _onUploadResponse.call(this, JSON.stringify(ret));
+
+            } catch (e) {
+            }
+            return _onUploadResponse.call(this, response);
+
+        };
+    });
+}
+require.config({
     paths: {
         'simditor': '../addons/simditor/js/simditor.min',
     },