async def resellerRebateSearch(ns={}):
    """
    search reseller rebate *为必填项
        id *
    :param ns:
    :return:
    """
    if not ns:
        return {
            "status": False,
            "msg": "reseller rebate failed, id is empty",
            "data": ""
        }
    db = DBPools()
    async with db.sqlorContext('kboss') as sor:
        try:
            ns['del_flg'] = '0'
            ns['sort'] = 'create_at'
            ns['order'] = 'desc'
            ns['page'] = ns.get('page') if ns.get('page') else 1
            rdt_sql = """select * from rp_rebate where resellerid = '%s' and del_flg=0 order by create_at desc""" % \
                      (ns.get('resellerid'))
            result = await sor.sqlExe(rdt_sql, {})
            # res = await sor.R('rp_discount', ns)
            return {
                    "status": True,
                    "msg": "reseller rebate search success",
                    "data": result
            }
        except Exception as e:
            print(e)
            return  {
                "status": False,
                "msg": "reseller rebate search failed",
                "data": ""
            }
			

ret = await resellerRebateSearch(params_kw)
return ret