From 26958aff1b844a743a805b4f9075bee800b72a46 Mon Sep 17 00:00:00 2001
From: hxp <ale99527@vip.qq.com>
Date: 星期二, 04 十一月 2025 14:35:37 +0800
Subject: [PATCH] 332 【主界面】座骑系统-服务端

---
 ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/PyMongoDB/Collections/DataServerPlayerData.py |  852 ++++++--------------------------------------------------
 1 files changed, 98 insertions(+), 754 deletions(-)

diff --git a/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/PyMongoDB/Collections/DataServerPlayerData.py b/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/PyMongoDB/Collections/DataServerPlayerData.py
index 41fd29e..cdfcca2 100644
--- a/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/PyMongoDB/Collections/DataServerPlayerData.py
+++ b/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/PyMongoDB/Collections/DataServerPlayerData.py
@@ -1898,7 +1898,7 @@
         ('ItemGUID', ctypes.c_char * 40),
         ('PlayerID', ctypes.c_ulong),
         ('ItemTypeID', ctypes.c_ulong),
-        ('Count', ctypes.c_ushort),
+        ('Count', ctypes.c_ulong),
         ('IsLocked', ctypes.c_ubyte),
         ('ItemPlaceType', ctypes.c_ubyte),
         ('ItemPlaceIndex', ctypes.c_ushort),
@@ -1946,7 +1946,7 @@
         self.ItemGUID, pos = CommFunc.ReadString(buf, pos, 40)
         self.PlayerID, pos = CommFunc.ReadDWORD(buf, pos)
         self.ItemTypeID, pos = CommFunc.ReadDWORD(buf, pos)
-        self.Count, pos = CommFunc.ReadWORD(buf, pos)
+        self.Count, pos = CommFunc.ReadDWORD(buf, pos)
         self.IsLocked, pos = CommFunc.ReadBYTE(buf, pos)
         self.ItemPlaceType, pos = CommFunc.ReadBYTE(buf, pos)
         self.ItemPlaceIndex, pos = CommFunc.ReadWORD(buf, pos)
@@ -1965,7 +1965,7 @@
         buf = CommFunc.WriteString(buf, sizeof(ctypes.c_char) * 40, self.ItemGUID)
         buf = CommFunc.WriteDWORD(buf, self.PlayerID)
         buf = CommFunc.WriteDWORD(buf, self.ItemTypeID)
-        buf = CommFunc.WriteWORD(buf, self.Count)
+        buf = CommFunc.WriteDWORD(buf, self.Count)
         buf = CommFunc.WriteBYTE(buf, self.IsLocked)
         buf = CommFunc.WriteBYTE(buf, self.ItemPlaceType)
         buf = CommFunc.WriteWORD(buf, self.ItemPlaceIndex)
@@ -1983,7 +1983,7 @@
         length += sizeof(ctypes.c_char) * 40
         length += sizeof(ctypes.c_ulong)
         length += sizeof(ctypes.c_ulong)
-        length += sizeof(ctypes.c_ushort)
+        length += sizeof(ctypes.c_ulong)
         length += sizeof(ctypes.c_ubyte)
         length += sizeof(ctypes.c_ubyte)
         length += sizeof(ctypes.c_ushort)
@@ -2259,7 +2259,6 @@
             self.CreateTime = Str
         else:
             self.CreateTime = Str[:30]
-            
 
 
                          
@@ -24589,527 +24588,6 @@
             )
         return output
 
