20 lines
770 B
Plaintext
20 lines
770 B
Plaintext
async def get_unreadmsg(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': '收件人 userid 未提供'}
|
|
|
|
mas = await sor.R('message', {'receiverid': await get_user(), 'del_flg': 0, 'msgstatus': 0})
|
|
|
|
if not mas:
|
|
return {'status': True, 'count': 0}
|
|
count = len(mas) # 未读信息数量
|
|
sorted_mas = sorted(mas, key=lambda x: x['sendtime'], reverse=True)
|
|
return {'status': True, 'msg': '查询未读消息成功', 'count': count, 'messages': sorted_mas}
|
|
ret = await get_unreadmsg(params_kw)
|
|
return ret |