package realarena import ( "go_dreamfactory/comm" "go_dreamfactory/pb" ) // 参数校验 func (this *apiComp) RankCheck(session comm.IUserSession, req *pb.RealArenaRankReq) (errdata *pb.ErrorData) { return } // /排行榜获取 func (this *apiComp) Rank(session comm.IUserSession, req *pb.RealArenaRankReq) (errdata *pb.ErrorData) { var ( info *pb.DBRealArena uids []string ranks []*pb.DBRealArena ranksMap map[string]*pb.DBRealArena players []*pb.DBRealArena err error ) if errdata = this.RankCheck(session, req); errdata != nil { return } if info, err = this.module.model.getinfo(session); 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.model.getinfos(uids); err != nil { errdata = &pb.ErrorData{ Code: pb.ErrorCode_DBError, Title: pb.ErrorCode_DBError.ToString(), Message: err.Error(), } return } ranksMap = make(map[string]*pb.DBRealArena) for _, v := range ranks { ranksMap[v.Uid] = v } players = make([]*pb.DBRealArena, 0, len(uids)) for i, v := range uids { if player, ok := ranksMap[v]; ok { rank := int32(i + 1) players = append(players, &pb.DBRealArena{ 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.model.change(info.Uid, map[string]interface{}{ "rank": info.Rank, }); 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.RealArenaRankResp{Rank: players}) return }