- 
-# 福地矿物表 #tagDBPyMineAreaItem
-class tagDBPyMineAreaItem(Structure):
-    _pack_ = 1
-    _fields_ = [
-        ('PlayerID', ctypes.c_ulong),
-        ('Index', ctypes.c_ubyte),
-        ('MineID', ctypes.c_ushort),
-        ('MineType', ctypes.c_ubyte),
-        ('UpdTime', ctypes.c_ulong),
-        ('PosLen', ctypes.c_ubyte),
-        ('Position', ctypes.c_char_p),
-        ('WorkerCount', ctypes.c_ubyte),
-        ('WorkerState', ctypes.c_ubyte),
-        ('RobPlayerID', ctypes.c_ulong),
-        ('RobWorkerCount', ctypes.c_ubyte),
-        ('RobWorkerState', ctypes.c_ubyte),
-        ('ADOResult', ctypes.c_ulong),
-    ]
-
-    def __init__(self):
-        Structure.__init__(self)
-        self.clear()
-
-    def clear(self):
-        self.PlayerID = 0
-        self.Index = 0
-        self.MineID = 0
-        self.MineType = 0
-        self.UpdTime = 0
-        self.PosLen = 0
-        self.Position = ''
-        self.WorkerCount = 0
-        self.WorkerState = 0
-        self.RobPlayerID = 0
-        self.RobWorkerCount = 0
-        self.RobWorkerState = 0
-
-    def readData(self, buf, pos = 0, length = 0):
-        if not pos <= length:
-            msg = error.formatMsg('error', error.ERROR_NO_148, '(pos = %s) > (length = %s)'%(pos, length))
-            mylog.error(msg)
-            return -1
-        if len(buf) < pos + self.getLength():
-            msg = error.formatMsg('error', error.ERROR_NO_149, 'len = %s while %s expected!'%(len(buf) - pos, self.getLength()))
-            mylog.error(msg)
-        self.clear()
-        self.PlayerID, pos = CommFunc.ReadDWORD(buf, pos)
-        self.Index, pos = CommFunc.ReadBYTE(buf, pos)
-        self.MineID, pos = CommFunc.ReadWORD(buf, pos)
-        self.MineType, pos = CommFunc.ReadBYTE(buf, pos)
-        self.UpdTime, pos = CommFunc.ReadDWORD(buf, pos)
-        self.PosLen, pos = CommFunc.ReadBYTE(buf, pos)
-        tmp, pos = CommFunc.ReadString(buf, pos, self.PosLen)
-        self.Position = ctypes.c_char_p(tmp)
-        self.WorkerCount, pos = CommFunc.ReadBYTE(buf, pos)
-        self.WorkerState, pos = CommFunc.ReadBYTE(buf, pos)
-        self.RobPlayerID, pos = CommFunc.ReadDWORD(buf, pos)
-        self.RobWorkerCount, pos = CommFunc.ReadBYTE(buf, pos)
-        self.RobWorkerState, pos = CommFunc.ReadBYTE(buf, pos)
-        return self.getLength()
-
-    def getBuffer(self):
-        buf = ''
-        buf = CommFunc.WriteDWORD(buf, self.PlayerID)
-        buf = CommFunc.WriteBYTE(buf, self.Index)
-        buf = CommFunc.WriteWORD(buf, self.MineID)
-        buf = CommFunc.WriteBYTE(buf, self.MineType)
-        buf = CommFunc.WriteDWORD(buf, self.UpdTime)
-        buf = CommFunc.WriteBYTE(buf, self.PosLen)
-        buf = CommFunc.WriteString(buf, self.PosLen, self.Position)
-        buf = CommFunc.WriteBYTE(buf, self.WorkerCount)
-        buf = CommFunc.WriteBYTE(buf, self.WorkerState)
-        buf = CommFunc.WriteDWORD(buf, self.RobPlayerID)
-        buf = CommFunc.WriteBYTE(buf, self.RobWorkerCount)
-        buf = CommFunc.WriteBYTE(buf, self.RobWorkerState)
-        return buf
-
-    def getLength(self):
-        length = 0
-        length += sizeof(ctypes.c_ulong)
-        length += sizeof(ctypes.c_ubyte)
-        length += sizeof(ctypes.c_ushort)
-        length += sizeof(ctypes.c_ubyte)
-        length += sizeof(ctypes.c_ulong)
-        length += sizeof(ctypes.c_ubyte)
-        length += self.PosLen
-        length += sizeof(ctypes.c_ubyte)
-        length += sizeof(ctypes.c_ubyte)
-        length += sizeof(ctypes.c_ulong)
-        length += sizeof(ctypes.c_ubyte)
-        length += sizeof(ctypes.c_ubyte)
-        return length
-
-    def getRecord(self):
-        '''组织存储记录'''
-        rec = {}
-        rec[u'PlayerID'] = self.PlayerID
-        rec[u'Index'] = self.Index
-        rec[u'MineID'] = self.MineID
-        rec[u'MineType'] = self.MineType
-        rec[u'UpdTime'] = self.UpdTime
-        rec[u'PosLen'] = self.PosLen
-        rec[u'Position'] = fix_incomingText(self.Position)
-        rec[u'WorkerCount'] = self.WorkerCount
-        rec[u'WorkerState'] = self.WorkerState
-        rec[u'RobPlayerID'] = self.RobPlayerID
-        rec[u'RobWorkerCount'] = self.RobWorkerCount
-        rec[u'RobWorkerState'] = self.RobWorkerState
-        return rec
-
-    def readRecord(self, rec):
-        '''由于MongoDB读出来是unicode,所有字符串需要进行转换'''
-        self.PlayerID = rec.get(u'PlayerID', 0)
-        self.Index = rec.get(u'Index', 0)
-        self.MineID = rec.get(u'MineID', 0)
-        self.MineType = rec.get(u'MineType', 0)
-        self.UpdTime = rec.get(u'UpdTime', 0)
-        self.PosLen = rec.get(u'PosLen', 0)
-        self.Position = fix_outgoingText(rec.get(u'Position', u''))
-        self.WorkerCount = rec.get(u'WorkerCount', 0)
-        self.WorkerState = rec.get(u'WorkerState', 0)
-        self.RobPlayerID = rec.get(u'RobPlayerID', 0)
-        self.RobWorkerCount = rec.get(u'RobWorkerCount', 0)
-        self.RobWorkerState = rec.get(u'RobWorkerState', 0)
-
-#Can not implement adoLoadStr method:No key defined!
-#Can not implement adoInsertStr method:No key defined!
-#Can not implement adoUpdateStr method:No key defined!
-#Can not implement adoUpdateStr method:No key defined!
-#Can not implement adoCheckUpdateStr method:No key defined!
-#Can not implement adoCheckUpdateExStr method:No key defined!
-
-    def getAdoRecords(self, resultCollection):
-        '''查询结果打包成二进制流'''
-        result = ''
-        result = CommFunc.WriteDWORD(result, resultCollection.count())
-        for rec in resultCollection:
-            self.readRecord(rec)
-            result += self.getBuffer()
-        return result
-
-#Can not implement adoQueryIndexStr method:No key defined!
-
-    def adoQueryCustom(self, collection, queryDict):
-        '''自定义查询'''
-        resultCollection = collection.find(queryDict)
-
-        return self.getAdoRecords(resultCollection)
-
-
-    def adoQueryAll(self, collection):
-        '''查询所有''' 
-        resultCollection = collection.find()
-         
-        return self.getAdoRecords(resultCollection)
-
-#Can not implement adoDeleteByIndexStr method:No key defined!
-    def outputString(self):
-        output = '''// 福地矿物表 #tagDBPyMineAreaItem:
-            PlayerID = %s,
-            Index = %s,
-            MineID = %s,
-            MineType = %s,
-            UpdTime = %s,
-            PosLen = %s,
-            Position = %s,
-            WorkerCount = %s,
-            WorkerState = %s,
-            RobPlayerID = %s,
-            RobWorkerCount = %s,
-            RobWorkerState = %s,
-            ADOResult = %s,
-            '''%(
-                self.PlayerID,
-                self.Index,
-                self.MineID,
-                self.MineType,
-                self.UpdTime,
-                self.PosLen,
-                self.Position,
-                self.WorkerCount,
-                self.WorkerState,
-                self.RobPlayerID,
-                self.RobWorkerCount,
-                self.RobWorkerState,
-                self.ADOResult,
-            )
-        return output
-
-    def dumpString(self):
-        output = '''%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s'''%(
-                self.PlayerID,
-                self.Index,
-                self.MineID,
-                self.MineType,
-                self.UpdTime,
-                self.PosLen,
-                self.Position,
-                self.WorkerCount,
-                self.WorkerState,
-                self.RobPlayerID,
-                self.RobWorkerCount,
-                self.RobWorkerState,
-            )
-        return output
-
-
-# 福地记录表 #tagDBPyMineAreaRecord
-class tagDBPyMineAreaRecord(Structure):
-    _pack_ = 1
-    _fields_ = [
-        ('PlayerID', ctypes.c_ulong),
-        ('RecordType', ctypes.c_ulong),
-        ('TagPlayerID', ctypes.c_ulong),
-        ('RecordTime', ctypes.c_ulong),
-        ('MineID', ctypes.c_ushort),
-        ('DataLen', ctypes.c_ushort),
-        ('Data', ctypes.c_char_p),
-        ('ADOResult', ctypes.c_ulong),
-    ]
-
-    def __init__(self):
-        Structure.__init__(self)
-        self.clear()
-
-    def clear(self):
-        self.PlayerID = 0
-        self.RecordType = 0
-        self.TagPlayerID = 0
-        self.RecordTime = 0
-        self.MineID = 0
-        self.DataLen = 0
-        self.Data = ''
-
-    def readData(self, buf, pos = 0, length = 0):
-        if not pos <= length:
-            msg = error.formatMsg('error', error.ERROR_NO_148, '(pos = %s) > (length = %s)'%(pos, length))
-            mylog.error(msg)
-            return -1
-        if len(buf) < pos + self.getLength():
-            msg = error.formatMsg('error', error.ERROR_NO_149, 'len = %s while %s expected!'%(len(buf) - pos, self.getLength()))
-            mylog.error(msg)
-        self.clear()
-        self.PlayerID, pos = CommFunc.ReadDWORD(buf, pos)
-        self.RecordType, pos = CommFunc.ReadDWORD(buf, pos)
-        self.TagPlayerID, pos = CommFunc.ReadDWORD(buf, pos)
-        self.RecordTime, pos = CommFunc.ReadDWORD(buf, pos)
-        self.MineID, pos = CommFunc.ReadWORD(buf, pos)
-        self.DataLen, pos = CommFunc.ReadWORD(buf, pos)
-        tmp, pos = CommFunc.ReadString(buf, pos, self.DataLen)
-        self.Data = ctypes.c_char_p(tmp)
-        return self.getLength()
-
-    def getBuffer(self):
-        buf = ''
-        buf = CommFunc.WriteDWORD(buf, self.PlayerID)
-        buf = CommFunc.WriteDWORD(buf, self.RecordType)
-        buf = CommFunc.WriteDWORD(buf, self.TagPlayerID)
-        buf = CommFunc.WriteDWORD(buf, self.RecordTime)
-        buf = CommFunc.WriteWORD(buf, self.MineID)
-        buf = CommFunc.WriteWORD(buf, self.DataLen)
-        buf = CommFunc.WriteString(buf, self.DataLen, self.Data)
-        return buf
-
-    def getLength(self):
-        length = 0
-        length += sizeof(ctypes.c_ulong)
-        length += sizeof(ctypes.c_ulong)
-        length += sizeof(ctypes.c_ulong)
-        length += sizeof(ctypes.c_ulong)
-        length += sizeof(ctypes.c_ushort)
-        length += sizeof(ctypes.c_ushort)
-        length += self.DataLen
-        return length
-
-    def getRecord(self):
-        '''组织存储记录'''
-        rec = {}
-        rec[u'PlayerID'] = self.PlayerID
-        rec[u'RecordType'] = self.RecordType
-        rec[u'TagPlayerID'] = self.TagPlayerID
-        rec[u'RecordTime'] = self.RecordTime
-        rec[u'MineID'] = self.MineID
-        rec[u'DataLen'] = self.DataLen
-        rec[u'Data'] = fix_incomingText(self.Data)
-        return rec
-
-    def readRecord(self, rec):
-        '''由于MongoDB读出来是unicode,所有字符串需要进行转换'''
-        self.PlayerID = rec.get(u'PlayerID', 0)
-        self.RecordType = rec.get(u'RecordType', 0)
-        self.TagPlayerID = rec.get(u'TagPlayerID', 0)
-        self.RecordTime = rec.get(u'RecordTime', 0)
-        self.MineID = rec.get(u'MineID', 0)
-        self.DataLen = rec.get(u'DataLen', 0)
-        self.Data = fix_outgoingText(rec.get(u'Data', u''))
-
-#Can not implement adoLoadStr method:No key defined!
-#Can not implement adoInsertStr method:No key defined!
-#Can not implement adoUpdateStr method:No key defined!
-#Can not implement adoUpdateStr method:No key defined!
-#Can not implement adoCheckUpdateStr method:No key defined!
-#Can not implement adoCheckUpdateExStr method:No key defined!
-
-    def getAdoRecords(self, resultCollection):
-        '''查询结果打包成二进制流'''
-        result = ''
-        result = CommFunc.WriteDWORD(result, resultCollection.count())
-        for rec in resultCollection:
-            self.readRecord(rec)
-            result += self.getBuffer()
-        return result
-
-#Can not implement adoQueryIndexStr method:No key defined!
-
-    def adoQueryCustom(self, collection, queryDict):
-        '''自定义查询'''
-        resultCollection = collection.find(queryDict)
-
-        return self.getAdoRecords(resultCollection)
-
-
-    def adoQueryAll(self, collection):
-        '''查询所有''' 
-        resultCollection = collection.find()
-         
-        return self.getAdoRecords(resultCollection)
-
-#Can not implement adoDeleteByIndexStr method:No key defined!
-    def outputString(self):
-        output = '''// 福地记录表 #tagDBPyMineAreaRecord:
-            PlayerID = %s,
-            RecordType = %s,
-            TagPlayerID = %s,
-            RecordTime = %s,
-            MineID = %s,
-            DataLen = %s,
-            Data = %s,
-            ADOResult = %s,
-            '''%(
-                self.PlayerID,
-                self.RecordType,
-                self.TagPlayerID,
-                self.RecordTime,
-                self.MineID,
-                self.DataLen,
-                self.Data,
-                self.ADOResult,
-            )
-        return output
-
-    def dumpString(self):
-        output = '''%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s'''%(
-                self.PlayerID,
-                self.RecordType,
-                self.TagPlayerID,
-                self.RecordTime,
-                self.MineID,
-                self.DataLen,
-                self.Data,
-            )
-        return output
-
-
-# 福地结算奖励表 #tagDBPyMineAreaAward
-class tagDBPyMineAreaAward(Structure):
-    _pack_ = 1
-    _fields_ = [
-        ('GUIDLen', ctypes.c_ubyte),
-        ('GUID', ctypes.c_char_p),
-        ('PlayerID', ctypes.c_ulong),
-        ('AwardTime', ctypes.c_ulong),
-        ('MineID', ctypes.c_ushort),
-        ('WorkerCount', ctypes.c_ubyte),
-        ('AreaPlayerID', ctypes.c_ulong),
-        ('ADOResult', ctypes.c_ulong),
-    ]
-
-    def __init__(self):
-        Structure.__init__(self)
-        self.clear()
-
-    def clear(self):
-        self.GUIDLen = 0
-        self.GUID = ''
-        self.PlayerID = 0
-        self.AwardTime = 0
-        self.MineID = 0
-        self.WorkerCount = 0
-        self.AreaPlayerID = 0
-
-    def readData(self, buf, pos = 0, length = 0):
-        if not pos <= length:
-            msg = error.formatMsg('error', error.ERROR_NO_148, '(pos = %s) > (length = %s)'%(pos, length))
-            mylog.error(msg)
-            return -1
-        if len(buf) < pos + self.getLength():
-            msg = error.formatMsg('error', error.ERROR_NO_149, 'len = %s while %s expected!'%(len(buf) - pos, self.getLength()))
-            mylog.error(msg)
-        self.clear()
-        self.GUIDLen, pos = CommFunc.ReadBYTE(buf, pos)
-        tmp, pos = CommFunc.ReadString(buf, pos, self.GUIDLen)
-        self.GUID = ctypes.c_char_p(tmp)
-        self.PlayerID, pos = CommFunc.ReadDWORD(buf, pos)
-        self.AwardTime, pos = CommFunc.ReadDWORD(buf, pos)
-        self.MineID, pos = CommFunc.ReadWORD(buf, pos)
-        self.WorkerCount, pos = CommFunc.ReadBYTE(buf, pos)
-        self.AreaPlayerID, pos = CommFunc.ReadDWORD(buf, pos)
-        return self.getLength()
-
-    def getBuffer(self):
-        buf = ''
-        buf = CommFunc.WriteBYTE(buf, self.GUIDLen)
-        buf = CommFunc.WriteString(buf, self.GUIDLen, self.GUID)
-        buf = CommFunc.WriteDWORD(buf, self.PlayerID)
-        buf = CommFunc.WriteDWORD(buf, self.AwardTime)
-        buf = CommFunc.WriteWORD(buf, self.MineID)
-        buf = CommFunc.WriteBYTE(buf, self.WorkerCount)
-        buf = CommFunc.WriteDWORD(buf, self.AreaPlayerID)
-        return buf
-
-    def getLength(self):
-        length = 0
-        length += sizeof(ctypes.c_ubyte)
-        length += self.GUIDLen
-        length += sizeof(ctypes.c_ulong)
-        length += sizeof(ctypes.c_ulong)
-        length += sizeof(ctypes.c_ushort)
-        length += sizeof(ctypes.c_ubyte)
-        length += sizeof(ctypes.c_ulong)
-        return length
-
-    def getRecord(self):
-        '''组织存储记录'''
-        rec = {}
-        rec[u'GUIDLen'] = self.GUIDLen
-        rec[u'GUID'] = fix_incomingText(self.GUID)
-        rec[u'PlayerID'] = self.PlayerID
-        rec[u'AwardTime'] = self.AwardTime
-        rec[u'MineID'] = self.MineID
-        rec[u'WorkerCount'] = self.WorkerCount
-        rec[u'AreaPlayerID'] = self.AreaPlayerID
-        return rec
-
-    def readRecord(self, rec):
-        '''由于MongoDB读出来是unicode,所有字符串需要进行转换'''
-        self.GUIDLen = rec.get(u'GUIDLen', 0)
-        self.GUID = fix_outgoingText(rec.get(u'GUID', u''))
-        self.PlayerID = rec.get(u'PlayerID', 0)
-        self.AwardTime = rec.get(u'AwardTime', 0)
-        self.MineID = rec.get(u'MineID', 0)
-        self.WorkerCount = rec.get(u'WorkerCount', 0)
-        self.AreaPlayerID = rec.get(u'AreaPlayerID', 0)
-
-#Can not implement adoLoadStr method:No key defined!
-#Can not implement adoInsertStr method:No key defined!
-#Can not implement adoUpdateStr method:No key defined!
-#Can not implement adoUpdateStr method:No key defined!
-#Can not implement adoCheckUpdateStr method:No key defined!
-#Can not implement adoCheckUpdateExStr method:No key defined!
-
-    def getAdoRecords(self, resultCollection):
-        '''查询结果打包成二进制流'''
-        result = ''
-        result = CommFunc.WriteDWORD(result, resultCollection.count())
-        for rec in resultCollection:
-            self.readRecord(rec)
-            result += self.getBuffer()
-        return result
-
-#Can not implement adoQueryIndexStr method:No key defined!
-
-    def adoQueryCustom(self, collection, queryDict):
-        '''自定义查询'''
-        resultCollection = collection.find(queryDict)
-
-        return self.getAdoRecords(resultCollection)
-
-
-    def adoQueryAll(self, collection):
-        '''查询所有''' 
-        resultCollection = collection.find()
-         
-        return self.getAdoRecords(resultCollection)
-
-#Can not implement adoDeleteByIndexStr method:No key defined!
-    def outputString(self):
-        output = '''// 福地结算奖励表 #tagDBPyMineAreaAward:
-            GUIDLen = %s,
-            GUID = %s,
-            PlayerID = %s,
-            AwardTime = %s,
-            MineID = %s,
-            WorkerCount = %s,
-            AreaPlayerID = %s,
-            ADOResult = %s,
-            '''%(
-                self.GUIDLen,
-                self.GUID,
-                self.PlayerID,
-                self.AwardTime,
-                self.MineID,
-                self.WorkerCount,
-                self.AreaPlayerID,
-                self.ADOResult,
-            )
-        return output
-
-    def dumpString(self):
-        output = '''%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s'''%(
-                self.GUIDLen,
-                self.GUID,
-                self.PlayerID,
-                self.AwardTime,
-                self.MineID,
-                self.WorkerCount,
-                self.AreaPlayerID,
-            )
-        return output
-
 
 # 玩家记录表 #tagDBPlayerRecData
 class tagDBPlayerRecData(Structure):
