Flask 构建微电影视频网站

已上线演示地址: http://movie.mtianyan.cn
项目源码地址：https://github.com/mtianyan/movie_project

本节教程对应github : commit：1-3完结并将ip密码省去.

持续更新教程与代码commit。欢迎大家一起学习，star。

介绍微电影网站整体开发流程

flask：轻量级，冗余度小，扩展丰富，可以自由选择组合各种插件，性能优越。

前台加后台微电影网站.

系统介绍：

前台首页-电影筛选-电影列表- 播放详情-评论：收藏-搜索-注册-登录-会员中心（修改会员资料，查看评论记录，登录日志，收藏电影）

后台-标签-电影管理-预告-会员-评论-收藏-日志-权限管理-角色-管理员。

适合人群：pythoner

个人必备基础:

• 有自学能力
• 需要掌握python基本语法。
• 会使用mysql数据库
• 会linux基本操作
• 有前端基础知识

课程介绍

flask + mysql

项目整体模块

开发及生产环境：

技术路线

国内知名的使用python做web开发。

国内python

python框架对比：

框架对比

flask简介

werkzeug封装了许多功能：文件上传。生成密码，校验密码等。

flask简介

微内核框架：

微内核框架

我们将学到得如下flask框架知识：

flask框架知识
flask框架知识2 flask框架知识3

微内核 + 丰富的扩展插件：

flask插件 flask插件 视频技术

环境搭建与工具

搭建开发环境安装依赖包，virtualenv虚拟化环境的使用

windows环境搭建：

• windows10（or win7）
• python3.6
• mysql5.7
• 虚拟化环境：virtualenv：pip install virtualenv
• 代码编辑器：pycharm（社区版就足够）

pycharm编辑器使用，介绍pip下载工具使用

pycharm：新建文件->点击run运行

1. virtualenv的使用及flask安装

virtualenv的使用：

• 创建虚拟环境：virtualenv venv
• 激活虚拟环境： source venv/bin/activate
• 退出虚拟环境 ：deactivate

2. flask的安装：

• 安装前检测：pip freeze
• 安装flask： pip install flask
• 安装后检测：pip freeze

error：
安装flask报错：UnicodeDecodeError: 'utf-8' codec can't decode byte 0xb6 in position 33: invalid
start byte

当前虚拟环境\lib\site-packages\pip\compat_init_.py约75行
return s.decode('utf_8') 改为return s.decode('cp936')

第一个flask程序

点击新建project->movie_project->选择解释环境为刚才新建的flask3

# _*_ coding: utf-8 _*_
__author__ = 'mtianyan'
__date__ = '2017/8/26 16:56'

from flask import Flask
app = Flask(__name__)

@app.route("/")
def index():
    return "<h1 style='color:red'>Hello World!</h1>"

if __name__ == "__main__":
    app.run()

右键点击run之后：控制台画面如下：

控制台信息

点击链接可看到红色的helloworld，此时flask安装及运行成功。

项目优化与模型设计

前后台项目目录分析：

微电影网站：

• 前台模块（home）
• 后台模块（admin）

前台模块：

• 数据模型：models.py
• 表单处理： home/forms.py
• 模板目录： templates/home
• 静态目录：static

后台

• 数据模型：models.py
• 表单处理： admin/forms.py
• 模板目录： templates/admin
• 静态目录：static

前台后台表单处理，模板目录独立。数据模型共有。

前后台目录分析：

项目目录分析

pythonpackage：

• app
• app::admin
• app::home

directory:

• static
• templates
• templates::admin
• templates::home

最终项目目录如下图：

目录结构

使用flask的蓝图Blueprint规划项目结构

1. 什么是蓝图？

一个应用中或跨应用制作应用组件和支持通用的模式

2. 蓝图的作用：

• 将不同的功能模块化
• 构建大型应用
• 优化项目结构
• 增强可读性，易于维护

将项目合理规划，易于扩展。

• 定义蓝图(app/admin/__init__.py)

from flask import Blueprint
admin = Blueprint("admin",__name__)
import views

• 注册蓝图(app/__init__.py)

from admin import admin as admin_blueprint
app.register_blueprint(admin_blueprint,url_prefix="admin")

• 调用蓝图(app/admin/views.py)

