Python-Flask构建用户注册登录后端逻辑架构

╰半橙微兮° 2023-01-02 06:30 269阅读 0赞

Python-Flask构建用户注册登录后端逻辑架构

1、项目结构
在这里插入图片描述
2、app.py

  1. from flask import Flask,render_template
  2. from controller.user_controller import user_controller
  3. from datetime import timedelta
  4. import os
  6. app=Flask(__name__)
  7. app.register_blueprint(user_controller)
  9. app.config['JSON_AS_ASCII'] = False
  10. app.config['SECRET_KEY'] = os.urandom(24)   #设置为24位的字符,每次运行服务器都是不同的，所以服务器启动一次上次的session就清除。
  11. app.config['PERMANENT_SESSION_LIFETIME'] = timedelta(minutes=30)  #设置session的保存时间。
  13. @app.route('/')
  14. def index():
  15.     return render_template('index.html')
  17. if __name__ == "__main__":
  18.     #在生产环境中host='0.0.0.0'
  19.     app.run(host='127.0.0.1',port=5020,debug=False)

3、user_controller

  1. from flask import Flask,Blueprint,request,render_template,session
  2. from dao.userdao import UserDAO
  3. from entity.user_entity import UserEntity
  5. user_controller=Blueprint('user_controller',__name__)
  7. userdao=UserDAO()
  8. userentity=UserEntity()
  10. @user_controller.route('/login',methods=['POST'])
  11. def login():
  12.     info=''
  13.     userentity.telphone=request.form['telphone']
  14.     userentity.password=request.form['password']
  15.     res=userdao.GetLoginInfo(userentity)
  16.     if res==None:
  17.         info='无用户信息，请注册'
  18.         return render_template('index.html',info=info)
  19.     elif res[0]==userentity.password:
  20.         info='登录成功'
  21.         session['telphone']=userentity.telphone
  22.         return render_template('index.html',info=info)
  23.     else:
  24.         info='登录失败'
  25.         return render_template('index.html',info=info)
  26.     return render_template('index.html',info='Unknow Error!!!')
  28. @user_controller.route('/register',methods=['POST'])
  29. def register():
  30.     info=''
  31.     userentity.telphone=request.form['telphone']
  32.     userentity.password=request.form['password']
  33.     password_again=request.form['password_again']
  34.     res=userdao.GetSameInfo(userentity)
  35.     if res:
  36.         info='手机号已被使用，请更换手机号重试'
  37.         return render_template('index.html',info=info)
  38.     elif userentity.password!=password_again:
  39.         info='两次密码不一致'
  40.         return render_template('index.html',info=info)
  41.     else:
  42.         info='注册成功'
  43.         userdao.CreateUser(userentity)
  44.         return render_template('index.html',info=info)
  45.     return render_template('index.html',info='Unknow Error!!!')
  47. @user_controller.route('/exit',methods=['GET'])
  48. def exit():
  49.     info=''
  50.     res=session.get('telphone')
  51.     if res==None:
  52.         info='未登录'
  53.         return render_template('index.html',info=info)
  54.     else:
  55.         session['telphone']=None
  56.         info='账号已成功注销'
  57.         return render_template('index.html',info=info)
  58.     return render_template('index.html',info='Unknow Error!!!')

