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

Merge branch 'dev' of http://git.legu.cc/liwei_3d/go_dreamfactory into dev

Browse Source
This commit is contained in:
liwei1dao 2023-01-29 15:03:05 +08:00
commit b0d5a9b892
5 changed files with 30 additions and 40 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
comm/const.go
View File

@ -136,8 +136,6 @@ const (
///有序的爬塔排行 (真正的排行榜 最多只有50条)
TablePagodaRankList = "pagodaranklist"
TableSeasonRankList = "seasonranklist" // 赛季塔列表
TableSeasonRecord = "seasonRecord" // 赛季塔记录
/// 美食馆
TableSmithy = "smithy"

16
modules/pagoda/model_rank.go
View File

@ -32,15 +32,15 @@ func (this *ModelRank) Init(service core.IService, module core.IModule, comp cor
return
}
func (this *ModelRank) GetRankData() (data []*pb.DBPagodaRecord, err error) {
data = make([]*pb.DBPagodaRecord, 0)
if conn, err := db.Cross(); err == nil {
err = conn.Redis.LRange(comm.TableSeasonRankList, 0, -1, &data)
}
//err = this.Redis.LRange(comm.TablePagodaRankList, 0, -1, &data)
// func (this *ModelRank) GetRankData() (data []*pb.DBPagodaRecord, err error) {
// data = make([]*pb.DBPagodaRecord, 0)
// if conn, err := db.Cross(); err == nil {
// err = conn.Redis.LRange(comm.TableSeasonRankList, 0, -1, &data)
// }
// //err = this.Redis.LRange(comm.TablePagodaRankList, 0, -1, &data)
return
}
// return
// }
// 写记录
func (this *ModelRank) AddPagodaRecord(uid string, costTime, pagodaId, pagodaType int32) (err error) {

2
modules/sociaty/api_cross_bossrank.go
View File

@ -11,7 +11,7 @@ import (
// 公会BOSS 赛季排行榜
func (this *apiComp) BrankCheck(session comm.IUserSession, req *pb.SociatyBRankReq) (code pb.ErrorCode) {
if req.RankType != 1 || req.RankType != 2 || req.RankType != 3 {
if req.RankType != 1 && req.RankType != 2 && req.RankType != 3 {
code = pb.ErrorCode_ReqParameterError
}
return

41
modules/timer/pagodarank.go
View File

@ -14,6 +14,7 @@ import (
"go.mongodb.org/mongo-driver/mongo/options"
)
// 此组件废弃
type PagodaRank struct {
cbase.ModuleBase
modules.MCompModel
@ -60,23 +61,23 @@ func (this *PagodaRank) TimerPagoda() {
}
}
func (this *PagodaRank) TimerSeason() {
data := make([]interface{}, 0) // options.Find().SetLimit(comm.MaxRankList)
if _data, err := this.DB.Find(comm.TableSeasonPagoda, bson.M{}, options.Find().SetSort(bson.M{"pagodaId": -1}).SetLimit(comm.MaxRankList)); err == nil {
for _data.Next(context.TODO()) {
temp := &pb.DBPagodaRecord{}
if err = _data.Decode(temp); err == nil {
data = append(data, temp)
}
}
}
if len(data) > 0 {
err := this.Redis.RPush(comm.TableSeasonRankList, data...)
if err == nil {
err = this.Redis.Ltrim(comm.TableSeasonRankList, -1*len(data), -1) //对一个列表进行修剪
if err != nil {
log.Errorf("delete failed")
}
}
}
}
// func (this *PagodaRank) TimerSeason() {
// data := make([]interface{}, 0) // options.Find().SetLimit(comm.MaxRankList)
// if _data, err := this.DB.Find(comm.TableSeasonPagoda, bson.M{}, options.Find().SetSort(bson.M{"pagodaId": -1}).SetLimit(comm.MaxRankList)); err == nil {
// for _data.Next(context.TODO()) {
// temp := &pb.DBPagodaRecord{}
// if err = _data.Decode(temp); err == nil {
// data = append(data, temp)
// }
// }
// }
// if len(data) > 0 {
// err := this.Redis.RPush(comm.TableSeasonRankList, data...)
// if err == nil {
// err = this.Redis.Ltrim(comm.TableSeasonRankList, -1*len(data), -1) //对一个列表进行修剪
// if err != nil {
// log.Errorf("delete failed")
// }
// }
// }
// }

9
modules/timer/season.go
View File

@ -231,7 +231,6 @@ func (this *SeasonPagoda) DbTest() {
)
score = int64(i)<<31 + int64(math.MaxInt32-new.CostTime)
tableName = "vikingRank" + strconv.Itoa(int(new.Bosstype))
//vikingrank:mmmxxx1-63bbb137b96efbd321222ce7
strKey := "vikingrank:" + new.Uid + "-" + new.Id // 自定义key new.Uid //
menbers = &redis.Z{Score: float64(score), Member: strKey}
@ -266,15 +265,7 @@ func (this *SeasonPagoda) DbTest() {
if err := model1.Redis.HGetAll(v, result); err == nil {
szRank = append(szRank, result)
}
// result := make([]*pb.DBVikingRank, 0)
// if err := model1.GetList(v, &result); err == nil {
// for _, v2 := range result {
// szRank = append(szRank, v2)
// }
// }
}
this.module.Debugf("%v", szRank)
}
}