services/passport/client.go

@@ -56,20 +56,6 @@ func (c *Client) EditCard(req EditCardRequestParam) (response string, err error)
 	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
 // 获取用户登录过的游戏大类
 func (c *Client) GetUserGameSign(req *GetUserGameSignRequest) (response *GetUserGameSignResponse, err error) {

services/passport/client_test.go

@@ -213,28 +213,6 @@ func TestGetUserId(t *testing.T) {
 	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) {
 	client, err := NewClient()

services/passport/weedong.go

@@ -2,11 +2,10 @@ package passport
 
 import (
 	"fmt"
-	"time"
-
 	"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/utils"
+	"time"
 )
 
 const weeDongKey = "aVCxX2B3yswpxCMjaaSUHFXAzLYyuGhW"
@@ -96,44 +95,3 @@ func CreateEditCardResponse() (response *EditCardResponse) {
 	}
 	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
-}

services/stat/client.go

@@ -164,10 +164,3 @@ func (c *Client) GetGamePayAmount(req *GetGamePayAmountReq) (resp *GetGamePayAmo
 	err = c.DoAction(req, resp)
 	return
 }
-
-// KafkaEvent 通用推入kafka数据
-func (c *Client) KafkaEvent(req *KafkaEventReq) (resp *KafkaEventResp, err error) {
-	resp = CreateKafkaEventResp()
-	err = c.DoAction(req, resp)
-	return
-}

services/stat/client_test.go

@@ -378,27 +378,3 @@ func TestGetGamePayAmount(t *testing.T) {
 		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)
-	}
-}

services/stat/event_track.go

@@ -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{},
-	}
-}