16 卡牌服务端（优化开关服：公共数据备档、db加载、入库逻辑；删除无用公共数据表；）

hxp

2025-05-21 3f0b93755905cef314b40b1800920b352a6c7634

16 卡牌服务端（优化开关服：公共数据备档、db加载、入库逻辑；删除无用公共数据表；）

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

@@ -2593,6 +2593,7 @@
#玩家时间的记录格式

TYPE_Time_Format = "%Y-%m-%d %H:%M:%S"

TYPE_Time_Format_Day = "%Y-%m-%d"

TYPE_Time_Format_YmdHMS = "%Y%m%d%H%M%S"

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



#无限封存时间(10年)


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

@@ -29,6 +29,7 @@
import binascii

import GameWorld

import traceback

import shutil

import zlib

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

#全局变量

@@ -414,6 +415,16 @@
        

    return data



def DelFolder(path, makeDir=False):

    ## 删除文件夹

    if os.path.exists(path):

        # 删除整个目录（包括自身）

        shutil.rmtree(path)

        if makeDir:

            # 重新创建空目录（保留原目录名）

            os.makedirs(path)

    return



#提示除零错误的EVAL

## 

#  @param 参数


 ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/DB/DBDataMgr.py

@@ -16,10 +16,13 @@
#-------------------------------------------------------------------------------



import CommFunc

import DBStruct

import ChConfig

import GameWorld

import PyGameData

import DBEventTrig

import PyMongoMain

import DBPlayerViewCache

import DBEventTrig

import DBBillboard

import DBFamily

import DBMail

@@ -28,43 +31,56 @@
import os



BakRoot = "C:\ServerRealTimeBackup"

BakFileType = ".bak"

BackupCopyMax = 3

BakFileType = ".rtb"

BackupCopyMax = 5 # 保留历史备档文件数

BackupInterval = 30 # 备档频率，分钟，暂定每30分钟



g_loadErr = False

    
def OnServerStart():

    ##启动服务器数据处理

    GameWorld.DebugLog("地图服务器启动")

    LoadServerDataBackup()

    if not LoadGameWorldDataFromBackup():

        LoadGameWorldDataFromDB()

    return



def OnServerClose():

    ##关服服务器数据处理

    SaveGameWorldDataToDB()

    return



def OnMinute(curTime):

    #curMinute = curTime.minute

    ServerDataBackup()

    if PyGameData.g_serverClosing:

        return

    DBFamily.OnMinute()

    DBBillboard.OnMinute()

    
    #备档、入库放最后，等数据都处理完后再保存，每天 [[时,分], ...]，尽量岔开整点、5分

    if [curTime.hour, curTime.minute] in [[3, 6]]:

        BackupGameWorldData(True)

    else:

        BackupGameWorldData(False)

    return



#------------------------------------------- 备档 ---------------------------------------------------

def GetBakFileSortList(bakPath):

    ## 按备档时间倒序排序返回 [[bakTime, filePath], ...]

    ## 按备档时间倒序排序返回 [[bakTime, 数据版本号, filePath], ...]

    bakFileList = []

    for parent, _, filenames in os.walk(bakPath):

        for filename in filenames:

            if not filename.endswith(BakFileType):

                continue

            fullPath = os.path.join(parent, filename)

            bakTime = GameWorld.ToIntDef(filename[:filename.index(".")].split("_")[1])

            bakFileList.append([bakTime, fullPath])

            bakInfo = filename[:filename.index(".")].split("_")

            if len(bakInfo) != 3:

                continue

            dataVersionNO = GameWorld.ToIntDef(bakInfo[1]) # 数据版本号

            bakTime = GameWorld.ToIntDef(bakInfo[2]) # yyyyMMddhhmmss

            bakFileList.append([bakTime, dataVersionNO, fullPath])

    bakFileList.sort(reverse=True)

    return bakFileList



def LoadServerDataBackup():

    ## 服务器公共数据备档加载

    global g_loadErr

def LoadGameWorldDataFromBackup():

    ## 备档加载服务器公共数据

    # @return: 是否存在备档成功加载

    serverID = GameWorld.GetGameWorld().GetServerID()

    serverName = "S%s" % serverID

    BakDir = os.path.join(BakRoot, serverName)

@@ -73,26 +89,42 @@
    if not bakFileList:

        GameWorld.Log("不存在备档!")

        return

    bakFilePath = bakFileList[0][1] # 取第一个为最近的一次备档

    finalBakInfo = bakFileList[0] # 排序后的第一个为最新备档数据

    bakVersionNO = finalBakInfo[1]

    bakFilePath = finalBakInfo[2]

    if bakVersionNO != DBStruct.GAMEWORLD_DATA_VERSION_NO:

        GameWorld.ErrLog("备档数据版本号校验失败，请使用正确版本服务器启动重新导入数据! bakVersionNO=%s, GAMEWORLD_DATA_VERSION_NO=%s" 
                         % (bakVersionNO, DBStruct.GAMEWORLD_DATA_VERSION_NO))

        raise

    
    GameWorld.Log("读取备档: %s" % bakFilePath)

    

    f = open(bakFilePath, 'rb')

    compressed_data = f.read()

    f.close()

    

    bakData = CommFunc.Decompress(compressed_data)

    if not bakData:

        g_loadErr = True

        raise 
    saveData = CommFunc.Decompress(compressed_data)

    if not saveData:

        raise

    

    LoadPyGameData(bakData, 0)

    return

    LoadPyGameData(saveData, 0)

    SaveGameWorldDataToDB(saveData) # 如果是从备档读取的则直接入库

    return True



def ServerDataBackup():

def BackupGameWorldData(saveToDB=False):

    ## 服务器公共数据定时备档，暂时直接存盘

    if g_loadErr:

        GameWorld.ErrLog("加载备档已异常，暂时不再存储备档，防止已经错误加载的数据覆盖")

    # @param saveToDB: 是否附带入库，为确保备档数据存在时一定优于db库数据，故常规入库时必须附带先备档一次

    if PyGameData.g_serverClosing:

        return

    if not PyGameData.g_loadDataOK:

        GameWorld.Log("加载数据未完成，不存储备档")

        return

    curTime = int(time.time())

    if saveToDB:

        if curTime - PyGameData.g_lastRTBTime < BackupInterval * 60:

            GameWorld.Log("备档冷却中!")

            return

    
    serverID = GameWorld.GetGameWorld().GetServerID()

    serverName = "S%s" % serverID

    BakDir = os.path.join(BakRoot, serverName)

@@ -101,11 +133,12 @@
    if not os.path.exists(BakDir):

        os.makedirs(BakDir)

        

    curTime = int(time.time())

    bakFilePath = os.path.join(BakDir, "%s_%s%s" % (serverName, curTime, BakFileType))

    bakData = GetSavePyData()

    GameWorld.Log("Bak:%s, len=%s, %s" % (serverName, len(bakData), bakFilePath))

    compressed_data = CommFunc.Compress(bakData)

    dataVersionNO = DBStruct.GAMEWORLD_DATA_VERSION_NO

    bakTiemStr = GameWorld.ChangeTimeNumToStr(curTime, ChConfig.TYPE_Time_Format_YmdHMS)

    bakFilePath = os.path.join(BakDir, "%s_%s_%s%s" % (serverName, dataVersionNO, bakTiemStr, BakFileType))

    saveData = GetSavePyData()

    GameWorld.Log("Bak:%s, len=%s, %s" % (serverName, len(saveData), bakFilePath))

    compressed_data = CommFunc.Compress(saveData) # 备档数据才进行压缩

    if not compressed_data:

        GameWorld.SendGameError("ServerDataBackupError")

        return

@@ -118,15 +151,42 @@
    except:

        return

    

    PyGameData.g_lastRTBTime = curTime

    bakFileList = GetBakFileSortList(BakDir)

    # 删除多余备档

    for _, filePath in bakFileList[BackupCopyMax:]:

    for bakInfo in bakFileList[BackupCopyMax:]:

        filePath = bakInfo[-1]

        os.remove(filePath)

        GameWorld.Log("删除多余备档文件: %s" % filePath)

        

    if saveToDB:

        SaveGameWorldDataToDB(saveData)

    return



def ClearBackupFile():

    ## 清空备档文件

    serverID = GameWorld.GetGameWorld().GetServerID()

    serverName = "S%s" % serverID

    BakDir = os.path.join(BakRoot, serverName)

    GameWorld.Log("清空备档: %s" % BakDir)

    CommFunc.DelFolder(BakDir, True)

    return



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



def LoadGameWorldDataFromDB():

    ## 直接从db读取公共数据

    GameWorld.Log("没有备档数据，直接从db加载数据!")

    serverData = PyMongoMain.GetUserCtrlDB().readGameWorldData()

    LoadPyGameData(serverData, 0)

    return



def SaveGameWorldDataToDB(saveData=""):

    ## 公共数据入库

    if not saveData:

        saveData = GetSavePyData()

    PyMongoMain.GetUserCtrlDB().saveGameWorldData(saveData)

    return



def GetSavePyData():

    

@@ -146,33 +206,36 @@
    #加载数据后，一些功能转化为功能业务数据

    #...

    

    
    #放最后

    PyGameData.g_loadDataOK = True

    return pos



class PyGameDataManager(object):

    def __init__(self):

        self.EventTrigMgr = DBEventTrig.EventTrigMgr()

        self.PlayerViewCacheMgr = DBPlayerViewCache.PlayerViewCacheMgr()

        self.FamilyMgr = DBFamily.FamilyMgr()

        self.MailMgr = DBMail.MailMgr()

        self.BillboardMgr = DBBillboard.BillboardMgr()

        self.MailMgr = DBMail.MailMgr()

        self.FamilyMgr = DBFamily.FamilyMgr()

        return

    

    def GetSaveData(self):

        buff = ""

        buff += self.EventTrigMgr.GetSaveData()

        buff += self.PlayerViewCacheMgr.GetSaveData()

        buff += self.FamilyMgr.GetSaveData()

        buff += self.MailMgr.GetSaveData()

        buff += self.BillboardMgr.GetSaveData()

        buff += self.MailMgr.GetSaveData()

        buff += self.FamilyMgr.GetSaveData()

        return buff

    

    def LoadGameData(self, gameBuffer, pos):

        dataslen = len(gameBuffer)

        pos = self.EventTrigMgr.LoadPyGameData(gameBuffer, pos, dataslen)

        pos = self.PlayerViewCacheMgr.LoadPyGameData(gameBuffer, pos, dataslen)

        pos = self.FamilyMgr.LoadPyGameData(gameBuffer, pos, dataslen)

        pos = self.MailMgr.LoadPyGameData(gameBuffer, pos, dataslen)

        pos = self.BillboardMgr.LoadPyGameData(gameBuffer, pos, dataslen)

        pos = self.MailMgr.LoadPyGameData(gameBuffer, pos, dataslen)

        pos = self.FamilyMgr.LoadPyGameData(gameBuffer, pos, dataslen)

        return pos

    

def GetDBDataMgr():


 ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/DB/DBStruct.py

@@ -10,6 +10,7 @@
# @version 1.0

#

# 详细描述: CodeMaker PyGameServerSaveData.py生成

# 注： 修改表结构、增删表时需同步修改 GAMEWORLD_DATA_VERSION_NO

#

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

#"""Version = 2025-05-09 12:20"""

@@ -1897,3 +1898,11 @@
        else:

            self.Name2 = Str[:65]

            



#服务器世界数据表版本号

GAMEWORLD_DATA_VERSION_NO = ctypes.c_ulong (\

    sizeof(tagDBEventTrig) + sizeof(tagDBFamily) + sizeof(tagDBFamilyMem) + sizeof(tagDBFamilyAction) + 
    sizeof(tagDBPlayerViewCache) + sizeof(tagDBMailPersonal) + sizeof(tagDBMailServer) + sizeof(tagDBMailItem) + 
    sizeof(tagDBMailPlayerRec) + sizeof(tagDBBillboard) 
    ).value

    

 ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/GameWorldLogic/GameWorldEvent.py

@@ -18,11 +18,13 @@
import DBDataMgr

import GameWorld

import IpyGameDataPY

import IPY_GameWorld

import PlayerEventCounter

import PlayerControl

import NetPackCommon

import ShareDefine

import PlayerTeam

import PyGameData

import NetPackCommon



import datetime

import time

@@ -231,6 +233,11 @@
    if tick - PyGameData.g_highProcessTick < 1000:

        return

    PyGameData.g_highProcessTick = tick

    
    if PyGameData.g_serverClosing:

        CheckCloseMapOK()

        return

    
    OnMinute(tick)

    

    # 其他逻辑

@@ -367,15 +374,43 @@


# 关闭地图通知py处理

def CloseMap(tick):

    serverID = GameWorld.GetGameWorld().GetServerID()

    GameWorld.Log("地图服务器关闭开始保存数据! serverID=%s" % serverID)

    PyGameData.g_serverClosing = 1

    
    playerManager = GameWorld.GetPlayerManager()

    for i in xrange(playerManager.GetPlayerCount()):

        curPlayer = playerManager.GetPlayerByIndex(i)

        if not curPlayer or curPlayer.GetID() == 0 or curPlayer.IsEmpty():

            continue

        
        #镜像玩家回收、真实玩家踢下线

        if GameWorld.IsMirrorPlayer(curPlayer):

            PlayerControl.DeleteMirror(curPlayer)

        else:

            curPlayer.Kick(IPY_GameWorld.disMapServerClose)

            
    DBDataMgr.OnServerClose()

    return



def CheckCloseMapOK():

    '''检查等待关服数据处理完毕

    没有玩家了，且公共数据已入库完毕

    '''

    if PyGameData.g_serverClosing != 1:

        return

    if not PyGameData.g_closeSaveDataOK:

        return

    if GameWorld.GetPlayerManager().OnlineCount():

        return

    DBDataMgr.ClearBackupFile() # 正常关服数据处理完毕可直接删除备档

    
    from PyMongoDB.DBCommon import CommonDefine

    from PyMongoDB.Common import CommFunc

    #初始化数据库, 恢复备档（按区服记录）， 加载静态表

    try:

        pass

    finally:

        #回发地图 处理完成,必须被调用地图才能正常关闭

        data = ''

        data = CommFunc.WriteBYTE(data, CommonDefine.dgPlayerSaveGameServerData)  
        NetPackCommon.SendPyPackToMapServerSelf(data, len(data))

        GameWorld.Log("python 已处理地图关闭逻辑")

    return
    data = ''

    data = CommFunc.WriteBYTE(data, CommonDefine.dgPlayerSaveGameServerData)  
    NetPackCommon.SendPyPackToMapServerSelf(data, len(data))

    GameWorld.Log("python 已处理地图关闭逻辑")

    PyGameData.g_serverClosing = 2

    return

    

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

@@ -15,10 +15,14 @@
#"""Version = 2017-09-05 21:30"""

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



g_loadDataOK = False # 是否成功加载数据，备档、db数据

g_lastRTBTime = 0 # 上一次备档时间戳

g_initGameTime = 0 # 开始初始化服务器时间戳

g_serverInitOK = False # 服务器是否启动成功

g_highProcessTick = 0 # 每秒触发一次，上次Tick

g_minuteProcess = -1 # 每分钟触发一次，上次处理的分钟

g_serverClosing = 0 # 是否关服中 0-非关服中；1-关服中；2-关服结束

g_closeSaveDataOK = False # 关服数据入库是否成功



