git/wechat
1
0
Fork 0
mirror of https://github.com/silenceper/wechat.git synced 2026-02-11 16:22:26 +08:00
Code Issues Projects Releases Wiki Activity

快捷获取公众号订阅消息对象 (#435)

Browse Source 
* 快捷获取公众号订阅消息对象

* fix: typo subscrib -> subscribe
This commit is contained in:
ZmJ
2021-08-16 14:39:44 +08:00
committed by GitHub
parent 13611466f3
commit fc1fc7e84e
2 changed files with 18 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
officialaccount/message/subscribe.go
View File

@@ -12,14 +12,14 @@ const (
subscribeTemplateListURL = "https://api.weixin.qq.com/wxaapi/newtmpl/gettemplate" subscribeTemplateListURL = "https://api.weixin.qq.com/wxaapi/newtmpl/gettemplate"
) )
//Subscrib 订阅消息 //Subscribe 订阅消息
type Subscrib struct { type Subscribe struct {
*context.Context *context.Context
} }
//NewSubscrib 实例化 //NewSubscribe 实例化
func NewSubscrib(context *context.Context) *Subscrib { func NewSubscribe(context *context.Context) *Subscribe {
tpl := new(Subscrib) tpl := new(Subscribe)
tpl.Context = context tpl.Context = context
return tpl return tpl
} }
@@ -42,7 +42,7 @@ type SubscribeDataItem struct {
} }
//Send 发送订阅消息 //Send 发送订阅消息
func (tpl *Subscrib) Send(msg *SubscribeMessage) (err error) { func (tpl *Subscribe) Send(msg *SubscribeMessage) (err error) {
var accessToken string var accessToken string
accessToken, err = tpl.GetAccessToken() accessToken, err = tpl.GetAccessToken()
if err != nil { if err != nil {
@@ -53,11 +53,11 @@ func (tpl *Subscrib) Send(msg *SubscribeMessage) (err error) {
if err != nil { if err != nil {
return return
} }
return util.DecodeWithCommonError(response, "SendSubscribMessage") return util.DecodeWithCommonError(response, "SendSubscribeMessage")
} }
// PrivateSubscribItem 私有订阅消息模板 // PrivateSubscribeItem 私有订阅消息模板
type PrivateSubscribItem struct { type PrivateSubscribeItem struct {
PriTmplID string `json:"priTmplId"` // 添加至帐号下的模板 id，发送订阅通知时所需 PriTmplID string `json:"priTmplId"` // 添加至帐号下的模板 id，发送订阅通知时所需
Title string `json:"title"` //模版标题 Title string `json:"title"` //模版标题
Content string `json:"content"` //模版内容 Content string `json:"content"` //模版内容
@@ -65,13 +65,13 @@ type PrivateSubscribItem struct {
SubType int `json:"type"` //模版类型，2 为一次性订阅，3 为长期订阅 SubType int `json:"type"` //模版类型，2 为一次性订阅，3 为长期订阅
} }
type resPrivateSubscribList struct { type resPrivateSubscribeList struct {
util.CommonError util.CommonError
SubscriptionList []*PrivateSubscribItem `json:"data"` SubscriptionList []*PrivateSubscribeItem `json:"data"`
} }
//List 获取私有订阅消息模板列表 //List 获取私有订阅消息模板列表
func (tpl *Subscrib) List() (templateList []*PrivateSubscribItem, err error) { func (tpl *Subscribe) List() (templateList []*PrivateSubscribeItem, err error) {
var accessToken string var accessToken string
accessToken, err = tpl.GetAccessToken() accessToken, err = tpl.GetAccessToken()
if err != nil { if err != nil {
@@ -83,7 +83,7 @@ func (tpl *Subscrib) List() (templateList []*PrivateSubscribItem, err error) {
if err != nil { if err != nil {
return return
} }
var res resPrivateSubscribList var res resPrivateSubscribeList
err = util.DecodeWithError(response, &res, "ListSubscription") err = util.DecodeWithError(response, &res, "ListSubscription")
if err != nil { if err != nil {
return return

5
officialaccount/officialaccount.go
View File

@@ -120,3 +120,8 @@ func (officialAccount *OfficialAccount) GetDataCube() *datacube.DataCube {
func (officialAccount *OfficialAccount) GetOCR() *ocr.OCR { func (officialAccount *OfficialAccount) GetOCR() *ocr.OCR {
return ocr.NewOCR(officialAccount.ctx) return ocr.NewOCR(officialAccount.ctx)
} }
//GetSubscribe 公众号订阅消息
func (officialAccount *OfficialAccount) GetSubscribe() *message.Subscribe {
return message.NewSubscribe(officialAccount.ctx)
}