kboss/b/product/search_user_inquiry.dspy
2025-08-14 17:15:44 +08:00

22 lines
742 B
Plaintext

async def search_user_inquiry(ns={}):
if not ns.get('url_link'):
return {
'status': False,
'msg': '请传递url_link'
}
domain_name = ns.get('url_link').split("//")[1].split("/")[0]
if 'localhost' in domain_name:
domain_name = 'dev.opencomputing.cn'
db = DBPools()
async with db.sqlorContext('kboss') as sor:
search_sql = """select * from product_inquiry where domain_name = '%s' and del_flg = '0' order by update_time desc;""" % domain_name
result = await sor.sqlExe(search_sql, {})
return {
'status': True,
'msg': 'search success',
'data': result
}
ret = await search_user_inquiry(params_kw)
return ret