g_pyGameDataManager = None




 ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/PyMongoDB/Collections/CollectionDefine.py

@@ -4,6 +4,19 @@
#

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

#

#卡牌服务器表

UCN_DBFamilyAction="tagDBFamilyAction"

UCN_DBFamilyMem="tagDBFamilyMem"

UCN_DBFamily="tagDBFamily"

UCN_DBMailItem="tagDBMailItem"

UCN_DBMailPersonal="tagDBMailPersonal"

UCN_DBMailPlayerRec="tagDBMailPlayerRec"

UCN_DBMailServer="tagDBMailServer"

UCN_DBBillboard="tagDBBillboard"

UCN_DBPlayerViewCache="tagDBPlayerViewCache"

UCN_DBEventTrig="tagDBEventTrig"



#MMO旧表

UCN_DBPlayerPackData="tagDBPlayerPackData"

UCN_DBGameRec="tagDBGameRec"

UCN_DBPyFuncTeam="tagDBPyFuncTeam"

@@ -45,7 +58,6 @@
UCN_BattleFormation="tagBattleFormation"

UCN_AccCoins="tagAccCoins"

UCN_AccIDSendPrize="tagAccIDSendPrize"

UCN_DBBillboard="tagDBBillboard"

UCN_DBCountryFamilyWarRace="tagDBCountryFamilyWarRace"

UCN_DBCountryFamilyWarRequest="tagDBCountryFamilyWarRequest"

UCN_DBCountryFamilyWarResult="tagDBCountryFamilyWarResult"

@@ -87,7 +99,6 @@
UCN_DBPlayer="tagDBPlayer"

UCN_DSAccount="tagDSAccount"

UCN_RoleItem="tagRoleItem"

UCN_DBFamilyAction="tagDBFamilyAction"

UCN_GameFBPassRec="tagGameFBPassRec"

UCN_UniversalGameRec="tagUniversalGameRec"

UCN_DBNewGuyCardState="tagDBNewGuyCardState"


 ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/PyMongoDB/Collections/DataServerPlayerData.py

@@ -5369,415 +5369,6 @@




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

#排行榜#tagDBBillboard