@@ -26406,9 +25884,12 @@
         ('RealmLV', ctypes.c_ubyte),
         ('Face', ctypes.c_int),
         ('FacePic', ctypes.c_int),
+        ('ModelMark', ctypes.c_ulong),
+        ('EquipShowSwitch', ctypes.c_ulong),
         ('FamilyID', ctypes.c_ulong),
         ('FamilyName', ctypes.c_char * 33),
         ('FamilyEmblemID', ctypes.c_ushort),
+        ('FamilyEmblemWord', ctypes.c_char * 3),
         ('TitleID', ctypes.c_ulong),
         ('FightPower', ctypes.c_ulong),
         ('FightPowerEx', ctypes.c_ulong),
@@ -26432,9 +25913,12 @@
         self.RealmLV = 0
         self.Face = 0
         self.FacePic = 0
+        self.ModelMark = 0
+        self.EquipShowSwitch = 0
         self.FamilyID = 0
         self.FamilyName = ''
         self.FamilyEmblemID = 0
+        self.FamilyEmblemWord = ''
         self.TitleID = 0
         self.FightPower = 0
         self.FightPowerEx = 0
@@ -26460,9 +25944,12 @@
         self.RealmLV, pos = CommFunc.ReadBYTE(buf, pos)
         self.Face, pos = CommFunc.ReadDWORD(buf, pos)
         self.FacePic, pos = CommFunc.ReadDWORD(buf, pos)
