This commit is contained in:
meixiongfeng 2024-02-06 15:46:59 +08:00
commit 26ce697be5

View File

@ -14,11 +14,12 @@ func (this *apiComp) RankCheck(session comm.IUserSession, req *pb.ArenaRankReq)
// /排行榜获取 // /排行榜获取
func (this *apiComp) Rank(session comm.IUserSession, req *pb.ArenaRankReq) (errdata *pb.ErrorData) { func (this *apiComp) Rank(session comm.IUserSession, req *pb.ArenaRankReq) (errdata *pb.ErrorData) {
var ( var (
info *pb.DBArenaUser info *pb.DBArenaUser
uids []string uids []string
ranks []*pb.DBArenaUser ranks []*pb.DBArenaUser
players []*pb.ArenaPlayer ranksMap map[string]*pb.DBArenaUser
err error players []*pb.ArenaPlayer
err error
) )
if errdata = this.RankCheck(session, req); errdata != nil { if errdata = this.RankCheck(session, req); errdata != nil {
@ -48,25 +49,32 @@ func (this *apiComp) Rank(session comm.IUserSession, req *pb.ArenaRankReq) (errd
} }
return return
} }
players = make([]*pb.ArenaPlayer, len(ranks)) ranksMap = make(map[string]*pb.DBArenaUser)
for i, v := range ranks { for _, v := range ranks {
rank := int32(i + 1) ranksMap[v.Uid] = v
players[i] = &pb.ArenaPlayer{ }
Uinfo: v.Uinfo, players = make([]*pb.ArenaPlayer, 0, len(uids))
Dan: v.Dan, for i, v := range uids {
Rank: rank, if player, ok := ranksMap[v]; ok {
Integral: v.Integral, rank := int32(i + 1)
} players = append(players, &pb.ArenaPlayer{
if session.GetUserId() == v.Uinfo.Uid && info.Rank != rank { Uinfo: player.Uinfo,
info.Rank = rank Dan: player.Dan,
if err = this.module.modelArena.updateArenaUserInfo(info); err != nil { Rank: rank,
errdata = &pb.ErrorData{ Integral: player.Integral,
Code: pb.ErrorCode_DBError, })
Title: pb.ErrorCode_DBError.ToString(), if session.GetUserId() == player.Uinfo.Uid && info.Rank != rank {
Message: err.Error(), info.Rank = rank
if err = this.module.modelArena.updateArenaUserInfo(info); err != nil {
errdata = &pb.ErrorData{
Code: pb.ErrorCode_DBError,
Title: pb.ErrorCode_DBError.ToString(),
Message: err.Error(),
}
} }
} }
} }
} }
session.SendMsg(string(this.module.GetType()), "rank", &pb.ArenaRankResp{Players: players, Info: info}) session.SendMsg(string(this.module.GetType()), "rank", &pb.ArenaRankResp{Players: players, Info: info})
return return