:zap:优化

file.go

@@ -1,6 +1,7 @@
 package go_aliyun_oss
 
 import (
+	"errors"
 	"fmt"
 	uuid "github.com/satori/go.uuid"
 	"io/ioutil"
@@ -35,7 +36,7 @@ func (ossFile *OssFile) FileTypeTransForm() (*OssFile,error) {
 		ossFile.FileByte, err = ioutil.ReadAll(ossFile.File.(*os.File))
 
 		if err != nil {
-			panic("read os type file failed:" + err.Error())
+			return nil, errors.New("read os type file failed:" + err.Error())
 		}
 
 		_, ossFile.FileOldName = filepath.Split(ossFile.File.(*os.File).Name())
@@ -55,7 +56,7 @@ func (ossFile *OssFile) FileTypeTransForm() (*OssFile,error) {
 		ossFile.FileByte, err = ioutil.ReadAll(fileResources)
 
 		if err != nil {
-			panic("read multipart file failed:" + err.Error())
+			return nil, errors.New("read multipart file failed:" + err.Error())
 		}
 
 		ossFile.FileOldName = ossFile.File.(*multipart.FileHeader).Filename
@@ -66,7 +67,7 @@ func (ossFile *OssFile) FileTypeTransForm() (*OssFile,error) {
 		newFile, err := os.Open(ossFile.File.(string))
 
 		if err != nil {
-			panic("open file path failed:" + err.Error())
+			return nil, errors.New("open file path failed:" + err.Error())
 		}
 
 		defer newFile.Close()
@@ -92,7 +93,7 @@ func (ossFile *OssFile) FileTypeTransForm() (*OssFile,error) {
 
 	default:
 		fmt.Println(reflect.TypeOf(ossFile.File))
-		panic("file type is not support" )
+		return nil, errors.New("file type is not support")
 	}
 
 	ossFile.GetFileType()

go.mod

@@ -3,7 +3,7 @@ module github.com/cowardmrx/go_aliyun_oss
 go 1.15
 
 require (
-	github.com/aliyun/aliyun-oss-go-sdk v2.1.5+incompatible
+	github.com/aliyun/aliyun-oss-go-sdk v2.2.5+incompatible
 	github.com/baiyubin/aliyun-sts-go-sdk v0.0.0-20180326062324-cfa1a18b161f // indirect
 	github.com/satori/go.uuid v1.2.0
 	golang.org/x/time v0.0.0-20200630173020-3af7569d3a1e // indirect

go.sum

@@ -1,5 +1,7 @@
 github.com/aliyun/aliyun-oss-go-sdk v2.1.5+incompatible h1:v5yDfjkRY/kOxu05gkh0/D/2wYxbTFCoTr3JqFI0FLE=
 github.com/aliyun/aliyun-oss-go-sdk v2.1.5+incompatible/go.mod h1:T/Aws4fEfogEE9v+HPhhw+CntffsBHJ8nXQCwKr0/g8=
+github.com/aliyun/aliyun-oss-go-sdk v2.2.5+incompatible h1:QoRMR0TCctLDqBCMyOu1eXdZyMw3F7uGA9qPn2J4+R8=
+github.com/aliyun/aliyun-oss-go-sdk v2.2.5+incompatible/go.mod h1:T/Aws4fEfogEE9v+HPhhw+CntffsBHJ8nXQCwKr0/g8=
 github.com/baiyubin/aliyun-sts-go-sdk v0.0.0-20180326062324-cfa1a18b161f h1:ZNv7On9kyUzm7fvRZumSyy/IUiSC7AzL0I1jKKtwooA=
 github.com/baiyubin/aliyun-sts-go-sdk v0.0.0-20180326062324-cfa1a18b161f/go.mod h1:AuiFmCCPBSrqvVMvuqFuk0qogytodnVFVSN5CeJB8Gc=
 github.com/kr/pretty v0.2.1 h1:Fmg33tUaq4/8ym9TJN1x7sLJnHVwhP33CNkpYV/7rwI=

oss_operation.go

@@ -2,6 +2,7 @@ package go_aliyun_oss
 
 import (
 	"bytes"
+	"errors"
 	"github.com/aliyun/aliyun-oss-go-sdk/oss"
 )
 
@@ -22,7 +23,7 @@ type ossResponse struct {
 // params:  ossDir string  `oss dir [要推送到的oss目录]`  example: test/20201121/
 // params:  file interface `upload file resource [文件资源]`
 // return string  `oss file accessible uri [可访问地址]`
-func (client *AliOssClient) Put(ossDir string, file interface{},fileType string) *ossResponse {
+func (client *AliOssClient) Put(ossDir string, file interface{}, fileType string) (*ossResponse, error) {
 	//file to []byte
 	//文件转字节流
 	uploadFile := &OssFile{
@@ -33,7 +34,7 @@ func (client *AliOssClient) Put(ossDir string, file interface{},fileType string)
 	ossFile, err := uploadFile.FileTypeTransForm()
 
 	if err != nil {
-		panic("transfer file failed" + err.Error())
+		return nil, err
 	}
 
 	// 最终的oss名称
@@ -58,7 +59,7 @@ func (client *AliOssClient) Put(ossDir string, file interface{},fileType string)
 	err = client.Client.PutObject(ossPath, bytes.NewReader(ossFile.FileByte))
 
 	if err != nil {
-		panic("put file to oss failed:" + err.Error())
+		return nil, errors.New("put file to oss failed:" + err.Error())
 	}
 
 	return &ossResponse{
@@ -66,59 +67,59 @@ func (client *AliOssClient) Put(ossDir string, file interface{},fileType string)
 		LongPath:  client.Domain + "/" + ossPath,
 		ShortPath: ossPath,
 		FileName:  ossFileName,
-	}
+	}, nil
 }
 
 // HasExists 校验文件是否已经存在
 // check file already exists in oss server
 // params: ossFilePath	string 	`file oss path [文件的oss的路径]`
-func (client *AliOssClient) HasExists(ossFilePath string) bool {
+func (client *AliOssClient) HasExists(ossFilePath string) (bool, error) {
 
 	//oss check fun
 	isExists, err := client.Client.IsObjectExist(ossFilePath)
 
 	if err != nil {
-		panic("check file in oss is exists failed:" + err.Error())
+		return false, errors.New("check file in oss is exists failed:" + err.Error())
 	}
 
-	return isExists
+	return isExists, nil
 }
 
 // Delete 删除文件-单文件删除
 // delete one file in oss
 // params ossPath string `file oss path [文件的oss路径]`
 // return bool
-func (client *AliOssClient) Delete(ossFilePath string) bool {
+func (client *AliOssClient) Delete(ossFilePath string) (bool, error) {
 
 	//oss delete one file fun
 	err := client.Client.DeleteObject(ossFilePath)
 
 	if err != nil {
-		panic("delete file "+ ossFilePath +" failed:" + err.Error())
+		return false, errors.New("delete file " + ossFilePath + " failed:" + err.Error())
 	}
 
-	return true
+	return true, nil
 }
 
 // DeleteMore 删除文件-多文件删除
 // delete more file in oss
 // params ossPath []string `file oss path array [文件的oss路径数组]`
 // return bool
-func (client *AliOssClient) DeleteMore(ossFilePath []string) bool {
+func (client *AliOssClient) DeleteMore(ossFilePath []string) (bool, error) {
 	//oss delete more file fun
 	_, err := client.Client.DeleteObjects(ossFilePath)
 
 	if err != nil {
-		panic("delete more file in oss failed:" + err.Error())
+		return false, errors.New("delete more file in oss failed:" + err.Error())
 	}
 
-	return true
+	return true, nil
 }
 
 // GetTemporaryUrl 获取文件临时地址
 // path string 文件路径
 // expireInSecond int64 多久后过期 单位: 秒，默认 60
-func (client *AliOssClient) GetTemporaryUrl(path string,expireInSecond int64) string {
+func (client *AliOssClient) GetTemporaryUrl(path string, expireInSecond int64) (string, error) {
 
 	var expireTime int64
 
@@ -131,9 +132,9 @@ func (client *AliOssClient) GetTemporaryUrl(path string,expireInSecond int64) st
 	signUrl, err := client.Client.SignURL(path, oss.HTTPGet, expireTime)
 
 	if err != nil {
-		panic("generate sign url failed:" + err.Error())
+		return "", errors.New("generate sign url failed:" + err.Error())
 	}
 
-	return signUrl
+	return signUrl, nil
 
 }

oss_test.go

@@ -35,12 +35,10 @@ func TestPutBase64(t *testing.T)  {
 	// 读取base
 	file, _ := ioutil.ReadFile("./File/3HaqWaOzJWD86DDvZD9Pmn9VUEOBOBbuWackGOXb (2).jpeg")
 
-
 	fileStr := base64.StdEncoding.EncodeToString(file)
 
 	bat, _ := base64.StdEncoding.DecodeString(fileStr)
 
-
 	uri := client.Put("logo/", bat, ".png")
 	//
 	fmt.Println(uri)
@@ -96,7 +94,7 @@ func TestAliOssClient_DeleteMore(t *testing.T) {
 
 func TestAliOssClient_GetTemporaryUrl(t *testing.T) {
 	ossConfig := &AliOssConfig{
-		EndPoint: "",
+		EndPoint:        "https://oss-cn-hangzhou.aliyuncs.com",
 		AccessKeyId:     "",
 		AccessKeySecret: "",
 		BucketName:      "",
@@ -104,8 +102,7 @@ func TestAliOssClient_GetTemporaryUrl(t *testing.T) {
 
 	client := ossConfig.CreateOssConnect()
 
-	singUrl := client.GetTemporaryUrl("logo/8497b913-2a79-58a1-984b-c25827f8212e.png",180)
+	singUrl := client.GetTemporaryUrl("", 180)
 
 	fmt.Println(singUrl)
 }
-