复习 – node.js（接口案例）

// 1.初始化 // 1.1创建项目 const express = require('express') const app = express() // 1.2配置跨域 const cors = require('cors') app.use(cors()) // 1.3配置解析表单中间件 // 错误点：记住要有参数 app.use(express.urlencoded({extended : false}))  // 2.3因为后面处理函数用到了很多res.send所以封装为一个全局中间件，给res绑定一个函数，那后面的中间件路由都可以用到这个函数了 app.use((req, res, next) => {     res.cc = function(err, status = 1) {         res.send({             status,             msg : err instanceof Error ? err.message : err         })     }     next() })  // 2.4.6配置解析token的中间件 const expressJWT = require('express-jwt') const secretKey = require('./secretKey') app.use(expressJWT({secret : secretKey.secretKey, algorithms : ['HS256']}).unless({path : [/^/api//]}))  // 1.4.4导入路由模块 const routerUser = require('./router/user') const Joi = require('joi') const { expressjwt } = require('express-jwt') const { path } = require('express/lib/application') app.use('/api', routerUser) // 3.1.1个人中心路由导入 const infoRouter = require('./router/userinfo') app.use('/my', infoRouter)  // 4.1.2文章管理导入 const article = require('./router/acticle') app.use('/my/article', article)  // 5.1.2发布文章路由导入 const cates = require('./router/cate') app.use('/my/article', cates)  // 2.2.3定义规则joi的错误级别中间件 app.use((err, req, res, next) => {     if (err instanceof Joi.ValidationError) return res.send(err.message)     // 2.4.7增加jwt错误中间件     if (err.name == 'UnauthorizedError') return res.cc('身份认证失败')     return res.send('其他错误') })   app.listen(80, () => {     console.log('http://127.0.0.1'); })

// 1.4初始化路由相关文件夹 不光要给路由分装一个模块 里面的处理函数也要有一个模块 const express = require('express') const { append } = require('express/lib/response') const router = express.Router() // 1.4.2导入路由处理函数 const routerHandler = require('../router_handler/user')  // 注册 // 2.2.2导入joi验证输入进来的是否合法 const expressJOI = require('@escook/express-joi') const {schema_user_info} = require('../schema/user') router.post('/reguser',expressJOI(schema_user_info), routerHandler.getReguser)  // 2.4登录 // 2.4.1添加语法规则，可以直接用注册的 router.post('/login',expressJOI(schema_user_info), routerHandler.getLogin)  module.exports = router

// 1.4.1初始化路由处理函数模块  //注册 const db = require('../mysql') //导入密码加密解密包 const bcrypt = require('bcryptjs') function getReguser(req, res) {     // res.send('这里是注册模块')     // 2.2.4检测用户名是否被占用 导入mysql     let selectUser = 'select * from users where username = ?'     db.query(selectUser, req.body.username, (err, results) => {         // 2.3.1用到我们前面定义的全局中间件优化res.send         if (err) return res.cc(err)         if (results.length == 1) return res.cc('用户名已被占用')         // 2.2.5如果过了前两关的验证 基本可以验证成功了 就先对密码进行加密处理安装bcryptjs         req.body.password = bcrypt.hashSync(req.body.password, 10)         // console.log(req.body.password);         // 2.2.6插入新用户         let insertUser = 'insert into users set ?'         // -------------注意一下这里插入数据库的参数怎么写的         db.query(insertUser, [{username : req.body.username, password : req.body.password}], (err, results) => {             if (err) return res.cc(err)             if (results.affectedRows !== 1) return res.cc('注册失败')             res.cc('注册成功',0)         })     }) }  //登录 // 2.4.4.1导入jwt const jwt = require('jsonwebtoken') const secretKey = require('../secretKey') const { result } = require('@hapi/joi/lib/base') function getLogin(req, res) {     // res.send('这里是登录模块')     // 2.4.2根据用户名查询用户的数据     let selectLoginuser = 'select * from users where username = ?'     db.query(selectLoginuser, req.body.username, (err, results) => {         if (err) res.cc(err)         if (results.length !== 1) res.cc('未找到该用户')         // 2.4.3有数据就去判断密码是否正确         // console.log(results);         if (!bcrypt.compareSync(req.body.password, results[0].password)) return res.cc('密码错误')         // 2.4.4用户名有，密码 也对上了说明登陆成功，开始jwt身份认证         // 先剔除密码和头像的值         let user = {...results[0], password : '', user_pic: '',algorithms : ['HS256']}         let userToken = jwt.sign(user, secretKey.secretKey, {expiresIn : '1h'})         // 2.4.5向客户端发送token         res.send({             status : 0,              msg : '登录成功',             token : 'Bearer ' + userToken         })     }) }  // 获取用户基本信息 function getInfo(req,res) {     // res.send('个人中心')     // 3.1.2获取用户基本信息     let selectInfo = 'select id,username,nickname,email,user_pic from users where id = ?'     db.query(selectInfo, req.user.id, (err, results) => {         if (err) return res.cc(err)         if (results.length !== 1) return res.cc('获取信息失败')         res.send({             status : 0,             msg : '获取信息成功',             data : results[0]         })     }) }  // 3.2更新用户信息 function updateInfo(req, res) {     // res.send('更新用户信息')     // 3.2.4更新用户功能     let updateInfo = 'update users set ? where id = ?'     db.query(updateInfo, [req.body, req.user.id], (err, results) => {         if (err) return res.cc(err)         if (results.affectedRows !== 1) return res.cc('更新信息失败')         res.cc('更新信息成功', 0)     }) }  // 3.3重置密码 function updatePwd(req, res) {     // res.send('重置密码')     // 3.3.2查询用户是否存在     let selectExist = 'select * from users where id = ?'     db.query(selectExist, req.user.id, (err, results) => {         if (err) return res.cc(err)         if (results.length !== 1) return res.cc('用户不存在')         // 3.3.3前面那一步虽然无所谓但这一步必须的 判断输入的旧密码是否正确         if(!bcrypt.compareSync(req.body.oldPwd, results[0].password)) return res.cc('输入密码错误')         // 3.3.4对新密码加密后更新到数据库         let password = bcrypt.hashSync(req.body.newPwd)         let updatePwd = 'update users set password =? where id =?'         db.query(updatePwd, [password,req.user.id], (err, results) => {             if (err) return res.cc(err)             if (results.affectedRows !== 1) return res.cc('修改密码失败')             res.cc('更新密码成功', 0)         })     }) }   // 3.4更换头像 function updateAvatar(req, res) {     // res.send('更换头像')     // 3.4.3     let updateAvatar = 'update users set user_pic = ? where id = ?'     db.query(updateAvatar, [req.body.avatar, req.user.id], (err, results) => {         if (err) return res.cc(err)         if (results.affectedRows !== 1) return res.cc('更新头像失败')         res.cc('更新头像成功', 0)     }) } module.exports = {     getLogin,     getReguser,     getInfo,     updateInfo,     updatePwd,     updateAvatar }

