msg.py 2.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172
  1. from flask import Flask, Blueprint, render_template, abort, redirect, url_for, flash
  2. from flask_wtf import FlaskForm
  3. from flask_login import login_required, current_user
  4. from wtforms import TextAreaField, BooleanField, SubmitField
  5. from wtforms.validators import DataRequired
  6. from typing import Optional
  7. from view.base import App
  8. from sql.base import DBBit
  9. from core.user import User
  10. from core.msg import Message, load_message_list
  11. msg = Blueprint("msg", __name__)
  12. app: Optional[Flask] = None
  13. class WriteForm(FlaskForm):
  14. """
  15. 写新内容表单
  16. """
  17. context = TextAreaField(validators=[DataRequired()])
  18. secret = BooleanField("私密留言")
  19. submit = SubmitField("留言")
  20. @msg.route('/<int:page>')
  21. def msg_page(page: int = 1):
  22. if page < 1:
  23. abort(404)
  24. return
  25. msg_list = load_message_list(20, (page - 1) * 20,
  26. show_secret=current_user.check_role("ReadSecretMsg")) # 判断是否可读取私密内容
  27. max_page = App.get_max_page(Message.get_msg_count(), 20)
  28. page_list = App.get_page("docx.docx_page", page, max_page)
  29. return render_template("msg/msg.html", msg_list=msg_list, page_list=page_list, form=WriteForm(),
  30. is_secret=DBBit.BIT_1)
  31. @msg.route('/write', methods=["POST"])
  32. @login_required
  33. def write_page():
  34. form = WriteForm()
  35. if form.validate_on_submit():
  36. auth: User = current_user
  37. if not auth.check_role("WriteMsg"): # 检查相应权限
  38. abort(403)
  39. return
  40. context = form.context.data
  41. secret = form.secret.data
  42. if Message(None, auth, context, secret, None).create():
  43. flash("留言成功")
  44. else:
  45. flash("留言失败")
  46. return redirect(url_for("msg.msg_page", page=1))
  47. abort(404)
  48. @msg.context_processor
  49. def inject_base():
  50. return {"top_nav": ["", "", "", "active", "", ""]}
  51. class MsgApp(App):
  52. def __init__(self, import_name):
  53. super(MsgApp, self).__init__(import_name)
  54. global app
  55. app = self._app
  56. app.register_blueprint(msg, url_prefix="/msg")