wechat_ipad_pro/api/service/favorService.go

package service

import (
	"strconv"
	"xiawan/wx/api/req"
	"xiawan/wx/api/vo"
	"xiawan/wx/clientsdk/baseinfo"
	"xiawan/wx/srv/wxface"
)

// FavSyncService 同步收藏
func FavSyncService(queryKey string) vo.DTO {
	return checkExIdPerformNoCreateConnect(queryKey, func(iwxConnect wxface.IWXConnect, newIWXConnect bool) vo.DTO {
		wxAccount := iwxConnect.GetWXAccount()
		loginState := wxAccount.GetLoginState()

		//判断在线情况
		if loginState == baseinfo.MMLoginStateNoLogin {
			return vo.NewFail("该账号需要重新登录！loginState == MMLoginStateNoLogin ")
		} else if !iwxConnect.CheckOnLineStatus() {
			return vo.NewFail("账号离线,自动上线失败！loginState == " + strconv.Itoa(int(wxAccount.GetLoginState())))
		}
		// 获取请求管理器
		reqInvoker := iwxConnect.GetWXReqInvoker()
		// 同步收藏
		resp, err := reqInvoker.SendFavSyncRequestResult()
		if err != nil {
			return vo.NewFail("FavSyncService！err :" + err.Error())
		}
		return vo.NewSuccessObj(resp, "")
	})
}

// 获取收藏list
func GetFavListService(queryKey string, req req.FavInfoModel) vo.DTO {
	return checkExIdPerformNoCreateConnect(queryKey, func(iwxConnect wxface.IWXConnect, newIWXConnect bool) vo.DTO {
		wxAccount := iwxConnect.GetWXAccount()
		loginState := wxAccount.GetLoginState()

		//判断在线情况
		if loginState == baseinfo.MMLoginStateNoLogin {
			return vo.NewFail("该账号需要重新登录！loginState == MMLoginStateNoLogin ")
		} else if !iwxConnect.CheckOnLineStatus() {
			return vo.NewFail("账号离线,自动上线失败！loginState == " + strconv.Itoa(int(wxAccount.GetLoginState())))
		}
		// 获取请求管理器
		reqInvoker := iwxConnect.GetWXReqInvoker()
		// 同步收藏
		resp, err := reqInvoker.SendFavSyncListRequestResult(req.KeyBuf)
		if err != nil {
			return vo.NewFail("FavSyncService！err :" + err.Error())
		}
		return vo.NewSuccessObj(resp, "")
	})
}

// GetFavInfoService 获取收藏信息
func BatchDelFavItemService(queryKey string, m req.FavInfoModel) vo.DTO {
	return checkExIdPerformNoCreateConnect(queryKey, func(iwxConnect wxface.IWXConnect, newIWXConnect bool) vo.DTO {
		wxAccount := iwxConnect.GetWXAccount()
		loginState := wxAccount.GetLoginState()

		//判断在线情况
		if loginState == baseinfo.MMLoginStateNoLogin {
			return vo.NewFail("该账号需要重新登录！loginState == MMLoginStateNoLogin ")
		} else if !iwxConnect.CheckOnLineStatus() {
			return vo.NewFail("账号离线,自动上线失败！loginState == " + strconv.Itoa(int(wxAccount.GetLoginState())))
		}
		// 获取请求管理器
		reqInvoker := iwxConnect.GetWXReqInvoker()
		// 获取收藏消息
		resp, err := reqInvoker.SendBatchDelFavItemRequestResult(m.FavId)
		if err != nil {
			return vo.NewFail("BatchDelFavItemService！err :" + err.Error())
		}
		return vo.NewSuccessObj(resp, "")
	})
}

// GetFavInfoService 获取收藏信息
func GetFavInfoService(queryKey string) vo.DTO {
	return checkExIdPerformNoCreateConnect(queryKey, func(iwxConnect wxface.IWXConnect, newIWXConnect bool) vo.DTO {
		wxAccount := iwxConnect.GetWXAccount()
		loginState := wxAccount.GetLoginState()

		//判断在线情况
		if loginState == baseinfo.MMLoginStateNoLogin {
			return vo.NewFail("该账号需要重新登录！loginState == MMLoginStateNoLogin ")
		} else if !iwxConnect.CheckOnLineStatus() {
			return vo.NewFail("账号离线,自动上线失败！loginState == " + strconv.Itoa(int(wxAccount.GetLoginState())))
		}
		// 获取请求管理器
		reqInvoker := iwxConnect.GetWXReqInvoker()
		// 获取收藏消息
		resp, err := reqInvoker.SendGetFavInfoRequestResult()
		if err != nil {
			return vo.NewFail("GetFavInfoService！err :" + err.Error())
		}
		return vo.NewSuccessObj(resp, "")
	})
}

// GetFavInfoService 获取收藏详细
func BatchGetFavItemService(queryKey string, m req.FavInfoModel) vo.DTO {
	return checkExIdPerformNoCreateConnect(queryKey, func(iwxConnect wxface.IWXConnect, newIWXConnect bool) vo.DTO {
		wxAccount := iwxConnect.GetWXAccount()
		loginState := wxAccount.GetLoginState()

		//判断在线情况
		if loginState == baseinfo.MMLoginStateNoLogin {
			return vo.NewFail("该账号需要重新登录！loginState == MMLoginStateNoLogin ")
		} else if !iwxConnect.CheckOnLineStatus() {
			return vo.NewFail("账号离线,自动上线失败！loginState == " + strconv.Itoa(int(wxAccount.GetLoginState())))
		}
		// 获取请求管理器
		reqInvoker := iwxConnect.GetWXReqInvoker()
		// 获取收藏消息
		resp, err := reqInvoker.SendBatchGetFavItemRequestResult(m.FavId)
		if err != nil {
			return vo.NewFail("GetFavInfoService！err :" + err.Error())
		}
		return vo.NewSuccessObj(resp, "")
	})
}