fusen/fusenapi
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge branch 'develop' of gitee.com:fusenpack/fusenapi into develop

Browse Source
This commit is contained in:
laodaming 2023-11-21 15:47:14 +08:00
commit d2619efa56
1 changed files with 4 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
server/resource/internal/logic/resourcebackuplogic.go
View File

@ -7,7 +7,6 @@ import (
"fusenapi/utils/s3url_to_s3id" "fusenapi/utils/s3url_to_s3id"
"regexp" "regexp"
"strings" "strings"
"time"
"context" "context"
@ -140,13 +139,10 @@ func (l *ResourceBackupLogic) ResourceBackup(req *types.ResourceBackupReq, useri
upload.AliyunOSS.Endpoint = l.svcCtx.Config.AliyunOSS.Endpoint upload.AliyunOSS.Endpoint = l.svcCtx.Config.AliyunOSS.Endpoint
upload.AliyunOSS.BasePath = l.svcCtx.Config.AliyunOSS.BasePath upload.AliyunOSS.BasePath = l.svcCtx.Config.AliyunOSS.BasePath
for k, v := range urls { for k, v := range urls {
var resourceId = k err := upload.UploadFileByUrl(k, v, 1)
time.AfterFunc(time.Second*1, func() { if err != nil {
err := upload.UploadFileByUrl(resourceId, v, 2) l.Logger.Errorf("更新文件镜像备份失败, err: %v, key: %v, val:%v", err, k, v)
if err != nil { }
l.Logger.Errorf("更新文件镜像备份, err: %v, key: %v, val:%v", err, k, v)
}
})
} }
return resp.SetStatus(basic.CodeOK) return resp.SetStatus(basic.CodeOK)
} }