diff --git a/api/viid_client.go b/api/viid_client.go index 61ac7d4..7721265 100644 --- a/api/viid_client.go +++ b/api/viid_client.go @@ -189,12 +189,11 @@ func SubmitFailure(ctx context.Context, taskID int64, errorCode, errorMessage st return nil } -func UploadFileToOSS(ctx context.Context, uploadUrl string, data []byte, contentType string) error { +func UploadFileToOSS(ctx context.Context, uploadUrl string, data []byte) error { req, err := http.NewRequestWithContext(ctx, "PUT", uploadUrl, bytes.NewReader(data)) if err != nil { return err } - req.Header.Set("Content-Type", contentType) resp, err := GetUploadClient().Do(req) if err != nil { diff --git a/api/viid_upload.go b/api/viid_upload.go index f45ccc9..a106cf9 100644 --- a/api/viid_upload.go +++ b/api/viid_upload.go @@ -4,6 +4,7 @@ import ( "ZhenTuLocalPassiveAdapter/logger" "context" "fmt" + "go.uber.org/zap" "golang.org/x/sync/errgroup" ) @@ -25,7 +26,7 @@ func UploadFaceData(ctx context.Context, scenicId int64, deviceNo string, faceIm // Upload Face Image g.Go(func() error { if len(faceImg) > 0 { - if err := UploadFileToOSS(subCtx, uploadConfig.FaceUploadURL, faceImg, "image/jpeg"); err != nil { + if err := UploadFileToOSS(subCtx, uploadConfig.FaceUploadURL, faceImg); err != nil { return fmt.Errorf("upload face image failed: %w", err) } } @@ -35,7 +36,7 @@ func UploadFaceData(ctx context.Context, scenicId int64, deviceNo string, faceIm // Upload Thumbnail Image g.Go(func() error { if len(thumbImg) > 0 { - if err := UploadFileToOSS(subCtx, uploadConfig.ThumbnailUploadURL, thumbImg, "image/jpeg"); err != nil { + if err := UploadFileToOSS(subCtx, uploadConfig.ThumbnailUploadURL, thumbImg); err != nil { return fmt.Errorf("upload thumbnail image failed: %w", err) } } @@ -45,7 +46,7 @@ func UploadFaceData(ctx context.Context, scenicId int64, deviceNo string, faceIm // Upload Source Image g.Go(func() error { if len(srcImg) > 0 { - if err := UploadFileToOSS(subCtx, uploadConfig.SourceUploadURL, srcImg, "image/jpeg"); err != nil { + if err := UploadFileToOSS(subCtx, uploadConfig.SourceUploadURL, srcImg); err != nil { return fmt.Errorf("upload source image failed: %w", err) } }