blk qq login

@@ -6,6 +6,9 @@
 'use strict';
 'use strict';
 
 
 const _ = require('lodash');
 const _ = require('lodash');
+const Fp = require('lodash/fp');
+const qs = require('querystring');
+
 const passport = require('passport');
 const passport = require('passport');
 const uuid = require('uuid');
 const uuid = require('uuid');
 const md5 = require('md5');
 const md5 = require('md5');
@@ -29,7 +32,7 @@ function doPassportCallback(req, res, user) {
     if (/sign|login/.test(refer)) {
     if (/sign|login/.test(refer)) {
         refer = config.siteUrl;
         refer = config.siteUrl;
     }
     }
-    if (user.openId && user.nickname) {
+    if (user.openId) {
         let signinByOpenID;
         let signinByOpenID;
 
 
         if (user.sourceType === 'wechat') {
         if (user.sourceType === 'wechat') {
@@ -80,7 +83,7 @@ const common = {
     },
     },
     needCaptcha: (req, res, next) => {
     needCaptcha: (req, res, next) => {
         let account = req.query.account;
         let account = req.query.account;
-        let result = { code: 400, message: '', data: '' };
+        let result = {code: 400, message: '', data: ''};
 
 
         if (account) {
         if (account) {
             let errorLoginKey = 'account_errorlogin_' + account;
             let errorLoginKey = 'account_errorlogin_' + account;
@@ -88,7 +91,7 @@ const common = {
             cache.get(errorLoginKey).then(errloginTimes => {
             cache.get(errorLoginKey).then(errloginTimes => {
                 errloginTimes = parseInt(errloginTimes, 0) || 0;
                 errloginTimes = parseInt(errloginTimes, 0) || 0;
                 if (!isNaN(errloginTimes) && errloginTimes >= 3) {
                 if (!isNaN(errloginTimes) && errloginTimes >= 3) {
-                    result.data = { needCaptcha: true };
+                    result.data = {needCaptcha: true};
                 }
                 }
                 res.json(result);
                 res.json(result);
             }).catch(next);
             }).catch(next);
@@ -278,12 +281,18 @@ const sina = {
 const qq = {
 const qq = {
     login: (req, res, next) => {
     login: (req, res, next) => {
         req.session = req.session || {};
         req.session = req.session || {};
-        req.session.authState = uuid.v4();
+
+        let type = req.query.type || 'yohobuy';
+        let authState = req.session.authState = (req.query.state || uuid.v4()) + '::' + type;
+
         return passport.authenticate('qq', {
         return passport.authenticate('qq', {
-            state: req.session.authState
+            state: authState
         })(req, res, next);
         })(req, res, next);
     },
     },
     callback: (req, res, next) => {
     callback: (req, res, next) => {
+        let auth = Fp.compose(Fp.head, Fp.split('::'))(req.query.state);
+        let type = Fp.compose(Fp.nth(1), Fp.split('::'))(req.query.state);
+
         if (req.session && req.session.authState && req.session.authState === req.query.state) {
         if (req.session && req.session.authState && req.session.authState === req.query.state) {
             passport.authenticate('qq', (err, user) => {
             passport.authenticate('qq', (err, user) => {
                 if (err) {
                 if (err) {
@@ -293,11 +302,16 @@ const qq = {
                 let nickname = _.trim(user.nickname);
                 let nickname = _.trim(user.nickname);
                 let openId = user.id;
                 let openId = user.id;
 
 
-                doPassportCallback(req, res, {
-                    openId: openId,
-                    nickname: nickname,
-                    sourceType: 'qq'
-                }).catch(next);
+                if (type === 'yohoblk') {
+                    return res.redirect('//www.yohoblk.com/passport/login/qq/callback?' +
+                        qs.stringify({openid: openId, nickname: nickname, state: auth}));
+                } else {
+                    doPassportCallback(req, res, {
+                        openId: openId,
+                        nickname: nickname,
+                        sourceType: 'qq'
+                    }).catch(next);
+                }
             })(req, res, next);
             })(req, res, next);
         } else {
         } else {
             return next(new Error('Auth State Mismatch'));
             return next(new Error('Auth State Mismatch'));