新增asdk踢人接口
This commit is contained in:
parent
5d0ba49e7e
commit
c8e5c19dc7
47
services/asdk/client.go
Normal file
47
services/asdk/client.go
Normal file
@ -0,0 +1,47 @@
|
|||||||
|
package asdk
|
||||||
|
|
||||||
|
import (
|
||||||
|
"fmt"
|
||||||
|
"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/utils"
|
||||||
|
"time"
|
||||||
|
)
|
||||||
|
|
||||||
|
const (
|
||||||
|
VERSION = "2020-11-16"
|
||||||
|
)
|
||||||
|
|
||||||
|
var HOST = requests.Host{
|
||||||
|
Default: "asdk",
|
||||||
|
}
|
||||||
|
|
||||||
|
type Client struct {
|
||||||
|
sdk.Client
|
||||||
|
}
|
||||||
|
|
||||||
|
func NewClient() (client *Client, err error) {
|
||||||
|
client = new(Client)
|
||||||
|
err = client.Init()
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
// GenerateInnerApiSign
|
||||||
|
// 生成内部接口签名
|
||||||
|
func GenerateInnerApiSign(ts int64) (int64, string) {
|
||||||
|
const InnerSignSecret = "sYbfhozSu^@K8~y*"
|
||||||
|
if ts == 0 {
|
||||||
|
ts = time.Now().Unix()
|
||||||
|
}
|
||||||
|
return ts, utils.Md5(fmt.Sprintf("%d%s", ts, InnerSignSecret))
|
||||||
|
}
|
||||||
|
|
||||||
|
// CreateKickUserReq 踢人
|
||||||
|
func (c *Client) CreateKickUserReq(req *KickUserReq) (resp *KickUserResp, err error) {
|
||||||
|
resp = CreateKickUserResp()
|
||||||
|
err = c.DoAction(req, resp)
|
||||||
|
if err != nil {
|
||||||
|
return
|
||||||
|
}
|
||||||
|
return
|
||||||
|
}
|
26
services/asdk/client_test.go
Normal file
26
services/asdk/client_test.go
Normal file
@ -0,0 +1,26 @@
|
|||||||
|
package asdk
|
||||||
|
|
||||||
|
import (
|
||||||
|
"fmt"
|
||||||
|
"testing"
|
||||||
|
)
|
||||||
|
|
||||||
|
// 获取用户累计付费
|
||||||
|
func TestKickUser(t *testing.T) {
|
||||||
|
client, err := NewClient()
|
||||||
|
if err != nil {
|
||||||
|
panic(err)
|
||||||
|
}
|
||||||
|
ts, sign := GenerateInnerApiSign(0)
|
||||||
|
req := CreateKickUserReq(KickUserParam{
|
||||||
|
Ts: ts,
|
||||||
|
Sign: sign,
|
||||||
|
UserName: "aq36604627",
|
||||||
|
})
|
||||||
|
|
||||||
|
resp, err := client.CreateKickUserReq(req)
|
||||||
|
if err != nil {
|
||||||
|
panic(err)
|
||||||
|
}
|
||||||
|
fmt.Println(resp.Code, resp.Msg, resp.Data)
|
||||||
|
}
|
45
services/asdk/inner_api.go
Normal file
45
services/asdk/inner_api.go
Normal file
@ -0,0 +1,45 @@
|
|||||||
|
package asdk
|
||||||
|
|
||||||
|
import (
|
||||||
|
"golib.gaore.com/GaoreGo/gaore-common-sdk-go/sdk/requests"
|
||||||
|
"golib.gaore.com/GaoreGo/gaore-common-sdk-go/sdk/responses"
|
||||||
|
"strconv"
|
||||||
|
)
|
||||||
|
|
||||||
|
type KickUserReq struct {
|
||||||
|
*requests.RpcRequest
|
||||||
|
}
|
||||||
|
|
||||||
|
type KickUserResp struct {
|
||||||
|
*responses.BaseResponse
|
||||||
|
Code int `json:"code"`
|
||||||
|
Msg string `json:"msg"`
|
||||||
|
Data struct{} `json:"data"`
|
||||||
|
TraceId string `json:"trace_id"`
|
||||||
|
}
|
||||||
|
type KickUserParam struct {
|
||||||
|
Ts int64 `json:"ts"`
|
||||||
|
Sign string `json:"sign"`
|
||||||
|
UserName string `json:"user_name"`
|
||||||
|
}
|
||||||
|
|
||||||
|
func CreateKickUserReq(data KickUserParam) *KickUserReq {
|
||||||
|
req := &KickUserReq{
|
||||||
|
&requests.RpcRequest{},
|
||||||
|
}
|
||||||
|
|
||||||
|
req.InitWithApiInfo(HOST, VERSION, "/api/kick")
|
||||||
|
req.Method = requests.GET
|
||||||
|
req.QueryParams = map[string]string{
|
||||||
|
"ts": strconv.FormatInt(data.Ts, 10),
|
||||||
|
"sign": data.Sign,
|
||||||
|
"user_name": data.UserName,
|
||||||
|
}
|
||||||
|
return req
|
||||||
|
}
|
||||||
|
|
||||||
|
func CreateKickUserResp() *KickUserResp {
|
||||||
|
return &KickUserResp{
|
||||||
|
BaseResponse: &responses.BaseResponse{},
|
||||||
|
}
|
||||||
|
}
|
Loading…
Reference in New Issue
Block a user