kboss/b/product/requirement_update.dspy
2025-07-31 15:37:38 +08:00

23 lines
883 B
Plaintext

async def requirement_update(ns={}):
product_category = ns.get('product_category')
company_type = ns.get('company_type')
if product_category:
ns['product_category'] = json.dumps(product_category) if isinstance(product_category, list) else product_category
if company_type:
ns['company_type'] = json.dumps(company_type) if isinstance(company_type, list) else company_type
db = DBPools()
async with db.sqlorContext('kboss') as sor:
try:
await sor.U('user_publish_requirement', ns)
return {
'status': True,
'msg': 'Requirement updated successfully'
}
except Exception as e:
return {
'status': False,
'msg': 'Failed to update requirement, %s' % str(e)
}
ret = await requirement_update(params_kw)
return ret