31 lines
886 B
Plaintext
31 lines
886 B
Plaintext
async def up_msg(ns={}):
|
|
"""
|
|
修改已读状态
|
|
:param ns:
|
|
:return:
|
|
"""
|
|
msgids = ns.get('msgids',[])
|
|
print(msgids)
|
|
db = DBPools()
|
|
try:
|
|
async with db.sqlorContext('kboss') as sor:
|
|
|
|
if not msgids:
|
|
return {'status': False, 'msg': 'msgid is not provided'}
|
|
|
|
for msgid in msgids:
|
|
print(msgid)
|
|
mas = await sor.R('message', {'id': msgid, 'del_flg': 0})
|
|
if not mas:
|
|
return {'status': True, 'msg': '没有通知消息'}
|
|
|
|
# 更新消息状态为已读
|
|
mas[0]['msgstatus'] = '1'
|
|
await sor.U('message', mas[0])
|
|
|
|
return {'status': True, 'msg': '修改消息状态成功'}
|
|
|
|
except Exception as e:
|
|
return {'status': False, 'msg': str(e)}
|
|
ret = await up_msg(params_kw)
|
|
return ret |