async def get_salesman(ns={}):
    """
    客户获取对应销售人员
    :param ns:
    :return:
    """
    userid = await get_user()
    db = DBPools()
    async with db.sqlorContext('kboss') as sor:
        # 获取用户orgid
        user_orgid = (await sor.R('users', {'id': userid, 'del_flg': '0'}))[0]['orgid']
        customer_info_li = await sor.R('customer', {'customerid': user_orgid, 'del_flg': '0'})
        if customer_info_li and customer_info_li[0]['salemanid']:
            salemanid = customer_info_li[0]['salemanid']
            return {
                'status': True,
                'msg': 'get salemanid success',
                'data': salemanid
            }
        else:
            user_parentid = (await sor.R('organization', {'id': user_orgid, 'del_flg': '0'}))[0]['parentid']

            # 机构找自己所有的销售人员id
            users_li_sql = """select u.id, u.username, u.orgid, ur.userid, ur.roleid, r.id, r.role from users u, userrole ur, role r 
                              where u.orgid = '%s' and u.id = ur.userid and ur.roleid = r.id and 
                              r.role = '运营';""" % user_parentid
            users_li = await sor.sqlExe(users_li_sql, {})
            operation_user_id = [item['userid'] for item in users_li][-1]
            return {
                'status': True,
                'msg': 'get operation success',
                'data': operation_user_id
            }
            
ret = await get_salesman(params_kw)
return ret