fatiao/ro-webgl-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

直播间爱心保存

Browse Source
This commit is contained in:
fatiao 2026-03-04 16:38:27 +08:00
parent 12b03945a8
commit 88cd38e659
1 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
server/roserver/fruit/model/live_room.go
View File

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