#!/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
import PlayerDBOper

# »ñÈ¡Íæ¼Ò¿ç·þ·þÎñÆ÷ÉϵÄÃû×Ö
#===============================================================================
# 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 GetCrossZoneIpyDataByZoneID(mapID, zoneID):
    ## »ñÈ¡¿ç·þ·ÖÇø
    zoneTypeName = ChConfig.Def_CrossZoneTypeName.get(mapID, "CrossZoneComm")
    crossZoneName = GameWorld.GetCrossZoneName()
    return IpyGameDataPY.GetIpyGameData(zoneTypeName, crossZoneName, zoneID)

def GetCrossZoneIpyDataByServerGroupID(mapID, serverGroupID):
    ## »ñÈ¡¿ç·þ·ÖÇø
    zoneTypeName = ChConfig.Def_CrossZoneTypeName.get(mapID, "CrossZoneComm")
    crossZoneName = GameWorld.GetCrossZoneName()
    ipyDataList = IpyGameDataPY.GetIpyGameDataByCondition(zoneTypeName, {"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
    GameWorld.ErrLog("ûÓÐÕÒµ½¿ç·þÍæ·¨¶ÔÓ¦·ÖÇø! mapID=%s, serverGroupID=%s, zoneTypeName=%s" % (mapID, serverGroupID, zoneTypeName))
    return

def GetCrossZoneIpyDataListByServerGroupID(mapID, serverGroupID):
    ## »ñÈ¡¿ç·þ³£¹æ·ÖÇøÁбí
    if serverGroupID:
        ipyData = GetCrossZoneIpyDataByServerGroupID(mapID, serverGroupID)
        if not ipyData:
            return
        ipyDataList = [ipyData]
    else:
        crossZoneName = GameWorld.GetCrossZoneName()
        zoneTypeName = ChConfig.Def_CrossZoneTypeName.get(mapID, "CrossZoneComm")
        ipyDataList = IpyGameDataPY.GetIpyGameDataByCondition(zoneTypeName, {"CrossZoneName":crossZoneName}, True)
    return ipyDataList

def GetServerCommCrossZoneID(serverGroupID):
    ## »ñÈ¡¿ç·þ³£¹æ·ÖÇø
    zoneTypeName = "CrossZoneComm"
    crossZoneName = GameWorld.GetCrossZoneName()
    ipyDataList = IpyGameDataPY.GetIpyGameDataByCondition(zoneTypeName, {"CrossZoneName":crossZoneName}, True)
    if not ipyDataList:
        return 0
    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.GetZoneID()
    return 0

def GetServerCrossZoneMapIpyData(zoneID, mapID):
    ## »ñÈ¡±¾·þ¶ÔÓ¦¿ç·þÍæ·¨·ÖÇøµØͼÐÅÏ¢ - ½öÊÊÓÃÓڹ̶¨µØͼ¼°ÐéÄâ·ÖÏߵĿç·þÍæ·¨
    if mapID not in ChConfig.Def_CrossZoneMapTableName:
        return
    tableName = ChConfig.Def_CrossZoneMapTableName[mapID]
    return IpyGameDataPY.GetIpyGameDataByCondition(tableName, {"ZoneID":zoneID})

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.GetGameWorld().SendCrossServerStateToLoginServer(isOpen)
    # ֪ͨµØͼ
    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)
        DoOfflinePlayerExitCrossServer(playerID)
        return
    PlayerControl.SetCrossMapID(curPlayer, 0)
    return

def DoOfflinePlayerExitCrossServer(playerID):
    ## ´¦ÀíÀëÏßÍæ¼ÒÍ˳ö¿ç·þ·þÎñÆ÷¸üÐÂDBÊý¾ÝÂß¼­
    
    PlayerDBOper.UpdateDBOper(PlayerDBOper.Table_DBPlayer, {"PlayerID":playerID}, {"ExAttr5":0})
    return

def SendCrossRealmReg(curPlayer, registerMap, mapID=0, dataMapID=0, copyMapID=0, posX=0, posY=0, lineID=0):
    # ·¢ËÍ¿ç·þÕ˺Å×¢²áÉÏ´«Êý¾Ý
    # @param mapID: Õæʵ³¡¾°µØͼID
    # @param dataMapID: Õæʵ³¡¾°µØͼID¶ÔÓ¦³¡¾°Êý¾ÝµØͼID
    
    # ÉèÖÃÉÏ´«Êý¾ÝµÄ»î¶¯ÀàÐÍ
    curPlayer.SetDict(ChConfig.Def_PlayerKey_CrossRegisterMap, registerMap)
    sysMsg = str([registerMap, mapID, dataMapID, copyMapID, posX, posY, lineID])
    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
#    BYTE        EquipClassLV;    //´óÓÚ0Ϊ²é¿´Ö¸¶¨¾³½ç½××°±¸ÐÅÏ¢,  0Ϊ²é¿´Ä¬ÈÏÐÅÏ¢
#};
def OnViewCrossPlayerInfo(index, clientData, tick):
    if GameWorld.IsCrossServer():
        return
    
    curPlayer = GameWorld.GetPlayerManager().GetPlayerByIndex(index)
    playerID = curPlayer.GetPlayerID()
    tagPlayerID = clientData.PlayerID
    equipClassLV = clientData.EquipClassLV
    curCache = PlayerViewCache.FindViewCache(tagPlayerID)
    ## ±¾·þÓУ¬Ö±½Ó»Ø¿Í»§¶Ë
    if curCache:
        GameWorld.DebugLog("²é¿´¿ç·þÍæ¼Ò£¬ÊDZ¾·þÍæ¼Ò£¬Ö±½Ó»Ø¸´!tagPlayerID=%s" % (tagPlayerID), playerID)
        PlayerViewCache.Sync_PlayerCache(curPlayer, curCache, equipClassLV)
        return
    
    if tagPlayerID in PyGameData.g_crossPlayerViewCache:
        validChaheTime = 10 * 60 * 1000
        cacheInfo, updTick = PyGameData.g_crossPlayerViewCache[tagPlayerID]
        if tick - updTick <= validChaheTime:
            GameWorld.DebugLog("²é¿´¿ç·þÍæ¼ÒÊý¾Ýͬ²½CDÖУ¬Ö±½ÓÓûº´æÊý¾Ý»Ø¸´!tagPlayerID=%s" % (tagPlayerID), playerID)
            SyncPlayerViewCrossPlayerInfo(curPlayer, tagPlayerID, equipClassLV, 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, "equipClassLV":equipClassLV}
    CrossRealmMsg.SendMsgToCrossServer(ShareDefine.ClientServerMsg_ViewPlayerCache, dataMsg)
    return

def ClientServerMsg_ViewPlayerCache(serverGroupID, msgData):
    tagPlayerID = msgData["tagPlayerID"]
    playerID = msgData["playerID"]
    equipClassLV = msgData["equipClassLV"]
    
    GameWorld.Log("ÊÕµ½×Ó·þ²é¿´¿ç·þÍæ¼ÒÐÅÏ¢: serverGroupID=%s,playerID=%s,tagPlayerID=%s" % (serverGroupID, playerID, tagPlayerID))
    
    cacheInfo = {}
    curCache = PlayerViewCache.FindViewCache(tagPlayerID)
    if curCache:
        cacheInfo = {"PropData":curCache.PropData, "PlusData":curCache.PlusData}
        for classLV in xrange(1, 15 + 1):
            attrName = "ItemData%s" % classLV
            if hasattr(curCache, attrName):
                cacheInfo[attrName] = getattr(curCache, attrName)
                
    viewPlayerCacheRet = [playerID, tagPlayerID, equipClassLV, cacheInfo]
    CrossRealmMsg.SendMsgToClientServer(ShareDefine.CrossServerMsg_ViewPlayerCacheRet, viewPlayerCacheRet, [serverGroupID])
    return

def CrossServerMsg_ViewPlayerCacheRet(msgData, tick):
    
    playerID, tagPlayerID, equipClassLV, 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, equipClassLV, cacheInfo)
        
    return

