Skip to content

5
51business
Commit 81fc205d authored by 李尚科's avatar 李尚科
Browse files
Options

fix gjj wechat login

parent 319a7566
Pipeline #17562 passed with stage
    in 7 seconds
    Hide whitespace changes
    Inline Side-by-side
    Showing with 53 additions and 71 deletions
    app/controller/gjj/wechat.js
    View file @ 81fc205d
    ...@@ -3,11 +3,8 @@ ...@@ -3,11 +3,8 @@
    const Controller = require('egg').Controller; const Controller = require('egg').Controller;
    const moment = require('moment'); const moment = require('moment');
    const WECHAT_CODE_URL = 'https://open.weixin.qq.com/connect/oauth2/authorize'; const WECHAT_CODE_URL = 'https://open.weixin.qq.com/connect/oauth2/authorize';
    const WECHAT_AUTH = 'https://api.weixin.qq.com/sns/oauth2/access_token';
    const WECHAT_APPID = 'wx3c772df2d8d78da3'; const WECHAT_APPID = 'wx3c772df2d8d78da3';
    const WECHAT_APPID_TEST = 'wxa9df2d60730b25d9'; const WECHAT_APPID_TEST = 'wxa9df2d60730b25d9';
    const WECHAT_SECRET = 'b369fd28a9f9320ebe4e35dfaa00b194';
    const WECHAT_SECRET_TEST = 'dfede7a3b543149a88b07b46bcc28e00';
    const REDIRECT_PAGE = '/webserve/accumulation/index'; const REDIRECT_PAGE = '/webserve/accumulation/index';
    class WechatController extends Controller { class WechatController extends Controller {
    ...@@ -18,81 +15,67 @@ class WechatController extends Controller { ...@@ -18,81 +15,67 @@ class WechatController extends Controller {
    const { ctx } = this; const { ctx } = this;
    const code = ctx.query.code; const code = ctx.query.code;
    const channel_id = ctx.query.channel_id; const channel_id = ctx.query.channel_id;
    const app_id = ['https://lan-nginx.jianbing.com', 'https://pro-nginx.jianbing.com'].includes(this.config.NODE_BASE_URL) ? WECHAT_APPID : WECHAT_APPID_TEST; const app_id = [ 'https://lan-nginx.jianbing.com', 'https://pro-nginx.jianbing.com', 'https://p.jianbing.com', 'https://b.jianbing.com' ].includes(this.config.NODE_BASE_URL) ? WECHAT_APPID : WECHAT_APPID_TEST;
    const appsecret = ['https://lan-nginx.jianbing.com', 'https://pro-nginx.jianbing.com'].includes(this.config.NODE_BASE_URL) ? WECHAT_SECRET : WECHAT_SECRET_TEST; if (!code || code.length === 0) {
    if (!code || code.length === 0) { // this.app.config.OUT_P_NODE_URL
    const target_url = WECHAT_CODE_URL + `?appid=${app_id}&redirect_uri=${encodeURIComponent(`${this.app.config.PULIC_BASE_URL}/51business/api/gjj/wechat/oauth_login?&channel_id=${channel_id}`)}&response_type=code&scope=snsapi_base&state=gjjquery#wechat_redirect`; const target_url = WECHAT_CODE_URL + `?appid=${app_id}&redirect_uri=${encodeURIComponent(`${this.app.config.PULIC_BASE_URL}/51business/api/gjj/wechat/oauth_login?&channel_id=${channel_id}`)}&response_type=code&scope=snsapi_base&state=gjjquery#wechat_redirect`;
    ctx.redirect(target_url); return; ctx.redirect(target_url); return;
    } }
    const url = `${WECHAT_AUTH}?appid=${app_id}&secret=${appsecret}&code=${code}&grant_type=authorization_code`; const oauth_url = `${this.config.NODE_BASE_URL}/user_api/v1/login/oauth_login`;// 用户中心授权地址
    const result = await ctx.helper.send_request(url, {}, { method: 'GET' }); // 授权参数
    ctx.logger.info(JSON.stringify({ wx_gjj_query: result })); const oauth_params = {
    if (result.status !== 200) { login_type: '5', // 5代表微信授权登录 如果有QQ授权登录，再扩展
    ctx.failed('获取openid失败1'); app_user_id: ctx.cookies.get('app_user_id', { signed: false }),
    } code,
    const wx_ret = result.data; token: ctx.cookies.get('token', { signed: false }),
    if (!wx_ret.openid) { app_id,
    ctx.failed('获取openid失败2'); };
    } const result = await ctx.helper.send_request(oauth_url, oauth_params, { method: 'POST' });// 通过授权码code返回授权状态
    const openid = wx_ret.openid; ctx.logger.info(JSON.stringify({ gjj_wechat_oauth_login_params: oauth_params, gjj_wechat_oauth_login_result: result }));
    // 在微信端需要关闭微信重新打开才会销毁cookie值，所以在这里重置cookie值
    ctx.cookies.set('openid', openid, { httpOnly: false, signed: false, path: '/', overwrite: true });
    ctx.cookies.set('token', null, { httpOnly: false, signed: false, path: '/', overwrite: true });
    ctx.cookies.set('user_id', null, { httpOnly: false, signed: false, path: '/', overwrite: true });
    ctx.cookies.set('app_user_id', null, { httpOnly: false, signed: false, path: '/', overwrite: true });
    ctx.cookies.set('jianbing_customer_id', null, { httpOnly: false, signed: false, path: '/', overwrite: true });
    ctx.cookies.set('auth_token', null, { httpOnly: false, signed: false, path: '/', overwrite: true });
    const redirect_url = this.app.config.PULIC_BASE_URL + REDIRECT_PAGE;
    // 判断是否已绑定手机号
    const user_exist_url = `${this.app.config.NODE_BASE_URL}/user_api/v1/user/is_exist/${openid}`;
    const bind_phone_result = await ctx.helper.send_request(user_exist_url, { type: 5 }, { method: 'GET' });
    ctx.logger.info(JSON.stringify({ bind_phone_result }));
    if (bind_phone_result.status !== 200) {
    ctx.redirect(redirect_url + `?channel_id=${channel_id}&type=noLogin`); return;
    }
    const user_exist_ret = bind_phone_result.data;
    if (user_exist_ret.result != 'true') { // 未绑定的手机号时
    ctx.redirect(redirect_url + `?channel_id=${channel_id}&type=noLogin`); return;
    }
    const user_id = user_exist_ret.uid;
    // 已绑定手机的 继续 判断是否有导入公积金 const ret = result.data;
    const login_result = await this.user_login({ code, openid, channel_id });// 已绑定的用户 直接登录 if (result.status !== 201) { // 调用接口出错抛出异常
    if (login_result.anew && !login_result.token) { const error_message = ret.error ? ret.error : '授权失败，请联系客服';
    ctx.redirect(redirect_url + `?channel_id=${channel_id}&type=noLogin`); return; ctx.failed(error_message);
    }
    const no_login_url = this.config.PULIC_BASE_URL + REDIRECT_PAGE + `?channel_id=${channel_id}&type=noLogin`;// 未登录并没有公积金数据的页面
    const detail_url = this.config.PULIC_BASE_URL + REDIRECT_PAGE + `?channel_id=${channel_id}&type=hasLogin`;// 已登录并且有公积金数据的公积金详情页，
    // { code: '-1', msg: 'APP用户状态异常' }
    // { code: '-2', msg: '需要重新授权' }
    // { code: '-3', msg: '需要先手机登录' }
    // { code: '-4', msg: '绑定失败，此QQ已绑定其他手机了'}
    if (ret.code && ret.code === -3) { // 如果用户未绑定手机，先去做登录绑定手机号
    ctx.redirect(no_login_url);
    return;
    }
    if (!ret || ret.code !== 1 || !ret.data || !ret.data.openid) {
    const error_msg = ret.msg || '获取openid失败';
    ctx.failed(error_msg);
    } }
    const openid = ret.data.openid;
    const login_result = await this.user_login({ code, openid, channel_id });// 用openid直接登录用户
    const user_id = login_result.user_id;
    // 已绑定手机的 继续 判断是否有导入公积金
    if (!login_result.token) {
    ctx.redirect(no_login_url + `?channel_id=${channel_id}&type=noLogin`); return;
    }
    const gjj_exist_url = `${this.app.config.NODE_BASE_URL}/cassandra-server/gjj/list/${user_id}`; const gjj_exist_url = `${this.app.config.NODE_BASE_URL}/cassandra-server/gjj/list/${user_id}`;
    const gjj_exist_result = await ctx.helper.send_request(gjj_exist_url, {}, { method: 'GET' }); const gjj_exist_result = await ctx.helper.send_request(gjj_exist_url, {}, { method: 'GET' });
    ctx.logger.info(JSON.stringify({ gjj_exist_result })); ctx.logger.info(JSON.stringify({ user_id, gjj_exist_result }));
    if (gjj_exist_result.status !== 200) { // 调用公积金接口出错 if (gjj_exist_result.status !== 200) { // 调用公积金接口出错
    ctx.redirect(redirect_url + `?channel_id=${channel_id}&type=noLogin`); return; ctx.redirect(no_login_url); return;
    } }
    const gjj_exist_ret = gjj_exist_result.data; const gjj_exist_ret = gjj_exist_result.data;
    if (!gjj_exist_ret.ret || gjj_exist_ret.ret.length === 0) { // 没有导入公积金时 if (!gjj_exist_ret.ret || gjj_exist_ret.ret.length === 0) { // 没有导入公积金时
    ctx.redirect(redirect_url + `?channel_id=${channel_id}&type=noLogin`); return; ctx.redirect(no_login_url); return;
    } }
    ctx.redirect(redirect_url + `?channel_id=${channel_id}&type=hasLogin`); return;// 已导入公积金 ctx.redirect(detail_url); return;// 已导入公积金
    } }
    // 判断是否有公积金导入并跳转
    // async checkGjj() {
    // const { ctx } = this;
    // const user_id = ctx.userId;
    // //判断是否有导入公积金
    // console.info(user_id);
    // const gjj_exist_url = `${this.app.config.NODE_BASE_URL}/cassandra-server/gjj/list/${user_id}`;
    // const gjj_exist_result = await ctx.helper.send_request(gjj_exist_url, {}, { method: 'GET' });
    // ctx.logger.info(JSON.stringify({ gjj_exist_result: gjj_exist_result }));
    // if (gjj_exist_result.status !== 200) {
    // ctx.redirect(NO_GJJ_PAGE); return;
    // }
    // ctx.redirect(GJJ_DETAIL_PAGE); return;
    // }
    async checkLogin() { async checkLogin() {
    const { ctx } = this; const { ctx } = this;
    ...@@ -101,7 +84,7 @@ class WechatController extends Controller { ...@@ -101,7 +84,7 @@ class WechatController extends Controller {
    if (user_id) { if (user_id) {
    is_login = true; is_login = true;
    } }
    // const phone = await ctx.helper.getPhoneCity('15968762898');
    ctx.success({ result: is_login }); ctx.success({ result: is_login });
    } }
    ...@@ -123,12 +106,13 @@ class WechatController extends Controller { ...@@ -123,12 +106,13 @@ class WechatController extends Controller {
    ctx.failed('渠道未关联APPID'); ctx.failed('渠道未关联APPID');
    } }
    const device_login_params = { const device_login_params = {// 设备登录的参数
    past_deviceno, past_deviceno,
    channel_id: app_channel_info.channel_id, channel_id: app_channel_info.channel_id,
    app_id: app_channel_info.app_id, app_id: app_channel_info.app_id,
    device_info: {}, device_info: {},
    }; };
    // 设备登录
    const result_device_login = await ctx.helper.send_request(this.config.NODE_URL + '/login/device', device_login_params, { method: 'POST' });// 设备登录 const result_device_login = await ctx.helper.send_request(this.config.NODE_URL + '/login/device', device_login_params, { method: 'POST' });// 设备登录
    const device_login_data = result_device_login.data;// 设备登录返回结果 const device_login_data = result_device_login.data;// 设备登录返回结果
    if (!device_login_data || Object.keys(device_login_data).length === 0) { if (!device_login_data || Object.keys(device_login_data).length === 0) {
    ...@@ -156,16 +140,13 @@ class WechatController extends Controller { ...@@ -156,16 +140,13 @@ class WechatController extends Controller {
    openid: openid || '', // 例如微信公众号的openid（不传默认是51查个税） openid: openid || '', // 例如微信公众号的openid（不传默认是51查个税）
    }; };
    const result_user_login = await ctx.helper.send_request(this.config.NODE_URL + '/login/user', user_login_params, { method: 'POST' });// 用户登录 const result_user_login = await ctx.helper.send_request(this.config.NODE_URL + '/login/user', user_login_params, { method: 'POST' });// 用户登录
    ctx.logger.info(JSON.stringify({ user_login_params, result_user_login })); ctx.logger.info(JSON.stringify({ user_ologin_params: user_login_params, result_user_ologin: result_user_login }));
    const user_login_data = result_user_login.data;// 用户登录返回结果 const user_login_data = result_user_login.data;// 用户登录返回结果
    if (!user_login_data || Object.keys(user_login_data).length === 0) { if (!user_login_data || Object.keys(user_login_data).length === 0) {
    ctx.failed('用户的登录失败'); ctx.failed('用户的登录失败');
    } }
    if (!user_login_data.token || !user_login_data.uid) { if (!user_login_data.token || !user_login_data.uid || !user_login_data.app_user_id) {
    const error_msg = user_login_data.error ? user_login_data.error : '用户的登录失败'; const error_msg = user_login_data.error ? user_login_data.error : '用户的openid登录失败';
    if (error_msg === '需要重新授权') {
    return { anew: 1 };
    }
    ctx.failed(error_msg); ctx.failed(error_msg);
    } }
    // 获取用户信息 // 获取用户信息
    ...@@ -182,6 +163,7 @@ class WechatController extends Controller { ...@@ -182,6 +163,7 @@ class WechatController extends Controller {
    auth_token = ctx.helper.md5(String(old_user_sid) + moment(new Date()).format('MDYYYY') + 'f74jkdsy83sjf', 'utf8'); auth_token = ctx.helper.md5(String(old_user_sid) + moment(new Date()).format('MDYYYY') + 'f74jkdsy83sjf', 'utf8');
    } }
    // 需要存cookie的用户信息
    const user_info = { const user_info = {
    token: login_token, token: login_token,
    app_user_id, app_user_id,
    ...@@ -193,7 +175,7 @@ class WechatController extends Controller { ...@@ -193,7 +175,7 @@ class WechatController extends Controller {
    jianbing_customer_id: old_user_sid, jianbing_customer_id: old_user_sid,
    auth_token, auth_token,
    }; };
    for (const key in user_info) { for (const key in user_info) { // 保存cookie
    const value = user_info[key]; const value = user_info[key];
    ctx.cookies.set(key, value, { httpOnly: false, signed: false, path: '/', overwrite: true }); ctx.cookies.set(key, value, { httpOnly: false, signed: false, path: '/', overwrite: true });
    } }
    ......
    Markdown is supported
    0% or
    You are about to add 0 people to the discussion. Proceed with caution.
    Finish editing this message first!
    Please register or to comment