chain/chain-dci
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

修改
All checks were successful
continuous-integration/drone/push Build is passing
Details

Browse Source
This commit is contained in:
jhc 2023-12-13 13:16:33 +08:00
parent b7b43438b5
commit 8011895c88
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
internal/logic/file.go
View File

@ -7,6 +7,7 @@ import (
"chain-dci/pkg/msg" "chain-dci/pkg/msg"
"chain-dci/pkg/utils" "chain-dci/pkg/utils"
"encoding/base64" "encoding/base64"
"errors"
"fmt" "fmt"
"github.com/alibabacloud-go/tea/tea" "github.com/alibabacloud-go/tea/tea"
bccrClient "github.com/antchain-openapi-sdk-go/bccr/client" bccrClient "github.com/antchain-openapi-sdk-go/bccr/client"
@ -91,10 +92,10 @@ func (f *File) Upload(req *dci.GetUploadUrlRequest) (res *dci.GetUploadUrlRespon
fmt.Println("+++++++++++++++ GetUploadUrl =================") fmt.Println("+++++++++++++++ GetUploadUrl =================")
if tea.ToString(getUploadUrlResponse.ResultCode) != "OK" { if tea.ToString(getUploadUrlResponse.ResultCode) != "OK" {
return res, errCommon.ReturnError(err, err.Error(), "获取授权访问OSS链接 错误:") return res, errCommon.ReturnError(errors.New(res.ResultMsg), err.Error(), "获取授权访问OSS链接 错误:")
} }
if tea.ToString(getUploadUrlResponse.Url) == "" || tea.ToString(getUploadUrlResponse.FileId) == "" { if tea.ToString(getUploadUrlResponse.Url) == "" || tea.ToString(getUploadUrlResponse.FileId) == "" {
return res, errCommon.ReturnError(err, err.Error(), "获取授权访问OSS链接 错误:") return res, errCommon.ReturnError(errors.New(res.ResultMsg), err.Error(), "获取授权访问OSS链接 错误:")
} }
code, result := utils.PutFromFileUrlWithStream(tea.ToString(res.Url), fileName, req.FileName) code, result := utils.PutFromFileUrlWithStream(tea.ToString(res.Url), fileName, req.FileName)