git/wechat
1
0
Fork 0
mirror of https://github.com/silenceper/wechat.git synced 2026-03-01 00:35:26 +08:00
Code Issues Projects Releases Wiki Activity

add stream_upload_source

Browse Source
This commit is contained in:
_oah
2024-07-23 23:39:28 +08:00
parent 05ac7148d4
commit b47cbba92c
4 changed files with 73 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files
work/material/media.go
+13 -5
View File
@@ -2,7 +2,6 @@ package material
import (
"fmt"
"github.com/silenceper/wechat/v2/util"
)
@@ -59,7 +58,8 @@ func (r *Client) UploadImg(filename string) (*UploadImgResponse, error) {
// UploadTempFile 上传临时素材
// @see https://developer.work.weixin.qq.com/document/path/90253
// @mediaType 媒体文件类型，分别有图片（image）、语音（voice）、视频（video），普通文件（file）
func (r *Client) UploadTempFile(filename string, mediaType string) (*UploadTempFileResponse, error) {
// 临时素材一般都是存储在oss上的，可以直接传递url
func (r *Client) UploadTempFile(url string, mediaType string) (*UploadTempFileResponse, error) {
var (
accessToken string
err error
@@ -67,8 +67,12 @@ func (r *Client) UploadTempFile(filename string, mediaType string) (*UploadTempF
if accessToken, err = r.GetAccessToken(); err != nil {
return nil, err
}
filename, byteData, err := util.GetFileSourceByURL(url)
if err != nil {
return nil, err
}
var response []byte
if response, err = util.PostFile("media", filename, fmt.Sprintf(uploadTempFile, accessToken, mediaType)); err != nil {
if response, err = util.PostFileByStream("media", filename, fmt.Sprintf(uploadTempFile, accessToken, mediaType), byteData); err != nil {
return nil, err
}
result := &UploadTempFileResponse{}
@@ -80,7 +84,7 @@ func (r *Client) UploadTempFile(filename string, mediaType string) (*UploadTempF
// @see https://developer.work.weixin.qq.com/document/path/95098
// @mediaType 媒体文件类型，分别有图片（image）、视频（video）、普通文件（file）
// @attachment_type 附件类型，不同的附件类型用于不同的场景。1：朋友圈；2:商品图册
func (r *Client) UploadAttachment(filename string, mediaType string, attachmentType int) (*UploadAttachmentResponse, error) {
func (r *Client) UploadAttachment(url string, mediaType string, attachmentType int) (*UploadAttachmentResponse, error) {
var (
accessToken string
err error
@@ -88,8 +92,12 @@ func (r *Client) UploadAttachment(filename string, mediaType string, attachmentT
if accessToken, err = r.GetAccessToken(); err != nil {
return nil, err
}
filename, byteData, err := util.GetFileSourceByURL(url)
if err != nil {
return nil, err
}
var response []byte
if response, err = util.PostFile("media", filename, fmt.Sprintf(uploadAttachment, accessToken, mediaType, attachmentType)); err != nil {
if response, err = util.PostFileByStream("media", filename, fmt.Sprintf(uploadAttachment, accessToken, mediaType, attachmentType), byteData); err != nil {
return nil, err
}
result := &UploadAttachmentResponse{}