37 lines
1.3 KiB
Plaintext
37 lines
1.3 KiB
Plaintext
async def computing_voucher_add(ns={}):
|
|
db = DBPools()
|
|
async with db.sqlorContext('kboss') as sor:
|
|
try:
|
|
voucher_dict = {
|
|
"id": uuid(),
|
|
"issuer_name": ns.get("issuer_name"),
|
|
"issuer_orgid": ns.get("issuer_orgid"),
|
|
"receiver_name": ns.get("receiver_name"),
|
|
"receiver_orgid": ns.get("receiver_orgid"),
|
|
"obtain_time": ns.get("obtain_time"),
|
|
"denomination": float(ns.get("denomination")),
|
|
"balance": float(ns.get("denomination")),
|
|
"region": ns.get("region"),
|
|
"zone": ns.get("zone"),
|
|
"use_scope": ns.get("use_scope"),
|
|
"status": ns.get("status"),
|
|
"record": ns.get("record"),
|
|
"start_time": ns.get("start_time"),
|
|
"end_time": ns.get("end_time")
|
|
}
|
|
await sor.C("computing_voucher", voucher_dict)
|
|
return {
|
|
"status": True,
|
|
"msg": "算力券创建成功"
|
|
}
|
|
except Exception as e:
|
|
sor.rollback()
|
|
return {
|
|
"status": False,
|
|
"msg": "算力券创建有误",
|
|
"error": str(e)
|
|
}
|
|
|
|
ret = await computing_voucher_add(params_kw)
|
|
return ret
|
|
|