from . import admin
@admin.route("/")

实际编码：

home/init.py:

from . import home

@home.route("/")
def index():
    return "<h1 style='color:green'>this is home</h1>"

admin/init.py"

from flask import Blueprint

admin = Blueprint("admin",__name__)

import app.admin.views

• 第一步：定义出了两个蓝图对象。
• 第二步：去views.py内调用蓝图对象：

home/views.py:

from . import home

@home.route("/")
def index():
    return "<h1 style='color:green'>this is home</h1>"

admin/views.py:

# _*_ coding: utf-8 _*_
__author__ = 'mtianyan'
__date__ = '2017/8/26 17:06'


from . import admin

@admin.route("/")
def index():
    return "<h1 style='color:red'>this is admin</h1>"

• 第三步：要注册蓝图对象

app/init.py:

# _*_ coding: utf-8 _*_
__author__ = 'mtianyan'
__date__ = '2017/8/26 17:05'

from flask import Flask

app = Flask(__name__)
app.debug = True

from app.home import home as home_blueprint
from app.admin import admin as admin_blueprint

app.register_blueprint(home_blueprint)
app.register_blueprint(admin_blueprint, url_prefix="/admin")

并为admin设置了url前缀"/admin"

• 最后一步：manage.py。启动app。

manage.py:

# _*_ coding: utf-8 _*_
__author__ = 'mtianyan'
__date__ = '2017/8/26 17:05'

from app import app

if __name__ == "__main__":
    app.run()

成果：
点击run之后可以在浏览器里看到：
前台绿色，后台(/admin)红色

使用flaskSQLAlchemy定义和业务需求相关的数据库模型

• 安装数据库连接依赖包
  pip install flask-sqlalchemy:sqlalchemy(企业级的orm对象关系映射框架。面向对象的思想操作数据库)

• 定义mysql数据库连接：

from flask_sqlalchemy import SQLAlchemy
from flask import Flask

app = from flask import Flask 
app = Flask(__name__)
app.config['SQLALCHEMY_DATABASE_URL'] = "mysql://root:ty158917@localhost/movie"
app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] =True
db = SQLAlchemy(app)

• 定义会员数据模型：

class User(db.Model):
    __tablename__ = "user"
    id = db.Column(db.Integer,primary_key=True)
    name = db.Column(db.String)
    pwd = db.Column(db.String)
    email = db.Column(db.String)
    phone = db.Column(db.String)
    info = db.Column(db.Text)
    face = db.Column(db.String)
    addtime = db.Column(db.DateTime,index=True,default=datetime.utcnow)
    uuid = db.Column(db.String)

会员数据模型字段说明

• 会员登录日志数据模型：
  • id:编号
  • user_id：所属会员编号
  • ip：最近登录ip地址
  • addtime：最近登录时间

实际编码：

• 控制台下使用：mysql -uroot -p密码进入mysql控制台
• mysql>create database movie;来创建数据库

models.py:

# _*_ coding: utf-8 _*_
import datetime

__author__ = 'mtianyan'
__date__ = '2017/8/26 17:05'

from flask import Flask
from flask_sqlalchemy import SQLAlchemy

app = Flask(__name__)
#用于连接数据的数据库。
app.config['SQLALCHEMY_DATABASE_URL'] = "mysql://root:ty158917@127.0.0.1:3306/movie"
#如果设置成 True (默认情况)，Flask-SQLAlchemy 将会追踪对象的修改并且发送信号。
app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] =True

db = SQLAlchemy(app)

#会员数据模型
class User(db.Model):
    __tablename__ = "user"
    id = db.Column(db.Integer,primary_key=True)#编号
    name = db.Column(db.String(100),unique=True)#昵称
    pwd = db.Column(db.String(100))#密码
    email = db.Column(db.String(100),unique=True)#邮箱
    phone = db.Column(db.String(11),unique=True)#手机号
    info = db.Column(db.Text)#个性简介
    face = db.Column(db.String(255),unique=True)#头像
    addtime = db.Column(db.DateTime,index=True,default=datetime.utcnow)#注册时间
    uuid = db.Column(db.String(255),unique=True)#唯一标识符
    #（设置外键的第二步）
    userlogs = db.relationship('userlog',backref = 'user')#会员日志外键关系关联

    def __repr__(self):
        return '<User %r>' % self.name

