#!/usr/bin/python
|
# -*- coding: GBK -*-
|
#-------------------------------------------------------------------------------
|
#
|
#-------------------------------------------------------------------------------
|
#
|
|
#from Common import mylog
|
from DBCommon import GlobalFunctions
|
import traceback
|
import ConfigParser
|
import os
|
|
from DBCommon import error
|
#mylog = __import__('Common.mylog')
|
from Common import mylog
|
|
#DBÅäÖÃ×Öµä
|
#¸ñʽ£ºkeyname:[defvalue, secionname]£¬ÐÂÔöÅäÖÃÖ»ÒªÔÚÏÂÃæ×ֵ䶨ÒåÖÐÐÂÔöÒ»Ðм´¿É
|
#Ó÷¨£¬importÄ£¿éºó£¬Ö±½ÓDBConfig.¿ª¹ØÃû³Æ ¼´¿É
|
|
###PyMongoDataServer.ini###
|
#ÔËά±ØÐëÐ޸ĵÄÅäÖÃÏî
|
BaseConfig ={
|
#connect section
|
#"PyMongoDBPort":[16899, "connect"], #PyMongoDBServer¶Ë¿Ú CenterGate ÓõĶ˿Ú
|
#"PyMongoDBPort_CreateRole":[16900, "connect"], #PyMongoDBServer¶Ë¿Ú CreateRole ÓõĶ˿Ú
|
#"PyMongoDBPort_GMTool":[16901, "connect"], #PyMongoDBServer¶Ë¿Ú GMTool ÓõĶ˿Ú
|
|
#"USER_DB_PORT":[27017, "connect"], #MongoDB¶Ë¿Ú
|
"USER_DB_IP":["localhost", "connect"], #MongoDB IP
|
"USER_DB_NAME":["GameUser", "connect"], #MongoDB Name#
|
|
#"SYS_DB_PORT":[27017, "connect"],#MongoDB¶Ë¿Ú
|
"SYS_DB_IP":["localhost", "connect"], #MongoDB IP
|
"SYS_DB_NAME":["GameSys", "connect"], #MongoDB Name
|
|
#"LOG_DB_PORT":[27017, "connect"],#MongoDB¶Ë¿Ú
|
"LOG_DB_IP":["localhost", "connect"], #MongoDB IP
|
"LOG_DB_NAME":["GameLog", "connect"], #MongoDB Name
|
|
#platform section
|
"PlatformName":["", "platform"], #ƽ̨
|
"ServerID":["", "platform"], #Çø·þID
|
|
#ID ·ÖÅä·þÎñÆ÷ÉèÖÃ
|
"UseIDDispatchServer":[0, "IDDispatch"], #ÆôÓÃID·ÖÅä·þÎñÆ÷¿ª¹Ø
|
"IDDispatchServerIP":["localhost", "IDDispatch"], #ID·ÖÅä·þÎñÆ÷ ÓòÃû
|
"IDDispatchServerPort":[8001, "IDDispatch"], #ID·ÖÅä·þÎñÆ÷ ¶Ë¿Ú
|
"IDDispatchPlayeIDLimit":[100, "IDDispatch"], #PlayerIDÔ¤·ÖÅäÊýÁ¿ÏÂÏÞ
|
#"IDDispatchFamilyIDLimit":[30, "IDDispatch"], #FamilyIDÔ¤·ÖÅäÊýÁ¿ÏÂÏÞ---ÔÚGameServerÅжÏ֪ͨ
|
|
#Õ˺ÅÑéÖ¤
|
"CheckTokenUrl":["", "CheckAccID"],
|
|
|
#ʼþ»Ø±¨ºÍ¶¨Ê±´¦Àí
|
"OpenErrLogReport":[0,"OpenErrLogReport"], #¿ªÆô»Ø±¨´íÎóÊýÁ¿
|
"PlatformName":["9377","platform"], #ZoneName
|
"ServerID":["s1","platform"], #OperatorID
|
"AppId":["AppId1","EventReport"], #AppId
|
"Key":["7ded96779343f198de9b95a05a0704c9","EventReport"], #Secret
|
"SessionGUID":["sid1","EventReport"], #SessionID
|
"ProductID":["pid1","EventReport"], #ProductID
|
"ErrLogReportEventID":[22222,"EventReport"], #»Ø±¨´íÎóÊýÁ¿Ê¼þID
|
"ErrLogReportInterval":[60000,"EventReport"], #»Ø±¨´íÎóÊýÁ¿¼ä¸ô
|
"ReportUrl":["","EventReport"], # Êý¾Ý»ã±¨µØÖ·
|
|
"LoginKey":["","SPGame"] # ˼è±ÓÎÏ·µÇ¼key
|
}
|
|
###config\\config.ini###
|
dbconfig = {
|
#auth section
|
"userdb_user":['', "auth"],
|
"userdb_pwd":['', 'auth'],
|
"sysdb_user":['', "auth"],
|
"sysdb_pwd":['', 'auth'],
|
"logdb_user":['', "auth"],
|
"logdb_pwd":['', 'auth'],
|
|
#connect section
|
"ConnectionQueueSize":[1, "connect"],
|
"PyMongoDBPort":[16899, "connect"], #PyMongoDBServer¶Ë¿Ú CenterGate ÓõĶ˿Ú
|
"PyMongoDBPort_CreateRole":[16900, "connect"], #PyMongoDBServer¶Ë¿Ú CreateRole ÓõĶ˿Ú
|
"PyMongoDBPort_GMTool":[16901, "connect"], #PyMongoDBServer¶Ë¿Ú GMTool ÓõĶ˿Ú
|
"MergePort":[16902, "connect"], #¿ç·þ½Ó¿Ú¶Ë¿Ú
|
|
"USER_DB_PORT":[27017, "connect"], #MongoDB¶Ë¿Ú
|
#"USER_DB_IP":["localhost", "connect"], #MongoDB IP
|
#"USER_DB_NAME":["GameUser", "connect"], #MongoDB Name
|
#
|
"SYS_DB_PORT":[27017, "connect"],#MongoDB¶Ë¿Ú
|
#"SYS_DB_IP":["localhost", "connect"], #MongoDB IP
|
#"SYS_DB_NAME":["GameSys", "connect"], #MongoDB Name
|
#
|
"LOG_DB_PORT":[27017, "connect"],#MongoDB¶Ë¿Ú
|
#"LOG_DB_IP":["localhost", "connect"], #MongoDB IP
|
#"LOG_DB_NAME":["GameLog", "connect"], #MongoDB Name
|
|
#encoding
|
"base64":[1, "encoding"], #ÊÇ·ñ¶Ô×Ö·û´®½øÐÐBASE64±àÂë
|
"encoding":['gbk', "encoding"], #×Ö·û´®±àÂ룬ÔÚbase64ΪFalseʱÓÐЧ
|
|
#merge
|
"randPswLen":[8, "merge"], #ºÏ·þÉú³ÉËæ»úÃÜÂ볤¶È,²»µÃ³¬¹ý32
|
"randPswHasDigit":[True, "merge"], #Ëæ»úÃÜÂëÊÇ·ñ°üº¬Êý×Ö
|
"randPswHasLowLetter":[True, "merge"], #Ëæ»úÃÜÂëÊÇ·ñ°üº¬Ð¡Ð´×Ö·û
|
"randPswHasUpperLetter":[True, "merge"], #Ëæ»úÃÜÂëÊÇ·ñ°üº¬´óд×Ö·û
|
"randPswHasSpecialChar":[False, "merge"], #Ëæ»úÃÜÂëÊÇ·ñ°üº¬ÌØÊâ×Ö·û
|
|
#config section
|
"MultiThreading":[False,"config"], #Ö÷mainÊÇ·ñ¿ªÆô¶àÏß³Ì
|
"checkSID":[False, "config"], #ÊÇ·ñ½øÐÐSIDУÑé
|
"TryCntOnWriteFail":[3, 'config'], #´æ´¢Ê§°Üºó£¬³¢ÊÔ´ÎÊý, ĬÈÏ3´Î
|
"IsOpenDbSaveServer":[False, 'config'], #ÊÇ·ñ´ò¿ªmongoDBSaveServer
|
"maxReconnectCnt":[100, 'config'],
|
"UploadSysTables":[False, "config"],
|
#"MainLogPath":["D:\\ServerLog", "config"],
|
|
"EventShellEnable":[False, "config"], #ÊÇ·ñÆôÓÃEventShellDLL·¢ËÍÁ÷Ïò¼Ç¼
|
"EventShellIP":["127.0.0.1", "config"], #ʼþ½Ó¿Ú·þÎñÆ÷µÄIPµØÖ·
|
"EventShellPort":[60000, "config"], #ʼþ½Ó¿Ú·þÎñÆ÷µÄ¶Ë¿ÚºÅ
|
"EventShellGroupID":[0,"config"], #±¾·þÎñÆ÷µÄ·þÎñÆ÷×é±êʶ
|
"EventShellServerID":[0,"config"], #±¾·þÎñÆ÷µÄID
|
"EventShellHeartInterval":[60000, "config"],#Á¬½Óʼþ½Ó¿Ú·þÎñÆ÷ÐÄÌøʱ¼ä¼ä¸ô(ms)
|
"EventShellDllPath":["EventToInterfaceDll.dll", "config"],#Ö¸¶¨Ê¼þ½Ó¿Ú·þÎñÆ÷DllµØÖ·
|
"EventShellDllLogPath":["D:\\ServerLog", "config"],
|
|
"IsOpenLogDBFileSave":[False, 'config'], #ÊÇ·ñ´ò¿ªLogDBÎļþ±£´æ
|
"LogDB_EventShell_Save":[True, 'config'], #LogDB±£´æͨ¹ýEventShell±£´æ(Èç¹ûҪʹÓøù¦ÄÜ,Ò»¶¨Òª¹Ø±ÕIsOpenLogDBFileSave,²¢¿ªÆôEventShellEnableºÍÅäÖÃÏà¹ØÍøÂç²ÎÊý)
|
"PackSave":[True, 'config'], #ÊÇ·ñ´ò¿ª´ò°ü±£´æ
|
"StartProfile":[True, 'config'], #ÊÇ·ñ¿ªÆôÐÔÄÜÆÀ²â
|
"ProfileThreshold":[100, 'config'], #ÐÔÄÜ·§Öµ£¬Ä¬ÈÏ100ºÁÃ룬³¬¹ýÔòÊä³öÒ»ÌõÈÕÖ¾
|
"ProfileQueueThresholdMax":[100, 'config'], #ÐÔÄÜͳ¼Æ¶ÓÁÐÉÏÏÞ£¬³¬¹ý´ËÉÏÏÞ´¥·¢Ð´Ò»ÌõÈÕÖ¾
|
"ProfileQueueThresholdMin":[10, 'config'], #ÐÔÄÜͳ¼Æ¶ÓÁÐÏÂÏÞ£¬µÍÓÚ´ËÉÏÏÞ´¥·¢Ð´Ò»ÌõÈÕÖ¾
|
|
#env section
|
"Python_Ver":["2.7.2", "environment"],
|
"PyMongo_Ver":["2.5.1", "environment"],
|
"MongoDB_Ver":["2.4.3", "environment"],
|
"MongoDB_Bits":[64, "environment"],
|
|
#InnerParam
|
"PLAYERID_FEED":[10000, "InnerParam"],
|
"PLAYERID_STEP":[1, 'InnerParam'],
|
"LOGINDEX_FEED":[0, "InnerParam"], #tagDBMapServerInfoÈÕÖ¾Ë÷ÒýÖÖ×ÓÆðʼ
|
"LOGINDEX_STEP":[1, 'InnerParam'], #tagDBMapServerInfoÈÕÖ¾Ë÷ÒýÔöÁ¿
|
"LOGDB_LOGINDEX_FEED":[0, 'InnerParam'],#tagDBPlayerLogÈÕÖ¾Ë÷ÒýÖÖ×ÓÆðʼ
|
"LOGDB_LOGINDEX_STEP":[1, 'InnerParam'],#tagDBPlayerLogÈÕÖ¾Ë÷ÒýÔöÁ¿
|
"LOGDB_SvrStatus_fldIndex_FEED":[0, 'InnerParam'],#SvrStatusÈÕÖ¾Ë÷ÒýÖÖ×ÓÆðʼ
|
"LOGDB_SvrStatus_fldIndex_STEP":[1, 'InnerParam'],#SvrStatusÈÕÖ¾Ë÷ÒýÔöÁ¿
|
"LOGDB_AccForbiddenLog_StateID_FEED":[0, 'InnerParam'], #AccForbiddenLogÈÕÖ¾Ë÷ÒýÖÖ×ÓÆðʼ
|
"LOGDB_AccForbiddenLog_StateID_STEP":[1, 'InnerParam'], #AccForbiddenLogÈÕÖ¾Ë÷ÒýÔöÁ¿
|
"LOGDB_tagDBServerMoneyLog_LogIndex_FEED":[0, 'InnerParam'], #tagDBServerMoneyLog ÈÕÖ¾Ë÷ÒýÖÖ×ÓÆðʼ
|
"LOGDB_tagDBServerMoneyLog_LogIndex_STEP":[1, 'InnerParam'], #tagDBServerMoneyLog ÈÕÖ¾Ë÷ÒýÔöÁ¿
|
"LOGDB_tagDBApexKickLog_KickLogIndex_FEED":[0, 'InnerParam'], #tagDBApexKickLog ÈÕÖ¾Ë÷ÒýÖÖ×ÓÆðʼ
|
"LOGDB_tagDBApexKickLog_KickLogIndex_STEP":[1, 'InnerParam'], #tagDBApexKickLog ÈÕÖ¾Ë÷ÒýÔöÁ¿
|
"LOGDB_tagDBGateServerIP_LogIndex_FEED":[0, 'InnerParam'], #tagDBGateServerIP ÈÕÖ¾Ë÷ÒýÖÖ×ÓÆðʼ
|
"LOGDB_tagDBGateServerIP_LogIndex_STEP":[1, 'InnerParam'], #tagDBGateServerIP ÈÕÖ¾Ë÷ÒýÔöÁ¿
|
"LOGDB_tagDBHugeTrade_TradeIndex_FEED":[0, 'InnerParam'], #tagDBHugeTrade ÈÕÖ¾Ë÷ÒýÖÖ×ÓÆðʼ
|
"LOGDB_tagDBHugeTrade_TradeIndex_STEP":[1, 'InnerParam'], #tagDBHugeTrade ÈÕÖ¾Ë÷ÒýÔöÁ¿
|
"LOGDB_tagDBPlayerSaveCoinLog_LogIndex_FEED":[0, 'InnerParam'], #tagDBPlayerSaveCoinLog ÈÕÖ¾Ë÷ÒýÖÖ×ÓÆðʼ
|
"LOGDB_tagDBPlayerSaveCoinLog_LogIndex_STEP":[1, 'InnerParam'], #tagDBPlayerSaveCoinLog ÈÕÖ¾Ë÷ÒýÔöÁ¿
|
"LOGDB_tagDBServerKickLog_LogIndex_FEED":[0, 'InnerParam'], #tagDBServerKickLog ÈÕÖ¾Ë÷ÒýÖÖ×ÓÆðʼ
|
"LOGDB_tagDBServerKickLog_LogIndex_STEP":[1, 'InnerParam'], #tagDBServerKickLog ÈÕÖ¾Ë÷ÒýÔöÁ¿
|
"LOGDB_tagDBTalkTraceLog_LogIndex_FEED":[0, 'InnerParam'], #tagDBTalkTraceLog ÈÕÖ¾Ë÷ÒýÖÖ×ÓÆðʼ
|
"LOGDB_tagDBTalkTraceLog_LogIndex_STEP":[1, 'InnerParam'], #tagDBTalkTraceLog ÈÕÖ¾Ë÷ÒýÔöÁ¿
|
"tagExpiation_ExpiationIndex_FEED":[0, 'InnerParam'], #tagExpiation Ë÷ÒýÖÖ×ÓÆðʼ
|
"tagExpiation_ExpiationIndex_STEP":[1, 'InnerParam'], #tagExpiation Ë÷ÒýÔöÁ¿
|
"tagPetExpiation_ExpiationIndex_FEED":[0, 'InnerParam'], #tagPetExpiation Ë÷ÒýÖÖ×ÓÆðʼ
|
"tagPetExpiation_ExpiationIndex_STEP":[1, 'InnerParam'], #tagPetExpiation Ë÷ÒýÔöÁ¿
|
"tagDBImpeach_ImpeachIndex_FEED":[0, 'InnerParam'], #tagDBImpeach Ë÷ÒýÖÖ×ÓÆðʼ
|
"tagDBImpeach_ImpeachIndex_STEP":[1, 'InnerParam'], #tagDBImpeach Ë÷ÒýÔöÁ¿
|
"tagDBCoinChangeLog_LogIndex_FEED":[0, 'InnerParam'], #tagDBCoinChangeLog Ë÷ÒýÖÖ×ÓÆðʼ
|
"tagDBCoinChangeLog_LogIndex_STEP":[1, 'InnerParam'], #tagDBCoinChangeLog Ë÷ÒýÔöÁ¿
|
}
|
|
|
def ReadCongfigValue(config, secname, keyname, defvalue):
|
try:
|
if config.has_option(secname, keyname):
|
value = config.get(secname, keyname)
|
# if type(defvalue) == str:
|
# value = type(defvalue)(value)
|
if type(defvalue) == bool:
|
value = type(defvalue)(int(value))
|
else:
|
value = type(defvalue)(value)
|
else:return defvalue
|
except:
|
msg = error.formatMsg('error', error.ERROR_NO_18, 'config = %s, secname = %s, keyname = %s, defvalue = %s\n%s'%(config, secname, keyname, defvalue, traceback.format_exc()))
|
mylog.error(msg)
|
return None
|
# print value
|
return value
|
|
def ReadDBConfig():
|
try:
|
self_module = __import__(__name__)
|
config = ConfigParser.ConfigParser()
|
|
#¶ÁÈ¡Êý¾Ý¿âÅäÖÃÎļþconfig\\config.ini
|
config.read(os.path.join(GlobalFunctions.getAppPath(), 'config\\config.ini'))
|
for k, v in dbconfig.items():
|
value = ReadCongfigValue(config, v[1], k, v[0])
|
if value == None:return False
|
setattr(self_module, k, value)
|
|
#¶ÁÈ¡Êý¾Ý¿âÅäÖÃÎļþPyMongoDataServer.ini
|
config.read(os.path.join(GlobalFunctions.getAppPath(), 'PyMongoDataServer.ini'))
|
for k, v in BaseConfig.items():
|
value = ReadCongfigValue(config, v[1], k, v[0])
|
if value == None:return False
|
setattr(self_module, k, value)
|
#¶¯Ì¬¼ÓÔØÓÐÅäÖÃƽ̨ºÏ·þÖ÷·þµÄƽ̨Ö÷·þID
|
sectionName = "platform"
|
if config.has_section(sectionName):
|
optionsList = config.options(sectionName)
|
# ×¢Òâoptions ÒѾÊÇСд µ÷ÓÃÒ²Ö»ÄÜÓÃСд
|
for k in optionsList:
|
if "mainserverid" in k:
|
value = ReadCongfigValue(config, sectionName, k, 0)
|
if value:
|
setattr(self_module, k, value)
|
elif "loginkey" in k:
|
value = ReadCongfigValue(config, sectionName, k, 0)
|
if value:
|
setattr(self_module, k, value)
|
|
#¼ì²é²¢½âÃÜmongodbµÄµÇ¼Óû§ÃûºÍÃÜÂë
|
#userdb
|
if not self_module.userdb_user:
|
msg = error.formatMsg('DeployError', error.ERROR_NO_19, "user db mongodb longin user name is empty!")
|
mylog.DeployError(msg, True)
|
return False
|
|
if self_module.userdb_pwd:
|
ret, self_module.userdb_pwd = GlobalFunctions.GetEncodePsw(self_module.userdb_pwd)
|
if not ret:
|
msg = error.formatMsg('DeployError', error.ERROR_NO_20, "Decrypt userdb_pwd faied.")
|
mylog.DeployError(msg, True)
|
return False
|
else:
|
msg = error.formatMsg('DeployError', error.ERROR_NO_21, "user db mongodb longin pwd is empty!")
|
mylog.DeployError(msg, True)
|
return False
|
|
#sysdb
|
if not self_module.sysdb_user:
|
msg = error.formatMsg('DeployError', error.ERROR_NO_22, "sys db mongodb longin user name is empty!")
|
mylog.DeployError(msg, True)
|
return False
|
|
if self_module.sysdb_pwd:
|
ret, self_module.sysdb_pwd = GlobalFunctions.GetEncodePsw(self_module.sysdb_pwd)
|
if not ret:
|
msg = error.formatMsg('DeployError', error.ERROR_NO_23, "Decrypt sysdb_pwd faied.")
|
mylog.DeployError(msg, True)
|
return False
|
else:
|
msg = error.formatMsg('DeployError', error.ERROR_NO_24, "sys db mongodb longin pwd is empty!")
|
mylog.DeployError(msg, True)
|
return False
|
|
#logdb
|
if not self_module.logdb_user:
|
msg = error.formatMsg('DeployError', error.ERROR_NO_25, "log db mongodb longin user name is empty!")
|
mylog.DeployError(msg, True)
|
return False
|
|
if self_module.logdb_pwd:
|
ret, self_module.logdb_pwd = GlobalFunctions.GetEncodePsw(self_module.logdb_pwd)
|
if not ret:
|
msg = error.formatMsg('DeployError', error.ERROR_NO_26, "Decrypt logdb_pwd faied.")
|
mylog.DeployError(msg, True)
|
return False
|
else:
|
msg = error.formatMsg('DeployError', error.ERROR_NO_27, "log db mongodb longin pwd is empty!")
|
mylog.DeployError(msg, True)
|
return False
|
except:
|
msg = error.formatMsg('error', error.ERROR_NO_28, '%s'%traceback.format_exc())
|
mylog.error(msg)
|
return False
|
return True
|
|
dbconfig_init = False
|
|
if not dbconfig_init:
|
if not ReadDBConfig():
|
msg = error.formatMsg('fatal', error.ERROR_NO_29, "Init config failed.")
|
mylog.fatal(msg)
|
dbconfig_init = True
|
|
