聊天模块增加视频上传

Author: linyiyuan

app/Controller/Laboratory/UploadController.php

@@ -117,4 +117,38 @@ public function uploadFile()
         $uploadResult = UploadService::getInstance()->uploadFile($params['file'], $params['savePath'], $params['messageId']);
         return $this->success($uploadResult);
     }
+
+    /**
+     * 上传文件
+     * @RequestMapping(path="upload_video", methods="post")
+     * @Middlewares({
+     *     @Middleware(RequestMiddleware::class),
+     * })
+     * @return \Psr\Http\Message\ResponseInterface
+     * @throws \League\Flysystem\FileExistsException
+     */
+    public function uploadVideo()
+    {
+        $params = [
+            'savePath' => $this->request->input('savePath') ?? '',
+            'file' => $this->request->file('file'),
+            'messageId' => $this->request->input('messageId') ?? ''
+        ];
+        //配置验证
+        $rules = [
+            'savePath' => 'required',
+            'file' => 'required|file',
+            'messageId' => 'required ',
+        ];
+        $message = [
+            'savePath.required' => '[savePath]缺失',
+            'file.required' => '[file]缺失',
+            'messageId.required' => '[messageId]缺失',
+            'file.file' => '[file] 参数必须为文件类型',
+        ];
+        $this->verifyParams($params, $rules, $message);
+
+        $uploadResult = UploadService::getInstance()->uploadVideo($params['file'], $params['savePath'], $params['messageId']);
+        return $this->success($uploadResult);
+    }
 }

app/Service/Laboratory/UploadService.php

@@ -129,4 +129,42 @@ public function uploadFile(object $file, string $savePath = '', string $messageI
             'messageId' => $messageId,
         ];
     }
+
+    /**
+     * 上传视频文件
+     * @param object $file
+     * @param string $savePath
+     * @param string $messageId
+     * @return array
+     * @throws \League\Flysystem\FileExistsException
+     */
+    public function uploadVideo(object $file, string $savePath = '', string $messageId = '') : array
+    {
+        if ($file->getSize() > 20971520) $this->throwExp(UploadCode::ERR_UPLOAD_SIZE, '上传文件不能超过20M');
+        //得到上传文件的后缀
+        $fileExt = getExtByFile($file->getClientFilename());
+        if (!in_array($fileExt, ['mp4', 'avi', 'mov', 'rmvb', 'flv', '3GP', 'FLV', 'WMV'])) $this->throwExp(UploadCode::ERR_UPLOAD_TYPE, '上传文件必须为视频文件');
+
+        //拼接得到文件名以及对应路径
+        $fileName =  md5(uniqid())  . '.' . $fileExt;
+        $uploadPath = $savePath . '/' . $fileName;
+
+        //外网访问的路径
+        $fileUrl = env('OSS_URL') . $uploadPath;
+
+        $stream = fopen($file->getRealPath(), 'r+');
+        $this->filesystem->writeStream(
+            $uploadPath,
+            $stream
+        );
+        if (is_resource($stream)) {
+            fclose($stream);
+        }
+        return [
+            'fileName' => $fileName,
+            'fileExt' => $fileExt,
+            'url' => $fileUrl,
+            'messageId' => $messageId,
+        ];
+    }
 }