66 【公会】基础主体-服务端（优化游戏服及跨服启动、通讯逻辑；服务器类型增加跨服中心、跨服事件、时间管理；跨服玩家在线状态、基础信息、玩家资源增减管...

hxp

6 天以前 01a0e539b786ae0f1c46646874502367f5410aca

 ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/ChPyNetSendPack.py

@@ -10725,6 +10725,158 @@




#------------------------------------------------------

# A5 05 公会跨服互通信息 #tagSCFamilyCrossInfo



class  tagSCFamilyCrossInfo(Structure):

    Head = tagHead()

    ZoneID = 0    #(BYTE ZoneID)// 所属分区

    ServerCnt = 0    #(WORD ServerCnt)

    ServerIDList = list()    #(vector<DWORD> ServerIDList)// 互通服务器ID列表

    data = None



    def __init__(self):

        self.Clear()

        self.Head.Cmd = 0xA5

        self.Head.SubCmd = 0x05

        return



    def ReadData(self, _lpData, _pos=0, _Len=0):

        self.Clear()

        _pos = self.Head.ReadData(_lpData, _pos)

        self.ZoneID,_pos = CommFunc.ReadBYTE(_lpData, _pos)

        self.ServerCnt,_pos = CommFunc.ReadWORD(_lpData, _pos)

        for i in range(self.ServerCnt):

            value,_pos=CommFunc.ReadDWORD(_lpData,_pos)

            self.ServerIDList.append(value)

        return _pos



    def Clear(self):

        self.Head = tagHead()

        self.Head.Clear()

        self.Head.Cmd = 0xA5

        self.Head.SubCmd = 0x05

        self.ZoneID = 0

        self.ServerCnt = 0

        self.ServerIDList = list()

        return



    def GetLength(self):

        length = 0

        length += self.Head.GetLength()

        length += 1

        length += 2

        length += 4 * self.ServerCnt



        return length



    def GetBuffer(self):

        data = ''

        data = CommFunc.WriteString(data, self.Head.GetLength(), self.Head.GetBuffer())

        data = CommFunc.WriteBYTE(data, self.ZoneID)

        data = CommFunc.WriteWORD(data, self.ServerCnt)

        for i in range(self.ServerCnt):

            data = CommFunc.WriteDWORD(data, self.ServerIDList[i])

        return data



    def OutputString(self):

        DumpString = '''

                                Head:%s,

                                ZoneID:%d,

                                ServerCnt:%d,

                                ServerIDList:%s

                                '''\

                                %(

                                self.Head.OutputString(),

                                self.ZoneID,

                                self.ServerCnt,

                                "..."

                                )

        return DumpString





m_NAtagSCFamilyCrossInfo=tagSCFamilyCrossInfo()

ChNetPackDict[eval("0x%02x%02x"%(m_NAtagSCFamilyCrossInfo.Head.Cmd,m_NAtagSCFamilyCrossInfo.Head.SubCmd))] = m_NAtagSCFamilyCrossInfo





#------------------------------------------------------

# A5 24 公会成员删除 #tagSCFamilyMemDel



class  tagSCFamilyMemDel(Structure):

    Head = tagHead()

    Type = 0    #(BYTE Type)// 0-踢出；1-主动退出

    PlayerID = 0    #(DWORD PlayerID)

    NameLen = 0    #(BYTE NameLen)

    Name = ""    #(String Name)

    data = None



    def __init__(self):

        self.Clear()

        self.Head.Cmd = 0xA5

        self.Head.SubCmd = 0x24

        return



    def ReadData(self, _lpData, _pos=0, _Len=0):

        self.Clear()

        _pos = self.Head.ReadData(_lpData, _pos)

        self.Type,_pos = CommFunc.ReadBYTE(_lpData, _pos)

        self.PlayerID,_pos = CommFunc.ReadDWORD(_lpData, _pos)

        self.NameLen,_pos = CommFunc.ReadBYTE(_lpData, _pos)

        self.Name,_pos = CommFunc.ReadString(_lpData, _pos,self.NameLen)

        return _pos



    def Clear(self):

        self.Head = tagHead()

        self.Head.Clear()

        self.Head.Cmd = 0xA5

        self.Head.SubCmd = 0x24

        self.Type = 0

        self.PlayerID = 0

        self.NameLen = 0

        self.Name = ""

        return



    def GetLength(self):

        length = 0

        length += self.Head.GetLength()

        length += 1

        length += 4

        length += 1

        length += len(self.Name)



        return length



    def GetBuffer(self):

        data = ''

        data = CommFunc.WriteString(data, self.Head.GetLength(), self.Head.GetBuffer())

        data = CommFunc.WriteBYTE(data, self.Type)

        data = CommFunc.WriteDWORD(data, self.PlayerID)

        data = CommFunc.WriteBYTE(data, self.NameLen)

        data = CommFunc.WriteString(data, self.NameLen, self.Name)

        return data



    def OutputString(self):

        DumpString = '''

                                Head:%s,

                                Type:%d,

                                PlayerID:%d,

                                NameLen:%d,

                                Name:%s

                                '''\

                                %(

                                self.Head.OutputString(),

                                self.Type,

                                self.PlayerID,

                                self.NameLen,

                                self.Name

                                )

        return DumpString





