#!/usr/bin/python
# -*- coding: GBK -*-
# ----------------------------------------------------------------------------------------------------
#
# ----------------------------------------------------------------------------------------------------
##@package NetPackManager
# @todo: ·â°ü´¦Àí
#
# @author: zfl
# @date 2011-10-17 19:50
# @version 1.5
# 
# ÐÞ¸Äʱ¼ä ÐÞ¸ÄÈË ÐÞ¸ÄÄÚÈÝ
# @change: "2013-05-17 14:30" Alee ·â°ü³ö´í²»ÔÙÊÜÀí£¬ÐÞ¸´BUG
# @change: "2014-03-11 20:00" Alee ·â°ü´íÎó²»Å׳öÒì³£
# @change: "2014-05-16 13:30" xmnathan Ôö¼Ó GameServerºÍMapServerÖ®¼äµÄ×Ô¶¯·â°ü
# @change: "2014-12-23 15:30" xmnathan GameServerÔö¼Ó¸ù¾ÝLineNO·¢ËÍPy×Ô¶¨Òå°ü½Ó¿Ú
# @change: "2015-10-22 23:00" hxp Ôö¼ÓRecv_MergerChildToCenter
#-------------------------------------------------------------------------------
#"""Version = 2015-10-22 23:00"""
#-------------------------------------------------------------------------------
#---µ¼Èë---
import IPY_GameServer
import ChConfig
import GameWorld
import CommFunc
import ConfigParser
import ChPyNetPack
import ChPyNetSendPack
import traceback
import ChMapToGamePyPack
import CrossRealmMsg
import PlayerControl
#-------------------------------------------------------------------------------
#---È«¾Ö±äÁ¿---

PY_NAME = "NetPackCommon"
g_rootPath = ChConfig.GetAppPath()
# ÊÕ°ü×Öµä
RecievePackDict = ChPyNetPack.ChNetPackDict
# ·¢°ü×Öµä
SendPackDict = ChPyNetSendPack.ChNetPackDict

# Py·â°ü×¢²áÐÅÏ¢
PyPackTable = {}


## Ìæ»»×Ö·û´®ASCIIÂë
#IsRelpace = False
#ReplaceChar = chr(0xFF)

#-------------------------------------------------------------------------------
#---PyרÓõ÷ÊÔÊä³öÐÅÏ¢
## PyרÓã¬Êä³öµ÷ÊÔÐÅÏ¢
#  @param msg ÏûÏ¢
#  @return ·µ»ØÖµÎÞÒâÒå
#  @remarks Õý³£Èռǵ÷ÊÔÊä³öÐÅÏ¢
def Log(msg):
    
    GameWorld.Log(PY_NAME + "->" + msg)
    return


## PyרÓã¬Êä³ö´íÎóÐÅÏ¢
#  @param msg ÏûÏ¢
#  @return ·µ»ØÖµÎÞÒâÒå
#  @remarks Õý³£Èռǵ÷ÊÔÊä³öÐÅÏ¢
def ErrLog(msg):
    
    GameWorld.ErrLog(PY_NAME + "->" + msg)
    return

#-------------------------------------------------------------------------------
## ½âÎöPy·â°ü×¢²áÐÅÏ¢
#  @param tableName ±íÃû
#  @return ½âÎö½á¹û
#  @remarks
def ReadPyPackTable(tableName):
            
    tDict = {}  
    
#    scriptPath = g_rootPath + "\\Script\\"
    curPath = g_rootPath + "%s.ini"%(tableName)
    config = ConfigParser.ConfigParser()
    config.read(curPath)
    
    for section in config.sections():
        if config.getint(section, "RegType") != 0:
            continue
        
        regCnt = config.getint(section, "RegisterPackCount")
        scriptName = config.get(section, "ScriptName")

        moudle = __import__(scriptName.split("\\")[-1].split(".")[0])
        reload(moudle)
#        Log("ReadPyPackTable: moudle: %s"%dir(moudle))
        
        for index in range(regCnt):
            if not config.get(section, "PacketCMD_%s"%(index + 1)):
                continue
            cmd = config.get(section, "PacketCMD_%s"%(index + 1))
            subCmd = config.get(section, "PacketSubCMD_%s"%(index + 1))
            callFunc = config.get(section, "PacketCallFunc_%s"%(index + 1))
            if not cmd or not subCmd or not callFunc:
                continue
            
            cmd = int(cmd, 16)
            subCmd = int(subCmd, 16)
#            Log("ReadPyPackTable: cmd = %s subCmd = %s"%(cmd, subCmd))
            evalStr = "moudle.%s"%callFunc
