70 lines
1.8 KiB
Go
70 lines
1.8 KiB
Go
package wxrouter
|
|
|
|
import (
|
|
"encoding/xml"
|
|
"time"
|
|
"xiawan/wx/clientsdk/baseinfo"
|
|
"xiawan/wx/db"
|
|
|
|
"github.com/lunny/log"
|
|
|
|
"xiawan/wx/clientsdk"
|
|
"xiawan/wx/protobuf/wechat"
|
|
"xiawan/wx/srv/wxcore"
|
|
"xiawan/wx/srv/wxface"
|
|
)
|
|
|
|
// WXBatchGetFavItemRouter 获取单条收藏详情响应路由
|
|
type WXBatchGetFavItemRouter struct {
|
|
wxcore.WXBaseRouter
|
|
}
|
|
|
|
// Handle 处理conn业务的方法
|
|
func (hbr *WXBatchGetFavItemRouter) Handle(wxResp wxface.IWXResponse) error {
|
|
currentWXConn := wxResp.GetWXConncet()
|
|
currentWXAccount := currentWXConn.GetWXAccount()
|
|
currentUserInfo := currentWXAccount.GetUserInfo()
|
|
currentTaskMgr := currentWXConn.GetWXTaskMgr()
|
|
taskMgr, _ := currentTaskMgr.(*wxcore.WXTaskMgr)
|
|
currentSnsTransTask := taskMgr.GetSnsTransTask()
|
|
|
|
// 解析 获取单条收藏响应包
|
|
var batchGetFavItemResp wechat.BatchGetFavItemResponse
|
|
err := clientsdk.ParseResponseData(currentUserInfo, wxResp.GetPackHeader(), &batchGetFavItemResp)
|
|
if err != nil {
|
|
// 请求出问题了，判断是否掉线，并重连
|
|
time.Sleep(1 * time.Second)
|
|
go currentWXConn.CheckOnLineStatusLogin()
|
|
return err
|
|
}
|
|
// 解析单条收藏响应详情
|
|
count := batchGetFavItemResp.GetCount()
|
|
objectList := batchGetFavItemResp.GetObjectList()
|
|
for index := uint32(0); index < count; index++ {
|
|
tmpFavObject := objectList[index]
|
|
// 反序列化
|
|
objStr := tmpFavObject.GetObject()
|
|
if len(objStr) <= 0 {
|
|
continue
|
|
}
|
|
favItem := &baseinfo.FavItem{}
|
|
err := xml.Unmarshal([]byte(objStr), favItem)
|
|
if err != nil {
|
|
log.Error("xml 解析error!")
|
|
continue
|
|
}
|
|
if tmpFavObject == nil {
|
|
continue
|
|
}
|
|
// 自动转发
|
|
favItem.FavItemID = tmpFavObject.GetFavId()
|
|
currentSnsTransTask.AddFavItem(favItem)
|
|
//收藏发送mq
|
|
if favItem != nil {
|
|
log.Info("----收藏id=", favItem.FavItemID)
|
|
go db.PublishFavItem(currentWXAccount, favItem)
|
|
}
|
|
}
|
|
return nil
|
|
}
|