#!/usr/bin/python
|
# -*- coding: GBK -*-
|
#-------------------------------------------------------------------------------
|
#
|
#-------------------------------------------------------------------------------
|
#
|
|
#-------------------------------------------------------------------------------
|
#¸ºÔðϵͳ±íµÄ¼ÓÔØ¡¢µ¼Èë¡¢´ò°ü
|
#Ô´±í±ØÐëÊÇutf-8±àÂ룬ÇëÏÈÐÐת»»£¬·ñÔòµ¼Èë»á³ö´í
|
#ʹÓÃProtocolStudio CodeMaker MongoDBGameData.pyÉú³É
|
#-------------------------------------------------------------------------------
|
|
import ctypes#Ìí¼Ó
|
from ctypes import *
|
from Common import(mylog, CommFuncEx)#import mylog
|
import pymongo
|
import sys
|
import binascii
|
import MangoDBCommon
|
from MangoDBCommon import( SPLITCHAR, addADOExceptionCount, fix_incomingText )
|
import traceback
|
import inspect
|
DBConfig = __import__('Config.DBConfig')
|
from DBCommon import error
|
|
#------------------------------------------------------
|
#ÖØÉúµã#tagBornRefresh
|
class tagBornRefresh(Structure):
|
_pack_ = 1
|
_fields_ = [
|
('RefreshID', c_ulong),
|
('MapID', c_ulong),
|
('PosX', c_ulong),
|
('PosY', c_ulong),
|
('Round', c_ulong),
|
('Country', c_ushort),
|
('ADOResult', c_ulong),
|
]
|
|
def __init__(self):
|
Structure.__init__(self)
|
self.clear()
|
|
def clear(self):
|
memset(addressof(self), 0, self.getLength())
|
|
|
def readLine(self, line):
|
self.clear()
|
wordList = line.split(SPLITCHAR)
|
try:
|
self.RefreshID = int(wordList[0].strip())
|
self.MapID = int(wordList[1].strip())
|
self.PosX = int(wordList[2].strip())
|
self.PosY = int(wordList[3].strip())
|
self.Round = int(wordList[4].strip())
|
self.Country = int(wordList[5].strip())
|
|
except IndexError,e:
|
errorStr = '''\nIndexError:%s [lineData:"%s"]'''%(e, line)
|
raise Exception(errorStr)
|
except:
|
errorStr = '''\nException on readLine:[lineData:"%s"]\n%s'''%(line,traceback.format_exc())
|
raise Exception(errorStr)
|
|
|
def __getRecord(self):
|
'''×éÖ¯´æ´¢¼Ç¼'''
|
rec = {}
|
rec[u'RefreshID'] = self.RefreshID
|
rec[u'MapID'] = self.MapID
|
rec[u'PosX'] = self.PosX
|
rec[u'PosY'] = self.PosY
|
rec[u'Round'] = self.Round
|
rec[u'Country'] = self.Country
|
|
return rec
|
|
|
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_146, 'tagBornRefresh Insert failed!RefreshID = %s, error = %s, trycnt = %d'%(self.RefreshID, err, trycnt))
|
mylog.error(msg)
|
|
return False
|
return True
|
|
|
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(tagBornRefresh)
|
|
|
def readData(self, buf, pos):
|
if len(buf) < pos + self.getLength():
|
msg = error.formatMsg('error', error.ERROR_NO_147, 'len = %s while %s expected!'%(len(buf) - pos, self.getLength()))
|
mylog.error(msg)
|
return -1
|
self.clear()
|
memmove(addressof(self), buf[pos:], self.getLength())
|
return pos + self.getLength()
|
|
def outputString(self):
|
output = '''//ÖØÉúµã#tagBornRefresh:
|
RefreshID = %s,
|
MapID = %s,
|
PosX = %s,
|
PosY = %s,
|
Round = %s,
|
Country = %s,
|
ADOResult = %s,
|
'''%(
|
self.RefreshID,
|
self.MapID,
|
self.PosX,
|
self.PosY,
|
self.Round,
|
self.Country,
|
self.ADOResult
|
)
|
return output
|
|
|
#------------------------------------------------------
|
#×°±¸´òÔì±í#tagBuildEquip
|
class tagBuildEquip(Structure):
|
_pack_ = 1
|
_fields_ = [
|
('BuildID', c_ulong),
|
('Item1ID', c_ulong),
|
('Item2ID', c_ulong),
|
('Item3ID', c_ulong),
|
('Item4ID', c_ulong),
|
('Item5ID', c_ulong),
|
('Item6ID', c_ulong),
|
('ItemCount', c_ushort),
|
('Money', c_ulong),
|
('Product1ID', c_ulong),
|
('Product2ID', c_ulong),
|
('Product3ID', c_ulong),
|
('Product4ID', c_ulong),
|
('Product5ID', c_ulong),
|
('Product6ID', c_ulong),
|
('Product7ID', c_ulong),
|
('ADOResult', c_ulong),
|
]
|
|
def __init__(self):
|
Structure.__init__(self)
|
self.clear()
|
|
def clear(self):
|
memset(addressof(self), 0, self.getLength())
|
|
|
def readLine(self, line):
|
self.clear()
|
wordList = line.split(SPLITCHAR)
|
try:
|
self.BuildID = int(wordList[0].strip())
|
self.Item1ID = int(wordList[1].strip())
|
self.Item2ID = int(wordList[2].strip())
|
self.Item3ID = int(wordList[3].strip())
|
self.Item4ID = int(wordList[4].strip())
|
self.Item5ID = int(wordList[5].strip())
|
self.Item6ID = int(wordList[6].strip())
|
self.ItemCount = int(wordList[7].strip())
|
self.Money = int(wordList[8].strip())
|
self.Product1ID = int(wordList[9].strip())
|
self.Product2ID = int(wordList[10].strip())
|
self.Product3ID = int(wordList[11].strip())
|
self.Product4ID = int(wordList[12].strip())
|
self.Product5ID = int(wordList[13].strip())
|
self.Product6ID = int(wordList[14].strip())
|
self.Product7ID = int(wordList[15].strip())
|
|
except IndexError,e:
|
errorStr = '''\nIndexError:%s [lineData:"%s"]'''%(e, line)
|
raise Exception(errorStr)
|
except:
|
errorStr = '''\nException on readLine:[lineData:"%s"]\n%s'''%(line,traceback.format_exc())
|
raise Exception(errorStr)
|
|
|
def __getRecord(self):
|
'''×éÖ¯´æ´¢¼Ç¼'''
|
rec = {}
|
rec[u'BuildID'] = self.BuildID
|
rec[u'Item1ID'] = self.Item1ID
|
rec[u'Item2ID'] = self.Item2ID
|
rec[u'Item3ID'] = self.Item3ID
|
rec[u'Item4ID'] = self.Item4ID
|
rec[u'Item5ID'] = self.Item5ID
|
rec[u'Item6ID'] = self.Item6ID
|
rec[u'ItemCount'] = self.ItemCount
|
rec[u'Money'] = self.Money
|
rec[u'Product1ID'] = self.Product1ID
|
rec[u'Product2ID'] = self.Product2ID
|
rec[u'Product3ID'] = self.Product3ID
|
rec[u'Product4ID'] = self.Product4ID
|
rec[u'Product5ID'] = self.Product5ID
|
rec[u'Product6ID'] = self.Product6ID
|
rec[u'Product7ID'] = self.Product7ID
|
|
return rec
|
|
|
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_146, 'tagBuildEquip Insert failed!BuildID = %s, error = %s, trycnt = %d'%(self.BuildID, err, trycnt))
|
mylog.error(msg)
|
|
return False
|
return True
|
|
|
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(tagBuildEquip)
|
|
|
def readData(self, buf, pos):
|
if len(buf) < pos + self.getLength():
|
msg = error.formatMsg('error', error.ERROR_NO_147, 'len = %s while %s expected!'%(len(buf) - pos, self.getLength()))
|
mylog.error(msg)
|
return -1
|
self.clear()
|
memmove(addressof(self), buf[pos:], self.getLength())
|
return pos + self.getLength()
|
|
def outputString(self):
|
output = '''//×°±¸´òÔì±í#tagBuildEquip:
|
BuildID = %s,
|
Item1ID = %s,
|
Item2ID = %s,
|
Item3ID = %s,
|
Item4ID = %s,
|
Item5ID = %s,
|
Item6ID = %s,
|
ItemCount = %s,
|
Money = %s,
|
Product1ID = %s,
|
Product2ID = %s,
|
Product3ID = %s,
|
Product4ID = %s,
|
Product5ID = %s,
|
Product6ID = %s,
|
Product7ID = %s,
|
ADOResult = %s,
|
'''%(
|
self.BuildID,
|
self.Item1ID,
|
self.Item2ID,
|
self.Item3ID,
|
self.Item4ID,
|
self.Item5ID,
|
self.Item6ID,
|
self.ItemCount,
|
self.Money,
|
self.Product1ID,
|
self.Product2ID,
|
self.Product3ID,
|
self.Product4ID,
|
self.Product5ID,
|
self.Product6ID,
|
self.Product7ID,
|
self.ADOResult
|
)
|
return output
|
|
|
#------------------------------------------------------
|
#µØͼÐÅÏ¢#tagChinMapPeriod Ϊ0£¬²»´¦Àí Period Ϊ1£¬´ú±íÿÌ쿪Æô, ´Ëʱ PeriodValue1 ÎÞÒâÒå, PeriodHour1 ΪСʱ(Èç20µã), PeriodMinute1 Ϊ·ÖÖÓ(30)Period Ϊ2£¬´ú±íÿÖÜ¿ªÆô, ´Ëʱ PeriodValue1 ±íʾÐÇÆÚ¼¸, PeriodHour1 ΪСʱ(Èç20µã), PeriodMinute1 Ϊ·ÖÖÓ(30)Period Ϊ3£¬´ú±íÿÔ¿ªÆô, ´Ëʱ PeriodValue1 ±íʾ¼¸ºÅ(ÈçÿÔÂ15ÈÕ¿ªÆô), PeriodHour1(20µã), PeriodMinute1 Ϊ·ÖÖÓ(30) PeriodValue2, PeriodHour2, PeriodMinute2ÒâÒåͬPeriodMinute1, PeriodHour1, PeriodMinute1, ±íʾµÚ¶þ¸ö¿ªÆôµÄʱ¼äµã
|
#µØͼÐÅÏ¢#tagChinMap
|
|
class tagChinMap(Structure):
|
_pack_ = 1
|
_fields_ = [
|
('MapID', c_ulong),
|
('MapName', c_char * 15),
|
('Country', c_ubyte),
|
('LV', c_ushort),
|
('ExistTime', c_ulong),
|
('MapFBType', c_ubyte),
|
('AutoSize', c_ubyte),
|
('Period', c_ubyte),
|
('PeriodValue1', c_ubyte),
|
('PeriodHour1', c_ubyte),
|
('PeriodMinute1', c_ubyte),
|
('PeriodValue2', c_ubyte),
|
('PeriodHour2', c_ubyte),
|
('PeriodMinute2', c_ubyte),
|
('LocalReborn', c_ubyte),
|
('SkillReborn', c_ubyte),
|
('RebornMap', c_ushort),
|
('RebornMapX', c_ushort),
|
('RebornMapY', c_ushort),
|
('CanRide', c_ubyte),
|
('CanOutPet', c_ubyte),
|
('TreasureID', c_ulong),
|
('InitAttackModel', c_ubyte),
|
('AttackModel', c_ubyte),
|
('ADOResult', c_ulong),
|
]
|
|
def __init__(self):
|
Structure.__init__(self)
|
self.clear()
|
|
def clear(self):
|
memset(addressof(self), 0, self.getLength())
|
|
|
def readLine(self, line):
|
self.clear()
|
wordList = line.split(SPLITCHAR)
|
try:
|
self.MapID = int(wordList[0].strip())
|
self.MapName = wordList[1].strip()
|
self.Country = int(wordList[2].strip())
|
self.LV = int(wordList[3].strip())
|
self.ExistTime = int(wordList[4].strip())
|
self.MapFBType = int(wordList[5].strip())
|
self.AutoSize = int(wordList[6].strip())
|
self.Period = int(wordList[7].strip())
|
self.PeriodValue1 = int(wordList[8].strip())
|
self.PeriodHour1 = int(wordList[9].strip())
|
self.PeriodMinute1 = int(wordList[10].strip())
|
self.PeriodValue2 = int(wordList[11].strip())
|
self.PeriodHour2 = int(wordList[12].strip())
|
self.PeriodMinute2 = int(wordList[13].strip())
|
self.LocalReborn = int(wordList[14].strip())
|
self.SkillReborn = int(wordList[15].strip())
|
self.RebornMap = int(wordList[16].strip())
|
self.RebornMapX = int(wordList[17].strip())
|
self.RebornMapY = int(wordList[18].strip())
|
self.CanRide = int(wordList[19].strip())
|
self.CanOutPet = int(wordList[20].strip())
|
self.TreasureID = int(wordList[21].strip())
|
self.InitAttackModel = int(wordList[22].strip())
|
self.AttackModel = int(wordList[23].strip())
|
|
except IndexError,e:
|
errorStr = '''\nIndexError:%s [lineData:"%s"]'''%(e, line)
|
raise Exception(errorStr)
|
except:
|
errorStr = '''\nException on readLine:[lineData:"%s"]\n%s'''%(line,traceback.format_exc())
|
raise Exception(errorStr)
|
|
|
def __getRecord(self):
|
'''×éÖ¯´æ´¢¼Ç¼'''
|
rec = {}
|
rec[u'MapID'] = self.MapID
|
rec[u'MapName'] = fix_incomingText(self.MapName)
|
rec[u'Country'] = self.Country
|
rec[u'LV'] = self.LV
|
rec[u'ExistTime'] = self.ExistTime
|
rec[u'MapFBType'] = self.MapFBType
|
rec[u'AutoSize'] = self.AutoSize
|
rec[u'Period'] = self.Period
|
rec[u'PeriodValue1'] = self.PeriodValue1
|
rec[u'PeriodHour1'] = self.PeriodHour1
|
rec[u'PeriodMinute1'] = self.PeriodMinute1
|
rec[u'PeriodValue2'] = self.PeriodValue2
|
rec[u'PeriodHour2'] = self.PeriodHour2
|
rec[u'PeriodMinute2'] = self.PeriodMinute2
|
rec[u'LocalReborn'] = self.LocalReborn
|
rec[u'SkillReborn'] = self.SkillReborn
|
rec[u'RebornMap'] = self.RebornMap
|
rec[u'RebornMapX'] = self.RebornMapX
|
rec[u'RebornMapY'] = self.RebornMapY
|
rec[u'CanRide'] = self.CanRide
|
rec[u'CanOutPet'] = self.CanOutPet
|
rec[u'TreasureID'] = self.TreasureID
|
rec[u'InitAttackModel'] = self.InitAttackModel
|
rec[u'AttackModel'] = self.AttackModel
|
|
return rec
|
|
|
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_146, 'tagChinMap Insert failed!MapID = %s, error = %s, trycnt = %d'%(self.MapID, err, trycnt))
|
mylog.error(msg)
|
|
return False
|
return True
|
|
|
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(tagChinMap)
|
|
|
def readData(self, buf, pos):
|
if len(buf) < pos + self.getLength():
|
msg = error.formatMsg('error', error.ERROR_NO_147, 'len = %s while %s expected!'%(len(buf) - pos, self.getLength()))
|
mylog.error(msg)
|
return -1
|
self.clear()
|
memmove(addressof(self), buf[pos:], self.getLength())
|
return pos + self.getLength()
|
|
def outputString(self):
|
output = ''':
|
MapID = %s,
|
MapName = %s,
|
Country = %s,
|
LV = %s,
|
ExistTime = %s,
|
MapFBType = %s,
|
AutoSize = %s,
|
Period = %s,
|
PeriodValue1 = %s,
|
PeriodHour1 = %s,
|
PeriodMinute1 = %s,
|
PeriodValue2 = %s,
|
PeriodHour2 = %s,
|
PeriodMinute2 = %s,
|
LocalReborn = %s,
|
SkillReborn = %s,
|
RebornMap = %s,
|
RebornMapX = %s,
|
RebornMapY = %s,
|
CanRide = %s,
|
CanOutPet = %s,
|
TreasureID = %s,
|
InitAttackModel = %s,
|
AttackModel = %s,
|
ADOResult = %s,
|
'''%(
|
self.MapID,
|
self.MapName,
|
self.Country,
|
self.LV,
|
self.ExistTime,
|
self.MapFBType,
|
self.AutoSize,
|
self.Period,
|
self.PeriodValue1,
|
self.PeriodHour1,
|
self.PeriodMinute1,
|
self.PeriodValue2,
|
self.PeriodHour2,
|
self.PeriodMinute2,
|
self.LocalReborn,
|
self.SkillReborn,
|
self.RebornMap,
|
self.RebornMapX,
|
self.RebornMapY,
|
self.CanRide,
|
self.CanOutPet,
|
self.TreasureID,
|
self.InitAttackModel,
|
self.AttackModel,
|
self.ADOResult
|
)
|
return output
|
|
|
|
#------------------------------------------------------
|
#³¡¾°Ð§¹û#tagEffectRefresh
|
class tagEffectRefresh(Structure):
|
_pack_ = 1
|
_fields_ = [
|
('RefreshID', c_ulong),
|
('MapID', c_ulong),
|
('PosX', c_ulong),
|
('PosY', c_ulong),
|
('Range', c_ulong),
|
('EffectId', c_ulong),
|
('EffectValue', c_ulong),
|
('ADOResult', c_ulong),
|
]
|
|
def __init__(self):
|
Structure.__init__(self)
|
self.clear()
|
|
def clear(self):
|
memset(addressof(self), 0, self.getLength())
|
|
|
def readLine(self, line):
|
self.clear()
|
wordList = line.split(SPLITCHAR)
|
try:
|
self.RefreshID = int(wordList[0].strip())
|
self.MapID = int(wordList[1].strip())
|
self.PosX = int(wordList[2].strip())
|
self.PosY = int(wordList[3].strip())
|
self.Range = int(wordList[4].strip())
|
self.EffectId = int(wordList[5].strip())
|
self.EffectValue = int(wordList[6].strip())
|
|
except IndexError,e:
|
errorStr = '''\nIndexError:%s [lineData:"%s"]'''%(e, line)
|
raise Exception(errorStr)
|
except:
|
errorStr = '''\nException on readLine:[lineData:"%s"]\n%s'''%(line,traceback.format_exc())
|
raise Exception(errorStr)
|
|
|
def __getRecord(self):
|
'''×éÖ¯´æ´¢¼Ç¼'''
|
rec = {}
|
rec[u'RefreshID'] = self.RefreshID
|
rec[u'MapID'] = self.MapID
|
rec[u'PosX'] = self.PosX
|
rec[u'PosY'] = self.PosY
|
rec[u'Range'] = self.Range
|
rec[u'EffectId'] = self.EffectId
|
rec[u'EffectValue'] = self.EffectValue
|
|
return rec
|
|
|
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_146, 'tagEffectRefresh Insert failed!MapID = %s, error = %s, trycnt = %d'%(self.MapID, err, trycnt))
|
mylog.error(msg)
|
|
return False
|
return True
|
|
|
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(tagEffectRefresh)
|
|
|
def readData(self, buf, pos):
|
if len(buf) < pos + self.getLength():
|
msg = error.formatMsg('error', error.ERROR_NO_147, 'len = %s while %s expected!'%(len(buf) - pos, self.getLength()))
|
mylog.error(msg)
|
return -1
|
self.clear()
|
memmove(addressof(self), buf[pos:], self.getLength())
|
return pos + self.getLength()
|
|
def outputString(self):
|
output = '''//³¡¾°Ð§¹û#tagEffectRefresh:
|
RefreshID = %s,
|
MapID = %s,
|
PosX = %s,
|
PosY = %s,
|
Range = %s,
|
EffectId = %s,
|
EffectValue = %s,
|
ADOResult = %s,
|
'''%(
|
self.RefreshID,
|
self.MapID,
|
self.PosX,
|
self.PosY,
|
self.Range,
|
self.EffectId,
|
self.EffectValue,
|
self.ADOResult
|
)
|
return output
|
|
|
#------------------------------------------------------
|
#´òÔìÅä·½±í#tagChinMixItem
|
class tagChinMixItem(Structure):
|
_pack_ = 1
|
_fields_ = [
|
('MixItemID', c_ulong),
|
('ItemLV', c_ubyte),
|
('ItemType', c_ubyte),
|
('IronCount', c_ubyte),
|
('CopperCount', c_ubyte),
|
('SilverCount', c_ubyte),
|
('Money', c_ushort),
|
('BreakIronCount', c_ubyte),
|
('BreakCopperCount', c_ubyte),
|
('BreakSilverCount', c_ubyte),
|
('BreakMoney', c_ushort),
|
('ADOResult', c_ulong),
|
]
|
|
def __init__(self):
|
Structure.__init__(self)
|
self.clear()
|
|
def clear(self):
|
memset(addressof(self), 0, self.getLength())
|
|
|
def readLine(self, line):
|
self.clear()
|
wordList = line.split(SPLITCHAR)
|
try:
|
self.MixItemID = int(wordList[0].strip())
|
self.ItemLV = int(wordList[1].strip())
|
self.ItemType = int(wordList[2].strip())
|
self.IronCount = int(wordList[3].strip())
|
self.CopperCount = int(wordList[4].strip())
|
self.SilverCount = int(wordList[5].strip())
|
self.Money = int(wordList[6].strip())
|
self.BreakIronCount = int(wordList[7].strip())
|
self.BreakCopperCount = int(wordList[8].strip())
|
self.BreakSilverCount = int(wordList[9].strip())
|
self.BreakMoney = int(wordList[10].strip())
|
|
except IndexError,e:
|
errorStr = '''\nIndexError:%s [lineData:"%s"]'''%(e, line)
|
raise Exception(errorStr)
|
except:
|
errorStr = '''\nException on readLine:[lineData:"%s"]\n%s'''%(line,traceback.format_exc())
|
raise Exception(errorStr)
|
|
|
def __getRecord(self):
|
'''×éÖ¯´æ´¢¼Ç¼'''
|
rec = {}
|
rec[u'MixItemID'] = self.MixItemID
|
rec[u'ItemLV'] = self.ItemLV
|
rec[u'ItemType'] = self.ItemType
|
rec[u'IronCount'] = self.IronCount
|
rec[u'CopperCount'] = self.CopperCount
|
rec[u'SilverCount'] = self.SilverCount
|
rec[u'Money'] = self.Money
|
rec[u'BreakIronCount'] = self.BreakIronCount
|
rec[u'BreakCopperCount'] = self.BreakCopperCount
|
rec[u'BreakSilverCount'] = self.BreakSilverCount
|
rec[u'BreakMoney'] = self.BreakMoney
|
|
return rec
|
|
|
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_146, 'tagChinMixItem Insert failed!MixItemID = %s, error = %s, trycnt = %d'%(self.MixItemID, err, trycnt))
|
mylog.error(msg)
|
|
return False
|
return True
|
|
|
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(tagChinMixItem)
|
|
|
def readData(self, buf, pos):
|
if len(buf) < pos + self.getLength():
|
msg = error.formatMsg('error', error.ERROR_NO_147, 'len = %s while %s expected!'%(len(buf) - pos, self.getLength()))
|
mylog.error(msg)
|
return -1
|
self.clear()
|
memmove(addressof(self), buf[pos:], self.getLength())
|
return pos + self.getLength()
|
|
def outputString(self):
|
output = '''//´òÔìÅä·½±í#tagChinMixItem:
|
MixItemID = %s,
|
ItemLV = %s,
|
ItemType = %s,
|
IronCount = %s,
|
CopperCount = %s,
|
SilverCount = %s,
|
Money = %s,
|
BreakIronCount = %s,
|
BreakCopperCount = %s,
|
BreakSilverCount = %s,
|
BreakMoney = %s,
|
ADOResult = %s,
|
'''%(
|
self.MixItemID,
|
self.ItemLV,
|
self.ItemType,
|
self.IronCount,
|
self.CopperCount,
|
self.SilverCount,
|
self.Money,
|
self.BreakIronCount,
|
self.BreakCopperCount,
|
self.BreakSilverCount,
|
self.BreakMoney,
|
self.ADOResult
|
)
|
return output
|
|
#------------------------------------------------------
|
#×°±¸Ì×װЧ¹û±í#tagSuiteEffect
|
class tagSuiteEffect(Structure):
|
_pack_ = 1
|
_fields_ = [
|
('SuiteID', c_ulong),
|
('SkillTriggeredBy2', c_ulong),
|
('SkillTriggeredBy3', c_ulong),
|
('SkillTriggeredBy4', c_ulong),
|
('SkillTriggeredBy5', c_ulong),
|
('SkillTriggeredBy6', c_ulong),
|
('SkillTriggeredBy7', c_ulong),
|
('SkillTriggeredBy8', c_ulong),
|
('SkillTriggeredBy9', c_ulong),
|
('SkillTriggeredBy10', c_ulong),
|
('ADOResult', c_ulong),
|
]
|
|
def __init__(self):
|
Structure.__init__(self)
|
self.clear()
|
|
def clear(self):
|
memset(addressof(self), 0, self.getLength())
|
|
|
def readLine(self, line):
|
self.clear()
|
wordList = line.split(SPLITCHAR)
|
try:
|
self.SuiteID = int(wordList[0].strip())
|
self.SkillTriggeredBy2 = int(wordList[1].strip())
|
self.SkillTriggeredBy3 = int(wordList[2].strip())
|
self.SkillTriggeredBy4 = int(wordList[3].strip())
|
self.SkillTriggeredBy5 = int(wordList[4].strip())
|
self.SkillTriggeredBy6 = int(wordList[5].strip())
|
self.SkillTriggeredBy7 = int(wordList[6].strip())
|
self.SkillTriggeredBy8 = int(wordList[7].strip())
|
self.SkillTriggeredBy9 = int(wordList[8].strip())
|
self.SkillTriggeredBy10 = int(wordList[9].strip())
|
|
except IndexError,e:
|
errorStr = '''\nIndexError:%s [lineData:"%s"]'''%(e, line)
|
raise Exception(errorStr)
|
except:
|
errorStr = '''\nException on readLine:[lineData:"%s"]\n%s'''%(line,traceback.format_exc())
|
raise Exception(errorStr)
|
|
|
def __getRecord(self):
|
'''×éÖ¯´æ´¢¼Ç¼'''
|
rec = {}
|
rec[u'SuiteID'] = self.SuiteID
|
rec[u'SkillTriggeredBy2'] = self.SkillTriggeredBy2
|
rec[u'SkillTriggeredBy3'] = self.SkillTriggeredBy3
|
rec[u'SkillTriggeredBy4'] = self.SkillTriggeredBy4
|
rec[u'SkillTriggeredBy5'] = self.SkillTriggeredBy5
|
rec[u'SkillTriggeredBy6'] = self.SkillTriggeredBy6
|
rec[u'SkillTriggeredBy7'] = self.SkillTriggeredBy7
|
rec[u'SkillTriggeredBy8'] = self.SkillTriggeredBy8
|
rec[u'SkillTriggeredBy9'] = self.SkillTriggeredBy9
|
rec[u'SkillTriggeredBy10'] = self.SkillTriggeredBy10
|
|
return rec
|
|
|
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_146, 'tagSuiteEffect Insert failed!SuiteID = %s, error = %s, trycnt = %d'%(self.SuiteID, err, trycnt))
|
mylog.error(msg)
|
|
return False
|
return True
|
|
|
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(tagSuiteEffect)
|
|
|
def readData(self, buf, pos):
|
if len(buf) < pos + self.getLength():
|
msg = error.formatMsg('error', error.ERROR_NO_147, 'len = %s while %s expected!'%(len(buf) - pos, self.getLength()))
|
mylog.error(msg)
|
return -1
|
self.clear()
|
memmove(addressof(self), buf[pos:], self.getLength())
|
return pos + self.getLength()
|
|
def outputString(self):
|
output = '''//×°±¸Ì×װЧ¹û±í#tagSuiteEffect:
|
SuiteID = %s,
|
SkillTriggeredBy2 = %s,
|
SkillTriggeredBy3 = %s,
|
SkillTriggeredBy4 = %s,
|
SkillTriggeredBy5 = %s,
|
SkillTriggeredBy6 = %s,
|
SkillTriggeredBy7 = %s,
|
SkillTriggeredBy8 = %s,
|
SkillTriggeredBy9 = %s,
|
SkillTriggeredBy10 = %s,
|
ADOResult = %s,
|
'''%(
|
self.SuiteID,
|
self.SkillTriggeredBy2,
|
self.SkillTriggeredBy3,
|
self.SkillTriggeredBy4,
|
self.SkillTriggeredBy5,
|
self.SkillTriggeredBy6,
|
self.SkillTriggeredBy7,
|
self.SkillTriggeredBy8,
|
self.SkillTriggeredBy9,
|
self.SkillTriggeredBy10,
|
self.ADOResult
|
)
|
return output
|
|
|
#------------------------------------------------------
|
#¾ÑéÊý¾Ý#tagChinExp
|
class tagChinExp(Structure):
|
_pack_ = 1
|
_fields_ = [
|
('LV', c_ushort),
|
('TotalExp', c_ulong),
|
('ReExp', c_ulong),
|
('ReMoney', c_ulong),
|
('ADOResult', c_ulong),
|
]
|
|
def __init__(self):
|
Structure.__init__(self)
|
self.clear()
|
|
def clear(self):
|
memset(addressof(self), 0, self.getLength())
|
|
|
def readLine(self, line):
|
self.clear()
|
wordList = line.split(SPLITCHAR)
|
try:
|
self.LV = int(wordList[0].strip())
|
self.TotalExp = int(wordList[1].strip())
|
self.ReExp = int(wordList[2].strip())
|
self.ReMoney = int(wordList[3].strip())
|
|
except IndexError,e:
|
errorStr = '''\nIndexError:%s [lineData:"%s"]'''%(e, line)
|
raise Exception(errorStr)
|
except:
|
errorStr = '''\nException on readLine:[lineData:"%s"]\n%s'''%(line,traceback.format_exc())
|
raise Exception(errorStr)
|
|
|
def __getRecord(self):
|
'''×éÖ¯´æ´¢¼Ç¼'''
|
rec = {}
|
rec[u'LV'] = self.LV
|
rec[u'TotalExp'] = self.TotalExp
|
rec[u'ReExp'] = self.ReExp
|
rec[u'ReMoney'] = self.ReMoney
|
|
return rec
|
|
|
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_146, 'tagChinExp Insert failed!LV = %s, error = %s, trycnt = %d'%(self.LV, err, trycnt))
|
mylog.error(msg)
|
|
return False
|
return True
|
|
|
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(tagChinExp)
|
|
|
def readData(self, buf, pos):
|
if len(buf) < pos + self.getLength():
|
msg = error.formatMsg('error', error.ERROR_NO_147, 'len = %s while %s expected!'%(len(buf) - pos, self.getLength()))
|
mylog.error(msg)
|
return -1
|
self.clear()
|
memmove(addressof(self), buf[pos:], self.getLength())
|
return pos + self.getLength()
|
|
def outputString(self):
|
output = '''//¾ÑéÊý¾Ý#tagChinExp:
|
LV = %s,
|
TotalExp = %s,
|
ReExp = %s,
|
ReMoney = %s,
|
ADOResult = %s,
|
'''%(
|
self.LV,
|
self.TotalExp,
|
self.ReExp,
|
self.ReMoney,
|
self.ADOResult
|
)
|
return output
|
|
|
|
#------------------------------------------------------
|
#ÎïÆ·#tagChinItem
|
class tagChinItem(Structure):
|
_pack_ = 1
|
_fields_ = [
|
('ID', c_ulong),
|
('LV', c_ushort),
|
('Identify', c_ubyte),
|
('Name', c_char * 24),
|
('Type', c_ubyte),
|
('EquipPlace', c_ubyte),
|
('CanNPCDrop', c_ubyte),
|
('CanIdentifyAppear', c_ubyte),
|
('CanRepair', c_ubyte),
|
('PackCount', c_ushort),
|
('UseLV', c_ushort),
|
('CanSell', c_ubyte),
|
('CanTrade', c_ubyte),
|
('CanDrop', c_ubyte),
|
('CanBind', c_ubyte),
|
('CanRenZhu', c_ubyte),
|
('DieDrop', c_ubyte),
|
('CanPlaceInShortcut', c_ubyte),
|
('CDType', c_ubyte),
|
('CDTime', c_ulong),
|
('PriceGene', c_ushort),
|
('GoldPrice', c_ulong),
|
('GoldPaperPrice', c_ulong),
|
('SilverPrice', c_ulong),
|
('SilverPaperPrice', c_ulong),
|
('UseTag', c_ubyte),
|
('UseDist', c_ushort),
|
('CanInsertHole', c_ubyte),
|
('Effect1', c_ulong),
|
('EffectValueA1', c_ulong),
|
('EffectValueB1', c_ulong),
|
('EffectValueC1', c_ulong),
|
('Effect2', c_ulong),
|
('EffectValueA2', c_ulong),
|
('EffectValueB2', c_ulong),
|
('EffectValueC2', c_ulong),
|
('Effect3', c_ulong),
|
('EffectValueA3', c_ulong),
|
('EffectValueB3', c_ulong),
|
('EffectValueC3', c_ulong),
|
('Effect4', c_ulong),
|
('EffectValueA4', c_ulong),
|
('EffectValueB4', c_ulong),
|
('EffectValueC4', c_ulong),
|
('Effect5', c_ulong),
|
('EffectValueA5', c_ulong),
|
('EffectValueB5', c_ulong),
|
('EffectValueC5', c_ulong),
|
('AddSkill1', c_ulong),
|
('AddSkill2', c_ulong),
|
('AddSkill3', c_ulong),
|
('AddSkill4', c_ulong),
|
('AddSkill5', c_ulong),
|
('JobLimit', c_ulong),
|
('EventCanUse', c_ubyte),
|
('SexReq', c_ubyte),
|
('ItemColor', c_ubyte),
|
('ItemQuality', c_ubyte),
|
('MaxHoleCount', c_ubyte),
|
('CanBreak', c_ubyte),
|
('MaxEndure', c_ulong),
|
('EndureReduceType', c_ubyte),
|
('NoEndureDisappear', c_ubyte),
|
('UseRestrict', c_ubyte),
|
('IsSoulOfWar', c_ubyte),
|
('ReincarnationLv', c_ushort),
|
('BindType', c_ubyte),
|
('MaxAddSkillCnt', c_ubyte),
|
('ExpireTime', c_ulong),
|
('MaxFitLV', c_ubyte),
|
('SuiteID', c_ulong),
|
('Weight', c_ulong),
|
('LimitSTR', c_ulong),
|
('LimitPHY', c_ulong),
|
('LimitPNE', c_ulong),
|
('IsBothHands', c_ubyte),
|
('ADOResult', c_ulong),
|
]
|
|
def __init__(self):
|
Structure.__init__(self)
|
self.clear()
|
|
def clear(self):
|
memset(addressof(self), 0, self.getLength())
|
|
|
def readLine(self, line):
|
self.clear()
|
wordList = line.split(SPLITCHAR)
|
try:
|
self.ID = int(wordList[0].strip())
|
self.LV = int(wordList[1].strip())
|
self.Identify = int(wordList[2].strip())
|
self.Name = wordList[3].strip()
|
self.Type = int(wordList[4].strip())
|
self.EquipPlace = int(wordList[5].strip())
|
self.CanNPCDrop = int(wordList[6].strip())
|
self.CanIdentifyAppear = int(wordList[7].strip())
|
self.CanRepair = int(wordList[8].strip())
|
self.PackCount = int(wordList[9].strip())
|
self.UseLV = int(wordList[10].strip())
|
self.CanSell = int(wordList[11].strip())
|
self.CanTrade = int(wordList[12].strip())
|
self.CanDrop = int(wordList[13].strip())
|
self.CanBind = int(wordList[14].strip())
|
self.CanRenZhu = int(wordList[15].strip())
|
self.DieDrop = int(wordList[16].strip())
|
self.CanPlaceInShortcut = int(wordList[17].strip())
|
self.CDType = int(wordList[18].strip())
|
self.CDTime = int(wordList[19].strip())
|
self.PriceGene = int(wordList[20].strip())
|
self.GoldPrice = int(wordList[21].strip())
|
self.GoldPaperPrice = int(wordList[22].strip())
|
self.SilverPrice = int(wordList[23].strip())
|
self.SilverPaperPrice = int(wordList[24].strip())
|
self.UseTag = int(wordList[25].strip())
|
self.UseDist = int(wordList[26].strip())
|
self.CanInsertHole = int(wordList[27].strip())
|
self.Effect1 = int(wordList[28].strip())
|
self.EffectValueA1 = int(wordList[29].strip())
|
self.EffectValueB1 = int(wordList[30].strip())
|
self.EffectValueC1 = int(wordList[31].strip())
|
self.Effect2 = int(wordList[32].strip())
|
self.EffectValueA2 = int(wordList[33].strip())
|
self.EffectValueB2 = int(wordList[34].strip())
|
self.EffectValueC2 = int(wordList[35].strip())
|
self.Effect3 = int(wordList[36].strip())
|
self.EffectValueA3 = int(wordList[37].strip())
|
self.EffectValueB3 = int(wordList[38].strip())
|
self.EffectValueC3 = int(wordList[39].strip())
|
self.Effect4 = int(wordList[40].strip())
|
self.EffectValueA4 = int(wordList[41].strip())
|
self.EffectValueB4 = int(wordList[42].strip())
|
self.EffectValueC4 = int(wordList[43].strip())
|
self.Effect5 = int(wordList[44].strip())
|
self.EffectValueA5 = int(wordList[45].strip())
|
self.EffectValueB5 = int(wordList[46].strip())
|
self.EffectValueC5 = int(wordList[47].strip())
|
self.AddSkill1 = int(wordList[48].strip())
|
self.AddSkill2 = int(wordList[49].strip())
|
self.AddSkill3 = int(wordList[50].strip())
|
self.AddSkill4 = int(wordList[51].strip())
|
self.AddSkill5 = int(wordList[52].strip())
|
self.JobLimit = int(wordList[53].strip())
|
self.EventCanUse = int(wordList[54].strip())
|
self.SexReq = int(wordList[55].strip())
|
self.ItemColor = int(wordList[56].strip())
|
self.ItemQuality = int(wordList[57].strip())
|
self.MaxHoleCount = int(wordList[58].strip())
|
self.CanBreak = int(wordList[59].strip())
|
self.MaxEndure = int(wordList[60].strip())
|
self.EndureReduceType = int(wordList[61].strip())
|
self.NoEndureDisappear = int(wordList[62].strip())
|
self.UseRestrict = int(wordList[63].strip())
|
self.IsSoulOfWar = int(wordList[64].strip())
|
self.ReincarnationLv = int(wordList[65].strip())
|
self.BindType = int(wordList[66].strip())
|
self.MaxAddSkillCnt = int(wordList[67].strip())
|
self.ExpireTime = int(wordList[68].strip())
|
self.MaxFitLV = int(wordList[69].strip())
|
self.SuiteID = int(wordList[70].strip())
|
self.Weight = int(wordList[71].strip())
|
self.LimitSTR = int(wordList[72].strip())
|
self.LimitPHY = int(wordList[73].strip())
|
self.LimitPNE = int(wordList[74].strip())
|
self.IsBothHands = int(wordList[75].strip())
|
|
except IndexError,e:
|
errorStr = '''\nIndexError:%s [lineData:"%s"]'''%(e, line)
|
raise Exception(errorStr)
|
except:
|
errorStr = '''\nException on readLine:[lineData:"%s"]\n%s'''%(line,traceback.format_exc())
|
raise Exception(errorStr)
|
|
|
def __getRecord(self):
|
'''×éÖ¯´æ´¢¼Ç¼'''
|
rec = {}
|
rec[u'ID'] = self.ID
|
rec[u'LV'] = self.LV
|
rec[u'Identify'] = self.Identify
|
rec[u'Name'] = fix_incomingText(self.Name)
|
rec[u'Type'] = self.Type
|
rec[u'EquipPlace'] = self.EquipPlace
|
rec[u'CanNPCDrop'] = self.CanNPCDrop
|
rec[u'CanIdentifyAppear'] = self.CanIdentifyAppear
|
rec[u'CanRepair'] = self.CanRepair
|
rec[u'PackCount'] = self.PackCount
|
rec[u'UseLV'] = self.UseLV
|
rec[u'CanSell'] = self.CanSell
|
rec[u'CanTrade'] = self.CanTrade
|
rec[u'CanDrop'] = self.CanDrop
|
rec[u'CanBind'] = self.CanBind
|
rec[u'CanRenZhu'] = self.CanRenZhu
|
rec[u'DieDrop'] = self.DieDrop
|
rec[u'CanPlaceInShortcut'] = self.CanPlaceInShortcut
|
rec[u'CDType'] = self.CDType
|
rec[u'CDTime'] = self.CDTime
|
rec[u'PriceGene'] = self.PriceGene
|
rec[u'GoldPrice'] = self.GoldPrice
|
rec[u'GoldPaperPrice'] = self.GoldPaperPrice
|
rec[u'SilverPrice'] = self.SilverPrice
|
rec[u'SilverPaperPrice'] = self.SilverPaperPrice
|
rec[u'UseTag'] = self.UseTag
|
rec[u'UseDist'] = self.UseDist
|
rec[u'CanInsertHole'] = self.CanInsertHole
|
rec[u'Effect1'] = self.Effect1
|
rec[u'EffectValueA1'] = self.EffectValueA1
|
rec[u'EffectValueB1'] = self.EffectValueB1
|
rec[u'EffectValueC1'] = self.EffectValueC1
|
rec[u'Effect2'] = self.Effect2
|
rec[u'EffectValueA2'] = self.EffectValueA2
|
rec[u'EffectValueB2'] = self.EffectValueB2
|
rec[u'EffectValueC2'] = self.EffectValueC2
|
rec[u'Effect3'] = self.Effect3
|
rec[u'EffectValueA3'] = self.EffectValueA3
|
rec[u'EffectValueB3'] = self.EffectValueB3
|
rec[u'EffectValueC3'] = self.EffectValueC3
|
rec[u'Effect4'] = self.Effect4
|
rec[u'EffectValueA4'] = self.EffectValueA4
|
rec[u'EffectValueB4'] = self.EffectValueB4
|
rec[u'EffectValueC4'] = self.EffectValueC4
|
rec[u'Effect5'] = self.Effect5
|
rec[u'EffectValueA5'] = self.EffectValueA5
|
rec[u'EffectValueB5'] = self.EffectValueB5
|
rec[u'EffectValueC5'] = self.EffectValueC5
|
rec[u'AddSkill1'] = self.AddSkill1
|
rec[u'AddSkill2'] = self.AddSkill2
|
rec[u'AddSkill3'] = self.AddSkill3
|
rec[u'AddSkill4'] = self.AddSkill4
|
rec[u'AddSkill5'] = self.AddSkill5
|
rec[u'JobLimit'] = self.JobLimit
|
rec[u'EventCanUse'] = self.EventCanUse
|
rec[u'SexReq'] = self.SexReq
|
rec[u'ItemColor'] = self.ItemColor
|
rec[u'ItemQuality'] = self.ItemQuality
|
rec[u'MaxHoleCount'] = self.MaxHoleCount
|
rec[u'CanBreak'] = self.CanBreak
|
rec[u'MaxEndure'] = self.MaxEndure
|
rec[u'EndureReduceType'] = self.EndureReduceType
|
rec[u'NoEndureDisappear'] = self.NoEndureDisappear
|
rec[u'UseRestrict'] = self.UseRestrict
|
rec[u'IsSoulOfWar'] = self.IsSoulOfWar
|
rec[u'ReincarnationLv'] = self.ReincarnationLv
|
rec[u'BindType'] = self.BindType
|
rec[u'MaxAddSkillCnt'] = self.MaxAddSkillCnt
|
rec[u'ExpireTime'] = self.ExpireTime
|
rec[u'MaxFitLV'] = self.MaxFitLV
|
rec[u'SuiteID'] = self.SuiteID
|
rec[u'Weight'] = self.Weight
|
rec[u'LimitSTR'] = self.LimitSTR
|
rec[u'LimitPHY'] = self.LimitPHY
|
rec[u'LimitPNE'] = self.LimitPNE
|
rec[u'IsBothHands'] = self.IsBothHands
|
|
return rec
|
|
|
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_146, 'tagChinItem Insert failed!ID = %s, error = %s, trycnt = %d'%(self.ID, err, trycnt))
|
mylog.error(msg)
|
|
return False
|
return True
|
|
|
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(tagChinItem)
|
|
|
def readData(self, buf, pos):
|
if len(buf) < pos + self.getLength():
|
msg = error.formatMsg('error', error.ERROR_NO_147, 'len = %s while %s expected!'%(len(buf) - pos, self.getLength()))
|
mylog.error(msg)
|
return -1
|
self.clear()
|
memmove(addressof(self), buf[pos:], self.getLength())
|
return pos + self.getLength()
|
|
def outputString(self):
|
output = '''//ÎïÆ·#tagChinItem:
|
ID = %s,
|
LV = %s,
|
Identify = %s,
|
Name = %s,
|
Type = %s,
|
EquipPlace = %s,
|
CanNPCDrop = %s,
|
CanIdentifyAppear = %s,
|
CanRepair = %s,
|
PackCount = %s,
|
UseLV = %s,
|
CanSell = %s,
|
CanTrade = %s,
|
CanDrop = %s,
|
CanBind = %s,
|
CanRenZhu = %s,
|
DieDrop = %s,
|
CanPlaceInShortcut = %s,
|
CDType = %s,
|
CDTime = %s,
|
PriceGene = %s,
|
GoldPrice = %s,
|
GoldPaperPrice = %s,
|
SilverPrice = %s,
|
SilverPaperPrice = %s,
|
UseTag = %s,
|
UseDist = %s,
|
CanInsertHole = %s,
|
Effect1 = %s,
|
EffectValueA1 = %s,
|
EffectValueB1 = %s,
|
EffectValueC1 = %s,
|
Effect2 = %s,
|
EffectValueA2 = %s,
|
EffectValueB2 = %s,
|
EffectValueC2 = %s,
|
Effect3 = %s,
|
EffectValueA3 = %s,
|
EffectValueB3 = %s,
|
EffectValueC3 = %s,
|
Effect4 = %s,
|
EffectValueA4 = %s,
|
EffectValueB4 = %s,
|
EffectValueC4 = %s,
|
Effect5 = %s,
|
EffectValueA5 = %s,
|
EffectValueB5 = %s,
|
EffectValueC5 = %s,
|
AddSkill1 = %s,
|
AddSkill2 = %s,
|
AddSkill3 = %s,
|
AddSkill4 = %s,
|
AddSkill5 = %s,
|
JobLimit = %s,
|
EventCanUse = %s,
|
SexReq = %s,
|
ItemColor = %s,
|
ItemQuality = %s,
|
MaxHoleCount = %s,
|
CanBreak = %s,
|
MaxEndure = %s,
|
EndureReduceType = %s,
|
NoEndureDisappear = %s,
|
UseRestrict = %s,
|
IsSoulOfWar = %s,
|
ReincarnationLv = %s,
|
BindType = %s,
|
MaxAddSkillCnt = %s,
|
ExpireTime = %s,
|
MaxFitLV = %s,
|
SuiteID = %s,
|
Weight = %s,
|
LimitSTR = %s,
|
LimitPHY = %s,
|
LimitPNE = %s,
|
IsBothHands = %s,
|
ADOResult = %s,
|
'''%(
|
self.ID,
|
self.LV,
|
self.Identify,
|
self.Name,
|
self.Type,
|
self.EquipPlace,
|
self.CanNPCDrop,
|
self.CanIdentifyAppear,
|
self.CanRepair,
|
self.PackCount,
|
self.UseLV,
|
self.CanSell,
|
self.CanTrade,
|
self.CanDrop,
|
self.CanBind,
|
self.CanRenZhu,
|
self.DieDrop,
|
self.CanPlaceInShortcut,
|
self.CDType,
|
self.CDTime,
|
self.PriceGene,
|
self.GoldPrice,
|
self.GoldPaperPrice,
|
self.SilverPrice,
|
self.SilverPaperPrice,
|
self.UseTag,
|
self.UseDist,
|
self.CanInsertHole,
|
self.Effect1,
|
self.EffectValueA1,
|
self.EffectValueB1,
|
self.EffectValueC1,
|
self.Effect2,
|
self.EffectValueA2,
|
self.EffectValueB2,
|
self.EffectValueC2,
|
self.Effect3,
|
self.EffectValueA3,
|
self.EffectValueB3,
|
self.EffectValueC3,
|
self.Effect4,
|
self.EffectValueA4,
|
self.EffectValueB4,
|
self.EffectValueC4,
|
self.Effect5,
|
self.EffectValueA5,
|
self.EffectValueB5,
|
self.EffectValueC5,
|
self.AddSkill1,
|
self.AddSkill2,
|
self.AddSkill3,
|
self.AddSkill4,
|
self.AddSkill5,
|
self.JobLimit,
|
self.EventCanUse,
|
self.SexReq,
|
self.ItemColor,
|
self.ItemQuality,
|
self.MaxHoleCount,
|
self.CanBreak,
|
self.MaxEndure,
|
self.EndureReduceType,
|
self.NoEndureDisappear,
|
self.UseRestrict,
|
self.IsSoulOfWar,
|
self.ReincarnationLv,
|
self.BindType,
|
self.MaxAddSkillCnt,
|
self.ExpireTime,
|
self.MaxFitLV,
|
self.SuiteID,
|
self.Weight,
|
self.LimitSTR,
|
self.LimitPHY,
|
self.LimitPNE,
|
self.IsBothHands,
|
self.ADOResult
|
)
|
return output
|
|
|
#------------------------------------------------------
|
#NPCÊý¾Ý#tagChinNPC
|
class tagChinNPC(Structure):
|
_pack_ = 1
|
_fields_ = [
|
('NPCID', c_ulong),
|
('Type', c_ubyte),
|
('FunctionType', c_ulong),
|
('Name', c_char * 24),
|
('LV', c_ushort),
|
('Country', c_ubyte),
|
('MinAtk', c_int),
|
('MaxAtk', c_int),
|
('Def', c_int),
|
('MAtkMin', c_int),
|
('MAtkMax', c_int),
|
('MDef', c_int),
|
('PoisionAtk', c_int),
|
('FireAtk', c_int),
|
('IceAtk', c_int),
|
('ThunderAtk', c_int),
|
('WindAtk', c_int),
|
('PoisionDef', c_int),
|
('FireDef', c_int),
|
('IceDef', c_int),
|
('ThunderDef', c_int),
|
('WindDef', c_int),
|
('AtkInterval', c_ushort),
|
('Hit', c_ulong),
|
('MissRate', c_ulong),
|
('SuperHiteRate', c_ushort),
|
('OrgSpeed', c_ushort),
|
('MoveType', c_ubyte),
|
('AtkDist', c_ubyte),
|
('Skill1', c_ushort),
|
('Skill2', c_ushort),
|
('Skill3', c_ushort),
|
('Skill4', c_ushort),
|
('Skill5', c_ushort),
|
('Skill6', c_ushort),
|
('Skill7', c_ushort),
|
('Skill8', c_ushort),
|
('AtkType', c_ubyte),
|
('Sight', c_ubyte),
|
('MoveArea', c_ushort),
|
('HP', c_ulong),
|
('HPEx', c_ulong),
|
('HPRestore', c_ushort),
|
('AttentionRefreshID', c_ushort),
|
('EventArea', c_ushort),
|
('IsBoss', c_ubyte),
|
('Exp', c_ulong),
|
('SP', c_ulong),
|
('AIType', c_ubyte),
|
('CanAttack', c_ubyte),
|
('HurtType', c_ubyte),
|
('ADOResult', c_ulong),
|
]
|
|
def __init__(self):
|
Structure.__init__(self)
|
self.clear()
|
|
def clear(self):
|
memset(addressof(self), 0, self.getLength())
|
|
|
def readLine(self, line):
|
self.clear()
|
wordList = line.split(SPLITCHAR)
|
try:
|
self.NPCID = int(wordList[0].strip())
|
self.Type = int(wordList[1].strip())
|
self.FunctionType = int(wordList[2].strip())
|
self.Name = wordList[3].strip()
|
self.LV = int(wordList[4].strip())
|
self.Country = int(wordList[5].strip())
|
self.MinAtk = int(wordList[6].strip())
|
self.MaxAtk = int(wordList[7].strip())
|
self.Def = int(wordList[8].strip())
|
self.MAtkMin = int(wordList[9].strip())
|
self.MAtkMax = int(wordList[10].strip())
|
self.MDef = int(wordList[11].strip())
|
self.PoisionAtk = int(wordList[12].strip())
|
self.FireAtk = int(wordList[13].strip())
|
self.IceAtk = int(wordList[14].strip())
|
self.ThunderAtk = int(wordList[15].strip())
|
self.WindAtk = int(wordList[16].strip())
|
self.PoisionDef = int(wordList[17].strip())
|
self.FireDef = int(wordList[18].strip())
|
self.IceDef = int(wordList[19].strip())
|
self.ThunderDef = int(wordList[20].strip())
|
self.WindDef = int(wordList[21].strip())
|
self.AtkInterval = int(wordList[22].strip())
|
self.Hit = int(wordList[23].strip())
|
self.MissRate = int(wordList[24].strip())
|
self.SuperHiteRate = int(wordList[25].strip())
|
self.OrgSpeed = int(wordList[26].strip())
|
self.MoveType = int(wordList[27].strip())
|
self.AtkDist = int(wordList[28].strip())
|
self.Skill1 = int(wordList[29].strip())
|
self.Skill2 = int(wordList[30].strip())
|
self.Skill3 = int(wordList[31].strip())
|
self.Skill4 = int(wordList[32].strip())
|
self.Skill5 = int(wordList[33].strip())
|
self.Skill6 = int(wordList[34].strip())
|
self.Skill7 = int(wordList[35].strip())
|
self.Skill8 = int(wordList[36].strip())
|
self.AtkType = int(wordList[37].strip())
|
self.Sight = int(wordList[38].strip())
|
self.MoveArea = int(wordList[39].strip())
|
self.HP = int(wordList[40].strip())
|
self.HPEx = int(wordList[41].strip())
|
self.HPRestore = int(wordList[42].strip())
|
self.AttentionRefreshID = int(wordList[43].strip())
|
self.EventArea = int(wordList[44].strip())
|
self.IsBoss = int(wordList[45].strip())
|
self.Exp = int(wordList[46].strip())
|
self.SP = int(wordList[47].strip())
|
self.AIType = int(wordList[48].strip())
|
self.CanAttack = int(wordList[49].strip())
|
self.HurtType = int(wordList[50].strip())
|
|
except IndexError,e:
|
errorStr = '''\nIndexError:%s [lineData:"%s"]'''%(e, line)
|
raise Exception(errorStr)
|
except:
|
errorStr = '''\nException on readLine:[lineData:"%s"]\n%s'''%(line,traceback.format_exc())
|
raise Exception(errorStr)
|
|
|
def __getRecord(self):
|
'''×éÖ¯´æ´¢¼Ç¼'''
|
rec = {}
|
rec[u'NPCID'] = self.NPCID
|
rec[u'Type'] = self.Type
|
rec[u'FunctionType'] = self.FunctionType
|
rec[u'Name'] = fix_incomingText(self.Name)
|
rec[u'LV'] = self.LV
|
rec[u'Country'] = self.Country
|
rec[u'MinAtk'] = self.MinAtk
|
rec[u'MaxAtk'] = self.MaxAtk
|
rec[u'Def'] = self.Def
|
rec[u'MAtkMin'] = self.MAtkMin
|
rec[u'MAtkMax'] = self.MAtkMax
|
rec[u'MDef'] = self.MDef
|
rec[u'PoisionAtk'] = self.PoisionAtk
|
rec[u'FireAtk'] = self.FireAtk
|
rec[u'IceAtk'] = self.IceAtk
|
rec[u'ThunderAtk'] = self.ThunderAtk
|
rec[u'WindAtk'] = self.WindAtk
|
rec[u'PoisionDef'] = self.PoisionDef
|
rec[u'FireDef'] = self.FireDef
|
rec[u'IceDef'] = self.IceDef
|
rec[u'ThunderDef'] = self.ThunderDef
|
rec[u'WindDef'] = self.WindDef
|
rec[u'AtkInterval'] = self.AtkInterval
|
rec[u'Hit'] = self.Hit
|
rec[u'MissRate'] = self.MissRate
|
rec[u'SuperHiteRate'] = self.SuperHiteRate
|
rec[u'OrgSpeed'] = self.OrgSpeed
|
rec[u'MoveType'] = self.MoveType
|
rec[u'AtkDist'] = self.AtkDist
|
rec[u'Skill1'] = self.Skill1
|
rec[u'Skill2'] = self.Skill2
|
rec[u'Skill3'] = self.Skill3
|
rec[u'Skill4'] = self.Skill4
|
rec[u'Skill5'] = self.Skill5
|
rec[u'Skill6'] = self.Skill6
|
rec[u'Skill7'] = self.Skill7
|
rec[u'Skill8'] = self.Skill8
|
rec[u'AtkType'] = self.AtkType
|
rec[u'Sight'] = self.Sight
|
rec[u'MoveArea'] = self.MoveArea
|
rec[u'HP'] = self.HP
|
rec[u'HPEx'] = self.HPEx
|
rec[u'HPRestore'] = self.HPRestore
|
rec[u'AttentionRefreshID'] = self.AttentionRefreshID
|
rec[u'EventArea'] = self.EventArea
|
rec[u'IsBoss'] = self.IsBoss
|
rec[u'Exp'] = self.Exp
|
rec[u'SP'] = self.SP
|
rec[u'AIType'] = self.AIType
|
rec[u'CanAttack'] = self.CanAttack
|
rec[u'HurtType'] = self.HurtType
|
|
return rec
|
|
|
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_146, 'tagChinNPC Insert failed!NPCID = %s, error = %s, trycnt = %d'%(self.NPCID, err, trycnt))
|
mylog.error(msg)
|
|
return False
|
return True
|
|
|
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(tagChinNPC)
|
|
|
def readData(self, buf, pos):
|
if len(buf) < pos + self.getLength():
|
msg = error.formatMsg('error', error.ERROR_NO_147, 'len = %s while %s expected!'%(len(buf) - pos, self.getLength()))
|
mylog.error(msg)
|
return -1
|
self.clear()
|
memmove(addressof(self), buf[pos:], self.getLength())
|
return pos + self.getLength()
|
|
def outputString(self):
|
output = '''//NPCÊý¾Ý#tagChinNPC:
|
NPCID = %s,
|
Type = %s,
|
FunctionType = %s,
|
Name = %s,
|
LV = %s,
|
Country = %s,
|
MinAtk = %s,
|
MaxAtk = %s,
|
Def = %s,
|
MAtkMin = %s,
|
MAtkMax = %s,
|
MDef = %s,
|
PoisionAtk = %s,
|
FireAtk = %s,
|
IceAtk = %s,
|
ThunderAtk = %s,
|
WindAtk = %s,
|
PoisionDef = %s,
|
FireDef = %s,
|
IceDef = %s,
|
ThunderDef = %s,
|
WindDef = %s,
|
AtkInterval = %s,
|
Hit = %s,
|
MissRate = %s,
|
SuperHiteRate = %s,
|
OrgSpeed = %s,
|
MoveType = %s,
|
AtkDist = %s,
|
Skill1 = %s,
|
Skill2 = %s,
|
Skill3 = %s,
|
Skill4 = %s,
|
Skill5 = %s,
|
Skill6 = %s,
|
Skill7 = %s,
|
Skill8 = %s,
|
AtkType = %s,
|
Sight = %s,
|
MoveArea = %s,
|
HP = %s,
|
HPEx = %s,
|
HPRestore = %s,
|
AttentionRefreshID = %s,
|
EventArea = %s,
|
IsBoss = %s,
|
Exp = %s,
|
SP = %s,
|
AIType = %s,
|
CanAttack = %s,
|
HurtType = %s,
|
ADOResult = %s,
|
'''%(
|
self.NPCID,
|
self.Type,
|
self.FunctionType,
|
self.Name,
|
self.LV,
|
self.Country,
|
self.MinAtk,
|
self.MaxAtk,
|
self.Def,
|
self.MAtkMin,
|
self.MAtkMax,
|
self.MDef,
|
self.PoisionAtk,
|
self.FireAtk,
|
self.IceAtk,
|
self.ThunderAtk,
|
self.WindAtk,
|
self.PoisionDef,
|
self.FireDef,
|
self.IceDef,
|
self.ThunderDef,
|
self.WindDef,
|
self.AtkInterval,
|
self.Hit,
|
self.MissRate,
|
self.SuperHiteRate,
|
self.OrgSpeed,
|
self.MoveType,
|
self.AtkDist,
|
self.Skill1,
|
self.Skill2,
|
self.Skill3,
|
self.Skill4,
|
self.Skill5,
|
self.Skill6,
|
self.Skill7,
|
self.Skill8,
|
self.AtkType,
|
self.Sight,
|
self.MoveArea,
|
self.HP,
|
self.HPEx,
|
self.HPRestore,
|
self.AttentionRefreshID,
|
self.EventArea,
|
self.IsBoss,
|
self.Exp,
|
self.SP,
|
self.AIType,
|
self.CanAttack,
|
self.HurtType,
|
self.ADOResult
|
)
|
return output
|
|
|
|
#------------------------------------------------------
|
#NPCË¢ÐÂ#tagNPCRefresh
|
class tagNPCRefresh(Structure):
|
_pack_ = 1
|
_fields_ = [
|
('RefreshID', c_ulong),
|
('NPCID', c_ulong),
|
('MapID', c_ushort),
|
('RefreshType', c_ubyte),
|
('RefreshPos', c_char * 100),
|
('RefreshTotal', c_ushort),
|
('RefreshCount', c_ushort),
|
('RefreshTimeType', c_ubyte),
|
('RefreshTime', c_ulong),
|
('StartTime', c_ulong),
|
('EndTime', c_ulong),
|
('PatrolType', c_ubyte),
|
('PatrolPos', c_char * 100),
|
('MinStopTime', c_ushort),
|
('MaxStopTime', c_ushort),
|
('RefreshDir', c_ubyte),
|
('RefreshMark', c_ulong),
|
('ADOResult', c_ulong),
|
]
|
|
def __init__(self):
|
Structure.__init__(self)
|
self.clear()
|
|
def clear(self):
|
memset(addressof(self), 0, self.getLength())
|
|
|
def readLine(self, line):
|
self.clear()
|
wordList = line.split(SPLITCHAR)
|
try:
|
self.RefreshID = int(wordList[0].strip())
|
self.NPCID = int(wordList[1].strip())
|
self.MapID = int(wordList[2].strip())
|
self.RefreshType = int(wordList[3].strip())
|
self.RefreshPos = wordList[4].strip()
|
self.RefreshTotal = int(wordList[5].strip())
|
self.RefreshCount = int(wordList[6].strip())
|
self.RefreshTimeType = int(wordList[7].strip())
|
self.RefreshTime = int(wordList[8].strip())
|
self.StartTime = int(wordList[9].strip())
|
self.EndTime = int(wordList[10].strip())
|
self.PatrolType = int(wordList[11].strip())
|
self.PatrolPos = wordList[12].strip()
|
self.MinStopTime = int(wordList[13].strip())
|
self.MaxStopTime = int(wordList[14].strip())
|
self.RefreshDir = int(wordList[15].strip())
|
self.RefreshMark = int(wordList[16].strip())
|
|
except IndexError,e:
|
errorStr = '''\nIndexError:%s [lineData:"%s"]'''%(e, line)
|
raise Exception(errorStr)
|
except:
|
errorStr = '''\nException on readLine:[lineData:"%s"]\n%s'''%(line,traceback.format_exc())
|
raise Exception(errorStr)
|
|
|
def __getRecord(self):
|
'''×éÖ¯´æ´¢¼Ç¼'''
|
rec = {}
|
rec[u'RefreshID'] = self.RefreshID
|
rec[u'NPCID'] = self.NPCID
|
rec[u'MapID'] = self.MapID
|
rec[u'RefreshType'] = self.RefreshType
|
rec[u'RefreshPos'] = fix_incomingText(self.RefreshPos)
|
rec[u'RefreshTotal'] = self.RefreshTotal
|
rec[u'RefreshCount'] = self.RefreshCount
|
rec[u'RefreshTimeType'] = self.RefreshTimeType
|
rec[u'RefreshTime'] = self.RefreshTime
|
rec[u'StartTime'] = self.StartTime
|
rec[u'EndTime'] = self.EndTime
|
rec[u'PatrolType'] = self.PatrolType
|
rec[u'PatrolPos'] = fix_incomingText(self.PatrolPos)
|
rec[u'MinStopTime'] = self.MinStopTime
|
rec[u'MaxStopTime'] = self.MaxStopTime
|
rec[u'RefreshDir'] = self.RefreshDir
|
rec[u'RefreshMark'] = self.RefreshMark
|
|
return rec
|
|
|
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_146, 'tagNPCRefresh Insert failed!RefreshID = %s, error = %s, trycnt = %d'%(self.RefreshID, err, trycnt))
|
mylog.error(msg)
|
|
return False
|
return True
|
|
|
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(tagNPCRefresh)
|
|
|
def readData(self, buf, pos):
|
if len(buf) < pos + self.getLength():
|
msg = error.formatMsg('error', error.ERROR_NO_147, 'len = %s while %s expected!'%(len(buf) - pos, self.getLength()))
|
mylog.error(msg)
|
return -1
|
self.clear()
|
memmove(addressof(self), buf[pos:], self.getLength())
|
return pos + self.getLength()
|
|
def outputString(self):
|
output = '''//NPCË¢ÐÂ#tagNPCRefresh:
|
RefreshID = %s,
|
NPCID = %s,
|
MapID = %s,
|
RefreshType = %s,
|
RefreshPos = %s,
|
RefreshTotal = %s,
|
RefreshCount = %s,
|
RefreshTimeType = %s,
|
RefreshTime = %s,
|
StartTime = %s,
|
EndTime = %s,
|
PatrolType = %s,
|
PatrolPos = %s,
|
MinStopTime = %s,
|
MaxStopTime = %s,
|
RefreshDir = %s,
|
RefreshMark = %s,
|
ADOResult = %s,
|
'''%(
|
self.RefreshID,
|
self.NPCID,
|
self.MapID,
|
self.RefreshType,
|
self.RefreshPos,
|
self.RefreshTotal,
|
self.RefreshCount,
|
self.RefreshTimeType,
|
self.RefreshTime,
|
self.StartTime,
|
self.EndTime,
|
self.PatrolType,
|
self.PatrolPos,
|
self.MinStopTime,
|
self.MaxStopTime,
|
self.RefreshDir,
|
self.RefreshMark,
|
self.ADOResult
|
)
|
return output
|
|
|
#------------------------------------------------------
|
#²¶×½NPC»ñµÃ³èÎïµ°/³èÎïµ°Éú³É³èÎï#tagNPC_Item_Pet
|
class tagNPC_Item_Pet(Structure):
|
_pack_ = 1
|
_fields_ = [
|
('NPCID', c_ulong),
|
('EggID', c_ulong),
|
('Pet', c_char * 30),
|
('ADOResult', c_ulong),
|
]
|
|
def __init__(self):
|
Structure.__init__(self)
|
self.clear()
|
|
def clear(self):
|
memset(addressof(self), 0, self.getLength())
|
|
|
def readLine(self, line):
|
self.clear()
|
wordList = line.split(SPLITCHAR)
|
try:
|
self.NPCID = int(wordList[0].strip())
|
self.EggID = int(wordList[1].strip())
|
self.Pet = wordList[2].strip()
|
|
except IndexError,e:
|
errorStr = '''\nIndexError:%s [lineData:"%s"]'''%(e, line)
|
raise Exception(errorStr)
|
except:
|
errorStr = '''\nException on readLine:[lineData:"%s"]\n%s'''%(line,traceback.format_exc())
|
raise Exception(errorStr)
|
|
|
def __getRecord(self):
|
'''×éÖ¯´æ´¢¼Ç¼'''
|
rec = {}
|
rec[u'NPCID'] = self.NPCID
|
rec[u'EggID'] = self.EggID
|
rec[u'Pet'] = fix_incomingText(self.Pet)
|
|
return rec
|
|
|
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_146, 'tagNPC_Item_Pet Insert failed!NPCID = %s, error = %s, trycnt = %d'%(self.NPCID, err, trycnt))
|
mylog.error(msg)
|
|
return False
|
return True
|
|
|
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(tagNPC_Item_Pet)
|
|
|
def readData(self, buf, pos):
|
if len(buf) < pos + self.getLength():
|
msg = error.formatMsg('error', error.ERROR_NO_147, 'len = %s while %s expected!'%(len(buf) - pos, self.getLength()))
|
mylog.error(msg)
|
return -1
|
self.clear()
|
memmove(addressof(self), buf[pos:], self.getLength())
|
return pos + self.getLength()
|
|
def outputString(self):
|
output = '''//²¶×½NPC»ñµÃ³èÎïµ°/³èÎïµ°Éú³É³èÎï#tagNPC_Item_Pet:
|
NPCID = %s,
|
EggID = %s,
|
Pet = %s,
|
ADOResult = %s,
|
'''%(
|
self.NPCID,
|
self.EggID,
|
self.Pet,
|
self.ADOResult
|
)
|
return output
|
|
|
#------------------------------------------------------
|
#ÈÎÎñɾ³ý´¥·¢±í#tagOnMissionDelete
|
class tagOnMissionDelete(Structure):
|
_pack_ = 1
|
_fields_ = [
|
('MissionID', c_ulong),
|
('CanDelete', c_ulong),
|
('DeleteTruck', c_ulong),
|
('DeleteItemCount', c_char * 100),
|
('DeleteMissionDict', c_char * 400),
|
('DecreaseCount', c_ulong),
|
('NextMissionID', c_ulong),
|
('ADOResult', c_ulong),
|
]
|
|
def __init__(self):
|
Structure.__init__(self)
|
self.clear()
|
|
def clear(self):
|
memset(addressof(self), 0, self.getLength())
|
|
|
def readLine(self, line):
|
self.clear()
|
wordList = line.split(SPLITCHAR)
|
try:
|
self.MissionID = int(wordList[0].strip())
|
self.CanDelete = int(wordList[1].strip())
|
self.DeleteTruck = int(wordList[2].strip())
|
self.DeleteItemCount = wordList[3].strip()
|
self.DeleteMissionDict = wordList[4].strip()
|
self.DecreaseCount = int(wordList[5].strip())
|
self.NextMissionID = int(wordList[6].strip())
|
|
except IndexError,e:
|
errorStr = '''\nIndexError:%s [lineData:"%s"]'''%(e, line)
|
raise Exception(errorStr)
|
except:
|
errorStr = '''\nException on readLine:[lineData:"%s"]\n%s'''%(line,traceback.format_exc())
|
raise Exception(errorStr)
|
|
|
def __getRecord(self):
|
'''×éÖ¯´æ´¢¼Ç¼'''
|
rec = {}
|
rec[u'MissionID'] = self.MissionID
|
rec[u'CanDelete'] = self.CanDelete
|
rec[u'DeleteTruck'] = self.DeleteTruck
|
rec[u'DeleteItemCount'] = fix_incomingText(self.DeleteItemCount)
|
rec[u'DeleteMissionDict'] = fix_incomingText(self.DeleteMissionDict)
|
rec[u'DecreaseCount'] = self.DecreaseCount
|
rec[u'NextMissionID'] = self.NextMissionID
|
|
return rec
|
|
|
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_146, 'tagOnMissionDelete Insert failed!MissionID = %s, error = %s, trycnt = %d'%(self.MissionID, err, trycnt))
|
mylog.error(msg)
|
|
return False
|
return True
|
|
|
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(tagOnMissionDelete)
|
|
|
def readData(self, buf, pos):
|
if len(buf) < pos + self.getLength():
|
msg = error.formatMsg('error', error.ERROR_NO_147, 'len = %s while %s expected!'%(len(buf) - pos, self.getLength()))
|
mylog.error(msg)
|
return -1
|
self.clear()
|
memmove(addressof(self), buf[pos:], self.getLength())
|
return pos + self.getLength()
|
|
def outputString(self):
|
output = '''//ÈÎÎñɾ³ý´¥·¢±í#tagOnMissionDelete:
|
MissionID = %s,
|
CanDelete = %s,
|
DeleteTruck = %s,
|
DeleteItemCount = %s,
|
DeleteMissionDict = %s,
|
DecreaseCount = %s,
|
NextMissionID = %s,
|
ADOResult = %s,
|
'''%(
|
self.MissionID,
|
self.CanDelete,
|
self.DeleteTruck,
|
self.DeleteItemCount,
|
self.DeleteMissionDict,
|
self.DecreaseCount,
|
self.NextMissionID,
|
self.ADOResult
|
)
|
return output
|
|
|
#------------------------------------------------------
|
#³èÎïÉý¼¶¾Ñé±í#tagPetExp
|
class tagPetExp(Structure):
|
_pack_ = 1
|
_fields_ = [
|
('Lv', c_ushort),
|
('Exp', c_ulong),
|
('Points', c_ubyte),
|
('ReExp', c_ushort),
|
('ADOResult', c_ulong),
|
]
|
|
def __init__(self):
|
Structure.__init__(self)
|
self.clear()
|
|
def clear(self):
|
memset(addressof(self), 0, self.getLength())
|
|
|
def readLine(self, line):
|
self.clear()
|
wordList = line.split(SPLITCHAR)
|
try:
|
self.Lv = int(wordList[0].strip())
|
self.Exp = int(wordList[1].strip())
|
self.Points = int(wordList[2].strip())
|
self.ReExp = int(wordList[3].strip())
|
|
except IndexError,e:
|
errorStr = '''\nIndexError:%s [lineData:"%s"]'''%(e, line)
|
raise Exception(errorStr)
|
except:
|
errorStr = '''\nException on readLine:[lineData:"%s"]\n%s'''%(line,traceback.format_exc())
|
raise Exception(errorStr)
|
|
|
def __getRecord(self):
|
'''×éÖ¯´æ´¢¼Ç¼'''
|
rec = {}
|
rec[u'Lv'] = self.Lv
|
rec[u'Exp'] = self.Exp
|
rec[u'Points'] = self.Points
|
rec[u'ReExp'] = self.ReExp
|
|
return rec
|
|
|
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_146, 'tagPetExp Insert failed!Lv = %s, error = %s, trycnt = %d'%(self.Lv, err, trycnt))
|
mylog.error(msg)
|
|
return False
|
return True
|
|
|
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(tagPetExp)
|
|
|
def readData(self, buf, pos):
|
if len(buf) < pos + self.getLength():
|
msg = error.formatMsg('error', error.ERROR_NO_147, 'len = %s while %s expected!'%(len(buf) - pos, self.getLength()))
|
mylog.error(msg)
|
return -1
|
self.clear()
|
memmove(addressof(self), buf[pos:], self.getLength())
|
return pos + self.getLength()
|
|
def outputString(self):
|
output = '''//³èÎïÉý¼¶¾Ñé±í#tagPetExp:
|
Lv = %s,
|
Exp = %s,
|
Points = %s,
|
ReExp = %s,
|
ADOResult = %s,
|
'''%(
|
self.Lv,
|
self.Exp,
|
self.Points,
|
self.ReExp,
|
self.ADOResult
|
)
|
return output
|
|
|
#------------------------------------------------------
|
#³èÎïÇ×Ãܶȼӳɱí#tagPetFriendliness
|
class tagPetFriendliness(Structure):
|
_pack_ = 1
|
_fields_ = [
|
('ZoneStart', c_ulong),
|
('ZoneEnd', c_ulong),
|
('IncPercent', c_ubyte),
|
('ADOResult', c_ulong),
|
]
|
|
def __init__(self):
|
Structure.__init__(self)
|
self.clear()
|
|
def clear(self):
|
memset(addressof(self), 0, self.getLength())
|
|
|
def readLine(self, line):
|
self.clear()
|
wordList = line.split(SPLITCHAR)
|
try:
|
self.ZoneStart = int(wordList[0].strip())
|
self.ZoneEnd = int(wordList[1].strip())
|
self.IncPercent = int(wordList[2].strip())
|
|
except IndexError,e:
|
errorStr = '''\nIndexError:%s [lineData:"%s"]'''%(e, line)
|
raise Exception(errorStr)
|
except:
|
errorStr = '''\nException on readLine:[lineData:"%s"]\n%s'''%(line,traceback.format_exc())
|
raise Exception(errorStr)
|
|
|
def __getRecord(self):
|
'''×éÖ¯´æ´¢¼Ç¼'''
|
rec = {}
|
rec[u'ZoneStart'] = self.ZoneStart
|
rec[u'ZoneEnd'] = self.ZoneEnd
|
rec[u'IncPercent'] = self.IncPercent
|
|
return rec
|
|
|
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_146, 'tagPetFriendliness Insert failed!ZoneStart = %s, error = %s, trycnt = %d'%(self.ZoneStart, err, trycnt))
|
mylog.error(msg)
|
|
return False
|
return True
|
|
|
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(tagPetFriendliness)
|
|
|
def readData(self, buf, pos):
|
if len(buf) < pos + self.getLength():
|
msg = error.formatMsg('error', error.ERROR_NO_147, 'len = %s while %s expected!'%(len(buf) - pos, self.getLength()))
|
mylog.error(msg)
|
return -1
|
self.clear()
|
memmove(addressof(self), buf[pos:], self.getLength())
|
return pos + self.getLength()
|
|
def outputString(self):
|
output = '''//³èÎïÇ×Ãܶȼӳɱí#tagPetFriendliness:
|
ZoneStart = %s,
|
ZoneEnd = %s,
|
IncPercent = %s,
|
ADOResult = %s,
|
'''%(
|
self.ZoneStart,
|
self.ZoneEnd,
|
self.IncPercent,
|
self.ADOResult
|
)
|
return output
|
|
|
#------------------------------------------------------
|
#³èÎïÆÀ·Ö¼Ó³É±í#tagPetGrade
|
class tagPetGrade(Structure):
|
_pack_ = 1
|
_fields_ = [
|
('GradeStart', c_ulong),
|
('GradeEnd', c_ulong),
|
('IncPercent', c_ubyte),
|
('ADOResult', c_ulong),
|
]
|
|
def __init__(self):
|
Structure.__init__(self)
|
self.clear()
|
|
def clear(self):
|
memset(addressof(self), 0, self.getLength())
|
|
|
def readLine(self, line):
|
self.clear()
|
wordList = line.split(SPLITCHAR)
|
try:
|
self.GradeStart = int(wordList[0].strip())
|
self.GradeEnd = int(wordList[1].strip())
|
self.IncPercent = int(wordList[2].strip())
|
|
except IndexError,e:
|
errorStr = '''\nIndexError:%s [lineData:"%s"]'''%(e, line)
|
raise Exception(errorStr)
|
except:
|
errorStr = '''\nException on readLine:[lineData:"%s"]\n%s'''%(line,traceback.format_exc())
|
raise Exception(errorStr)
|
|
|
def __getRecord(self):
|
'''×éÖ¯´æ´¢¼Ç¼'''
|
rec = {}
|
rec[u'GradeStart'] = self.GradeStart
|
rec[u'GradeEnd'] = self.GradeEnd
|
rec[u'IncPercent'] = self.IncPercent
|
|
return rec
|
|
|
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_146, 'tagPetGrade Insert failed!GradeStart = %s, error = %s, trycnt = %d'%(self.GradeStart, err, trycnt))
|
mylog.error(msg)
|
|
return False
|
return True
|
|
|
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(tagPetGrade)
|
|
|
def readData(self, buf, pos):
|
if len(buf) < pos + self.getLength():
|
msg = error.formatMsg('error', error.ERROR_NO_147, 'len = %s while %s expected!'%(len(buf) - pos, self.getLength()))
|
mylog.error(msg)
|
return -1
|
self.clear()
|
memmove(addressof(self), buf[pos:], self.getLength())
|
return pos + self.getLength()
|
|
def outputString(self):
|
output = '''//³èÎïÆÀ·Ö¼Ó³É±í#tagPetGrade:
|
GradeStart = %s,
|
GradeEnd = %s,
|
IncPercent = %s,
|
ADOResult = %s,
|
'''%(
|
self.GradeStart,
|
self.GradeEnd,
|
self.IncPercent,
|
self.ADOResult
|
)
|
return output
|
|
|
#------------------------------------------------------
|
#Öظ´Ê¼þ±í#tagRepeatEvent
|
class tagRepeatEvent(Structure):
|
_pack_ = 1
|
_fields_ = [
|
('EventID', c_ushort),
|
('EventName', c_char * 30),
|
('ClearType', c_ushort),
|
('RepeatTime', c_char * 20),
|
('ADOResult', c_ulong),
|
]
|
|
def __init__(self):
|
Structure.__init__(self)
|
self.clear()
|
|
def clear(self):
|
memset(addressof(self), 0, self.getLength())
|
|
|
def readLine(self, line):
|
self.clear()
|
wordList = line.split(SPLITCHAR)
|
try:
|
self.EventID = int(wordList[0].strip())
|
self.EventName = wordList[1].strip()
|
self.ClearType = int(wordList[2].strip())
|
self.RepeatTime = wordList[3].strip()
|
|
except IndexError,e:
|
errorStr = '''\nIndexError:%s [lineData:"%s"]'''%(e, line)
|
raise Exception(errorStr)
|
except:
|
errorStr = '''\nException on readLine:[lineData:"%s"]\n%s'''%(line,traceback.format_exc())
|
raise Exception(errorStr)
|
|
|
def __getRecord(self):
|
'''×éÖ¯´æ´¢¼Ç¼'''
|
rec = {}
|
rec[u'EventID'] = self.EventID
|
rec[u'EventName'] = fix_incomingText(self.EventName)
|
rec[u'ClearType'] = self.ClearType
|
rec[u'RepeatTime'] = fix_incomingText(self.RepeatTime)
|
|
return rec
|
|
|
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_146, 'tagRepeatEvent Insert failed!EventID = %s, error = %s, trycnt = %d'%(self.EventID, err, trycnt))
|
mylog.error(msg)
|
|
return False
|
return True
|
|
|
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(tagRepeatEvent)
|
|
|
def readData(self, buf, pos):
|
if len(buf) < pos + self.getLength():
|
msg = error.formatMsg('error', error.ERROR_NO_147, 'len = %s while %s expected!'%(len(buf) - pos, self.getLength()))
|
mylog.error(msg)
|
return -1
|
self.clear()
|
memmove(addressof(self), buf[pos:], self.getLength())
|
return pos + self.getLength()
|
|
def outputString(self):
|
output = '''//Öظ´Ê¼þ±í#tagRepeatEvent:
|
EventID = %s,
|
EventName = %s,
|
ClearType = %s,
|
RepeatTime = %s,
|
ADOResult = %s,
|
'''%(
|
self.EventID,
|
self.EventName,
|
self.ClearType,
|
self.RepeatTime,
|
self.ADOResult
|
)
|
return output
|
|
|
#------------------------------------------------------
|
#É̵êÎïÆ·±í#tagChinShopItem
|
class tagChinShopItem(Structure):
|
_pack_ = 1
|
_fields_ = [
|
('ShopItemID', c_ulong),
|
('NPCID', c_ulong),
|
('KindIndex', c_ubyte),
|
('ItemID', c_ulong),
|
('ItemCount', c_ulong),
|
('MoneyType', c_ubyte),
|
('Money', c_ulong),
|
('StarLV', c_ubyte),
|
('IsLucky', c_ubyte),
|
('SkillBoostIndex', c_ushort),
|
('SkillBoostValue', c_ulong),
|
('AddAttrLV', c_ubyte),
|
('AddAttrType', c_ubyte),
|
('AddAttrValue', c_ushort),
|
('Hole', c_ubyte),
|
('StoneInfo', c_char * 256),
|
('LimitFamilyLV', c_ubyte),
|
('LimitCountDaily', c_ulong),
|
('LimitPlusType1', c_ubyte),
|
('LimitPlusValue1', c_ushort),
|
('LimitPlusType2', c_ubyte),
|
('LimitPlusValue2', c_ushort),
|
('LimitPlusType3', c_ubyte),
|
('LimitPlusValue3', c_ushort),
|
('ADOResult', c_ulong),
|
]
|
|
def __init__(self):
|
Structure.__init__(self)
|
self.clear()
|
|
def clear(self):
|
memset(addressof(self), 0, self.getLength())
|
|
|
def readLine(self, line):
|
self.clear()
|
wordList = line.split(SPLITCHAR)
|
try:
|
self.ShopItemID = int(wordList[0].strip())
|
self.NPCID = int(wordList[1].strip())
|
self.KindIndex = int(wordList[2].strip())
|
self.ItemID = int(wordList[3].strip())
|
self.ItemCount = int(wordList[4].strip())
|
self.MoneyType = int(wordList[5].strip())
|
self.Money = int(wordList[6].strip())
|
self.StarLV = int(wordList[7].strip())
|
self.IsLucky = int(wordList[8].strip())
|
self.SkillBoostIndex = int(wordList[9].strip())
|
self.SkillBoostValue = int(wordList[10].strip())
|
self.AddAttrLV = int(wordList[11].strip())
|
self.AddAttrType = int(wordList[12].strip())
|
self.AddAttrValue = int(wordList[13].strip())
|
self.Hole = int(wordList[14].strip())
|
self.StoneInfo = wordList[15].strip()
|
self.LimitFamilyLV = int(wordList[16].strip())
|
self.LimitCountDaily = int(wordList[17].strip())
|
self.LimitPlusType1 = int(wordList[18].strip())
|
self.LimitPlusValue1 = int(wordList[19].strip())
|
self.LimitPlusType2 = int(wordList[20].strip())
|
self.LimitPlusValue2 = int(wordList[21].strip())
|
self.LimitPlusType3 = int(wordList[22].strip())
|
self.LimitPlusValue3 = int(wordList[23].strip())
|
|
except IndexError,e:
|
errorStr = '''\nIndexError:%s [lineData:"%s"]'''%(e, line)
|
raise Exception(errorStr)
|
except:
|
errorStr = '''\nException on readLine:[lineData:"%s"]\n%s'''%(line,traceback.format_exc())
|
raise Exception(errorStr)
|
|
|
def __getRecord(self):
|
'''×éÖ¯´æ´¢¼Ç¼'''
|
rec = {}
|
rec[u'ShopItemID'] = self.ShopItemID
|
rec[u'NPCID'] = self.NPCID
|
rec[u'KindIndex'] = self.KindIndex
|
rec[u'ItemID'] = self.ItemID
|
rec[u'ItemCount'] = self.ItemCount
|
rec[u'MoneyType'] = self.MoneyType
|
rec[u'Money'] = self.Money
|
rec[u'StarLV'] = self.StarLV
|
rec[u'IsLucky'] = self.IsLucky
|
rec[u'SkillBoostIndex'] = self.SkillBoostIndex
|
rec[u'SkillBoostValue'] = self.SkillBoostValue
|
rec[u'AddAttrLV'] = self.AddAttrLV
|
rec[u'AddAttrType'] = self.AddAttrType
|
rec[u'AddAttrValue'] = self.AddAttrValue
|
rec[u'Hole'] = self.Hole
|
rec[u'StoneInfo'] = fix_incomingText(self.StoneInfo)
|
rec[u'LimitFamilyLV'] = self.LimitFamilyLV
|
rec[u'LimitCountDaily'] = self.LimitCountDaily
|
rec[u'LimitPlusType1'] = self.LimitPlusType1
|
rec[u'LimitPlusValue1'] = self.LimitPlusValue1
|
rec[u'LimitPlusType2'] = self.LimitPlusType2
|
rec[u'LimitPlusValue2'] = self.LimitPlusValue2
|
rec[u'LimitPlusType3'] = self.LimitPlusType3
|
rec[u'LimitPlusValue3'] = self.LimitPlusValue3
|
|
return rec
|
|
|
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_146, 'tagChinShopItem Insert failed!NPCID = %s, error = %s, trycnt = %d'%(self.NPCID, err, trycnt))
|
mylog.error(msg)
|
|
return False
|
return True
|
|
|
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(tagChinShopItem)
|
|
|
def readData(self, buf, pos):
|
if len(buf) < pos + self.getLength():
|
msg = error.formatMsg('error', error.ERROR_NO_147, 'len = %s while %s expected!'%(len(buf) - pos, self.getLength()))
|
mylog.error(msg)
|
return -1
|
self.clear()
|
memmove(addressof(self), buf[pos:], self.getLength())
|
return pos + self.getLength()
|
|
def outputString(self):
|
output = '''//É̵êÎïÆ·±í#tagChinShopItem:
|
ShopItemID = %s,
|
NPCID = %s,
|
KindIndex = %s,
|
ItemID = %s,
|
ItemCount = %s,
|
MoneyType = %s,
|
Money = %s,
|
StarLV = %s,
|
IsLucky = %s,
|
SkillBoostIndex = %s,
|
SkillBoostValue = %s,
|
AddAttrLV = %s,
|
AddAttrType = %s,
|
AddAttrValue = %s,
|
Hole = %s,
|
StoneInfo = %s,
|
LimitFamilyLV = %s,
|
LimitCountDaily = %s,
|
LimitPlusType1 = %s,
|
LimitPlusValue1 = %s,
|
LimitPlusType2 = %s,
|
LimitPlusValue2 = %s,
|
LimitPlusType3 = %s,
|
LimitPlusValue3 = %s,
|
ADOResult = %s,
|
'''%(
|
self.ShopItemID,
|
self.NPCID,
|
self.KindIndex,
|
self.ItemID,
|
self.ItemCount,
|
self.MoneyType,
|
self.Money,
|
self.StarLV,
|
self.IsLucky,
|
self.SkillBoostIndex,
|
self.SkillBoostValue,
|
self.AddAttrLV,
|
self.AddAttrType,
|
self.AddAttrValue,
|
self.Hole,
|
self.StoneInfo,
|
self.LimitFamilyLV,
|
self.LimitCountDaily,
|
self.LimitPlusType1,
|
self.LimitPlusValue1,
|
self.LimitPlusType2,
|
self.LimitPlusValue2,
|
self.LimitPlusType3,
|
self.LimitPlusValue3,
|
self.ADOResult
|
)
|
return output
|
|
|
#------------------------------------------------------
|
|
#¼¼ÄÜÊý¾Ý#tagChinSkill
|
class tagChinSkill(Structure):
|
_pack_ = 1
|
_fields_ = [
|
('SkillID', c_ulong),
|
('SkillName', c_char * 22),
|
('SkillTypeID', c_ulong),
|
('SkillLV', c_ulong),
|
('SkillMaxLV', c_ulong),
|
('UseType', c_ubyte),
|
('FuncType', c_ubyte),
|
('CastTime', c_ulong),
|
('SkillType', c_ubyte),
|
('HurtType', c_ubyte),
|
('ContinueUse', c_ubyte),
|
('AtkType', c_ubyte),
|
('AtkRadius', c_ubyte),
|
('Tag', c_ubyte),
|
('AtkDist', c_ubyte),
|
('StiffTime', c_ulong),
|
('CoolDownTime', c_ulong),
|
('MP', c_ulong),
|
('HP', c_ulong),
|
('XP', c_ulong),
|
('UseItemID', c_ulong),
|
('UseItemCount', c_ulong),
|
('Effect1', c_ulong),
|
('EffectValue11', c_ulong),
|
('EffectValue12', c_ulong),
|
('EffectValue13', c_ulong),
|
('Effect2', c_ulong),
|
('EffectValue21', c_ulong),
|
('EffectValue22', c_ulong),
|
('EffectValue23', c_ulong),
|
('Effect3', c_ulong),
|
('EffectValue31', c_ulong),
|
('EffectValue32', c_ulong),
|
('EffectValue33', c_ulong),
|
('Effect4', c_ulong),
|
('EffectValue41', c_ulong),
|
('EffectValue42', c_ulong),
|
('EffectValue43', c_ulong),
|
('Effect5', c_ulong),
|
('EffectValue51', c_ulong),
|
('EffectValue52', c_ulong),
|
('EffectValue53', c_ulong),
|
('Effect6', c_ulong),
|
('EffectValue61', c_ulong),
|
('EffectValue62', c_ulong),
|
('EffectValue63', c_ulong),
|
('HappenRate', c_ulong),
|
('LastTime', c_ulong),
|
('SkillAngry', c_ulong),
|
('SkillEnhance1', c_ulong),
|
('SkillEnhance2', c_ulong),
|
('StateSkillReq', c_ulong),
|
('StateSkillLV', c_ulong),
|
('LearnSkillReq', c_ulong),
|
('LearnSkillLV', c_ushort),
|
('LVReq', c_ushort),
|
('LearnSkillPointReq', c_ushort),
|
('DieContinue', c_ubyte),
|
('CanRepeatTime', c_ubyte),
|
('CommonCD', c_ubyte),
|
('ClientEffectType', c_ubyte),
|
('FightPower', c_ulong),
|
('LVUpCostMoneyType', c_ubyte),
|
('LVUpCostMoney', c_ulong),
|
('LVUpCostExp', c_ulong),
|
('ServerSkillSeriesLimit', c_ulong),
|
('ServerActionLimit', c_ulong),
|
('ClientActionLimit', c_ulong),
|
('ClientSkillSeriesLimit', c_ulong),
|
('SkillOfSeries', c_ulong),
|
('ExpendMPRate', c_ushort),
|
('ExAttr1', c_ulong),
|
('ExAttr2', c_ulong),
|
('ExAttr3', c_ulong),
|
('ExAttr4', c_ulong),
|
('ExAttr5', c_ulong),
|
('ADOResult', c_ulong),
|
]
|
|
def __init__(self):
|
Structure.__init__(self)
|
self.clear()
|
|
def clear(self):
|
memset(addressof(self), 0, self.getLength())
|
|
|
def readLine(self, line):
|
self.clear()
|
wordList = line.split(SPLITCHAR)
|
try:
|
self.SkillID = int(wordList[0].strip())
|
self.SkillName = wordList[1].strip()
|
self.SkillTypeID = int(wordList[2].strip())
|
self.SkillLV = int(wordList[3].strip())
|
self.SkillMaxLV = int(wordList[4].strip())
|
self.UseType = int(wordList[5].strip())
|
self.FuncType = int(wordList[6].strip())
|
self.CastTime = int(wordList[7].strip())
|
self.SkillType = int(wordList[8].strip())
|
self.HurtType = int(wordList[9].strip())
|
self.ContinueUse = int(wordList[10].strip())
|
self.AtkType = int(wordList[11].strip())
|
self.AtkRadius = int(wordList[12].strip())
|
self.Tag = int(wordList[13].strip())
|
self.AtkDist = int(wordList[14].strip())
|
self.StiffTime = int(wordList[15].strip())
|
self.CoolDownTime = int(wordList[16].strip())
|
self.MP = int(wordList[17].strip())
|
self.HP = int(wordList[18].strip())
|
self.XP = int(wordList[19].strip())
|
self.UseItemID = int(wordList[20].strip())
|
self.UseItemCount = int(wordList[21].strip())
|
self.Effect1 = int(wordList[22].strip())
|
self.EffectValue11 = int(wordList[23].strip())
|
self.EffectValue12 = int(wordList[24].strip())
|
self.EffectValue13 = int(wordList[25].strip())
|
self.Effect2 = int(wordList[26].strip())
|
self.EffectValue21 = int(wordList[27].strip())
|
self.EffectValue22 = int(wordList[28].strip())
|
self.EffectValue23 = int(wordList[29].strip())
|
self.Effect3 = int(wordList[30].strip())
|
self.EffectValue31 = int(wordList[31].strip())
|
self.EffectValue32 = int(wordList[32].strip())
|
self.EffectValue33 = int(wordList[33].strip())
|
self.Effect4 = int(wordList[34].strip())
|
self.EffectValue41 = int(wordList[35].strip())
|
self.EffectValue42 = int(wordList[36].strip())
|
self.EffectValue43 = int(wordList[37].strip())
|
self.Effect5 = int(wordList[38].strip())
|
self.EffectValue51 = int(wordList[39].strip())
|
self.EffectValue52 = int(wordList[40].strip())
|
self.EffectValue53 = int(wordList[41].strip())
|
self.Effect6 = int(wordList[42].strip())
|
self.EffectValue61 = int(wordList[43].strip())
|
self.EffectValue62 = int(wordList[44].strip())
|
self.EffectValue63 = int(wordList[45].strip())
|
self.HappenRate = int(wordList[46].strip())
|
self.LastTime = int(wordList[47].strip())
|
self.SkillAngry = int(wordList[48].strip())
|
self.SkillEnhance1 = int(wordList[49].strip())
|
self.SkillEnhance2 = int(wordList[50].strip())
|
self.StateSkillReq = int(wordList[51].strip())
|
self.StateSkillLV = int(wordList[52].strip())
|
self.LearnSkillReq = int(wordList[53].strip())
|
self.LearnSkillLV = int(wordList[54].strip())
|
self.LVReq = int(wordList[55].strip())
|
self.LearnSkillPointReq = int(wordList[56].strip())
|
self.DieContinue = int(wordList[57].strip())
|
self.CanRepeatTime = int(wordList[58].strip())
|
self.CommonCD = int(wordList[59].strip())
|
self.ClientEffectType = int(wordList[60].strip())
|
self.FightPower = int(wordList[61].strip())
|
self.LVUpCostMoneyType = int(wordList[62].strip())
|
self.LVUpCostMoney = int(wordList[63].strip())
|
self.LVUpCostExp = int(wordList[64].strip())
|
self.ServerSkillSeriesLimit = int(wordList[65].strip())
|
self.ServerActionLimit = int(wordList[66].strip())
|
self.ClientActionLimit = int(wordList[67].strip())
|
self.ClientSkillSeriesLimit = int(wordList[68].strip())
|
self.SkillOfSeries = int(wordList[69].strip())
|
self.ExpendMPRate = int(wordList[70].strip())
|
self.ExAttr1 = int(wordList[71].strip())
|
self.ExAttr2 = int(wordList[72].strip())
|
self.ExAttr3 = int(wordList[73].strip())
|
self.ExAttr4 = int(wordList[74].strip())
|
self.ExAttr5 = int(wordList[75].strip())
|
|
except IndexError,e:
|
errorStr = '''\nIndexError:%s [lineData:"%s"]'''%(e, line)
|
raise Exception(errorStr)
|
except:
|
errorStr = '''\nException on readLine:[lineData:"%s"]\n%s'''%(line,traceback.format_exc())
|
raise Exception(errorStr)
|
|
|
def __getRecord(self):
|
'''×éÖ¯´æ´¢¼Ç¼'''
|
rec = {}
|
rec[u'SkillID'] = self.SkillID
|
rec[u'SkillName'] = fix_incomingText(self.SkillName)
|
rec[u'SkillTypeID'] = self.SkillTypeID
|
rec[u'SkillLV'] = self.SkillLV
|
rec[u'SkillMaxLV'] = self.SkillMaxLV
|
rec[u'UseType'] = self.UseType
|
rec[u'FuncType'] = self.FuncType
|
rec[u'CastTime'] = self.CastTime
|
rec[u'SkillType'] = self.SkillType
|
rec[u'HurtType'] = self.HurtType
|
rec[u'ContinueUse'] = self.ContinueUse
|
rec[u'AtkType'] = self.AtkType
|
rec[u'AtkRadius'] = self.AtkRadius
|
rec[u'Tag'] = self.Tag
|
rec[u'AtkDist'] = self.AtkDist
|
rec[u'StiffTime'] = self.StiffTime
|
rec[u'CoolDownTime'] = self.CoolDownTime
|
rec[u'MP'] = self.MP
|
rec[u'HP'] = self.HP
|
rec[u'XP'] = self.XP
|
rec[u'UseItemID'] = self.UseItemID
|
rec[u'UseItemCount'] = self.UseItemCount
|
rec[u'Effect1'] = self.Effect1
|
rec[u'EffectValue11'] = self.EffectValue11
|
rec[u'EffectValue12'] = self.EffectValue12
|
rec[u'EffectValue13'] = self.EffectValue13
|
rec[u'Effect2'] = self.Effect2
|
rec[u'EffectValue21'] = self.EffectValue21
|
rec[u'EffectValue22'] = self.EffectValue22
|
rec[u'EffectValue23'] = self.EffectValue23
|
rec[u'Effect3'] = self.Effect3
|
rec[u'EffectValue31'] = self.EffectValue31
|
rec[u'EffectValue32'] = self.EffectValue32
|
rec[u'EffectValue33'] = self.EffectValue33
|
rec[u'Effect4'] = self.Effect4
|
rec[u'EffectValue41'] = self.EffectValue41
|
rec[u'EffectValue42'] = self.EffectValue42
|
rec[u'EffectValue43'] = self.EffectValue43
|
rec[u'Effect5'] = self.Effect5
|
rec[u'EffectValue51'] = self.EffectValue51
|
rec[u'EffectValue52'] = self.EffectValue52
|
rec[u'EffectValue53'] = self.EffectValue53
|
rec[u'Effect6'] = self.Effect6
|
rec[u'EffectValue61'] = self.EffectValue61
|
rec[u'EffectValue62'] = self.EffectValue62
|
rec[u'EffectValue63'] = self.EffectValue63
|
rec[u'HappenRate'] = self.HappenRate
|
rec[u'LastTime'] = self.LastTime
|
rec[u'SkillAngry'] = self.SkillAngry
|
rec[u'SkillEnhance1'] = self.SkillEnhance1
|
rec[u'SkillEnhance2'] = self.SkillEnhance2
|
rec[u'StateSkillReq'] = self.StateSkillReq
|
rec[u'StateSkillLV'] = self.StateSkillLV
|
rec[u'LearnSkillReq'] = self.LearnSkillReq
|
rec[u'LearnSkillLV'] = self.LearnSkillLV
|
rec[u'LVReq'] = self.LVReq
|
rec[u'LearnSkillPointReq'] = self.LearnSkillPointReq
|
rec[u'DieContinue'] = self.DieContinue
|
rec[u'CanRepeatTime'] = self.CanRepeatTime
|
rec[u'CommonCD'] = self.CommonCD
|
rec[u'ClientEffectType'] = self.ClientEffectType
|
rec[u'FightPower'] = self.FightPower
|
rec[u'LVUpCostMoneyType'] = self.LVUpCostMoneyType
|
rec[u'LVUpCostMoney'] = self.LVUpCostMoney
|
rec[u'LVUpCostExp'] = self.LVUpCostExp
|
rec[u'ServerSkillSeriesLimit'] = self.ServerSkillSeriesLimit
|
rec[u'ServerActionLimit'] = self.ServerActionLimit
|
rec[u'ClientActionLimit'] = self.ClientActionLimit
|
rec[u'ClientSkillSeriesLimit'] = self.ClientSkillSeriesLimit
|
rec[u'SkillOfSeries'] = self.SkillOfSeries
|
rec[u'ExpendMPRate'] = self.ExpendMPRate
|
rec[u'ExAttr1'] = self.ExAttr1
|
rec[u'ExAttr2'] = self.ExAttr2
|
rec[u'ExAttr3'] = self.ExAttr3
|
rec[u'ExAttr4'] = self.ExAttr4
|
rec[u'ExAttr5'] = self.ExAttr5
|
|
return rec
|
|
|
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_146, 'tagChinSkill Insert failed!SkillID = %s, error = %s, trycnt = %d'%(self.SkillID, err, trycnt))
|
mylog.error(msg)
|
|
return False
|
return True
|
|
|
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(tagChinSkill)
|
|
|
def readData(self, buf, pos):
|
if len(buf) < pos + self.getLength():
|
msg = error.formatMsg('error', error.ERROR_NO_147, 'len = %s while %s expected!'%(len(buf) - pos, self.getLength()))
|
mylog.error(msg)
|
return -1
|
self.clear()
|
memmove(addressof(self), buf[pos:], self.getLength())
|
return pos + self.getLength()
|
|
def outputString(self):
|
output = '''//¼¼ÄÜÊý¾Ý#tagChinSkill:
|
SkillID = %s,
|
SkillName = %s,
|
SkillTypeID = %s,
|
SkillLV = %s,
|
SkillMaxLV = %s,
|
UseType = %s,
|
FuncType = %s,
|
CastTime = %s,
|
SkillType = %s,
|
HurtType = %s,
|
ContinueUse = %s,
|
AtkType = %s,
|
AtkRadius = %s,
|
Tag = %s,
|
AtkDist = %s,
|
StiffTime = %s,
|
CoolDownTime = %s,
|
MP = %s,
|
HP = %s,
|
XP = %s,
|
UseItemID = %s,
|
UseItemCount = %s,
|
Effect1 = %s,
|
EffectValue11 = %s,
|
EffectValue12 = %s,
|
EffectValue13 = %s,
|
Effect2 = %s,
|
EffectValue21 = %s,
|
EffectValue22 = %s,
|
EffectValue23 = %s,
|
Effect3 = %s,
|
EffectValue31 = %s,
|
EffectValue32 = %s,
|
EffectValue33 = %s,
|
Effect4 = %s,
|
EffectValue41 = %s,
|
EffectValue42 = %s,
|
EffectValue43 = %s,
|
Effect5 = %s,
|
EffectValue51 = %s,
|
EffectValue52 = %s,
|
EffectValue53 = %s,
|
Effect6 = %s,
|
EffectValue61 = %s,
|
EffectValue62 = %s,
|
EffectValue63 = %s,
|
HappenRate = %s,
|
LastTime = %s,
|
SkillAngry = %s,
|
SkillEnhance1 = %s,
|
SkillEnhance2 = %s,
|
StateSkillReq = %s,
|
StateSkillLV = %s,
|
LearnSkillReq = %s,
|
LearnSkillLV = %s,
|
LVReq = %s,
|
LearnSkillPointReq = %s,
|
DieContinue = %s,
|
CanRepeatTime = %s,
|
CommonCD = %s,
|
ClientEffectType = %s,
|
FightPower = %s,
|
LVUpCostMoneyType = %s,
|
LVUpCostMoney = %s,
|
LVUpCostExp = %s,
|
ServerSkillSeriesLimit = %s,
|
ServerActionLimit = %s,
|
ClientActionLimit = %s,
|
ClientSkillSeriesLimit = %s,
|
SkillOfSeries = %s,
|
ExpendMPRate = %s,
|
ExAttr1 = %s,
|
ExAttr2 = %s,
|
ExAttr3 = %s,
|
ExAttr4 = %s,
|
ExAttr5 = %s,
|
ADOResult = %s,
|
'''%(
|
self.SkillID,
|
self.SkillName,
|
self.SkillTypeID,
|
self.SkillLV,
|
self.SkillMaxLV,
|
self.UseType,
|
self.FuncType,
|
self.CastTime,
|
self.SkillType,
|
self.HurtType,
|
self.ContinueUse,
|
self.AtkType,
|
self.AtkRadius,
|
self.Tag,
|
self.AtkDist,
|
self.StiffTime,
|
self.CoolDownTime,
|
self.MP,
|
self.HP,
|
self.XP,
|
self.UseItemID,
|
self.UseItemCount,
|
self.Effect1,
|
self.EffectValue11,
|
self.EffectValue12,
|
self.EffectValue13,
|
self.Effect2,
|
self.EffectValue21,
|
self.EffectValue22,
|
self.EffectValue23,
|
self.Effect3,
|
self.EffectValue31,
|
self.EffectValue32,
|
self.EffectValue33,
|
self.Effect4,
|
self.EffectValue41,
|
self.EffectValue42,
|
self.EffectValue43,
|
self.Effect5,
|
self.EffectValue51,
|
self.EffectValue52,
|
self.EffectValue53,
|
self.Effect6,
|
self.EffectValue61,
|
self.EffectValue62,
|
self.EffectValue63,
|
self.HappenRate,
|
self.LastTime,
|
self.SkillAngry,
|
self.SkillEnhance1,
|
self.SkillEnhance2,
|
self.StateSkillReq,
|
self.StateSkillLV,
|
self.LearnSkillReq,
|
self.LearnSkillLV,
|
self.LVReq,
|
self.LearnSkillPointReq,
|
self.DieContinue,
|
self.CanRepeatTime,
|
self.CommonCD,
|
self.ClientEffectType,
|
self.FightPower,
|
self.LVUpCostMoneyType,
|
self.LVUpCostMoney,
|
self.LVUpCostExp,
|
self.ServerSkillSeriesLimit,
|
self.ServerActionLimit,
|
self.ClientActionLimit,
|
self.ClientSkillSeriesLimit,
|
self.SkillOfSeries,
|
self.ExpendMPRate,
|
self.ExAttr1,
|
self.ExAttr2,
|
self.ExAttr3,
|
self.ExAttr4,
|
self.ExAttr5,
|
self.ADOResult
|
)
|
return output
|
|
|
|
#------------------------------------------------------
|
#×°±¸Ì××°¼¤»î±í#tagSuiteActivation
|
class tagSuiteActivation(Structure):
|
_pack_ = 1
|
_fields_ = [
|
('EquipID', c_ulong),
|
('ItemID', c_ulong),
|
('ItemCount', c_ushort),
|
('Money', c_ulong),
|
('ADOResult', c_ulong),
|
]
|
|
def __init__(self):
|
Structure.__init__(self)
|
self.clear()
|
|
def clear(self):
|
memset(addressof(self), 0, self.getLength())
|
|
|
def readLine(self, line):
|
self.clear()
|
wordList = line.split(SPLITCHAR)
|
try:
|
self.EquipID = int(wordList[0].strip())
|
self.ItemID = int(wordList[1].strip())
|
self.ItemCount = int(wordList[2].strip())
|
self.Money = int(wordList[3].strip())
|
|
except IndexError,e:
|
errorStr = '''\nIndexError:%s [lineData:"%s"]'''%(e, line)
|
raise Exception(errorStr)
|
except:
|
errorStr = '''\nException on readLine:[lineData:"%s"]\n%s'''%(line,traceback.format_exc())
|
raise Exception(errorStr)
|
|
|
def __getRecord(self):
|
'''×éÖ¯´æ´¢¼Ç¼'''
|
rec = {}
|
rec[u'EquipID'] = self.EquipID
|
rec[u'ItemID'] = self.ItemID
|
rec[u'ItemCount'] = self.ItemCount
|
rec[u'Money'] = self.Money
|
|
return rec
|
|
|
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_146, 'tagSuiteActivation Insert failed!EquipID = %s, error = %s, trycnt = %d'%(self.EquipID, err, trycnt))
|
mylog.error(msg)
|
|
return False
|
return True
|
|
|
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(tagSuiteActivation)
|
|
|
def readData(self, buf, pos):
|
if len(buf) < pos + self.getLength():
|
msg = error.formatMsg('error', error.ERROR_NO_147, 'len = %s while %s expected!'%(len(buf) - pos, self.getLength()))
|
mylog.error(msg)
|
return -1
|
self.clear()
|
memmove(addressof(self), buf[pos:], self.getLength())
|
return pos + self.getLength()
|
|
def outputString(self):
|
output = '''//×°±¸Ì××°¼¤»î±í#tagSuiteActivation:
|
EquipID = %s,
|
ItemID = %s,
|
ItemCount = %s,
|
Money = %s,
|
ADOResult = %s,
|
'''%(
|
self.EquipID,
|
self.ItemID,
|
self.ItemCount,
|
self.Money,
|
self.ADOResult
|
)
|
return output
|
|
|
#------------------------------------------------------
|
#³èÎïϵͳ±í#tagPet
|
class tagPet(Structure):
|
_pack_ = 1
|
_fields_ = [
|
('NPCID', c_ulong),
|
('PetType', c_ubyte),
|
('BringLV', c_ushort),
|
('HPTalent', c_ushort),
|
('MPTalent', c_ushort),
|
('PhysicAtkTalent', c_ushort),
|
('MagicAtkTalent', c_ushort),
|
('PhysicDefTalent', c_ushort),
|
('MagicDefTalent', c_ushort),
|
('HPTalentFactor', c_ushort),
|
('MPTalentFactor', c_ushort),
|
('PhysicAtkTalentFactor', c_ushort),
|
('MagicAtkTalentFactor', c_ushort),
|
('PhysicDefTalentFactor', c_ushort),
|
('MagicDefTalentFactor', c_ushort),
|
('MaxSkillCount', c_ubyte),
|
('SkillList', c_char * 1000),
|
('LVUpSkillList', c_char * 1000),
|
('SkillListFromRewash', c_char * 1000),
|
('SkillLimit', c_ubyte),
|
('SkillLimitIncreateCnt', c_ubyte),
|
('ADOResult', c_ulong),
|
]
|
|
def __init__(self):
|
Structure.__init__(self)
|
self.clear()
|
|
def clear(self):
|
memset(addressof(self), 0, self.getLength())
|
|
|
def readLine(self, line):
|
self.clear()
|
wordList = line.split(SPLITCHAR)
|
try:
|
self.NPCID = int(wordList[0].strip())
|
self.PetType = int(wordList[1].strip())
|
self.BringLV = int(wordList[2].strip())
|
self.HPTalent = int(wordList[3].strip())
|
self.MPTalent = int(wordList[4].strip())
|
self.PhysicAtkTalent = int(wordList[5].strip())
|
self.MagicAtkTalent = int(wordList[6].strip())
|
self.PhysicDefTalent = int(wordList[7].strip())
|
self.MagicDefTalent = int(wordList[8].strip())
|
self.HPTalentFactor = int(wordList[9].strip())
|
self.MPTalentFactor = int(wordList[10].strip())
|
self.PhysicAtkTalentFactor = int(wordList[11].strip())
|
self.MagicAtkTalentFactor = int(wordList[12].strip())
|
self.PhysicDefTalentFactor = int(wordList[13].strip())
|
self.MagicDefTalentFactor = int(wordList[14].strip())
|
self.MaxSkillCount = int(wordList[15].strip())
|
self.SkillList = wordList[16].strip()
|
self.LVUpSkillList = wordList[17].strip()
|
self.SkillListFromRewash = wordList[18].strip()
|
self.SkillLimit = int(wordList[19].strip())
|
self.SkillLimitIncreateCnt = int(wordList[20].strip())
|
|
except IndexError,e:
|
errorStr = '''\nIndexError:%s [lineData:"%s"]'''%(e, line)
|
raise Exception(errorStr)
|
except:
|
errorStr = '''\nException on readLine:[lineData:"%s"]\n%s'''%(line,traceback.format_exc())
|
raise Exception(errorStr)
|
|
|
def __getRecord(self):
|
'''×éÖ¯´æ´¢¼Ç¼'''
|
rec = {}
|
rec[u'NPCID'] = self.NPCID
|
rec[u'PetType'] = self.PetType
|
rec[u'BringLV'] = self.BringLV
|
rec[u'HPTalent'] = self.HPTalent
|
rec[u'MPTalent'] = self.MPTalent
|
rec[u'PhysicAtkTalent'] = self.PhysicAtkTalent
|
rec[u'MagicAtkTalent'] = self.MagicAtkTalent
|
rec[u'PhysicDefTalent'] = self.PhysicDefTalent
|
rec[u'MagicDefTalent'] = self.MagicDefTalent
|
rec[u'HPTalentFactor'] = self.HPTalentFactor
|
rec[u'MPTalentFactor'] = self.MPTalentFactor
|
rec[u'PhysicAtkTalentFactor'] = self.PhysicAtkTalentFactor
|
rec[u'MagicAtkTalentFactor'] = self.MagicAtkTalentFactor
|
rec[u'PhysicDefTalentFactor'] = self.PhysicDefTalentFactor
|
rec[u'MagicDefTalentFactor'] = self.MagicDefTalentFactor
|
rec[u'MaxSkillCount'] = self.MaxSkillCount
|
rec[u'SkillList'] = fix_incomingText(self.SkillList)
|
rec[u'LVUpSkillList'] = fix_incomingText(self.LVUpSkillList)
|
rec[u'SkillListFromRewash'] = fix_incomingText(self.SkillListFromRewash)
|
rec[u'SkillLimit'] = self.SkillLimit
|
rec[u'SkillLimitIncreateCnt'] = self.SkillLimitIncreateCnt
|
|
return rec
|
|
|
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_146, 'tagPet Insert failed!NPCID = %s, error = %s, trycnt = %d'%(self.NPCID, err, trycnt))
|
mylog.error(msg)
|
|
return False
|
return True
|
|
|
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(tagPet)
|
|
|
def readData(self, buf, pos):
|
if len(buf) < pos + self.getLength():
|
msg = error.formatMsg('error', error.ERROR_NO_147, 'len = %s while %s expected!'%(len(buf) - pos, self.getLength()))
|
mylog.error(msg)
|
return -1
|
self.clear()
|
memmove(addressof(self), buf[pos:], self.getLength())
|
return pos + self.getLength()
|
|
def outputString(self):
|
output = '''//³èÎïϵͳ±í#tagPet:
|
NPCID = %s,
|
PetType = %s,
|
BringLV = %s,
|
HPTalent = %s,
|
MPTalent = %s,
|
PhysicAtkTalent = %s,
|
MagicAtkTalent = %s,
|
PhysicDefTalent = %s,
|
MagicDefTalent = %s,
|
HPTalentFactor = %s,
|
MPTalentFactor = %s,
|
PhysicAtkTalentFactor = %s,
|
MagicAtkTalentFactor = %s,
|
PhysicDefTalentFactor = %s,
|
MagicDefTalentFactor = %s,
|
MaxSkillCount = %s,
|
SkillList = %s,
|
LVUpSkillList = %s,
|
SkillListFromRewash = %s,
|
SkillLimit = %s,
|
SkillLimitIncreateCnt = %s,
|
ADOResult = %s,
|
'''%(
|
self.NPCID,
|
self.PetType,
|
self.BringLV,
|
self.HPTalent,
|
self.MPTalent,
|
self.PhysicAtkTalent,
|
self.MagicAtkTalent,
|
self.PhysicDefTalent,
|
self.MagicDefTalent,
|
self.HPTalentFactor,
|
self.MPTalentFactor,
|
self.PhysicAtkTalentFactor,
|
self.MagicAtkTalentFactor,
|
self.PhysicDefTalentFactor,
|
self.MagicDefTalentFactor,
|
self.MaxSkillCount,
|
self.SkillList,
|
self.LVUpSkillList,
|
self.SkillListFromRewash,
|
self.SkillLimit,
|
self.SkillLimitIncreateCnt,
|
self.ADOResult
|
)
|
return output
|
|
|
|
|
#------------------------------------------------------
|
#È«¾ÖµôÂÊ#tagDBGameWorldDrop
|
class tagDBGameWorldDrop(Structure):
|
_pack_ = 1
|
_fields_ = [
|
('DropKey', c_ulong),
|
('ItemID', c_ulong),
|
('FunctionType', c_ubyte),
|
('DropCount', c_ulong),
|
('RefreshType', c_ubyte),
|
('ADOResult', c_ulong),
|
]
|
|
def __init__(self):
|
Structure.__init__(self)
|
self.clear()
|
|
def clear(self):
|
memset(addressof(self), 0, self.getLength())
|
|
|
def readLine(self, line):
|
self.clear()
|
wordList = line.split(SPLITCHAR)
|
try:
|
self.DropKey = int(wordList[0].strip())
|
self.ItemID = int(wordList[1].strip())
|
self.FunctionType = int(wordList[2].strip())
|
self.DropCount = int(wordList[3].strip())
|
self.RefreshType = int(wordList[4].strip())
|
|
except IndexError,e:
|
errorStr = '''\nIndexError:%s [lineData:"%s"]'''%(e, line)
|
raise Exception(errorStr)
|
except:
|
errorStr = '''\nException on readLine:[lineData:"%s"]\n%s'''%(line,traceback.format_exc())
|
raise Exception(errorStr)
|
|
|
def __getRecord(self):
|
'''×éÖ¯´æ´¢¼Ç¼'''
|
rec = {}
|
rec[u'DropKey'] = self.DropKey
|
rec[u'ItemID'] = self.ItemID
|
rec[u'FunctionType'] = self.FunctionType
|
rec[u'DropCount'] = self.DropCount
|
rec[u'RefreshType'] = self.RefreshType
|
|
return rec
|
|
|
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_146, 'tagDBGameWorldDrop Insert failed!DropKey = %s, error = %s, trycnt = %d'%(self.DropKey, err, trycnt))
|
mylog.error(msg)
|
|
return False
|
return True
|
|
|
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(tagDBGameWorldDrop)
|
|
|
def readData(self, buf, pos):
|
if len(buf) < pos + self.getLength():
|
msg = error.formatMsg('error', error.ERROR_NO_147, 'len = %s while %s expected!'%(len(buf) - pos, self.getLength()))
|
mylog.error(msg)
|
return -1
|
self.clear()
|
memmove(addressof(self), buf[pos:], self.getLength())
|
return pos + self.getLength()
|
|
def outputString(self):
|
output = '''//È«¾ÖµôÂÊ#tagDBGameWorldDrop:
|
DropKey = %s,
|
ItemID = %s,
|
FunctionType = %s,
|
DropCount = %s,
|
RefreshType = %s,
|
ADOResult = %s,
|
'''%(
|
self.DropKey,
|
self.ItemID,
|
self.FunctionType,
|
self.DropCount,
|
self.RefreshType,
|
self.ADOResult
|
)
|
return output
|
|
|
#------------------------------------------------------
|
#É̳ÇÎïÆ·#tagDBStoreItem
|
class tagDBStoreItem(Structure):
|
_pack_ = 1
|
_fields_ = [
|
('StoreItemKey', c_ulong),
|
('AreaIndex', c_ubyte),
|
('MenuIndex', c_ubyte),
|
('TypeIndex', c_ubyte),
|
('ItemID', c_ulong),
|
('SaleState', c_ubyte),
|
('ItemCount', c_ushort),
|
('Gold', c_ulong),
|
('GoldPaper', c_ulong),
|
('Silver', c_ulong),
|
('SilverPaper', c_ulong),
|
('ADOResult', c_ulong),
|
]
|
|
def __init__(self):
|
Structure.__init__(self)
|
self.clear()
|
|
def clear(self):
|
memset(addressof(self), 0, self.getLength())
|
|
|
def readLine(self, line):
|
self.clear()
|
wordList = line.split(SPLITCHAR)
|
try:
|
self.StoreItemKey = int(wordList[0].strip())
|
self.AreaIndex = int(wordList[1].strip())
|
self.MenuIndex = int(wordList[2].strip())
|
self.TypeIndex = int(wordList[3].strip())
|
self.ItemID = int(wordList[4].strip())
|
self.SaleState = int(wordList[5].strip())
|
self.ItemCount = int(wordList[6].strip())
|
self.Gold = int(wordList[7].strip())
|
self.GoldPaper = int(wordList[8].strip())
|
self.Silver = int(wordList[9].strip())
|
self.SilverPaper = int(wordList[10].strip())
|
|
except IndexError,e:
|
errorStr = '''\nIndexError:%s [lineData:"%s"]'''%(e, line)
|
raise Exception(errorStr)
|
except:
|
errorStr = '''\nException on readLine:[lineData:"%s"]\n%s'''%(line,traceback.format_exc())
|
raise Exception(errorStr)
|
|
|
def __getRecord(self):
|
'''×éÖ¯´æ´¢¼Ç¼'''
|
rec = {}
|
rec[u'StoreItemKey'] = self.StoreItemKey
|
rec[u'AreaIndex'] = self.AreaIndex
|
rec[u'MenuIndex'] = self.MenuIndex
|
rec[u'TypeIndex'] = self.TypeIndex
|
rec[u'ItemID'] = self.ItemID
|
rec[u'SaleState'] = self.SaleState
|
rec[u'ItemCount'] = self.ItemCount
|
rec[u'Gold'] = self.Gold
|
rec[u'GoldPaper'] = self.GoldPaper
|
rec[u'Silver'] = self.Silver
|
rec[u'SilverPaper'] = self.SilverPaper
|
|
return rec
|
|
|
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_146, 'tagDBStoreItem Insert failed!StoreItemKey = %s, error = %s, trycnt = %d'%(self.StoreItemKey, err, trycnt))
|
mylog.error(msg)
|
|
return False
|
return True
|
|
|
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(tagDBStoreItem)
|
|
|
def readData(self, buf, pos):
|
if len(buf) < pos + self.getLength():
|
msg = error.formatMsg('error', error.ERROR_NO_147, 'len = %s while %s expected!'%(len(buf) - pos, self.getLength()))
|
mylog.error(msg)
|
return -1
|
self.clear()
|
memmove(addressof(self), buf[pos:], self.getLength())
|
return pos + self.getLength()
|
|
def outputString(self):
|
output = '''//É̳ÇÎïÆ·#tagDBStoreItem:
|
StoreItemKey = %s,
|
AreaIndex = %s,
|
MenuIndex = %s,
|
TypeIndex = %s,
|
ItemID = %s,
|
SaleState = %s,
|
ItemCount = %s,
|
Gold = %s,
|
GoldPaper = %s,
|
Silver = %s,
|
SilverPaper = %s,
|
ADOResult = %s,
|
'''%(
|
self.StoreItemKey,
|
self.AreaIndex,
|
self.MenuIndex,
|
self.TypeIndex,
|
self.ItemID,
|
self.SaleState,
|
self.ItemCount,
|
self.Gold,
|
self.GoldPaper,
|
self.Silver,
|
self.SilverPaper,
|
self.ADOResult
|
)
|
return output
|
|
|
#------------------------------------------------------
|
#Çл»µã¶¨Òå#tagTransportRefresh
|
class tagTransportRefresh(Structure):
|
_pack_ = 1
|
_fields_ = [
|
('RefreshID', c_ulong),
|
('MapID', c_ushort),
|
('PosX', c_ushort),
|
('PosY', c_ushort),
|
('Range', c_ushort),
|
('TargetMapID', c_ushort),
|
('TargetPosX', c_ushort),
|
('TargetPosY', c_ushort),
|
('ADOResult', c_ulong),
|
]
|
|
def __init__(self):
|
Structure.__init__(self)
|
self.clear()
|
|
def clear(self):
|
memset(addressof(self), 0, self.getLength())
|
|
|
def readLine(self, line):
|
self.clear()
|
wordList = line.split(SPLITCHAR)
|
try:
|
self.RefreshID = int(wordList[0].strip())
|
self.MapID = int(wordList[1].strip())
|
self.PosX = int(wordList[2].strip())
|
self.PosY = int(wordList[3].strip())
|
self.Range = int(wordList[4].strip())
|
self.TargetMapID = int(wordList[5].strip())
|
self.TargetPosX = int(wordList[6].strip())
|
self.TargetPosY = int(wordList[7].strip())
|
|
except IndexError,e:
|
errorStr = '''\nIndexError:%s [lineData:"%s"]'''%(e, line)
|
raise Exception(errorStr)
|
except:
|
errorStr = '''\nException on readLine:[lineData:"%s"]\n%s'''%(line,traceback.format_exc())
|
raise Exception(errorStr)
|
|
|
def __getRecord(self):
|
'''×éÖ¯´æ´¢¼Ç¼'''
|
rec = {}
|
rec[u'RefreshID'] = self.RefreshID
|
rec[u'MapID'] = self.MapID
|
rec[u'PosX'] = self.PosX
|
rec[u'PosY'] = self.PosY
|
rec[u'Range'] = self.Range
|
rec[u'TargetMapID'] = self.TargetMapID
|
rec[u'TargetPosX'] = self.TargetPosX
|
rec[u'TargetPosY'] = self.TargetPosY
|
|
return rec
|
|
|
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_146, 'tagTransportRefresh Insert failed!RefreshID = %s, error = %s, trycnt = %d'%(self.RefreshID, err, trycnt))
|
mylog.error(msg)
|
|
return False
|
return True
|
|
|
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(tagTransportRefresh)
|
|
|
def readData(self, buf, pos):
|
if len(buf) < pos + self.getLength():
|
msg = error.formatMsg('error', error.ERROR_NO_147, 'len = %s while %s expected!'%(len(buf) - pos, self.getLength()))
|
mylog.error(msg)
|
return -1
|
self.clear()
|
memmove(addressof(self), buf[pos:], self.getLength())
|
return pos + self.getLength()
|
|
def outputString(self):
|
output = '''//Çл»µã¶¨Òå#tagTransportRefresh:
|
RefreshID = %s,
|
MapID = %s,
|
PosX = %s,
|
PosY = %s,
|
Range = %s,
|
TargetMapID = %s,
|
TargetPosX = %s,
|
TargetPosY = %s,
|
ADOResult = %s,
|
'''%(
|
self.RefreshID,
|
self.MapID,
|
self.PosX,
|
self.PosY,
|
self.Range,
|
self.TargetMapID,
|
self.TargetPosX,
|
self.TargetPosY,
|
self.ADOResult
|
)
|
return output
|
|
|
#·ÉÐÐÎï¼þ»ù´¡ÐÅÏ¢±í#tagFlyObjBaseInfo
|
class tagFlyObjBaseInfo(Structure):
|
_pack_ = 1
|
_fields_ = [
|
('TypeID', c_ulong),
|
('Size', c_ushort),
|
('Speed', c_ushort),
|
('BombOnArrive', c_ubyte),
|
('DisapperaredOnHit', c_ubyte),
|
('ADOResult', c_ulong),
|
]
|
|
def __init__(self):
|
Structure.__init__(self)
|
self.clear()
|
|
def clear(self):
|
memset(addressof(self), 0, self.getLength())
|
|
|
def readLine(self, line):
|
self.clear()
|
wordList = line.split(SPLITCHAR)
|
try:
|
self.TypeID = int(wordList[0].strip())
|
self.Size = int(wordList[1].strip())
|
self.Speed = int(wordList[2].strip())
|
self.BombOnArrive = int(wordList[3].strip())
|
self.DisapperaredOnHit = int(wordList[4].strip())
|
|
except IndexError,e:
|
errorStr = '''\nIndexError:%s [lineData:"%s"]'''%(e, line)
|
raise Exception(errorStr)
|
except:
|
errorStr = '''\nException on readLine:[lineData:"%s"]\n%s'''%(line,traceback.format_exc())
|
raise Exception(errorStr)
|
|
|
def __getRecord(self):
|
'''×éÖ¯´æ´¢¼Ç¼'''
|
rec = {}
|
rec[u'TypeID'] = self.TypeID
|
rec[u'Size'] = self.Size
|
rec[u'Speed'] = self.Speed
|
rec[u'BombOnArrive'] = self.BombOnArrive
|
rec[u'DisapperaredOnHit'] = self.DisapperaredOnHit
|
|
return rec
|
|
|
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_146, 'tagFlyObjBaseInfo Insert failed!TypeID = %s, error = %s, trycnt = %d'%(self.TypeID, err, trycnt))
|
mylog.error(msg)
|
|
return False
|
return True
|
|
|
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(tagFlyObjBaseInfo)
|
|
|
def readData(self, buf, pos):
|
if len(buf) < pos + self.getLength():
|
msg = error.formatMsg('error', error.ERROR_NO_147, 'len = %s while %s expected!'%(len(buf) - pos, self.getLength()))
|
mylog.error(msg)
|
return -1
|
self.clear()
|
memmove(addressof(self), buf[pos:], self.getLength())
|
return pos + self.getLength()
|
|
def outputString(self):
|
output = '''//·ÉÐÐÎï¼þ»ù´¡ÐÅÏ¢±í#tagFlyObjBaseInfo:
|
TypeID = %s,
|
Size = %s,
|
Speed = %s,
|
BombOnArrive = %s,
|
DisapperaredOnHit = %s,
|
ADOResult = %s,
|
'''%(
|
self.TypeID,
|
self.Size,
|
self.Speed,
|
self.BombOnArrive,
|
self.DisapperaredOnHit,
|
self.ADOResult
|
)
|
return output
|
|
|
|
|
def sysDBLoadFromFile(className, fileName):
|
return MangoDBCommon.sysDBLoadFromFile(className, fileName)
|
|
|
def SysDBUpdate(className, collection, fileName):
|
return MangoDBCommon.SysDBUpdate(className, collection, fileName)
|
|
