前言：

✌ 作者简介：渴望力量的哈士奇 ✌，大家可以叫我 🐶哈士奇🐶 ，一位致力于 TFS - 全栈 赋能的博主 ✌

🏆 CSDN博客专家认证、新星计划第三季全栈赛道 MVP 、华为云享专家、阿里云专家博主 🏆

📫 如果文章知识点有错误的地方，请指正！和大家一起学习，一起进步👀

💬 人生格言：优于别人,并不高贵,真正的高贵应该是优于过去的自己。💬

🔥 如果感觉博主的文章还不错的话，还请👍关注、点赞、收藏三连支持👍一下博主哦

文章目录

❤️‍🔥 需要缓存的新闻类型❤️‍🔥 编写 "新闻编辑" 角色的业务流程❣️ 实现新闻编辑功能 - "type_dao.py" - 编写查询新闻类型列表 - search_list() 方法❣️ 实现新闻编辑功能 - "type_service.py" - 编写查询新闻类型列表 - search_list() 方法❣️ 实现新闻编辑功能 - "news_dao.py" - 保存新闻记录 - insert() 方法❣️ 实现新闻编辑功能 - "news_service.py" - 保存新闻记录 - insert() 方法❣️ 实现查询用户 id 功能 - "user_dao.py" - 查询用户 id - search_userid() 方法❣️ 实现查询用户 id 功能 - "user_service.py" - 查询用户 id - search_userid() 方法❤️‍🔥 编写 "新闻编辑" 角色的业务 - "发表新闻" 流程

接下来这段时间我们将要又回到 《新闻管理系统》 这个项目，在这个阶段我们将要针对 《新闻管理系统》 进行改造。为这个系统添加 “缓存新闻” 的功能。

如果登录用户是以 “新闻编辑” 的身份登录，发表新闻之后，发表的新闻是不会立刻缓存到 redis 的。只有改新闻被管理员审批通过之后，才能够缓存到 redis 。

如果审批通过的是置顶新闻，则置顶的新闻是没有缓存过期时间的，也就是说将一直在 redis 中缓存着；如果审批通过的事非置顶的新闻，则改新闻只会缓存 24小时 ，如果用户重新编辑了已经审批通过的新闻，那么这条新闻需要被重新审批，所以这里之前缓存的新闻也应该立即被删除。

管理员身份的用户在执行 “删除新闻” 操作的时候，也需要连带着将 redis 中缓存的新闻删掉。

以上这些内容就是我们将要在这一阶段学习、实现、并且需要完成的，内容已经介绍完了，接下来就开始我们将要实现的第一个功能，"发表新闻" 吧。

❤️‍🔥 需要缓存的新闻类型

《新闻管理系统》 需要缓存的就是新闻的内容，当然了，我们并不能将所有的新闻都缓存到 redis 里面，所以我们需要缓存的新闻主要由两种类型。第一种是当天发表的新闻，由于热度关系，这一类型的新闻在当天的访问量一般情况下都会很大，针对这类的新闻可以设置一个过期时间，超过 24 小时就会将其从 redis 中 销毁。第二种需要缓存的新闻是置顶的新闻，这一类型的新闻是人为操控的，这类新闻既需要保存在 redis 中，也需要保存到 MySQL数据库 中。

❤️‍🔥 编写 “新闻编辑” 角色的业务流程

接下来打开我们之前缩写的 “news” 这个项目，找到 “app.py” 这个模块，搜索if role == "新闻编辑":这行代码。在此之前，我们并没有针对 “新闻编辑” 这个角色进行业务流程的编写，而是实现了 “管理员” 这个角色的业务。接下来，我们就以 “新闻编辑” 的身份切入到 “news” 这个项目的业务流程。

❣️ 实现新闻编辑功能 - “type_dao.py” - 编写查询新闻类型列表 - search_list() 方法

与之前编写 “新闻管理” 的功能一样，依然要从 “db” 包的 “dao” 层写起，因为在 “发表新闻” 的业务流程里面，需要让用户选择要发表的新闻的 “类别” ；在 “news” 这个项目的 MySQL 数据库中有一章表 - “t_type” ，在这张表中存储的就是 “新闻的类别” 的记录，这些记录需要被读取出来，在执行 “发表新闻” 的操作的时候，需要将 “新闻的类别” 输出到控制台，让用户选择要发表新闻的 “新闻类别” 。所以接下来，我们需要在 “db” 包中，先创建一个 “type_dao.py” 的模块文件，代码内容如下：

# coding:utf-8from db.mysql_db import pool"""定义 TypeDao 类"""class TypeDao:"""查询新闻类型列表"""def search_list(self):try:con=pool.get_connection()cursor=con.cursor()sql="SELECT id, type FROM t_type ORDER BY id" # 查询 t_type 表的 id 与 type ，并根据 id 排序。cursor.execute(sql)result=cursor.fetchall() # 返回的是结果集，使用 fetchall()return resultexcept Exception as e:print(e)finally:if "con" in dir():con.close()

