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

38 lines
1.4 KiB
Plaintext

async def getissues(ns):
"""
展示工单
"""
db = DBPools()
async with db.sqlorContext('kboss') as sor:
if ns:
if not ns.get('type'):
user = await get_user()
orgid = await sor.R('users', {'id': user})
ns['customerid'] = orgid[0]['orgid']
ns['del_flg'] = '0'
ns['sort'] = 'create_at desc'
reacsissues = await sor.R('issues', ns)
ns.pop('page')
listdata = []
for i in reacsissues['rows']:
try:
id = i['id']
ns['id'] = i['customerid']
reacs = await sor.R('organization', ns)
i['name'] = reacs[0]['orgname']
ns['id'] = i['orderid']
reacs = await sor.R('bz_order', ns)
i['bz_order'] = reacs[0]
ns['issueid'] = id
ns.pop('id')
reacs = await sor.R('issue_detail', ns)
i['issue_detail'] = reacs[0]
listdata.append(i)
reacsissues['rows'] = listdata
except:
continue
return {'status': True, 'data': reacsissues}
return {'status': False, 'msg': '参数错误'}
ret = await getissues(params_kw)
return ret