hongze_api/services/oss.go

package services

import (
	"github.com/aliyun/aliyun-oss-go-sdk/oss"
	"time"

	"hongze/hongze_api/utils"
)

/*
上传demo
func init() {
	fmt.Println("start")
	randStr := utils.GetRandStringNoSpecialChar(28)
	fileName :=  randStr + ".jpg"
	fmt.Println("fileName:",fileName)
	fpath:="./1.png"
	resourceUrl,err:=UploadAliyun(fileName,fpath)
	if err!=nil {
		fmt.Println("UploadAliyun Err:",err.Error())
		return
	}
	fmt.Println("resourceUrl:",resourceUrl)
	fmt.Println("end")
}
*/

//图片上传到阿里云
func UploadAliyun(filename, filepath string) (string,error) {
	client, err := oss.New(utils.Endpoint, utils.AccessKeyId, utils.AccessKeySecret)
	if err != nil {
		return "1",err
	}
	bucket, err := client.Bucket(utils.Bucketname)
	if err != nil {
		return "2",err
	}
	path := utils.Upload_dir + time.Now().Format("200601/20060102/")
	path += filename
	err = bucket.PutObjectFromFile(path, filepath)
	if err != nil {
		return "3",err
	}
	path = utils.Imghost + path
	return path,err
}


//音频上传到阿里云
func UploadAudioAliyun(filename, filepath string) (string,error) {
	client, err := oss.New(utils.Endpoint, utils.AccessKeyId, utils.AccessKeySecret)
	if err != nil {
		return "1",err
	}
	bucket, err := client.Bucket(utils.Bucketname)
	if err != nil {
		return "2",err
	}
	path := utils.Upload_Audio_Dir + time.Now().Format("200601/20060102/")
	path += filename
	err = bucket.PutObjectFromFile(path, filepath)
	if err != nil {
		return "3",err
	}
	path = utils.Imghost + path
	return path,err
}