| | |
| | | import PlayerFuncTeam
|
| | | import CrossLuckyCloudBuy
|
| | | import IPY_GameServer
|
| | | import PlayerViewCache
|
| | | import CrossRealmPlayer
|
| | | import PlayerCompensation
|
| | | import PlayerActBossTrial
|
| | |
| | | if not GameWorld.GetGameWorld().GetDictByKey(ChConfig.Def_WorldKey_GameWorldInitOK):
|
| | | GameWorld.ErrLog("服务器未启动好,不允许向跨服服务器发送数据! %s" % (srcMsg))
|
| | | return
|
| | | GameWorld.Log("SendMsgToCrossServer => %s" % (srcMsg)) |
| | | GameWorld.Log("SendMsgToCrossServer => %s, %s" % (msgType, srcMsg)) |
| | | GameWorld.GetGameWorld().SendMergerChildToCenterStringData(sendMsg, len(sendMsg))
|
| | | return
|
| | |
|
| | |
| | | return
|
| | | msgDict = cPickle.loads(recvMsg)
|
| | |
|
| | | GameWorld.Log("OnCrossServerReceiveMsg: %s" % msgDict)
|
| | | |
| | | msgType = msgDict.get("MsgType", -1)
|
| | | msgData = msgDict.get("Data", "")
|
| | | serverGroupID = msgDict.get("ServerGroupID", 0)
|
| | | |
| | | GameWorld.Log("OnCrossServerReceiveMsg: %s, %s, %s" % (msgType, serverGroupID, msgDict))
|
| | |
|
| | | if msgType == ShareDefine.ClientServerMsg_PKMatch:
|
| | | CrossRealmPK.ClientServerMsg_PKMatch(serverGroupID, msgData, tick)
|
| | |
| | | ClientServerMsg_ServerInitOK(serverGroupID, tick)
|
| | |
|
| | | elif msgType == ShareDefine.ClientServerMsg_ViewPlayerCache:
|
| | | CrossRealmPlayer.ClientServerMsg_ViewPlayerCache(serverGroupID, msgData)
|
| | | PlayerViewCache.ClientServerMsg_ViewPlayerCache(serverGroupID, msgData)
|
| | | |
| | | elif msgType == ShareDefine.ClientServerMsg_PushPlayerCache:
|
| | | PlayerViewCache.ClientServerMsg_PushPlayerCache(serverGroupID, msgData)
|
| | |
|
| | | elif msgType == ShareDefine.ClientServerMsg_PullOtherPlayerPackData:
|
| | | PlayerPackData.ClientServerMsg_PullOtherPlayerPackData(serverGroupID, msgData)
|
| | |
| | | if not GameWorld.GetGameWorld().GetDictByKey(ChConfig.Def_WorldKey_GameWorldInitOK):
|
| | | GameWorld.ErrLog("跨服服务器未启动好,不允许向子服发送数据! serverGroupIDList=%s, srcMsg=%s" % (serverGroupIDList, srcMsg))
|
| | | return
|
| | | GameWorld.Log("SendMsgToClientServer => serverGroupIDList=%s, srcMsg=%s" % (serverGroupIDList, srcMsg))
|
| | | GameWorld.Log("SendMsgToClientServer => %s, %s, %s" % (msgType, serverGroupIDList, srcMsg))
|
| | | if not serverGroupIDList:
|
| | | GameWorld.GetGameWorld().SendBroadcastMergeClient(sendMsg, len(sendMsg))
|
| | | else:
|
| | |
| | | msgType = msgDict.get("MsgType", -1)
|
| | | msgData = msgDict.get("Data", "")
|
| | | crossServerTimeStr = msgDict.get("CrossServerTime", "")
|
| | | GameWorld.Log("OnClientServerReceiveMsg: %s" % msgDict)
|
| | | GameWorld.Log("OnClientServerReceiveMsg: %s, %s" % (msgType, msgDict))
|
| | | if crossServerTimeStr:
|
| | | curServerTime = int(time.time())
|
| | | crossServerTime = GameWorld.ChangeTimeStrToNum(crossServerTimeStr)
|
| | |
| | | PlayerTalk.CrossServerMsg_ChatCrossWorld(msgData)
|
| | |
|
| | | elif msgType == ShareDefine.CrossServerMsg_ViewPlayerCacheRet:
|
| | | CrossRealmPlayer.CrossServerMsg_ViewPlayerCacheRet(msgData, tick)
|
| | | PlayerViewCache.CrossServerMsg_ViewPlayerCacheRet(msgData, tick)
|
| | | |
| | | elif msgType == ShareDefine.CrossServerMsg_PullPlayerViewCache:
|
| | | PlayerViewCache.CrossServerMsg_PullPlayerViewCache(msgData)
|
| | |
|
| | | elif msgType == ShareDefine.CrossServerMsg_PlayerPackDataState:
|
| | | PlayerPackData.CrossServerMsg_PlayerPackDataState(msgData)
|