|
@@ -366,6 +366,21 @@ async def readall_system_notice(
|
|
|
db.query(MsgCenter).filter(where).update({"recv_status": 1, "update_time": datetime.now()})
|
|
|
db.commit()
|
|
|
|
|
|
+ return {
|
|
|
+ "code": 200,
|
|
|
+ "msg": "保存成功"
|
|
|
+ }
|
|
|
+
|
|
|
+@router.post('/read_system_notice_by_id')
|
|
|
+async def read_system_notice_by_id(
|
|
|
+ body = Depends(remove_xss_json),
|
|
|
+ db: Session = Depends(get_db),
|
|
|
+ user_id = Depends(valid_access_token)
|
|
|
+):
|
|
|
+ where = and_(MsgCenter.del_flag == '0', MsgCenter.msg_type == '系统消息', MsgCenter.id == body['id'], MsgCenter.recv_userid == user_id)
|
|
|
+ db.query(MsgCenter).filter(where).update({"recv_status": 1, "update_time": datetime.now()})
|
|
|
+ db.commit()
|
|
|
+
|
|
|
return {
|
|
|
"code": 200,
|
|
|
"msg": "保存成功"
|