/**
 * 注册
 *
 * @author Bi Kai<kai.bi@yoho.cn>
 * @date 2016/06/23
 */

'use strict';

const _ = require('lodash');
const url = require('url');
const utils = require(global.utils);
const helpers = global.yoho.helpers;
const sign = global.yoho.sign;
const cookie = global.yoho.cookie;
const RegService = require('../models/reg-service');
const AuthHelper = require('../models/auth-helper');

/*
    session 结构
    phoneReg: {
        step  //当前步骤
        captcha // step1 的校验码
        count: 5 // 默认可以重发5次, 当count: 0, 冻结30min,之后解冻
        expire // 解冻时间
    }
*/


/**
 *  步骤校验
 *  step: 预期步骤
 */
let guardStep = function(step) {
    return (req, res, next) => {
        let curStep = _.get(req.session, 'phoneReg.step');

        if (curStep !== step) {
            if (req.xhr) {
                return res.json({
                    code: 400,
                    refer: '/reg.html',
                    message: '页面失效'
                });
            } else {
                return res.redirect('/reg.html');
            }
        }

        return next();
    };
};

/**
 *  Step1: 输入手机号码 + 验证码
 */
let index = (req, res) => {
    if (req.user.uid) {
        return res.redirect(req.get('refer') || '/');
    }

    // 判断是否 来自 个人中心
    if (!_.get(req.session, 'phoneReg.isFromMy')) {
        let referer = req.get('Referer') || '';
        let urlObj = url.parse(referer, true, true);

        referer = _.get(urlObj, 'query.refer', '');

        urlObj = url.parse(referer, true, true);
        urlObj.path === '/home' && _.set(req.session, 'phoneReg.isFromMy', '1');
    }

    // 设置注册有效时间30分钟, 防机器刷
    // req.session.REG_EXPIRE = Date.now() + 1800000;
    let refer = req.query.refer;

    refer = utils.refererLimit(refer);

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

    // session init
    _.set(req.session, 'phoneReg.step', 1);

    if (req.session.captchaValidCount == null) { // eslint-disable-line
        req.session.captchaValidCount = 5;
    }

    if (req.session.phoneReg.count == null) { // eslint-disable-line
        req.session.phoneReg.count = 5;
    }

    res.render('reg/index', {
        width750: true,
        module: 'passport',
        page: 'reg',
        title: '注册',
        backUrl: 'javascript:history.go(-1)', // eslint-disable-line
        captchaUrl: helpers.urlFormat('/passport/reg/captcha.png', {t: Date.now()}),
        headerText: '注册', // 头部信息
        isPassportPage: true, // 模板中模块标识
        areaCode: '+86', // 默认的区号
        countrys: RegService.getAreaData() // 地区信息列表
    });
};


let verifyMobile = (req, res, next) => {
    let data = {
        code: 400,
        message: '手机号已存在',
        data: ''
    };

    let mobile = +req.body.phoneNum;
    let area = +(req.body.areaCode || 86);
    let inviteCode = +req.body.inviteCode || '';

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

    // 设置注册有效时间30分钟, 防机器刷
    // let expire = req.session.REG_EXPIRE;

    // if (!expire || expire < Date.now()) {
    //     data.message = '非法请求';
    //     return res.json(data);
    // }


    // 向手机发送注册验证码
    RegService.sendCodeToMobile(area, mobile).then((result) => {
        if (result.code !== 200) {
            data.message = result.message;
            return res.json(data);
        }

        // 返回跳转到验证页面的链接
        if (result.code === 200) {
            let token = sign.makeToken(mobile);

            _.set(req.session, 'phoneReg.step', 2); // go step 2
            --req.session.phoneReg.count;

            // count is 0, will freeze;
            if (!req.session.phoneReg.count) {
                _.set(req.session, 'phoneReg.expire', Date.now() + 5 * 60 * 1000);
            }

            result.data = helpers.urlFormat('/passport/reg/code', {
                token: token,
                phoneNum: mobile,
                areaCode: area,
                inviteCode: inviteCode
            });
        }

        return res.json(result);
    }).catch(next);
};


/**
 *  Step2: 校验 手机验证码
 */
let codeAction = (req, res, next) => {
    let token = req.query.token;
    let mobile = +req.query.phoneNum;
    let area = +(req.query.areaCode || 86);
    let inviteCode = +req.query.inviteCode || '';

    // 判断是否允许访问, 不允许则跳转到错误页面
    if (!_.isString(token) || !_.isNumber(mobile) || !sign.verifyToken(mobile, token)) {
        return next({
            code: 403,
            message: 'error token or mobile'
        });
    }

    let serviceUrl = helpers.urlFormat('/service/im');

    res.render('reg/code', {
        page: 'code',
        title: '注册-验证码',
        headerText: '注册', // 头部信息
        isPassportPage: true, // 模板中模块标识
        areaCode: area, // 默认的区号
        phoneNum: mobile, // 手机号
        token: token, // 访问令牌
        inviteCode: inviteCode,
        serviceUrl: serviceUrl // 在线客服
    });
};

let sendCodeBusyBoy = (req, res, next) => {
    let count = _.get(req.session, 'phoneReg.count');
    let expire = _.get(req.session, 'phoneReg.expire');

    if (count) {
        return next();
    } else {

        /*
            如果 count === 0
                1. 没过解冻期
                2. 过了解冻期, count reset to 5
        */
        let now = Date.now();

        if (now > expire) {
            _.set(req.session, 'phoneReg.count', 5);
            return next();

        } else {
            return res.json({
                code: 400,
                message: '发送次数太多, 5分钟稍后再试'
            });
        }

    }
};

