MOD:接口修改

model/UserAuthUtils.py

@@ -99,6 +99,65 @@ def get_auth_channel(user_id):
     return tuple(data1 + data3)
 
 
+def get_auth_game_info(user_id):
+    """获取用户拥有的所有用户拥有的游戏"""
+    db = MysqlUtils()
+    # 1.获取用户名字
+    g_time = int(time.time())
+    base_url = 'https://api.zanxiangnet.com'
+    params = '/erp/api/user/search/3'
+    g_token = get_g_token(g_time, params)
+    params_other_urlencode = urlencode({'g_time': g_time, 'g_token': g_token})
+    url = base_url + params + '?' + params_other_urlencode
+    rsp = requests.get(url)
+
+    user_name = None
+    for _ in rsp.json()['data']:
+        if str(_['userId']) == str(user_id):
+            user_name = _['nickName']
+    # 2.获取所有游戏id
+    sql = f'''
+    SELECT d.id ,d.name,min(DATE_FORMAT(a.start_date,"%Y-%m-%d"))
+       FROM quchen_text.advertiser_vx a
+                                left join db_mp.mp_mp_conf b on  a.name =b.wx_name 
+                                left join db_mp.mp_conf_agent c on c.advertiser_conf_id = b.id
+                                left join db_mp.h_game d on c.app_id = d.id
+        where pitcher ='{user_name}' and d.id is not null
+        group by id
+    '''
+    user_ids = db.quchen_text.get_data_list(sql)
+    return user_ids
+
+
+def get_auth_game_name(user_id):
+    """获取用户拥有的所有用户拥有的游戏"""
+    db = MysqlUtils()
+    # 1.获取用户名字
+    g_time = int(time.time())
+    base_url = 'https://api.zanxiangnet.com'
+    params = '/erp/api/user/search/3'
+    g_token = get_g_token(g_time, params)
+    params_other_urlencode = urlencode({'g_time': g_time, 'g_token': g_token})
+    url = base_url + params + '?' + params_other_urlencode
+    rsp = requests.get(url)
+    user_name = None
+    for _ in rsp.json()['data']:
+        if str(_['userId']) == str(user_id):
+            user_name = _['nickName']
+    # 2.获取所有游戏id
+    sql = f'''
+   SELECT d.name 
+       FROM quchen_text.advertiser_vx a
+                                left join db_mp.mp_mp_conf b on  a.name =b.wx_name 
+                                left join db_mp.mp_conf_agent c on c.advertiser_conf_id = b.id
+                                left join db_mp.h_game d on c.app_id = d.id
+        where pitcher ='{user_name}' and d.name is not null
+        group by name
+    '''
+    user_ids = db.quchen_text.get_data_list(sql)
+    return user_ids
+
+
 def super_auth():
     "获取超级数据权限的用户列表"
     g_time = int(time.time())
@@ -106,7 +165,7 @@ def super_auth():
     params = '/erp/api/user/search/3'
     g_token = get_g_token(g_time, params)
     params_other_urlencode = urlencode({'g_time': g_time, 'g_token': g_token})
-    url = base_url + params  + '?' + params_other_urlencode
+    url = base_url + params + '?' + params_other_urlencode
     rsp = requests.get(url)
     print(rsp.text)
     user_list = []
@@ -118,7 +177,7 @@ def super_auth():
 
 
 if __name__ == '__main__':
-    print(super_auth())
+    print(get_auth_game_name(85))
     # print(get_role(78))
     # print(f"ssed{tuple([1, 3, 4])}")
     # xx = super_auth()