❣️ 实现新闻编辑功能 - “type_service.py” - 编写查询新闻类型列表 - search_list() 方法

封装 “type_service.py” ，代码内容如下：

# coding:utf-8from db.type_dao import TypeDao"""定义 TypeService 类"""class TypeService:__type_dao=TypeDao()"""查询新闻类型列表"""def search_list(self):result=self.__type_dao.search_list()return result

❣️ 实现新闻编辑功能 - “news_dao.py” - 保存新闻记录 - insert() 方法

接下来我们应该去写一下 “news_dao.py” 里面的函数了，用来保存新闻的记录。代码示例如下：重点新增了 “添加新闻” -第 157 行 - 第 185 行

# coding:utf-8from db.mysql_db import pool"""定义 NewsDao 类"""class NewsDao:"""查询待审批新闻列表1、定义 search_unreview_list 方法，传入参数 page2、针对 search_unreview_list 方法，进行异常捕获"""def search_unreview_list(self, page): # 定义 search_unreview_list；查询 "待审批" 新闻列表try:# try 语句捕获异常con=pool.get_connection() # 定义一个连接（从连接池取出一个连接）cursor=con.cursor() # 创建游标"""1、将查询待审批新闻列表 SQL语句 赋值给 sql2、使用表连接将查询到的新闻记录进行 分页 ，每一页 10条记录；"新闻表、类型表、用户表"3、根据 creat_time 字段降序排列，也就是最新的新闻排在最上面"""sql="SELECT n.id,n.title,t.type,u.username " \"FROM t_news n JOIN t_type t ON n.type_id=t.id " \"JOIN t_user u ON n.editor_id=u.id " \"WHERE n.state=%s " \"ORDER BY n.create_time DESC " \"LIMIT %s,%s"cursor.execute(sql, ("待审批", (page-1)*10, 10))# 将 page 换算为起始位置 和偏移量# 举例：显示第一页 --> page为1# '(1-1)*10 ,10'为查询第0位开始，偏移10的记录，则就是前十条记录# 同理：第二页记录从第 10 条记录开始，为 '(2-1)*10 ,10'result=cursor.fetchall() # 将查询的结果集 赋值 给 result ； 获取全部结果集 使用 fetchall()方法。return resultexcept Exception as e:print(e)finally:if "con" in dir():con.close()"""查询 "待审批新闻" 的总页数1、定义 search_unreview_count_page 方法，不需要传入参数2、针对 search_unreview_count_page 方法，进行异常捕获"""def search_unreview_count_page(self):try:con=pool.get_connection()cursor=con.cursor()"""将 "查询待审批新闻"总数分页的 SQL语句 赋值给 sql"""sql="SELECT CEIL(COUNT(*)/10) FROM t_news WHERE state=%s" # CEIL() 函数是结果有小数位，强制进一位。cursor.execute(sql, ["待审批"])count_page=cursor.fetchone()[0] # 查询结果集只有一条记录，所以这里使用 fetchone()return count_pageexcept Exception as e:print(e)finally:if "con" in dir():con.close()"""审批新闻1、定义 update_unreview_news() 方法，传入参数 id2、针对 update_unreview_news() 方法，进行异常捕获"""def update_unreview_news(self, id):try:con = pool.get_connection()con.start_transaction()cursor = con.cursor()sql = "UPDATE t_news SET state=%s WHERE id=%s"# 预编译 "待审批新闻" SQL语句，将其变更为 "已审批"cursor.execute(sql, ("已审批", id))mit()except Exception as e:if "con" in dir():con.rollback()print(e)finally:if "con" in dir():con.close()"""查询新闻列表1、定义 search_list() 方法，传入参数 page ， 查询全部 新闻记录 的SQL语句赋值给 sql2、针对 search_list() 方法，进行异常捕获。"""def search_list(self, page):try:# try 语句捕获异常con=pool.get_connection() # 定义一个连接（从连接池取出一个连接）cursor=con.cursor() # 创建游标"""1、将查询待审批新闻列表 SQL语句 赋值给 sql2、使用表连接将查询到的新闻记录进行 分页 ，每一页 10条记录；"新闻表、类型表、用户表""""sql="SELECT n.id,n.title,t.type,u.username " \"FROM t_news n JOIN t_type t ON n.type_id=t.id " \"JOIN t_user u ON n.editor_id=u.id " \"ORDER BY n.create_time DESC " \"LIMIT %s,%s"cursor.execute(sql, ((page-1)*10, 10))# 将 page 换算为起始位置 和偏移量# 举例：显示第一页 --> page为1# '(1-1)*10 ,10'为查询第0位开始，偏移10的记录，则就是前十条记录# 同理：第二页记录从第 10 条记录开始，为 '(2-1)*10 ,10'result=cursor.fetchall() # 将查询的结果集 赋值 给 result ； 获取全部结果集 使用 fetchall()方法。return resultexcept Exception as e:print(e)finally:if "con" in dir():con.close()"""查询新闻总页数"""def search_count_page(self):try:con=pool.get_connection()cursor=con.cursor()"""将 "查询新闻总页数" SQL语句 赋值给 sql"""sql="SELECT CEIL(COUNT(*)/10) FROM t_news" # CEIL() 函数是结果有小数位，强制进一位。cursor.execute(sql)count_page=cursor.fetchone()[0] # 查询结果集只有一条记录，所以这里使用 fetchone()return count_pageexcept Exception as e:print(e)finally:if "con" in dir():con.close()"""删除新闻1、定义 delete_by_id() 方法，传入参数 id ， 根据新闻主键 id 删除新闻记录的 SQL语句 赋值给 sql2、针对 delete_by_id() 方法，进行异常捕获。"""def delete_by_id(self, id):try:con = pool.get_connection()con.start_transaction()cursor = con.cursor()sql = "DELETE FROM t_news WHERE id=%s" # 预编译 "删除新闻" SQL语句cursor.execute(sql, [id])mit()except Exception as e:if "con" in dir():con.rollback()print(e)finally:if "con" in dir():con.close()"""添加新闻1、定义 insert() 方法，传入 title[新闻标题], editor_id[新闻作者id], type_id[新闻类型], content_id[新闻正文id], '正文' 是保存在 'MongoDB' 数据库的，目前我们还没有接触，当学完 MongoDB 知识点后，就可以使用了is_top[是否置顶|置顶级别]2、将传入的新闻的参数，赋值给添加新闻的 SQL 语句3、针对 insert() 方法，进行异常捕获。"""def insert(self, title, editor_id, type_id, content_id, is_top):try:con = pool.get_connection()con.start_transaction()# 开启事务cursor=con.cursor() # 打开游标"""添加新闻的SQL语句 [通过格式化字符串将传入的参数作为 SQL 的 VALUES，state 的值为 '待审批']"""sql="INSERT INTO t_news(title,editor_id,type_id,content_id,is_top,state) " \"VALUES(%s,%s,%s,%s,%s,%s)"cursor.execute(sql, (title, editor_id, type_id, content_id, is_top, "待审批"))mit()# 提交事务except Exception as e:if "con" in dir():# 回滚事务con.rollback()print(e)finally:if "con" in dir():# 关闭事务con.close()

