ADD:添加游戏接口

config/db_config.yaml

@@ -1,17 +1,17 @@
 quchen_text:
-  host: rm-bp1c9cj79872tx3aaro.mysql.rds.aliyuncs.com
-  user: superc
+  host: rm-bp11m4nyb4z61fy342o.mysql.rds.aliyuncs.com
+  user: qc
   passwd: Qc_1234567
-  db: quchen_text
+  db: qc_database
 
 zx:
   host: rm-bp145mi6r24ik50z5xo.mysql.rds.aliyuncs.com
   user: readonly
-  passwd: toDataOfReadOnly@2021
+  passwd: toDataOfReadOnly@2021asdf
   db: zx_prod
 
 dm:
-  host: rm-bp10mvfktc9o41ir91o.mysql.rds.aliyuncs.com
-  user: qucheng
+  host: rm-bp11m4nyb4z61fy342o.mysql.rds.aliyuncs.com
+  user: qc
   passwd: Qc_1234567
   db: dm

data_manage/operate.py

@@ -81,12 +81,9 @@ def get_channel(arg):
     db = MysqlUtils()
     user_id = arg.get('user_id')
     name = arg.get('name')
-
     if user_id in super_auth():
         sql = f"select id,nick_name from t_mp_account where nick_name like '%{name}%' and del_flag=0"
-
         return db.zx.getData_json(sql)
-
     # 普通权限------java,获取本人对应拥有的公众号
     rsp = requests.get(f'http://api.zanxiangnet.com/system/api/mp/mpAccount/subAccountWithUser/{user_id}')
     channel_list = rsp.json()['data']
@@ -99,7 +96,6 @@ def get_channel(arg):
     sql2 = f"""select GROUP_CONCAT(channel_ids) from user_channel_group_auth a
                      left join channel_group b on a.channel_group_id=b.id
                      where user_id={user_id}"""
-
     data2 = db.quchen_text.getOne(sql2)
 
     if data2:

handlers/ApiHandler.py

@@ -4,6 +4,32 @@ import json
 import requests
 from model.DataBaseUtils import MysqlUtils
 
+
+class WxGameApiHandler(BaseHandler):
+
+    def get(self):
+        import base64
+        print(self.request.query_arguments)
+        print(base64.b64encode(str(self.request.query_arguments).encode('utf-8')))
+        wx_info=base64.b64encode(str(self.request.query_arguments).encode('utf-8')).decode('utf-8')
+        print('微信游戏get',self.request.body.decode(encoding='utf-8'))
+
+        sql=f'''replace into wx_game(wx_info) values ('{wx_info}')  '''
+        print(sql)
+        MysqlUtils().quchen_text.execute(sql)
+        print("入库成功")
+        self.write(json.dumps({"code":200,"msg":"ok"}))
+
+    def post(self):
+
+        print('微信游戏post',self.request.body.decode(encoding='utf-8'))
+        # path=self.get_args()["path"]
+        # task_id=self.get_args()["taskId"]
+        # print(path)
+        # MysqlUtils().quchen_text.execute(f"update yangguang_path set path='{path}' where task_id='{task_id}'")
+        self.write(json.dumps({"code":200,"msg":"ok"}))
+
+
 class YgApiHandler(BaseHandler):
 
     def post(self):

urls.py

@@ -1,5 +1,5 @@
 from handlers.PitcherPanelHandler import *
-from handlers.ApiHandler import YgApiHandler,TtApiHandler
+from handlers.ApiHandler import YgApiHandler,TtApiHandler,WxGameApiHandler
 from handlers.GitHookHandler import *
 from handlers.PublicAnalysisHandler import *
 from handlers.TaskHandler import *
@@ -38,6 +38,8 @@ urls = [
     # 头条接口
     (r'/api/get_toutiao_data', TtApiHandler),  # 阳光订单回调接口
 
+    (r'/api/get_wx_game_data', WxGameApiHandler),  # 微信游戏订单回调接口
+
     # web hook
     (r'/api/git_hook/data_center', DataCenerHook),
     (r'/api/git_hook/qc_web', QcWebHook),