From ed69045096446682268a15030eecfd1c3153ffb3 Mon Sep 17 00:00:00 2001 From: pengtao Date: Tue, 15 Jun 2021 13:56:26 +0800 Subject: [PATCH] 1 --- web.py | 39 +++++++++++++++++---------------------- 1 file changed, 17 insertions(+), 22 deletions(-) diff --git a/web.py b/web.py index 012ec47..91aaa35 100644 --- a/web.py +++ b/web.py @@ -21,7 +21,8 @@ import json define_logger("ops_interface.log") log = logging.getLogger(__name__) -tornado.options.define("port", default=interface_port, type=int, help="run server on the given port.") +tornado.options.define("port", default=interface_port, + type=int, help="run server on the given port.") class DispatchHandler(tornado.web.RequestHandler): @@ -32,9 +33,9 @@ class DispatchHandler(tornado.web.RequestHandler): self._selfgamelogexternal() elif self.get_query_argument('c') == 'Ops' and self.get_query_argument('a') == 'mp2ss': yield self._selfmp2ss() - if self.get_query_argument('c') == 'Ops' and self.get_query_argument('a') == 'user_online': - print(f"get user_online get") - self._user_online() + elif self.get_query_argument('c') == 'Ops' and self.get_query_argument('a') == 'user_online': + #print(f"get user_online get") + yield self._user_online() elif self.get_query_argument('c') == 'Ops' and self.get_query_argument('a') == 'clear_redis': yield self._selfclear_redis() elif self.get_query_argument('c') == 'Deploy' and self.get_query_argument('a') == 'keys': @@ -42,31 +43,26 @@ class DispatchHandler(tornado.web.RequestHandler): else: self.write("pls check args!") - # @gen.coroutine - # def post(self): - # print(f"post {self.get_argument()}") - # log.info(f"get requests {self.request.body_arguments}") - # if self.get_query_argument('c') == 'Ops' and self.get_query_argument('a') == 'user_online': - # print(f"get user_online get") - # self._user_online() + @gen.coroutine + def post(self): + pdb.set_trace() + data = json.loads(self.request.body) + print(data) + if self.get_query_argument('c') == 'Ops' and self.get_query_argument('a') == 'git_webhook': + yield self._git_webhook() + else: + self.write("pls check args!") + + def _git_webhook(self): + pass def _user_online(self): - # post_data = self.request.body_arguments - # print(post_data) - # post_data = {x: post_data.get(x)[0].decode("utf-8") for x in post_data.keys()} - # if not post_data: - # post_data = self.request.body.decode('utf-8') - # post_data = json.loads(post_data) - # param = self.request.body.decode('utf-8') - # prarm = json.loads(param) post_data = {} - # zone_id=10000&number=0&sign=de2e4303b3a4154a9a813a44ecd645f5&channel_id=0&game_id=5213 post_data['zone_id'] = self.get_query_argument('zone_id') post_data['number'] = self.get_query_argument('number') post_data['channel_id'] = self.get_query_argument('channel_id') post_data['game_id'] = self.get_query_argument('game_id') post_data['gamename'] = 'wjtx' - # log.info(f"get user_online prarm was {post_data}") aa = OnlineData2mysql(post_data) aa.run() @@ -86,7 +82,6 @@ class DispatchHandler(tornado.web.RequestHandler): except Exception: log.error(f"clear keys with {accountid} failed", exc_info=True) - def _selfgamelogexternal(self): try: cc = Build_Gamelog_Config()