fix(oss): presigned multipart upload mismatch

pkg/filemanager/driver/oss/oss.go

@@ -66,10 +66,6 @@ type key int
 
 const (
 	chunkRetrySleep = time.Duration(5) * time.Second
-	uploadIdParam     = "uploadId"
-	partNumberParam   = "partNumber"
-	callbackParam     = "callback"
-	completeAllHeader = "x-oss-complete-all"
 	maxDeleteBatch  = 1000
 
 	// MultiPartUploadThreshold 服务端使用分片上传的阈值
@@ -530,6 +526,11 @@ func (handler *Driver) Token(ctx context.Context, uploadSession *fs.UploadSessio
 				UploadId:   imur.UploadId,
 				PartNumber: int32(c.Index() + 1),
 				Body:       chunk,
+				RequestCommon: oss.RequestCommon{
+					Headers: map[string]string{
+						"Content-Type": "application/octet-stream",
+					},
+				},
 			}, oss.PresignExpires(ttl))
 			if err != nil {
 				return err
@@ -548,9 +549,16 @@ func (handler *Driver) Token(ctx context.Context, uploadSession *fs.UploadSessio
 		Bucket:   &handler.policy.BucketName,
 		Key:      &file.Props.SavePath,
 		UploadId: imur.UploadId,
-		CompleteAll:     oss.Ptr("yes"),
-		ForbidOverwrite: oss.Ptr(strconv.FormatBool(true)),
-		Callback:        oss.Ptr(callbackPolicyEncoded),
+		RequestCommon: oss.RequestCommon{
+			Parameters: map[string]string{
+				"callback": callbackPolicyEncoded,
+			},
+			Headers: map[string]string{
+				"Content-Type":           "application/octet-stream",
+				"x-oss-complete-all":     "yes",
+				"x-oss-forbid-overwrite": "true",
+			},
+		},
 	}, oss.PresignExpires(ttl))
 	if err != nil {
 		return nil, err
@@ -562,6 +570,7 @@ func (handler *Driver) Token(ctx context.Context, uploadSession *fs.UploadSessio
 		CompleteURL: completeURL.URL,
 		SessionID:   uploadSession.Props.UploadSessionID,
 		ChunkSize:   handler.chunkSize,
+		Callback:    callbackPolicyEncoded,
 	}, nil
 }
 

pkg/filemanager/fs/fs.go

@@ -244,7 +244,7 @@ type (
 		UploadURLs     []string `json:"upload_urls,omitempty"`
 		Credential     string   `json:"credential,omitempty"`
 		UploadID       string   `json:"uploadID,omitempty"`
-		Callback       string   `json:"callback,omitempty"` // 回调地址
+		Callback       string   `json:"callback,omitempty"`
 		Uri            string   `json:"uri,omitempty"` // 存储路径
 		AccessKey      string   `json:"ak,omitempty"`
 		KeyTime        string   `json:"keyTime,omitempty"` // COS用有效期