diff --git a/pkg/service/import/imageContentProcessor.go b/pkg/service/import/imageContentProcessor.go index 6007f3d..50b4fe5 100644 --- a/pkg/service/import/imageContentProcessor.go +++ b/pkg/service/import/imageContentProcessor.go @@ -585,34 +585,34 @@ func downloadAndUploadToBucket(imageURL string) (string, error) { return "", fmt.Errorf("读取本地文件失败: %v", err) } - //// 上传到桶 - //BOSClient, err := objstorage.NewOSS( - // os.Getenv(config.ConfigData.Oss.AccessKeyId), - // os.Getenv(config.ConfigData.Oss.AccessKeySecret), - // os.Getenv(config.ConfigData.Oss.Endpoint), - //) - //if BOSClient == nil { - // return "", fmt.Errorf("上传文件失败: %v", err) - //} - //_, err = BOSClient.PutObjectFromBytes(os.Getenv(config.ConfigData.Oss.BucketName), fileName, fileBytes) - //if err != nil { - // return "", fmt.Errorf("上传文件失败: %v", err) - //} - //url := fmt.Sprintf("%s/%s", os.Getenv(config.ConfigData.Oss.CdnHost), fileName) // 上传到桶 BOSClient, err := objstorage.NewOSS( - config.ConfigData.Oss.AccessKeyId, - config.ConfigData.Oss.AccessKeySecret, - config.ConfigData.Oss.Endpoint, + os.Getenv(config.ConfigData.Oss.AccessKeyId), + os.Getenv(config.ConfigData.Oss.AccessKeySecret), + os.Getenv(config.ConfigData.Oss.Endpoint), ) if BOSClient == nil { return "", fmt.Errorf("上传文件失败: %v", err) } - _, err = BOSClient.PutObjectFromBytes(config.ConfigData.Oss.BucketName, fileName, fileBytes) + _, err = BOSClient.PutObjectFromBytes(os.Getenv(config.ConfigData.Oss.BucketName), fileName, fileBytes) if err != nil { return "", fmt.Errorf("上传文件失败: %v", err) } - url := fmt.Sprintf("%s/%s", config.ConfigData.Oss.CdnHost, fileName) + url := fmt.Sprintf("%s/%s", os.Getenv(config.ConfigData.Oss.CdnHost), fileName) + // 上传到桶 + //BOSClient, err := objstorage.NewOSS( + // config.ConfigData.Oss.AccessKeyId, + // config.ConfigData.Oss.AccessKeySecret, + // config.ConfigData.Oss.Endpoint, + //) + //if BOSClient == nil { + // return "", fmt.Errorf("上传文件失败: %v", err) + //} + //_, err = BOSClient.PutObjectFromBytes(config.ConfigData.Oss.BucketName, fileName, fileBytes) + //if err != nil { + // return "", fmt.Errorf("上传文件失败: %v", err) + //} + //url := fmt.Sprintf("%s/%s", config.ConfigData.Oss.CdnHost, fileName) return url, nil }