server/game2004api
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
aozhiwei 2020-12-04 13:28:28 +08:00
parent 5b0463bede
commit 4d1302659b
1 changed files with 10 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
tools/rankserver/app.py
View File

@ -21,7 +21,7 @@ import functools
CONFIG_DIR = '../config' if f7.isOnlineEnv() else '/var/data/conf_test/game2004api_rankserver/config' CONFIG_DIR = '../config' if f7.isOnlineEnv() else '/var/data/conf_test/game2004api_rankserver/config'
RANK_KEY_PREFIX = 'game2004api:' RANK_KEY_PREFIX = 'game2004api:'
DBNAME_PREFIX = 'gamedb2004_' DBNAME_PREFIX = 'gamedb2004_'
IGNORE_GUESET_ACCOUNT = 0 IGNORE_GUEST_ACCOUNT = 0
def _take_pass(elem): def _take_pass(elem):
return elem[3] return elem[3]
@ -139,7 +139,8 @@ def fullUpdateRank():
for row in cursor: for row in cursor:
has_data = True has_data = True
last_idx = max(row[8], last_idx) last_idx = max(row[8], last_idx)
if IGNORE_GUESET_ACCOUNT and (row[1] == '游客' or row[1] == '极乐玩家'): user_name = str(row[1], encoding='utf8')
if IGNORE_GUEST_ACCOUNT and (user_name == '游客' or user_name == '极乐玩家'):
continue continue
#更新击杀榜 #更新击杀榜
channel = f7.getChannelByAccountId(row[0]) channel = f7.getChannelByAccountId(row[0])
@ -207,7 +208,8 @@ def incrementUpdateRank():
has_data = True has_data = True
channel = f7.getChannelByAccountId(row[0]) channel = f7.getChannelByAccountId(row[0])
last_idx = max(row[8], last_idx) last_idx = max(row[8], last_idx)
if IGNORE_GUESET_ACCOUNT and (row[1] == '游客' or row[1] == '极乐玩家'): user_name = str(row[1], encoding='utf8')
if IGNORE_GUEST_ACCOUNT and (user_name == '游客' or user_name == '极乐玩家'):
continue continue
if checkchannel(channel): if checkchannel(channel):
#更新击杀榜 #更新击杀榜
@ -247,16 +249,16 @@ def _incrementUpdateRank(rushtime):
lambda : _incrementUpdateRank(rushtime)) lambda : _incrementUpdateRank(rushtime))
f7.app.createAsyncTask(done_callback, incrementUpdateRank, ()) f7.app.createAsyncTask(done_callback, incrementUpdateRank, ())
conf = json.loads(open(CONFIG_DIR + '/rankserver.json', 'r').read())
RANK_KEY_PREFIX = conf.get('key_prefix', RANK_KEY_PREFIX)
DBNAME_PREFIX = conf.get('dbname_prefix', DBNAME_PREFIX)
IGNORE_GUEST_ACCOUNT = conf.get('ignore_guest_account', IGNORE_GUEST_ACCOUNT)
if __name__ == "__main__": if __name__ == "__main__":
q7.xPrint('pid %d' % os.getpid()) q7.xPrint('pid %d' % os.getpid())
f7.app.init('/data/logs/game2004_rankserver/logs') f7.app.init('/data/logs/game2004_rankserver/logs')
f7.udplog.info('rankserver start pid:' + str(os.getpid())) f7.udplog.info('rankserver start pid:' + str(os.getpid()))
conf = json.loads(open(CONFIG_DIR + '/rankserver.json', 'r').read())
RANK_KEY_PREFIX = conf.get('key_prefix', RANK_KEY_PREFIX)
DBNAME_PREFIX = conf.get('dbname_prefix', DBNAME_PREFIX)
IGNORE_GUESET_ACCOUNT = conf.get('ignore_guest_account', IGNORE_GUESET_ACCOUNT)
conf['rushtime'] = 300 conf['rushtime'] = 300
f7.timer.callLater(conf['rushtime'], f7.timer.callLater(conf['rushtime'],
lambda : _incrementUpdateRank(conf['rushtime'])) lambda : _incrementUpdateRank(conf['rushtime']))