❣️ 实现新闻编辑功能 - “news_service.py” - 保存新闻记录 - insert() 方法

封装 “news_service.py” ，代码内容如下：重点新增了 “添加新闻” -第 59 行 - 第 65 行

# coding:utf-8from db.news_dao import NewsDao"""定义 NewsService 类"""class NewsService:__new_dao = NewsDao() # 实例化 NewsDao ，赋值给私有变量 __new_dao"""1、查询待审批新闻列表；定义 search_unreview_list 方法，传入参数 page2、调用 __new_dao 实例 的 search_unreview_list 方法，赋值给 "result"，并返回结果"""def search_unreview_list(self, page):result = self.__new_dao.search_unreview_list(page)return result"""1、查询 "待审批新闻" 的总页数；定义 search_unreview_count_page 方法，不需要传入参数2、调用 __new_dao 实例 的 search_unreview_count_page 方法，赋值给 "count_page"，并返回结果"""def search_unreview_count_page(self):count_page = self.__new_dao.search_unreview_count_page()return count_page"""1、审批新闻；定义 update_unreview_news() 方法，传入参数 id。2、调用 __new_dao 实例 的 update_unreview_news() 方法"""def update_unreview_news(self, id):self.__new_dao.update_unreview_news(id)"""1、查询新闻列表；定义 search_list() 方法，传入参数 apge2、调用 __new_dao 实例 的 update_unreview_news() 方法"""def search_list(self, page):result = self.__new_dao.search_list(page)return result"""查询新闻总页数"""def search_count_page(self):count_page = self.__new_dao.search_count_page()return count_page"""删除新闻1、定义 delete_by_id() 方法，传入参数 id ，2、调用 __new_dao 实例的 delete_by_id() 方法"""def delete_by_id(self, id):self.__new_dao.delete_by_id(id)"""添加新闻1、定义 insert() 方法，传入 title, editor_id, type_id, content_id, is_top2、调用 __new_dao 实例的 insert() 方法"""def insert(self, title, editor_id, type_id, content_id, is_top):self.__new_dao.insert(title, editor_id, type_id, content_id, is_top)

❣️ 实现查询用户 id 功能 - “user_dao.py” - 查询用户 id - search_userid() 方法

