| | |
| | | import CrossRealmPlayer
|
| | | import GameWorldBoss
|
| | | import CrossRealmPK
|
| | | import PlayerQuery
|
| | | import PlayerTalk
|
| | | import CrossBoss
|
| | | import ChConfig
|
| | | import GMShell
|
| | |
| | | msgType = msgDict.get("MsgType", -1)
|
| | | msgData = msgDict.get("Data", "")
|
| | | serverGroupID = msgDict.get("ServerGroupID", 0)
|
| | | |
| | | |
| | | if msgType == ShareDefine.ClientServerMsg_PKMatch:
|
| | | CrossRealmPK.ClientServerMsg_PKMatch(serverGroupID, msgData, tick)
|
| | |
|
| | |
| | | elif msgType == ShareDefine.ClientServerMsg_PKBillboard:
|
| | | CrossRealmPK.ClientServerMsg_PKBillboard(serverGroupID, msgData)
|
| | |
|
| | | elif msgType == ShareDefine.ClientServerMsg_ChatCrossWorld:
|
| | | PlayerTalk.ClientServerMsg_ChatCrossWorld(serverGroupID, msgData, tick)
|
| | | |
| | | elif msgType == ShareDefine.ClientServerMsg_GMCMD:
|
| | | GMShell.ClientServerMsg_GMCMD(msgData, tick)
|
| | |
|
| | |
| | |
|
| | | elif msgType == ShareDefine.ClientServerMsg_ViewPlayerCache:
|
| | | CrossRealmPlayer.ClientServerMsg_ViewPlayerCache(serverGroupID, msgData)
|
| | | |
| | | elif msgType == ShareDefine.ClientServerMsg_QueryNPCInfo:
|
| | | PlayerQuery.ClientServerMsg_QueryNPCInfo(serverGroupID, msgData)
|
| | | |
| | | elif msgType == ShareDefine.ClientServerMsg_SetPlayerAttrValue:
|
| | | MapServer_CrossSetPlayerAttrValue(msgData)
|
| | | |
| | | # 需要发送到地图服务器处理的
|
| | | elif msgType in [ShareDefine.ClientServerMsg_Reborn, ShareDefine.ClientServerMsg_CollectNPC]:
|
| | | MapServer_CrossServerReceiveMsg(msgType, msgData, serverGroupID)
|
| | |
|
| | | else:
|
| | | GameWorld.ErrLog("没有该信息类型逻辑处理!")
|
| | |
| | | CrossRealmPlayer.ClientServerMsg_ServerInitOK(serverGroupID)
|
| | | CrossRealmPK.ClientServerMsg_ServerInitOK(serverGroupID, tick)
|
| | | CrossBoss.ClientServerMsg_ServerInitOK(serverGroupID)
|
| | | return
|
| | |
|
| | | def MapServer_CrossServerReceiveMsg(msgType, msgData, serverGroupID):
|
| | | ## 收到子服信息,需要发送到地图服务器处理
|
| | | |
| | | if not isinstance(msgData, dict):
|
| | | return
|
| | | tagPlayerID = msgData.get("PlayerID")
|
| | | if not tagPlayerID:
|
| | | return
|
| | | tagPlayer = GameWorld.GetPlayerManager().FindPlayerByID(tagPlayerID)
|
| | | if not tagPlayer:
|
| | | return
|
| | | msgInfo = str([msgType, msgData, serverGroupID])
|
| | | tagPlayer.MapServer_QueryPlayerResult(0, 0, "CrossServerReceiveMsg", msgInfo, len(msgInfo))
|
| | | return
|
| | |
|
| | | def MapServer_CrossSetPlayerAttrValue(msgData):
|
| | | for playerID, setAttrInfoList in msgData.items():
|
| | | player = GameWorld.GetPlayerManager().FindPlayerByID(playerID)
|
| | | if not player:
|
| | | return
|
| | | msgInfo = str(setAttrInfoList)
|
| | | player.MapServer_QueryPlayerResult(0, 0, "CrossSetPlayerAttrValue", msgInfo, len(msgInfo))
|
| | | return
|
| | |
|
| | | ## ================================================================================================
|
| | |
| | | elif msgType == ShareDefine.CrossServerMsg_Notify:
|
| | | PlayerControl.CrossServerMsg_Notify(msgData)
|
| | |
|
| | | elif msgType == ShareDefine.CrossServerMsg_ChatCrossWorld:
|
| | | PlayerTalk.CrossServerMsg_ChatCrossWorld(msgData)
|
| | | |
| | | elif msgType == ShareDefine.CrossServerMsg_ViewPlayerCacheRet:
|
| | | CrossRealmPlayer.CrossServerMsg_ViewPlayerCacheRet(msgData, tick)
|
| | |
|
| | |
| | | elif msgType == ShareDefine.CrossServerMsg_DropGoodItem:
|
| | | GameWorldBoss.CrossServerMsg_DropGoodItem(msgData, tick)
|
| | |
|
| | | elif msgType == ShareDefine.CrossServerMsg_NPCInfoRet:
|
| | | PlayerQuery.CrossServerMsg_NPCInfoRet(msgData, tick)
|
| | | |
| | | # 需要发送到地图服务器处理的
|
| | | elif msgType in [ShareDefine.CrossServerMsg_RebornRet, ShareDefine.CrossServerMsg_CollectNPCOK]:
|
| | | MapServer_ClientServerReceiveMsg(msgType, msgData)
|
| | | |
| | | elif msgType == ShareDefine.CrossServerMsg_CrossServerState:
|
| | | CrossRealmPlayer.CrossServerMsg_CrossServerState(msgData)
|
| | |
|
| | |
| | |
|
| | | return
|
| | |
|
| | | def MapServer_ClientServerReceiveMsg(msgType, msgData):
|
| | | ## 收到跨服服务器信息,需要发送到地图服务器处理
|
| | | |
| | | if not isinstance(msgData, dict):
|
| | | return
|
| | | tagPlayerID = msgData.get("PlayerID")
|
| | | if not tagPlayerID:
|
| | | return
|
| | | tagPlayer = GameWorld.GetPlayerManager().FindPlayerByID(tagPlayerID)
|
| | | if not tagPlayer:
|
| | | return
|
| | | msgInfo = str([msgType, msgData])
|
| | | tagPlayer.MapServer_QueryPlayerResult(0, 0, "ClientServerReceiveMsg", msgInfo, len(msgInfo))
|
| | | return
|
| | |
|
| | | # 连接跨服服务器状态
|
| | | # 1 为连接成功; 其他为失败,失败会延迟通知
|