#会员登录日志
class Userlog(db.Model):
    __tablename__ = "userlog"
    #（设置外键的第一步）
    id = db.Column(db.Integer,primary_key=True)#编号
    user_id =db.Column(db.Integer,db.ForeignKey('user.id'))#所属会员
    ip = db.Column(db.String(100))#ip地址
    addtime = db.Column(db.DateTime,index=True,default=datetime.utcnow)#登录时间

    def __repr__(self):
        return '<User %r>' % self.id

注意设置外键分为两步进行。

标签、电影、上映预告数据模型设计

• 定义标签数据模型：
  • id：编号
  • name：标题
  • movies：电影外键关联
  • addtime：创建时间
• 定义电影数据模型：

电影数据模型

• 定义上映预告数据模型
  • id：编号
  • title：上映预告标题
  • logo：上映预告封面
  • addtime：创建时间

# 标签
class Tag(db.Model):
    __tablename__ = "tag"
    id = db.Column(db.Integer, primary_key=True)  # 编号
    name = db.Column(db.String(100), unique=True)  # 标题
    addtime = db.Column(db.DateTime, index=True, default=datetime.utcnow)  # 添加电影时间
    # （设置外键的第二步）
    movies = db.relationship("Movie", backref='tag')  # 电影外键关系关联

    def __repr__(self):
        return "<Tag %r>" % self.name

# 电影
class Movie(db.Model):
    __tablename__ = "movie"
    id = db.Column(db.Integer, primary_key=True)  # 编号
    title = db.Column(db.String(255), unique=True)  # 标题
    url = db.Column(db.String(255), unique=True)  # 地址
    info = db.Column(db.Text)  # 电影简介
    logo = db.Column(db.String(255), unique=True)  # 封面
    star = db.Column(db.SmallInteger)  # 星级
    playnum = db.Column(db.BigInteger)  # 播放量c
    commentnum = db.Column(db.BigInteger)  # 评论量
    #  （设置外键第一步）
    tag_id = db.Column(db.Integer, db.ForeignKey('tag.id'))  # 所属标签
    area = db.Column(db.String(255))  # 上映地区
    release_time = db.Column(db.Date)  # 上映时间
    length = db.Column(db.String(100))  # 播放时间
    addtime = db.Column(db.DateTime, index=True, default=datetime.utcnow)  # 添加时间
    comments = db.relationship("Comment", backref='movie')  # 评论外键关系关联
    moviecols = db.relationship("Moviecol", backref='movie')  # 收藏外键关系关联

    def __repr__(self):
        return "<Movie %r>" % self.title


# 上映预告
class Preview(db.Model):
    __tablename__ = "preview"
    id = db.Column(db.Integer, primary_key=True)  # 编号
    title = db.Column(db.String(255), unique=True)  # 标题
    logo = db.Column(db.String(255), unique=True)  # 封面
    addtime = db.Column(db.DateTime, index=True, default=datetime.utcnow)  # 添加时间

    def __repr__(self):
        return "<Preview %r>" % self.title

评论及收藏电影数据模型设计

定义评论数据模型：

• id：编号
• content：评论内容
• movie_id: 所属电影
• user_id: 所属用户
• addtime：最近登录时间

# 评论
class Comment(db.Model):
    __tablename__ = "comment"
    id = db.Column(db.Integer, primary_key=True)  # 编号
    content = db.Column(db.Text)  # 内容
    movie_id = db.Column(db.Integer, db.ForeignKey('movie.id'))  # 所属电影
    user_id = db.Column(db.Integer, db.ForeignKey('user.id'))  # 所属用户
    addtime = db.Column(db.DateTime, index=True, default=datetime.utcnow)  # 添加时间

    def __repr__(self):
        return "<Comment %r>" % self.id


# 电影收藏
class Moviecol(db.Model):
    __tablename__ = "moviecol"
    id = db.Column(db.Integer, primary_key=True)  # 编号
    movie_id = db.Column(db.Integer, db.ForeignKey('movie.id'))  # 所属电影
    user_id = db.Column(db.Integer, db.ForeignKey('user.id'))  # 所属用户
    addtime = db.Column(db.DateTime, index=True, default=datetime.utcnow)  # 添加时间

    def __repr__(self):
        return "<Moviecol %r>" % self.id