+        self.ModelMark, pos = CommFunc.ReadDWORD(buf, pos)
+        self.EquipShowSwitch, pos = CommFunc.ReadDWORD(buf, pos)
         self.FamilyID, pos = CommFunc.ReadDWORD(buf, pos)
         self.FamilyName, pos = CommFunc.ReadString(buf, pos, 33)
         self.FamilyEmblemID, pos = CommFunc.ReadWORD(buf, pos)
+        self.FamilyEmblemWord, pos = CommFunc.ReadString(buf, pos, 3)
         self.TitleID, pos = CommFunc.ReadDWORD(buf, pos)
         self.FightPower, pos = CommFunc.ReadDWORD(buf, pos)
         self.FightPowerEx, pos = CommFunc.ReadDWORD(buf, pos)
@@ -26483,9 +25970,12 @@
         buf = CommFunc.WriteBYTE(buf, self.RealmLV)
         buf = CommFunc.WriteDWORD(buf, self.Face)
         buf = CommFunc.WriteDWORD(buf, self.FacePic)
+        buf = CommFunc.WriteDWORD(buf, self.ModelMark)
+        buf = CommFunc.WriteDWORD(buf, self.EquipShowSwitch)
         buf = CommFunc.WriteDWORD(buf, self.FamilyID)
         buf = CommFunc.WriteString(buf, sizeof(ctypes.c_char) * 33, self.FamilyName)
         buf = CommFunc.WriteWORD(buf, self.FamilyEmblemID)
