|
@@ -11,6 +11,7 @@ import (
|
|
|
"roserver/serverproto"
|
|
"roserver/serverproto"
|
|
|
"sort"
|
|
"sort"
|
|
|
"strconv"
|
|
"strconv"
|
|
|
|
|
+ "time"
|
|
|
)
|
|
)
|
|
|
|
|
|
|
|
// 远航试炼
|
|
// 远航试炼
|
|
@@ -525,8 +526,14 @@ func (this *YuanHangTrialManager) RefreshTrialRank(lastSeasonId int32, rewardPla
|
|
|
data := &serverproto.SSFriendDataSaveReq{
|
|
data := &serverproto.SSFriendDataSaveReq{
|
|
|
SubList: make([]*serverproto.KeyValueType64, 0),
|
|
SubList: make([]*serverproto.KeyValueType64, 0),
|
|
|
}
|
|
}
|
|
|
|
|
+ sleep := service.GetServiceConfig().Node.Type
|
|
|
|
|
+ //其他服等待1服设置奖励排行榜
|
|
|
|
|
+ if sleep != 2 {
|
|
|
|
|
+ time.Sleep(time.Duration(sleep) * time.Second)
|
|
|
|
|
+ }
|
|
|
err := model.GetMessageFromRedis("", YuanHangTrialRankAwardPrefix, data)
|
|
err := model.GetMessageFromRedis("", YuanHangTrialRankAwardPrefix, data)
|
|
|
- if err == redis.Nil {
|
|
|
|
|
|
|
+ //只保留1服来操作排行榜数据,其他服只负责获取奖励排行榜
|
|
|
|
|
+ if err == redis.Nil && sleep == 2 {
|
|
|
//获得前100排行玩家数据
|
|
//获得前100排行玩家数据
|
|
|
for idx := 0; idx < 5; idx++ {
|
|
for idx := 0; idx < 5; idx++ {
|
|
|
startIdx := int64(idx * 20)
|
|
startIdx := int64(idx * 20)
|