reg.js 9.25 KB
/**
* 注册控制器
*/
'use strict';
const _ = require('lodash');
const passportHelper = require('../models/passport-helper');
const regService = require('../models/reg-service');
const userService = require('../models/user-service');
const authHelper = require('../models/auth-helper');
const config = require('../../../config/common');

let helpers = global.yoho.helpers;
let cache = global.yoho.cache;
let cookie = global.yoho.cookie;

let index = (req, res, next) => {
    // 设置注册有效时间30分钟, 防机器刷
    req.session._REG_EXPIRE = Date.now() + 1800000;

    let refer = req.query.refer;

    refer && res.cookie('refer', encodeURI(refer), {
        domain: 'yohobuy.com'
    });

    regService.getRegData().then((result) => {
        res.render('reg/index', {
            title: '新用户注册',
            passport: {
                region: passportHelper.getCountry(),
                location: '+86',
                captchaUrl: helpers.urlFormat('/passport/images', {t: Date.now()}),
                itemUrl: helpers.urlFormat('/help/', {category_id: 9}),
                referUrl: refer,
                loginUrl: helpers.urlFormat('/signin.html', {refer: refer}),
                coverHref: result.url,
                coverImg: result.img,
                regBtnText: '立即注册'
            }
        });
    }).catch(next);
};

let checkMobile = (req, res, next) => {
    let data = {
        code: 400
    };
    let mobile = +req.body.mobile;
    let area = +req.body.area;

    if (!_.isNumber(mobile) || !_.isNumber(area)) {
        data.message = '手机号码格式不正确';
        return res.json(data);
    }

    // 判断手机号是否检查超过指定次数
    let key = 'checkmobilenum_' + passportHelper.makeAreaMobile(area, mobile);

    cache.get(key).then((checkNum) => {
        checkNum = +(checkNum || 0);

        cache.set(key, ++checkNum).catch(next);
        if (checkNum > 500) {
            data.message = '检查次数太多';
            return res.json(data);
        }

        // 判断用户是否存在
        return userService.findByMobileAsync(area, mobile).then((user) => {
            if (!_.isEmpty(user)) {
                data.message = '手机号码已经存在';
                return res.json(data);
            }

            data.code = 200;
            return res.json(data);
        });
    }).catch(next);
};

let picCaptcha = (req, res, next) => {
    let verifyCode = _.trim(req.body.verifyCode);
    let picFlag = true; // TODO: 图形验证码校验

    if (picFlag) {
        return res.json({
            code: 200,
            message: '验证码正确'
        });
    }

    return res.json({
        code: 400,
        message: '验证码错误'
    });
};

let sendBindMsg = (req, res, next) => {
    let data = {
        code: 400,
        message: '',
        data: ''
    };

    let mobile = +req.body.mobile;
    let area = +req.body.area;
    let verifyCode = +req.body.verifyCode;

    // 判断参数是否合法
    if (!_.isNumber(mobile) || !_.isNumber(area)) {
        data.message = '手机号码格式不正确';
        return res.json(data);
    }

    // 检查是否检查过
    // let makeMobile = passportHelper.makeAreaMobile(area, mobile);
    //
    // if (req.session[`checkmobile_${makeMobile}`] !== makeMobile) {
    //     data.message = '发送失败';
    //     return res.json(data);
    // }

    // 校验是否发送过多
    let sendCodeKey = `send_code_${area}_${mobile}`;

    cache.get(sendCodeKey).then((sendCodeTimes) => {
        if (!sendCodeTimes) {
            sendCodeTimes = 0;
        } else {
            sendCodeTimes = +sendCodeTimes;
        }

        if (sendCodeTimes >= 10) {
            data.message = '您已多次提交验证码,请尽快联系客服解决';
            return res.json(data);
        }

        if (sendCodeTimes >= 5) {
            data.message = '您收到的验证码短信已超过本日限定最多次数,请您耐心等待';
            return res.json(data);
        }

        // TODO: 检测验证码不正确
        // if (!PassportModel::verifyCode($verifyCode)) {
        //     $data['code'] = 400;
        //     $data['message'] = '图形验证码不正确';
        //     break;
        // }

        /* 向手机发送注册验证码 */
        return regService.sendCodeToMobile(area, mobile).then((result) => {
            return cache.set(sendCodeKey, sendCodeTimes + 1, 3600).then(() => {
                if (result.code) {
                    return res.json(result);
                } else {
                    data.message = '发送失败';
                    return res.json(data);
                }
            });
        });
    }).catch(next);
};