m_NAtagSCFamilyMemDel=tagSCFamilyMemDel()

ChNetPackDict[eval("0x%02x%02x"%(m_NAtagSCFamilyMemDel.Head.Cmd,m_NAtagSCFamilyMemDel.Head.SubCmd))] = m_NAtagSCFamilyMemDel





#------------------------------------------------------

# A5 22 家族申请加入的玩家信息 #tagMCFamilyReqJoinInfo



class  tagMCFamilyReqJoinPlayer(Structure):

@@ -11338,6 +11490,7 @@
    TotalPage = 0    #(BYTE TotalPage)//一共有多少页

    FamilyCount = 0    #(BYTE FamilyCount)

    FamilyList = list()    #(vector<tagMCFamilyView> FamilyList)//本页家族信息列表

    Rank = 0    #(DWORD Rank)//玩家公会所在名次，0-没有公会或没有在榜上；>0-对应排名

    data = None



    def __init__(self):

@@ -11359,6 +11512,7 @@
            temFamilyList = tagMCFamilyView()

            _pos = temFamilyList.ReadData(_lpData, _pos)

            self.FamilyList.append(temFamilyList)

        self.Rank,_pos = CommFunc.ReadDWORD(_lpData, _pos)

        return _pos



    def Clear(self):

@@ -11373,6 +11527,7 @@
        self.TotalPage = 0

        self.FamilyCount = 0

        self.FamilyList = list()

        self.Rank = 0

        return



    def GetLength(self):

@@ -11386,6 +11541,7 @@
        length += 1

        for i in range(self.FamilyCount):

            length += self.FamilyList[i].GetLength()

        length += 4



        return length



@@ -11400,6 +11556,7 @@
        data = CommFunc.WriteBYTE(data, self.FamilyCount)

        for i in range(self.FamilyCount):

            data = CommFunc.WriteString(data, self.FamilyList[i].GetLength(), self.FamilyList[i].GetBuffer())

        data = CommFunc.WriteDWORD(data, self.Rank)

        return data



    def OutputString(self):

@@ -11411,7 +11568,8 @@
                                ShowCount:%d,

                                TotalPage:%d,

                                FamilyCount:%d,

                                FamilyList:%s

                                FamilyList:%s,

                                Rank:%d

                                '''\

                                %(

                                self.Head.OutputString(),

@@ -11421,7 +11579,8 @@
                                self.ShowCount,

                                self.TotalPage,

                                self.FamilyCount,

                                "..."

                                "...",

                                self.Rank

                                )

        return DumpString



@@ -11738,6 +11897,7 @@
    LeaderID = 0    #(DWORD LeaderID)//族长玩家ID

    MemberCount = 0    #(BYTE MemberCount)//人数

    MemberList = list()    #(vector<tagMCRoleFamilyMember> MemberList)//size = MemberCount

    Extra1 = 0    #(DWORD Extra1)//附加字段1

    data = None



    def __init__(self):

@@ -11768,6 +11928,7 @@
            temMemberList = tagMCRoleFamilyMember()

            _pos = temMemberList.ReadData(_lpData, _pos)

            self.MemberList.append(temMemberList)

        self.Extra1,_pos = CommFunc.ReadDWORD(_lpData, _pos)

        return _pos



    def Clear(self):

@@ -11791,6 +11952,7 @@
        self.LeaderID = 0

        self.MemberCount = 0

        self.MemberList = list()

        self.Extra1 = 0

        return



    def GetLength(self):

@@ -11813,6 +11975,7 @@
        length += 1

        for i in range(self.MemberCount):

            length += self.MemberList[i].GetLength()

        length += 4



        return length



@@ -11836,6 +11999,7 @@
        data = CommFunc.WriteBYTE(data, self.MemberCount)

        for i in range(self.MemberCount):

            data = CommFunc.WriteString(data, self.MemberList[i].GetLength(), self.MemberList[i].GetBuffer())

        data = CommFunc.WriteDWORD(data, self.Extra1)

        return data



    def OutputString(self):

@@ -11856,7 +12020,8 @@
                                Broadcast:%s,

                                LeaderID:%d,

                                MemberCount:%d,

                                MemberList:%s

                                MemberList:%s,

                                Extra1:%d

                                '''\

                                %(

                                self.Head.OutputString(),

@@ -11875,7 +12040,8 @@
                                self.Broadcast,

                                self.LeaderID,

                                self.MemberCount,

                                "..."

                                "...",

                                self.Extra1

                                )

        return DumpString



