kboss/b/hpc/jnan_get_sign.dspy
2025-07-16 14:27:17 +08:00

37 lines
1.3 KiB
Plaintext

async def jnan_get_sign(ns={}):
warn_msg = None
db = DBPools()
async with db.sqlorContext('kboss') as sor:
# 查看用户是否有没有同步的核时信息
sync_status = await sor.R('jncs_syncinfo', {'customerid': await get_user(), 'sync_status': '0'})
if sync_status:
warn_msg = '您当前有未同步的购买信息, 请联系售后同步'
method = 'POST'
url = 'https://hpc.kaiyuancloud.cn/rms/api/urlLogin/userSign'
formdata = {
"loginid": await get_user(),
"loginname": ns.get('username'),
"cipher": "WIfHaMnen2WaRw4Agwenoe6TwDD3LxBbLEgMjVKDHADPE7xDJicjSG3yAfK4iNes1vUmVcoTxV2/+gMfla8ZDg=="
}
async with aiohttp_client.request(
method=method,
url=url,
data=formdata) as res:
data_token = await res.json()
if data_token.get('code') == 200:
return {
'status': True,
'msg': 'get token success',
'data': data_token['data']['key'],
'warn_msg': warn_msg
}
else:
return {
'status': False,
'msg': 'get token failed',
'data': data_token,
'warn_msg': warn_msg
}
ret = await jnan_get_sign(params_kw)
return ret