From 5768776e564b852e6a77089a37da1e2f54724cf2 Mon Sep 17 00:00:00 2001
From: hahwu <31872165+hahwu@users.noreply.github.com>
Date: Wed, 24 Dec 2025 17:05:39 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B6=88=E6=81=AF=E6=9C=8D=E5=8A=A1=E4=BC=98?=
 =?UTF-8?q?=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/server/game/message_mgr.go | 8 +++-----
 1 file changed, 3 insertions(+), 5 deletions(-)

diff --git a/src/server/game/message_mgr.go b/src/server/game/message_mgr.go
index f2da29e9..2be9a055 100644
--- a/src/server/game/message_mgr.go
+++ b/src/server/game/message_mgr.go
@@ -185,9 +185,9 @@ func ClusterSyncHandler(data *msg.Msg) (interface{}, error) {
 	defer messageMgrData.mu.Unlock()
 	TempMessageList := messageMgrData.MessageList
 	messageMgrData.MessageList = make(map[int64]*MessageList)
-	for PlayerId, Message := range TempMessageList {
+	for _, Message := range TempMessageList {
 		for _, msgItem := range Message.Messages {
-			go SendMsgToNodeAsync(msgItem, messageMgrData.PlayerList[PlayerId])
+			SendMsgToCenterAsync(msgItem)
 		}
 	}
 	return nil, nil
@@ -263,9 +263,7 @@ func CenterPlayerMsgHandler(data *msg.Msg) (interface{}, error) {
 	defer messages.mu.Unlock()
 	messages.Messages = append(messages.Messages, data)
 	if node, ok := messageMgrData.PlayerList[int64(PlayerId)]; ok {
-		for _, message := range messages.Messages {
-			go SendMsgToNodeAsync(message, node)
-		}
+		go SendMsgToNodeAsync(data, node)
 	}
 	return nil, nil
 }