liwei_3d/go_dreamfactory
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

周比赛奖励推送接口

Browse Source
This commit is contained in:
liwei1dao 2022-10-26 18:47:11 +08:00
parent 496c7a405f
commit b8817f7dcf
1 changed files with 18 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
modules/arena/modelrank.go
View File

@ -8,6 +8,7 @@ import (
"go_dreamfactory/modules" "go_dreamfactory/modules"
"go_dreamfactory/pb" "go_dreamfactory/pb"
cfg "go_dreamfactory/sys/configure/structs" cfg "go_dreamfactory/sys/configure/structs"
"time"
"github.com/go-redis/redis/v8" "github.com/go-redis/redis/v8"
) )
@ -86,6 +87,7 @@ func (this *modelRank) raceSettlement() {
reward *cfg.GameArenaRankReward reward *cfg.GameArenaRankReward
result []string result []string
uids []string uids []string
Items []*pb.UserAssets
err error err error
) )
if reward, err = this.module.configure.getRankReward(); err != nil { if reward, err = this.module.configure.getRankReward(); err != nil {
@ -93,7 +95,7 @@ func (this *modelRank) raceSettlement() {
return return
} }
for _, v := range reward.GetDataList() { 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) this.module.Errorln(err)
return return
} }
@ -101,9 +103,22 @@ func (this *modelRank) raceSettlement() {
for i := 0; i < len(result); i += 2 { for i := 0; i < len(result); i += 2 {
uids = append(uids, result[i]) 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
} }
} }