From 0c65af22ea6e9eb260da56f9202981bc229b5ea0 Mon Sep 17 00:00:00 2001
From: sk <123456@qq.com>
Date: Tue, 17 Dec 2024 13:29:50 +0800
Subject: [PATCH] =?UTF-8?q?add:=E5=AF=B9=E5=B1=80=E4=B8=AD=E7=8E=A9?=
 =?UTF-8?q?=E5=AE=B6=E4=BA=BA=E6=95=B0=E4=B8=8A=E6=8A=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 common/clock.go              |   5 ++
 model/rabbit_mq.go           |   7 ++
 mq/keyconf.go                |   1 +
 worldsrv/player.go           |   5 --
 worldsrv/playeronline.go     |  36 ++++++++--
 worldsrv/playeronlinegame.go | 125 +++++++++++++++++++++++++++++++++++
 worldsrv/scene.go            |   4 ++
 7 files changed, 174 insertions(+), 9 deletions(-)
 create mode 100644 worldsrv/playeronlinegame.go

diff --git a/common/clock.go b/common/clock.go
index 92bf8ec..c46dc37 100644
--- a/common/clock.go
+++ b/common/clock.go
@@ -250,6 +250,7 @@ func RegisterClockFunc(fs *ClockFunc) {
 	if fs == nil {
 		return
 	}
+
 	if fs.OnSecTimerFunc != nil {
 		fs.event = fs.event | 1<<ClockEventSecond
 	}
@@ -272,5 +273,9 @@ func RegisterClockFunc(fs *ClockFunc) {
 		fs.event = fs.event | 1<<ClockEventShutdown
 	}
 
+	if fs.event == 0 {
+		return
+	}
+
 	ClockMgrSingleton.RegisterSinker(fs)
 }
diff --git a/model/rabbit_mq.go b/model/rabbit_mq.go
index f2a59a1..ab7fd03 100644
--- a/model/rabbit_mq.go
+++ b/model/rabbit_mq.go
@@ -15,6 +15,13 @@ func GenerateOnline(online map[string]map[string]int) *mq.RabbitMQData {
 	return NewRabbitMQData(mq.BackOnline, params)
 }
 
