教你用Koa发送手机验证码实现注册登录

function ajaxs(callback){
    $.get('a.html',function(dataa) {
        console.log(dataa);
        $.get('b.html',function(datab) {
            console.log(datab);
            $.get('c.html',function(datac) {
                console.log(datac);
            	callback();
            });
        });
    });
}

ajaxs(function(){
    console.log('OK');
});

function request(url) {
  $.get(url, function(response){
    console.log(response);
    it.next(response);
  });
}
function* ajaxs() {
    yield request('a.html');
    yield request('b.html');
    yield request('c.html');
    return console.log('OK');
}
let it = ajaxs();
it.next();

async function request(url) {
  await $.get(url, function(response){
    console.log(response);
  });
}
async function ajaxs() {
    await request('a.html');
    await request('b.html');
    await request('c.html');
    console.log('OK');
}
ajaxs();

'use strict'

/**
 *  mongoose Node连接MongoDB数据库
 *  bluebird 功能全面的Promise库
 *  koa web框架核心库
 *  koa-router 路由中间件
 *  koa-logger 打印日志中间件
 *  koa-session session中间件
 *  koa-bodyparser body解析器（如：POST请求传参）
 *  
 *  speakeasy 验证码生成器
 *  xss  防止xss攻击
 *  uuid 唯一识别码token
 *  sms  发送螺丝帽短信工具
 *
 **/

//引入node读取文件和路径库
const fs = require('fs')
const path = require('path')

//引入mongoose，配置MongoDB数据库
const mongoose = require('mongoose')
const url = 'mongodb://localhost/xjs'

//mongoose默认的promise库已过时
mongoose.Promise = require('bluebird')

//创建数据库连接
//方法1
//const db = mongoose.createConnection('localhost', 'xjs');
//方法2
mongoose.connect(url);
const db = mongoose.connection;


//监听数据库连接状态
db.on('error', ctx => console.log('连接异常:' + ctx))
db.on('connected', ctx => console.log('连接成功'))
db.on('disconnected', ctx => console.log('连接断开'))

//当前models路径
const models_path = path.join(__dirname, '/app/models')

//循环读取models
const walk = function(modelPath) {
  fs
    .readdirSync(modelPath)
    .forEach(function(file) {
      let filePath = path.join(modelPath, '/' + file)
      let stat = fs.statSync(filePath)
      console.log(filePath);
      if (stat.isFile()) {
        if (/(.*)\.(js|coffee)/.test(file)) {
          require(filePath)
        }
      } else if (stat.isDirectory()) {
        walk(filePath)
      }
    })
}

//执行
walk(models_path)

//引入Koa框架
const Koa = require('koa')
const logger = require('koa-logger')
const session = require('koa-session')
const bodyParser = require('koa-bodyparser')

//实例化koa
const app = new Koa()

//使用中间件
//引入koa-logger,支持日志打印
app.use(logger())

//引入koa-bodyparser，支持body为json、form、text格式
app.use(bodyParser())

//引入session,设置自定义的cookie名，默认是koa.sid
app.keys = ['xjs']
app.use(session(app))

//引入koa-router配置路由
const router = require('./config/routes')()
app.use(router.routes()).use(router.allowedMethods())


//监听端口3001
app.listen(3001)
console.log('Listening:3001')

'use strict'
//引入koa-router中间件
const Router = require('koa-router')

//引入业务层
const User = require('../app/controllers/user')
const App = require('../app/controllers/app')

//导出一个匿名方法在配置koa时调用(app.js)
module.exports = function() {
	//实例化一个router，并声明前缀
	let router = new Router({
		prefix: '/api'
	});
	//用户请求 中间件依次执行
	router.post('/user/signup', App.hasBody, User.signup);
	router.post('/user/verify', App.hasBody, User.verify);
	router.post('/user/update', App.hasBody, App.hasToken, User.update);

	//公用请求或工具请求，如：加密，校验accessToken
	router.get('/app/jm', App.jm);

	//TODO
	return router;
}

'use strict'
//引入mongoose
const mongoose = require('mongoose')

//定义表结构
const UserSchema = new mongoose.Schema({
	number: { //手机号
		unique: true,
		type: String
	},
	code: String, //验证码
	accessToken: String, //用户唯一标识
	nickname: String, //昵称
	avatar: String, //头像
	verified: { //是否验证过
		type: Boolean,
		default: false
	},
	meta: {
		createAt: { //创建时间
			type: Date,
			default: Date.now()
		},
		updateAt: { //更新时间
			type: Date,
			default: Date.now()
		}
	}
})

//定义添加数据的拦截器
UserSchema.pre('save', function(next) {
	if (!this.isNew) { //老数据
		this.meta.updateAt = Date.now()
	}
	next()
})

//导出用户Model
module.exports = mongoose.model('User', UserSchema)

const mongoose = require('mongoose')
const User = mongoose.model('User')

//引入mongoose
const mongoose = require('mongoose')

//引入用户Model
const User = mongoose.model('User')

//导出加密方法 暂未写
exports.jm = ctx => {
	console.log(ctx);
	console.log(ctx.method);
	ctx.body = '加密';
}

//导出是否缺少参数方法
exports.hasBody = async(ctx, next) => {
	let body = ctx.request.body || {}
	if (Object.keys(body).length === 0) {
		ctx.body = {
			success: false,
			msg: '参数缺失'
		}
		return ctx
	}
	await next();
}

//导出是否有accessToken方法
exports.hasToken = async(ctx, next) => {
	var accessToken = ctx.query.accessToken
	if (!accessToken) {
		accessToken = ctx.request.body.accessToken
	}
	if (!accessToken) {
		ctx.body = {
			success: false,
			msg: '没accessToken'
		}
		return ctx
	}
	var user = await User.findOne({
		accessToken: accessToken
	}).exec();

	if (!user) {
		ctx.body = {
			success: false,
			msg: '用户没登录'
		}
		return ctx
	}
	ctx.session = ctx.session || {}
	ctx.session.user = user;
	await next();
}