// 2.登录注册 // 2.1建好数据库后配置数据库 const { result } = require('@hapi/joi/lib/base') const mysql = require('mysql') const db = mysql.createPool({     host : '127.0.0.1',     user : 'root',     password : 'admin123',     database : 'mydb' })  // 测试 /* db.query('select 1' , (err, results) => {     if(err) return console.log(err.message);     return console.log(results); }) */  module.exports = db

const express = require('express') const router = express.Router() const routerHandler = require('../router_handler/user') // 3.个人中心 // 3.1获取用户基本信息 router.get('/userinfo', routerHandler.getInfo)   // 3.2.1更新用户信息 // 3.2.3添加验证规则 const expressJoi = require('@escook/express-joi') const {schema_update_info, schema_update_avatar} = require('../schema/user') router.post('/userinfo',expressJoi(schema_update_info),routerHandler.updateInfo)  // 3.3.1重置密码 const {schema_update_pwd} = require('../schema/user') router.post('/updatepwd',expressJoi(schema_update_pwd), routerHandler.updatePwd)  // 3.4.1更换头像 const {schema_updatee_avatar} = require('../schema/user') router.post('/update/avatar',expressJoi(schema_updatee_avatar), routerHandler.updateAvatar)  module.exports = router

module.exports = {     secretKey : 'sdfafsfds' }

// 2.2注册 // 2.2.1对表单数据验证，这里就不if else了直接用上joi来验证 joi要下最新版而且直接导入joi const { number } = require('joi') const joi = require('joi')  const username = joi.string().alphanum().min(1).max(10).required() // 错误点：正则｛｝里面的量词之间不能以空格隔开 const password = joi.string().pattern(/^[S]{6,12}$/).required()  // 3.2.2更新用户信息规则 const id = joi.number().integer().min(1).required() const nickname = joi.string().required() const email = joi.string().email().required()  // 3.4.2更换头像规则 const avatar = joi.string().dataUri().required() module.exports.schema_user_info = {     body : {         username,         password     } }  module.exports.schema_update_info = {     body : {         id,         nickname,         email     } }  module.exports.schema_update_pwd = {     // 3.3.2重置密码规则     body : {         oldPwd : password,         // --------------错误点这里就算是变量也要添加引号         newPwd : joi.not(joi.ref('oldPwd')).concat(password)     } }  module.exports.schema_updatee_avatar = {     body : {         avatar     } }