接下来我们将要切换到 “user_dao.py” 这个模块，编写一个函数，根据用户的用户名获取用户的 id （因为在刚刚那个 “news_dao.py” 这个模块进行添加新闻的操作的时候，需要知道 “发表新闻” 的 用户id是什么。）打开"user_dao.py" 这个模块，添加 search_userid() 方法。重点新增了 “查询用户ID” -第 179 行 - 第 197 行

# coding:utf-8from db.mysql_db import poolclass UserDao:"""验证用户登录1、定义 login 方法，传入 username, password2、针对 login 方法，进行异常捕获"""def login(self, username, password): # 定义 logintry:# try 语句捕获异常con=pool.get_connection()# 定义一个连接（从连接池取出一个连接）cursor=con.cursor()# 创建游标"""1、将查询用户的预编译 SQL语句 赋值给 sql2、根据输入的账号、密码查找对应的记录"""sql="SELECT COUNT(*) FROM t_user WHERE username=%s AND " \"AES_DECRYPT(UNHEX(password),'HelloWorld')=%s"cursor.execute(sql, (username, password)) # 利用 游标 执行 SLQ语句count=cursor.fetchone()[0] # 获取 游标 结果集的第一个结果，并赋值给 countreturn True if count==1 else False # 如果 count 为1，返回 True(登录成功) ，否则返回 False(登录失败)except Exception as e:# 打印输出异常print(e)finally:# 这里不是 关闭连接 的意思，而是将 连接 归还给 连接池。if "con" in dir():con.close()"""查询用户角色1、定义 search_user_role 方法，传入 username2、将 user表 与 role表做表连接，根据传入的 username 查询用户的身份角色"""def search_user_role(self, username):try:con=pool.get_connection()cursor=con.cursor()"""1、将查询用户角色的的预编译 SQL语句 赋值给 sql2、根据传入的用户名查找对应的角色记录"""sql="SELECT r.role FROM t_user u JOIN t_role r ON u.role_id=r.id " \"WHERE u.username=%s"cursor.execute(sql, [username])role=cursor.fetchone()[0] # 获取 游标 结果集的第一个结果，并赋值给 rolereturn role# 直接返回获取的结果except Exception as e:# 打印输出异常print(e)finally:# 这里不是 关闭连接 的意思，而是将 连接 归还给 连接池。if "con" in dir():con.close()"""添加用户记录1、定义 insert() 方法，传入参数 "username"、 "password"、 "email"、 "role_id"2、针对 insert() 方法 进行异常捕获"""def insert(self, username, password, email, role_id):try:con = pool.get_connection()con.start_transaction()cursor=con.cursor()"""1、将 添加用户 的的预编译 SQL语句 赋值给 sql2、需要针对插入的用户的 password 字段进行加密，秘钥 "HelloWorld""""sql="INSERT INTO t_user(username,password,email,role_id) " \"VALUES(%s,HEX(AES_ENCRYPT(%s,'HelloWorld')),%s,%s)"cursor.execute(sql, (username, password, email, role_id))mit()except Exception as e:if "con" in dir():con.rollback()print(e)finally:if "con" in dir():con.close()"""查询用户总页数1、定义 search_count_page() 方法2、针对 search_count_page() 方法 进行异常捕获"""def search_count_page(self):try:con=pool.get_connection()cursor=con.cursor()sql="SELECT CEIL(COUNT(*)/10) FROM t_user"# 单表查询；CEIL() 函数是结果有小数位，强制进一位。cursor.execute(sql)count_page=cursor.fetchone()[0] # 将 结果集 赋值 给 count_pagereturn count_pageexcept Exception as e:print(e)finally:if "con" in dir():con.close()"""查询用户记录的分页1、定义 search_list() 方法，传入参数 page2、针对 search_list() 方法，进行异常捕获"""def search_list(self, page):try:con=pool.get_connection()cursor=con.cursor()"""1、使用表连接查询，获取用户表的 id、username 及 角色表的 role2、将预编译的查询语句赋值给 sql"""sql="SELECT u.id,u.username,r.role " \"FROM t_user u JOIN t_role r " \"ON u.role_id=r.id " \"ORDER BY u.id " \"LIMIT %s,%s"cursor.execute(sql, ((page-1)*10, 10))result=cursor.fetchall()return resultexcept Exception as e:print(e)finally:if "con" in dir():con.close()"""修改用户信息1、定义 update() 方法，传入参数 id、 username、 password、 email、 role_id2、针对 update() 方法，进行异常捕获"""def update(self, id, username, password, email, role_id):try:con = pool.get_connection()con.start_transaction()cursor=con.cursor()"""1、将 修改用户 的的预编译 SQL语句 赋值给 sql2、需要针对插入的用户的 password 字段进行加密，秘钥 "HelloWorld""""sql="UPDATE t_user SET username=%s," \"password=HEX(AES_ENCRYPT(%s,'HelloWorld'))," \"email=%s,role_id=%s " \"WHERE id=%s"cursor.execute(sql, (username, password, email, role_id, id))mit()except Exception as e:if "con" in dir():con.rollback()print(e)finally:if "con" in dir():con.close()"""删除用户1、定义 delete_by_id() 方法，传入参数 id2、针对 delete_by_id() 方法，进行异常捕获"""def delete_by_id(self, id):try:con = pool.get_connection()con.start_transaction()cursor=con.cursor()"""将 修改用户 的的预编译 SQL语句 赋值给 sql"""sql="DELETE FROM t_user WHERE id=%s"cursor.execute(sql, [id])mit()except Exception as e:if "con" in dir():con.rollback()print(e)finally:if "con" in dir():con.close()"""查询用户id1、定义 search_userid() 方法，传入参数 username2、"""def search_userid(self, username):try:con = pool.get_connection()cursor = con.cursor()"""将 查询用户id 的的预编译 SQL语句 赋值给 sql"""sql = "SELECT id FROM t_user WHERE username=%s"cursor.execute(sql, [username])userid = cursor.fetchone()[0] # 因为根据用户名查询返回的用户id只有一条，所以这里使用的是 fetchone()return useridexcept Exception as e:print(e)finally:if "con" in dir():con.close()

❣️ 实现查询用户 id 功能 - “user_service.py” - 查询用户 id - search_userid() 方法

封装 “user_service.py” ，代码内容如下：重点新增了 “添加新闻” -第 70 行 - 第 77 行

# coding:utf-8from db.user_dao import UserDaoclass UserService:__user_dao=UserDao() # 实例化 UserDao() 对象 ---> __user_dao "私有变量""""定义登录方法1、login方法，传参 "username" 与 "password"2、调用 __user_dao 实例的 login 方法赋值给 "result"，并返回结果"""def login(self, username, password):result = self.__user_dao.login(username, password)return result"""定义查询用户身份方法1、search_user_role，传参 "username"2、调用 __user_dao 实例的 search_user_role 方法赋值给 "role"，并返回结果"""def search_user_role(self, username):role = self.__user_dao.search_user_role(username)return role"""添加用户记录1、定义 insert() 方法，传入参数 "username"、 "password"、 "email"、 "role_id"2、调用 __user_dao 实例的 insert() 方法"""def insert(self, username, password, email, role_id):self.__user_dao.insert(username, password, email, role_id)"""查询用户总页数1、定义 search_count_page() 方法2、调用 __user_dao 实例的 search_count_page() 方法"""def search_count_page(self):count_page = self.__user_dao.search_count_page()return count_page"""查询用户分页记录1、定义 search_list() 方法，传入参数 page2、调用 __user_dao 实例的 search_list 方法"""def search_list(self, page):result = self.__user_dao.search_list(page)return result"""修改用户信息1、定义 update() 方法，传入参数 id、 username、 password、 email、 role_id2、调用 __user_dao 实例的 update 方法"""def update(self, id, username, password, email, role_id):self.__user_dao.update(id, username, password, email, role_id)"""删除用户1、定义 delete_by_id() 方法，传入参数 id2、调用 __user_dao 实例的 delete_by_id 方法"""def delete_by_id(self, id):self.__user_dao.delete_by_id(id)"""查询用户 id1、定义 search_userid() 方法，传入参数 username2、调用 __user_dao 实例的 search_userid 方法"""def search_userid(self, username):userid = self.__user_dao.search_userid(username)return userid

❤️‍🔥 编写 “新闻编辑” 角色的业务 - “发表新闻” 流程

询问用户 “发表新闻” 的相关属性重点新增了 “添加新闻” -第 9 行 、第 18 行、第 62 行- 第 83 行