@@ -48857,12 +49023,133 @@




#------------------------------------------------------

# C2 02 跨服通用信息包 #tagSSCommMsg

# C2 03 跨服中心事件同步 #tagSSCrossCenterEvent



class  tagSSCrossCenterEvent(Structure):

    _pack_ = 1

    _fields_ = [

                  ("Cmd", c_ubyte),

                  ("SubCmd", c_ubyte),

                  ("ServerID", c_int),    
                  ("ServerType", c_ubyte),    #服务器类型

                  ("EventValue", c_int),    #事件值，yyyyMMddhh用于判断过天等

                  ]



    def __init__(self):

        self.Clear()

        self.Cmd = 0xC2

        self.SubCmd = 0x03

        return



    def ReadData(self, stringData, _pos=0, _len=0):

        self.Clear()

        memmove(addressof(self), stringData[_pos:], self.GetLength())

        return _pos + self.GetLength()



    def Clear(self):

        self.Cmd = 0xC2

        self.SubCmd = 0x03

        self.ServerID = 0

        self.ServerType = 0

        self.EventValue = 0

        return



    def GetLength(self):

        return sizeof(tagSSCrossCenterEvent)



    def GetBuffer(self):

        return string_at(addressof(self), self.GetLength())



    def OutputString(self):

        DumpString = '''// C2 03 跨服中心事件同步 //tagSSCrossCenterEvent:

                                Cmd:%s,

                                SubCmd:%s,

                                ServerID:%d,

                                ServerType:%d,

                                EventValue:%d

                                '''\

                                %(

                                self.Cmd,

                                self.SubCmd,

                                self.ServerID,

                                self.ServerType,

                                self.EventValue

                                )

        return DumpString





m_NAtagSSCrossCenterEvent=tagSSCrossCenterEvent()

ChNetPackDict[eval("0x%02x%02x"%(m_NAtagSSCrossCenterEvent.Cmd,m_NAtagSSCrossCenterEvent.SubCmd))] = m_NAtagSSCrossCenterEvent





#------------------------------------------------------

# C2 02 服务器连接跨服成功 #tagSSServerConnOK



class  tagSSServerConnOK(Structure):

    _pack_ = 1

    _fields_ = [

                  ("Cmd", c_ubyte),

                  ("SubCmd", c_ubyte),

                  ("ServerID", c_int),    
                  ("ServerType", c_ubyte),    #服务器类型

                  ("IsReconn", c_ubyte),    #是否重连的

                  ]



    def __init__(self):

        self.Clear()

        self.Cmd = 0xC2

        self.SubCmd = 0x02

        return



    def ReadData(self, stringData, _pos=0, _len=0):

        self.Clear()

        memmove(addressof(self), stringData[_pos:], self.GetLength())

        return _pos + self.GetLength()



    def Clear(self):

        self.Cmd = 0xC2

        self.SubCmd = 0x02

        self.ServerID = 0

        self.ServerType = 0

        self.IsReconn = 0

        return



    def GetLength(self):

        return sizeof(tagSSServerConnOK)



    def GetBuffer(self):

        return string_at(addressof(self), self.GetLength())



    def OutputString(self):

        DumpString = '''// C2 02 服务器连接跨服成功 //tagSSServerConnOK:

                                Cmd:%s,

                                SubCmd:%s,

                                ServerID:%d,

                                ServerType:%d,

                                IsReconn:%d

                                '''\

                                %(

                                self.Cmd,

                                self.SubCmd,

                                self.ServerID,

                                self.ServerType,

                                self.IsReconn

                                )

        return DumpString





m_NAtagSSServerConnOK=tagSSServerConnOK()

ChNetPackDict[eval("0x%02x%02x"%(m_NAtagSSServerConnOK.Cmd,m_NAtagSSServerConnOK.SubCmd))] = m_NAtagSSServerConnOK





#------------------------------------------------------

# C2 10 跨服通用信息包 #tagSSCommMsg



class  tagSSCommMsg(Structure):

    Head = tagHead()

    FromServerID = 0    #(DWORD FromServerID)//哪个服发的

    ServerTime = 0    #(DWORD ServerTime)//来源服务器时间戳

    ServerType = 0    #(BYTE ServerType)//服务器类型

    PlayerID = 0    #(DWORD PlayerID)//哪个玩家触发发送的

    TypeLen = 0    #(BYTE TypeLen)

    MsgType = ""    #(String MsgType)

    Len = 0    #(DWORD Len)

