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-10-27 15:17:09 +08:00
parent 461a6aa4ed
commit 481bb278dc
1 changed files with 36 additions and 27 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

63
tools/rankserver/app.py
View File

@ -37,6 +37,11 @@ def getRedisConf():
redis_conf = json.loads(open(CONFIG_DIR + '/rankserver.redis.cluster.json', 'r').read()) redis_conf = json.loads(open(CONFIG_DIR + '/rankserver.redis.cluster.json', 'r').read())
return redis_conf; return redis_conf;
def checkchannel(channel):
if channel == 6006:
return false
else:
return true
def info(msg): def info(msg):
print(str(datetime.datetime.now()) + '[INFO] ' + msg) print(str(datetime.datetime.now()) + '[INFO] ' + msg)
@ -132,19 +137,22 @@ def fullUpdateRank():
has_data = True has_data = True
#更新击杀榜 #更新击杀榜
channel = f7.getChannelByAccountId(row[0]) channel = f7.getChannelByAccountId(row[0])
if channel not in kill_hash: if checkchannel(channel) == true:
kill_hash[channel] = [] if channel not in kill_hash:
_refreshData(row, kill_hash[channel], take_kills) kill_hash[channel] = []
_refreshData(row, kill_hash[channel], take_kills)
#更新胜场榜 #更新胜场榜
channel = f7.getChannelByAccountId(row[0]) channel = f7.getChannelByAccountId(row[0])
if channel not in win_hash: if checkchannel(channel) == true:
win_hash[channel] = [] if channel not in win_hash:
_refreshData(row, win_hash[channel], take_game_times) win_hash[channel] = []
_refreshData(row, win_hash[channel], take_game_times)
#更新积分榜 #更新积分榜
channel = f7.getChannelByAccountId(row[0]) channel = f7.getChannelByAccountId(row[0])
if channel not in integral_hash: if checkchannel(channel) == true:
integral_hash[channel] = [] if channel not in integral_hash:
_refreshData(row, integral_hash[channel], take_integral_times) integral_hash[channel] = []
_refreshData(row, integral_hash[channel], take_integral_times)
last_idx = max(row[8], last_idx) last_idx = max(row[8], last_idx)
time.sleep(0.001); time.sleep(0.001);
if not has_data: if not has_data:
@ -193,24 +201,25 @@ def incrementUpdateRank():
for row in cursor: for row in cursor:
has_data = True has_data = True
channel = f7.getChannelByAccountId(row[0]) channel = f7.getChannelByAccountId(row[0])
#更新击杀榜 if checkchannel(channel) == true:
if channel not in kill_hash: #更新击杀榜
kill_list = r.get('game2004api:kill_rank_' + channel) if channel not in kill_hash:
kill_hash[channel] = [] if not kill_list else json.loads(kill_list) kill_list = r.get('game2004api:kill_rank_' + channel)
_delRepeatData(row, kill_hash[channel]) kill_hash[channel] = [] if not kill_list else json.loads(kill_list)
_refreshData(row, kill_hash[channel], take_kills) _delRepeatData(row, kill_hash[channel])
#更新胜场榜 _refreshData(row, kill_hash[channel], take_kills)
if channel not in win_hash: #更新胜场榜
win_list = r.get('game2004api:win_rank_' + channel) if channel not in win_hash:
win_hash[channel] = [] if not win_list else json.loads(win_list) win_list = r.get('game2004api:win_rank_' + channel)
_delRepeatData(row, win_hash[channel]) win_hash[channel] = [] if not win_list else json.loads(win_list)
_refreshData(row, win_hash[channel], take_game_times) _delRepeatData(row, win_hash[channel])
#更新积分榜 _refreshData(row, win_hash[channel], take_game_times)
if channel not in integral_hash: #更新积分榜
integral_list = r.get('game2004api:integral_rank_' + channel) if channel not in integral_hash:
integral_hash[channel] = [] if not integral_list else json.loads(integral_list) integral_list = r.get('game2004api:integral_rank_' + channel)
_delRepeatData(row, integral_hash[channel]) integral_hash[channel] = [] if not integral_list else json.loads(integral_list)
_refreshData(row, integral_hash[channel], take_integral_times) _delRepeatData(row, integral_hash[channel])
_refreshData(row, integral_hash[channel], take_integral_times)
last_idx = max(row[8], last_idx) last_idx = max(row[8], last_idx)
time.sleep(0.001); time.sleep(0.001);
if not has_data: if not has_data: