From ec635783c44d422f5867079153fef843d2b97a45 Mon Sep 17 00:00:00 2001
From: sk <123456@qq.com>
Date: Thu, 25 Apr 2024 13:34:23 +0800
Subject: [PATCH] =?UTF-8?q?evt=5Fonline=E6=B7=BB=E5=8A=A0=E6=B8=A0?=
 =?UTF-8?q?=E9=81=93=E4=BF=A1=E6=81=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 model/rabbit_mq.go       | 10 +---------
 worldsrv/playeronline.go |  8 ++++----
 2 files changed, 5 insertions(+), 13 deletions(-)

diff --git a/model/rabbit_mq.go b/model/rabbit_mq.go
index d42ca2a..059409b 100644
--- a/model/rabbit_mq.go
+++ b/model/rabbit_mq.go
@@ -9,16 +9,8 @@ import (
 
 // GenerateOnline 在线统计
 func GenerateOnline(online map[string]map[string]int) *RabbitMQData {
-	m := map[string]map[int]int{} // 渠道：平台：真人数
-	for k, v := range online {
-		m[k] = map[int]int{}
-		for k1, v1 := range v {
-			pf, _ := strconv.Atoi(k1)
-			m[k][pf] = v1
-		}
-	}
 	params := make(map[string]interface{})
-	params["Online"] = m
+	params["Online"] = online
 	params["Time"] = time.Now().Unix()
 	return NewRabbitMQData(mq.BackOnline, params)
 }
diff --git a/worldsrv/playeronline.go b/worldsrv/playeronline.go
index 6db8d03..71de553 100644
--- a/worldsrv/playeronline.go
+++ b/worldsrv/playeronline.go
@@ -32,12 +32,12 @@ func (p *PlayerOnlineEvent) Update() {
 	onlineCh := map[string]map[string]int{}
 	for _, player := range PlayerMgrSington.sidMap {
 		if player != nil && !player.IsRob && player.IsOnLine() {
-			info, ok := onlineCh[player.Channel]
+			info, ok := onlineCh[player.Platform]
 			if !ok {
-				onlineCh[player.Channel] = map[string]int{}
-				info = onlineCh[player.Channel]
+				onlineCh[player.Platform] = map[string]int{}
+				info = onlineCh[player.Platform]
 			}
-			info[player.Platform] += 1
+			info[player.Channel] += 1
 		}
 	}
 	if len(onlineCh) == len(p.OnlineCh) {