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