diff --git a/modules/arena/modelrank.go b/modules/arena/modelrank.go index 2866ad501..579361f5d 100644 --- a/modules/arena/modelrank.go +++ b/modules/arena/modelrank.go @@ -8,6 +8,7 @@ import ( "go_dreamfactory/modules" "go_dreamfactory/pb" cfg "go_dreamfactory/sys/configure/structs" + "time" "github.com/go-redis/redis/v8" ) @@ -86,6 +87,7 @@ func (this *modelRank) raceSettlement() { reward *cfg.GameArenaRankReward result []string uids []string + Items []*pb.UserAssets err error ) if reward, err = this.module.configure.getRankReward(); err != nil { @@ -93,7 +95,7 @@ func (this *modelRank) raceSettlement() { return } for _, v := range reward.GetDataList() { - if uids, 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), int64(v.RankUp)).Result(); err != nil { this.module.Errorln(err) return } @@ -101,9 +103,22 @@ func (this *modelRank) raceSettlement() { 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, + } + } + //发邮件 + this.module.mail.SendNewMail(&pb.DBMailData{ + CreateTime: uint64(time.Now().Unix()), + Items: Items, + }, uids...) + } - //发邮件 - // this.module.mail } }