From b8c226f1dbcdf25df9b73f4913ce5c984d765464 Mon Sep 17 00:00:00 2001 From: yuxh Date: Wed, 19 Nov 2025 09:52:20 +0800 Subject: [PATCH] =?UTF-8?q?feat(stat):=20=E6=96=B0=E5=A2=9E=E9=80=9A?= =?UTF-8?q?=E8=BF=87site=5Fid=E8=8E=B7=E5=8F=96=E8=BE=BE=E4=BA=BA=E4=BF=A1?= =?UTF-8?q?=E6=81=AF=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- services/stat/agent.go | 24 ++++++++++++++++++++++++ services/stat/client.go | 10 ++++++++++ services/stat/client_test.go | 13 +++++++++++++ 3 files changed, 47 insertions(+) diff --git a/services/stat/agent.go b/services/stat/agent.go index e56ca05..6db6306 100644 --- a/services/stat/agent.go +++ b/services/stat/agent.go @@ -75,3 +75,27 @@ func CreateGetAgentListResp() *GetAgentListResp { 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 +} diff --git a/services/stat/client.go b/services/stat/client.go index c5401ed..0b56e07 100644 --- a/services/stat/client.go +++ b/services/stat/client.go @@ -3,6 +3,7 @@ package stat import ( "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/responses" "time" ) @@ -65,6 +66,15 @@ func (c *Client) GetUserRoleRegPage(req *UserRoleRegReq) (resp *UserRoleRegResp, 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 获取用户累计付费 func (c *Client) GetUserTotalPay(req *GetUserTotalPayReq) (resp *GetUserTotalPayResp, err error) { resp = CreateGetUserTotalPayResp() diff --git a/services/stat/client_test.go b/services/stat/client_test.go index f9f9193..26c710d 100644 --- a/services/stat/client_test.go +++ b/services/stat/client_test.go @@ -99,6 +99,19 @@ func TestClient_GetUserRoleRegPage(t *testing.T) { 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) { client, err := NewClient()