32 lines
1.1 KiB
Plaintext
32 lines
1.1 KiB
Plaintext
async def jncs_get_product(ns={}):
|
|
db = DBPools()
|
|
async with db.sqlorContext('kboss') as sor:
|
|
try:
|
|
# 查找济南超算id
|
|
jncs_li = await sor.R('organization', {'orgname': '济南超算', 'del_flg': '0'})
|
|
if not jncs_li:
|
|
return {
|
|
'status': False,
|
|
'msg': '没有找到名称是 济南超算 的供应商'
|
|
}
|
|
jncs_orgid = jncs_li[0]['id']
|
|
product_list = await sor.R('product', {'providerid': jncs_orgid, 'del_flg': '0'})
|
|
if not product_list:
|
|
return {
|
|
'status': False,
|
|
'msg': '没有找到供应商名称是 济南超算 的对应产品, 请到运营界面先添加产品'
|
|
}
|
|
return {
|
|
'status': True,
|
|
'msg': '获取济南超算产品成功',
|
|
'data': product_list
|
|
}
|
|
|
|
except Exception as e:
|
|
return {
|
|
'status': False,
|
|
'msg': e
|
|
}
|
|
|
|
ret = await jncs_get_product(params_kw)
|
|
return ret |