4、basedao

  1. import pymysql # 导入数据的api包
  2. from logger.syslogger import logger
  4. #数据库访问封装的基类
  5. class BaseDAO():
  7.     # 1. 这些参数做私有化，就体现了封装安全性的好处
  8.     def __init__(self, host='IP', name='root', pwd='PWD', port='3306', schema='talk_system', charset='utf8mb4'):
  9.         self.__host = host
  10.         self.__name = name
  11.         self.__pwd = pwd
  12.         self.__port = port
  13.         self.__schema = schema
  14.         self.__charset = charset
  15.         self.__conn = None
  16.         self.__cursor = None
  17.         pass
  19.     # 2. 编写建立数据库连接的公有方法（通用的）
  20.     def getConnection(self):
  21.         try:
  22.             self.__conn = pymysql.connect(self.__host, self.__name, self.__pwd, self.__schema, charset=self.__charset)
  23.         except (pymysql.MySQLError, pymysql.DatabaseError, Exception):
  24.             logger.error("数据库连接异常：" + self.__host)
  25.             pass
  26.         self.__cursor = self.__conn.cursor()
  27.         pass
  29.     # 3. 封装一个通用的对数据库进行操作的方法
  30.     def execute(self, sql, params=None, isBatch=False):
  31.         try:
  32.             # self.getConnection() # 每次连接的是独立的一个连接
  33.             if self.__conn and self.__cursor:
  34.                 if params:
  35.                     # print('not None')
  36.                     # print(parms)
  37.                     if isBatch:
  38.                         return self.__cursor.executemany(sql, params)
  39.                         pass
  40.                     else:
  41.                         return self.__cursor.execute(sql, params)
  42.                 else:
  43.                     return self.__cursor.execute(sql)
  44.                 pass
  45.         except:
  46.             logger.error("执行SQL：" + sql + " params：" + str(params) )
  47.             self.__cursor.close()
  48.             self.__conn.close()
  49.             pass
  50.         pass
  52.     # 调用存储过程
  53.     def executeProc(self, sql, params=None):
  54.         try:
  55.             if self.__conn and self.__cursor:
  56.                 if params:
  57.                     return self.__cursor.callproc(sql, params)
  58.                 else:
  59.                     return self.__cursor.callproc(sql)
  60.                 pass
  61.         except:
  62.             logger.error("执行SQL：" + sql + " params：" + str(params))
  63.             self.__cursor.close()
  64.             self.__conn.close()
  65.             pass
  66.         pass
  68.     # 4. 为了支持事务管理，把对数据库的关闭的动作提取出来，封装成独立的方法
  69.     def close(self):
  70.         if self.__cursor and self.__conn:
  71.             self.__cursor.close()
  72.             self.__conn.close()
  73.         pass
  75.     # 5. 为了支持事务管理，把对数据库事务提交的动作提取出来，封装成独立的方法
  76.     def commit(self):
  77.         # print("----------")
  78.         self.__conn.commit()
  79.         pass
  81.     # 6. 如果出现异常情况，事务要回滚
  82.     def rollback(self):
  83.         self.__conn.rollback()
  84.         pass
  86.     # 查询操作
  87.     def fetchall(self, sql, params=None):
  88.         self.execute(sql, params)
  89.         return self.__cursor.fetchall()
  90.         pass
  92.     # 查询操作
  93.     def fetchone(self, sql, params=None):
  94.         self.execute(sql, params)
  95.         return self.__cursor.fetchone()
  96.         pass
  98.     # 执行存储过程
  99.     def fetchproc(self, sql, params=None):
  100.         self.executeProc(sql, params)
  101.         return self.__cursor.fetchall()
  102.         pass
  103.     pass

5、userdao

  1. from dao.basedao import BaseDAO
  2. from logger.syslogger import logger
  3. import math
  5. class UserDAO(BaseDAO):
  6.     #注册查重验证
  7.     def GetSameInfo(self,user):
  8.         sqlSelect = "select id from user where telphone=%s;"
  9.         params = (user.telphone,)
  10.         try:
  11.             super().getConnection()
  12.             result = super().fetchone(sqlSelect,params)
  13.             super().commit()
  14.             return result
  15.         except Exception as e:
  16.             logger.error("执行SQL：" + str(sqlSelect) + " 出现异常，params:" + str(e))
  17.         finally:
  18.             super().close()
  20.     # 新用户注册
  21.     def CreateUser(self, user):
  22.         try:
  23.             super().getConnection()
  24.             sqlCreate = "insert into user (id,telphone,password) values (NULL ,%s, %s);"
  25.             params = (user.telphone,user.password)
  26.             result = super().execute(sqlCreate, params)
  27.             super().commit()
  28.             return result
  29.         except Exception as e:
  30.             super().rollback()
  31.             logger.error("执行SQL：" + sqlCreate + " 出现异常，params:" + params + str(e))
  32.         finally:
  33.             super().close()
  35.     #登录验证
  36.     def GetLoginInfo(self,user):
  37.         sqlSelect = "select password from user where telphone=%s;"
  38.         params = (user.telphone,)
  39.         try:
  40.             super().getConnection()
  41.             result = super().fetchone(sqlSelect, params)
  42.             super().commit()
  43.             return result
  44.         except Exception as e:
  45.             logger.error("执行SQL：" + str(sqlSelect) + " 出现异常，params:" + str(e))
  46.         finally:
  47.             super().close()

6、user_entity

  1. class UserEntity():
  2.     def __init__(self):
  3.         self.__id=None
  4.         self.__telphone=None
  5.         self.__password=None
  7.     @property
  8.     def id(self):
  9.         return self.__id
  11.     @id.setter
  12.     def id(self, id):
  13.         self.__id = id
  15.     @property
  16.     def telphone(self):
  17.         return self.__telphone
  19.     @telphone.setter
  20.     def telphone(self, telphone):
  21.         self.__telphone = telphone
  23.     @property
  24.     def password(self):
  25.         return self.__password
  27.     @password.setter
  28.     def password(self, password):
  29.         self.__password = password

