From 01a0e539b786ae0f1c46646874502367f5410aca Mon Sep 17 00:00:00 2001
From: hxp <ale99527@vip.qq.com>
Date: 星期三, 04 二月 2026 18:18:51 +0800
Subject: [PATCH] 66 【公会】基础主体-服务端（优化游戏服及跨服启动、通讯逻辑；服务器类型增加跨服中心、跨服事件、时间管理；跨服玩家在线状态、基础信息、玩家资源增减管理、发送跨服个人邮件等；跨服公会初版，修复公会成员审核、成员战力刷新等bug，增加公会名次同步；跨服公会暂未测试；）
---
ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/ChPyNetSendPack.py | 347 ++++++++++++++++++++++++++++++++++++++++++++++++++++++---
1 files changed, 324 insertions(+), 23 deletions(-)
diff --git a/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/ChPyNetSendPack.py b/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/ChPyNetSendPack.py
index 5986a54..c146402 100644
--- a/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/ChPyNetSendPack.py
+++ b/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
\ No newline at end of file
+m_NAtagSSHeart=tagSSHeart()
+ChNetPackDict[eval("0x%02x%02x"%(m_NAtagSSHeart.Cmd,m_NAtagSSHeart.SubCmd))] = m_NAtagSSHeart
\ No newline at end of file
--
Gitblit v1.8.0