From 3752feb4efa8d1dfe7a964e5501c69e79362f247 Mon Sep 17 00:00:00 2001
From: liuxiaobo <1224730913@qq.com>
Date: Thu, 29 May 2025 20:30:31 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0client=E6=B5=8B=E8=AF=95?=
 =?UTF-8?q?=E7=AB=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 server/gate/server/service.go | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git a/server/gate/server/service.go b/server/gate/server/service.go
index cde86aa..0f3bf3b 100644
--- a/server/gate/server/service.go
+++ b/server/gate/server/service.go
@@ -158,7 +158,8 @@ func (s *GateService) OnMessage(data []byte) error {
 */
 func (s *GateService) findTopic(userId int64, serviceTypeId pb.ServiceTypeId) (topic, sName string) {
 	if userId != 0 {
-		if sName, err := s.bindService.FindServiceName(userId, serviceTypeId); err == nil {
+		var err error
+		if sName, err = s.bindService.FindServiceName(userId, serviceTypeId); err == nil {
 			return service.TopicEx(sName), sName
 		} else {
 			log.Error(err.Error())
@@ -181,6 +182,12 @@ func (s *GateService) WsOnMessage(conn ws.IConn, data []byte) {
 		topic, msg.ServiceName = s.findTopic(conn.UserId(), msg.ServiceTid)
 	}
 	if topic != "" {
+		if msg.MsgId == int32(pb.MsgId_C2SUserLoginId) {
+			req := &pb.C2SUserLogin{}
+			_ = proto.Unmarshal(msg.Data, req)
+			req.Ip = conn.Addr()
+			msg.Data, _ = proto.Marshal(req)
+		}
 		s.SendServiceData(topic, conn, msg.MsgId, msg.Data)
 	} else {
 		log.Error(s.Log("topic:%v not exist.user:%v", topic, conn.UserId()))