class tagDBBillboard(Structure):

    _pack_ = 1

    _fields_ = [

        ('Type', ctypes.c_ubyte),

        ('ID', ctypes.c_ulong),

        ('ID2', ctypes.c_ulong),

        ('Name1', ctypes.c_char * 33),

        ('Name2', ctypes.c_char * 65),

        ('Type2', ctypes.c_ubyte),

        ('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),

        ('CmpValue', ctypes.c_ulong),

        ('CmpValue2', ctypes.c_ulong),

        ('CmpValue3', ctypes.c_ulong),

        ('DataLen', ctypes.c_ushort),

        ('UserData', ctypes.c_char_p),

        ('ADOResult', ctypes.c_ulong),

    ]



    def __init__(self):

        Structure.__init__(self)

        self.clear()



    def clear(self):

        self.Type = 0

        self.ID = 0

        self.ID2 = 0

        self.Name1 = ''

        self.Name2 = ''

        self.Type2 = 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.CmpValue = 0

        self.CmpValue2 = 0

        self.CmpValue3 = 0

        self.DataLen = 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.Type, pos = CommFunc.ReadBYTE(buf, pos)

        self.ID, pos = CommFunc.ReadDWORD(buf, pos)

        self.ID2, pos = CommFunc.ReadDWORD(buf, pos)

        self.Name1, pos = CommFunc.ReadString(buf, pos, 33)

        self.Name2, pos = CommFunc.ReadString(buf, pos, 65)

        self.Type2, pos = CommFunc.ReadBYTE(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.CmpValue, pos = CommFunc.ReadDWORD(buf, pos)

        self.CmpValue2, pos = CommFunc.ReadDWORD(buf, pos)

        self.CmpValue3, 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)

        return self.getLength()



    def getBuffer(self):

        buf = ''

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

        buf = CommFunc.WriteDWORD(buf, self.ID)

        buf = CommFunc.WriteDWORD(buf, self.ID2)

        buf = CommFunc.WriteString(buf, sizeof(ctypes.c_char) * 33, self.Name1)

        buf = CommFunc.WriteString(buf, sizeof(ctypes.c_char) * 65, self.Name2)

        buf = CommFunc.WriteBYTE(buf, self.Type2)

        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.WriteDWORD(buf, self.CmpValue)

        buf = CommFunc.WriteDWORD(buf, self.CmpValue2)

        buf = CommFunc.WriteDWORD(buf, self.CmpValue3)

        buf = CommFunc.WriteWORD(buf, self.DataLen)

        buf = CommFunc.WriteString(buf, self.DataLen, self.UserData)

        return buf



    def getLength(self):

        length = 0

        length += sizeof(ctypes.c_ubyte)

        length += sizeof(ctypes.c_ulong)

        length += sizeof(ctypes.c_ulong)

        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)

        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.DataLen

        return length



    def getRecord(self):

        '''组织存储记录'''

        rec = {}

        rec[u'Type'] = self.Type

        rec[u'ID'] = self.ID

        rec[u'ID2'] = self.ID2

        rec[u'Name1'] = fix_incomingText(self.Name1)

        rec[u'Name2'] = fix_incomingText(self.Name2)

        rec[u'Type2'] = self.Type2

        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'CmpValue'] = self.CmpValue

        rec[u'CmpValue2'] = self.CmpValue2

        rec[u'CmpValue3'] = self.CmpValue3

        rec[u'DataLen'] = self.DataLen

        rec[u'UserData'] = fix_incomingText(self.UserData)

        return rec



    def readRecord(self, rec):

        '''由于MongoDB读出来是unicode,所有字符串需要进行转换'''

        self.Type = rec.get(u'Type', 0)

        self.ID = rec.get(u'ID', 0)

        self.ID2 = rec.get(u'ID2', 0)

        self.Name1 = fix_outgoingText(rec.get(u'Name1', u''))

        self.Name2 = fix_outgoingText(rec.get(u'Name2', u''))

        self.Type2 = rec.get(u'Type2', 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.CmpValue = rec.get(u'CmpValue', 0)

        self.CmpValue2 = rec.get(u'CmpValue2', 0)

        self.CmpValue3 = rec.get(u'CmpValue3', 0)

        self.DataLen = rec.get(u'DataLen', 0)

        self.UserData = fix_outgoingText(rec.get(u'UserData', u''))



    def adoLoad(self, collection):

        '''使用KEY查找并读取'''

        resultCollection = collection.find({'Type':self.Type,'ID':self.ID,})



        if resultCollection.count() <= 0:

            return False

        #由于是KEY查找，所有如果存在就只有一条记录

        rec = resultCollection[0]

        #读取数据

        self.readRecord(rec)

        return True





    def adoInsert(self, collection):

        '''执行插入'''



        trycnt = 0

        rec = self.getRecord()

        while(True):

            try:

                collection.insert(rec, False, True)

                break

            except pymongo.errors.OperationFailure, err:



                if(DBConfig.TryCntOnWriteFail > trycnt):

                    trycnt += 1

                    continue

                    
                addADOExceptionCount()

                mylog.info("%s.%s:rec = %s"%(self.__class__.__name__, inspect.stack()[0][3], rec))

                msg = error.formatMsg('error', error.ERROR_NO_152, 'Insert failed!Type = %s, error = %s, trycnt = %d'%(self.Type, err, trycnt))

                mylog.error(msg)



                return False

        return True





    def adoUpdate(self, collection):

        '''执行更新'''

        trycnt = 0

        rec = self.getRecord()

        while(True):

            try:

                collection.update({'Type':self.Type,'ID':self.ID,}, {'$set':rec}, False, False, True, True)

                break

            except pymongo.errors.OperationFailure, err:

                if(DBConfig.TryCntOnWriteFail > trycnt):

                    trycnt += 1

                    continue



                addADOExceptionCount()

                mylog.info("%s.%s:rec = %s"%(self.__class__.__name__, inspect.stack()[0][3], rec))

                msg = error.formatMsg('error', error.ERROR_NO_153, 'Update failed!Type = %s, error = %s, trycnt = %d'%(self.Type, err, trycnt))

                mylog.error(msg)



                return False

        return True





    def adoUpdateEx(self, collection, spec):

        '''执行更新'''

        trycnt = 0

        rec = self.getRecord()

        while(True):

            try:

                collection.update(spec, {'$set':rec}, False, False, True, True)

                break

            except pymongo.errors.OperationFailure, err:

                if(DBConfig.TryCntOnWriteFail > trycnt):

                    trycnt += 1

                    continue

                addADOExceptionCount()

                mylog.info("%s.%s:rec = %s"%(self.__class__.__name__, inspect.stack()[0][3], rec))

                msg = error.formatMsg('error', error.ERROR_NO_154, 'Update failed!Type = %s, error = %s, trycnt = %d'%(self.Type, err, trycnt))

                mylog.error(msg)



                return False

        return True





    def adoCheckUpdate(self, collection):

        '''根据情况执行插入或更新'''

        resultCollection = collection.find({'Type':self.Type,'ID':self.ID,})

         
        if resultCollection.count() <= 0:

            return self.adoInsert(collection)

        return self.adoUpdate(collection)





    def adoCheckUpdateEx(self, collection, spec):

        '''根据情况执行插入或更新'''

        resultCollection = collection.find(spec)

         
        if resultCollection.count() <= 0:

            return self.adoInsert(collection)

        return self.adoUpdateEx(collection, spec)





    def getAdoRecords(self, resultCollection):

        '''查询结果打包成二进制流'''

        result = ''

        result = CommFunc.WriteDWORD(result, resultCollection.count())

        for rec in resultCollection:

            self.readRecord(rec)

            result += self.getBuffer()

        return result





    def adoQueryIndex(self, collection):

        '''用索引字段查找'''

        resultCollection = collection.find({'Type':self.Type})

         
        return self.getAdoRecords(resultCollection)





    def adoQueryCustom(self, collection, queryDict):

        '''自定义查询'''

        resultCollection = collection.find(queryDict)



        return self.getAdoRecords(resultCollection)





    def adoQueryAll(self, collection):

        '''查询所有''' 
        resultCollection = collection.find()

         
        return self.getAdoRecords(resultCollection)





    def adoDeleteByIndex(self, collection):

        '''根据索引删除'''

        trycnt = 0

        while(True):

            try:

                collection.remove({'Type':self.Type})

                break

            except pymongo.errors.OperationFailure, err:

                if(DBConfig.TryCntOnWriteFail > trycnt):

                    trycnt += 1

                    continue

                addADOExceptionCount()

                mylog.info("%s.%s:Type = %s"%(self.__class__.__name__, inspect.stack()[0][3], self.Type))

                msg = error.formatMsg('error', error.ERROR_NO_155, 'delete failure!self.Type = %s, error = %s, trycnt = %d'%(self.Type, err, trycnt))

                mylog.error(msg)



                return False

        return True



    def outputString(self):

        output = '''//排行榜#tagDBBillboard:

            Type = %s,

            ID = %s,

            ID2 = %s,

            Name1 = %s,

            Name2 = %s,

            Type2 = %s,

            Value1 = %s,

            Value2 = %s,

            Value3 = %s,

            Value4 = %s,

            Value5 = %s,

            Value6 = %s,

            Value7 = %s,

            Value8 = %s,

            CmpValue = %s,

            CmpValue2 = %s,

            CmpValue3 = %s,

            DataLen = %s,

            UserData = %s,

            ADOResult = %s,

            '''%(

                self.Type,

                self.ID,

                self.ID2,

                self.Name1,

                self.Name2,

                self.Type2,

                self.Value1,

                self.Value2,

                self.Value3,

                self.Value4,

                self.Value5,

                self.Value6,

                self.Value7,

                self.Value8,

                self.CmpValue,

                self.CmpValue2,

                self.CmpValue3,

                self.DataLen,

                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\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s'''%(

                self.Type,

                self.ID,

                self.ID2,

                self.Name1,

                self.Name2,

                self.Type2,

                self.Value1,

                self.Value2,

                self.Value3,

                self.Value4,

                self.Value5,

                self.Value6,

                self.Value7,

                self.Value8,

                self.CmpValue,

                self.CmpValue2,

                self.CmpValue3,

                self.DataLen,

                self.UserData,

            )

        return output



    #Char数组类型Set接口,使用该接口对此类型数据赋值，防止赋值的数据过长报错

    def SetName1(self,Str):

        if len(Str)<=33:

            self.Name1 = Str

        else:

            self.Name1 = Str[:33]

            
    def SetName2(self,Str):

        if len(Str)<=65:

            self.Name2 = Str

        else:

            self.Name2 = Str[:65]

            






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

#国家家族战排位赛表#tagDBCountryFamilyWarRace

class tagDBCountryFamilyWarRace(Structure):

    _pack_ = 1

@@ -6676,288 +6267,7 @@
        else:

            self.KingName = Str[:33]         



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

#家族行为表#tagDBFamilyAction

class tagDBFamilyAction(Structure):

    _pack_ = 1

    _fields_ = [

        ('FamilyID', ctypes.c_ulong),

        ('ActionType', ctypes.c_ubyte),

        ('Name', ctypes.c_char * 33),

        ('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),

        ('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.FamilyID = 0

        self.ActionType = 0

        self.Name = ''

        self.Time = 0.0

        self.Value1 = 0

        self.Value2 = 0

        self.Value3 = 0

        self.Value4 = 0

        self.Value5 = 0

        self.Value6 = 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.FamilyID, pos = CommFunc.ReadDWORD(buf, pos)

        self.ActionType, pos = CommFunc.ReadBYTE(buf, pos)

        self.Name, pos = CommFunc.ReadString(buf, pos, 33)

        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.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.FamilyID)

        buf = CommFunc.WriteBYTE(buf, self.ActionType)

        buf = CommFunc.WriteString(buf, sizeof(ctypes.c_char) * 33, self.Name)

        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.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_ubyte)

        length += sizeof(ctypes.c_char) * 33

        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_ushort)

        length += self.DataLen

        return length



    def getRecord(self):

        '''组织存储记录'''

        rec = {}

        rec[u'FamilyID'] = self.FamilyID

        rec[u'ActionType'] = self.ActionType

        rec[u'Name'] = fix_incomingText(self.Name)

        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'DataLen'] = self.DataLen

        rec[u'Data'] = fix_incomingText(self.Data)

        return rec



    def readRecord(self, rec):

        '''由于MongoDB读出来是unicode,所有字符串需要进行转换'''

        self.FamilyID = rec.get(u'FamilyID', 0)

        self.ActionType = rec.get(u'ActionType', 0)

        self.Name = fix_outgoingText(rec.get(u'Name', u''))

        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.DataLen = rec.get(u'DataLen', 0)

        self.Data = fix_outgoingText(rec.get(u'Data', u''))



#Can not implement adoLoadStr method:No key defined!



    def adoInsert(self, collection):

        '''执行插入'''



        trycnt = 0

        rec = self.getRecord()

        while(True):

            try:

                collection.insert(rec, False, True)

                break

            except pymongo.errors.OperationFailure, err:



                if(DBConfig.TryCntOnWriteFail > trycnt):

                    trycnt += 1

                    continue

                    
                addADOExceptionCount()

                mylog.info("%s.%s:rec = %s"%(self.__class__.__name__, inspect.stack()[0][3], rec))

                msg = error.formatMsg('error', error.ERROR_NO_152, 'Insert failed!FamilyID = %s, error = %s, trycnt = %d'%(self.FamilyID, err, trycnt))

                mylog.error(msg)



                return False

        return True



#Can not implement adoUpdateStr method:No key defined!



    def adoUpdateEx(self, collection, spec):

        '''执行更新'''

        trycnt = 0

        rec = self.getRecord()

        while(True):

            try:

                collection.update(spec, {'$set':rec}, False, False, True, True)

                break

            except pymongo.errors.OperationFailure, err:

                if(DBConfig.TryCntOnWriteFail > trycnt):

                    trycnt += 1

                    continue

                addADOExceptionCount()

                mylog.info("%s.%s:rec = %s"%(self.__class__.__name__, inspect.stack()[0][3], rec))

                msg = error.formatMsg('error', error.ERROR_NO_154, 'Update failed!FamilyID = %s, error = %s, trycnt = %d'%(self.FamilyID, err, trycnt))

                mylog.error(msg)



                return False

        return True



#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





    def adoQueryIndex(self, collection):

        '''用索引字段查找'''

        resultCollection = collection.find({'FamilyID':self.FamilyID})

         
        return self.getAdoRecords(resultCollection)





    def adoQueryCustom(self, collection, queryDict):

        '''自定义查询'''

        resultCollection = collection.find(queryDict)



        return self.getAdoRecords(resultCollection)





    def adoQueryAll(self, collection):

        '''查询所有''' 
        resultCollection = collection.find()

         
        return self.getAdoRecords(resultCollection)





    def adoDeleteByIndex(self, collection):

        '''根据索引删除'''

        trycnt = 0

        while(True):

            try:

                collection.remove({'FamilyID':self.FamilyID})

                break

            except pymongo.errors.OperationFailure, err:

                if(DBConfig.TryCntOnWriteFail > trycnt):

                    trycnt += 1

                    continue

                addADOExceptionCount()

                mylog.info("%s.%s:FamilyID = %s"%(self.__class__.__name__, inspect.stack()[0][3], self.FamilyID))

                msg = error.formatMsg('error', error.ERROR_NO_155, 'delete failure!self.FamilyID = %s, error = %s, trycnt = %d'%(self.FamilyID, err, trycnt))

                mylog.error(msg)



                return False

        return True



    def outputString(self):

        output = '''//家族行为表#tagDBFamilyAction:

            FamilyID = %s,

            ActionType = %s,

            Name = %s,

            Time = %s,

            Value1 = %s,

            Value2 = %s,

            Value3 = %s,

            Value4 = %s,

            Value5 = %s,

            Value6 = %s,

            DataLen = %s,

            Data = %s,

            ADOResult = %s,

            '''%(

                self.FamilyID,

                self.ActionType,

                self.Name,

                self.Time,

                self.Value1,

                self.Value2,

                self.Value3,

                self.Value4,

                self.Value5,

                self.Value6,

                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\t%1s\t%1s\t%1s\t%1s\t%1s'''%(

                self.FamilyID,

                self.ActionType,

                self.Name,

                self.Time,

                self.Value1,

                self.Value2,

                self.Value3,

                self.Value4,

                self.Value5,

                self.Value6,

                self.DataLen,

                self.Data,

            )

        return output



    #Char数组类型Set接口,使用该接口对此类型数据赋值，防止赋值的数据过长报错

    def SetName(self,Str):

        if len(Str)<=33:

            self.Name = Str

        else:

            self.Name = Str[:33]

            


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

#帮会科技表#tagDBFamilyTech

@@ -26851,3 +26161,2539 @@
            )

        return output



# 事件触发表 #tagDBEventTrig

class tagDBEventTrig(Structure):

    _pack_ = 1

    _fields_ = [

        ('EventLen', ctypes.c_ulong),

        ('EventID', ctypes.c_char_p),

        ('EventValue', ctypes.c_ulong),

        ('ADOResult', ctypes.c_ulong),

    ]



    def __init__(self):

        Structure.__init__(self)

        self.clear()



    def clear(self):

        self.EventLen = 0

        self.EventID = ''

        self.EventValue = 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.EventLen, pos = CommFunc.ReadDWORD(buf, pos)

        tmp, pos = CommFunc.ReadString(buf, pos, self.EventLen)

        self.EventID = ctypes.c_char_p(tmp)

        self.EventValue, pos = CommFunc.ReadDWORD(buf, pos)

        return self.getLength()



    def getBuffer(self):

        buf = ''

        buf = CommFunc.WriteDWORD(buf, self.EventLen)

        buf = CommFunc.WriteString(buf, self.EventLen, self.EventID)

        buf = CommFunc.WriteDWORD(buf, self.EventValue)

        return buf



    def getLength(self):

        length = 0

        length += sizeof(ctypes.c_ulong)

        length += self.EventLen

        length += sizeof(ctypes.c_ulong)

        return length



    def getRecord(self):

        '''组织存储记录'''

        rec = {}

        rec[u'EventLen'] = self.EventLen

        rec[u'EventID'] = fix_incomingText(self.EventID)

        rec[u'EventValue'] = self.EventValue

        return rec



    def readRecord(self, rec):

        '''由于MongoDB读出来是unicode,所有字符串需要进行转换'''

        self.EventLen = rec.get(u'EventLen', 0)

        self.EventID = fix_outgoingText(rec.get(u'EventID', u''))

        self.EventValue = rec.get(u'EventValue', 0)



    def adoLoad(self, collection):

        '''使用KEY查找并读取'''

        resultCollection = collection.find({'EventID':fix_incomingText(self.EventID)})



        if resultCollection.count() <= 0:

            return False

        #由于是KEY查找，所有如果存在就只有一条记录

        rec = resultCollection[0]

        #读取数据

        self.readRecord(rec)

        return True





    def adoInsert(self, collection):

        '''执行插入'''



        trycnt = 0

        rec = self.getRecord()

        while(True):

            try:

                collection.insert(rec, False, True)

                break

            except pymongo.errors.OperationFailure, err:



                if(DBConfig.TryCntOnWriteFail > trycnt):

                    trycnt += 1

                    continue

                    
                addADOExceptionCount()

                mylog.info("%s.%s:rec = %s"%(self.__class__.__name__, inspect.stack()[0][3], rec))

                msg = error.formatMsg('error', error.ERROR_NO_152, 'Insert failed!EventID = %s, error = %s, trycnt = %d'%(self.EventID, err, trycnt))

                mylog.error(msg)



                return False

        return True





    def adoUpdate(self, collection):

        '''执行更新'''

        trycnt = 0

        rec = self.getRecord()

        while(True):

            try:

                collection.update({'EventID':fix_incomingText(self.EventID)}, {'$set':rec}, False, False, True, True)

                break

            except pymongo.errors.OperationFailure, err:

                if(DBConfig.TryCntOnWriteFail > trycnt):

                    trycnt += 1

                    continue



                addADOExceptionCount()

                mylog.info("%s.%s:rec = %s"%(self.__class__.__name__, inspect.stack()[0][3], rec))

                msg = error.formatMsg('error', error.ERROR_NO_153, 'Update failed!EventID = %s, error = %s, trycnt = %d'%(self.EventID, err, trycnt))

                mylog.error(msg)



                return False

        return True





    def adoUpdateEx(self, collection, spec):

        '''执行更新'''

        trycnt = 0

        rec = self.getRecord()

        while(True):

            try:

                collection.update(spec, {'$set':rec}, False, False, True, True)

                break

            except pymongo.errors.OperationFailure, err:

                if(DBConfig.TryCntOnWriteFail > trycnt):

                    trycnt += 1

                    continue

                addADOExceptionCount()

                mylog.info("%s.%s:rec = %s"%(self.__class__.__name__, inspect.stack()[0][3], rec))

                msg = error.formatMsg('error', error.ERROR_NO_154, 'Update failed!EventID = %s, error = %s, trycnt = %d'%(self.EventID, err, trycnt))

                mylog.error(msg)



                return False

        return True





    def adoCheckUpdate(self, collection):

        '''根据情况执行插入或更新'''

        resultCollection = collection.find({'EventID':fix_incomingText(self.EventID)})

         
        if resultCollection.count() <= 0:

            return self.adoInsert(collection)

        return self.adoUpdate(collection)





    def adoCheckUpdateEx(self, collection, spec):

        '''根据情况执行插入或更新'''

        resultCollection = collection.find(spec)

         
        if resultCollection.count() <= 0:

            return self.adoInsert(collection)

        return self.adoUpdateEx(collection, spec)





    def getAdoRecords(self, resultCollection):

        '''查询结果打包成二进制流'''

        result = ''

        result = CommFunc.WriteDWORD(result, resultCollection.count())

        for rec in resultCollection:

            self.readRecord(rec)

            result += self.getBuffer()

        return result





    def adoQueryIndex(self, collection):

        '''用索引字段查找'''

        resultCollection = collection.find({'EventID':fix_incomingText(self.EventID)})

         
        return self.getAdoRecords(resultCollection)





    def adoQueryCustom(self, collection, queryDict):

        '''自定义查询'''

        resultCollection = collection.find(queryDict)



        return self.getAdoRecords(resultCollection)





    def adoQueryAll(self, collection):

        '''查询所有''' 
        resultCollection = collection.find()

         
        return self.getAdoRecords(resultCollection)





    def adoDeleteByIndex(self, collection):

        '''根据索引删除'''

        trycnt = 0

        while(True):

            try:

                collection.remove({'EventID':fix_incomingText(self.EventID)})

                break

            except pymongo.errors.OperationFailure, err:

                if(DBConfig.TryCntOnWriteFail > trycnt):

                    trycnt += 1

                    continue

                addADOExceptionCount()

                mylog.info("%s.%s:EventID = %s"%(self.__class__.__name__, inspect.stack()[0][3], self.EventID))

                msg = error.formatMsg('error', error.ERROR_NO_155, 'delete failure!self.EventID = %s, error = %s, trycnt = %d'%(self.EventID, err, trycnt))

                mylog.error(msg)



                return False

        return True



    def outputString(self):

        output = '''// 事件触发表 #tagDBEventTrig:

            EventLen = %s,

            EventID = %s,

            EventValue = %s,

            ADOResult = %s,

            '''%(

                self.EventLen,

                self.EventID,

                self.EventValue,

                self.ADOResult,

            )

        return output



    def dumpString(self):

        output = '''%1s\t%1s\t%1s'''%(

                self.EventLen,

                self.EventID,

                self.EventValue,

            )

        return output





# 玩家查看缓存表 #tagDBPlayerViewCache

class tagDBPlayerViewCache(Structure):

    _pack_ = 1

    _fields_ = [

        ('PlayerID', ctypes.c_ulong),

        ('AccID', ctypes.c_char * 65),

        ('PlayerName', ctypes.c_char * 33),

        ('LV', ctypes.c_int),

        ('Job', ctypes.c_int),

        ('RealmLV', ctypes.c_ubyte),

        ('Face', ctypes.c_int),

        ('FacePic', ctypes.c_int),

        ('FamilyID', ctypes.c_ulong),

        ('FamilyName', ctypes.c_char * 33),

        ('FamilyEmblemID', ctypes.c_ushort),

        ('TitleID', ctypes.c_ulong),

        ('FightPower', ctypes.c_ulong),

        ('FightPowerEx', ctypes.c_ulong),

        ('ServerID', ctypes.c_ulong),

        ('OffTime', ctypes.c_ulong),

        ('PlusDataSize', ctypes.c_ulong),

        ('PlusData', ctypes.c_char_p),

        ('ADOResult', ctypes.c_ulong),

    ]



    def __init__(self):

        Structure.__init__(self)

        self.clear()



    def clear(self):

        self.PlayerID = 0

        self.AccID = ''

        self.PlayerName = ''

        self.LV = 0

        self.Job = 0

        self.RealmLV = 0

        self.Face = 0

        self.FacePic = 0

        self.FamilyID = 0

        self.FamilyName = ''

        self.FamilyEmblemID = 0

        self.TitleID = 0

        self.FightPower = 0

        self.FightPowerEx = 0

        self.ServerID = 0

        self.OffTime = 0

        self.PlusDataSize = 0

        self.PlusData = ''



    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.AccID, pos = CommFunc.ReadString(buf, pos, 65)

        self.PlayerName, pos = CommFunc.ReadString(buf, pos, 33)

        self.LV, pos = CommFunc.ReadDWORD(buf, pos)

        self.Job, pos = CommFunc.ReadDWORD(buf, pos)

        self.RealmLV, pos = CommFunc.ReadBYTE(buf, pos)

        self.Face, pos = CommFunc.ReadDWORD(buf, pos)

        self.FacePic, 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.TitleID, pos = CommFunc.ReadDWORD(buf, pos)

        self.FightPower, pos = CommFunc.ReadDWORD(buf, pos)

        self.FightPowerEx, pos = CommFunc.ReadDWORD(buf, pos)

        self.ServerID, pos = CommFunc.ReadDWORD(buf, pos)

        self.OffTime, pos = CommFunc.ReadDWORD(buf, pos)

        self.PlusDataSize, pos = CommFunc.ReadDWORD(buf, pos)

        tmp, pos = CommFunc.ReadString(buf, pos, self.PlusDataSize)

        self.PlusData = ctypes.c_char_p(tmp)

        return self.getLength()



    def getBuffer(self):

        buf = ''

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

        buf = CommFunc.WriteString(buf, sizeof(ctypes.c_char) * 65, self.AccID)

        buf = CommFunc.WriteString(buf, sizeof(ctypes.c_char) * 33, self.PlayerName)

        buf = CommFunc.WriteDWORD(buf, self.LV)

        buf = CommFunc.WriteDWORD(buf, self.Job)

        buf = CommFunc.WriteBYTE(buf, self.RealmLV)

        buf = CommFunc.WriteDWORD(buf, self.Face)

        buf = CommFunc.WriteDWORD(buf, self.FacePic)

        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.WriteDWORD(buf, self.TitleID)

        buf = CommFunc.WriteDWORD(buf, self.FightPower)

        buf = CommFunc.WriteDWORD(buf, self.FightPowerEx)

        buf = CommFunc.WriteDWORD(buf, self.ServerID)

        buf = CommFunc.WriteDWORD(buf, self.OffTime)

        buf = CommFunc.WriteDWORD(buf, self.PlusDataSize)

        buf = CommFunc.WriteString(buf, self.PlusDataSize, self.PlusData)

        return buf



    def getLength(self):

        length = 0

        length += sizeof(ctypes.c_ulong)

        length += sizeof(ctypes.c_char) * 65

        length += sizeof(ctypes.c_char) * 33

        length += sizeof(ctypes.c_int)

        length += sizeof(ctypes.c_int)

        length += sizeof(ctypes.c_ubyte)

        length += sizeof(ctypes.c_int)

        length += sizeof(ctypes.c_int)

        length += sizeof(ctypes.c_ulong)

        length += sizeof(ctypes.c_char) * 33

        length += sizeof(ctypes.c_ushort)

        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 += self.PlusDataSize

        return length



    def getRecord(self):

        '''组织存储记录'''

        rec = {}

        rec[u'PlayerID'] = self.PlayerID

        rec[u'AccID'] = fix_incomingText(self.AccID)

        rec[u'PlayerName'] = fix_incomingText(self.PlayerName)

        rec[u'LV'] = self.LV

        rec[u'Job'] = self.Job

        rec[u'RealmLV'] = self.RealmLV

        rec[u'Face'] = self.Face

        rec[u'FacePic'] = self.FacePic

        rec[u'FamilyID'] = self.FamilyID

        rec[u'FamilyName'] = fix_incomingText(self.FamilyName)

        rec[u'FamilyEmblemID'] = self.FamilyEmblemID

        rec[u'TitleID'] = self.TitleID

        rec[u'FightPower'] = self.FightPower

        rec[u'FightPowerEx'] = self.FightPowerEx

        rec[u'ServerID'] = self.ServerID

        rec[u'OffTime'] = self.OffTime

        rec[u'PlusDataSize'] = self.PlusDataSize

        rec[u'PlusData'] = fix_incomingText(self.PlusData)

        return rec



    def readRecord(self, rec):

        '''由于MongoDB读出来是unicode,所有字符串需要进行转换'''

        self.PlayerID = rec.get(u'PlayerID', 0)

        self.AccID = fix_outgoingText(rec.get(u'AccID', u''))

        self.PlayerName = fix_outgoingText(rec.get(u'PlayerName', u''))

        self.LV = rec.get(u'LV', 0)

        self.Job = rec.get(u'Job', 0)

        self.RealmLV = rec.get(u'RealmLV', 0)

        self.Face = rec.get(u'Face', 0)

        self.FacePic = rec.get(u'FacePic', 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.TitleID = rec.get(u'TitleID', 0)

        self.FightPower = rec.get(u'FightPower', 0)

        self.FightPowerEx = rec.get(u'FightPowerEx', 0)

        self.ServerID = rec.get(u'ServerID', 0)

        self.OffTime = rec.get(u'OffTime', 0)

        self.PlusDataSize = rec.get(u'PlusDataSize', 0)

        self.PlusData = fix_outgoingText(rec.get(u'PlusData', u''))



#Can not implement adoLoadStr method:No key defined!



    def adoInsert(self, collection):

        '''执行插入'''



        trycnt = 0

        rec = self.getRecord()

        while(True):

            try:

                collection.insert(rec, False, True)

                break

            except pymongo.errors.OperationFailure, err:



                if(DBConfig.TryCntOnWriteFail > trycnt):

                    trycnt += 1

                    continue

                    
                addADOExceptionCount()

                mylog.info("%s.%s:rec = %s"%(self.__class__.__name__, inspect.stack()[0][3], rec))

                msg = error.formatMsg('error', error.ERROR_NO_152, 'Insert failed!PlayerID = %s, error = %s, trycnt = %d'%(self.PlayerID, err, trycnt))

                mylog.error(msg)



                return False

        return True



#Can not implement adoUpdateStr method:No key defined!



    def adoUpdateEx(self, collection, spec):

        '''执行更新'''

        trycnt = 0

        rec = self.getRecord()

        while(True):

            try:

                collection.update(spec, {'$set':rec}, False, False, True, True)

                break

            except pymongo.errors.OperationFailure, err:

                if(DBConfig.TryCntOnWriteFail > trycnt):

                    trycnt += 1

                    continue

                addADOExceptionCount()

                mylog.info("%s.%s:rec = %s"%(self.__class__.__name__, inspect.stack()[0][3], rec))

                msg = error.formatMsg('error', error.ERROR_NO_154, 'Update failed!PlayerID = %s, error = %s, trycnt = %d'%(self.PlayerID, err, trycnt))

                mylog.error(msg)



                return False

        return True



#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





    def adoQueryIndex(self, collection):

        '''用索引字段查找'''

        resultCollection = collection.find({'PlayerID':self.PlayerID})

         
        return self.getAdoRecords(resultCollection)





    def adoQueryCustom(self, collection, queryDict):

        '''自定义查询'''

        resultCollection = collection.find(queryDict)



        return self.getAdoRecords(resultCollection)





    def adoQueryAll(self, collection):

        '''查询所有''' 
        resultCollection = collection.find()

         
        return self.getAdoRecords(resultCollection)





    def adoDeleteByIndex(self, collection):

        '''根据索引删除'''

        trycnt = 0

        while(True):

            try:

                collection.remove({'PlayerID':self.PlayerID})

                break

            except pymongo.errors.OperationFailure, err:

                if(DBConfig.TryCntOnWriteFail > trycnt):

                    trycnt += 1

                    continue

                addADOExceptionCount()

                mylog.info("%s.%s:PlayerID = %s"%(self.__class__.__name__, inspect.stack()[0][3], self.PlayerID))

                msg = error.formatMsg('error', error.ERROR_NO_155, 'delete failure!self.PlayerID = %s, error = %s, trycnt = %d'%(self.PlayerID, err, trycnt))

                mylog.error(msg)



                return False

        return True



    def outputString(self):

        output = '''// 玩家查看缓存表 #tagDBPlayerViewCache:

            PlayerID = %s,

            AccID = %s,

            PlayerName = %s,

            LV = %s,

            Job = %s,

            RealmLV = %s,

            Face = %s,

            FacePic = %s,

            FamilyID = %s,

            FamilyName = %s,

            FamilyEmblemID = %s,

            TitleID = %s,

            FightPower = %s,

            FightPowerEx = %s,

            ServerID = %s,

            OffTime = %s,

            PlusDataSize = %s,

            PlusData = %s,

            ADOResult = %s,

            '''%(

                self.PlayerID,

                self.AccID,

                self.PlayerName,

                self.LV,

                self.Job,

                self.RealmLV,

                self.Face,

                self.FacePic,

                self.FamilyID,

                self.FamilyName,

                self.FamilyEmblemID,

                self.TitleID,

                self.FightPower,

                self.FightPowerEx,

                self.ServerID,

                self.OffTime,

                self.PlusDataSize,

                self.PlusData,

                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\t%1s\t%1s'''%(

                self.PlayerID,

                self.AccID,

                self.PlayerName,

                self.LV,

                self.Job,

                self.RealmLV,

                self.Face,

                self.FacePic,

                self.FamilyID,

                self.FamilyName,

                self.FamilyEmblemID,

                self.TitleID,

                self.FightPower,

                self.FightPowerEx,

                self.ServerID,

                self.OffTime,

                self.PlusDataSize,

                self.PlusData,

            )

        return output



    #Char数组类型Set接口,使用该接口对此类型数据赋值，防止赋值的数据过长报错

    def SetAccID(self,Str):

        if len(Str)<=65:

            self.AccID = Str

        else:

            self.AccID = Str[:65]

            
    def SetPlayerName(self,Str):

        if len(Str)<=33:

            self.PlayerName = Str

        else:

            self.PlayerName = Str[:33]

            
    def SetFamilyName(self,Str):

        if len(Str)<=33:

            self.FamilyName = Str

        else:

            self.FamilyName = Str[:33]

            


# 排行榜表 #tagDBBillboard

class tagDBBillboard(Structure):

    _pack_ = 1

    _fields_ = [

        ('GroupValue1', ctypes.c_ulong),

        ('GroupValue2', ctypes.c_ulong),

        ('BillboardType', ctypes.c_ubyte),

        ('ID', ctypes.c_ulong),

        ('ID2', ctypes.c_ulong),

        ('Name1', ctypes.c_char * 33),

        ('Name2', ctypes.c_char * 65),

        ('Type2', ctypes.c_ubyte),

        ('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),

        ('CmpValue', ctypes.c_ulong),

        ('CmpValue2', ctypes.c_ulong),

        ('CmpValue3', ctypes.c_ulong),

        ('DataLen', ctypes.c_ushort),

        ('UserData', ctypes.c_char_p),

        ('ADOResult', ctypes.c_ulong),

    ]



    def __init__(self):

        Structure.__init__(self)

        self.clear()



    def clear(self):

        self.GroupValue1 = 0

        self.GroupValue2 = 0

        self.BillboardType = 0

        self.ID = 0

        self.ID2 = 0

        self.Name1 = ''

        self.Name2 = ''

        self.Type2 = 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.CmpValue = 0

        self.CmpValue2 = 0

        self.CmpValue3 = 0

        self.DataLen = 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.GroupValue1, pos = CommFunc.ReadDWORD(buf, pos)

        self.GroupValue2, pos = CommFunc.ReadDWORD(buf, pos)

        self.BillboardType, pos = CommFunc.ReadBYTE(buf, pos)

        self.ID, pos = CommFunc.ReadDWORD(buf, pos)

        self.ID2, pos = CommFunc.ReadDWORD(buf, pos)

        self.Name1, pos = CommFunc.ReadString(buf, pos, 33)

        self.Name2, pos = CommFunc.ReadString(buf, pos, 65)

        self.Type2, pos = CommFunc.ReadBYTE(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.CmpValue, pos = CommFunc.ReadDWORD(buf, pos)

        self.CmpValue2, pos = CommFunc.ReadDWORD(buf, pos)

        self.CmpValue3, 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)

        return self.getLength()



    def getBuffer(self):

        buf = ''

        buf = CommFunc.WriteDWORD(buf, self.GroupValue1)

        buf = CommFunc.WriteDWORD(buf, self.GroupValue2)

        buf = CommFunc.WriteBYTE(buf, self.BillboardType)

        buf = CommFunc.WriteDWORD(buf, self.ID)

        buf = CommFunc.WriteDWORD(buf, self.ID2)

        buf = CommFunc.WriteString(buf, sizeof(ctypes.c_char) * 33, self.Name1)

        buf = CommFunc.WriteString(buf, sizeof(ctypes.c_char) * 65, self.Name2)

        buf = CommFunc.WriteBYTE(buf, self.Type2)

        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.WriteDWORD(buf, self.CmpValue)

        buf = CommFunc.WriteDWORD(buf, self.CmpValue2)

        buf = CommFunc.WriteDWORD(buf, self.CmpValue3)

        buf = CommFunc.WriteWORD(buf, self.DataLen)

        buf = CommFunc.WriteString(buf, self.DataLen, self.UserData)

        return buf



    def getLength(self):

        length = 0

        length += sizeof(ctypes.c_ulong)

        length += sizeof(ctypes.c_ulong)

        length += sizeof(ctypes.c_ubyte)

        length += sizeof(ctypes.c_ulong)

        length += sizeof(ctypes.c_ulong)

        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)

        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.DataLen

        return length



    def getRecord(self):

        '''组织存储记录'''

        rec = {}

        rec[u'GroupValue1'] = self.GroupValue1

        rec[u'GroupValue2'] = self.GroupValue2

        rec[u'BillboardType'] = self.BillboardType

        rec[u'ID'] = self.ID

        rec[u'ID2'] = self.ID2

        rec[u'Name1'] = fix_incomingText(self.Name1)

        rec[u'Name2'] = fix_incomingText(self.Name2)

        rec[u'Type2'] = self.Type2

        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'CmpValue'] = self.CmpValue

        rec[u'CmpValue2'] = self.CmpValue2

        rec[u'CmpValue3'] = self.CmpValue3

        rec[u'DataLen'] = self.DataLen

        rec[u'UserData'] = fix_incomingText(self.UserData)

        return rec



    def readRecord(self, rec):

        '''由于MongoDB读出来是unicode,所有字符串需要进行转换'''

        self.GroupValue1 = rec.get(u'GroupValue1', 0)

        self.GroupValue2 = rec.get(u'GroupValue2', 0)

        self.BillboardType = rec.get(u'BillboardType', 0)

        self.ID = rec.get(u'ID', 0)

        self.ID2 = rec.get(u'ID2', 0)

        self.Name1 = fix_outgoingText(rec.get(u'Name1', u''))

        self.Name2 = fix_outgoingText(rec.get(u'Name2', u''))

        self.Type2 = rec.get(u'Type2', 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.CmpValue = rec.get(u'CmpValue', 0)

        self.CmpValue2 = rec.get(u'CmpValue2', 0)

        self.CmpValue3 = rec.get(u'CmpValue3', 0)

        self.DataLen = rec.get(u'DataLen', 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 = '''// 排行榜表 #tagDBBillboard:

            GroupValue1 = %s,

            GroupValue2 = %s,

            BillboardType = %s,

            ID = %s,

            ID2 = %s,

            Name1 = %s,

            Name2 = %s,

            Type2 = %s,

            Value1 = %s,

            Value2 = %s,

            Value3 = %s,

            Value4 = %s,

            Value5 = %s,

            Value6 = %s,

            Value7 = %s,

            Value8 = %s,

            CmpValue = %s,

            CmpValue2 = %s,

            CmpValue3 = %s,

            DataLen = %s,

            UserData = %s,

            ADOResult = %s,

            '''%(

                self.GroupValue1,

                self.GroupValue2,

                self.BillboardType,

                self.ID,

                self.ID2,

                self.Name1,

                self.Name2,

                self.Type2,

                self.Value1,

                self.Value2,

                self.Value3,

                self.Value4,

                self.Value5,

                self.Value6,

                self.Value7,

                self.Value8,

                self.CmpValue,

                self.CmpValue2,

                self.CmpValue3,

                self.DataLen,

                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\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s'''%(

                self.GroupValue1,

                self.GroupValue2,

                self.BillboardType,

                self.ID,

                self.ID2,

                self.Name1,

                self.Name2,

                self.Type2,

                self.Value1,

                self.Value2,

                self.Value3,

                self.Value4,

                self.Value5,

                self.Value6,

                self.Value7,

                self.Value8,

                self.CmpValue,

                self.CmpValue2,

                self.CmpValue3,

                self.DataLen,

                self.UserData,

            )

        return output



    #Char数组类型Set接口,使用该接口对此类型数据赋值，防止赋值的数据过长报错

    def SetName1(self,Str):

        if len(Str)<=33:

            self.Name1 = Str

        else:

            self.Name1 = Str[:33]

            
    def SetName2(self,Str):

        if len(Str)<=65:

            self.Name2 = Str

        else:

            self.Name2 = Str[:65]

            


# 邮件个人邮件表 #tagDBMailPersonal

class tagDBMailPersonal(Structure):

    _pack_ = 1

    _fields_ = [

        ('PlayerID', ctypes.c_ulong),

        ('GUID', ctypes.c_char * 36),

        ('Type', ctypes.c_ubyte),

        ('CreateTime', ctypes.c_char * 30),

        ('LimitDays', ctypes.c_ubyte),

        ('TitleLen', ctypes.c_ubyte),

        ('Title', ctypes.c_char_p),

        ('TextLen', ctypes.c_ushort),

        ('Text', ctypes.c_char_p),

        ('MailState', ctypes.c_ubyte),

        ('ADOResult', ctypes.c_ulong),

    ]



    def __init__(self):

        Structure.__init__(self)

        self.clear()



    def clear(self):

        self.PlayerID = 0

        self.GUID = ''

        self.Type = 0

        self.CreateTime = ''

        self.LimitDays = 0

        self.TitleLen = 0

        self.Title = ''

        self.TextLen = 0

        self.Text = ''

        self.MailState = 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.GUID, pos = CommFunc.ReadString(buf, pos, 36)

        self.Type, pos = CommFunc.ReadBYTE(buf, pos)

        self.CreateTime, pos = CommFunc.ReadString(buf, pos, 30)

        self.LimitDays, pos = CommFunc.ReadBYTE(buf, pos)

        self.TitleLen, pos = CommFunc.ReadBYTE(buf, pos)

        tmp, pos = CommFunc.ReadString(buf, pos, self.TitleLen)

        self.Title = ctypes.c_char_p(tmp)

        self.TextLen, pos = CommFunc.ReadWORD(buf, pos)

        tmp, pos = CommFunc.ReadString(buf, pos, self.TextLen)

        self.Text = ctypes.c_char_p(tmp)

        self.MailState, pos = CommFunc.ReadBYTE(buf, pos)

        return self.getLength()



    def getBuffer(self):

        buf = ''

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

        buf = CommFunc.WriteString(buf, sizeof(ctypes.c_char) * 36, self.GUID)

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

        buf = CommFunc.WriteString(buf, sizeof(ctypes.c_char) * 30, self.CreateTime)

        buf = CommFunc.WriteBYTE(buf, self.LimitDays)

        buf = CommFunc.WriteBYTE(buf, self.TitleLen)

        buf = CommFunc.WriteString(buf, self.TitleLen, self.Title)

        buf = CommFunc.WriteWORD(buf, self.TextLen)

        buf = CommFunc.WriteString(buf, self.TextLen, self.Text)

        buf = CommFunc.WriteBYTE(buf, self.MailState)

        return buf



    def getLength(self):

        length = 0

        length += sizeof(ctypes.c_ulong)

        length += sizeof(ctypes.c_char) * 36

        length += sizeof(ctypes.c_ubyte)

        length += sizeof(ctypes.c_char) * 30

        length += sizeof(ctypes.c_ubyte)

        length += sizeof(ctypes.c_ubyte)

        length += self.TitleLen

        length += sizeof(ctypes.c_ushort)

        length += self.TextLen

        length += sizeof(ctypes.c_ubyte)

        return length



    def getRecord(self):

        '''组织存储记录'''

        rec = {}

        rec[u'PlayerID'] = self.PlayerID

        rec[u'GUID'] = fix_incomingText(self.GUID)

        rec[u'Type'] = self.Type

        rec[u'CreateTime'] = fix_incomingText(self.CreateTime)

        rec[u'LimitDays'] = self.LimitDays

        rec[u'TitleLen'] = self.TitleLen

        rec[u'Title'] = fix_incomingText(self.Title)

        rec[u'TextLen'] = self.TextLen

        rec[u'Text'] = fix_incomingText(self.Text)

        rec[u'MailState'] = self.MailState

        return rec



    def readRecord(self, rec):

        '''由于MongoDB读出来是unicode,所有字符串需要进行转换'''

        self.PlayerID = rec.get(u'PlayerID', 0)

        self.GUID = fix_outgoingText(rec.get(u'GUID', u''))

        self.Type = rec.get(u'Type', 0)

        self.CreateTime = fix_outgoingText(rec.get(u'CreateTime', u''))

        self.LimitDays = rec.get(u'LimitDays', 0)

        self.TitleLen = rec.get(u'TitleLen', 0)

        self.Title = fix_outgoingText(rec.get(u'Title', u''))

        self.TextLen = rec.get(u'TextLen', 0)

        self.Text = fix_outgoingText(rec.get(u'Text', u''))

        self.MailState = rec.get(u'MailState', 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 = '''// 邮件个人邮件表 #tagDBMailPersonal:

            PlayerID = %s,

            GUID = %s,

            Type = %s,

            CreateTime = %s,

            LimitDays = %s,

            TitleLen = %s,

            Title = %s,

            TextLen = %s,

            Text = %s,

            MailState = %s,

            ADOResult = %s,

            '''%(

                self.PlayerID,

                self.GUID,

                self.Type,

                self.CreateTime,

                self.LimitDays,

                self.TitleLen,

                self.Title,

                self.TextLen,

                self.Text,

                self.MailState,

                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'''%(

                self.PlayerID,

                self.GUID,

                self.Type,

                self.CreateTime,

                self.LimitDays,

                self.TitleLen,

                self.Title,

                self.TextLen,

                self.Text,

                self.MailState,

            )

        return output



    #Char数组类型Set接口,使用该接口对此类型数据赋值，防止赋值的数据过长报错

    def SetGUID(self,Str):

        if len(Str)<=36:

            self.GUID = Str

        else:

            self.GUID = Str[:36]

            
    def SetCreateTime(self,Str):

        if len(Str)<=30:

            self.CreateTime = Str

        else:

            self.CreateTime = Str[:30]

            


# 邮件全服邮件表 #tagDBMailServer

class tagDBMailServer(Structure):

    _pack_ = 1

    _fields_ = [

        ('GUID', ctypes.c_char * 36),

        ('Type', ctypes.c_ubyte),

        ('CreateTime', ctypes.c_char * 30),

        ('LimitDays', ctypes.c_ubyte),

        ('TitleLen', ctypes.c_ubyte),

        ('Title', ctypes.c_char_p),

        ('TextLen', ctypes.c_ushort),

        ('Text', ctypes.c_char_p),

        ('LimitLV', ctypes.c_ushort),

        ('LimitLVType', ctypes.c_ubyte),

        ('CheckState', ctypes.c_ubyte),

        ('ADOResult', ctypes.c_ulong),

    ]



    def __init__(self):

        Structure.__init__(self)

        self.clear()



    def clear(self):

        self.GUID = ''

        self.Type = 0

        self.CreateTime = ''

        self.LimitDays = 0

        self.TitleLen = 0

        self.Title = ''

        self.TextLen = 0

        self.Text = ''

        self.LimitLV = 0

        self.LimitLVType = 0

        self.CheckState = 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.GUID, pos = CommFunc.ReadString(buf, pos, 36)

        self.Type, pos = CommFunc.ReadBYTE(buf, pos)

        self.CreateTime, pos = CommFunc.ReadString(buf, pos, 30)

        self.LimitDays, pos = CommFunc.ReadBYTE(buf, pos)

        self.TitleLen, pos = CommFunc.ReadBYTE(buf, pos)

        tmp, pos = CommFunc.ReadString(buf, pos, self.TitleLen)

        self.Title = ctypes.c_char_p(tmp)

        self.TextLen, pos = CommFunc.ReadWORD(buf, pos)

        tmp, pos = CommFunc.ReadString(buf, pos, self.TextLen)

        self.Text = ctypes.c_char_p(tmp)

        self.LimitLV, pos = CommFunc.ReadWORD(buf, pos)

        self.LimitLVType, pos = CommFunc.ReadBYTE(buf, pos)

        self.CheckState, pos = CommFunc.ReadBYTE(buf, pos)

        return self.getLength()



    def getBuffer(self):

        buf = ''

        buf = CommFunc.WriteString(buf, sizeof(ctypes.c_char) * 36, self.GUID)

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

        buf = CommFunc.WriteString(buf, sizeof(ctypes.c_char) * 30, self.CreateTime)

        buf = CommFunc.WriteBYTE(buf, self.LimitDays)

        buf = CommFunc.WriteBYTE(buf, self.TitleLen)

        buf = CommFunc.WriteString(buf, self.TitleLen, self.Title)

        buf = CommFunc.WriteWORD(buf, self.TextLen)

        buf = CommFunc.WriteString(buf, self.TextLen, self.Text)

        buf = CommFunc.WriteWORD(buf, self.LimitLV)

        buf = CommFunc.WriteBYTE(buf, self.LimitLVType)

        buf = CommFunc.WriteBYTE(buf, self.CheckState)

        return buf



    def getLength(self):

        length = 0

        length += sizeof(ctypes.c_char) * 36

        length += sizeof(ctypes.c_ubyte)

        length += sizeof(ctypes.c_char) * 30

        length += sizeof(ctypes.c_ubyte)

        length += sizeof(ctypes.c_ubyte)

        length += self.TitleLen

        length += sizeof(ctypes.c_ushort)

        length += self.TextLen

        length += sizeof(ctypes.c_ushort)

        length += sizeof(ctypes.c_ubyte)

        length += sizeof(ctypes.c_ubyte)

        return length



    def getRecord(self):

        '''组织存储记录'''

        rec = {}

        rec[u'GUID'] = fix_incomingText(self.GUID)

        rec[u'Type'] = self.Type

        rec[u'CreateTime'] = fix_incomingText(self.CreateTime)

        rec[u'LimitDays'] = self.LimitDays

        rec[u'TitleLen'] = self.TitleLen

        rec[u'Title'] = fix_incomingText(self.Title)

        rec[u'TextLen'] = self.TextLen

        rec[u'Text'] = fix_incomingText(self.Text)

        rec[u'LimitLV'] = self.LimitLV

        rec[u'LimitLVType'] = self.LimitLVType

        rec[u'CheckState'] = self.CheckState

        return rec



    def readRecord(self, rec):

        '''由于MongoDB读出来是unicode,所有字符串需要进行转换'''

        self.GUID = fix_outgoingText(rec.get(u'GUID', u''))

        self.Type = rec.get(u'Type', 0)

        self.CreateTime = fix_outgoingText(rec.get(u'CreateTime', u''))

        self.LimitDays = rec.get(u'LimitDays', 0)

        self.TitleLen = rec.get(u'TitleLen', 0)

        self.Title = fix_outgoingText(rec.get(u'Title', u''))

        self.TextLen = rec.get(u'TextLen', 0)

        self.Text = fix_outgoingText(rec.get(u'Text', u''))

        self.LimitLV = rec.get(u'LimitLV', 0)

        self.LimitLVType = rec.get(u'LimitLVType', 0)

        self.CheckState = rec.get(u'CheckState', 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 = '''// 邮件全服邮件表 #tagDBMailServer:

            GUID = %s,

            Type = %s,

            CreateTime = %s,

            LimitDays = %s,

            TitleLen = %s,

            Title = %s,

            TextLen = %s,

            Text = %s,

            LimitLV = %s,

            LimitLVType = %s,

            CheckState = %s,

            ADOResult = %s,

            '''%(

                self.GUID,

                self.Type,

                self.CreateTime,

                self.LimitDays,

                self.TitleLen,

                self.Title,

                self.TextLen,

                self.Text,

                self.LimitLV,

                self.LimitLVType,

                self.CheckState,

                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'''%(

                self.GUID,

                self.Type,

                self.CreateTime,

                self.LimitDays,

                self.TitleLen,

                self.Title,

                self.TextLen,

                self.Text,

                self.LimitLV,

                self.LimitLVType,

                self.CheckState,

            )

        return output



    #Char数组类型Set接口,使用该接口对此类型数据赋值，防止赋值的数据过长报错

    def SetGUID(self,Str):

        if len(Str)<=36:

            self.GUID = Str

        else:

            self.GUID = Str[:36]

            
    def SetCreateTime(self,Str):

        if len(Str)<=30:

            self.CreateTime = Str

        else:

            self.CreateTime = Str[:30]

            


# 邮件全服记录表 #tagDBMailPlayerRec

class tagDBMailPlayerRec(Structure):

    _pack_ = 1

    _fields_ = [

        ('PlayerID', ctypes.c_ulong),

        ('GUID', ctypes.c_char * 36),

        ('MailState', ctypes.c_ubyte),

        ('ADOResult', ctypes.c_ulong),

    ]



    def __init__(self):

        Structure.__init__(self)

        self.clear()





    def clear(self):

        memset(addressof(self), 0, self.getLength())



    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.GUID, pos = CommFunc.ReadString(buf, pos, 36)

        self.MailState, pos = CommFunc.ReadBYTE(buf, pos)

        return self.getLength()





    def getBuffer(self):

        buf = create_string_buffer(self.getLength())

        memmove(addressof(buf), addressof(self), self.getLength())

        return string_at(addressof(buf), self.getLength())



    def getLength(self):

        return sizeof(tagDBMailPlayerRec)



    def getRecord(self):

        '''组织存储记录'''

        rec = {}

        rec[u'PlayerID'] = self.PlayerID

        rec[u'GUID'] = fix_incomingText(self.GUID)

        rec[u'MailState'] = self.MailState

        return rec



    def readRecord(self, rec):

        '''由于MongoDB读出来是unicode,所有字符串需要进行转换'''

        self.PlayerID = rec.get(u'PlayerID', 0)

        self.GUID = fix_outgoingText(rec.get(u'GUID', u''))

        self.MailState = rec.get(u'MailState', 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 = '''// 邮件全服记录表 #tagDBMailPlayerRec:

            PlayerID = %s,

            GUID = %s,

            MailState = %s,

            ADOResult = %s,

            '''%(

                self.PlayerID,

                self.GUID,

                self.MailState,

                self.ADOResult,

            )

        return output



    def dumpString(self):

        output = '''%1s\t%1s\t%1s'''%(

                self.PlayerID,

                self.GUID,

                self.MailState,

            )

        return output



    #Char数组类型Set接口,使用该接口对此类型数据赋值，防止赋值的数据过长报错

    def SetGUID(self,Str):

        if len(Str)<=36:

            self.GUID = Str

        else:

            self.GUID = Str[:36]

            


# 邮件物品表 #tagDBMailItem

class tagDBMailItem(Structure):

    _pack_ = 1

    _fields_ = [

        ('GUID', ctypes.c_char * 36),

        ('ItemID', ctypes.c_ulong),

        ('Count', ctypes.c_ulong),

        ('IsBind', ctypes.c_ubyte),

        ('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.GUID = ''

        self.ItemID = 0

        self.Count = 0

        self.IsBind = 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.GUID, pos = CommFunc.ReadString(buf, pos, 36)

        self.ItemID, pos = CommFunc.ReadDWORD(buf, pos)

        self.Count, pos = CommFunc.ReadDWORD(buf, pos)

        self.IsBind, pos = CommFunc.ReadBYTE(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.WriteString(buf, sizeof(ctypes.c_char) * 36, self.GUID)

        buf = CommFunc.WriteDWORD(buf, self.ItemID)

        buf = CommFunc.WriteDWORD(buf, self.Count)

        buf = CommFunc.WriteBYTE(buf, self.IsBind)

        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_char) * 36

        length += sizeof(ctypes.c_ulong)

        length += sizeof(ctypes.c_ulong)

        length += sizeof(ctypes.c_ubyte)

        length += sizeof(ctypes.c_ushort)

        length += self.UserDataLen

        return length



    def getRecord(self):

        '''组织存储记录'''

        rec = {}

        rec[u'GUID'] = fix_incomingText(self.GUID)

        rec[u'ItemID'] = self.ItemID

        rec[u'Count'] = self.Count

        rec[u'IsBind'] = self.IsBind

        rec[u'UserDataLen'] = self.UserDataLen

        rec[u'UserData'] = fix_incomingText(self.UserData)

        return rec



    def readRecord(self, rec):

        '''由于MongoDB读出来是unicode,所有字符串需要进行转换'''

        self.GUID = fix_outgoingText(rec.get(u'GUID', u''))

        self.ItemID = rec.get(u'ItemID', 0)

        self.Count = rec.get(u'Count', 0)

        self.IsBind = rec.get(u'IsBind', 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 = '''// 邮件物品表 #tagDBMailItem:

            GUID = %s,

            ItemID = %s,

            Count = %s,

            IsBind = %s,

            UserDataLen = %s,

            UserData = %s,

            ADOResult = %s,

            '''%(

                self.GUID,

                self.ItemID,

                self.Count,

                self.IsBind,

                self.UserDataLen,

                self.UserData,

                self.ADOResult,

            )

        return output



    def dumpString(self):

        output = '''%1s\t%1s\t%1s\t%1s\t%1s\t%1s'''%(

                self.GUID,

                self.ItemID,

                self.Count,

                self.IsBind,

                self.UserDataLen,

                self.UserData,

            )

        return output



    #Char数组类型Set接口,使用该接口对此类型数据赋值，防止赋值的数据过长报错

    def SetGUID(self,Str):

        if len(Str)<=36:

            self.GUID = Str

        else:

            self.GUID = Str[:36]

            


# 家族表 #tagDBFamily

class tagDBFamily(Structure):

    _pack_ = 1

    _fields_ = [

        ('ID', ctypes.c_ulong),

        ('Name', ctypes.c_char * 33),

        ('LeaderID', ctypes.c_ulong),

        ('LV', ctypes.c_ubyte),

        ('Exp', ctypes.c_ulong),

        ('JoinReview', ctypes.c_ubyte),

        ('JoinLVMin', ctypes.c_ushort),

        ('CreateTime', ctypes.c_ulong),

        ('ServerID', ctypes.c_ulong),

        ('BroadcastLen', ctypes.c_ubyte),

        ('Broadcast', ctypes.c_char_p),

        ('FightPower', ctypes.c_ulong),

        ('FightPowerEx', ctypes.c_ulong),

        ('EmblemID', ctypes.c_ushort),

        ('ADOResult', ctypes.c_ulong),

    ]



    def __init__(self):

        Structure.__init__(self)

        self.clear()



    def clear(self):

        self.ID = 0

        self.Name = ''

        self.LeaderID = 0

        self.LV = 0

        self.Exp = 0

        self.JoinReview = 0

        self.JoinLVMin = 0

        self.CreateTime = 0

        self.ServerID = 0

        self.BroadcastLen = 0

        self.Broadcast = ''

        self.FightPower = 0

        self.FightPowerEx = 0

        self.EmblemID = 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.ID, pos = CommFunc.ReadDWORD(buf, pos)

        self.Name, pos = CommFunc.ReadString(buf, pos, 33)

        self.LeaderID, pos = CommFunc.ReadDWORD(buf, pos)

        self.LV, pos = CommFunc.ReadBYTE(buf, pos)

        self.Exp, pos = CommFunc.ReadDWORD(buf, pos)

        self.JoinReview, pos = CommFunc.ReadBYTE(buf, pos)

        self.JoinLVMin, pos = CommFunc.ReadWORD(buf, pos)

        self.CreateTime, pos = CommFunc.ReadDWORD(buf, pos)

        self.ServerID, pos = CommFunc.ReadDWORD(buf, pos)

        self.BroadcastLen, pos = CommFunc.ReadBYTE(buf, pos)

        tmp, pos = CommFunc.ReadString(buf, pos, self.BroadcastLen)

        self.Broadcast = ctypes.c_char_p(tmp)

        self.FightPower, pos = CommFunc.ReadDWORD(buf, pos)

        self.FightPowerEx, pos = CommFunc.ReadDWORD(buf, pos)

        self.EmblemID, pos = CommFunc.ReadWORD(buf, pos)

        return self.getLength()



    def getBuffer(self):

        buf = ''

        buf = CommFunc.WriteDWORD(buf, self.ID)

        buf = CommFunc.WriteString(buf, sizeof(ctypes.c_char) * 33, self.Name)

        buf = CommFunc.WriteDWORD(buf, self.LeaderID)

        buf = CommFunc.WriteBYTE(buf, self.LV)

        buf = CommFunc.WriteDWORD(buf, self.Exp)

        buf = CommFunc.WriteBYTE(buf, self.JoinReview)

        buf = CommFunc.WriteWORD(buf, self.JoinLVMin)

        buf = CommFunc.WriteDWORD(buf, self.CreateTime)

        buf = CommFunc.WriteDWORD(buf, self.ServerID)

        buf = CommFunc.WriteBYTE(buf, self.BroadcastLen)

        buf = CommFunc.WriteString(buf, self.BroadcastLen, self.Broadcast)

        buf = CommFunc.WriteDWORD(buf, self.FightPower)

        buf = CommFunc.WriteDWORD(buf, self.FightPowerEx)

        buf = CommFunc.WriteWORD(buf, self.EmblemID)

        return buf



    def getLength(self):

        length = 0

        length += sizeof(ctypes.c_ulong)

        length += sizeof(ctypes.c_char) * 33

        length += sizeof(ctypes.c_ulong)

        length += sizeof(ctypes.c_ubyte)

        length += sizeof(ctypes.c_ulong)

        length += sizeof(ctypes.c_ubyte)

        length += sizeof(ctypes.c_ushort)

        length += sizeof(ctypes.c_ulong)

        length += sizeof(ctypes.c_ulong)

        length += sizeof(ctypes.c_ubyte)

        length += self.BroadcastLen

        length += sizeof(ctypes.c_ulong)

        length += sizeof(ctypes.c_ulong)

        length += sizeof(ctypes.c_ushort)

        return length



    def getRecord(self):

        '''组织存储记录'''

        rec = {}

        rec[u'ID'] = self.ID

        rec[u'Name'] = fix_incomingText(self.Name)

        rec[u'LeaderID'] = self.LeaderID

        rec[u'LV'] = self.LV

        rec[u'Exp'] = self.Exp

        rec[u'JoinReview'] = self.JoinReview

        rec[u'JoinLVMin'] = self.JoinLVMin

        rec[u'CreateTime'] = self.CreateTime

        rec[u'ServerID'] = self.ServerID

        rec[u'BroadcastLen'] = self.BroadcastLen

        rec[u'Broadcast'] = fix_incomingText(self.Broadcast)

        rec[u'FightPower'] = self.FightPower

        rec[u'FightPowerEx'] = self.FightPowerEx

        rec[u'EmblemID'] = self.EmblemID

        return rec



    def readRecord(self, rec):

        '''由于MongoDB读出来是unicode,所有字符串需要进行转换'''

        self.ID = rec.get(u'ID', 0)

        self.Name = fix_outgoingText(rec.get(u'Name', u''))

        self.LeaderID = rec.get(u'LeaderID', 0)

        self.LV = rec.get(u'LV', 0)

        self.Exp = rec.get(u'Exp', 0)

        self.JoinReview = rec.get(u'JoinReview', 0)

        self.JoinLVMin = rec.get(u'JoinLVMin', 0)

        self.CreateTime = rec.get(u'CreateTime', 0)

        self.ServerID = rec.get(u'ServerID', 0)

        self.BroadcastLen = rec.get(u'BroadcastLen', 0)

        self.Broadcast = fix_outgoingText(rec.get(u'Broadcast', u''))

        self.FightPower = rec.get(u'FightPower', 0)

        self.FightPowerEx = rec.get(u'FightPowerEx', 0)

        self.EmblemID = rec.get(u'EmblemID', 0)



    def adoLoad(self, collection):

        '''使用KEY查找并读取'''

        resultCollection = collection.find({'ID':self.ID})



        if resultCollection.count() <= 0:

            return False

        #由于是KEY查找，所有如果存在就只有一条记录

        rec = resultCollection[0]

        #读取数据

        self.readRecord(rec)

        return True





    def adoInsert(self, collection):

        '''执行插入'''



        trycnt = 0

        rec = self.getRecord()

        while(True):

            try:

                collection.insert(rec, False, True)

                break

            except pymongo.errors.OperationFailure, err:



                if(DBConfig.TryCntOnWriteFail > trycnt):

                    trycnt += 1

                    continue

                    
                addADOExceptionCount()

                mylog.info("%s.%s:rec = %s"%(self.__class__.__name__, inspect.stack()[0][3], rec))

                msg = error.formatMsg('error', error.ERROR_NO_152, 'Insert failed!ID = %s, error = %s, trycnt = %d'%(self.ID, err, trycnt))

                mylog.error(msg)



                return False

        return True





    def adoUpdate(self, collection):

        '''执行更新'''

        trycnt = 0

        rec = self.getRecord()

        while(True):

            try:

                collection.update({'ID':self.ID}, {'$set':rec}, False, False, True, True)

                break

            except pymongo.errors.OperationFailure, err:

                if(DBConfig.TryCntOnWriteFail > trycnt):

                    trycnt += 1

                    continue



                addADOExceptionCount()

                mylog.info("%s.%s:rec = %s"%(self.__class__.__name__, inspect.stack()[0][3], rec))

                msg = error.formatMsg('error', error.ERROR_NO_153, 'Update failed!ID = %s, error = %s, trycnt = %d'%(self.ID, err, trycnt))

                mylog.error(msg)



                return False

        return True





    def adoUpdateEx(self, collection, spec):

        '''执行更新'''

        trycnt = 0

        rec = self.getRecord()

        while(True):

            try:

                collection.update(spec, {'$set':rec}, False, False, True, True)

                break

            except pymongo.errors.OperationFailure, err:

                if(DBConfig.TryCntOnWriteFail > trycnt):

                    trycnt += 1

                    continue

                addADOExceptionCount()

                mylog.info("%s.%s:rec = %s"%(self.__class__.__name__, inspect.stack()[0][3], rec))

                msg = error.formatMsg('error', error.ERROR_NO_154, 'Update failed!ID = %s, error = %s, trycnt = %d'%(self.ID, err, trycnt))

                mylog.error(msg)



                return False

        return True





    def adoCheckUpdate(self, collection):

        '''根据情况执行插入或更新'''

        resultCollection = collection.find({'ID':self.ID})

         
        if resultCollection.count() <= 0:

            return self.adoInsert(collection)

        return self.adoUpdate(collection)





    def adoCheckUpdateEx(self, collection, spec):

        '''根据情况执行插入或更新'''

        resultCollection = collection.find(spec)

         
        if resultCollection.count() <= 0:

            return self.adoInsert(collection)

        return self.adoUpdateEx(collection, spec)





    def getAdoRecords(self, resultCollection):

        '''查询结果打包成二进制流'''

        result = ''

        result = CommFunc.WriteDWORD(result, resultCollection.count())

        for rec in resultCollection:

            self.readRecord(rec)

            result += self.getBuffer()

        return result





    def adoQueryIndex(self, collection):

        '''用索引字段查找'''

        resultCollection = collection.find({'ID':self.ID})

         
        return self.getAdoRecords(resultCollection)





    def adoQueryCustom(self, collection, queryDict):

        '''自定义查询'''

        resultCollection = collection.find(queryDict)



        return self.getAdoRecords(resultCollection)





    def adoQueryAll(self, collection):

        '''查询所有''' 
        resultCollection = collection.find()

         
        return self.getAdoRecords(resultCollection)





    def adoDeleteByIndex(self, collection):

        '''根据索引删除'''

        trycnt = 0

        while(True):

            try:

                collection.remove({'ID':self.ID})

                break

            except pymongo.errors.OperationFailure, err:

                if(DBConfig.TryCntOnWriteFail > trycnt):

                    trycnt += 1

                    continue

                addADOExceptionCount()

                mylog.info("%s.%s:ID = %s"%(self.__class__.__name__, inspect.stack()[0][3], self.ID))

                msg = error.formatMsg('error', error.ERROR_NO_155, 'delete failure!self.ID = %s, error = %s, trycnt = %d'%(self.ID, err, trycnt))

                mylog.error(msg)



                return False

        return True



    def outputString(self):

        output = '''// 家族表 #tagDBFamily:

            ID = %s,

            Name = %s,

            LeaderID = %s,

            LV = %s,

            Exp = %s,

            JoinReview = %s,

            JoinLVMin = %s,

            CreateTime = %s,

            ServerID = %s,

            BroadcastLen = %s,

            Broadcast = %s,

            FightPower = %s,

            FightPowerEx = %s,

            EmblemID = %s,

            ADOResult = %s,

            '''%(

                self.ID,

                self.Name,

                self.LeaderID,

                self.LV,

                self.Exp,

                self.JoinReview,

                self.JoinLVMin,

                self.CreateTime,

                self.ServerID,

                self.BroadcastLen,

                self.Broadcast,

                self.FightPower,

                self.FightPowerEx,

                self.EmblemID,

                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'''%(

                self.ID,

                self.Name,

                self.LeaderID,

                self.LV,

                self.Exp,

                self.JoinReview,

                self.JoinLVMin,

                self.CreateTime,

                self.ServerID,

                self.BroadcastLen,

                self.Broadcast,

                self.FightPower,

                self.FightPowerEx,

                self.EmblemID,

            )

        return output



    #Char数组类型Set接口,使用该接口对此类型数据赋值，防止赋值的数据过长报错

    def SetName(self,Str):

        if len(Str)<=33:

            self.Name = Str

        else:

            self.Name = Str[:33]

            


# 家族成员表 #tagDBFamilyMem

class tagDBFamilyMem(Structure):

    _pack_ = 1

    _fields_ = [

        ('PlayerID', ctypes.c_ulong),

        ('FamilyID', ctypes.c_ulong),

        ('JoinTime', ctypes.c_ulong),

        ('PlayerName', ctypes.c_char * 33),

        ('LV', ctypes.c_int),

        ('Job', ctypes.c_int),

        ('RealmLV', ctypes.c_ubyte),

        ('Face', ctypes.c_int),

        ('FacePic', ctypes.c_int),

        ('FightPower', ctypes.c_ulong),

        ('FightPowerEx', ctypes.c_ulong),

        ('ServerID', ctypes.c_ulong),

        ('OffTime', ctypes.c_ulong),

        ('FmLV', ctypes.c_ubyte),

        ('ContribTotal', ctypes.c_ulong),

        ('ContribWeek', ctypes.c_ulong),

        ('ADOResult', ctypes.c_ulong),

    ]



    def __init__(self):

        Structure.__init__(self)

        self.clear()





    def clear(self):

        memset(addressof(self), 0, self.getLength())



    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.FamilyID, pos = CommFunc.ReadDWORD(buf, pos)

        self.JoinTime, pos = CommFunc.ReadDWORD(buf, pos)

        self.PlayerName, pos = CommFunc.ReadString(buf, pos, 33)

        self.LV, pos = CommFunc.ReadDWORD(buf, pos)

        self.Job, pos = CommFunc.ReadDWORD(buf, pos)

        self.RealmLV, pos = CommFunc.ReadBYTE(buf, pos)

        self.Face, pos = CommFunc.ReadDWORD(buf, pos)

        self.FacePic, pos = CommFunc.ReadDWORD(buf, pos)

        self.FightPower, pos = CommFunc.ReadDWORD(buf, pos)

        self.FightPowerEx, pos = CommFunc.ReadDWORD(buf, pos)

        self.ServerID, pos = CommFunc.ReadDWORD(buf, pos)

        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)

        return self.getLength()





    def getBuffer(self):

        buf = create_string_buffer(self.getLength())

        memmove(addressof(buf), addressof(self), self.getLength())

        return string_at(addressof(buf), self.getLength())



    def getLength(self):

        return sizeof(tagDBFamilyMem)



    def getRecord(self):

        '''组织存储记录'''

        rec = {}

        rec[u'PlayerID'] = self.PlayerID

        rec[u'FamilyID'] = self.FamilyID

        rec[u'JoinTime'] = self.JoinTime

        rec[u'PlayerName'] = fix_incomingText(self.PlayerName)

        rec[u'LV'] = self.LV

        rec[u'Job'] = self.Job

        rec[u'RealmLV'] = self.RealmLV

        rec[u'Face'] = self.Face

        rec[u'FacePic'] = self.FacePic

        rec[u'FightPower'] = self.FightPower

        rec[u'FightPowerEx'] = self.FightPowerEx

        rec[u'ServerID'] = self.ServerID

        rec[u'OffTime'] = self.OffTime

        rec[u'FmLV'] = self.FmLV

        rec[u'ContribTotal'] = self.ContribTotal

        rec[u'ContribWeek'] = self.ContribWeek

        return rec



    def readRecord(self, rec):

        '''由于MongoDB读出来是unicode,所有字符串需要进行转换'''

        self.PlayerID = rec.get(u'PlayerID', 0)

        self.FamilyID = rec.get(u'FamilyID', 0)

        self.JoinTime = rec.get(u'JoinTime', 0)

        self.PlayerName = fix_outgoingText(rec.get(u'PlayerName', u''))

        self.LV = rec.get(u'LV', 0)

        self.Job = rec.get(u'Job', 0)

        self.RealmLV = rec.get(u'RealmLV', 0)

        self.Face = rec.get(u'Face', 0)

        self.FacePic = rec.get(u'FacePic', 0)

        self.FightPower = rec.get(u'FightPower', 0)

        self.FightPowerEx = rec.get(u'FightPowerEx', 0)

        self.ServerID = rec.get(u'ServerID', 0)

        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)



    def adoLoad(self, collection):

        '''使用KEY查找并读取'''

        resultCollection = collection.find({'PlayerID':self.PlayerID})



        if resultCollection.count() <= 0:

            return False

        #由于是KEY查找，所有如果存在就只有一条记录

        rec = resultCollection[0]

        #读取数据

        self.readRecord(rec)

        return True





    def adoInsert(self, collection):

        '''执行插入'''



        trycnt = 0

        rec = self.getRecord()

        while(True):

            try:

                collection.insert(rec, False, True)

                break

            except pymongo.errors.OperationFailure, err:



                if(DBConfig.TryCntOnWriteFail > trycnt):

                    trycnt += 1

                    continue

                    
                addADOExceptionCount()

                mylog.info("%s.%s:rec = %s"%(self.__class__.__name__, inspect.stack()[0][3], rec))

                msg = error.formatMsg('error', error.ERROR_NO_152, 'Insert failed!PlayerID = %s, error = %s, trycnt = %d'%(self.PlayerID, err, trycnt))

                mylog.error(msg)



                return False

        return True





    def adoUpdate(self, collection):

        '''执行更新'''

        trycnt = 0

        rec = self.getRecord()

        while(True):

            try:

                collection.update({'PlayerID':self.PlayerID}, {'$set':rec}, False, False, True, True)

                break

            except pymongo.errors.OperationFailure, err:

                if(DBConfig.TryCntOnWriteFail > trycnt):

                    trycnt += 1

                    continue



                addADOExceptionCount()

                mylog.info("%s.%s:rec = %s"%(self.__class__.__name__, inspect.stack()[0][3], rec))

                msg = error.formatMsg('error', error.ERROR_NO_153, 'Update failed!PlayerID = %s, error = %s, trycnt = %d'%(self.PlayerID, err, trycnt))

                mylog.error(msg)



                return False

        return True





    def adoUpdateEx(self, collection, spec):

        '''执行更新'''

        trycnt = 0

        rec = self.getRecord()

        while(True):

            try:

                collection.update(spec, {'$set':rec}, False, False, True, True)

                break

            except pymongo.errors.OperationFailure, err:

                if(DBConfig.TryCntOnWriteFail > trycnt):

                    trycnt += 1

                    continue

                addADOExceptionCount()

                mylog.info("%s.%s:rec = %s"%(self.__class__.__name__, inspect.stack()[0][3], rec))

                msg = error.formatMsg('error', error.ERROR_NO_154, 'Update failed!PlayerID = %s, error = %s, trycnt = %d'%(self.PlayerID, err, trycnt))

                mylog.error(msg)



                return False

        return True





    def adoCheckUpdate(self, collection):

        '''根据情况执行插入或更新'''

        resultCollection = collection.find({'PlayerID':self.PlayerID})

         
        if resultCollection.count() <= 0:

            return self.adoInsert(collection)

        return self.adoUpdate(collection)





    def adoCheckUpdateEx(self, collection, spec):

        '''根据情况执行插入或更新'''

        resultCollection = collection.find(spec)

         
        if resultCollection.count() <= 0:

            return self.adoInsert(collection)

        return self.adoUpdateEx(collection, spec)





    def getAdoRecords(self, resultCollection):

        '''查询结果打包成二进制流'''

        result = ''

        result = CommFunc.WriteDWORD(result, resultCollection.count())

        for rec in resultCollection:

            self.readRecord(rec)

            result += self.getBuffer()

        return result





    def adoQueryIndex(self, collection):

        '''用索引字段查找'''

        resultCollection = collection.find({'PlayerID':self.PlayerID})

         
        return self.getAdoRecords(resultCollection)





    def adoQueryCustom(self, collection, queryDict):

        '''自定义查询'''

        resultCollection = collection.find(queryDict)



        return self.getAdoRecords(resultCollection)





    def adoQueryAll(self, collection):

        '''查询所有''' 
        resultCollection = collection.find()

         
        return self.getAdoRecords(resultCollection)





    def adoDeleteByIndex(self, collection):

        '''根据索引删除'''

        trycnt = 0

        while(True):

            try:

                collection.remove({'PlayerID':self.PlayerID})

                break

            except pymongo.errors.OperationFailure, err:

                if(DBConfig.TryCntOnWriteFail > trycnt):

                    trycnt += 1

                    continue

                addADOExceptionCount()

                mylog.info("%s.%s:PlayerID = %s"%(self.__class__.__name__, inspect.stack()[0][3], self.PlayerID))

                msg = error.formatMsg('error', error.ERROR_NO_155, 'delete failure!self.PlayerID = %s, error = %s, trycnt = %d'%(self.PlayerID, err, trycnt))

                mylog.error(msg)



                return False

        return True



    def outputString(self):

        output = '''// 家族成员表 #tagDBFamilyMem:

            PlayerID = %s,

            FamilyID = %s,

            JoinTime = %s,

            PlayerName = %s,

            LV = %s,

            Job = %s,

            RealmLV = %s,

            Face = %s,

            FacePic = %s,

            FightPower = %s,

            FightPowerEx = %s,

            ServerID = %s,

            OffTime = %s,

            FmLV = %s,

            ContribTotal = %s,

            ContribWeek = %s,

            ADOResult = %s,

            '''%(

                self.PlayerID,

                self.FamilyID,

                self.JoinTime,

                self.PlayerName,

                self.LV,

                self.Job,

                self.RealmLV,

                self.Face,

                self.FacePic,

                self.FightPower,

                self.FightPowerEx,

                self.ServerID,

                self.OffTime,

                self.FmLV,

                self.ContribTotal,

                self.ContribWeek,

                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'''%(

                self.PlayerID,

                self.FamilyID,

                self.JoinTime,

                self.PlayerName,

                self.LV,

                self.Job,

                self.RealmLV,

                self.Face,

                self.FacePic,

                self.FightPower,

                self.FightPowerEx,

                self.ServerID,

                self.OffTime,

                self.FmLV,

                self.ContribTotal,

                self.ContribWeek,

            )

        return output



    #Char数组类型Set接口,使用该接口对此类型数据赋值，防止赋值的数据过长报错

    def SetPlayerName(self,Str):

        if len(Str)<=33:

            self.PlayerName = Str

        else:

            self.PlayerName = Str[:33]

            


# 家族行为表 #tagDBFamilyAction

class tagDBFamilyAction(Structure):

    _pack_ = 1

    _fields_ = [

        ('FamilyID', ctypes.c_ulong),

        ('ActionType', ctypes.c_ubyte),

        ('Name', ctypes.c_char * 33),

        ('Time', ctypes.c_ulong),

        ('Value1', ctypes.c_ulong),

        ('Value2', ctypes.c_ulong),

        ('Value3', ctypes.c_ulong),

        ('Value4', ctypes.c_ulong),

        ('Value5', ctypes.c_ulong),

        ('Value6', ctypes.c_ulong),

        ('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.FamilyID = 0

        self.ActionType = 0

        self.Name = ''

        self.Time = 0

        self.Value1 = 0

        self.Value2 = 0

        self.Value3 = 0

        self.Value4 = 0

        self.Value5 = 0

        self.Value6 = 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.FamilyID, pos = CommFunc.ReadDWORD(buf, pos)

        self.ActionType, pos = CommFunc.ReadBYTE(buf, pos)

        self.Name, pos = CommFunc.ReadString(buf, pos, 33)

        self.Time, pos = CommFunc.ReadDWORD(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.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.FamilyID)

        buf = CommFunc.WriteBYTE(buf, self.ActionType)

        buf = CommFunc.WriteString(buf, sizeof(ctypes.c_char) * 33, self.Name)

        buf = CommFunc.WriteDWORD(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.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_ubyte)

        length += sizeof(ctypes.c_char) * 33

        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.DataLen

        return length



    def getRecord(self):

        '''组织存储记录'''

        rec = {}

        rec[u'FamilyID'] = self.FamilyID

        rec[u'ActionType'] = self.ActionType

        rec[u'Name'] = fix_incomingText(self.Name)

        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'DataLen'] = self.DataLen

        rec[u'Data'] = fix_incomingText(self.Data)

        return rec



    def readRecord(self, rec):

        '''由于MongoDB读出来是unicode,所有字符串需要进行转换'''

        self.FamilyID = rec.get(u'FamilyID', 0)

        self.ActionType = rec.get(u'ActionType', 0)

        self.Name = fix_outgoingText(rec.get(u'Name', u''))

        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.DataLen = rec.get(u'DataLen', 0)

        self.Data = fix_outgoingText(rec.get(u'Data', u''))



#Can not implement adoLoadStr method:No key defined!



    def adoInsert(self, collection):

        '''执行插入'''



        trycnt = 0

        rec = self.getRecord()

        while(True):

            try:

                collection.insert(rec, False, True)

                break

            except pymongo.errors.OperationFailure, err:



                if(DBConfig.TryCntOnWriteFail > trycnt):

                    trycnt += 1

                    continue

                    
                addADOExceptionCount()

                mylog.info("%s.%s:rec = %s"%(self.__class__.__name__, inspect.stack()[0][3], rec))

                msg = error.formatMsg('error', error.ERROR_NO_152, 'Insert failed!FamilyID = %s, error = %s, trycnt = %d'%(self.FamilyID, err, trycnt))

                mylog.error(msg)



                return False

        return True



#Can not implement adoUpdateStr method:No key defined!



    def adoUpdateEx(self, collection, spec):

        '''执行更新'''

        trycnt = 0

        rec = self.getRecord()

        while(True):

            try:

                collection.update(spec, {'$set':rec}, False, False, True, True)

                break

            except pymongo.errors.OperationFailure, err:

                if(DBConfig.TryCntOnWriteFail > trycnt):

                    trycnt += 1

                    continue

                addADOExceptionCount()

                mylog.info("%s.%s:rec = %s"%(self.__class__.__name__, inspect.stack()[0][3], rec))

                msg = error.formatMsg('error', error.ERROR_NO_154, 'Update failed!FamilyID = %s, error = %s, trycnt = %d'%(self.FamilyID, err, trycnt))

                mylog.error(msg)



                return False

        return True



#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





    def adoQueryIndex(self, collection):

        '''用索引字段查找'''

        resultCollection = collection.find({'FamilyID':self.FamilyID})

         
        return self.getAdoRecords(resultCollection)





    def adoQueryCustom(self, collection, queryDict):

        '''自定义查询'''

        resultCollection = collection.find(queryDict)



        return self.getAdoRecords(resultCollection)





    def adoQueryAll(self, collection):

        '''查询所有''' 
        resultCollection = collection.find()

         
        return self.getAdoRecords(resultCollection)





    def adoDeleteByIndex(self, collection):

        '''根据索引删除'''

        trycnt = 0

        while(True):

            try:

                collection.remove({'FamilyID':self.FamilyID})

                break

            except pymongo.errors.OperationFailure, err:

                if(DBConfig.TryCntOnWriteFail > trycnt):

                    trycnt += 1

                    continue

                addADOExceptionCount()

                mylog.info("%s.%s:FamilyID = %s"%(self.__class__.__name__, inspect.stack()[0][3], self.FamilyID))

                msg = error.formatMsg('error', error.ERROR_NO_155, 'delete failure!self.FamilyID = %s, error = %s, trycnt = %d'%(self.FamilyID, err, trycnt))

                mylog.error(msg)



                return False

        return True



    def outputString(self):

        output = '''// 家族行为表 #tagDBFamilyAction:

            FamilyID = %s,

            ActionType = %s,

            Name = %s,

            Time = %s,

            Value1 = %s,

            Value2 = %s,

            Value3 = %s,

            Value4 = %s,

            Value5 = %s,

            Value6 = %s,

            DataLen = %s,

            Data = %s,

            ADOResult = %s,

            '''%(

                self.FamilyID,

                self.ActionType,

                self.Name,

                self.Time,

                self.Value1,

                self.Value2,

                self.Value3,

                self.Value4,

                self.Value5,

                self.Value6,

                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\t%1s\t%1s\t%1s\t%1s\t%1s'''%(

                self.FamilyID,

                self.ActionType,

                self.Name,

                self.Time,

                self.Value1,

                self.Value2,

                self.Value3,

                self.Value4,

                self.Value5,

                self.Value6,

                self.DataLen,

                self.Data,

            )

        return output



    #Char数组类型Set接口,使用该接口对此类型数据赋值，防止赋值的数据过长报错

    def SetName(self,Str):

        if len(Str)<=33:

            self.Name = Str

        else:

            self.Name = Str[:33]

            



 ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/PyMongoDB/LogicProcess/UserCtrlDB.py

@@ -18,6 +18,7 @@
from MangoDBCommon import (getADOExceptionCount, getSIDErrorCnt, addADOExceptionCount, seq, fix_outgoingText, fix_incomingText)

from ServerClientShareDefine import *

import ConfigParser

import IpyGameDataPY

#import IPY_GameWorld

#from Config import (DBConfig,)

DBConfig = __import__('Config.DBConfig')

@@ -479,19 +480,19 @@
            return True



        #GameServer保存数据

        if requestType == CommonDefine.gstSaveGameServerData:

            oFuncGrade = self.GetFuncGrade("gstSaveGameServerData")

            oFuncGrade.Start()  
            self.onSaveGameServerData(db, pack)

            oFuncGrade.End()

            return True

        #if requestType == CommonDefine.gstSaveGameServerData:

        #    oFuncGrade = self.GetFuncGrade("gstSaveGameServerData")

        #    oFuncGrade.Start()  
        #    self.onSaveGameServerData(db, pack)

        #    oFuncGrade.End()

        #    return True

        #GameServer读取玩家数据

        if requestType == CommonDefine.gstGetGameServerPlayerData:

            oFuncGrade = self.GetFuncGrade("gstGetGameServerPlayerData")

            oFuncGrade.Start()  
            self.onGetGameServerPlayerData(db, pack)

            oFuncGrade.End()

            return True

        #if requestType == CommonDefine.gstGetGameServerPlayerData:

        #    oFuncGrade = self.GetFuncGrade("gstGetGameServerPlayerData")

        #    oFuncGrade.Start()  
        #    self.onGetGameServerPlayerData(db, pack)

        #    oFuncGrade.End()

        #    return True

        #GameServer读取GM命令列表

        if requestType == CommonDefine.gstGMCommandListReq:

            oFuncGrade = self.GetFuncGrade("gstGMCommandListReq")

@@ -2394,8 +2395,9 @@
            msg = error.formatMsg('error', error.ERROR_NO_65, 'PlayerID Dispatch failed!accid = %s'%createPlayer.AccID)

            mylog.error(msg)

            return 0, disDataBaseError, createPlayer.AccID, '' 

        nameFormat = IpyGameDataPY.GetFuncCfg("CreateRole", 1)

        createPlayer.PlayerID = newPlayerID

        createPlayer.PlayerName = "role" + str(newPlayerID)

        createPlayer.PlayerName = (nameFormat % newPlayerID).decode('gbk').encode(DBConfig.encoding)

        #校验通过，往数据库中插入角色

        mylog.debug('Before insert role!accid = %s, PlayerName = %s'%(createPlayer.AccID, createPlayer.PlayerName))       

        if not createPlayer.adoInsertC(collection):

@@ -3348,7 +3350,100 @@
        #已废除

        pass

    

    def readGameWorldData(self):

        '''读取服务器公共数据

                            【注】：新建的表往后添加

        '''

        db = self.db

        
        data = ''

        mylog.info('readGameWorldData Start...')

        
        collection = db[UCN_DBEventTrig]

        DBEventTrig = DataServerPlayerData.tagDBEventTrig()

        data += DBEventTrig.adoQueryAll(collection)

        mylog.info("tagDBEventTrig ok")

        
        collection = db[UCN_DBPlayerViewCache]

        DBPlayerViewCache = DataServerPlayerData.tagDBPlayerViewCache()

        data += DBPlayerViewCache.adoQueryAll(collection)

        mylog.info("tagDBPlayerViewCache ok")

        
        collection = db[UCN_DBBillboard]

        DBBillboard = DataServerPlayerData.tagDBBillboard()

        data += DBBillboard.adoQueryAll(collection)

        mylog.info("tagDBBillboard ok")

        
        collection = db[UCN_DBMailServer]

        DBMailServer = DataServerPlayerData.tagDBMailServer()

        data += DBMailServer.adoQueryAll(collection)

        mylog.info("tagDBMailServer ok")

        
        collection = db[UCN_DBMailPlayerRec]

        DBMailPlayerRec = DataServerPlayerData.tagDBMailPlayerRec()

        data += DBMailPlayerRec.adoQueryAll(collection)

        mylog.info("tagDBMailPlayerRec ok")

        
        collection = db[UCN_DBMailPersonal]

        DBMailPersonal = DataServerPlayerData.tagDBMailPersonal()

        data += DBMailPersonal.adoQueryAll(collection)

        mylog.info("tagDBMailPersonal ok")

        
        collection = db[UCN_DBMailItem]

        DBMailItem = DataServerPlayerData.tagDBMailItem()

        data += DBMailItem.adoQueryAll(collection)

        mylog.info("tagDBMailItem ok")

        
        collection = db[UCN_DBFamily]

        DBFamily = DataServerPlayerData.tagDBFamily()

        data += DBFamily.adoQueryAll(collection)

        mylog.info("tagDBFamily ok")

        
        collection = db[UCN_DBFamilyMem]

        DBFamilyMem = DataServerPlayerData.tagDBFamilyMem()

        data += DBFamilyMem.adoQueryAll(collection)

        mylog.info("tagDBFamilyMem ok")

        
        collection = db[UCN_DBFamilyAction]

        DBFamilyAction = DataServerPlayerData.tagDBFamilyAction()

        data += DBFamilyAction.adoQueryAll(collection)

        mylog.info("tagDBFamilyAction ok")

        
        mylog.info('readGameWorldData len:%s' % len(data))

        return data

    
    def saveGameWorldData(self, saveData):

        ## 保存服务器公共数据

        
        db = self.db

        dataLen = len(saveData)

        mylog.info('saveGameWorldData, len = %s!saving...'%dataLen)

        gameDataReadPos = 0

        try:

            gameDataReadPos = self.savegameServerWorldData(saveData, gameDataReadPos, UCN_DBEventTrig, DataServerPlayerData.tagDBEventTrig, db)

            gameDataReadPos = self.savegameServerWorldData(saveData, gameDataReadPos, UCN_DBPlayerViewCache, DataServerPlayerData.tagDBPlayerViewCache, db)

            gameDataReadPos = self.savegameServerWorldData(saveData, gameDataReadPos, UCN_DBBillboard, DataServerPlayerData.tagDBBillboard, db)

            gameDataReadPos = self.savegameServerWorldData(saveData, gameDataReadPos, UCN_DBMailServer, DataServerPlayerData.tagDBMailServer, db)

            gameDataReadPos = self.savegameServerWorldData(saveData, gameDataReadPos, UCN_DBMailPlayerRec, DataServerPlayerData.tagDBMailPlayerRec, db)

            gameDataReadPos = self.savegameServerWorldData(saveData, gameDataReadPos, UCN_DBMailPersonal, DataServerPlayerData.tagDBMailPersonal, db)

            gameDataReadPos = self.savegameServerWorldData(saveData, gameDataReadPos, UCN_DBMailItem, DataServerPlayerData.tagDBMailItem, db)

            gameDataReadPos = self.savegameServerWorldData(saveData, gameDataReadPos, UCN_DBFamily, DataServerPlayerData.tagDBFamily, db)

            gameDataReadPos = self.savegameServerWorldData(saveData, gameDataReadPos, UCN_DBFamilyMem, DataServerPlayerData.tagDBFamilyMem, db)

            gameDataReadPos = self.savegameServerWorldData(saveData, gameDataReadPos, UCN_DBFamilyAction, DataServerPlayerData.tagDBFamilyAction, db)

            
            mylog.info('saveGameWorldData ok!')

            
            # 如果是关服中的，设置关服保存数据处理完毕

            if PyGameData.g_serverClosing:

                PyGameData.g_closeSaveDataOK = True

        except:

            msg = error.formatMsg('error', error.ERROR_NO_81, '%s'%traceback.format_exc())

            mylog.error(msg)

            
        return

    
    def onGetGameServerPlayerData(self, db, pack):

        ## 废弃，改为使用 readGameWorldData

        data = ''

        

        #玩家打包数据表较大，不同步GameServer，由db自己管理

@@ -3735,6 +3830,7 @@
        self.saveGameServerGameData(db, pack, pack.getBuffer(), pos, type, needReturn)

            

    def saveGameServerGameData(self, db, pack, data, pos, saveType, needReturn):

        ##废弃，改为使用 saveGameWorldData

        if saveType == CommonDefine.dgGameServerCrashData:

            #FileLog.getLogger('GameServerDataRestoreLog').info('解析崩溃数据中。。。')

            #tagGDGameServerGameData


 ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/PyMongoDB/index/GameUser.txt

@@ -1,110 +1,46 @@
#数据库的索引字典

{

    'tagDBPyXMZZ':  #表名

    {

        'PlayerID_1':   #索引名

    'tagDBMailItem':    #表名

        {

            'key':[('PlayerID', 1)] #索引的字典和递增(1)或递减(-1)

        }

    },

    
    'tagDBPySealDemonRecord':  #表名

    {

        'PlayerID_1':   #索引名

        'GUID_1':    #索引名

                {

                    'key':[('GUID', 1)]    #索引的字典和递增(1)或递减(-1)

                }

        },

		
    'tagDBMailPersonal':    #表名

        {

            'key':[('PlayerID', 1)] #索引的字典和递增(1)或递减(-1)

        }

    },

    
    'tagDBPyBossAttention':  #表名

    {

        'PlayerID_1':   #索引名

        {

            'key':[('PlayerID', 1)] #索引的字典和递增(1)或递减(-1)

        }

    },

    
    'tagDBPyBourseItemLastPrice':  #表名

    {

        'ItemID_1':   #索引名

        {

            'key':[('ItemID', 1)] #索引的字典和递增(1)或递减(-1)

        }

    },

    
    'tagDBPyBourseRecord':    #表名

    {

        'PlayerID_1':    #索引名

        {

            'key':[('PlayerID', 1)]    #索引的字典和递增(1)或递减(-1)

        }

    },

	
    'tagDBPyFamilyStoreItem':    #表名

    {

        'FamilyID_1':    #索引名

        {

            'key':[('FamilyID', 1)]    #索引的字典和递增(1)或递减(-1)

        }

    },



    'tagDBPlayerInfoLog':    #表名

    {

        'AccID_1':    #索引名

        {

            'key':[('AccID', 1)]    #索引的字典和递增(1)或递减(-1)

        }

    },

    
    'tagDBGateServerIP':    #表名

    {

        'LineID_1':    #索引名

        {

            'key':[('LineID', 1)]    #索引的字典和递增(1)或递减(-1)

        }

    },

    
    'tagDBPyPlayerFriend':    #表名

    {

        'PlayerID_1':    #索引名

        {

            'key':[('PlayerID', 1)]    #索引的字典和递增(1)或递减(-1)

        }

    },

    
    'tagPlayerEnemy':    #表名

    {

        'PlayerID_1':    #索引名

        {

            'key':[('PlayerID', 1)]    #索引的字典和递增(1)或递减(-1)

        }

    },

    
    'tagDBPyPlayerBlack':    #表名

    {

        'PlayerID_1':    #索引名

        {

            'key':[('PlayerID', 1)]    #索引的字典和递增(1)或递减(-1)

        }

    },

    
    'tagDBPyPlayerContacts':    #表名

    {

        'PlayerID_1':    #索引名

        {

            'key':[('PlayerID', 1)]    #索引的字典和递增(1)或递减(-1)

        }

    },

    
        'tagPersonalSocial':    #表名

    {

        'PlayerID_1':    #索引名

                {

                    'unique':True,

                    'key':[('PlayerID', 1)]    #索引的字典和递增(1)或递减(-1)

                },

                }

        },



    'tagDBFamilyMem':    #表名

        {

        'PlayerID_1':    #索引名

                {

                    'key':[('PlayerID', 1)]    #索引的字典和递增(1)或递减(-1)

                }

        },



    'tagDBPlayerViewCache':    #表名

    {

        'PlayerID_1':    #索引名

        {

            'unique':True,

            'key':[('PlayerID', 1)]    #索引的字典和递增(1)或递减(-1)

        }

    },

    

    'tagDBMapServerInfo':    #表名

        {

        'LogIndex_1':    #索引名

                {

                    'key':[('LogIndex', 1)]    #索引的字典和递增(1)或递减(-1)

                }

        },

		
    'tagRoleMission':    #表名

    {

        'PlayerID_1':    #索引名

@@ -235,197 +171,6 @@
        }

        },



'tagDBPlayerRecall':    #表名

        {

        'PlayerID_1':    #索引名

                {

                    'unique':True,

                    'key':[('PlayerID', 1)]    #索引的字典和递增(1)或递减(-1)

                }

        },



'tagDBVsReward':    #表名

        {

        'PlayerID_1':    #索引名

                {

                    'unique':True,

                    'key':[('PlayerID', 1)]    #索引的字典和递增(1)或递减(-1)

                }

        },



'tagAccCoins':    #表名

        {

        'AccID_1':    #索引名

                {

                    'unique':True,

                    'key':[('AccID', 1)]    #索引的字典和递增(1)或递减(-1)

                }

        },



'tagAccIDSendPrize':    #表名

        {

        'CheckValue_1':    #索引名

                {

                    'unique':True,

                    'key':[('CheckValue', 1)]    #索引的字典和递增(1)或递减(-1)

                }

        },



'tagDBBillboard':    #表名

        {

        'Type_1_ID_1':    #索引名

                {

                    'unique':True,

                    'key':[('Type', 1), ('ID', 1)]    #索引的字典和递增(1)或递减(-1)

                }

        },



'tagDBCountryFamilyWarRequest':    #表名

        {

        'FamilyID_1':    #索引名

                {

                    'unique':True,

                    'key':[('FamilyID', 1)]    #索引的字典和递增(1)或递减(-1)

                }

        },



'tagDBCountryFamilyWarResult':    #表名

        {

        'FamilyID_1':    #索引名

                {

                    'unique':True,

                    'key':[('FamilyID', 1)]    #索引的字典和递增(1)或递减(-1)

                }

        },



'tagDBCountryInfo':    #表名

        {

        'CountryID_1':    #索引名

                {

                    'unique':True,

                    'key':[('CountryID', 1)]    #索引的字典和递增(1)或递减(-1)

                }

        },



'tagDBGameServerEventTrig':    #表名

        {

        'EventID_1':    #索引名

                {

                    'unique':True,

                    'key':[('EventID', 1)]    #索引的字典和递增(1)或递减(-1)

                }

        },



'tagDBGMCommandList':    #表名

        {

        'CmdIndex_1':    #索引名

                {

                    'unique':True,

                    'key':[('CmdIndex', 1)]    #索引的字典和递增(1)或递减(-1)

                }

        },



'tagDBGoldOrderForm':    #表名

        {

        'PlayerID_1':    #索引名

                {

                    'unique':True,

                    'key':[('PlayerID', 1)]    #索引的字典和递增(1)或递减(-1)

                }

        },



'tagDBImpeach':    #表名

        {

        'ImpeachIndex_1':    #索引名

                {

                    'unique':True,

                    'key':[('ImpeachIndex', 1)]    #索引的字典和递增(1)或递减(-1)

                }

        },



'tagDBMailList':    #表名

        {

        'MailID_1':    #索引名

                {

                    'unique':True,

                    'key':[('MailID', 1)]    #索引的字典和递增(1)或递减(-1)

                }

        },



'tagDBMapServerInfo':    #表名

        {

        'LogIndex_1':    #索引名

                {

                    'key':[('LogIndex', 1)]    #索引的字典和递增(1)或递减(-1)

                }

        },



'tagDBOverdueGoldOrderForm':    #表名

        {

        'PlayerID_1':    #索引名

                {

                    'unique':True,

                    'key':[('PlayerID', 1)]    #索引的字典和递增(1)或递减(-1)

                }

        },



'tagDBPlayerChangeNameLog':    #表名

        {

        'PlayerID_1':    #索引名

                {

                    'unique':True,

                    'key':[('PlayerID', 1)]    #索引的字典和递增(1)或递减(-1)

                }

        },



'tagExpiation':    #表名

        {

        'AccID_1':    #索引名

                {

                    'key':[('AccID', 1)]    #索引的字典和递增(1)或递减(-1)

                }

        },



'tagFamilyInfo':    #表名

        {

        'ID_1':    #索引名

                {

                    'unique':True,

                    'key':[('ID', 1)]    #索引的字典和递增(1)或递减(-1)

                }

        },



'tagGameWorldEvent':    #表名

        {

        'EventID_1':    #索引名

                {

                    'unique':True,

                    'key':[('EventID', 1)]    #索引的字典和递增(1)或递减(-1)

                }

        },



'tagPetExpiation':    #表名

        {

        'ExpiationIndex_1':    #索引名

                {

                    'unique':True,

                    'key':[('ExpiationIndex', 1)]    #索引的字典和递增(1)或递减(-1)

                },

        'AccID_1':    #索引名

                {

                    'key':[('AccID', 1)]    #索引的字典和递增(1)或递减(-1)

                }

        },



'tagPlayerFamily':    #表名

        {

        'PlayerID_1':    #索引名

                {

                    'unique':True,

                    'key':[('PlayerID', 1)]    #索引的字典和递增(1)或递减(-1)

                }

        },



'tagRolePet':    #表名

        {

        'PlayerID_1':    #索引名

@@ -437,13 +182,4 @@
                    'key':[('PetID', 1)]    #索引的字典和递增(1)或递减(-1)

                }

        },



'tagPlayerTeamTable':    #表名

        {

        'TeamID_1':    #索引名

                {

                    'unique':True,

                    'key':[('TeamID', 1)]    #索引的字典和递增(1)或递减(-1)

                }

        }

}