17 lines
553 B
Plaintext
17 lines
553 B
Plaintext
async def get_cpcnodes(params_kw={}):
|
|
debug(f'{params_kw=}')
|
|
db = DBPools()
|
|
dbname = 'kboss'
|
|
ns = {
|
|
"cpcid":params_kw.cpcid
|
|
}
|
|
async with db.sqlorContext(dbname) as sor:
|
|
sql = "select * from cpcnode where cpcid=${cpcid}$ and node_status = '0'"
|
|
recs = await sor.sqlExe(sql, ns.copy())
|
|
return {'status': True,'msg': '获取空闲设备成功','data': recs}
|
|
exception(f'{sql=},{ns=}')
|
|
return {'status': False,'msg': '获取空闲设备失败'}
|
|
|
|
ret = await get_cpcnodes(params_kw)
|
|
return ret
|