diff --git a/modules/arena/modelrank.go b/modules/arena/modelrank.go index 0bcff26c3..99795152d 100644 --- a/modules/arena/modelrank.go +++ b/modules/arena/modelrank.go @@ -2,6 +2,7 @@ package arena import ( "context" + "fmt" "go_dreamfactory/comm" "go_dreamfactory/lego/core" "go_dreamfactory/lego/sys/redis/pipe" @@ -95,30 +96,30 @@ func (this *modelRank) raceSettlement() { return } for _, v := range reward.GetDataList() { - if result, err = this.DBModel.Redis.ZRevRange(this.TableName, int64(v.RankLow), int64(v.RankUp)).Result(); err != nil { + if result, err = this.DBModel.Redis.ZRevRange(this.TableName, int64(v.RankLow-1), int64(v.RankUp-1)).Result(); err != nil { this.module.Errorln(err) return } this.module.Debugf("uid:%v", uids) - for i := 0; i < len(result); i += 2 { - uids = append(uids, result[i]) - } - if len(uids) > 0 { - Items = make([]*pb.UserAssets, len(v.RankReward)) - for i, v := range v.RankReward { - Items[i] = &pb.UserAssets{ - A: v.A, - T: v.T, - N: v.N, - } + + Items = make([]*pb.UserAssets, len(v.RankReward)) + for i, v := range v.RankReward { + Items[i] = &pb.UserAssets{ + A: v.A, + T: v.T, + N: v.N, } + } + for i := 0; i < len(result); i += 2 { + // uids = append(uids, result[i]) //发邮件 this.module.mail.SendNewMail(&pb.DBMailData{ + Cid: "ArenaRankingReward", + Param: []string{fmt.Sprintf("%d", v.RankLow+int32(i))}, CreateTime: uint64(configure.Now().Unix()), Items: Items, - }, uids...) + }, result[i]) } - } }