#            Log("ReadPyPackTable: %s"%evalStr)
            
            try:
                callFunc = eval(evalStr)
            except:
                ErrLog("ReadPyPackTable: Error--%s"%traceback.format_exc())
                continue
            
            if not callable(callFunc):
                ErrLog("ReadPyPackTable: callFunc = %s is not callable!"%callFunc)
                continue
            
            head = eval("0x%02x%02x"%(cmd, subCmd))
            tDict[head] = {"Head": head, "CallFunc": callFunc}
    
#    Log("ReadPyPackTable: tDict = %s"%tDict)
    return tDict


## »ñµÃPy·â°üÊý¾Ý
#  @param head °üÍ·
#  @return Py·â°ü
#  @remarks
def GetPyRecievePack(head):
    
    if not RecievePackDict.has_key(head):
        ErrLog("GetPyRecievePack: No PyRecievePack head = %s"%head)
        return None
    
    return RecievePackDict[head]


## »ñµÃPy·â°üÊý¾Ý
#  @param head °üÍ·
#  @return Py·â°ü
#  @remarks
def GetPySendPack(head):
    
    if not SendPackDict.has_key(head):
        ErrLog("GetPySendPack: No PySendPack head = %s"%head)
        return None
    
    return SendPackDict[head]

#-------------------------------------------------------------------------------
## ½ÓÊÕÍòÄÜ·â°ü
#  @param index Íæ¼ÒË÷Òý
#  @param tick ʱ¼ä´Á
#  @return ÎÞ·µ»ØÖµ
#  @remarks
def RecNetPack(index, tick):
    
    try:
    
    #    Log("½Óµ½Í¨Ó÷â°ü!!!! index = %s"%index)
        
        clientPack = IPY_GameServer.IPY_CGameServerGeneralPack().GetData()
        
        #ûÓÐPY·â°üÍ·
        if len(clientPack) <= 1:
            return
        
        #Log("RevieveFakePack: clientPack = %s  %d"% (`[clientPack]`, IPY_GameServer.IPY_CFakePack().GetMsgLen()))
        #Log("RevieveFakePack: %s  %d"%(type(clientPack), len(clientPack)))
        
        headData = clientPack[1] + clientPack[0]
        curPackHead = CommFunc.ReadWORD(headData, 0)[0]
        
    #    Log("RevieveFakePack: curPackHead = %s"%curPackHead)
        
        curPackData = RecievePackDict.get(curPackHead)
        if not curPackData:
            return
        
    #    if IsRelpace:
    #        clientPack = clientPack[:2] + clientPack[2:].replace(ReplaceChar, chr(0x0))
    #    Log("RevieveFakePack: after replace clientPack = %s"%[clientPack])
        
        # ³¤¶ÈУÑé
    #    if curPackData.GetLength() > len(clientPack):
    #        Log("PyPack Length Error! curLen = %s, normalLen = %s"%(len(clientPack), curPackData.GetLength()))
    #        return 
        
        curPackData.ReadData(clientPack)
        
        # ½Ø¶Ï×Ö·û´®
        for key in dir(curPackData):
            value = getattr(curPackData, key)
            if isinstance(value, str):
                setattr(curPackData, key, value.rstrip(chr(0x0)))
        
        # È¡´Ë°üÍ·×¢²áÐÅÏ¢
        curPackHeadRegDict = PyPackTable.get(curPackHead)
        # ÎÞ´Ë·â°ü×¢²áÐÅÏ¢
        if curPackHeadRegDict == None:
            #Log("RevieveFakePack: No Register curPackHead = %s"%curPackHead)
            return
        
        curPackHeadRegDict["CallFunc"](index, curPackData, tick)
        
    except Exception:
        GameWorld.RaiseException("python×Ô¶¨Òå·â°ü½âÎöʧ°Ü\r\n%s" % traceback.format_exc())
        return 
    
    
## ·¢ËÍÍòÄÜ·â°ü
#  @param curPlayer Íæ¼ÒʵÀý
#  @param clientPack Òª°ü×°µÄ·â°ü
#  @return ÎÞ·µ»ØÖµ
#  @remarks
def SendFakePack(curPlayer, clientPack):
#    Log("SendFakePack: clientPack = %s"%[clientPack.GetBuffer()])
    innerPackData = clientPack.GetBuffer()
    curPlayer.Sync_GeneralPack(len(innerPackData), innerPackData)
    
