kboss/b/hpc/HpcLdapSearch.dspy
2025-07-16 14:27:17 +08:00

32 lines
1009 B
Plaintext

async def HpcLdapSearch(ns={}):
"""
查找可用ldap账号
:param ns:
:return:
"""
db = DBPools()
async with db.sqlorContext('kboss') as sor:
try:
res_li = await sor.R('jncs_usermapping', {'del_flg': '0'})
for usermap in res_li:
orgid = usermap['orgid']
if orgid:
orgname_li = (await sor.R('organization', {'id': orgid, 'del_flg': '0'}))
if orgname_li:
usermap['orgname'] = orgname_li[0]['orgname']
else:
usermap['orgname'] = '测试使用'
return {
'status': True,
'msg': '查找ldap账号成功',
'data': res_li
}
except Exception as e:
return {
'status': False,
'msg': '查找ldap账号失败',
'err': e
}
ret = await HpcLdapSearch(params_kw)
return ret