@@ -48872,14 +49159,15 @@
    def __init__(self):

        self.Clear()

        self.Head.Cmd = 0xC2

        self.Head.SubCmd = 0x02

        self.Head.SubCmd = 0x10

        return



    def ReadData(self, _lpData, _pos=0, _Len=0):

        self.Clear()

        _pos = self.Head.ReadData(_lpData, _pos)

        self.FromServerID,_pos = CommFunc.ReadDWORD(_lpData, _pos)

        self.ServerTime,_pos = CommFunc.ReadDWORD(_lpData, _pos)

        self.ServerType,_pos = CommFunc.ReadBYTE(_lpData, _pos)

        self.PlayerID,_pos = CommFunc.ReadDWORD(_lpData, _pos)

        self.TypeLen,_pos = CommFunc.ReadBYTE(_lpData, _pos)

        self.MsgType,_pos = CommFunc.ReadString(_lpData, _pos,self.TypeLen)

        self.Len,_pos = CommFunc.ReadDWORD(_lpData, _pos)

@@ -48890,9 +49178,10 @@
        self.Head = tagHead()

        self.Head.Clear()

        self.Head.Cmd = 0xC2

        self.Head.SubCmd = 0x02

        self.Head.SubCmd = 0x10

        self.FromServerID = 0

        self.ServerTime = 0

        self.ServerType = 0

        self.PlayerID = 0

        self.TypeLen = 0

        self.MsgType = ""

        self.Len = 0

@@ -48903,6 +49192,7 @@
        length = 0

        length += self.Head.GetLength()

        length += 4

        length += 1

        length += 4

        length += 1

        length += len(self.MsgType)

@@ -48915,7 +49205,8 @@
        data = ''

        data = CommFunc.WriteString(data, self.Head.GetLength(), self.Head.GetBuffer())

        data = CommFunc.WriteDWORD(data, self.FromServerID)

        data = CommFunc.WriteDWORD(data, self.ServerTime)

        data = CommFunc.WriteBYTE(data, self.ServerType)

        data = CommFunc.WriteDWORD(data, self.PlayerID)

        data = CommFunc.WriteBYTE(data, self.TypeLen)

        data = CommFunc.WriteString(data, self.TypeLen, self.MsgType)

        data = CommFunc.WriteDWORD(data, self.Len)

@@ -48926,7 +49217,8 @@
        DumpString = '''

                                Head:%s,

                                FromServerID:%d,

                                ServerTime:%d,

                                ServerType:%d,

                                PlayerID:%d,

                                TypeLen:%d,

                                MsgType:%s,

                                Len:%d,

@@ -48935,7 +49227,8 @@
                                %(

                                self.Head.OutputString(),

                                self.FromServerID,

                                self.ServerTime,

                                self.ServerType,

                                self.PlayerID,

                                self.TypeLen,

                                self.MsgType,

                                self.Len,

@@ -48949,14 +49242,16 @@




#------------------------------------------------------

# C2 01 跨服服务器间的测试包 #tagSSTest

# C2 01 跨服服务器心跳包 #tagSSHeart



class  tagSSTest(Structure):

class  tagSSHeart(Structure):

    _pack_ = 1

    _fields_ = [

                  ("Cmd", c_ubyte),

                  ("SubCmd", c_ubyte),

                  ("Data", c_int),    #测试

                  ("ServerID", c_int),    
                  ("ServerType", c_ubyte),    #服务器类型

                  ("ServerTime", c_int),    #服务器时间戳

                  ]



    def __init__(self):

@@ -48973,28 +49268,34 @@
    def Clear(self):

        self.Cmd = 0xC2

        self.SubCmd = 0x01

        self.Data = 0

        self.ServerID = 0

        self.ServerType = 0

        self.ServerTime = 0

        return



    def GetLength(self):

        return sizeof(tagSSTest)

        return sizeof(tagSSHeart)



    def GetBuffer(self):

        return string_at(addressof(self), self.GetLength())



    def OutputString(self):

        DumpString = '''// C2 01 跨服服务器间的测试包 //tagSSTest:

        DumpString = '''// C2 01 跨服服务器心跳包 //tagSSHeart:

                                Cmd:%s,

                                SubCmd:%s,

                                Data:%d

                                ServerID:%d,

                                ServerType:%d,

                                ServerTime:%d

                                '''\

                                %(

                                self.Cmd,

                                self.SubCmd,

                                self.Data

                                self.ServerID,

                                self.ServerType,

                                self.ServerTime

                                )

        return DumpString





m_NAtagSSTest=tagSSTest()

ChNetPackDict[eval("0x%02x%02x"%(m_NAtagSSTest.Cmd,m_NAtagSSTest.SubCmd))] = m_NAtagSSTest
m_NAtagSSHeart=tagSSHeart()

ChNetPackDict[eval("0x%02x%02x"%(m_NAtagSSHeart.Cmd,m_NAtagSSHeart.SubCmd))] = m_NAtagSSHeart