小程序上传图片

@@ -7,11 +7,30 @@
 namespace api\user\controller;
 namespace api\user\controller;
 
 
 use cmf\controller\RestUserBaseController;
 use cmf\controller\RestUserBaseController;
+use Qiniu\Auth;
+use Qiniu\Storage\UploadManager;
 use think\Db;
 use think\Db;
 
 
+/**
+ * @title 文件上传
+ * @description 文件上传
+ * @package api\wxapp\controller
+ */
 class UploadController extends RestUserBaseController
 class UploadController extends RestUserBaseController
 {
 {
-    // 用户密码修改
+
+    /**
+     * @title 上传单个文件
+     * @description 上传单个文件
+     * @author Tiger Yang
+     * @url /user/upload/one
+     * @method POST
+     *
+     * @header name:XX-Token require:1 default: desc:登录标识
+     * @header name:XX-Device-Type require:0 default:wxapp desc:设备类型
+     *
+     * @param name:file type:file require:1 other: desc:上传文件
+     */
     public function one()
     public function one()
     {
     {
         $file = $this->request->file('file');
         $file = $this->request->file('file');
@@ -26,7 +45,7 @@ class UploadController extends RestUserBaseController
         $findFile = Db::name("asset")->where('file_md5', $fileMd5)->where('file_sha1', $fileSha1)->find();
         $findFile = Db::name("asset")->where('file_md5', $fileMd5)->where('file_sha1', $fileSha1)->find();
 
 
         if (!empty($findFile)) {
         if (!empty($findFile)) {
-            $this->success("上传成功!", ['url' => $findFile['file_path'], 'filename' => $findFile['filename']]);
+            $this->success("上传成功!", ['url' => cmf_get_asset_url($findFile['file_path']), 'filename' => $findFile['filename']]);
         }
         }
         $info = $info->move(ROOT_PATH . 'public' . DS . 'upload');
         $info = $info->move(ROOT_PATH . 'public' . DS . 'upload');
         if ($info) {
         if ($info) {
@@ -43,14 +62,20 @@ class UploadController extends RestUserBaseController
                 'file_key'    => $fileKey,
                 'file_key'    => $fileKey,
                 'filename'    => $originalName,
                 'filename'    => $originalName,
                 'file_size'   => $fileSize,
                 'file_size'   => $fileSize,
-                'file_path'   => $saveName,
+                'file_path'   => cmf_get_asset_url($saveName),
                 'file_md5'    => $fileMd5,
                 'file_md5'    => $fileMd5,
                 'file_sha1'   => $fileSha1,
                 'file_sha1'   => $fileSha1,
                 'create_time' => time(),
                 'create_time' => time(),
                 'suffix'      => $suffix
                 'suffix'      => $suffix
             ]);
             ]);
 
 
-            $this->success("上传成功!", ['url' => $saveName, 'filename' => $originalName]);
+            $storage = cmf_get_option('storage');
+
+            if (isset($storage['type'])&&$storage['type']=='Qiniu') {
+                $this->uploadToQiniu($saveName);
+            }
+
+            $this->success("上传成功!", ['url' => cmf_get_asset_url($saveName), 'filename' => $originalName]);
         } else {
         } else {
             // 上传失败获取错误信息
             // 上传失败获取错误信息
             $this->error($file->getError());
             $this->error($file->getError());
@@ -59,4 +84,45 @@ class UploadController extends RestUserBaseController
     }
     }
 
 
 
 
+    /**
+     * 上传到七牛云
+     * @param $save_name
+     * @param bool $is_del_local
+     * @return array
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\ModelNotFoundException
+     * @throws \think\exception\DbException
+     */
+    public function uploadToQiniu($save_name,$is_del_local=true){
+        $plugin=Db::name('plugin')->field('config')->where(['name'=>'Qiniu'])->find();
+        $config=json_decode($plugin['config'],true);
+
+        $filePath = './../upload/'.$save_name;
+        // 上传到七牛后保存的文件名
+        $key =$save_name;
+        require_once VENDOR_PATH . 'qiniu/php-sdk/autoload.php';
+        // 需要填写你的 Access Key 和 Secret Key
+        $accessKey = $config['accessKey'];
+        $secretKey = $config['secretKey'];
+        // 构建鉴权对象
+        $auth = new Auth($accessKey,$secretKey);
+        // 要上传的空间
+        $bucket = $config['bucket'];
+
+        $token = $auth->uploadToken($bucket);
+        // 初始化 UploadManager 对象并进行文件的上传
+        $uploadMgr = new UploadManager();
+        // 调用 UploadManager 的 putFile 方法进行文件的上传
+        list($ret, $err) = $uploadMgr->putFile($token, $key, $filePath);
+        if($is_del_local){
+            unlink($filePath);
+        }
+        if ($err !== null) {
+            return ["err"=>1,"msg"=>$err,"data"=>""];
+        } else {
+            return ["err"=>0,"msg"=>"上传完成","data"=>cmf_get_image_url($ret['key'])];
+        }
+    }
+
+
 }
 }