Project_SG_ServerCode.git

			@@ -36,8 +36,8 @@
			def GetLength(self):
			length = 0
			length += 1
			length += self.Name.Length()
			return length
			length += self.Name.Length();
			return length;

			def GetBuffer(self):
			data = ''
			@@ -81,7 +81,7 @@
			length = 0
			length += 1
			length += 1
			return length
			return length;

			def GetBuffer(self):
			data = ''
			@@ -101,12 +101,133 @@

			return DumpString
			#------------------------------------------------------
			# 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)
			@@ -116,14 +237,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)
			@@ -134,9 +256,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
			@@ -147,6 +270,7 @@
			length = 0
			length += self.Head.GetLength()
			length += 4
			length += 1
			length += 4
			length += 1
			length += len(self.MsgType)
			@@ -159,7 +283,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)
			@@ -170,7 +295,8 @@
			DumpString = '''
			Head:%s,
			FromServerID:%d,
			ServerTime:%d,
			ServerType:%d,
			PlayerID:%d,
			TypeLen:%d,
			MsgType:%s,
			Len:%d,
			@@ -179,7 +305,8 @@
			%(
			self.Head.OutputString(),
			self.FromServerID,
			self.ServerTime,
			self.ServerType,
			self.PlayerID,
			self.TypeLen,
			self.MsgType,
			self.Len,
			@@ -193,14 +320,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):
			@@ -217,28 +346,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