node+koa2+mongod构建项目及与express对比

var router = require(‘koa-router‘)()
var mongoose = require(‘mongoose‘);
var Goods = require(‘../models/goods‘);
 
 
//连接MongoDB数据库
mongoose.connect(‘mongodb://quan:123456@127.0.0.1:27017/material‘,{useMongoClient:true});
 
mongoose.connection.on("connected", function () {
  console.log("MongoDB connected success.")
});
 
mongoose.connection.on("error", function () {
  console.log("MongoDB connected fail.")
});
 
mongoose.connection.on("disconnected", function () {
  console.log("MongoDB connected disconnected.")
});
 
 
router.post("/addPv", async (ctx, next) =>  {  //post请求
//   console.log(ctx.request.body)
//  console.log(ctx.request.body.id)
  let id = ctx.request.body.id  //获取前端接口传参
  var conditions = {id: id};
  var updates = {};
 
 
  const res = await Goods.find(conditions).catch(err => ctx.throw(500, ‘服务器内部错误‘))  //数据库查找
  console.log(res)
    if (res) {
      // console.log(res[0].pv+1);
      if(ctx.request.body.cmd == 1001) { //1001 pv; 1002 click
 
        updates = {$set: {pv: res[0].pv+1, ctr:res[0].click/(res[0].pv+1)}};
      } else if(ctx.request.body.cmd == 1002) {
 
        updates = {$set: {click: res[0].click+1, ctr:(res[0].click+1)/(res[0].pv)}};
      }
       
 
      const up = await Goods.update(conditions, updates).catch(err => ctx.throw(500, ‘服务器内部错误‘))  //数据库更新数据
      console.log(up)
      if (up) {
        ctx.response.body = "更新成功"  //传给前端接口返回的值
      } else {
        ctx.response.body = "更新失败" 
      }    
    }
   
});
 
module.exports = router;

/**
 * 在app.use(router)之前调用
 */
var response_formatter = async (ctx, next) => {
    //先去执行路由
    await next();
 
 
    //如果有返回数据，将返回数据添加到data中
    if (ctx.body) {
        ctx.body = {
            code: 0,
            message: ‘success‘,
            data: ctx.body
        }
    } else {
        ctx.body = {
            code: 0,
            message: ‘success‘
        }
    }
}
 
module.exports = response_formatter;

const response_formatter = require(‘./middlewares/response_formatter‘);
 
 
//添加格式化处理响应结果的中间件，在添加路由之前调用
app.use(response_formatter);

router.post("/addPv", function (req,res,next) {
 console.log(req.body.id)
  let id = req.body.id  //获取前端传参
  var conditions = {id: id};
  var updates = {};
  // let obj = new Goods({url:"http://test-static.qukan.aimodou.net/wlx/image/2018/09/21/5ba4e9518093d.png",click:20,pv:1000,ctr:"2%",dtus:"2282",id:"7"})
  // obj.save((err,res) => { })
 
 
  Goods.find(conditions, (err,doc1) => {  // 在查询回调里处理更新数据库
    if (err) {
      console.log(err);
    } else {
      // console.log(doc1[0].pv+1);
      if(req.body.cmd == 1001) { //1001 pv; 1002 click
 
        updates = {$set: {pv: doc1[0].pv+1, ctr:doc1[0].click/(doc1[0].pv+1)}};
      } else if(req.body.cmd == 1002) {
 
        updates = {$set: {click: doc1[0].click+1, ctr:(doc1[0].click+1)/(doc1[0].pv)}};
      }
       
 
      Goods.update(conditions, updates, function (err,doc) {  // 在更新回调里处理接口返回
        console.log(err,doc)
          if (err) {
              console.error(err);
              res.json({  //接口返回处理跟koa2不同，koa2是 ctx.response.body = ‘‘
                status:‘-1‘,
                msg:err.message
              });
          } else {
              console.error("更新成功")
              res.json({
                status:‘0‘,
                msg:‘ok‘,
            });
          }
      });
    }
  })
   
});

var express = require(‘express‘);
var goods = require(‘./routes/goods‘)
 
var app = express();
app.use(‘/goods‘, goods);