38 lines
1.1 KiB
Plaintext
38 lines
1.1 KiB
Plaintext
async def get_deerer_header(ns={}):
|
|
from appPublic.aes import aes_decode_b64, aes_encode_b64
|
|
if not ns.get('userid'):
|
|
userid = await get_user()
|
|
else:
|
|
userid = ns.get('userid')
|
|
if not userid:
|
|
return {
|
|
'status': False,
|
|
'msg': '请传递用户ID'
|
|
}
|
|
db = DBPools()
|
|
async with db.sqlorContext('kboss') as sor:
|
|
records = await sor.R('user_api_keys', {'userid': userid})
|
|
if not records:
|
|
return {
|
|
'status': False,
|
|
'msg': '未找到匹配的用户'
|
|
}
|
|
apikey = records[0]['opc_apikey']
|
|
appid = records[0]['appid']
|
|
sk = records[0]['secretkey']
|
|
if not apikey or not appid or not sk:
|
|
return {
|
|
'status': False,
|
|
'msg': '没有找到匹配的用户'
|
|
}
|
|
tim = time.time()
|
|
txt = f'{tim}:{apikey}'
|
|
cyber = aes_encode_b64(sk, txt)
|
|
return {
|
|
'status': True,
|
|
'data': f'Deerer {appid}-:-{cyber}'
|
|
}
|
|
|
|
|
|
ret = await get_deerer_header(params_kw)
|
|
return ret |