async def cancelbz_order(ns): """取消订单""" db = DBPools() async with db.sqlorContext('kboss') as sor: if ns: try: # 需要加事务 await sor.U('bz_order', {'id': ns['orderid'], 'order_status': '3'}) return {'status': True, 'msg': '取消订单'} except Exception as error: raise error else: return {'status': False, 'msg': '参数错误'} return {'status': False, 'msg': '取消失败'} ret = await cancelbz_order(params_kw) return ret