From 88cd38e659e3245a97d7d7a340daa37c85f7a240 Mon Sep 17 00:00:00 2001 From: fatiao <515948292@qq.com> Date: Wed, 4 Mar 2026 16:38:27 +0800 Subject: [PATCH] =?UTF-8?q?=E7=9B=B4=E6=92=AD=E9=97=B4=E7=88=B1=E5=BF=83?= =?UTF-8?q?=E4=BF=9D=E5=AD=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- server/roserver/fruit/model/live_room.go | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/server/roserver/fruit/model/live_room.go b/server/roserver/fruit/model/live_room.go index 3ab336e..ddb9d64 100644 --- a/server/roserver/fruit/model/live_room.go +++ b/server/roserver/fruit/model/live_room.go @@ -210,9 +210,9 @@ func (self *LiveRoom) BaseInit() { time4 := self.CalcTimelineSec(self.resultTimeline) util.InfoF("GetTimelineTime: ", time1, time2, time3, time4) - heartStr, err := service.GetRedis().HGet(model.LiveRoomHeartPrefix, string(self.roomType)).Result() + heartStr, err := service.GetRedis().HGet(model.LiveRoomHeartPrefix, fmt.Sprintf("%d", self.roomType)).Result() if err != nil { - util.InfoF("ERR: Redis HGet %s:%s err", model.LiveRoomHeartPrefix, string(self.roomType)) + util.InfoF("ERR: Redis HGet %s:%s err", model.LiveRoomHeartPrefix, fmt.Sprintf("%d", self.roomType)) } heartNum, _ := strconv.ParseInt(heartStr, 10, 64) self.heart = heartNum @@ -271,6 +271,12 @@ func (self *LiveRoom) Update(deltaMS uint32) { self.giftRankResetTime = util.GetCurrentTime() util.InfoF("ResetGiftRank: RoomType=%d, time=%d", self.roomType, self.giftRankResetTime) } + if self.updateCount%300 == 0 { + ret, err := service.GetRedis().HSet(model.LiveRoomHeartPrefix, fmt.Sprintf("%d", self.roomType), fmt.Sprintf("%d", self.heart)).Result() + if err != nil { + util.InfoF("[LiveRoom] Update HSet: %v %v", err, ret) + } + } } func (self *LiveRoom) ChangeStage(newStage uint32) {