from model.DataBaseUtils import MysqlUtils,CkUtils
import base64
import requests
import time
import hashlib
from config.using_config import sha256_token, sha256_account
from urllib.parse import urlencode
from Crypto.Cipher import AES
from Crypto.Util.Padding import pad
def get_g_token_sha256(g_time, params):
secret = sha256_token
sha256_str = secret + params + str(g_time)
g_token = hashlib.sha256(sha256_str.encode('utf-8')).hexdigest()
return g_token
def get_auth_user(user_id):
"""获取用户拥有所有用户（包括自己）的权限"""
g_time = int(time.time())
base_url = 'https://api.zanxiangnet.com'
params = f'/erp/api/user/subUser/3/{user_id}'
print(params)
g_token = get_g_token_sha256(g_time, params)
params_other_urlencode = urlencode({'g_time': g_time, 'g_token': g_token, 'g_account': sha256_account})
url = base_url + params + '?' + params_other_urlencode
rsp = requests.get(url)
nick_name_list = []
for _ in rsp.json()['data']:
nick_name_list.append(_['nickName'])
return nick_name_list
def get_auth_channel_self(user_id):
g_time = int(time.time())
base_url = 'https://api.zanxiangnet.com'
params = '/erp/api/resource/search/3'
g_token = get_g_token_sha256(g_time, params)
params_other_urlencode = urlencode({'g_time': g_time, 'g_token': g_token, 'g_account': sha256_account})
params_other = f'?userIds={user_id}'
url = base_url + params + params_other + '&' + params_other_urlencode
rsp = requests.get(url)
channel_list = rsp.json()['data']
data1 = []
if channel_list:
for _ in channel_list:
data1.append(_['resourceName'])
return tuple(data1)
def get_auth_channel(user_id):
"""获取用户拥有的所有公众号权限"""
db = MysqlUtils()
# 普通权限------java,获取本人对应拥有的公众号
g_time = int(time.time())
base_url = 'https://api.zanxiangnet.com'
params = f'/erp/api/resource/subUserResourceList/3/{user_id}/投手,运营'
g_token = get_g_token_sha256(g_time, params)
params_other_urlencode = urlencode({'g_time': g_time, 'g_token': g_token, 'g_account': sha256_account})
# 防止urlencode自动换行
params_other_urlencode = params_other_urlencode.replace('%0A', '')
url = base_url + params + '?' + params_other_urlencode
rsp = requests.get(url)
channel_list = rsp.json()['data']
data1 = []
if channel_list:
for _ in channel_list:
data1.append(_['resourceName'])
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)
data3 = []
if data2:
g_time = int(time.time())
base_url = 'https://api.zanxiangnet.com'
params = '/erp/api/resource/search/3'
g_token = get_g_token_sha256(g_time, params)
params_other_urlencode = urlencode({'g_time': g_time, 'g_token': g_token, 'g_account': sha256_account})
url = base_url + params + '?' + params_other_urlencode
rsp = requests.get(url)
channel_list = []
channel_dict = {}
for _ in rsp.json()['data']:
channel_list.append((_['id'], _['resourceName']))
channel_dict[_['id']] = _['resourceName']
data2_2 = tuple(data2.split(','))
for _ in data2_2:
data3.append(channel_dict[int(_)])
return tuple(data1 + data3)
def get_auth_game_info(user_id):
"""获取用户拥有的所有用户拥有的游戏"""
ck = CkUtils()
# 1.获取用户名字
g_time = int(time.time())
base_url = 'https://api.zanxiangnet.com'
params = '/erp/api/user/search/3'
g_token = get_g_token_sha256(g_time, params)
params_other_urlencode = urlencode({'g_time': g_time, 'g_token': g_token, 'g_account': sha256_account})
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']
print(user_name)
# 2.获取所有游戏id
'''
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
'''
sql = f'''
SELECT d.id ,d.name,toUnixTimestamp(concat(toString(min(a.start_date)),' 00:00:00'),'Asia/Shanghai')
FROM CostSourceData.advertiser_vx a
left join GameDataSum.mp_mp_conf_sum b on a.name =b.wx_name
left join GameDataSum.mp_conf_agent_sum c on c.advertiser_conf_id = b.id
left join GameDataSum.h_game_sum d on c.app_id = d.id
where LENGTH (d.id)>0 and a.pitcher = '{user_name}'
group by d.id,d.name
'''
data_res = ck.execute(sql)
# user_ids = db.quchen_text.get_data_list(sql)
return data_res
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_sha256(g_time, params)
params_other_urlencode = urlencode({'g_time': g_time, 'g_token': g_token, 'g_account': sha256_account})
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())
base_url = 'https://api.zanxiangnet.com'
params = '/erp/api/user/search/3'
g_token = get_g_token_sha256(g_time, params)
params_other_urlencode = urlencode({'g_time': g_time, 'g_token': g_token, 'g_account': sha256_account})
url = base_url + params + '?' + params_other_urlencode
rsp = requests.get(url)
print(rsp.text)
user_list = []
for _ in rsp.json()['data']:
if _['powerLevel'] >= 99:
user_list.append(_['userId'])
print(user_list)
return user_list
if __name__ == '__main__':
print(get_auth_game_name(85))
# print(get_role(78))
# print(f"ssed{tuple([1, 3, 4])}")
# xx = super_auth()
# print(xx)