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) {