直传oss配置接口

app/controller/oss.ts

+import { Controller } from 'egg';
+
+const gmt_iso8601 = (time: any) => {
+  const date = new Date(time * 1000);
+  const expireTime = date.toISOString();
+  const pos = expireTime.indexOf('.');
+  const expiration = expireTime.substring(0, pos);
+  return expiration + 'Z';
+};
+
+export default class OssController extends Controller {
+  async getSignature() {
+    const { ctx } = this;
+
+    const date = parseInt(`${Date.now() / 1000}`, 10);
+    const expire = 30;
+    const end = (date + expire);
+    const expiration = gmt_iso8601(end);
+    const json = JSON.stringify({
+      expiration,
+      conditions: [
+        [ 'content-length-range', 0, 500 * 1024 * 1024 ], // 设置上传文件的大小限制,5mb
+      ],
+    });
+    const policy = new Buffer(json).toString('base64');
+    const signature = ctx.oss.get('media').signature(policy);
+    ctx.success({ res: { policy, signature, OSSAccessKeyId: 'LTAIRRW7SbrqKUIJ' } });
+  }
+}

app/router.ts

@@ -8,6 +8,9 @@ export default (app: Application) => {
   router.get('/api/session/menus', controller.user.index.menus);
   router.post('/api/upload/media', controller.util.uploadMedia);
 
+  // oss直传配置
+  router.get('/api/upload/oss/config', controller.oss.getSignature);
+
   // 新房房源管理
   router.get('/api/estate/list', controller.mpEstate.list.list);
   router.get('/api/estate/:id', controller.mpEstate.list.show);

app/service/file.ts

@@ -169,6 +169,45 @@ export default class FileService extends Service {
     ctx.throw(500, 'oss upload failed！');
   }
 
+  async saveLocalToCDN(option?: any, stream?: any) {
+    const { ctx } = this;
+
+    try {
+      const localPathObj = await this.saveToLocal(option, stream);
+      const localPath = localPathObj.url;
+      const localFilName = localPathObj.fileName;
+
+      const ext = path.extname(localFilName).toLocaleLowerCase();
+      const ossFilename = 'zeus/' + moment().format('YYYYMMDD') + '/' + uuid.v4() + ext;
+      let oss_url: any;
+      let url: any;
+      const progress = (p: any, _checkpoint: any) => {
+        console.log(p); // Object的上传进度。
+        console.log(_checkpoint); // 分片上传的断点信息。
+      };
+      try {
+        const result = await ctx.oss.get('media').multipartUpload(ossFilename, localPath, {
+          progress,
+        });
+        oss_url = result.url;
+        url = `https://r.51gjj.com/${ossFilename}`;
+      } catch (e) {
+        ctx.throw(500, e);
+      }
+
+      if (url) {
+        return {
+          fileName: localFilName,
+          url,
+          oss_url,
+        };
+      }
+      ctx.throw(500, 'oss upload failed！');
+    } catch (e) {
+      ctx.throw(500, e);
+    }
+  }
+
   async saveToDB({ fileName, url }: any) {
     const { ctx } = this;
     const row = await ctx.model.File.create({

typings/app/controller/index.d.ts

@@ -2,6 +2,7 @@
 // Do not modify this file!!!!!!!!!
 
 import 'egg';
+import ExportOss from '../../../app/controller/oss';
 import ExportUtil from '../../../app/controller/util';
 import ExportMpEstateAppointment from '../../../app/controller/mpEstate/appointment';
 import ExportMpEstateList from '../../../app/controller/mpEstate/list';
@@ -12,6 +13,7 @@ import ExportUserIndex from '../../../app/controller/user/index';
 
 declare module 'egg' {
   interface IController {
+    oss: ExportOss;
     util: ExportUtil;
     mpEstate: {
       appointment: ExportMpEstateAppointment;