opms_backend/opms_libary/plugin/wechat/mp/material/material.go

package material

import (
	"dashoo.cn/opms_libary/plugin/wechat/context"
	"dashoo.cn/opms_libary/plugin/wechat/mp/base"
	"encoding/json"
)

const (
	addNewsURL     = "https://api.weixin.qq.com/cgi-bin/material/add_news"
	addMaterialURL = "https://api.weixin.qq.com/cgi-bin/material/add_material"
	delMaterialURL = "https://api.weixin.qq.com/cgi-bin/material/del_material"
)

//Material 素材管理
type Material struct {
	base.MpBase
}

//NewMaterial init
func NewMaterial(context *context.Context) *Material {
	material := new(Material)
	material.Context = context
	return material
}

//Article 永久图文素材
type Article struct {
	Title            string `json:"title"`
	ThumbMediaID     string `json:"thumb_media_id"`
	Author           string `json:"author"`
	Digest           string `json:"digest"`
	ShowCoverPic     int    `json:"show_cover_pic"`
	Content          string `json:"content"`
	ContentSourceURL string `json:"content_source_url"`
}

//reqArticles 永久性图文素材请求信息
type reqArticles struct {
	Articles []*Article `json:"articles"`
}

//resArticles 永久性图文素材返回结果
type resArticles struct {
	context.WxError

	MediaID string `json:"media_id"`
}

//AddNews 新增永久图文素材
func (material *Material) AddNews(articles []*Article) (mediaID string, err error) {
	req := &reqArticles{articles}

	responseBytes, err := material.HTTPPostJSONWithAccessToken(addNewsURL, req)
	if err != nil {
		return
	}

	var res resArticles
	err = json.Unmarshal(responseBytes, res)
	if err != nil {
		return
	}
	mediaID = res.MediaID
	return
}

//resAddMaterial 永久性素材上传返回的结果
type resAddMaterial struct {
	context.WxError

	MediaID string `json:"media_id"`
	URL     string `json:"url"`
}

//AddMaterial 上传永久性素材（处理视频需要单独上传）
func (material *Material) AddMaterial(mediaType MediaType, filename string) (mediaID string, url string, err error) {
	//if mediaType == MediaTypeVideo {
	//	err = errors.New("永久视频素材上传使用 AddVideo 方法")
	//}
	//var accessToken string
	//accessToken, err = material.GetAccessToken()
	//if err != nil {
	//	return
	//}
	//
	//uri := fmt.Sprintf("%s?access_token=%s&type=%s", addMaterialURL, accessToken, mediaType)
	//var response []byte
	//response, err = util.PostFile("media", filename, uri)
	//if err != nil {
	//	return
	//}
	//var resMaterial resAddMaterial
	//err = json.Unmarshal(response, &resMaterial)
	//if err != nil {
	//	return
	//}
	//if resMaterial.Code != 0 {
	//	err = fmt.Errorf("AddMaterial error : errcode=%v , errmsg=%v", resMaterial.Code, resMaterial.Msg)
	//	return
	//}
	//mediaID = resMaterial.MediaID
	//url = resMaterial.URL
	return
}

type reqVideo struct {
	Title        string `json:"title"`
	Introduction string `json:"introduction"`
}

//AddVideo 永久视频素材文件上传
func (material *Material) AddVideo(filename, title, introduction string) (mediaID string, url string, err error) {
	//var accessToken string
	//accessToken, err = material.GetAccessToken()
	//if err != nil {
	//	return
	//}
	//
	//uri := fmt.Sprintf("%s?access_token=%s&type=video", addMaterialURL, accessToken)
	//
	//videoDesc := &reqVideo{
	//	Title:        title,
	//	Introduction: introduction,
	//}
	//var fieldValue []byte
	//fieldValue, err = json.Marshal(videoDesc)
	//if err != nil {
	//	return
	//}
	//
	//fields := []util.MultipartFormField{
	//	{
	//		IsFile:    true,
	//		Fieldname: "video",
	//		Filename:  filename,
	//	},
	//	{
	//		IsFile:    true,
	//		Fieldname: "description",
	//		Value:     fieldValue,
	//	},
	//}
	//
	//var response []byte
	//response, err = util.PostMultipartForm(fields, uri)
	//
	//
	//if err != nil {
	//	return
	//}
	//
	//var resMaterial resAddMaterial
	//err = json.Unmarshal(response, &resMaterial)
	//if err != nil {
	//	return
	//}
	//if resMaterial.Code != 0 {
	//	err = fmt.Errorf("AddMaterial error : errcode=%v , errmsg=%v", resMaterial.Code, resMaterial.Msg)
	//	return
	//}
	//mediaID = resMaterial.MediaID
	//url = resMaterial.URL
	return
}

type reqDeleteMaterial struct {
	MediaID string `json:"media_id"`
}

//DeleteMaterial 删除永久素材
func (material *Material) DeleteMaterial(mediaID string) error {
	_, err := material.HTTPPostJSONWithAccessToken(delMaterialURL, reqDeleteMaterial{mediaID})
	if err != nil {
		return err
	}
	return nil
}