+        buf = CommFunc.WriteString(buf, sizeof(ctypes.c_char) * 3, self.FamilyEmblemWord)
         buf = CommFunc.WriteDWORD(buf, self.TitleID)
         buf = CommFunc.WriteDWORD(buf, self.FightPower)
         buf = CommFunc.WriteDWORD(buf, self.FightPowerEx)
@@ -26506,8 +25996,11 @@
         length += sizeof(ctypes.c_int)
         length += sizeof(ctypes.c_int)
         length += sizeof(ctypes.c_ulong)
+        length += sizeof(ctypes.c_ulong)
+        length += sizeof(ctypes.c_ulong)
         length += sizeof(ctypes.c_char) * 33
         length += sizeof(ctypes.c_ushort)
+        length += sizeof(ctypes.c_char) * 3
         length += sizeof(ctypes.c_ulong)
         length += sizeof(ctypes.c_ulong)
         length += sizeof(ctypes.c_ulong)
@@ -26528,9 +26021,12 @@
         rec[u'RealmLV'] = self.RealmLV
         rec[u'Face'] = self.Face
         rec[u'FacePic'] = self.FacePic
+        rec[u'ModelMark'] = self.ModelMark
+        rec[u'EquipShowSwitch'] = self.EquipShowSwitch
         rec[u'FamilyID'] = self.FamilyID
         rec[u'FamilyName'] = fix_incomingText(self.FamilyName)
         rec[u'FamilyEmblemID'] = self.FamilyEmblemID
+        rec[u'FamilyEmblemWord'] = fix_incomingText(self.FamilyEmblemWord)
         rec[u'TitleID'] = self.TitleID
         rec[u'FightPower'] = self.FightPower
         rec[u'FightPowerEx'] = self.FightPowerEx
@@ -26550,9 +26046,12 @@
         self.RealmLV = rec.get(u'RealmLV', 0)
         self.Face = rec.get(u'Face', 0)
         self.FacePic = rec.get(u'FacePic', 0)
+        self.ModelMark = rec.get(u'ModelMark', 0)
+        self.EquipShowSwitch = rec.get(u'EquipShowSwitch', 0)
         self.FamilyID = rec.get(u'FamilyID', 0)
         self.FamilyName = fix_outgoingText(rec.get(u'FamilyName', u''))
         self.FamilyEmblemID = rec.get(u'FamilyEmblemID', 0)
+        self.FamilyEmblemWord = fix_outgoingText(rec.get(u'FamilyEmblemWord', u''))
         self.TitleID = rec.get(u'TitleID', 0)
         self.FightPower = rec.get(u'FightPower', 0)
         self.FightPowerEx = rec.get(u'FightPowerEx', 0)
@@ -26671,9 +26170,12 @@
             RealmLV = %s,
             Face = %s,
             FacePic = %s,
+            ModelMark = %s,
+            EquipShowSwitch = %s,
             FamilyID = %s,
             FamilyName = %s,
             FamilyEmblemID = %s,
+            FamilyEmblemWord = %s,
             TitleID = %s,
             FightPower = %s,
             FightPowerEx = %s,
@@ -26691,9 +26193,12 @@
                 self.RealmLV,
                 self.Face,
                 self.FacePic,
+                self.ModelMark,
+                self.EquipShowSwitch,
                 self.FamilyID,
                 self.FamilyName,
                 self.FamilyEmblemID,
+                self.FamilyEmblemWord,
                 self.TitleID,
                 self.FightPower,
                 self.FightPowerEx,
@@ -26706,7 +26211,7 @@
         return output
 
     def dumpString(self):