def SendPackByPlayer(clientPack, curPlayer=None):
    ## ·¢ËÍ·â°ü£¬µ±curPlayerΪNoneʱÔò·¢ËÍÈ«·þÍæ¼Ò
    if not curPlayer:
        # È«·þ¹ã²¥ÔÚÏßÍæ¼Ò
        playerManager = GameWorld.GetPlayerManager()
        for i in xrange(playerManager.GetActivePlayerCount()):
            curPlayer = playerManager.GetActivePlayerAt(i)
            if curPlayer == None:
                continue
            if PlayerControl.GetIsTJG(curPlayer):
                continue
            SendFakePack(curPlayer, clientPack)
    else:
        if PlayerControl.GetIsTJG(curPlayer):
            return
        SendFakePack(curPlayer, clientPack)
    return

#-------------------------------------------------------------------------------
#---Py·â°ü×¢²áÐÅÏ¢
PyPackTable = ReadPyPackTable("PyNetPack")


#-------------------------------------------------------------------------------
#-------------------------------------------------------------------------------
#MapServer Py·â°ü×¢²áÐÅÏ¢
MapServerPyPackTable = {}
MapServerPyPackTable = ReadPyPackTable("MapServerPyPack")
# ÊÕ°ü×Öµä
RecMapServerPyPackDict = ChMapToGamePyPack.ChNetPackDict
## ½ÓÊÕMapServerPyPack
#  @param index Íæ¼ÒË÷Òý
#  @param tick ʱ¼ä´Á
#  @return ÎÞ·µ»ØÖµ
#  @remarks
def RecvMapPyPack(index, tick):
    
    try:       
        mapPack = IPY_GameServer.IPY_GGeneralPack().GetData()
        #ûÓÐPY·â°üÍ·
        if len(mapPack) < 1 + 4 + 1 + 1:#BYTE + DWORD + tagHead(BYTE + BYTE)
            return
        pos = 0
        routeIndex, pos = CommFunc.ReadBYTE(mapPack, pos)
        mapID, pos = CommFunc.ReadDWORD(mapPack, pos)
                
        headData = mapPack[pos + 1] + mapPack[pos]
        curPackHead = CommFunc.ReadWORD(headData, 0)[0]
        
        #Log("RecvMapPyPack: curPackHead = %s"%curPackHead)
        curPackData = RecMapServerPyPackDict.get(curPackHead)
        
        if not curPackData:
            #Log("RecvMapPyPack: not curPackData curPackHead = %s"%curPackHead)
            return
        
        curPackData.ReadData(mapPack, pos)
        
        # ½Ø¶Ï×Ö·û´®
        for key in dir(curPackData):
            value = getattr(curPackData, key)
            if isinstance(value, str):
                setattr(curPackData, key, value.rstrip(chr(0x0)))
        
        # È¡´Ë°üÍ·×¢²áÐÅÏ¢
        curPackHeadRegDict = MapServerPyPackTable.get(curPackHead)
        # ÎÞ´Ë·â°ü×¢²áÐÅÏ¢
        if curPackHeadRegDict == None:
        
            return
        
        curPackHeadRegDict["CallFunc"](routeIndex, mapID, curPackData, tick)
        #Log("RecvMapPyPack: CallFunc curPackHead = %s"%curPackHead)
    except Exception:
        GameWorld.RaiseException("RecvMapPyPack python×Ô¶¨Òå·â°ü½âÎöʧ°Ü\r\n%s" % traceback.format_exc())
        return 
    
#-------------------------------------------------------------------------------
##·¢ËÍGameµ½MapServerµÄ¹µÍ¨°ü
#
def SendPyPackToMapServer(LineNO, mapID, sendPack):
    
    GameWorld.GetGameWorld().SendMapServerGeneralPackByLineNO(LineNO, mapID, sendPack.GetLength(), sendPack.GetBuffer())

#-------------------------------------------------------------------------------
## ½ÓÊÕtagMGMergerChildToCenter
#  @param index ÎÞЧ
#  @param tick ʱ¼ä´Á
#  @return ÎÞ·µ»ØÖµ
#  @remarks
def Recv_MergerChildToCenter(index, tick):
    try:
        packData = IPY_GameServer.IPY_MGMergerChildToCenter().GetData()
        # ²»ÒªÊä³ö¾ßÌå·â°üÄÚÈÝ£¬¿ÉÄÜ»áÒòΪÄÚÈݵ¼ÖÂÈÕÖ¾Êä³ö±¨´í
        Log("ÊÕµ½¿ç·þ×Ó·þ×Ô¶¨Òå·â°üÏûÏ¢£º³¤¶È=%s" % len(packData))
        #ÒÔÏÂÌí¼ÓºóÐø´¦Àíº¯Êý
        #...
        #...
        CrossRealmMsg.OnCrossServerReceiveMsg(packData, tick)
    except Exception:
        Log("¿ç·þ×Ó·þ×Ô¶¨Òå·â°üÏûÏ¢´¦Àíʧ°Ü")
    return