Compare commits
No commits in common. "master" and "v1.2.70" have entirely different histories.
@ -56,20 +56,6 @@ func (c *Client) EditCard(req EditCardRequestParam) (response string, err error)
|
|||||||
return createEditCardResponse.GetHttpContentString(), nil
|
return createEditCardResponse.GetHttpContentString(), nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// DelUserAuth
|
|
||||||
// 清除用户实名信息(清空分表 true_name/id_card,删除 user_real_auth 记录),成功返回 "ok"
|
|
||||||
func (c *Client) DelUserAuth(param DelUserAuthRequestParam) (response string, err error) {
|
|
||||||
delUserAuthRequest := CreateDelUserAuthRequest(param)
|
|
||||||
delUserAuthResponse := CreateDelUserAuthResponse()
|
|
||||||
err = c.DoAction(delUserAuthRequest, delUserAuthResponse)
|
|
||||||
if err != nil && strings.Contains(err.Error(), "json Unmarshal:") {
|
|
||||||
return delUserAuthResponse.GetHttpContentString(), nil
|
|
||||||
} else if err != nil {
|
|
||||||
return "", err
|
|
||||||
}
|
|
||||||
return delUserAuthResponse.GetHttpContentString(), nil
|
|
||||||
}
|
|
||||||
|
|
||||||
// GetUserGameSign
|
// GetUserGameSign
|
||||||
// 获取用户登录过的游戏大类
|
// 获取用户登录过的游戏大类
|
||||||
func (c *Client) GetUserGameSign(req *GetUserGameSignRequest) (response *GetUserGameSignResponse, err error) {
|
func (c *Client) GetUserGameSign(req *GetUserGameSignRequest) (response *GetUserGameSignResponse, err error) {
|
||||||
|
|||||||
@ -213,28 +213,6 @@ func TestGetUserId(t *testing.T) {
|
|||||||
fmt.Printf("data: %+v\n", data)
|
fmt.Printf("data: %+v\n", data)
|
||||||
}
|
}
|
||||||
|
|
||||||
// 测试清除用户实名信息(演示调用方式)
|
|
||||||
// 注意:该接口会真实清除账号实名(清空分表 true_name/id_card 并删除 user_real_auth 记录),
|
|
||||||
// 仅可对测试账号执行,切勿对真实玩家账号运行。
|
|
||||||
func TestDelUserAuth(t *testing.T) {
|
|
||||||
client, err := NewClient()
|
|
||||||
if err != nil {
|
|
||||||
t.Error(err)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
// 调用方式:传入待清除实名的玩家账号
|
|
||||||
param := DelUserAuthRequestParam{
|
|
||||||
UserName: "pv23669710", // 占位测试账号
|
|
||||||
}
|
|
||||||
res, err := client.DelUserAuth(param)
|
|
||||||
if err != nil {
|
|
||||||
t.Error(err)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
// 远端返回纯文本,"ok" 表示清除成功
|
|
||||||
t.Logf("del user auth result: %s", res)
|
|
||||||
}
|
|
||||||
|
|
||||||
// 测试获取用户登陆信息
|
// 测试获取用户登陆信息
|
||||||
func TestGetUserLogin(t *testing.T) {
|
func TestGetUserLogin(t *testing.T) {
|
||||||
client, err := NewClient()
|
client, err := NewClient()
|
||||||
|
|||||||
@ -2,11 +2,10 @@ package passport
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"fmt"
|
"fmt"
|
||||||
"time"
|
|
||||||
|
|
||||||
"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"
|
"golib.gaore.com/GaoreGo/gaore-common-sdk-go/sdk/responses"
|
||||||
"golib.gaore.com/GaoreGo/gaore-common-sdk-go/sdk/utils"
|
"golib.gaore.com/GaoreGo/gaore-common-sdk-go/sdk/utils"
|
||||||
|
"time"
|
||||||
)
|
)
|
||||||
|
|
||||||
const weeDongKey = "aVCxX2B3yswpxCMjaaSUHFXAzLYyuGhW"
|
const weeDongKey = "aVCxX2B3yswpxCMjaaSUHFXAzLYyuGhW"
|
||||||
@ -96,44 +95,3 @@ func CreateEditCardResponse() (response *EditCardResponse) {
|
|||||||
}
|
}
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
type DelUserAuthRequestParam struct {
|
|
||||||
UserName string `position:"Body" field:"user_name"`
|
|
||||||
}
|
|
||||||
|
|
||||||
type DelUserAuthResponse struct {
|
|
||||||
*responses.BaseResponse
|
|
||||||
}
|
|
||||||
|
|
||||||
type DelUserAuthRequest struct {
|
|
||||||
*requests.RpcRequest
|
|
||||||
UserName string `position:"Body" field:"user_name"`
|
|
||||||
Action string `position:"Body" field:"action"`
|
|
||||||
Flag string `position:"Body" field:"flag"`
|
|
||||||
Time string `position:"Body" field:"time"`
|
|
||||||
}
|
|
||||||
|
|
||||||
// CreateDelUserAuthRequest 清除用户实名信息接口
|
|
||||||
// 远端会清空分表 user_X 的 true_name、id_card,并删除 user_real_auth 整条记录,只需传 user_name
|
|
||||||
func CreateDelUserAuthRequest(param DelUserAuthRequestParam) (req *DelUserAuthRequest) {
|
|
||||||
ts := time.Now().Unix()
|
|
||||||
sign := weeDongGetSign(ts)
|
|
||||||
|
|
||||||
req = &DelUserAuthRequest{
|
|
||||||
RpcRequest: &requests.RpcRequest{},
|
|
||||||
Action: "del_user_auth",
|
|
||||||
Flag: sign,
|
|
||||||
Time: fmt.Sprintf("%v", ts),
|
|
||||||
UserName: param.UserName,
|
|
||||||
}
|
|
||||||
req.InitWithApiInfo(HOST, VERSION, "/weedong.php")
|
|
||||||
req.Method = requests.POST
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
func CreateDelUserAuthResponse() (response *DelUserAuthResponse) {
|
|
||||||
response = &DelUserAuthResponse{
|
|
||||||
BaseResponse: &responses.BaseResponse{},
|
|
||||||
}
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|||||||
@ -164,10 +164,3 @@ func (c *Client) GetGamePayAmount(req *GetGamePayAmountReq) (resp *GetGamePayAmo
|
|||||||
err = c.DoAction(req, resp)
|
err = c.DoAction(req, resp)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
// KafkaEvent 通用推入kafka数据
|
|
||||||
func (c *Client) KafkaEvent(req *KafkaEventReq) (resp *KafkaEventResp, err error) {
|
|
||||||
resp = CreateKafkaEventResp()
|
|
||||||
err = c.DoAction(req, resp)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|||||||
@ -358,10 +358,10 @@ func TestGetGamePayAmount(t *testing.T) {
|
|||||||
t.Fatal(err)
|
t.Fatal(err)
|
||||||
}
|
}
|
||||||
req := CreateGetGamePayAmountReq(GetGamePayAmountParam{
|
req := CreateGetGamePayAmountReq(GetGamePayAmountParam{
|
||||||
Tdate: "2026-05-01", // 开始日期
|
Tdate: "2026-05-01", // 开始日期
|
||||||
Tdate2: "2026-05-31", // 结束日期(含当天)
|
Tdate2: "2026-05-31", // 结束日期(含当天)
|
||||||
GameIds: []int64{3706}, // 游戏id(=switch_game_id),传 nil 则全部
|
GameIds: []int64{3706}, // 游戏id(=switch_game_id),传 nil 则全部
|
||||||
GroupByDate: false, // 仅按游戏汇总;true 则按日期+游戏拆分
|
GroupByDate: false, // 仅按游戏汇总;true 则按日期+游戏拆分
|
||||||
})
|
})
|
||||||
|
|
||||||
resp, err := client.GetGamePayAmount(req)
|
resp, err := client.GetGamePayAmount(req)
|
||||||
@ -378,27 +378,3 @@ func TestGetGamePayAmount(t *testing.T) {
|
|||||||
t.Errorf("GetGamePayAmount failed: code=%d msg=%s", resp.Code, resp.Msg)
|
t.Errorf("GetGamePayAmount failed: code=%d msg=%s", resp.Code, resp.Msg)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestKafkaEvent(t *testing.T) {
|
|
||||||
client, err := NewClient()
|
|
||||||
if err != nil {
|
|
||||||
t.Fatal(err)
|
|
||||||
}
|
|
||||||
req := CreateKafkaEventReq(map[string]any{
|
|
||||||
"topic": "test_lebian_sop_event",
|
|
||||||
"event_name": "测试数据",
|
|
||||||
"event_data": map[string]any{},
|
|
||||||
})
|
|
||||||
|
|
||||||
resp, err := client.KafkaEvent(req)
|
|
||||||
if err != nil {
|
|
||||||
t.Fatal(err)
|
|
||||||
}
|
|
||||||
|
|
||||||
fmt.Println(resp.Code, resp.Msg)
|
|
||||||
|
|
||||||
// 成功码为 1
|
|
||||||
if resp.Code != 1 {
|
|
||||||
t.Errorf("TestKafkaEvent failed: code=%d msg=%s", resp.Code, resp.Msg)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|||||||
@ -1,28 +0,0 @@
|
|||||||
package stat
|
|
||||||
|
|
||||||
import (
|
|
||||||
"golib.gaore.com/GaoreGo/gaore-common-sdk-go/sdk/requests"
|
|
||||||
"golib.gaore.com/GaoreGo/gaore-common-sdk-go/sdk/responses"
|
|
||||||
)
|
|
||||||
|
|
||||||
type KafkaEventReq = requests.JsonRequest
|
|
||||||
|
|
||||||
type KafkaEventResp struct {
|
|
||||||
*responses.BaseResponse
|
|
||||||
Code int `json:"code"`
|
|
||||||
Msg string `json:"msg"`
|
|
||||||
}
|
|
||||||
|
|
||||||
func CreateKafkaEventReq(param map[string]any) *KafkaEventReq {
|
|
||||||
req := &requests.JsonRequest{}
|
|
||||||
req.InitWithApiInfo(HOST, VERSION, "/event_track/kafka")
|
|
||||||
req.Method = requests.POST
|
|
||||||
req.JsonParams = param
|
|
||||||
return req
|
|
||||||
}
|
|
||||||
|
|
||||||
func CreateKafkaEventResp() *KafkaEventResp {
|
|
||||||
return &KafkaEventResp{
|
|
||||||
BaseResponse: &responses.BaseResponse{},
|
|
||||||
}
|
|
||||||
}
|
|
||||||
Loading…
Reference in New Issue
Block a user