From dae842ad6e4a43d66255251e3ca60880af8d08bb Mon Sep 17 00:00:00 2001
From: hxp <ale99527@vip.qq.com>
Date: 星期四, 09 十月 2025 16:26:25 +0800
Subject: [PATCH] 242 【福利内容】每日签到-服务端
---
ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/NetPackCommon.py | 57 +++++++++++++++++++++++++++++++++++++++++++--------------
1 files changed, 43 insertions(+), 14 deletions(-)
diff --git a/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/NetPackCommon.py b/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/NetPackCommon.py
index 2213f4d..a9b3f02 100644
--- a/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/NetPackCommon.py
+++ b/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/NetPackCommon.py
@@ -30,6 +30,8 @@
import ChPyNetSendPack
import traceback
import ChGameToMapPyPack
+from PyMongoDB.DBCommon import CommonDefine
+import ObjPool
#-------------------------------------------------------------------------------
#---全局变量---
@@ -226,7 +228,22 @@
Log("SendFakePack: clientPack Len = %s > %s"%(clientPack.GetLength(), len(innerPackData)))
#curPlayer.SendFakePack(innerPackData, len(innerPackData))
curPlayer.SendFakePack(clientPack.GetBuffer(), clientPack.GetLength())
+ ObjPool.GetPoolMgr().release(clientPack)
+ return
+def SendFackPackOnline(clientPack, parseFunc=None, *args):
+ ## 发送给全服在线玩家
+ # @param parseFunc: 中间处理逻辑，可以做一些修改包数据的逻辑或者过滤某些玩家不发送，返回值为True时发送
+ # @param args: parseFunc方法参数(curPlayer, ...)
+ playerManager = GameWorld.GetPlayerManager()
+ for i in xrange(playerManager.OnlineCount()):
+ curPlayer = playerManager.OnlineAt(i)
+ if not GameWorld.IsNormalPlayer(curPlayer):
+ continue
+ if parseFunc and not parseFunc(curPlayer, *args):
+ continue
+ SendFakePack(curPlayer, clientPack)
+ return
#-------------------------------------------------------------------------------
#---Py封包注册信息
@@ -288,21 +305,33 @@
##发送Map到GameServer的沟通包
#
def SendPyPackToGameServer(sendPack):
- if hasattr(sendPack, 'PlayerID'):
- if sendPack.PlayerID >= 100000000:
- return
- routeIndex = GameWorld.GetGameWorld().GetLineNO()
- #这里必须用GetRealMapID,GetMapID 实际取到的是DataMapID，在有分线的地图会问题
- mapID = GameWorld.GetGameWorld().GetRealMapID()
- #先写入当前地图标识，方便GameServer回包时可以正确通知到对应地图
- data = ''
- data = CommFunc.WriteBYTE(data, routeIndex) #1
- data = CommFunc.WriteDWORD(data, mapID) #4
- data = CommFunc.WriteString(data, sendPack.GetLength(), sendPack.GetBuffer())
+ # if hasattr(sendPack, 'PlayerID'):
+ # if sendPack.PlayerID >= 100000000:
+ # return
+ # routeIndex = GameWorld.GetGameWorld().GetLineNO()
+ # #这里必须用GetRealMapID,GetMapID 实际取到的是DataMapID，在有分线的地图会问题
+ # mapID = GameWorld.GetGameWorld().GetRealMapID()
+ # #先写入当前地图标识，方便GameServer回包时可以正确通知到对应地图
+ # data = ''
+ # data = CommFunc.WriteBYTE(data, routeIndex) #1
+ # data = CommFunc.WriteDWORD(data, mapID) #4
+ # data = CommFunc.WriteString(data, sendPack.GetLength(), sendPack.GetBuffer())
- dataLen = 1 + 4 + sendPack.GetLength()
+ # dataLen = 1 + 4 + sendPack.GetLength()
- GameWorld.GetGameWorld().SendGameServerGeneralPack(dataLen, data)
+ # GameWorld.GetGameWorld().SendGameServerGeneralPack(dataLen, data)
+ return
-
+##向地图（c++）发送数据
+# 结构体要求第一个类型为枚举 TDataServerToBalanceServer，不需要封包头，用类型做判断
+def SendPyPackToMapServerSelf(data, datalen):
+ GameWorld.GetGameWorld().SendPyPackToMapServerSelf(datalen, data)
+ return
+
+
+
+# 向ServersRoute发送数据
+def SendPyPackToServersRoute(data, datalen):
+ GameWorld.GetGameWorld().SendPyPackToServersRoute(datalen, data)
+ return
\ No newline at end of file
--
Gitblit v1.8.0