28 lines
956 B
Plaintext
28 lines
956 B
Plaintext
async def get_unreadmsg(ns={}):
|
|
"""
|
|
展示当前收件人的未读信息和数量
|
|
:param ns:
|
|
:return:
|
|
"""
|
|
# 处理userid
|
|
if ns.get('userid'):
|
|
ns['userid'] = ns.get('userid')
|
|
else:
|
|
ns['userid'] = await get_user()
|
|
if not ns.get('userid'):
|
|
server_error(401)
|
|
|
|
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': ns['userid'], '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 |