blackteay/open-im-server
1
0
Fork 0
mirror of https://github.com/openimsdk/open-im-server.git synced 2025-04-06 04:15:46 +08:00
Code Issues Packages Projects Releases Wiki Activity

add

Browse Source
This commit is contained in:
wangchuxiao 2022-08-29 16:05:12 +08:00
parent 7f5b12d4d2
commit 9b5e1465c3
3 changed files with 18 additions and 56 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
internal/cms_api/router.go
View File

@ -54,7 +54,6 @@ func NewGinRouter() *gin.Engine {
userRouterGroup.POST("/unblock_user", user.UnblockUser) userRouterGroup.POST("/unblock_user", user.UnblockUser)
userRouterGroup.POST("/block_user", user.BlockUser) userRouterGroup.POST("/block_user", user.BlockUser)
userRouterGroup.GET("/get_block_users", user.GetBlockUsers) userRouterGroup.GET("/get_block_users", user.GetBlockUsers)
userRouterGroup.GET("/get_block_user", user.GetBlockUserById)
} }
messageCMSRouterGroup := r2.Group("/message") messageCMSRouterGroup := r2.Group("/message")
{ {

51
internal/cms_api/user/user.go
View File

@ -143,15 +143,13 @@ func GetBlockUsers(c *gin.Context) {
for _, v := range respPb.BlockUsers { for _, v := range respPb.BlockUsers {
resp.BlockUsers = append(resp.BlockUsers, cms_api_struct.BlockUser{ resp.BlockUsers = append(resp.BlockUsers, cms_api_struct.BlockUser{
UserResponse: cms_api_struct.UserResponse{ UserResponse: cms_api_struct.UserResponse{
UserId: v.User.UserId, UserID: v.UserInfo.UserID,
ProfilePhoto: v.User.ProfilePhoto, FaceURL: v.UserInfo.FaceURL,
Nickname: v.User.Nickname, Nickname: v.UserInfo.Nickname,
IsBlock: v.User.IsBlock, PhoneNumber: v.UserInfo.PhoneNumber,
Birth: v.User.Birth, Email: v.UserInfo.Email,
PhoneNumber: v.User.PhoneNumber, Gender: int(v.UserInfo.Gender),
Email: v.User.Email, // CreateTime: v.UserInfo.CreateTime,
Gender: int(v.User.Gender),
CreateTime: v.User.CreateTime,
}, },
BeginDisableTime: v.BeginDisableTime, BeginDisableTime: v.BeginDisableTime,
EndDisableTime: v.EndDisableTime, EndDisableTime: v.EndDisableTime,
@ -163,38 +161,3 @@ func GetBlockUsers(c *gin.Context) {
log.NewInfo(reqPb.OperationID, utils.GetSelfFuncName(), "req: ", resp) log.NewInfo(reqPb.OperationID, utils.GetSelfFuncName(), "req: ", resp)
openIMHttp.RespHttp200(c, constant.OK, resp) openIMHttp.RespHttp200(c, constant.OK, resp)
} }
func GetBlockUserById(c *gin.Context) {
var (
req cms_api_struct.GetBlockUserRequest
resp cms_api_struct.GetBlockUserResponse
reqPb pb.GetBlockUserByIdReq
)
if err := c.ShouldBindQuery(&req); err != nil {
log.NewError("0", "BindJSON failed ", err.Error())
openIMHttp.RespHttp200(c, constant.ErrArgs, nil)
return
}
reqPb.OperationID = utils.OperationIDGenerator()
log.NewInfo(reqPb.OperationID, utils.GetSelfFuncName(), "req: ", req)
reqPb.UserId = req.UserId
etcdConn := getcdv3.GetDefaultConn(config.Config.Etcd.EtcdSchema, strings.Join(config.Config.Etcd.EtcdAddr, ","), config.Config.RpcRegisterName.OpenImUserName, reqPb.OperationID)
if etcdConn == nil {
errMsg := reqPb.OperationID + "getcdv3.GetDefaultConn == nil"
log.NewError(reqPb.OperationID, errMsg)
c.JSON(http.StatusInternalServerError, gin.H{"errCode": 500, "errMsg": errMsg})
return
}
client := pb.NewUserClient(etcdConn)
respPb, err := client.GetBlockUserById(context.Background(), &reqPb)
if err != nil {
log.NewError(reqPb.OperationID, "GetBlockUserById rpc failed ", err.Error())
openIMHttp.RespHttp200(c, err, nil)
return
}
resp.EndDisableTime = respPb.BlockUser.EndDisableTime
resp.BeginDisableTime = respPb.BlockUser.BeginDisableTime
utils.CopyStructFields(&resp, respPb.BlockUser.User)
log.NewInfo(reqPb.OperationID, utils.GetSelfFuncName(), "resp: ", resp)
openIMHttp.RespHttp200(c, constant.OK, resp)
}

22
pkg/cms_api_struct/user.go
View File

@ -1,17 +1,17 @@
package cms_api_struct package cms_api_struct
type UserResponse struct { type UserResponse struct {
ProfilePhoto string `json:"profile_photo"` FaceURL string `json:"faceURL"`
Nickname string `json:"nick_name"` Nickname string `json:"nickName"`
UserId string `json:"user_id"` UserID string `json:"userID"`
CreateTime string `json:"create_time,omitempty"` CreateTime string `json:"createTime,omitempty"`
CreateIp string `json:"create_ip,omitempty"` CreateIp string `json:"createIp,omitempty"`
LastLoginTime string `json:"last_login_time,omitempty"` LastLoginTime string `json:"lastLoginTime,omitempty"`
LastLoginIp string `json:"last_login_ip,omitempty"` LastLoginIp string `json:"lastLoginIP,omitempty"`
LoginTimes int32 `json:"login_times"` LoginTimes int32 `json:"loginTimes"`
LoginLimit int32 `json:"login_limit"` LoginLimit int32 `json:"loginLimit"`
IsBlock bool `json:"is_block"` IsBlock bool `json:"isBlock"`
PhoneNumber string `json:"phone_number"` PhoneNumber string `json:"phoneNumber"`
Email string `json:"email"` Email string `json:"email"`
Birth string `json:"birth"` Birth string `json:"birth"`
Gender int `json:"gender"` Gender int `json:"gender"`