From 4c169cf0bb2dde3944c5012d4e67f98851edb497 Mon Sep 17 00:00:00 2001 From: hjdtpz Date: Mon, 22 Apr 2024 21:47:49 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AF=BC=E5=87=BARankData.RefreshTimestamp?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- sysservice/rankservice/MongodbPersist.go | 2 +- sysservice/rankservice/RankData.go | 4 ++-- sysservice/rankservice/RankSkip.go | 2 +- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/sysservice/rankservice/MongodbPersist.go b/sysservice/rankservice/MongodbPersist.go index 2fc7499..6694fb1 100644 --- a/sysservice/rankservice/MongodbPersist.go +++ b/sysservice/rankservice/MongodbPersist.go @@ -357,7 +357,7 @@ func (mp *MongoPersist) removeRankData(rankId uint64,keys []uint64) bool { func (mp *MongoPersist) upsertToDB(collectName string,rankData *RankData) error{ condition := bson.D{{"_id", rankData.Key}} - upsert := bson.M{"_id":rankData.Key,"RefreshTime": rankData.refreshTimestamp, "SortData": rankData.SortData, "Data": rankData.Data,"ExData":rankData.ExData} + upsert := bson.M{"_id":rankData.Key,"RefreshTime": rankData.RefreshTimestamp, "SortData": rankData.SortData, "Data": rankData.Data,"ExData":rankData.ExData} update := bson.M{"$set": upsert} s := mp.mongo.TakeSession() diff --git a/sysservice/rankservice/RankData.go b/sysservice/rankservice/RankData.go index 00a9e88..af0d260 100644 --- a/sysservice/rankservice/RankData.go +++ b/sysservice/rankservice/RankData.go @@ -19,7 +19,7 @@ type RankData struct { Data []byte ExData []int64 - refreshTimestamp int64 //刷新时间 + RefreshTimestamp int64 //刷新时间 //bRelease bool ref bool compareFunc func(other skip.Comparator) int @@ -39,7 +39,7 @@ func NewRankData(isDec bool, data *rpc.RankData,refreshTimestamp int64) *RankDat ret.ExData = append(ret.ExData,d.InitValue+d.IncreaseValue) } - ret.refreshTimestamp = refreshTimestamp + ret.RefreshTimestamp = refreshTimestamp return ret } diff --git a/sysservice/rankservice/RankSkip.go b/sysservice/rankservice/RankSkip.go index e2a7dc1..e6918d7 100644 --- a/sysservice/rankservice/RankSkip.go +++ b/sysservice/rankservice/RankSkip.go @@ -250,7 +250,7 @@ func (rs *RankSkip) UpsetRank(upsetData *rpc.RankData, refreshTimestamp int64, f //找到的情况对比排名数据是否有变化,无变化进行data更新,有变化则进行删除更新 if compareIsEqual(rankNode.SortData, upsetData.SortData) { rankNode.Data = upsetData.GetData() - rankNode.refreshTimestamp = refreshTimestamp + rankNode.RefreshTimestamp = refreshTimestamp if fromLoad == false { rs.rankModule.OnChangeRankData(rs, rankNode)