7、syslogger

  1. #-*- coding:utf-8 -*-
  2. ''' demo03-logging-file.py ------------------------ 日志写入文件 @Copyright: Chinasoft International·ETC '''
  4. # 导入模块
  5. import logging
  6. import os
  7. import time
  9. # 首先，创建并设置日志logger对象
  10. # 创建logger对象并设置信息源对象名称
  11. logger = logging.getLogger('mainlogger')
  12. # 设置日志的输出的输出级别
  13. logger.setLevel(logging.DEBUG)
  14. # 设置日志的输出格式
  15. formatter = logging.Formatter('%(asctime)s - %(name)s - %(levelname)s - %(message)s')
  18. # 其次，创建并设置文件处理器FileHandler对象
  19. dirPath = os.path.join(os.getcwd(), 'log')
  20. if not os.path.exists(dirPath):
  21.     os.mkdir(dirPath)
  22. logFileName = time.strftime('%Y%m%d', time.localtime())+'.log'
  23. logPath = dirPath + os.sep + logFileName
  24. # 创建FileHandler对象
  25. fileHandler = logging.FileHandler(logPath)
  26. # 设置Filehandler对象的写入信息级别
  27. fileHandler.setLevel(logging.DEBUG)
  28. # 设置FileHandler对象的信息格式
  29. fileHandler.setFormatter(formatter)
  32. # 创建一个 StreamHandler对象
  33. consoleHandler = logging.StreamHandler()
  34. # 设置控制台输出的信息级别
  35. consoleHandler.setLevel(logging.DEBUG)
  36. # 设置consoleHandler对象的信息格式
  37. consoleHandler.setFormatter(formatter)
  39. # 最后，logger对象添加Handler对象替换原有默认的Handler对象
  40. logger.addHandler(fileHandler)
  41. logger.addHandler(consoleHandler)
  45. # 测试输出不同级别的日志信息
  46. ''' logger.fatal('系统崩溃或发生致命性错误，导致程序中断时需要输出的信息') logger.critical('系统资源浩劫时需要输出的信息（一般很少用到）') logger.error('系统报错异常时需要输出的信息') logger.warning("系统运行警告时需要输出的信息") logger.info("一般信息数据") logger.debug("测试调试时需要输出的信息数据") '''

8、index.html

  1. <!DOCTYPE html>
  2. <html lang="en">
  4. <head>
  5.     <meta charset="UTF-8">
  6.     <meta name="viewport" content="width=device-width, initial-scale=1.0">
  7.     <title>Document</title>
  8. </head>
  10. <body>
  11.     { { info}}
  12.     <h2>登录</h2>
  13.     <form action="/login" method="post">
  14.         <label for="username">手机号:</label>
  15.         <input type="text" name="telphone" required>
  16.         <label for="password">密码:</label>
  17.         <input type="text" name="password" required>
  18.         <button type="reset">重置</button>
  19.         <button type="submit">提交</button>
  20.     </form>
  21.     <h2>注册</h2>
  22.     <form action="/register" method="post">
  23.         <label for="telphone">手机号:</label>
  24.         <input type="text" name="telphone" required>
  25.         <label for="password">密码:</label>
  26.         <input type="text" name="password" required>
  27.         <label for="password_again">密码二次确认:</label>
  28.         <input type="text" name="password_again" required>
  29.         <button type="reset">重置</button>
  30.         <button type="submit">提交</button>
  31.     </form>
  32.     <a href="/exit">账号注销</a>
  33. </body>
  35. </html>

9、程序启动效果图
在这里插入图片描述——————————————————————————————————————————————
在这里插入图片描述——————————————————————————————————————————————
在这里插入图片描述——————————————————————————————————————————————
在这里插入图片描述——————————————————————————————————————————————
在这里插入图片描述——————————————————————————————————————————————
在这里插入图片描述——————————————————————————————————————————————
在这里插入图片描述——————————————————————————————————————————————
在这里插入图片描述
10、备注
这个架构只考虑最简单的登录、注册、注销逻辑，之后优化可以注重前端输入限制、placeholder、登录密码加盐Hash等等

发表评论

表情：
评论列表 （有 0 条评论，269人围观）

还没有评论，来说两句吧...

相关阅读

    相关 java_后端获取当前登录用户信息

    后端获取当前登录用户信息 开发过程中，发现有很多地方需要获取当前登录的用户信息，比如新增、修改时候要记录创建人和更新人信息，如果每次操作都从数据库中获取用户信息，会增加不

    心已赠人心已赠人/ 0 赞/ 126 阅读

    相关 用户注册登录流程

    用户注册: 1.用户填写参数,移出鼠标效验手机号,登录账号,邮箱, 2.判断用户id是否是超级管理员用户,超级管理员是不允许修改的 3.随机生成盐,用户赋值盐

    旧城等待，旧城等待，/ 0 赞/ 730 阅读

    相关 移动端用户登录&注册案例

    用的是TypeScript语言，主要是展示相关的思想逻辑，而不是语法。会说明注册和登录页面进行局部切换的逻辑、用账号密码登录的相关逻辑、用手机号和验证码登录的相关逻辑、获取验证

    旧城等待，旧城等待，/ 0 赞/ 600 阅读