def SyncPlayerViewCrossPlayerInfo(curPlayer, tagPlayerID, equipClassLV, cacheInfo):
    if not cacheInfo:
        PlayerControl.NotifyCode(curPlayer, "ViewPlayer_OffLine")
        return
    
    if equipClassLV:
        itemData = cacheInfo.get("ItemData%s" % equipClassLV, "")
        sendPack = ChPyNetSendPack.tagSCPlayerEquipCacheResult()
        sendPack.PlayerID = tagPlayerID
        sendPack.EquipClassLV = equipClassLV
        sendPack.ItemData = itemData
        sendPack.ItemDataSize = len(sendPack.ItemData)
        NetPackCommon.SendFakePack(curPlayer, sendPack)
        return
    
    #»Ø°ü¿Í»§¶Ë
    sendPack = ChPyNetSendPack.tagSCQueryPlayerCacheResult()
    sendPack.PlayerID = tagPlayerID
    sendPack.PropData = cacheInfo.get("PropData", "")
    sendPack.PropDataSize = len(sendPack.PropData)
    sendPack.PlusData = cacheInfo.get("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, "IsAuctionItem":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

def OnPlayerLogin(curPlayer):
    if not IsCrossServerOpen():
        return
    
    Sync_CrossZoneInfo(curPlayer)
    LoginDoUnNotifyCrossMsg(curPlayer)
    return
    
def MapServer_QueryCrossPlayerResult(playerID, callName, msgInfo, offlineExitCross=False):
    ## ͬ²½µØͼ¿ç·þÍæ¼Ò´¦ÀíÐÅÏ¢£¬Íæ¼Ò¿ÉÄܲ»ÔÚÏߣ¬»º´æºóµÈÍæ¼ÒÉÏÏß´¦Àí£¬Ôݲ»¿¼ÂÇ´æµµÎÊÌ⣬·þÎñÆ÷ά»¤ºóδ´¦ÀíµÄÃüÁʧЧ
    
    curPlayer = GameWorld.GetPlayerManager().FindPlayerByID(playerID)
    if curPlayer and curPlayer.GetInitOK():
        msgInfo = str(msgInfo)
        curPlayer.MapServer_QueryPlayerResult(0, 0, callName, msgInfo, len(msgInfo))
        return curPlayer
    else:
        # »º´æÆðÀ´£¬µÈÉÏÏߺó´¦Àí
        if playerID not in PyGameData.g_unNotifyPlayerCrossMsgDict:
            PyGameData.g_unNotifyPlayerCrossMsgDict[playerID] = []
        msgList = PyGameData.g_unNotifyPlayerCrossMsgDict[playerID]
        msgList.append([callName, msgInfo])
        GameWorld.Log("Íæ¼Ò²»ÔÚÏߣ¬Ìí¼Óδ֪ͨµÄ¿ç·þÃüÁî: %s, msgInfo=%s" % (callName, msgInfo), playerID)
        if offlineExitCross:
            DoOfflinePlayerExitCrossServer(playerID)
    return

def LoginDoUnNotifyCrossMsg(curPlayer):
    playerID = curPlayer.GetPlayerID()
    msgList = PyGameData.g_unNotifyPlayerCrossMsgDict.pop(playerID, [])
    if not msgList:
        return
    for callName, msgInfo in msgList:
        GameWorld.Log("ÉÏÏß´¦Àíδ֪ͨµÄ¿ç·þÃüÁî: %s, msgInfo=%s" % (callName, msgInfo), playerID)
        msgInfo = str(msgInfo)
        curPlayer.MapServer_QueryPlayerResult(0, 0, callName, msgInfo, len(msgInfo))
    return

def Sync_CrossZoneInfo(curPlayer):
    clientPack = ChPyNetSendPack.tagGCCrossZoneInfo()
    clientPack.CommZoneID = GetServerCommCrossZoneID(GameWorld.GetServerGroupID())
    NetPackCommon.SendFakePack(curPlayer, clientPack)
    return