async def user_demand(ns={}):
    db = DBPools()
    async with db.sqlorContext('kboss') as sor:
        demand_res = await sor.R('user_demand', {})
        return {
            'status': True,
            'msg': '获取用户需求信息',
            'data': demand_res
        }

ret = await user_demand(params_kw)
return ret