From b8c226f1dbcdf25df9b73f4913ce5c984d765464 Mon Sep 17 00:00:00 2001 From: yuxh Date: Wed, 19 Nov 2025 09:52:20 +0800 Subject: [PATCH 1/4] =?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() From b6de510bf74256e9c09123c53efd4e1ef56c9b5e Mon Sep 17 00:00:00 2001 From: yuxh Date: Wed, 19 Nov 2025 12:26:04 +0800 Subject: [PATCH 2/4] =?UTF-8?q?feat(stat):=20=E6=96=B0=E5=A2=9E=E9=80=9A?= =?UTF-8?q?=E8=BF=87=E5=8F=A3=E4=BB=A4=E8=8E=B7=E5=8F=96=E8=BE=BE=E4=BA=BA?= =?UTF-8?q?=E4=BF=A1=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 | 26 ++++++++++++++++++++++++++ services/stat/client.go | 8 ++++++++ services/stat/client_test.go | 13 +++++++++++++ 3 files changed, 47 insertions(+) diff --git a/services/stat/agent.go b/services/stat/agent.go index 6db6306..51eaf9b 100644 --- a/services/stat/agent.go +++ b/services/stat/agent.go @@ -99,3 +99,29 @@ func CreateGetAnchorBySiteIdReq(siteId int64) *GetAnchorBySiteId { req.Method = requests.POST return req } + +// ======== 根据口令获取达人名称 + +type GetAnchorByLiveCodeReq struct { + *requests.RpcRequest + LiveCode string `position:"Body" field:"live_code" default:"" json:"live_code"` +} + +type GetAnchorByLiveCodeResp struct { + *responses.BaseResponse + Code int `json:"code"` + Msg string `json:"msg"` + Data struct { + AnchorName string `json:"anchor_name"` + } `json:"data"` +} + +func CreateGetAnchorByLiveCodeReq(liveCode string) *GetAnchorByLiveCodeReq { + req := &GetAnchorByLiveCodeReq{ + RpcRequest: &requests.RpcRequest{}, + LiveCode: liveCode, + } + req.InitWithApiInfo(HOST, VERSION, "/livecode/getAnchorByLiveCode") + req.Method = requests.POST + return req +} diff --git a/services/stat/client.go b/services/stat/client.go index 0b56e07..7b5a977 100644 --- a/services/stat/client.go +++ b/services/stat/client.go @@ -94,3 +94,11 @@ func (c *Client) GetGameServerCountData(req *GetGameServerCountDataReq) (resp *G } return } + +func (c *Client) GetAnchorByLiveCode(req *GetAnchorByLiveCodeReq) (resp *GetAnchorByLiveCodeResp, err error) { + resp = &GetAnchorByLiveCodeResp{ + BaseResponse: &responses.BaseResponse{}, + } + err = c.DoAction(req, resp) + return +} diff --git a/services/stat/client_test.go b/services/stat/client_test.go index 26c710d..cab1143 100644 --- a/services/stat/client_test.go +++ b/services/stat/client_test.go @@ -112,6 +112,19 @@ func TestClient_GetAnchorBySiteId(t *testing.T) { fmt.Println(resp.Code, resp.Msg, resp.Data.AnchorName) } +func TestClient_GetAnchorByLiveCode(t *testing.T) { + client, err := NewClient() + if err != nil { + t.Fatal(err) + } + req := CreateGetAnchorByLiveCodeReq("梦无敌111") + resp, err := client.GetAnchorByLiveCode(req) + if err != nil { + t.Fatal(err) + } + fmt.Println(resp.Code, resp.Msg, resp.Data.AnchorName) +} + // 获取用户累计付费 func TestGetUserTotalPay(t *testing.T) { client, err := NewClient() From 2895a34a180fc39487b6b7de0a15156d04974dbb Mon Sep 17 00:00:00 2001 From: yuxh Date: Wed, 19 Nov 2025 14:45:03 +0800 Subject: [PATCH 3/4] =?UTF-8?q?feat(stat):=20=E6=96=B0=E5=A2=9E=E9=80=9A?= =?UTF-8?q?=E8=BF=87=E5=8F=A3=E4=BB=A4=E8=8E=B7=E5=8F=96=E5=8F=A3=E4=BB=A4?= =?UTF-8?q?=E9=85=8D=E7=BD=AE=E4=BF=A1=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- services/stat/agent.go | 29 +++++++++++++++++++++++++++++ services/stat/client.go | 10 ++++++++++ services/stat/client_test.go | 13 +++++++++++++ 3 files changed, 52 insertions(+) diff --git a/services/stat/agent.go b/services/stat/agent.go index 51eaf9b..4089c81 100644 --- a/services/stat/agent.go +++ b/services/stat/agent.go @@ -125,3 +125,32 @@ func CreateGetAnchorByLiveCodeReq(liveCode string) *GetAnchorByLiveCodeReq { req.Method = requests.POST return req } + +// 根据口令获取对应的site_id + +type GetLiveCodeReq struct { + *requests.RpcRequest + LiveCode string `position:"Body" field:"code" default:"" json:"code"` +} + +type GetLiveCodeResp struct { + *responses.BaseResponse + Code int `json:"code"` + Msg string `json:"msg"` + Data struct { + Code string `json:"code"` + GameId int64 `json:"game_id"` + AgentId int64 `json:"agent_id"` + SiteId int64 `json:"site_id"` + } `json:"data"` +} + +func CreateGetLiveCodeReq(liveCode string) *GetLiveCodeReq { + req := &GetLiveCodeReq{ + RpcRequest: &requests.RpcRequest{}, + LiveCode: liveCode, + } + req.InitWithApiInfo(HOST, VERSION, "/livecode/queryCode") + req.Method = requests.POST + return req +} diff --git a/services/stat/client.go b/services/stat/client.go index 7b5a977..909627e 100644 --- a/services/stat/client.go +++ b/services/stat/client.go @@ -95,6 +95,7 @@ func (c *Client) GetGameServerCountData(req *GetGameServerCountDataReq) (resp *G return } +// GetAnchorByLiveCode 通过口令获取达人信息 func (c *Client) GetAnchorByLiveCode(req *GetAnchorByLiveCodeReq) (resp *GetAnchorByLiveCodeResp, err error) { resp = &GetAnchorByLiveCodeResp{ BaseResponse: &responses.BaseResponse{}, @@ -102,3 +103,12 @@ func (c *Client) GetAnchorByLiveCode(req *GetAnchorByLiveCodeReq) (resp *GetAnch err = c.DoAction(req, resp) return } + +// GetLiveCode 根据口令获取口令信息 +func (c *Client) GetLiveCode(req *GetLiveCodeReq) (resp *GetLiveCodeResp, err error) { + resp = &GetLiveCodeResp{ + BaseResponse: &responses.BaseResponse{}, + } + err = c.DoAction(req, resp) + return +} diff --git a/services/stat/client_test.go b/services/stat/client_test.go index cab1143..2b85881 100644 --- a/services/stat/client_test.go +++ b/services/stat/client_test.go @@ -161,3 +161,16 @@ func TestGetGameServerCountData(t *testing.T) { fmt.Printf("%+v", resp.Data) } + +func TestClient_GetLiveCode(t *testing.T) { + client, err := NewClient() + if err != nil { + t.Fatal(err) + } + req := CreateGetLiveCodeReq("梦无敌111") + resp, err := client.GetLiveCode(req) + if err != nil { + t.Fatal(err) + } + t.Log(resp.Code, resp.Msg, resp.Data) +} From 713b43d2ba198f0dd35aa611994efb2d8fd149f0 Mon Sep 17 00:00:00 2001 From: yuxh Date: Thu, 20 Nov 2025 14:20:39 +0800 Subject: [PATCH 4/4] =?UTF-8?q?feat(stat):=20=E6=96=B0=E5=A2=9E=E4=B8=8A?= =?UTF-8?q?=E6=8A=A5=E7=94=A8=E6=88=B7=E5=8F=A3=E4=BB=A4=E7=BB=91=E5=AE=9A?= =?UTF-8?q?=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- services/stat/client.go | 8 ++++++++ services/stat/client_test.go | 24 ++++++++++++++++++++++++ services/stat/user.go | 34 ++++++++++++++++++++++++++++++++++ 3 files changed, 66 insertions(+) diff --git a/services/stat/client.go b/services/stat/client.go index 909627e..ca915f2 100644 --- a/services/stat/client.go +++ b/services/stat/client.go @@ -112,3 +112,11 @@ func (c *Client) GetLiveCode(req *GetLiveCodeReq) (resp *GetLiveCodeResp, err er err = c.DoAction(req, resp) return } + +func (c *Client) BindLiveCode(req *BindLiveCodeReq) (resp *BindLiveCodeResp, err error) { + resp = &BindLiveCodeResp{ + BaseResponse: &responses.BaseResponse{}, + } + err = c.DoAction(req, resp) + return +} diff --git a/services/stat/client_test.go b/services/stat/client_test.go index 2b85881..308d292 100644 --- a/services/stat/client_test.go +++ b/services/stat/client_test.go @@ -3,6 +3,7 @@ package stat import ( "fmt" "testing" + "time" ) func TestSyncGameServerList(t *testing.T) { @@ -174,3 +175,26 @@ func TestClient_GetLiveCode(t *testing.T) { } t.Log(resp.Code, resp.Msg, resp.Data) } + +func TestClient_BindLiveCode(t *testing.T) { + client, err := NewClient() + if err != nil { + t.Fatal(err) + } + req := CreateBindLiveCodeReq(BindLiveCodeParam{ + AnchorName: "梦无敌111", + BindTime: time.Now().Unix(), + GameId: 3706, + GameSign: "qwldy", + LiveCode: "梦无敌111", + LiveSiteId: 203902, + RegDate: "2023-10-09", + Uid: 123456, + UserName: "grtest1001", + }) + resp, err := client.BindLiveCode(req) + if err != nil { + t.Fatal(err) + } + t.Log(resp.Code, resp.Msg) +} diff --git a/services/stat/user.go b/services/stat/user.go index 5d59692..ffea1f3 100644 --- a/services/stat/user.go +++ b/services/stat/user.go @@ -3,6 +3,7 @@ package stat import ( "crypto/md5" "encoding/hex" + "encoding/json" "fmt" "golib.gaore.com/GaoreGo/gaore-common-sdk-go/sdk/requests" "golib.gaore.com/GaoreGo/gaore-common-sdk-go/sdk/responses" @@ -113,3 +114,36 @@ func CreateUserRoleRegPageResp() *UserRoleRegResp { BaseResponse: &responses.BaseResponse{}, } } + +// ======== 上报用户绑定口令数据 ========= + +type BindLiveCodeParam struct { + Uid int64 `json:"uid"` + UserName string `json:"user_name"` + GameId int64 `json:"game_id"` + GameSign string `json:"game_sign"` + RegDate string `json:"reg_date"` + LiveCode string `json:"live_code"` + LiveSiteId int64 `json:"live_site_id"` + AnchorName string `json:"anchor_name"` + BindTime int64 `json:"bind_time"` +} + +type BindLiveCodeReq = requests.JsonRequest + +type BindLiveCodeResp struct { + *responses.BaseResponse + Code int `json:"code"` + Msg string `json:"msg"` +} + +func CreateBindLiveCodeReq(param BindLiveCodeParam) *BindLiveCodeReq { + req := &requests.JsonRequest{} + _param, _ := json.Marshal(param) + paramMap := make(map[string]any) + _ = json.Unmarshal(_param, ¶mMap) + req.InitWithApiInfo(HOST, VERSION, "/user/bindLiveCode") + req.Method = requests.POST + req.JsonParams = paramMap + return req +}