权限及角色数据模型设计

定义权限数据模型：

• id：编号
• name：名称
• url：地址（路由地址）
• addtime：创建时间

定义角色模型：

• id：编号
• name：名称
• auths：权限列表（多个权限以分隔符分开组成的字符串）
• addtime：创建时间
• admins：管理员外键关联

# 权限
class Auth(db.Model):
    __tablename__ = "auth"
    id = db.Column(db.Integer, primary_key=True)  # 编号
    name = db.Column(db.String(100), unique=True)  # 名称
    url = db.Column(db.String(255), unique=True)  # 地址
    addtime = db.Column(db.DateTime, index=True, default=datetime.now)  # 添加时间

    def __repr__(self):
        return "<Auth %r>" % self.name


# 角色
class Role(db.Model):
    __tablename__ = "role"
    id = db.Column(db.Integer, primary_key=True)  # 编号
    name = db.Column(db.String(100), unique=True)  # 名称
    auths = db.Column(db.String(600))  # 角色权限列表
    addtime = db.Column(db.DateTime, index=True, default=datetime.now)  # 添加时间
    admins = db.relationship("Admin", backref='role')  # 管理员外键关系关联

    def __repr__(self):
        return "<Role %r>" % self.name

管理员.登陆日志。操作日志数据模型设计

管理员数据模型 管理员登录日志数据模型 操作日志数据模型

# 管理员
class Admin(db.Model):
    __tablename__ = "admin"
    id = db.Column(db.Integer, primary_key=True)  # 编号
    name = db.Column(db.String(100), unique=True)  # 管理员账号
    pwd = db.Column(db.String(100))  # 管理员密码
    is_super = db.Column(db.SmallInteger)  # 是否为超级管理员，0为超级管理员
    role_id = db.Column(db.Integer, db.ForeignKey('role.id'))  # 所属角色
    addtime = db.Column(db.DateTime, index=True, default=datetime.now)  # 添加时间
    adminlogs = db.relationship("Adminlog", backref='admin')  # 管理员登录日志外键关系关联
    oplogs = db.relationship("Oplog", backref='admin')  # 管理员操作日志外键关系关联

    def __repr__(self):
        return "<Admin %r>" % self.name

    def check_pwd(self, pwd):
        from werkzeug.security import check_password_hash
        return check_password_hash(self.pwd, pwd)


# 管理员登录日志
class Adminlog(db.Model):
    __tablename__ = "adminlog"
    id = db.Column(db.Integer, primary_key=True)  # 编号
    admin_id = db.Column(db.Integer, db.ForeignKey('admin.id'))  # 所属管理员
    ip = db.Column(db.String(100))  # 登录IP
    addtime = db.Column(db.DateTime, index=True, default=datetime.now)  # 登录时间

    def __repr__(self):
        return "<Adminlog %r>" % self.id


# 操作日志
class Oplog(db.Model):
    __tablename__ = "oplog"
    id = db.Column(db.Integer, primary_key=True)  # 编号
    admin_id = db.Column(db.Integer, db.ForeignKey('admin.id'))  # 所属管理员
    ip = db.Column(db.String(100))  # 操作IP
    reason = db.Column(db.String(600))  # 操作原因
    addtime = db.Column(db.DateTime, index=True, default=datetime.now)  # 登录时间

    def __repr__(self):
        return "<Oplog %r>" % self.id

结合mysql数据库生成数据表

1. 安装pymysql然后点击run运行。

故障提示：

SQLAlchemy插入数据产生警告

cursors.py:166: Warning: (1366, "Incorrect string value: '\\xD6\\xD0\\xB9\\xFA\\xB1\\xEA...' for column 'VARIABLE_VALUE' at row 479")result = self._query(query)

windows系统默认使用的是gbk的字符集，而我在windows系统上使用的数据库也是在本机windows系统上，而报错是因为字符集的问题，但是我指定了数据库的字符集是utf8的，然每次连接依然有这个错误，个人分析应该是系统字符串造成的。所以我改到使用linux系统里的mysql建立一个utf8的数据库后，使用未出现上述问题，所以分析应该是系统字符串导致的。

此处我使用了远程连接linux服务器上的数据库，消除了警告。

