59 lines
1.8 KiB
Go
59 lines
1.8 KiB
Go
|
package ability305
|
||
|
|
|
||
|
|
import (
|
||
|
|
"errors"
|
||
|
|
"log"
|
||
|
|
"repository.lenntc.com/lenntc/third-platform-sdk/sdk/fliggysdk"
|
||
|
|
"repository.lenntc.com/lenntc/third-platform-sdk/sdk/fliggysdk/ability305/request"
|
||
|
|
"repository.lenntc.com/lenntc/third-platform-sdk/sdk/fliggysdk/ability305/response"
|
||
|
|
"repository.lenntc.com/lenntc/third-platform-sdk/sdk/fliggysdk/util"
|
||
|
|
)
|
||
|
|
|
||
|
|
type Ability305 struct {
|
||
|
|
Client *fliggysdk.TopClient
|
||
|
|
}
|
||
|
|
|
||
|
|
func NewAbility305(client *fliggysdk.TopClient) *Ability305 {
|
||
|
|
return &Ability305{client}
|
||
|
|
}
|
||
|
|
|
||
|
|
/*
|
||
|
|
获取消息队列积压情况
|
||
|
|
*/
|
||
|
|
func (ability *Ability305) TaobaoTmcQueueGet(req *request.TaobaoTmcQueueGetRequest) (*response.TaobaoTmcQueueGetResponse, error) {
|
||
|
|
if ability.Client == nil {
|
||
|
|
return nil, errors.New("Ability305 topClient is nil")
|
||
|
|
}
|
||
|
|
var jsonStr, err = ability.Client.Execute("taobao.tmc.queue.get", req.ToMap(), req.ToFileMap())
|
||
|
|
var respStruct = response.TaobaoTmcQueueGetResponse{}
|
||
|
|
if err != nil {
|
||
|
|
log.Println("taobaoTmcQueueGet error", err)
|
||
|
|
return &respStruct, err
|
||
|
|
}
|
||
|
|
err = util.HandleJsonResponse(jsonStr, &respStruct)
|
||
|
|
if respStruct.Body == "" || len(respStruct.Body) == 0 {
|
||
|
|
respStruct.Body = jsonStr
|
||
|
|
}
|
||
|
|
return &respStruct, err
|
||
|
|
}
|
||
|
|
|
||
|
|
/*
|
||
|
|
获取用户开通的topic列表
|
||
|
|
*/
|
||
|
|
func (ability *Ability305) TaobaoTmcUserTopicsGet(req *request.TaobaoTmcUserTopicsGetRequest) (*response.TaobaoTmcUserTopicsGetResponse, error) {
|
||
|
|
if ability.Client == nil {
|
||
|
|
return nil, errors.New("Ability305 topClient is nil")
|
||
|
|
}
|
||
|
|
var jsonStr, err = ability.Client.Execute("taobao.tmc.user.topics.get", req.ToMap(), req.ToFileMap())
|
||
|
|
var respStruct = response.TaobaoTmcUserTopicsGetResponse{}
|
||
|
|
if err != nil {
|
||
|
|
log.Println("taobaoTmcUserTopicsGet error", err)
|
||
|
|
return &respStruct, err
|
||
|
|
}
|
||
|
|
err = util.HandleJsonResponse(jsonStr, &respStruct)
|
||
|
|
if respStruct.Body == "" || len(respStruct.Body) == 0 {
|
||
|
|
respStruct.Body = jsonStr
|
||
|
|
}
|
||
|
|
return &respStruct, err
|
||
|
|
}
|