# coding:utf-8from colorama import Fore, Stylefrom getpass import getpass# 该模块的作用是遮挡输入的密码from service.user_service import UserServicefrom service.news_service import NewsServicefrom service.role_service import RoleServicefrom service.type_service import TypeServiceimport os # os 模块的作用是利用 "clear" 系统命令(win电脑 - "cls")，清空控制台的内容import sys # sys 模块的作用主要是利用 "exit()" 方法进行安全退出；(释放数据库连接、文件连接...之后退出)import time__user_service = UserService()# 实例化 UserService() 对象，赋值给私有变量 "__user_service"__news_service = NewsService()__role_service = RoleService()__type_service = TypeService()while 1:os.system("clear")# 清空控制台print(Fore.LIGHTBLUE_EX, "\n\t=========================") # "\n"：换行 ；"\t"：table，四个空格。print(Fore.LIGHTBLUE_EX, "\n\t欢迎使用新闻管理系统")print(Fore.LIGHTBLUE_EX, "\n\t=========================")print(Fore.LIGHTGREEN_EX, "\n\t1.登录系统")print(Fore.LIGHTGREEN_EX, "\n\t2.退出系统")print(Style.RESET_ALL) # 重置字体的颜色# opt = input("\n\t请输入操作编号：") # 将用户输入的内容 赋值给变量 optopt=input("\n\t输入操作编号:")"""对用户输入的交互内容进行校验1、输入 "1" ，进入 "登录系统"2、输入 "2" ，则退出系统"""if opt=="1": # 当用户输入 1，进行 登录系统username = input("\n\t用户名：")password = getpass("\n\t密码：") # 使用 getpass() 可以将输入的密码 隐去result = __user_service.login(username, password) # 调用 __user_service 的 login 方法，实现登录；赋值给 result"""针对登录成功用户进行身份校验1、为 True ，判断 登录用户 的身份，根据对应的身份，进入对应的身份层级的轮询2、为 False ，则 登录失败，返回 登录 层级的轮询"""if result == True:role = __user_service.search_user_role(username) # 调用 __user_service 的 search_user_role 方法，校验用户身份os.system("clear")"""判断登陆成功后的身份；"新闻编辑" 与 "管理员" 分别跳转各自对应的菜单层级 """while 1:os.system("clear") # 清空终端信息if role == "新闻编辑":print(Fore.LIGHTGREEN_EX, "\n\t1.发表新闻")print(Fore.LIGHTGREEN_EX, "\n\t2.编辑新闻")print(Fore.LIGHTRED_EX, "\n\tback.退出登录")print(Fore.LIGHTRED_EX, "\n\texit.退出系统 ")print(Style.RESET_ALL)opt = input("\n\t请输入操作编号：")"""[发表新闻] 需求的实现"""if opt=="1":os.system("clear")title=input("\n\t新闻标题:") # 定义新闻标题userid=__user_service.search_userid(username)# 查询用户 idresult=__type_service.search_list()# 获得所有新闻类型"""利用 for 循环获取所有的新闻类型"""for index in range(len(result)):one = result[index]print(Fore.LIGHTBLUE_EX, "\n\t%d.%s" % (index + 1, one[1]))print(Style.RESET_ALL)opt = input("\n\t类型编号:")type_id = result[int(opt) - 1][0]#TODO 新闻正文内容；正文牵扯到 MongoDB 数据库，这里先备注个 TODO，也顺便先将 content_id 的值固定为 100content_id=100is_top=input("\n\t置顶级别(0-5):")# 设置置顶级别is_commite=input("\n\t是否提交(Y/N):")# 询问是否保存if is_commite=="Y" or is_commite=="y":# 判断用户的输入__news_service.insert(title, userid, type_id, content_id, is_top)# 传入参数print("\n\t保存成功(3秒自动返回)")time.sleep(3)elif role == "管理员":print(Fore.LIGHTGREEN_EX, "\n\t1.新闻管理")print(Fore.LIGHTGREEN_EX, "\n\t2.用户管理")print(Fore.LIGHTRED_EX, "\n\tback.退出登录")print(Fore.LIGHTRED_EX, "\n\texit.退出系统 ")print(Style.RESET_ALL)opt = input("\n\t请输入操作编号：")"""根据登录用户键入的选项，执行对应的操作"""if opt == "1":"""选项 1 ：进入 "新闻管理" 三级菜单（轮询）"""while 1:os.system("clear") # 清空终端信息print(Fore.LIGHTGREEN_EX, "\n\t1.审批新闻") #print(Fore.LIGHTGREEN_EX, "\n\t2.删除新闻")print(Fore.LIGHTRED_EX, "\n\tback.返回上一层")print(Style.RESET_ALL)opt = input("\n\t输入操作编号:")# 根据输入的选项，执行对应的操作if opt=="1":"""选项 1 ：进入 "审批新闻" 四级菜单（轮询）"""page=1# 定义 page 变量，保存当前是 "第1页"# page 这个变量不能定义在 while 循环内，定义在 while 内，每一次轮询都会重置 pagewhile 1:os.system("clear") # 清空终端"""1、需要导入 service包 news_service模块 NewsService类，将其赋值给 私有变量 ---> __news_service 2、__news_service 私有变量 参考 第 14 行代码"""count_page=__news_service.search_unreview_count_page() # 调用查询"待审批新闻"总页数的方法result=__news_service.search_unreview_list(page) # 将第1页的结果集赋值给 result"""将结果集通过索引的形式进行一个 for 循环输出"""for index in range(len(result)):one=result[index]print(Fore.LIGHTBLUE_EX, "\n\t%d\t%s\t%s\t%s" %(index+1, one[1], one[2], one[3]))print(Fore.LIGHTBLUE_EX, "\n\t-------------------")print(Fore.LIGHTBLUE_EX, "\n\t%d/%d" %(page, count_page))print(Fore.LIGHTBLUE_EX, "\n\t-------------------")print(Fore.LIGHTRED_EX, "\n\tback.返回上一层")print(Fore.LIGHTRED_EX, "\n\tprev.上一页")print(Fore.LIGHTRED_EX, "\n\tnext.下一页")print(Style.RESET_ALL)opt = input("\n\t输入操作编号:")"""针对用户的输入进行 判断；"""if opt=="back":# 返回上一层breakelif opt=="prev" and page>1: # 向 "上一页" 翻页，前置条件不能为 "第一页"page-=1elif opt=="next" and page<count_page: # 向 "下一页" 翻页，前置条件不能为 "最后一页"page+=1elif int(opt) >= 1 and int(opt) <= 10:""" 1、这里的 opt 获取到输入的编号是 string 类型，需要先转成 int 类型2、因为每一页的新闻数量是十条，所以输入的取值范围是 大于等于1、小于等于103、在获取输入的记录时，这里获取的新闻的id并不是数据库中新闻记录的主键id4、传入的记录其实是显示在终端的待审批新闻的索引，所以我们需要将传入的记录换算为 "待审批新闻" 的索引位"""news_id = result[int(opt) - 1][0]__news_service.update_unreview_news(news_id)elif opt=="2":"""选项 2 ：进入 "删除新闻" 四级菜单（轮询）"""page = 1 # 定义 page 变量，保存当前是 "第1页"# page 这个变量不能定义在 while 循环内，定义在 while 内，每一次轮询都会重置 pagewhile 1:os.system("clear") # 清空终端"""1、需要导入 service包 news_service模块 NewsService类，将其赋值给 私有变量 ---> __news_service 2、__news_service 私有变量 参考 第 14 行代码"""count_page = __news_service.search_count_page() # 调用 "新闻总页数" 的方法result = __news_service.search_list(page) # 将查询 "新闻列表" 的结果集赋值给 result"""将结果集通过索引的形式进行一个 for 循环输出"""for index in range(len(result)):one = result[index]print(Fore.LIGHTBLUE_EX,"\n\t%d\t%s\t%s\t%s" % (index + 1, one[1], one[2], one[3]))print(Fore.LIGHTBLUE_EX, "\n\t-------------------")print(Fore.LIGHTBLUE_EX, "\n\t%d/%d" % (page, count_page))print(Fore.LIGHTBLUE_EX, "\n\t-------------------")print(Fore.LIGHTRED_EX, "\n\tback.返回上一层")print(Fore.LIGHTRED_EX, "\n\tprev.上一页")print(Fore.LIGHTRED_EX, "\n\tnext.下一页")print(Style.RESET_ALL)opt = input("\n\t输入操作编号:")"""针对用户的输入进行 判断；"""if opt == "back": # 返回上一层breakelif opt == "prev" and page > 1: # 向 "上一页" 翻页，前置条件不能为 "第一页"page -= 1elif opt == "next" and page < count_page: # 向 "下一页" 翻页，前置条件不能为 "最后一页"page += 1elif int(opt) >= 1 and int(opt) <= 10:""" 1、这里的 opt 获取到输入的编号是 string 类型，需要先转成 int 类型2、因为每一页的新闻数量是十条，所以输入的取值范围是 大于等于1、小于等于103、在获取输入的记录时，这里获取的新闻的id并不是数据库中新闻记录的主键id4、传入的记录其实是显示在终端的新闻记录的索引，所以我们需要将传入的记录换算为 "新闻记录" 的索引位"""news_id = result[int(opt)-1][0]__news_service.delete_by_id(news_id)elif opt == "back":breakelif opt == "2":"""选项 2 ：进入 "用户管理" 三级菜单（轮询）"""while True:os.system("clear")print(Fore.LIGHTGREEN_EX, "\n\t1.添加用户")print(Fore.LIGHTGREEN_EX, "\n\t2.修改用户")print(Fore.LIGHTGREEN_EX, "\n\t3.删除用户")print(Fore.LIGHTRED_EX, "\n\tback.返回上一层")print(Style.RESET_ALL)opt = input("\n\t输入操作编号:")if opt=="back":breakelif opt=="1":"""选项 1 ：进入 "添加用户" 四级菜单（轮询）"""os.system("clear")username=input("\n\t用户名:")password = getpass("\n\t密码:") # getpass() 遮挡输入的密码repassword=getpass("\n\t重复密码:")# 密码需要输入两次，且需要针对两次密码进行相等判断if password!=repassword: # 两次密码不一致，进入下一次的轮询print("\n\t两次密码不一致(3秒自动返回)")time.sleep(3)continueemail=input("\n\t邮箱:")result=__role_service.search_list()# 向控制台输出已有的角色列表# 此处需要导入 service包 role_service模块 的 RoleService类# 参考 第 8 行 与 第 16 行 代码for index in range(len(result)): # 循环输出 "角色列表" 的结果集one=result[index]print(Fore.LIGHTBLUE_EX, "\n\t%d.%s" %(index+1, one[1]))print(Style.RESET_ALL)opt=input("\n\t角色编号:")# 根据输入的内容，将其换算为 "角色编号"role_id=result[int(opt)-1][0]__user_service.insert(username, password, email, role_id)print("\n\t保存成功(3秒自动返回)")time.sleep(3)elif opt=="2":page = 1while True:os.system("clear")count_page = __user_service.search_count_page()result = __user_service.search_list(page)for index in range(len(result)):one = result[index]print(Fore.LIGHTBLUE_EX,"\n\t%d\t%s\t%s" % (index + 1, one[1], one[2]))print(Fore.LIGHTBLUE_EX, "\n\t-------------------")print(Fore.LIGHTBLUE_EX, "\n\t%d/%d" % (page, count_page))print(Fore.LIGHTBLUE_EX, "\n\t-------------------")print(Fore.LIGHTRED_EX, "\n\tback.返回上一层")print(Fore.LIGHTRED_EX, "\n\tprev.上一页")print(Fore.LIGHTRED_EX, "\n\tnext.下一页")print(Style.RESET_ALL)opt = input("\n\t输入操作编号:")if opt == "back":breakelif opt == "prev" and page > 1:page -= 1elif opt == "next" and page < count_page:page += 1elif int(opt) >= 1 and int(opt) <= 10:""" 1、这里的 opt 获取到输入的编号是 string 类型，需要先转成 int 类型2、因为每一页的用户数量是十条，所以输入的取值范围是 大于等于1、小于等于103、在获取输入的记录时，这里获取的用户的id并不是数据库中新闻记录的主键id4、传入的记录其实是显示在终端的用户记录的索引，所以我们需要将传入的记录换算为 "用户记录" 的索引位"""os.system("clear")user_id=result[int(opt)-1][0] # 获取终端显示的用户记录索引对应的用户idusername = input("\n\t新用户名:")password = getpass("\n\t新密码:")repassword = getpass("\n\t再次输入密码:")if password!=repassword:print(Fore.LIGHTRED_EX, "\n\t两次密码不一致(3秒自动返回)")print(Style.RESET_ALL)time.sleep(3)breakemail = input("\n\t新邮箱:")result = __role_service.search_list()for index in range(len(result)): # 循环输出 "角色列表" 的结果集one = result[index]print(Fore.LIGHTBLUE_EX, "\n\t%d.%s" % (index + 1, one[1]))print(Style.RESET_ALL)opt = input("\n\t角色编号:")role_id = result[int(opt) - 1][0]opt=input("\n\t是否保存(Y/N)")if opt=="Y" or opt=="y":__user_service.update(user_id, username, password, email, role_id)print("\n\t保存成功(3秒自动返回)")time.sleep(3)elif opt=="3":page = 1while True:os.system("clear")count_page = __user_service.search_count_page()result = __user_service.search_list(page)for index in range(len(result)):one = result[index]print(Fore.LIGHTBLUE_EX,"\n\t%d\t%s\t%s" % (index + 1, one[1], one[2]))print(Fore.LIGHTBLUE_EX, "\n\t-------------------")print(Fore.LIGHTBLUE_EX, "\n\t%d/%d" % (page, count_page))print(Fore.LIGHTBLUE_EX, "\n\t-------------------")print(Fore.LIGHTRED_EX, "\n\tback.返回上一层")print(Fore.LIGHTRED_EX, "\n\tprev.上一页")print(Fore.LIGHTRED_EX, "\n\tnext.下一页")print(Style.RESET_ALL)opt = input("\n\t输入操作编号:")if opt == "back":breakelif opt == "prev" and page > 1:page -= 1elif opt == "next" and page < count_page:page += 1elif int(opt) >= 1 and int(opt) <= 10:""" 1、这里的 opt 获取到输入的编号是 string 类型，需要先转成 int 类型2、因为每一页的用户数量是十条，所以输入的取值范围是 大于等于1、小于等于103、在获取输入的记录时，这里获取的用户的id并不是数据库中新闻记录的主键id4、传入的记录其实是显示在终端的用户记录的索引，所以我们需要将传入的记录换算为 "用户记录" 的索引位"""os.system("clear")user_id=result[int(opt)-1][0]__user_service.delete_by_id(user_id)print("\n\t删除成功(3秒自动返回)")time.sleep(3)elif opt == "back": # 返回上一级层级菜单breakelif opt == "exit": # 安全退出sys.exit(0)else:print("\n\t*****登录失败...3秒后自动返回！*****")time.sleep(3)elif opt=="2":sys.exit(0)# 安全退出 ---> 利用 "exit()" 方法安全退出；(释放数据库连接、文件连接...之后退出)