ops/ops_interface
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
pengtao 2021-06-15 13:56:26 +08:00
parent 6216b448b2
commit ed69045096
1 changed files with 17 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

39
web.py
View File

@ -21,7 +21,8 @@ import json
define_logger("ops_interface.log") define_logger("ops_interface.log")
log = logging.getLogger(__name__) 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): class DispatchHandler(tornado.web.RequestHandler):
@ -32,9 +33,9 @@ class DispatchHandler(tornado.web.RequestHandler):
self._selfgamelogexternal() self._selfgamelogexternal()
elif self.get_query_argument('c') == 'Ops' and self.get_query_argument('a') == 'mp2ss': elif self.get_query_argument('c') == 'Ops' and self.get_query_argument('a') == 'mp2ss':
yield self._selfmp2ss() yield self._selfmp2ss()
if self.get_query_argument('c') == 'Ops' and self.get_query_argument('a') == 'user_online': elif self.get_query_argument('c') == 'Ops' and self.get_query_argument('a') == 'user_online':
print(f"get user_online get") #print(f"get user_online get")
self._user_online() yield self._user_online()
elif self.get_query_argument('c') == 'Ops' and self.get_query_argument('a') == 'clear_redis': elif self.get_query_argument('c') == 'Ops' and self.get_query_argument('a') == 'clear_redis':
yield self._selfclear_redis() yield self._selfclear_redis()
elif self.get_query_argument('c') == 'Deploy' and self.get_query_argument('a') == 'keys': elif self.get_query_argument('c') == 'Deploy' and self.get_query_argument('a') == 'keys':
@ -42,31 +43,26 @@ class DispatchHandler(tornado.web.RequestHandler):
else: else:
self.write("pls check args!") self.write("pls check args!")
# @gen.coroutine @gen.coroutine
# def post(self): def post(self):
# print(f"post {self.get_argument()}") pdb.set_trace()
# log.info(f"get requests {self.request.body_arguments}") data = json.loads(self.request.body)
# if self.get_query_argument('c') == 'Ops' and self.get_query_argument('a') == 'user_online': print(data)
# print(f"get user_online get") if self.get_query_argument('c') == 'Ops' and self.get_query_argument('a') == 'git_webhook':
# self._user_online() yield self._git_webhook()
else:
self.write("pls check args!")
def _git_webhook(self):
pass
def _user_online(self): 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 = {} 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['zone_id'] = self.get_query_argument('zone_id')
post_data['number'] = self.get_query_argument('number') post_data['number'] = self.get_query_argument('number')
post_data['channel_id'] = self.get_query_argument('channel_id') post_data['channel_id'] = self.get_query_argument('channel_id')
post_data['game_id'] = self.get_query_argument('game_id') post_data['game_id'] = self.get_query_argument('game_id')
post_data['gamename'] = 'wjtx' post_data['gamename'] = 'wjtx'
# log.info(f"get user_online prarm was {post_data}")
aa = OnlineData2mysql(post_data) aa = OnlineData2mysql(post_data)
aa.run() aa.run()
@ -86,7 +82,6 @@ class DispatchHandler(tornado.web.RequestHandler):
except Exception: except Exception:
log.error(f"clear keys with {accountid} failed", exc_info=True) log.error(f"clear keys with {accountid} failed", exc_info=True)
def _selfgamelogexternal(self): def _selfgamelogexternal(self):
try: try:
cc = Build_Gamelog_Config() cc = Build_Gamelog_Config()