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:29:38 +08:00
parent 306a8db668
commit 2e4d0485ac
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
internal/logic/file.go
View File

@ -91,13 +91,17 @@ func (f *File) Upload(req *dci.GetUploadUrlRequest) (res *dci.GetUploadUrlRespon
fmt.Printf("GetUploadUrl is : %+v\n", res) fmt.Printf("GetUploadUrl is : %+v\n", res)
fmt.Println("+++++++++++++++ GetUploadUrl =================") fmt.Println("+++++++++++++++ GetUploadUrl =================")
fmt.Println("====== =========== =================== 1 ===============")
if tea.ToString(getUploadUrlResponse.ResultCode) != "OK" { if tea.ToString(getUploadUrlResponse.ResultCode) != "OK" {
return res, errCommon.ReturnError(errors.New(res.ResultMsg), err.Error(), "获取授权访问OSS链接 错误:") return res, errCommon.ReturnError(errors.New(res.ResultMsg), err.Error(), "获取授权访问OSS链接 错误:")
} }
fmt.Println("====== =========== =================== 2 ===============")
if getUploadUrlResponse.Url == nil || getUploadUrlResponse.FileId == nil { if getUploadUrlResponse.Url == nil || getUploadUrlResponse.FileId == nil {
return res, errCommon.ReturnError(errors.New(res.ResultMsg), err.Error(), "获取授权访问OSS链接 错误:") return res, errCommon.ReturnError(errors.New(res.ResultMsg), err.Error(), "获取授权访问OSS链接 错误:")
} }
fmt.Println("====== =========== =================== 3 ===============")
code, result := utils.PutFromFileUrlWithStream(tea.ToString(res.Url), fileName, req.FileName) code, result := utils.PutFromFileUrlWithStream(tea.ToString(res.Url), fileName, req.FileName)
if code != 200 { if code != 200 {
return res, errCommon.ReturnError(errors.New(result), result, "上传文件 错误:") return res, errCommon.ReturnError(errors.New(result), result, "上传文件 错误:")