// 4.1.1文章分类列表函数 const { result } = require('@hapi/joi/lib/base') const db = require('../mysql') function getArticleList(req, res) {     // res.send('文章分类列表')     // 4.1.3获取文章数据     let selectArticleList = 'select * from article where is_delete = 0'     db.query(selectArticleList, (err, results) => {         if (err) return res.cc(err)         res.send({             status : 0,             msg : '获取文章分类列表成功',             data : results         })     }) }  // 4.2.1新增文章分类 function addCates(req,res) {     // 4.2.3名字与别名是否重名     let selectDuplicate = 'select * from article where name = ? or alias = ?'     db.query(selectDuplicate, [req.body.name, req.body.alias], (err, results) => {         if(err) return res.cc(err)         if(results.length == 2) return res.cc('文章名字和别名已被占用')         if(results.length == 1 && results[0].name == req.body.name && results[0].alias == req.body.alias) return res.cc('文章名字和别名已被占用')         if(results.length == 1 && results[0].name == req.body.name) return res.cc('文章名字被占用')         if(results.length == 1 && results[0].alias == req.body.alias) return res.cc('文章别名被占用')         // 4.2.4实现文章分类新增         let addArt = 'insert into article set ?'         db.query(addArt, req.body, (err, results) => {             if(err) return res.cc(err)             if (results.affectedRows !== 1) return res.cc('新增文章失败')             res.cc('新增文章分类成功', 0)         })     }) }  // 4.3.1根据idshanchuwenzhan function deleteCate(req, res) {     // 4.3.3实现删除功能     let deleteId = 'update article set is_delete = 1 where id = ?'     db.query(deleteId, req.params.id, (err, results) => {         if (err) return res.cc(err)         if (results.affectedRows !== 1) return res.cc('删除文章失败')         res.cc('删除文章分类成功', 0)     }) }  // 4.4.1根据id获取文章分类 function requireArt(req,res) {     // 4.4.2     let selectArt = 'select * from article where id = ?'     db.query(selectArt, req.params.id, (err, results) => {         if (err) return res.cc(err)         if (results.length !== 1 || results[0].is_delete == 1) return res.cc('没有该文章')         res.send({             status : 0,             msg : '获取文章分类数据成功',             data : results[0]         })     }) }  // 4.5.1根据id更新文章 function updateArt(req, res) {     // 4.5.2查看是否重名     // -----------------这里需要先将自己这一项排除出来     let selectIdDuplicate = 'select * from article where id != ? and (name = ? or alias = ?)'     db.query(selectIdDuplicate, [req.body.id, req.body.name, req.body.alias], (err, results) => {         if (err) return res.cc(err)         if (results.length == 2) return res.cc('文章名称和别名已被占用')         if (results.length == 1 && results[0].name == req.body.name && results[0].alias == req.body.alias) return res.cc('文章名称和别名已被占用')         if (results.length == 1 && results[0].name == req.body.name) return res.cc('文章名称已被占用')         if (results.length == 1 && results[0].alias == req.body.alias) return res.cc('别名已被占用')         let updateIdArt = 'update article set ? where id = ?'         db.query(updateIdArt, [req.body, req.body.id] , (err,results) => {             if (err) return res.cc(err)             if (results.affectedRows !== 1) return res.cc('文章更新失败')             res.cc('更新分类信息成功', 0)         })     }) } module.exports = {     getArticleList,     addCates,     deleteCate,     requireArt,     updateArt }

// 4.文章类别管理 const express = require('express') const router = express.Router() const routerhanlder = require('../router_handler/article') // 4.1获取文章分类列表 router.get('/cates',routerhanlder.getArticleList)  // 4.2新增文章分类 const expressJoi = require('@escook/express-joi') const {add_article_list, update_id_cate} =require('../schema/article') router.post('/addcates',expressJoi(add_article_list),routerhanlder.addCates)  // 4.3根据id删除文章 const {delete_id_cate} = require('../schema/article') router.get('/deletecate/:id',expressJoi(delete_id_cate),routerhanlder.deleteCate)  // 4.4根据id获取文章分类数据 router.get('/cates/:id',expressJoi(delete_id_cate), routerhanlder.requireArt)  // 4.5根据id更新文章分类数据 const {update_id_Art} = require('../schema/article') router.post('/updatecate',expressJoi(update_id_Art) ,routerhanlder.updateArt)  module.exports = router

const joi = require('joi')  // 4.2.2新增文章规则 const name = joi.string().required() const alias = joi.string().alphanum().required()  // 4.3.2根据id删除文章 注意这个id是动态的而且是get请求，所以不再是body数据 const id = joi.number().integer().min(1).required() module.exports.add_article_list = {     body : {         name,         alias     } }  module.exports.delete_id_cate = {     params : {         id     } }  module.exports.update_id_Art = {     body : {         id : id,         name : name,         alias : alias     } }

// 5.1.1发布文章函数 const path = require('path') const db = require('../mysql') function addCate(req, res) {     // 5.1.5因为上传表单无法用joi所以要单独规定     if (!req.file || req.file.fieldname !== 'cover_img') return res.cc('请上传图片')     // 5.1.6事先发布文章功能     const cateObj = {         ...req.body,         cover_img : path.join('/uploads', req.file.filename),         pub_date : new Date(),         author_id : req.user.id     }     let addInsert = 'insert into articles set ?'     db.query(addInsert,  cateObj, (err, results) => {         if (err) return res.cc(err)         if (results.affectedRows !== 1) return res.cc('发布文章失败')         res.cc('发布文章成功', 0)     })      }   module.exports = {     addCate }