-        output = '''%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s'''%(
+        output = '''%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s'''%(
                 self.PlayerID,
                 self.AccID,
                 self.PlayerName,
@@ -26715,9 +26220,12 @@
                 self.RealmLV,
                 self.Face,
                 self.FacePic,
+                self.ModelMark,
+                self.EquipShowSwitch,
                 self.FamilyID,
                 self.FamilyName,
                 self.FamilyEmblemID,
+                self.FamilyEmblemWord,
                 self.TitleID,
                 self.FightPower,
                 self.FightPowerEx,
@@ -26747,6 +26255,12 @@
         else:
             self.FamilyName = Str[:33]
             
+    def SetFamilyEmblemWord(self,Str):
+        if len(Str)<=3:
+            self.FamilyEmblemWord = Str
+        else:
+            self.FamilyEmblemWord = Str[:3]
+            
 
 # 排行榜表 #tagDBBillboard
 class tagDBBillboard(Structure):
@@ -26771,6 +26285,7 @@
         ('CmpValue', ctypes.c_ulong),
         ('CmpValue2', ctypes.c_ulong),
         ('CmpValue3', ctypes.c_ulong),
+        ('Time', ctypes.c_ulong),
         ('DataLen', ctypes.c_ushort),
         ('UserData', ctypes.c_char_p),
         ('ADOResult', ctypes.c_ulong),
@@ -26800,6 +26315,7 @@
         self.CmpValue = 0
         self.CmpValue2 = 0
         self.CmpValue3 = 0
+        self.Time = 0
         self.DataLen = 0
         self.UserData = ''
 
@@ -26831,6 +26347,7 @@
         self.CmpValue, pos = CommFunc.ReadDWORD(buf, pos)
         self.CmpValue2, pos = CommFunc.ReadDWORD(buf, pos)
         self.CmpValue3, pos = CommFunc.ReadDWORD(buf, pos)
+        self.Time, pos = CommFunc.ReadDWORD(buf, pos)
         self.DataLen, pos = CommFunc.ReadWORD(buf, pos)
         tmp, pos = CommFunc.ReadString(buf, pos, self.DataLen)
         self.UserData = ctypes.c_char_p(tmp)
@@ -26857,6 +26374,7 @@
         buf = CommFunc.WriteDWORD(buf, self.CmpValue)
         buf = CommFunc.WriteDWORD(buf, self.CmpValue2)
         buf = CommFunc.WriteDWORD(buf, self.CmpValue3)
+        buf = CommFunc.WriteDWORD(buf, self.Time)
         buf = CommFunc.WriteWORD(buf, self.DataLen)
         buf = CommFunc.WriteString(buf, self.DataLen, self.UserData)
         return buf
@@ -26871,6 +26389,7 @@
         length += sizeof(ctypes.c_char) * 33
         length += sizeof(ctypes.c_char) * 65
         length += sizeof(ctypes.c_ubyte)
+        length += sizeof(ctypes.c_ulong)
         length += sizeof(ctypes.c_ulong)
         length += sizeof(ctypes.c_ulong)
         length += sizeof(ctypes.c_ulong)
@@ -26908,6 +26427,7 @@
         rec[u'CmpValue'] = self.CmpValue
         rec[u'CmpValue2'] = self.CmpValue2
         rec[u'CmpValue3'] = self.CmpValue3
+        rec[u'Time'] = self.Time
         rec[u'DataLen'] = self.DataLen
         rec[u'UserData'] = fix_incomingText(self.UserData)
         return rec
@@ -26933,6 +26453,7 @@
         self.CmpValue = rec.get(u'CmpValue', 0)
         self.CmpValue2 = rec.get(u'CmpValue2', 0)
         self.CmpValue3 = rec.get(u'CmpValue3', 0)
+        self.Time = rec.get(u'Time', 0)
         self.DataLen = rec.get(u'DataLen', 0)
         self.UserData = fix_outgoingText(rec.get(u'UserData', u''))
 
@@ -26989,6 +26510,7 @@
             CmpValue = %s,
             CmpValue2 = %s,
             CmpValue3 = %s,
+            Time = %s,
             DataLen = %s,
             UserData = %s,
             ADOResult = %s,
@@ -27012,6 +26534,7 @@
                 self.CmpValue,
                 self.CmpValue2,
                 self.CmpValue3,
+                self.Time,
                 self.DataLen,
                 self.UserData,
                 self.ADOResult,
@@ -27019,7 +26542,7 @@
         return output
 
     def dumpString(self):
-        output = '''%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s'''%(
+        output = '''%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s'''%(
                 self.GroupValue1,
                 self.GroupValue2,
                 self.BillboardType,
@@ -27039,6 +26562,7 @@
                 self.CmpValue,
                 self.CmpValue2,
                 self.CmpValue3,
+                self.Time,
                 self.DataLen,
                 self.UserData,
             )
@@ -27759,6 +27283,7 @@
         ('FightPower', ctypes.c_ulong),
         ('FightPowerEx', ctypes.c_ulong),
         ('EmblemID', ctypes.c_ushort),
+        ('EmblemWord', ctypes.c_char * 3),
         ('ADOResult', ctypes.c_ulong),
     ]
 
@@ -27781,6 +27306,7 @@
         self.FightPower = 0
         self.FightPowerEx = 0
         self.EmblemID = 0
+        self.EmblemWord = ''
 
     def readData(self, buf, pos = 0, length = 0):
         if not pos <= length:
@@ -27806,6 +27332,7 @@
         self.FightPower, pos = CommFunc.ReadDWORD(buf, pos)
         self.FightPowerEx, pos = CommFunc.ReadDWORD(buf, pos)
         self.EmblemID, pos = CommFunc.ReadWORD(buf, pos)
+        self.EmblemWord, pos = CommFunc.ReadString(buf, pos, 3)
         return self.getLength()
 
     def getBuffer(self):
@@ -27824,6 +27351,7 @@
         buf = CommFunc.WriteDWORD(buf, self.FightPower)
         buf = CommFunc.WriteDWORD(buf, self.FightPowerEx)
         buf = CommFunc.WriteWORD(buf, self.EmblemID)
+        buf = CommFunc.WriteString(buf, sizeof(ctypes.c_char) * 3, self.EmblemWord)
         return buf
 
     def getLength(self):
@@ -27842,6 +27370,7 @@
         length += sizeof(ctypes.c_ulong)
         length += sizeof(ctypes.c_ulong)
         length += sizeof(ctypes.c_ushort)
+        length += sizeof(ctypes.c_char) * 3
         return length
 
     def getRecord(self):
@@ -27861,6 +27390,7 @@
         rec[u'FightPower'] = self.FightPower
         rec[u'FightPowerEx'] = self.FightPowerEx
         rec[u'EmblemID'] = self.EmblemID
+        rec[u'EmblemWord'] = fix_incomingText(self.EmblemWord)
         return rec
 
     def readRecord(self, rec):
@@ -27879,6 +27409,7 @@
         self.FightPower = rec.get(u'FightPower', 0)
         self.FightPowerEx = rec.get(u'FightPowerEx', 0)
         self.EmblemID = rec.get(u'EmblemID', 0)
+        self.EmblemWord = fix_outgoingText(rec.get(u'EmblemWord', u''))
 
     def adoLoad(self, collection):
         '''使用KEY查找并读取'''
@@ -28044,6 +27575,7 @@
             FightPower = %s,
             FightPowerEx = %s,
             EmblemID = %s,
+            EmblemWord = %s,
             ADOResult = %s,
             '''%(
                 self.ID,
@@ -28060,12 +27592,13 @@
                 self.FightPower,
                 self.FightPowerEx,
                 self.EmblemID,
+                self.EmblemWord,
                 self.ADOResult,
             )
         return output
 
     def dumpString(self):
-        output = '''%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s'''%(
+        output = '''%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s'''%(
                 self.ID,
                 self.Name,
                 self.LeaderID,
@@ -28080,6 +27613,7 @@
                 self.FightPower,
                 self.FightPowerEx,
                 self.EmblemID,
+                self.EmblemWord,
             )
         return output
 
@@ -28089,6 +27623,12 @@
             self.Name = Str
         else:
             self.Name = Str[:33]
+            
+    def SetEmblemWord(self,Str):
+        if len(Str)<=3:
+            self.EmblemWord = Str
+        else:
+            self.EmblemWord = Str[:3]
             
 
 # 家族成员表 #tagDBFamilyMem
@@ -28110,7 +27650,10 @@
         ('OffTime', ctypes.c_ulong),
         ('FmLV', ctypes.c_ubyte),
         ('ContribTotal', ctypes.c_ulong),
-        ('ContribWeek', ctypes.c_ulong),
+        ('ContribDay', ctypes.c_ulong),
+        ('DonateCntTotal', ctypes.c_ulong),
+        ('DonateCntDay', ctypes.c_ubyte),
+        ('TitleID', ctypes.c_ulong),
         ('ADOResult', ctypes.c_ulong),
     ]
 
@@ -28146,7 +27689,10 @@
         self.OffTime, pos = CommFunc.ReadDWORD(buf, pos)
         self.FmLV, pos = CommFunc.ReadBYTE(buf, pos)
         self.ContribTotal, pos = CommFunc.ReadDWORD(buf, pos)
-        self.ContribWeek, pos = CommFunc.ReadDWORD(buf, pos)
+        self.ContribDay, pos = CommFunc.ReadDWORD(buf, pos)
+        self.DonateCntTotal, pos = CommFunc.ReadDWORD(buf, pos)
+        self.DonateCntDay, pos = CommFunc.ReadBYTE(buf, pos)
+        self.TitleID, pos = CommFunc.ReadDWORD(buf, pos)
         return self.getLength()
 
 
@@ -28176,7 +27722,10 @@
         rec[u'OffTime'] = self.OffTime
         rec[u'FmLV'] = self.FmLV
         rec[u'ContribTotal'] = self.ContribTotal
-        rec[u'ContribWeek'] = self.ContribWeek
+        rec[u'ContribDay'] = self.ContribDay
+        rec[u'DonateCntTotal'] = self.DonateCntTotal
+        rec[u'DonateCntDay'] = self.DonateCntDay
+        rec[u'TitleID'] = self.TitleID
         return rec
 
     def readRecord(self, rec):
@@ -28196,7 +27745,10 @@
         self.OffTime = rec.get(u'OffTime', 0)
         self.FmLV = rec.get(u'FmLV', 0)
         self.ContribTotal = rec.get(u'ContribTotal', 0)
-        self.ContribWeek = rec.get(u'ContribWeek', 0)
+        self.ContribDay = rec.get(u'ContribDay', 0)
+        self.DonateCntTotal = rec.get(u'DonateCntTotal', 0)
+        self.DonateCntDay = rec.get(u'DonateCntDay', 0)
+        self.TitleID = rec.get(u'TitleID', 0)
 
     def adoLoad(self, collection):
         '''使用KEY查找并读取'''
@@ -28363,7 +27915,10 @@
             OffTime = %s,
             FmLV = %s,
             ContribTotal = %s,
-            ContribWeek = %s,
+            ContribDay = %s,
+            DonateCntTotal = %s,
+            DonateCntDay = %s,
+            TitleID = %s,
             ADOResult = %s,
             '''%(
                 self.PlayerID,
@@ -28381,13 +27936,16 @@
                 self.OffTime,
                 self.FmLV,
                 self.ContribTotal,
-                self.ContribWeek,
+                self.ContribDay,
+                self.DonateCntTotal,
+                self.DonateCntDay,
+                self.TitleID,
                 self.ADOResult,
             )
         return output
 
     def dumpString(self):
-        output = '''%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s'''%(
+        output = '''%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s'''%(
                 self.PlayerID,
                 self.FamilyID,
                 self.JoinTime,
@@ -28403,7 +27961,10 @@
                 self.OffTime,
                 self.FmLV,
                 self.ContribTotal,
-                self.ContribWeek,
+                self.ContribDay,
+                self.DonateCntTotal,
+                self.DonateCntDay,
+                self.TitleID,
             )
         return output
 
@@ -28696,223 +28257,6 @@
         else:
             self.Name = Str[:33]
             
-
-
-# 通用记录表新 #tagDBGameRec
-class tagDBGameRec(Structure):
-    _pack_ = 1
-    _fields_ = [
-        ('RecType', ctypes.c_ushort),
-        ('RecID', ctypes.c_ulong),
-        ('Time', ctypes.c_double),
-        ('Value1', ctypes.c_ulong),
-        ('Value2', ctypes.c_ulong),
-        ('Value3', ctypes.c_ulong),
-        ('Value4', ctypes.c_ulong),
-        ('Value5', ctypes.c_ulong),
-        ('Value6', ctypes.c_ulong),
-        ('Value7', ctypes.c_ulong),
-        ('Value8', ctypes.c_ulong),
-        ('UserDataLen', ctypes.c_ushort),
-        ('UserData', ctypes.c_char_p),
-        ('ADOResult', ctypes.c_ulong),
-    ]
-
-    def __init__(self):
-        Structure.__init__(self)
-        self.clear()
-
-    def clear(self):
-        self.RecType = 0
-        self.RecID = 0
-        self.Time = 0.0
-        self.Value1 = 0
-        self.Value2 = 0
-        self.Value3 = 0
-        self.Value4 = 0
-        self.Value5 = 0
-        self.Value6 = 0
-        self.Value7 = 0
-        self.Value8 = 0
-        self.UserDataLen = 0
-        self.UserData = ''
-
-    def readData(self, buf, pos = 0, length = 0):
-        if not pos <= length:
-            msg = error.formatMsg('error', error.ERROR_NO_148, '(pos = %s) > (length = %s)'%(pos, length))
-            mylog.error(msg)
-            return -1
-        if len(buf) < pos + self.getLength():
-            msg = error.formatMsg('error', error.ERROR_NO_149, 'len = %s while %s expected!'%(len(buf) - pos, self.getLength()))
-            mylog.error(msg)
-        self.clear()
-        self.RecType, pos = CommFunc.ReadWORD(buf, pos)
-        self.RecID, pos = CommFunc.ReadDWORD(buf, pos)
-        self.Time, pos = CommFunc.ReadDouble(buf, pos)
-        self.Value1, pos = CommFunc.ReadDWORD(buf, pos)
-        self.Value2, pos = CommFunc.ReadDWORD(buf, pos)
-        self.Value3, pos = CommFunc.ReadDWORD(buf, pos)
-        self.Value4, pos = CommFunc.ReadDWORD(buf, pos)
-        self.Value5, pos = CommFunc.ReadDWORD(buf, pos)
-        self.Value6, pos = CommFunc.ReadDWORD(buf, pos)
-        self.Value7, pos = CommFunc.ReadDWORD(buf, pos)
-        self.Value8, pos = CommFunc.ReadDWORD(buf, pos)
-        self.UserDataLen, pos = CommFunc.ReadWORD(buf, pos)
-        tmp, pos = CommFunc.ReadString(buf, pos, self.UserDataLen)
-        self.UserData = ctypes.c_char_p(tmp)
-        return self.getLength()
-
-    def getBuffer(self):
-        buf = ''
-        buf = CommFunc.WriteWORD(buf, self.RecType)
-        buf = CommFunc.WriteDWORD(buf, self.RecID)
-        buf = CommFunc.WriteDouble(buf, self.Time)
-        buf = CommFunc.WriteDWORD(buf, self.Value1)
-        buf = CommFunc.WriteDWORD(buf, self.Value2)
-        buf = CommFunc.WriteDWORD(buf, self.Value3)
-        buf = CommFunc.WriteDWORD(buf, self.Value4)
-        buf = CommFunc.WriteDWORD(buf, self.Value5)
-        buf = CommFunc.WriteDWORD(buf, self.Value6)
-        buf = CommFunc.WriteDWORD(buf, self.Value7)
-        buf = CommFunc.WriteDWORD(buf, self.Value8)
-        buf = CommFunc.WriteWORD(buf, self.UserDataLen)
-        buf = CommFunc.WriteString(buf, self.UserDataLen, self.UserData)
-        return buf
-
-    def getLength(self):
-        length = 0
-        length += sizeof(ctypes.c_ushort)
-        length += sizeof(ctypes.c_ulong)
-        length += sizeof(ctypes.c_double)
-        length += sizeof(ctypes.c_ulong)
-        length += sizeof(ctypes.c_ulong)
-        length += sizeof(ctypes.c_ulong)
-        length += sizeof(ctypes.c_ulong)
-        length += sizeof(ctypes.c_ulong)
-        length += sizeof(ctypes.c_ulong)
-        length += sizeof(ctypes.c_ulong)
-        length += sizeof(ctypes.c_ulong)
-        length += sizeof(ctypes.c_ushort)
-        length += self.UserDataLen
-        return length
-
-    def getRecord(self):
-        '''组织存储记录'''
-        rec = {}
-        rec[u'RecType'] = self.RecType
-        rec[u'RecID'] = self.RecID
-        rec[u'Time'] = self.Time
-        rec[u'Value1'] = self.Value1
-        rec[u'Value2'] = self.Value2
-        rec[u'Value3'] = self.Value3
-        rec[u'Value4'] = self.Value4
-        rec[u'Value5'] = self.Value5
-        rec[u'Value6'] = self.Value6
-        rec[u'Value7'] = self.Value7
-        rec[u'Value8'] = self.Value8
-        rec[u'UserDataLen'] = self.UserDataLen
-        rec[u'UserData'] = fix_incomingText(self.UserData)
-        return rec
-
-    def readRecord(self, rec):
-        '''由于MongoDB读出来是unicode,所有字符串需要进行转换'''
-        self.RecType = rec.get(u'RecType', 0)
-        self.RecID = rec.get(u'RecID', 0)
-        self.Time = rec.get(u'Time', 0)
-        self.Value1 = rec.get(u'Value1', 0)
-        self.Value2 = rec.get(u'Value2', 0)
-        self.Value3 = rec.get(u'Value3', 0)
-        self.Value4 = rec.get(u'Value4', 0)
-        self.Value5 = rec.get(u'Value5', 0)
-        self.Value6 = rec.get(u'Value6', 0)
-        self.Value7 = rec.get(u'Value7', 0)
-        self.Value8 = rec.get(u'Value8', 0)
-        self.UserDataLen = rec.get(u'UserDataLen', 0)
-        self.UserData = fix_outgoingText(rec.get(u'UserData', u''))
-
-#Can not implement adoLoadStr method:No key defined!
-#Can not implement adoInsertStr method:No key defined!
-#Can not implement adoUpdateStr method:No key defined!
-#Can not implement adoUpdateStr method:No key defined!
-#Can not implement adoCheckUpdateStr method:No key defined!
-#Can not implement adoCheckUpdateExStr method:No key defined!
-
-    def getAdoRecords(self, resultCollection):
-        '''查询结果打包成二进制流'''
-        result = ''
-        result = CommFunc.WriteDWORD(result, resultCollection.count())
-        for rec in resultCollection:
-            self.readRecord(rec)
-            result += self.getBuffer()
-        return result
-
-#Can not implement adoQueryIndexStr method:No key defined!
-
-    def adoQueryCustom(self, collection, queryDict):
-        '''自定义查询'''
-        resultCollection = collection.find(queryDict)
-
-        return self.getAdoRecords(resultCollection)
-
-
-    def adoQueryAll(self, collection):
-        '''查询所有''' 
-        resultCollection = collection.find()
-         
-        return self.getAdoRecords(resultCollection)
-
-#Can not implement adoDeleteByIndexStr method:No key defined!
-    def outputString(self):
-        output = '''// 通用记录表新 #tagDBGameRec:
-            RecType = %s,
-            RecID = %s,
-            Time = %s,
-            Value1 = %s,
-            Value2 = %s,
-            Value3 = %s,
-            Value4 = %s,
-            Value5 = %s,
-            Value6 = %s,
-            Value7 = %s,
-            Value8 = %s,
-            UserDataLen = %s,
-            UserData = %s,
-            ADOResult = %s,
-            '''%(
-                self.RecType,
-                self.RecID,
-                self.Time,
-                self.Value1,
-                self.Value2,
-                self.Value3,
-                self.Value4,
-                self.Value5,
-                self.Value6,
-                self.Value7,
-                self.Value8,
-                self.UserDataLen,
-                self.UserData,
-                self.ADOResult,
-            )
-        return output
-
-    def dumpString(self):
-        output = '''%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s'''%(
-                self.RecType,
-                self.RecID,
-                self.Time,
-                self.Value1,
-                self.Value2,
-                self.Value3,
-                self.Value4,
-                self.Value5,
-                self.Value6,
-                self.Value7,
-                self.Value8,
-                self.UserDataLen,
-                self.UserData,
-            )
-        return output
 
 
 # 功能队伍表 #tagDBFuncTeam

--
Gitblit v1.8.0