let sendCode = (req, res, next) => {
    let data = {
        code: 400,
        message: '发送验证码失败',
        data: ''
    };

    let mobile = +req.body.phoneNum;
    let area = +(req.body.areaCode || 86);

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

    // 设置注册有效时间30分钟, 防机器刷
    // let expire = req.session.REG_EXPIRE;

    // if (!expire || expire < Date.now()) {
    //     data.message = '非法请求';
    //     return res.json(data);
    // }

    // 向手机发送注册验证码
    RegService.sendCodeToMobile(area, mobile).then((result) => {
        let code = _.get(result, 'code');

        if (code) {
            --req.session.phoneReg.count;

            // count is 0, will freeze;
            if (!req.session.phoneReg.count) {
                _.set(req.session, 'phoneReg.expire', Date.now() + 5 * 60 * 1000);
            }
            return res.json(result);
        } else {
            return res.json(data);
        }
    }).catch(next);
};

let verifyCode = (req, res, next) => {
    let data = {
        code: 400,
        message: '验证码错误',
        data: ''
    };

    let mobile = +req.body.phoneNum;
    let area = +(req.body.areaCode || 86);
    let code = +req.body.code;
    let inviteCode = +req.body.inviteCode || '';

    /* 判断参数是否合法 */
    if (!_.isNumber(mobile) || !_.isNumber(area) || !_.isNumber(code)) {
        data.message = '手机号错误';
        return res.json(data);
    }

    // 设置注册有效时间30分钟, 防机器刷
    // let expire = req.session.REG_EXPIRE;

    // if (!expire || expire < Date.now()) {
    //     data.message = '非法请求';
    //     return res.json(data);
    // }

    // 验证注册的标识码是否有效
    RegService.validMobileCode(area, mobile, code).then((result) => {
        if (!result.code) {
            return res.json(data);
        }

        let resultCode = _.get(result, 'code');
        let token = sign.makeToken(mobile);

        switch (resultCode) {
            case 200:
                _.set(req.session, 'phoneReg.step', 3); // go step 3
                result.data = helpers.urlFormat('/passport/reg/password', {
                    token: token,
                    phoneNum: mobile,
                    areaCode: area,
                    smsCode: code,
                    inviteCode: inviteCode
                });
                break;
            case 404:
            default:
                result = data;
        }

        return res.json(result);
    }).catch(next);
};

/**
 *  Step3: set Password
 */
let passwordAction = (req, res, next) => {
    let token = req.query.token;
    let mobile = +req.query.phoneNum;
    let area = +(req.query.areaCode || 86);
    let smsCode = +req.query.smsCode;
    let inviteCode = +req.query.inviteCode || '';

    // 判断是否允许访问, 不允许则跳转到错误页面
    if (!smsCode || !_.isString(token) || !_.isNumber(mobile) ||
    !_.isNumber(area) || !sign.verifyToken(mobile, token)) {
        return next({
            code: 403,
            message: 'error token, mobile or verifyCode'
        });
    }

    res.render('reg/password', {
        page: 'password',
        title: '注册-设置密码',
        backUrl: '/?go=1', // eslint-disable-line
        headerText: '注册', // 头部信息
        isPassportPage: true, // 模板中模块标识
        areaCode: area, // 默认的区号
        phoneNum: mobile, // 手机号
        token: token, // 访问令牌
        smsCode: smsCode, // 手机验证码
        inviteCode: inviteCode
    });
};

let setPassword = (req, res, next) => {
    let data = {
        code: 400,
        message: '密码格式不正确',
        data: ''
    };

    let mobile = +req.body.phoneNum;
    let area = +(req.body.areaCode || 86);
    let password = req.body.password;
    let token = req.body.token;
    let smsCode = +req.body.smsCode;
    let isFromMy = _.get(req.session, 'phoneReg.isFromMy', '0');
    let inviteCode = req.body.inviteCode || '';

    // 判断参数是否合法
    if (!smsCode || !_.isString(token) || !_.isNumber(mobile) || !_.isNumber(area) || !password) {
        data.message = '请求参数不合法';
        return res.json(data);
    }

    // 判断是否允许访问
    if (!sign.verifyToken(mobile, token)) {
        data.message = '非法 token';
        return res.json(data);
    }

    // 判断密码是否符合规则
    if (!/^(?![0-9]+$)(?![a-zA-Z]+$)[0-9A-Za-z]{6,20}$/.test(password)) {
        return res.json(data);
    }

    // 购物车key
    let shoppingKey = cookie.getShoppingKey(req);

    // 验证注册的标识码是否有效
    let resultCopy = null;

    RegService.regMobileAes(area, mobile, password, shoppingKey, smsCode, inviteCode, isFromMy).then((result) => {
        if (!result.code || result.code !== 200) {
            return res.send(result);
        }
        if (!result.data || !result.data.uid) {
            return res.send(result);
        }

        resultCopy = result;

        return AuthHelper.syncUserSession(result.data.uid, req, res, result.data.session_key);
    }).then(() => {
        if (!resultCopy) {
            return;
        }

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

        // isFromMy  to 新人会场
        if (resultCopy.data.newUserPage) {
            refer = resultCopy.data.msgDelivery; // 来自个人中心，跳新人会场
        } else {
            if (refer) {
                refer = decodeURI(req.cookies.refer);
            } else {
                refer = '/home';
            }

            if (/sign|login/.test(refer)) {
                refer = '/home';
            }

            refer = utils.refererLimit(refer);
        }


        delete req.session.phoneNum;

        return res.json({
            code: 200,
            message: '注册成功',
            data: {
                session: refer,
                href: refer
            }
        });
    }).catch(next);
};


module.exports = {
    guardStep,
    sendCodeBusyBoy,
    index,
    verifyMobile,
    code: codeAction,
    sendCode,
    verifyCode,
    password: passwordAction,
    setPassword
};