RoServer/RO_Server_Trunk-branch_0.1.39/rocommon/myta/rpc.go

package myta

import (
	"fmt"
	"github.com/go-redis/redis"
	"rocommon/service"
)

const (
	rankTest = "rank_test"
)

type Rank struct {
}

//member:{
//ServerIndex int         //来自哪个服
//Name string //昵称
//}

type Datas struct {
	Member interface{} //玩家数据
	Score  float64     //分数
}

type Limits struct {
	Page  int64
	Limit int64
}

func (r *Rank) Add(data *Datas, reply *int) error {
	fmt.Println(data)
	*reply = 8
	key := rankTest
	service.GetRedis().ZAdd(key, redis.Z{Member: data.Member, Score: data.Score})
	return nil
}

func (r *Rank) GetRankInfo(l *Limits, reply *[]Datas) error {
	key := rankTest
	s, er := service.GetRedis().ZRangeWithScores(key, (l.Page-1)*l.Limit, l.Page*l.Limit).Result()
	if er != nil {
		return er
	}
	for _, v := range s {
		d := Datas{}
		d.Member = v.Member
		d.Score = v.Score
		*reply = append(*reply, d)
	}
	return nil
}