完整models.py代码：

# _*_ coding: utf-8 _*_
from datetime import datetime

__author__ = 'mtianyan'
__date__ = '2017/8/26 17:05'

from flask import Flask
from flask_sqlalchemy import SQLAlchemy
import pymysql

app = Flask(__name__)
#用于连接数据的数据库。
app.config["SQLALCHEMY_DATABASE_URI"] = "mysql+pymysql://用户名:密码@ip地址:3306/movie"
#如果设置成 True (默认情况)，Flask-SQLAlchemy 将会追踪对象的修改并且发送信号。
app.config["SQLALCHEMY_TRACK_MODIFICATIONS"] =True

db = SQLAlchemy(app)

#会员数据模型
class User(db.Model):
    __tablename__ = "user"
    id = db.Column(db.Integer,primary_key=True)#编号
    name = db.Column(db.String(100),unique=True)#昵称
    pwd = db.Column(db.String(100))#密码
    email = db.Column(db.String(100),unique=True)#邮箱
    phone = db.Column(db.String(11),unique=True)#手机号
    info = db.Column(db.Text)#个性简介
    face = db.Column(db.String(255),unique=True)#头像
    addtime = db.Column(db.DateTime,index=True,default=datetime.utcnow)#注册时间
    uuid = db.Column(db.String(255),unique=True)#唯一标识符
    #（设置外键的第二步）
    userlogs = db.relationship('userlog',backref = 'user')#会员日志外键关系关联
    comments = db.relationship('Comment', backref='user')  # 评论外键关系关联
    moviecols = db.relationship('Moviecol', backref='user')  # 收藏外键关系关联
    def __repr__(self):
        return '<User %r>' % self.name

#会员登录日志
class Userlog(db.Model):
    __tablename__ = "userlog"
    #（设置外键的第一步）
    id = db.Column(db.Integer,primary_key=True)#编号
    user_id =db.Column(db.Integer,db.ForeignKey('user.id'))#所属会员
    ip = db.Column(db.String(100))#ip地址
    addtime = db.Column(db.DateTime,index=True,default=datetime.utcnow)#登录时间

    def __repr__(self):
        return '<User %r>' % self.id

# 标签
class Tag(db.Model):
    __tablename__ = "tag"
    id = db.Column(db.Integer, primary_key=True)  # 编号
    name = db.Column(db.String(100), unique=True)  # 标题
    addtime = db.Column(db.DateTime, index=True, default=datetime.utcnow)  # 添加电影时间
    # （设置外键的第二步）
    movies = db.relationship("Movie", backref='tag')  # 电影外键关系关联

    def __repr__(self):
        return "<Tag %r>" % self.name

# 电影
class Movie(db.Model):
    __tablename__ = "movie"
    id = db.Column(db.Integer, primary_key=True)  # 编号
    title = db.Column(db.String(255), unique=True)  # 标题
    url = db.Column(db.String(255), unique=True)  # 地址
    info = db.Column(db.Text)  # 电影简介
    logo = db.Column(db.String(255), unique=True)  # 封面
    star = db.Column(db.SmallInteger)  # 星级
    playnum = db.Column(db.BigInteger)  # 播放量c
    commentnum = db.Column(db.BigInteger)  # 评论量
    #  （设置外键第一步）
    tag_id = db.Column(db.Integer, db.ForeignKey('tag.id'))  # 所属标签
    area = db.Column(db.String(255))  # 上映地区
    release_time = db.Column(db.Date)  # 上映时间
    length = db.Column(db.String(100))  # 播放时间
    addtime = db.Column(db.DateTime, index=True, default=datetime.utcnow)  # 添加时间
    comments = db.relationship("Comment", backref='movie')  # 评论外键关系关联
    moviecols = db.relationship("Moviecol", backref='movie')  # 收藏外键关系关联

    def __repr__(self):
        return "<Movie %r>" % self.title


# 上映预告
class Preview(db.Model):
    __tablename__ = "preview"
    id = db.Column(db.Integer, primary_key=True)  # 编号
    title = db.Column(db.String(255), unique=True)  # 标题
    logo = db.Column(db.String(255), unique=True)  # 封面
    addtime = db.Column(db.DateTime, index=True, default=datetime.utcnow)  # 添加时间

    def __repr__(self):
        return "<Preview %r>" % self.title

