diff --git a/routers/repo/attachment.go b/routers/repo/attachment.go index 5d678cd23..da950eb31 100755 --- a/routers/repo/attachment.go +++ b/routers/repo/attachment.go @@ -669,29 +669,37 @@ func GetSuccessChunks(ctx *context.Context) { modelname := "" if dbmodeluuid != modeluuid { log.Info("The file has uploaded.fileChunk.ObjectName=" + fileChunk.ObjectName + " typeCloudBrain=" + fmt.Sprint(typeCloudBrain)) - model, err := models.QueryModelById(dbmodeluuid) - if err == nil { - modelname = model.Name + srcObjectName := fileChunk.ObjectName + var isExist bool + if dbmodeluuid != "" { + model, err := models.QueryModelById(dbmodeluuid) + if err == nil && model != nil { + modelname = model.Name + } } //copy - srcObjectName := fileChunk.ObjectName destObjectName := getObjectName(fileName, modeluuid) - var isExist bool - if typeCloudBrain == int(models.TypeCloudBrainOne) { - log.Info("minio copy..") + if typeCloudBrain == models.TypeCloudBrainOne { bucketName := setting.Attachment.Minio.Bucket + log.Info("minio copy..srcObjectName=" + srcObjectName + " bucketName=" + bucketName) if storage.MinioGetFilesSize(bucketName, []string{destObjectName}) > 0 { isExist = true } else { + if srcObjectName == "" { + srcObjectName = getMinioInitObjectName("", fileChunk.UUID, "", "") + } storage.MinioCopyAFile(bucketName, srcObjectName, bucketName, destObjectName) } } else { - log.Info("obs copy..") bucketName := setting.Bucket + log.Info("obs copy..srcObjectName=" + srcObjectName + " bucketName=" + bucketName) if storage.ObsGetFilesSize(bucketName, []string{destObjectName}) > 0 { isExist = true } else { - log.Info("obs copy............") + if srcObjectName == "" { + srcObjectName = getOBSInitObjectName("", fileChunk.UUID, "", attach.Name) + } + log.Info("obs copy..srcObjectName=" + srcObjectName + " bucketName=" + bucketName) storage.ObsCopyFile(bucketName, srcObjectName, bucketName, destObjectName) } }