From b41487734847cecb16c1315d14a20523cb548297 Mon Sep 17 00:00:00 2001
From: pengtao <pengtao@kingsome.cn>
Date: Fri, 20 Mar 2020 15:13:16 +0800
Subject: [PATCH] add user_online interface

---
 config/config.py | 21 ++++++++++++++-------
 env.py           | 15 +++++++++++++++
 web.py           | 11 ++++++++---
 3 files changed, 37 insertions(+), 10 deletions(-)
 create mode 100644 env.py

diff --git a/config/config.py b/config/config.py
index 47d1597..849e467 100644
--- a/config/config.py
+++ b/config/config.py
@@ -17,10 +17,17 @@ else:
 
 if not interface_port:
     interface_port = 6500
-
-online_mysql = {
-    "host": '10.10.3.5',
-    "user": 'ops',
-    "pswd": 'deploy2018',
-    "db": 'user_online'
-}
+if  os.getenv("IS_DEBUG"):
+    online_mysql = {
+        "host": '127.0.0.1',
+        "user": 'root',
+        "pswd": 'aspect',
+        "db": 'user_online'
+    }
+else:
+    online_mysql = {
+        "host": '10.10.3.5',
+        "user": 'ops',
+        "pswd": 'deploy2018',
+        "db": 'user_online'
+    }
diff --git a/env.py b/env.py
new file mode 100644
index 0000000..c200795
--- /dev/null
+++ b/env.py
@@ -0,0 +1,15 @@
+#!/usr/bin/python  
+# -*- coding:utf-8 _*-
+""" 
+@author: pengtao 
+@file: env.py 
+@time: 2020/03/20
+"""
+import os
+
+
+if os.getenv("IS_DEBUG"):
+    is_debug = True
+else:
+    is_debug = False
+is_debug = True
diff --git a/web.py b/web.py
index 4968b9f..2cb497b 100644
--- a/web.py
+++ b/web.py
@@ -16,8 +16,10 @@ from data_channel.mp2shushu import Mp2shushu
 from deploy.deploy_keys import DeployKeys
 from deploy.clear_service_data import ClearService
 from online.online_data import OnlineData2mysql
+import json
 
-define_logger("/data/logs/myops/ops_interface.log")
+
+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.")
 
@@ -44,8 +46,11 @@ class DispatchHandler(tornado.web.RequestHandler):
     #     if self.get_query_argument('c') == 'Ops' and self.get_query_argument('a') == 'upJumpRecording':
     #         self._selfupJumpRecording()
     def _user_online(self):
-        data = self.get_query_argument('accountid')
-        aa = OnlineData2mysql(data)
+        param = self.request.body.decode('utf-8')
+        prarm = json.loads(param)
+        log.info(f"get user_online prarm was {prarm}")
+        # data = self.get_query_argument('data')
+        aa = OnlineData2mysql(prarm)
         aa.run()
 
     def _selfdeploykeys(self):