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

17 lines
625 B
Plaintext

async def get_readmsg(ns={}):
"""
展示当前收件人的已读信息
:param ns:
:return:
"""
db = DBPools()
async with db.sqlorContext('kboss') as sor:
# if 'userid' not in ns or not ns['userid']:
# return {'status': False, 'msg': 'senderid is not'}
mas = await sor.R('message', {'receiverid': await get_user(),'del_flg':0,'msgstatus':1})
if not mas:
return {'status': True}
sorted_mas = sorted(mas, key=lambda x: x['sendtime'], reverse=True)
return {'status': True, 'msg': sorted_mas}
ret = await get_readmsg(params_kw)
return ret