url

controllers/file.go

 	})
 }
 
+func (c *BaseController) FileUploadForMatrial() (string, error) {
+	file, err := c.uploadFileToOSS("media")
+	if err != nil {
+		return "", err
+	}
+	return file, nil
+}
+
 func (c *BaseController) uploadFileToOSS(field string) (string, error) {
 	aliConf, ok := c.Configer[AliYunConf]
 	if !ok {

controllers/wechatimg/wechatimt.go

 package wechatimg
 
 import (
-	"errors"
 	"fmt"
 	"io"
 	"os"
 		fmt.Println("文件保存失败")
 		return
 	}
-	url, err := c.FileUploadForMatrial()
+	url, err := c.BaseController.FileUploadForMatrial()
 	if err != nil {
 		c.ResponseError(err)
 	}
 	}
 	c.ResponseJSON("删除成功")
 }
-
-func (c *BaseController) FileUploadForMatrial() (string, error) {
-	file, err := c.uploadFileToOSS("media")
-	if err != nil {
-		return nil, err
-	}
-	return file, nil
-}
-
-func (c *BaseController) uploadFileToOSS(field string) (string, error) {
-	aliConf, ok := c.Configer[AliYunConf]
-	if !ok {
-		return "", errors.New("没有找到阿里云相关配置")
-	}
-
-	endpoint := aliConf.String("oss::Endpoint")
-	accessKeyID := aliConf.String("oss::AccessKeyId")
-	accessKeySecret := aliConf.String("oss::AccessKeySecret")
-	bucket := aliConf.String("oss::Bucket")
-
-	aliCli, err := utils.GetOssClient(endpoint, accessKeyID, accessKeySecret)
-	if err != nil {
-		return "", err
-	}
-
-	fNameExtra := strconv.FormatInt(time.Now().Unix(), 10)
-
-	fileURL, err := utils.UploadFileToBucket(aliCli, c.Ctx.Request, bucket, field, fNameExtra)
-	if err != nil {
-		return "", err
-	}
-
-	return fileURL, nil
-}