This commit is contained in:
liwei1dao 2022-08-24 17:42:31 +08:00
commit 5ec1af1f54
4 changed files with 6 additions and 8 deletions

View File

@ -3,7 +3,6 @@ package pagoda
import ( import (
"go_dreamfactory/comm" "go_dreamfactory/comm"
"go_dreamfactory/pb" "go_dreamfactory/pb"
"log"
"go.mongodb.org/mongo-driver/bson/primitive" "go.mongodb.org/mongo-driver/bson/primitive"
"google.golang.org/protobuf/proto" "google.golang.org/protobuf/proto"
@ -45,7 +44,6 @@ func (this *apiComp) GetList(session comm.IUserSession, req *pb.PagodaGetListReq
list.PagodaId = season.PagodaId list.PagodaId = season.PagodaId
list.Type = season.Type list.Type = season.Type
} }
ranklist, _ := this.module.modulerank.GetRankData()
log.Fatalf("%v", ranklist)
return return
} }

View File

@ -17,9 +17,9 @@ func (this *apiComp) RankList(session comm.IUserSession, req *pb.PagodaRankListR
code = this.RankListCheck(session, req) code = this.RankListCheck(session, req)
if code != pb.ErrorCode_Success { if code != pb.ErrorCode_Success {
return // 参数校验失败直接返回 return
} }
// 临时测试用
szRank, err := this.module.modulerank.GetRankData() szRank, err := this.module.modulerank.GetRankData()
if err != nil { if err != nil {
code = pb.ErrorCode_DBError code = pb.ErrorCode_DBError

View File

@ -55,9 +55,9 @@ func (this *ModelRank) ChangeUserRank(uid string, value map[string]interface{})
return this.Change(uid, value) return this.Change(uid, value)
} }
// 临时测试
func (this *ModelRank) GetRankData() (data []*pb.DBPagodaRank, err error) { func (this *ModelRank) GetRankData() (data []*pb.DBPagodaRank, err error) {
err = this.Redis.Get(comm.TablePagodaRank, data) data = make([]*pb.DBPagodaRank, 0)
err = this.Redis.LRange(comm.TablePagodaRank, 0, -1, &data)
return return
} }

View File

@ -30,7 +30,7 @@ func (this *PagodaRank) Init(service core.IService, module core.IModule, comp co
func (this *PagodaRank) Start() (err error) { func (this *PagodaRank) Start() (err error) {
err = this.MCompModel.Start() err = this.MCompModel.Start()
cron.AddFunc("*/5 * * * * ?", this.Timer) //每五秒执行一次 cron.AddFunc("*/60 * * * * ?", this.Timer) //每60s执行一次
return return
} }