7
0

feat(stat): 新增通过site_id获取达人信息接口

This commit is contained in:
余 欣怀 2025-11-19 09:52:20 +08:00
parent dee3b1ad0c
commit b8c226f1db
3 changed files with 47 additions and 0 deletions

View File

@ -75,3 +75,27 @@ func CreateGetAgentListResp() *GetAgentListResp {
BaseResponse: &responses.BaseResponse{}, BaseResponse: &responses.BaseResponse{},
} }
} }
type GetAnchorBySiteId struct {
*requests.RpcRequest
SiteId int64 `position:"Body" field:"site_id" default:"0" json:"site_id"`
}
type GetAnchorBySiteIdResp struct {
*responses.BaseResponse
Code int `json:"code"`
Msg string `json:"msg"`
Data struct {
AnchorName string `json:"anchor_name"`
} `json:"data"`
}
func CreateGetAnchorBySiteIdReq(siteId int64) *GetAnchorBySiteId {
req := &GetAnchorBySiteId{
RpcRequest: &requests.RpcRequest{},
SiteId: siteId,
}
req.InitWithApiInfo(HOST, VERSION, "/site/getAnchorBySiteID")
req.Method = requests.POST
return req
}

View File

@ -3,6 +3,7 @@ package stat
import ( import (
"golib.gaore.com/GaoreGo/gaore-common-sdk-go/sdk" "golib.gaore.com/GaoreGo/gaore-common-sdk-go/sdk"
"golib.gaore.com/GaoreGo/gaore-common-sdk-go/sdk/requests" "golib.gaore.com/GaoreGo/gaore-common-sdk-go/sdk/requests"
"golib.gaore.com/GaoreGo/gaore-common-sdk-go/sdk/responses"
"time" "time"
) )
@ -65,6 +66,15 @@ func (c *Client) GetUserRoleRegPage(req *UserRoleRegReq) (resp *UserRoleRegResp,
return return
} }
// GetAnchorBySiteId 通过site_id获取达人信息
func (c *Client) GetAnchorBySiteId(req *GetAnchorBySiteId) (resp *GetAnchorBySiteIdResp, err error) {
resp = &GetAnchorBySiteIdResp{
BaseResponse: &responses.BaseResponse{},
}
err = c.DoAction(req, resp)
return
}
// GetUserTotalPay 获取用户累计付费 // GetUserTotalPay 获取用户累计付费
func (c *Client) GetUserTotalPay(req *GetUserTotalPayReq) (resp *GetUserTotalPayResp, err error) { func (c *Client) GetUserTotalPay(req *GetUserTotalPayReq) (resp *GetUserTotalPayResp, err error) {
resp = CreateGetUserTotalPayResp() resp = CreateGetUserTotalPayResp()

View File

@ -99,6 +99,19 @@ func TestClient_GetUserRoleRegPage(t *testing.T) {
fmt.Println(resp.Code, resp.Msg, resp.Data) fmt.Println(resp.Code, resp.Msg, resp.Data)
} }
func TestClient_GetAnchorBySiteId(t *testing.T) {
client, err := NewClient()
if err != nil {
t.Fatal(err)
}
req := CreateGetAnchorBySiteIdReq(6434244)
resp, err := client.GetAnchorBySiteId(req)
if err != nil {
t.Fatal(err)
}
fmt.Println(resp.Code, resp.Msg, resp.Data.AnchorName)
}
// 获取用户累计付费 // 获取用户累计付费
func TestGetUserTotalPay(t *testing.T) { func TestGetUserTotalPay(t *testing.T) {
client, err := NewClient() client, err := NewClient()