async def addpromoting(ns): """ 添加促销活动 """ db = DBPools() async with db.sqlorContext('kboss') as sor: users_id = await get_user() orgid = await sor.R('users', {'id':users_id}) ns['orgid'] = orgid[0]['orgid'] ns['id'] = uuid() await sor.C('promoting',ns) return {'status': True, 'msg': '添加成功'} ret = await addpromoting(params_kw) return ret