#!/usr/bin/python # -*- coding: GBK -*- #------------------------------------------------------------------------------- # ##@package CrossRealmPlayer # # @todo:¿ç·þÍæ¼Ò # @author hxp # @date 2018-12-21 # @version 1.0 # # ÏêϸÃèÊö: ¿ç·þÍæ¼Ò # #------------------------------------------------------------------------------- #"""Version = 2018-12-21 18:00""" #------------------------------------------------------------------------------- import GameWorld import ShareDefine import CrossRealmMsg import ReadChConfig import ChConfig import PlayerControl import PlayerViewCache import PlayerCompensation import ChPyNetSendPack import PlayerDBGSEvent import NetPackCommon import IpyGameDataPY import PyGameData # »ñÈ¡Íæ¼Ò¿ç·þ·þÎñÆ÷ÉϵÄÃû×Ö #=============================================================================== # def GetCrossPlayerName(curPlayer): # # ͨ¹ýÓÎÏ·Õ˺ÅÖÐµÄÆ½Ì¨±êÖ¾»ñÈ¡Ãû³Æ£¬Ä¿Ç°Îªspid # playerName = curPlayer.GetPlayerName() # nameFormat = ReadChConfig.GetPyMongoConfig("Merge", "NameFormat", True) # if not nameFormat: # return playerName # # opName = ReadChConfig.GetPyMongoConfig("Merge", "OpName_%s" % GameWorld.GetPlayerPlatform(curPlayer)) # # return (nameFormat%{"opname":opName, "sid":GameWorld.GetPlayerServerID(curPlayer)}).decode('gbk').encode(GameWorld.GetCharacterEncoding()) + playerName #=============================================================================== # »ñÈ¡Íæ¼Ò¿ç·þ·þÎñÆ÷ÉϵÄÃû×Ö def GetCrossPlayerName(curPlayer): # ͨ¹ýÓÎÏ·Õ˺ÅÖÐµÄÆ½Ì¨±êÖ¾»ñÈ¡Ãû³Æ£¬Ä¿Ç°Îªspid playerName = curPlayer.GetName() opName = ReadChConfig.GetPyMongoConfig("Merge", "OpName_%s_%s" % (GameWorld.GetPlayerPlatform(curPlayer), GameWorld.GetPlayerServerSID(curPlayer))) if not opName: return playerName return opName.decode('gbk').encode(GameWorld.GetCharacterEncoding()) + playerName def GetCrossCommZoneIpyDataByZoneID(zoneID): ## »ñÈ¡¿ç·þ³£¹æ·ÖÇø crossZoneName = GameWorld.GetCrossZoneName() ipyData = IpyGameDataPY.GetIpyGameDataNotLog("CrossZoneComm", crossZoneName, zoneID) return ipyData def GetCrossCommZoneIpyDataByServerGroupID(serverGroupID): ## »ñÈ¡¿ç·þ³£¹æ·ÖÇø crossZoneName = GameWorld.GetCrossZoneName() ipyDataList = IpyGameDataPY.GetIpyGameDataByCondition("CrossZoneComm", {"CrossZoneName":crossZoneName}, True) if not ipyDataList: return for ipyData in ipyDataList: serverGroupIDList = ipyData.GetServerGroupIDList() for serverGroupIDInfo in serverGroupIDList: if (isinstance(serverGroupIDInfo, tuple) and serverGroupIDInfo[0] <= serverGroupID <= serverGroupIDInfo[1]) \ or (isinstance(serverGroupIDInfo, int) and serverGroupIDInfo == serverGroupID): return ipyData return def GetCrossCommZoneIpyDataListByServerGroupID(serverGroupID): ## »ñÈ¡¿ç·þ³£¹æ·ÖÇøÁбí if serverGroupID: ipyData = GetCrossCommZoneIpyDataByServerGroupID(serverGroupID) if not ipyData: return ipyDataList = [ipyData] else: crossZoneName = GameWorld.GetCrossZoneName() ipyDataList = IpyGameDataPY.GetIpyGameDataByCondition("CrossZoneComm", {"CrossZoneName":crossZoneName}, True) return ipyDataList def GetServerCrossZoneMapIpyData(mapID, serverGroupID=0): ## »ñÈ¡±¾·þ¶ÔÓ¦¿ç·þÍæ·¨·ÖÇøµØÍ¼ÐÅÏ¢ if mapID not in ChConfig.Def_CrossZoneMapTableName: return tableName = ChConfig.Def_CrossZoneMapTableName[mapID] if not serverGroupID: if GameWorld.IsCrossServer(): return serverGroupID = GameWorld.GetServerGroupID() zoneIpyData = GetCrossCommZoneIpyDataByServerGroupID(serverGroupID) if not zoneIpyData: return commZoneID = zoneIpyData.GetZoneID() return IpyGameDataPY.GetIpyGameDataByCondition(tableName, {"ZoneID":commZoneID}) def IsCrossServerOpen(): ## ¿ç·þ·þÎñÆ÷ÊÇ·ñ¿ª·ÅÖÐ return GameWorld.GetGameWorld().GetDictByKey(ShareDefine.Def_Notify_WorldKey_CrossServerOpen) def Sync_CrossCommInitDataToClientServer(serverGroupID=0): ''' ͬ²½¿ç·þ³£¹æÍ¨ÓÃÊý¾Ýµ½×Ó·þÎñÆ÷ @param serverGroupID: Ϊ0ʱͬ²½ËùÓÐ×Ó·þ ''' isOpen = GameWorld.GetGameWorld().GetDictByKey(ShareDefine.Def_Notify_WorldKey_CrossServerOpen) crossZoneName = GameWorld.GetCrossZoneName() GameWorld.Log("֪ͨµ±Ç°¿ç·þ·þÎñÆ÷״̬: isOpen=%s,crossZoneName=%s,syncServerGroupID=%s" % (isOpen, crossZoneName, serverGroupID)) serverGroupIDList = [serverGroupID] if serverGroupID else [] CrossRealmMsg.SendMsgToClientServer(ShareDefine.CrossServerMsg_CrossServerState, {"isOpen":isOpen, "crossZoneName":crossZoneName}, serverGroupIDList) return def DoChangeCrossServerState(isOpen): ## ¿ç·þ·þÎñÆ÷״̬±ä¸ü PlayerDBGSEvent.SetDBGSTrig_ByKey(PlayerDBGSEvent.Def_CrossServerClose, 0 if isOpen else 1) # ´æDBµÄ·´×Å´æ GameWorld.GetGameWorld().SetDict(ShareDefine.Def_Notify_WorldKey_CrossServerOpen, isOpen) if not isOpen: # ÌßµôËùÓÐÍæ¼Ò playerManager = GameWorld.GetPlayerManager() for i in xrange(playerManager.GetActivePlayerCount()): curPlayer = playerManager.GetActivePlayerAt(i) if curPlayer == None: continue PlayerControl.SetCrossMapID(curPlayer, 0) curPlayer.Kick(0) # ¹ã²¥ËùÓÐ×Ó·þ£¬±¾·þÎñÆ÷½øÈëά»¤ CrossRealmMsg.SendMsgToClientServer(ShareDefine.CrossServerMsg_CrossServerState, {"isOpen":isOpen}) return def CrossServerMsg_CrossServerState(msgData): ## ×Ó·þÊÕµ½¿ç·þ·þÎñÆ÷״̬±ä¸ü£¬×Ó·þ²»´æDB£¬Ä¬ÈÏ¿ç·þά»¤ÖУ¬Á¬½Ó¿ç·þ³É¹¦ºóÓÉ¿ç·þͬ²½×´Ì¬Ö±½Ó¸üе½×ֵ伴¿É£¬Ã»Á¬ÉϾÍĬÈÏά»¤ÖÐ if "crossZoneName" in msgData: PyGameData.g_crossZoneName = msgData["crossZoneName"] GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_CrossZoneName, PyGameData.g_crossZoneName) isOpen = msgData["isOpen"] isOpen = 1 if isOpen else 0 GameWorld.Log("ÊÕµ½¿ç·þ·þÎñÆ÷״̬±ä¸ü: ÊÇ·ñÕý³£¿ª·ÅÖÐ=%s" % isOpen) GameWorld.GetGameWorld().SetDict(ShareDefine.Def_Notify_WorldKey_CrossServerOpen, isOpen) if not isOpen: playerManager = GameWorld.GetPlayerManager() for i in xrange(playerManager.GetActivePlayerCount()): curPlayer = playerManager.GetActivePlayerAt(i) if curPlayer == None: continue PlayerControl.SetCrossMapID(curPlayer, 0) # ֪ͨµØÍ¼ GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_CrossServerOpen, isOpen) return def PlayerExitCrossServer(curPlayer): ## Íæ¼ÒÍ˳ö¿ç·þ·þÎñÆ÷ if not GameWorld.IsCrossServer(): return # ֪ͨ×Ó·þÍæ¼ÒÍ˳ö¿ç·þ·þÎñÆ÷ playerID = curPlayer.GetPlayerID() serverGroupID = PlayerControl.GetPlayerServerGroupID(curPlayer) CrossRealmMsg.SendMsgToClientServer(ShareDefine.CrossServerMsg_ExitCrossServer, playerID, [serverGroupID]) # ÉèÖ÷ǿç·þ״̬£¬ÌßÏÂÏß PlayerControl.SetCrossMapID(curPlayer, 0) curPlayer.Kick(0) GameWorld.Log("PlayerExitCrossServer...serverGroupID=%s" % serverGroupID, playerID) return def CrossServerMsg_ExitCrossServer(msgData): ## ÊÕµ½¿ç·þ·þÎñÆ÷ͬ²½µÄÍæ¼ÒÍ˳ö¿ç·þ·þÎñÆ÷ playerID = msgData GameWorld.Log("ÊÕµ½¿ç·þ·þÎñÆ÷ͬ²½µÄÍæ¼ÒÍ˳ö¿ç·þ·þÎñÆ÷: playerID=%s" % playerID) curPlayer = GameWorld.GetPlayerManager().FindPlayerByID(playerID) if not curPlayer: GameWorld.Log(" Í˳ö¿ç·þʱ±¾·þÍæ¼Ò²»ÔÚÏß!", playerID) return PlayerControl.SetCrossMapID(curPlayer, 0) return def SendCrossRealmReg(curPlayer, registerMap, mapID=0, dataMapID=0, copyMapID=0, posX=0, posY=0): # ·¢ËÍ¿ç·þÕ˺Å×¢²áÉÏ´«Êý¾Ý # ÉèÖÃÉÏ´«Êý¾ÝµÄ»î¶¯ÀàÐÍ curPlayer.SetDict(ChConfig.Def_PlayerKey_CrossRegisterMap, registerMap) sysMsg = str([registerMap, mapID, dataMapID, copyMapID, posX, posY]) curPlayer.MapServer_QueryPlayerResult(0, 0, "CrossRealmReg", sysMsg, len(sysMsg)) GameWorld.Log("SendCrossRealmReg registerMap=%s,mapID=%s,dataMapID=%s,copyMapID=%s,posX=%s,posY=%s" % (registerMap, mapID, dataMapID, copyMapID, posX, posY), curPlayer.GetPlayerID()) return def OnCrossRealmRegOK(playerID, msgList, tick): ## ¿ç·þ±¨Ãû½á¹û curPlayer = GameWorld.GetPlayerManager().FindPlayerByID(playerID) if not curPlayer: return if not IsCrossServerOpen(): return registerMap = msgList[0] playerRegisterMap = curPlayer.GetDictByKey(ChConfig.Def_PlayerKey_CrossRegisterMap) if playerRegisterMap and registerMap != playerRegisterMap: return curPlayer.SetDict(ChConfig.Def_PlayerKey_CrossRegisterMap, 0) GameWorld.Log("¿ç·þ±¨Ãû³É¹¦ , registerMap=%s" % (registerMap), playerID) # ¿ç·þPKÉÏ´«Êý¾ÝÍê±Ï£¬Í¨Öª¿ç·þ·þÎñÆ÷£¬×¼±¸Íê±Ï if registerMap == ChConfig.Def_FBMapID_CrossRealmPK: regVSRoomID = curPlayer.GetDictByKey(ChConfig.Def_PlayerKey_MergeRegisterRoomID) vsRoomID = curPlayer.GetVsRoomId() if regVSRoomID != vsRoomID: GameWorld.Log("ÉÏ´«¿ç·þ·þÎñÆ÷µÄ regVSRoomID=%s ÓëÍæ¼Òµ±Ç°µÄ roomID=%s ²»Í¬!²»·¢ËÍ×¼±¸Íê±Ï£¡" % (regVSRoomID, vsRoomID), playerID) return dataMsg = { "accID":curPlayer.GetAccID(), # ½ÇÉ«Õ˺ÅID "playerID":playerID, # ½ÇÉ«ID "vsRoomID":vsRoomID, # ËùÊô¶ÔÕ½·¿¼äID } CrossRealmMsg.SendMsgToCrossServer(ShareDefine.ClientServerMsg_PKPrepareOK, dataMsg) GameWorld.Log("֪ͨ¿ç·þ·þÎñÆ÷, Íæ¼ÒÆ¥ÅäPK×¼±¸Íê±Ï£¡%s" % str(dataMsg), playerID) # ÆäËûµÄ£¬ÔÚÉÏ´«Êý¾ÝÍê±Ïºó£¬Ê¹ÓÃͨÓõÄ֪ͨ¿É½øÈë¿ç·þ else: NotifyCanEnterMergeServer(curPlayer, registerMap) # hxp 2015.09.10 ¿ç·þboss£¬ºóÃæµÄÔÝʱ²»ÐèÒª return def NotifyCanEnterMergeServer(curPlayer, registerMap): # ͨÓðü£¬Í¨Öª¿Í»§¶Ë¿É½øÈë¿ç·þ·þÎñÆ÷ return #// C0 03 Ç¿ÖÆÍ˳ö¿ç·þ״̬ #tagCGForceQuitCrossState # #struct tagCGForceQuitCrossState #{ # tagHead Head; #}; def OnForceQuitCrossState(index, clientData, tick): ''' Ô¼¶¨¸Ã·â°ü½öÍæ¼Òµ±Ç°´¦ÓÚ¿ç·þ״̬£¬µ«ÊÇÒ»Ö±Á¬²»ÉÏ¿ç·þ·þÎñÆ÷ʱ²Å»á·¢´Î°üÇ¿ÖÆÖØÖÿç·þ״̬ Ò»°ãÊÇ¿ç·þ·þÎñÆ÷Òì³£»òÆäËû´íÎóµ¼ÖÂÎÞ·¨µÇ¼¿ç·þ·þÎñÆ÷ ''' curPlayer = GameWorld.GetPlayerManager().GetPlayerByIndex(index) GameWorld.ErrLog("ijЩÒì³£Çé¿öÏ£¬Ç°¶ËÇ¿ÖÆ·¢°üÍ˳ö¿ç·þ״̬! ", curPlayer.GetPlayerID()) PlayerControl.SetCrossMapID(curPlayer, 0) return #// C0 02 ²é¿´¿ç·þÍæ¼ÒÐÅÏ¢ #tagCGViewCrossPlayerInfo # #struct tagCGViewCrossPlayerInfo #{ # tagHead Head; # DWORD PlayerID; // ¿ç·þÍæ¼ÒID #}; def OnViewCrossPlayerInfo(index, clientData, tick): if GameWorld.IsCrossServer(): return curPlayer = GameWorld.GetPlayerManager().GetPlayerByIndex(index) playerID = curPlayer.GetPlayerID() tagPlayerID = clientData.PlayerID curCache = PlayerViewCache.ViewCacheMgr.FindCache(tagPlayerID) ## ±¾·þÓУ¬Ö±½Ó»Ø¿Í»§¶Ë if curCache: GameWorld.DebugLog("²é¿´¿ç·þÍæ¼Ò£¬ÊDZ¾·þÍæ¼Ò£¬Ö±½Ó»Ø¸´!tagPlayerID=%s" % (tagPlayerID), playerID) sendPack = ChPyNetSendPack.tagSCQueryPlayerCacheResult() sendPack.PlayerID = tagPlayerID sendPack.PropData = curCache.GetPropData() sendPack.PropDataSize = len(sendPack.PropData) sendPack.ItemData = PlayerViewCache.GetItemData(curCache) sendPack.ItemDataSize = len(sendPack.ItemData) sendPack.PlusData = PlayerViewCache.GetPlusData(curCache) sendPack.PlusDataSize = len(sendPack.PlusData) NetPackCommon.SendFakePack(curPlayer, sendPack) return if tagPlayerID in PyGameData.g_crossPlayerViewCache: validChaheTime = 5 * 60 * 1000 cacheInfo, updTick = PyGameData.g_crossPlayerViewCache[tagPlayerID] if tick - updTick <= validChaheTime: GameWorld.DebugLog("²é¿´¿ç·þÍæ¼ÒÊý¾Ýͬ²½CDÖУ¬Ö±½ÓÓûº´æÊý¾Ý»Ø¸´!tagPlayerID=%s" % (tagPlayerID), playerID) SyncPlayerViewCrossPlayerInfo(curPlayer, tagPlayerID, cacheInfo) return for crossPlayerID, cacheInfoList in PyGameData.g_crossPlayerViewCache.items(): if tick - cacheInfoList[1] > validChaheTime: PyGameData.g_crossPlayerViewCache.pop(crossPlayerID) # ·¢ËÍ¿ç·þ·þÎñÆ÷²éѯ dataMsg = {"tagPlayerID":tagPlayerID, "playerID":playerID} CrossRealmMsg.SendMsgToCrossServer(ShareDefine.ClientServerMsg_ViewPlayerCache, dataMsg) return def ClientServerMsg_ViewPlayerCache(serverGroupID, msgData): tagPlayerID = msgData["tagPlayerID"] playerID = msgData["playerID"] GameWorld.Log("ÊÕµ½×Ó·þ²é¿´¿ç·þÍæ¼ÒÐÅÏ¢: serverGroupID=%s,playerID=%s,tagPlayerID=%s" % (serverGroupID, playerID, tagPlayerID)) cacheInfo = [] curCache = PlayerViewCache.ViewCacheMgr.FindCache(tagPlayerID) if curCache: cacheInfo = [curCache.GetPropData(), PlayerViewCache.GetItemData(curCache), PlayerViewCache.GetPlusData(curCache)] viewPlayerCacheRet = [playerID, tagPlayerID, cacheInfo] CrossRealmMsg.SendMsgToClientServer(ShareDefine.CrossServerMsg_ViewPlayerCacheRet, viewPlayerCacheRet, [serverGroupID]) return def CrossServerMsg_ViewPlayerCacheRet(msgData, tick): playerID, tagPlayerID, cacheInfo = msgData GameWorld.Log("ÊÕµ½¿ç·þ·þÎñÆ÷»Ø¸´µÄ²é¿´Íæ¼ÒÐÅÏ¢: playerID=%s,tagPlayerID=%s" % (playerID, tagPlayerID)) PyGameData.g_crossPlayerViewCache[tagPlayerID] = [cacheInfo, tick] # ¸üÐÂÐÅÏ¢ curPlayer = GameWorld.GetPlayerManager().FindPlayerByID(playerID) if curPlayer: SyncPlayerViewCrossPlayerInfo(curPlayer, tagPlayerID, cacheInfo) return def SyncPlayerViewCrossPlayerInfo(curPlayer, tagPlayerID, cacheInfo): if not cacheInfo: PlayerControl.NotifyCode(curPlayer, "ViewPlayer_OffLine") return PropData, ItemData, PlusData = cacheInfo sendPack = ChPyNetSendPack.tagSCQueryPlayerCacheResult() sendPack.PlayerID = tagPlayerID sendPack.PropData = PropData sendPack.PropDataSize = len(sendPack.PropData) sendPack.ItemData = ItemData sendPack.ItemDataSize = len(sendPack.ItemData) sendPack.PlusData = PlusData sendPack.PlusDataSize = len(sendPack.PlusData) NetPackCommon.SendFakePack(curPlayer, sendPack) return def CrossServerMsg_PutInItem(itemInfo): ## ¿ç·þ»ñµÃÎïÆ· GameWorld.DebugLog("ÊÕµ½¿ç·þ·þÎñÆ÷»ñµÃÎïÆ·!") playerID = itemInfo["PlayerID"] itemData = itemInfo["ItemData"] event = itemInfo["Event"] curPlayer = GameWorld.GetPlayerManager().FindPlayerByID(playerID) if curPlayer: # ÔÚÏߵϰÍƵ½MapServer´¦Àí itemMsg = str(itemInfo) curPlayer.MapServer_QueryPlayerResult(0, 0, "CrossPutInItem", itemMsg, len(itemMsg)) return # ÀëÏߵϰֱ½Ó·¢Óʼþ GameWorld.Log("ÊÕµ½¿ç·þ»ñµÃÎïÆ·£¬Íæ¼Ò²»ÔÚÏߣ¬Ö±½Ó·¢Óʼþ! itemInfo=%s" % str(itemInfo), playerID) itemID, itemCount, isBind, itemUserData = itemData addItemList = [{"ItemID":itemID, "Count":itemCount, "IsBind":isBind, "UserData":itemUserData}] PlayerCompensation.SendMailByKey("", [playerID], addItemList, detail={"CrossPutInItem":1, "Event":event}) return def CrossServerMsg_GiveMoney(msgInfo): ## ¿ç·þ»ñµÃ»õ±Ò playerID = msgInfo["PlayerID"] curPlayer = GameWorld.GetPlayerManager().FindPlayerByID(playerID) if not curPlayer: GameWorld.ErrLog("¿ç·þ»ñµÃ»õ±ÒÊ±Íæ¼Ò²»ÔÚÏß! msgInfo=%s" % str(msgInfo), playerID) return msgInfo = str(msgInfo) curPlayer.MapServer_QueryPlayerResult(0, 0, "CrossGiveMoney", msgInfo, len(msgInfo)) return def SetCrossPlayerAttrValue(msgInfo, tick): ## ÉèÖÿç·þÍæ¼ÒÊôÐÔÖµ playerID, setType, setDict, isDelay = msgInfo if not PyGameData.g_crossSetPlayerAttr: GameWorld.GetGameWorld().SetDict(ChConfig.Def_WorldKey_CrossSetPlayerAttrTick, tick) playerSetInfoList = PyGameData.g_crossSetPlayerAttr.get(playerID, []) playerSetInfoList.append([setType, setDict]) PyGameData.g_crossSetPlayerAttr[playerID] = playerSetInfoList if not isDelay: __SendCrossServerSetPlayerAttr(0) return def OnCrossProcess(tick): __SendCrossServerSetPlayerAttr(tick) return def __SendCrossServerSetPlayerAttr(tick): if not PyGameData.g_crossSetPlayerAttr: return if tick: # ÑÓ³Ù10ÃëÒ»´ÎÐÔͬ²½£¬Ö÷ÒªÊDZÈÈçOnDayµÄʱºòµ±¶à¸öÍæ¼Òͬʱ¿ç·þʱ£¬¼õÉÙͬ²½´ÎÊý£¬ÑÓ³Ùͳһ·¢ËÍ if tick - GameWorld.GetGameWorld().GetDictByKey(ChConfig.Def_WorldKey_CrossSetPlayerAttrTick) < 10 * 1000: return GameWorld.GetGameWorld().SetDict(ChConfig.Def_WorldKey_CrossSetPlayerAttrTick, tick) CrossRealmMsg.SendMsgToCrossServer(ShareDefine.ClientServerMsg_SetPlayerAttrValue, PyGameData.g_crossSetPlayerAttr) PyGameData.g_crossSetPlayerAttr = {} return