一、接口功能

1、接收接口返回参数

koa项目接口的制作，使用的是router的请求功能进行判断。
如下，我们的接口文件user.js

  1.  const Router = require('koa-router')
  2.  const router = new Router()
  4.  // 引入user模板
  5.  const User = require('../../modules/User')
  7.  /** *
  8.   * @route GET api/users/test
  9.   * @desc 测试接口地址
  10.   * @access 接口公开
  11.   * **/
  12.  router.get('/test',async ctx => {
  13.    ctx.status = 200
  14.    ctx.body = {msg: 'users works...'}
  15.  })
  17.  router.get('/test2',async ctx => {
  18.   ctx.status = 200
  19.   ctx.body = {
  20.     code: 200,
  21.     data: {
  22.       name: '李大宝',
  23.       sex: '男',
  24.       profession: '医生'
  25.     }
  26.   }
  27. })
  29.  module.exports = router.routes()

在入口文件中，我们需要将接口文件安装上。

  1. const Router = require('koa-router')
  2. const router = new Router()
  3. const users = require('./routes/api/users')
  4. // 通过这个配置，我们可以得到user.js文件中两个接口，分别是/api/users/test,/api/users/test2
  5. router.use('/api/users', users)

在postman中，我们请求一下接口，如图：
image.png

2、接口获取前端传递的参数

解析前端参数需要用到插件：koa-bodyparser // npm install koa-bodyparser —save

在入口文件app.js中使用koa-bodyparser

  1. var Koa = require('koa')
  2. var bodyParser = require('koa-bodyparser')
  4. var app = new Koa()
  6. // 注意！使用bodyParser()一定要在使用router中间件之前，否则获取的body为undefined
  7. app.use(bodyParser())

在接口文件user.js中，查看接口请求参数：

  1. // 在user.js接口中添加一个register接口如下
  2. router.get('/register',async ctx => {
  3.   console.log(ctx.request.body)
  4. })

postman如下：（Not Found是因为我们接口没有设置返回数据）
image.png

查看控制台，输出如下：
image.png

3、接口将获取到的前端参数存入数据库

我们有如下信息要存储入数据库：
{
name: ‘李大宝’,
sex: ‘男’,
phone: ‘17718511566’
}

在存储之前，我们需要先查询是否已经有个这个手机号（作为唯一标识），如果没有，则将数据存入数据库（我们用的mongoDB数据库）

①先查询数据是否已存储

在users.js文件中，我们引入模板数据（module中的User.js）

  1. const User = require('../../modules/User')
  1. 然后查询：
  1. router.post('/register', async ctx => {
  2.     const result =  await User.find({phone: ctx.request.body.phone})
  3.     console.log(result) //  result是一个数组
  4.  })

为了证明这个方法是好用的，我们现在mongoCompass中手动加入了一组数据：
{ “name”: “马桂芬”,
“sex”: “女”,
“phone”: “18201170363”
}

image.png

数据加入后，会自动生成oid：
image.png

接下来我们在postman中查一下马桂芬的手机号，控制台会输出马桂芬的信息如图：
image.png

  1. 如果输入一个数据库不存在的手机号，则数组为空，所以我们可以根据数据的长度去判断该user的数据是否已存在。

②数据存储

代码如下：

  1.  router.post('/register', async ctx => {
  2.     const result =  await User.find({phone: ctx.request.body.phone})
  3.     if(result.length) {
  4.       ctx.status = 200
  5.       ctx.body = {
  6.         code: 500,
  7.         msg: '该用户已存在'
  8.       }
  9.     } else {
  10.       const { name, sex, phone} = ctx.request.body
  11.       const newUser = new User({
  12.         name,
  13.         sex,
  14.         phone
  15.       })
  16.       // 存储数据库
  17.       await newUser.save().then(user => {
  18.         ctx.body = user
  19.       }).catch(err => {
  20.         console.log(err)
  21.       })
  23.       // 返回json数据
  24.       ctx.body = newUser
  25.     }
  26.   })

postman发送数据后，去查看mongocompass:
image.png

我们看到李大宝的数据已经添加到数据库了。
mongo数据库的操作非常简单，以json数据形式存储，代码层面来说，操作起来非常简单！

③明文加密

在存储信息时候，很多特殊数据（比如密码）为了安全性，我们需要对数据进行加密存储，最常见的有md5加密。

插件：bcrypt.js // npm install bcryptjs —save

使用方法：
全部users.js接口文件如下：

**bcrypt.genSalt()这个方法本身就是异步方法

  1.  const Router = require('koa-router')
  2.  const router = new Router()
  3.  const bodyParser = require('koa-bodyparser')
  4.  const bcrypt = require('bcryptjs')
  6.  // 引入user模板
  7.  const User = require('../../modules/User')
  9.  /** *
  10.   * @route GET api/users/test
  11.   * @desc 测试接口地址
  12.   * @access 接口公开
  13.   * **/
  14.  router.get('/test',async ctx => {
  15.    ctx.status = 200
  16.    ctx.body = {msg: 'users works...'}
  17.  })
  20.  /** *
  21.   * @route GET api/users/register
  22.   * @desc 测试接口地址
  23.   * @access 接口公开
  24.   * **/
  26.   router.post('/register', async ctx => {
  27.     const result =  await User.find({phone: ctx.request.body.phone})
  28.     if(result.length) {
  29.       ctx.status = 200
  30.       ctx.body = {
  31.         code: 500,
  32.         msg: '该用户已存在'
  33.       }
  34.     } else {
  35.       const { name, sex, phone, password} = ctx.request.body
  36.       let newUser = new User({
  37.         name,
  38.         sex,
  39.         phone
  40.       })
  42.       // 对password加密存储
  43.       //直接await不起作用用promise做包裹，将异步变为同步
  44.       /**await new Promise(function (resolve, reject) {
  45.         bcrypt.genSalt(10, (err, salt) => {
  46.           bcrypt.hash(password, salt, (err, hash) => {
  47.             if (err) {
  48.               reject(err)
  49.             }
  50.             newUser.password = hash
  51.             resolve(newUser)
  52.           })
  53.         })
  54.       })**/
  56.       // 采用crypto提供的同步方法，更加优雅方便
  57.       const salt = bcrypt.genSaltSync(10)
  58.       const hash = bcrypt.hashSync(password, salt)
  59.       newUser.password = hash
  61.       await newUser.save().then(user => {
  62.         console.log('数据添加成功')
  63.        }).catch(err => {
  64.          console.log(err)
  65.          if(err) {throw err}
  66.        })
  68.       // 返回json数据
  69.       ctx.body = {
  70.         code: 200,
  71.         msg: '数据添加成功',
  72.         data: newUser
  73.       }
  74.     }
  75.   })
  77.  module.exports = router.routes()

④加密方法抽离

在config下简历tools.js文件

  1. const bcrypt = require('bcryptjs')
  3. const tools = {
  4.   enbcrypt(password) {
  5.     const salt = bcrypt.genSaltSync(10)
  6.     const hash = bcrypt.hashSync(password, salt)
  7.     return hash
  8.   }
  9. }
  11. module.exports = tools

在需要使用的文件中共引入：

  1. const tools = require('../../config/tools')
  2. const password = tools.enbcrypt(password)