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