package arena import ( "go_dreamfactory/comm" "go_dreamfactory/pb" ) // 参数校验 func (this *apiComp) RankCheck(session comm.IUserSession, req *pb.ArenaRankReq) (errdata *pb.ErrorData) { return } // /排行榜获取 func (this *apiComp) Rank(session comm.IUserSession, req *pb.ArenaRankReq) (errdata *pb.ErrorData) { var ( info *pb.DBArenaUser uids []string ranks []*pb.DBArenaUser ranksMap map[string]*pb.DBArenaUser players []*pb.ArenaPlayer err error ) if errdata = this.RankCheck(session, req); errdata != nil { return } if info, err = this.module.modelArena.queryPlayerInfo(session.GetUserId()); err != nil { errdata = &pb.ErrorData{ Code: pb.ErrorCode_DBError, Title: pb.ErrorCode_DBError.ToString(), Message: err.Error(), } return } if uids, err = this.module.modelRank.queryRankUser(); err != nil { errdata = &pb.ErrorData{ Code: pb.ErrorCode_DBError, Title: pb.ErrorCode_DBError.ToString(), Message: err.Error(), } return } if ranks, err = this.module.modelArena.queryPlayers(uids); err != nil { errdata = &pb.ErrorData{ Code: pb.ErrorCode_DBError, Title: pb.ErrorCode_DBError.ToString(), Message: err.Error(), } return } ranksMap = make(map[string]*pb.DBArenaUser) for _, v := range ranks { ranksMap[v.Uid] = v } players = make([]*pb.ArenaPlayer, 0, len(uids)) for i, v := range uids { if player, ok := ranksMap[v]; ok { rank := int32(i + 1) players = append(players, &pb.ArenaPlayer{ Uinfo: player.Uinfo, Dan: player.Dan, Rank: rank, Integral: player.Integral, }) if session.GetUserId() == player.Uinfo.Uid && info.Rank != rank { 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}) return }