From 1a0048ec154244e19d9742ae4c737f6c45d9a814 Mon Sep 17 00:00:00 2001 From: wuhao <15392746632@qq.com> Date: Fri, 13 Nov 2020 20:19:35 +0800 Subject: [PATCH] update --- handler/handler.py | 17 ++++++++++------- 1 file changed, 10 insertions(+), 7 deletions(-) diff --git a/handler/handler.py b/handler/handler.py index 2e7a88c..91e6add 100644 --- a/handler/handler.py +++ b/handler/handler.py @@ -1,4 +1,5 @@ import hashlib +import os from abc import ABCMeta, abstractmethod import traceback import arrow @@ -13,14 +14,14 @@ class Handler(metaclass=ABCMeta): def __init__(self, data): self._data = data - self._appid = data['appid'] + appid = data['appid'] self._event = self._data['event'] self._game = self._data['project'] self._type = self._data['type'] - Handler._init_game_config(self._appid) - Handler._init_mdb(f'{settings.DB_PREFIX}_{Handler.game_config["id_name"]}') - self.secret_token = Handler.game_config.get('secret_token', '') - self._nt = arrow.now(tz=Handler.game_config.get('timezone', 'local')).timestamp + Handler._init_game_config() + Handler._init_mdb(f'{settings.DB_PREFIX}_{Handler.game_config[appid]["id_name"]}') + self.secret_token = Handler.game_config[appid].get('secret_token', '') + self._nt = arrow.now(tz=Handler.game_config[appid].get('timezone', 'local')).timestamp @classmethod def _init_mdb(cls, dbname): @@ -44,9 +45,11 @@ class Handler(metaclass=ABCMeta): coll.update_one(where, {'$set': update_data}, upsert=True) @classmethod - def _init_game_config(cls, appid): + def _init_game_config(cls): if not cls.game_config: - cls.game_config = settings.admin_game_coll.find_one({'appid': appid}) + topic_list = settings.kafka_setting['topic_name'] + data = settings.admin_game_coll.find({'appid': {'$in': topic_list}}, {'_id': False}) + cls.game_config = {item['appid']:item for item in data} return cls.game_config def handler_event(self):