# 获取机构下所有客户及销售归属
db = DBPools()
resellerid = params_kw.get('resellerid') or '0'

sql = """
select o.id as customerid, o.orgname as customer_name,
       dcb.id as bind_id, dcb.sale_id,
       u.name as sale_name
from organization o
left join discount_customer_bind dcb on dcb.customerid = o.id and dcb.resellerid = ${resellerid}$
left join user u on u.id = dcb.sale_id
where 1=1
order by o.orgname
"""

async with db.sqlorContext('sage') as sor:
    rows = await sor.sqlExe(sql, {'resellerid': resellerid})
    return rows