+func GenerateOnlineGame(online map[string]map[string]map[string]map[int]map[int]int) *mq.RabbitMQData {
+	params := make(map[string]interface{})
+	params["Online"] = online
+	params["Time"] = time.Now().Unix()
+	return NewRabbitMQData(mq.BackOnlineGame, params)
+}
+
 // GenerateLogin 玩家登陆事件
 func GenerateLogin(o *PlayerLoginEvent) *mq.RabbitMQData {
 	return NewRabbitMQData(mq.BackLogin, o)
diff --git a/mq/keyconf.go b/mq/keyconf.go
index 942db62..1bb8836 100644
--- a/mq/keyconf.go
+++ b/mq/keyconf.go
@@ -18,6 +18,7 @@ const (
 	BackSystemPermitTask     = "back_permittask"
 	BackSystemJyb            = "back_jyblog"
 	BackActivityLog          = "back_activitylog"
+	BackOnlineGame           = "back_onlinegame"
 )
 
 // mgrsrv
diff --git a/worldsrv/player.go b/worldsrv/player.go
index 2326fb5..f558772 100644
--- a/worldsrv/player.go
+++ b/worldsrv/player.go
@@ -324,8 +324,6 @@ func (this *Player) OnLogined() {
 
 		this.DealShopLog()
 
-		PlayerOnlineSington.Check = true
-
 		this.LoadMessage(tLastLogout.Unix(), isFirstLogin, !inSameWeek)
 
 		//登录次数
@@ -401,7 +399,6 @@ func (this *Player) OnRehold() {
 	if !this.IsRob {
 		TournamentMgr.Quit(this.Platform, this.SnId) // 比赛没有开始，退赛
 		this.SendJackPotInit()
-		PlayerOnlineSington.Check = true
 
 		this.DealShopLog()
 
@@ -1188,7 +1185,6 @@ func (this *Player) DropLine() {
 
 		this.SendPlayerCoin()
 		this.OnlineLogDrop()
-		PlayerOnlineSington.Check = true
 	}
 
 	if this.scene != nil && this.scene.gameSess != nil {
@@ -1222,7 +1218,6 @@ func (this *Player) OnLogoutFinish() {
 
 	if !this.IsRobot() {
 		FriendUnreadMgrSington.SaveFriendUnreadData(this.Platform, this.SnId)
-		PlayerOnlineSington.Check = true
 
 		//登录日志
 		logState := LoginStateMgrSington.GetLoginStateBySid(this.sid)
diff --git a/worldsrv/playeronline.go b/worldsrv/playeronline.go
index 6c0d77a..65ca683 100644
--- a/worldsrv/playeronline.go
+++ b/worldsrv/playeronline.go
@@ -8,8 +8,40 @@ import (
 	"mongo.games.com/game/common"
 	"mongo.games.com/game/model"
 	"mongo.games.com/game/mq"
+	"mongo.games.com/game/worldsrv/internal"
 )
 
+func init() {
+	module.RegisteModule(PlayerOnlineSington, 5*time.Second, 0)
+
+	internal.RegisterPlayerListenerFunc(&internal.PlayerListenerFunc[*Player, *Scene]{
+		OnPlayerLoginedFunc: func(p *Player) {
+			if p == nil || p.IsRob {
+				return
+			}
+			PlayerOnlineSington.Check = true
+		},
+		OnPlayerLogoutedFunc: func(p *Player) {
+			if p == nil || p.IsRob {
+				return
+			}
+			PlayerOnlineSington.Check = true
+		},
+		OnPlayerDropLineFunc: func(p *Player) {
+			if p == nil || p.IsRob {
+				return
+			}
+			PlayerOnlineSington.Check = true
+		},
+		OnPlayerReholdFunc: func(p *Player) {
+			if p == nil || p.IsRob {
+				return
+			}
+			PlayerOnlineSington.Check = true
+		},
+	})
+}
+
 var PlayerOnlineSington = &PlayerOnlineEvent{
 	OnlineCh: make(map[string]map[string]int),
 }
@@ -66,7 +98,3 @@ here:
 func (p *PlayerOnlineEvent) Shutdown() {
 	module.UnregisteModule(p)
 }
-
-func init() {
-	module.RegisteModule(PlayerOnlineSington, 5*time.Second, 0)
-}
diff --git a/worldsrv/playeronlinegame.go b/worldsrv/playeronlinegame.go
new file mode 100644
index 0000000..7495b0d
--- /dev/null
+++ b/worldsrv/playeronlinegame.go
@@ -0,0 +1,125 @@
+package main
+
+import (
+	"slices"
+	"time"
+
+	"golang.org/x/exp/maps"
+	"mongo.games.com/goserver/core/logger"
+	"mongo.games.com/goserver/core/module"
+
+	"mongo.games.com/game/common"
+	"mongo.games.com/game/model"
+	"mongo.games.com/game/mq"
+	"mongo.games.com/game/worldsrv/internal"
+)
+
+func init() {
+	module.RegisteModule(PlayerOnlineGameSingleton, 10*time.Second, 0)
+
+	internal.RegisterPlayerListenerFunc(&internal.PlayerListenerFunc[*Player, *Scene]{
+		OnPlayerEnterSceneAfterFunc: func(p *Player, s *Scene) {
+			if p == nil || p.IsRob {
+				return
+			}
+			PlayerOnlineGameSingleton.Check = true
+		},
+		OnPlayerLeaveSceneAfterFunc: func(p *Player, s *Scene) {
+			if p == nil || p.IsRob {
+				return
+			}
+			PlayerOnlineGameSingleton.Check = true
+		},
+	})
+}
+
+var PlayerOnlineGameSingleton = &PlayerOnlineGameEvent{
+	Online: make(map[string]map[string]map[string]map[int]map[int]int),
+}
+
+type PlayerOnlineGameEvent struct {
+	Online map[string]map[string]map[string]map[int]map[int]int // 平台：推广渠道：游戏组：游戏id：场次id：在线人数
+	Check  bool
+}
+
+func (p *PlayerOnlineGameEvent) ModuleName() string {
+	return "PlayerOnlineGameEvent"
+}
+
+func (p *PlayerOnlineGameEvent) Init() {
+}
+
+func (p *PlayerOnlineGameEvent) Update() {
+	if !p.Check {
+		return
+	}
+	p.Check = false
+
+	onlineCh := make(map[string]map[string]map[string]map[int]map[int]int)
+
+	for _, v := range SceneMgrSingleton.scenes {
+		if v == nil {
+			continue
+		}
+
+		plt := SceneMgrSingleton.GetPlatformBySceneId(v.sceneId)
+		// 平台
+		if _, ok := onlineCh[plt]; !ok {
+			onlineCh[plt] = map[string]map[string]map[int]map[int]int{}
+		}
+
+		for _, player := range v.players {
+			if player == nil || player.IsRob || player.Platform == common.Platform_Rob && player.Channel == common.Channel_Rob {
+				continue
+			}
+
+			// 渠道
+			if _, ok := onlineCh[plt][player.ChannelId]; !ok {
+				onlineCh[plt][player.ChannelId] = map[string]map[int]map[int]int{}
+			}
+			// 游戏组
+			if _, ok := onlineCh[plt][player.ChannelId][v.dbGameFree.GetGameDif()]; !ok {
+				onlineCh[plt][player.ChannelId][v.dbGameFree.GetGameDif()] = map[int]map[int]int{}
+			}
+			// 游戏id
+			if _, ok := onlineCh[plt][player.ChannelId][v.dbGameFree.GetGameDif()][int(v.dbGameFree.GetGameId())]; !ok {
+				onlineCh[plt][player.ChannelId][v.dbGameFree.GetGameDif()][int(v.dbGameFree.GetGameId())] = map[int]int{}
+			}
+			onlineCh[plt][player.ChannelId][v.dbGameFree.GetGameDif()][int(v.dbGameFree.GetGameId())][int(v.dbGameFree.GetId())] += 1
+		}
+	}
+
+	// 判断差异
+	if !slices.Equal(maps.Keys(p.Online), maps.Keys(onlineCh)) {
+		goto here
+	}
+	for k, v := range p.Online {
+		if !slices.Equal(maps.Keys(v), maps.Keys(onlineCh[k])) {
+			goto here
+		}
+		for k1, v1 := range v {
+			if !slices.Equal(maps.Keys(v1), maps.Keys(onlineCh[k][k1])) {
+				goto here
+			}
+			for k2, v2 := range v1 {
+				if !slices.Equal(maps.Keys(v2), maps.Keys(onlineCh[k][k1][k2])) {
+					goto here
+				}
+				for k3, v3 := range v2 {
+					if !slices.Equal(maps.Keys(v3), maps.Keys(onlineCh[k][k1][k2][k3])) {
+						goto here
+					}
+				}
+			}
+		}
+	}
+
+here:
+	p.Online = onlineCh
+	mq.Write(model.GenerateOnlineGame(p.Online))
+	logger.Logger.Trace("PlayerOnlineGameEvent", p.Online)
+}
+
+func (p *PlayerOnlineGameEvent) Shutdown() {
+	module.UnregisteModule(p)
+}
diff --git a/worldsrv/scene.go b/worldsrv/scene.go
index a23bafa..c8e81e9 100644
--- a/worldsrv/scene.go
+++ b/worldsrv/scene.go
@@ -162,6 +162,10 @@ func NewScene(args *CreateSceneParam) *Scene {
 	return s
 }
 
+func (this *Scene) GetPlatform() *Platform {
+	return this.platform
+}
+
 func (this *Scene) RobotIsLimit() bool {
 	if this.robotLimit != 0 {
 		if this.robotNum >= this.robotLimit {