let msgCaptcha = (req, res, next) => {
    let data = {
        code: 400,
        message: '',
        data: ''
    };

    let area = +req.body.area;
    let mobile = +req.body.mobile;
    let code = +req.body.code; // 短信验证码

    // 判断参数是否合法
    if (!_.isNumber(mobile) || !_.isNumber(area)) {
        data.message = '手机号码格式不正确';
        return res.json(data);
    }

    regService.validMobileCode(area, mobile, code).then((result) => {
        if (result.code) {
            return res.json(result);
        } else {
            data.message = '验证码错误';
            return res.json(data);
        }
    }).catch(next);
};

let mobileRegister = (req, res, next) => {
    let data = {
        code: 400,
        message: '',
        data: ''
    };

    let area = +req.body.area;
    let mobile = +req.body.mobile;

    // 判断参数是否合法
    if (!_.isNumber(mobile) || !_.isNumber(area)) {
        data.message = '手机号码格式不正确';
        return res.json(data);
    }

    /* 判断是否是有效的注册方式,防注册机刷 */
    let regExpireTime = req.session._REG_EXPIRE;

    if (!regExpireTime || regExpireTime < Date.now()) {
        data.message = '注册超时';
        return res.json(data);
    }

    // TODO: 检测验证码不正确
    // $verifyCode = strtolower(trim($this->post('verifyCode'))); //图形验证码
    // if (!PassportModel::verifyCode($verifyCode)) {
    //     $data['message'] = '验证码不正确';
    //     break;
    // }

    /* 判断密码是否符合规则 */
    let code = +req.body.code; // 短信验证码
    let password = req.body.password;

    if (!helpers.verifyPassword(password)) {
        data.message = '密码不正确';
        return res.json(data);
    }

    /* IP仅允许点击注册500次/时 */
    let ip = req.ip;
    let ipKey = 'ip_register_' + ip;

    cache.get(ipKey).then((ipTimes) => {
        if (!ipTimes) {
            ipTimes = 0;
        } else {
            ipTimes = +ipTimes;
        }

        if (ipTimes >= 500) {
            data.message = '由于你IP受限无法注册';
            return res.json(data);
        }

        return cache.set(ipKey, ipTimes + 1, 3600).then(() => {
            /* 验证注册的标识码是否有效 */
            return regService.validMobileCode(area, mobile, code).then((result) => {
                if (!result.code || result.code !== 200) {
                    data.message = '验证码错误';
                    return res.json(data);
                }

                let shoppingKey = cookie.getShoppingKey(req);

                /* 手机注册: 调用注册接口,ip限制计数 */
                return regService.regMobile(area, mobile, password, shoppingKey).then((regResult) => {
                    if (!regResult.code || regResult.code !== 200) {
                        data.message = '注册失败';
                        return res.json(data);
                    }

                    // 返回跳转到来源页面
                    let refer = req.cookies.refer;

                    if (refer) {
                        refer = decodeURI(req.cookies.refer);
                    } else {
                        refer = '/?go=1';
                    }

                    if (/signin|login/.test(refer)) {
                        refer = '/?go=1';
                    }

                    return authHelper.syncUserSession(regResult.data.uid, req, res).then(() => {
                        return res.json({
                            code: 200,
                            message: '注册成功',
                            data: {
                                href: helpers.urlFormat('/passport/reg/success', {
                                    next: refer,
                                    goShoppingUrl: config.siteUrl
                                })
                            }
                        });
                    });
                });
            });
        });
    }).catch(next);
};

let success = (req, res, next) => {
    let goUrl = req.query.next || config.siteUrl;
    let goShoppingUrl = req.query.goShoppingUrl || config.siteUrl;

    regService.getRegData().then((result) => {
        res.render('reg/success', {
            title: '注册成功',
            passport: {
                goUrl: goUrl,
                goShoppong: goShoppingUrl,
                coverHref: result.url,
                coverImg: result.img
            }
        });
    }).catch(next);
};

module.exports = {
    index,
    success,
    checkMobile,
    picCaptcha,
    sendBindMsg,
    msgCaptcha,
    mobileRegister
};