# 评论
class Comment(db.Model):
    __tablename__ = "comment"
    id = db.Column(db.Integer, primary_key=True)  # 编号
    content = db.Column(db.Text)  # 内容
    movie_id = db.Column(db.Integer, db.ForeignKey('movie.id'))  # 所属电影
    user_id = db.Column(db.Integer, db.ForeignKey('user.id'))  # 所属用户
    addtime = db.Column(db.DateTime, index=True, default=datetime.utcnow)  # 添加时间

    def __repr__(self):
        return "<Comment %r>" % self.id


# 电影收藏
class Moviecol(db.Model):
    __tablename__ = "moviecol"
    id = db.Column(db.Integer, primary_key=True)  # 编号
    movie_id = db.Column(db.Integer, db.ForeignKey('movie.id'))  # 所属电影
    user_id = db.Column(db.Integer, db.ForeignKey('user.id'))  # 所属用户
    addtime = db.Column(db.DateTime, index=True, default=datetime.utcnow)  # 添加时间

    def __repr__(self):
        return "<Moviecol %r>" % self.id

# 权限
class Auth(db.Model):
    __tablename__ = "auth"
    id = db.Column(db.Integer, primary_key=True)  # 编号
    name = db.Column(db.String(100), unique=True)  # 名称
    url = db.Column(db.String(255), unique=True)  # 地址
    addtime = db.Column(db.DateTime, index=True, default=datetime.now)  # 添加时间

    def __repr__(self):
        return "<Auth %r>" % self.name


# 角色
class Role(db.Model):
    __tablename__ = "role"
    id = db.Column(db.Integer, primary_key=True)  # 编号
    name = db.Column(db.String(100), unique=True)  # 名称
    auths = db.Column(db.String(600))  # 角色权限列表
    addtime = db.Column(db.DateTime, index=True, default=datetime.now)  # 添加时间
    admins = db.relationship("Admin", backref='role')  # 管理员外键关系关联

    def __repr__(self):
        return "<Role %r>" % self.name


# 管理员
class Admin(db.Model):
    __tablename__ = "admin"
    id = db.Column(db.Integer, primary_key=True)  # 编号
    name = db.Column(db.String(100), unique=True)  # 管理员账号
    pwd = db.Column(db.String(100))  # 管理员密码
    is_super = db.Column(db.SmallInteger)  # 是否为超级管理员，0为超级管理员
    role_id = db.Column(db.Integer, db.ForeignKey('role.id'))  # 所属角色
    addtime = db.Column(db.DateTime, index=True, default=datetime.now)  # 添加时间
    adminlogs = db.relationship("Adminlog", backref='admin')  # 管理员登录日志外键关系关联
    oplogs = db.relationship("Oplog", backref='admin')  # 管理员操作日志外键关系关联

    def __repr__(self):
        return "<Admin %r>" % self.name

    def check_pwd(self, pwd):
        from werkzeug.security import check_password_hash
        return check_password_hash(self.pwd, pwd)


# 管理员登录日志
class Adminlog(db.Model):
    __tablename__ = "adminlog"
    id = db.Column(db.Integer, primary_key=True)  # 编号
    admin_id = db.Column(db.Integer, db.ForeignKey('admin.id'))  # 所属管理员
    ip = db.Column(db.String(100))  # 登录IP
    addtime = db.Column(db.DateTime, index=True, default=datetime.now)  # 登录时间

    def __repr__(self):
        return "<Adminlog %r>" % self.id


# 操作日志
class Oplog(db.Model):
    __tablename__ = "oplog"
    id = db.Column(db.Integer, primary_key=True)  # 编号
    admin_id = db.Column(db.Integer, db.ForeignKey('admin.id'))  # 所属管理员
    ip = db.Column(db.String(100))  # 操作IP
    reason = db.Column(db.String(600))  # 操作原因
    addtime = db.Column(db.DateTime, index=True, default=datetime.now)  # 登录时间

    def __repr__(self):
        return "<Oplog %r>" % self.id

if __name__ == "__main__":
    db.create_all()

最终映射成功后的数据表：

运行成功 映射出的数据库表

附录：
mysql命令：

• use movie;
• show tables;
• desc admin;