手把手实现第三方社交登录方式微信登录

{
  "expire_seconds": 604800,
  "action_name": "QR_SCENE", 
  "action_info": {
    "scene": {"scene_id": 123}
  }
} 

https://mp.weixin.qq.com/cgi-bin/showqrcode?ticket=TICKET

// sha1加密安装
yarn add sha1@1.1.1

const SecretTool = require('../utils/SecretTool')
const WxLoginService = {
  wechat_insert: (signature, timestamp, nonce, echostr) => {
    // 服务器的token
    let token = 'testxdclass'
    // 将token、timestamp、nonce三个参数进行字典序排序,拼接成一个字符串,进行sha1加密
    let str = SecretTool.sha1([token, timestamp, nonce].sort().join(''))
    // 获得加密后的字符串可与signature对比，验证标识该请求来源于微信服务器
    if (str === signature) {
      // 确认此次GET请求来自微信服务器，原样返回echostr参数内容，则接入生效
      return echostr
    }
  },
}
module.exports = WxLoginService

const appId = 'wx5beac15ca207c40c';
const appSecret = '8189e5f14346ccaa3bd5f6909f31a362';
const accessTokenPc = `https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=${appId}&secret=${appSecret}`;
const getAccess_token = () => {
  return axios({
    method: 'get',
    url: accessTokenPc,
  });
};

const ticketReq = (token) => {
  return axios({
    method: 'post',
    url: `https://api.weixin.qq.com/cgi-bin/qrcode/create?access_token=${token}`,
    data: {
      expire_seconds: 60 * 2, // 二维码有效时间
      action_name: 'QR_SCENE',
      action_info: { scene: { scene_id: 123 } },
    },
  });
};

const qrUrl = 'https://mp.weixin.qq.com/cgi-bin/showqrcode';
const wechatLogin = {
  // 获取微信登录二维码
  getQR: async () => {
    let token = (await getAccess_token()).data.access_token;
    console.log((await getAccess_token()))
    console.log('token:', token)
    let ticket = (await ticketReq(token)).data.ticket;
    return { qrcodeUrl: `${qrUrl}?ticket=${ticket}`, ticket: ticket };
  }
}

let key = `wechat:ticket:${ticket}`
redisConfig.set(key, JSON.stringify({ isScan: 'no' }), 120)

// controller 控制层
wechat_message: (req, res) => {
  let handleRes = WxLoginService.wechat_message(req)
  res.send(handleRes)
}

// service 数据层
wechat_message: (req, res) => {
  return '成功'
}

/**
 * @param {*} getXMLStr 以流的形式接收微信服务器发过来的数据
 * @param {*} getJsData 通过工具解析xml数据转换成对象
 * @param {*} getObjData 优化数据
 */
var { parseString } = require('xml2js');
// 微信XML数据类型处理
class WxDataTool {
  static getXMLStr(req) {
    return new Promise((resolve, reject) => {
      let data = '';
      req.on('data', (msg) => {
        data += msg.toString();
      });
      req.on('end', () => {
        resolve(data);
      });
    });
  }
  static getJsData(data) {
    return new Promise((resolve, reject) => {
      parseString(data, (err, result) => {
        if (err) {
          reject('error');
        } else {
          resolve(result);
        }
      });
    });
  }
  static getObjData(obj) {
    let tempObj = {};
    if (obj && typeof obj === 'object') {
      // 循环对象，提取数据
      for (let key in obj) {
        let value = obj[key];
        if (value && value.length > 0) {
          tempObj[key] = value[0];
        }
      }
      return tempObj;
    } else {
      return tempObj;
    }
  }
};
module.exports = WxDataTool

// 根据openid判断是否注册
let openidRes = await DB.Account.findAll({ where: { openid }, raw: true })
// 随机获取头像、用户名
let head_img = RandomTool.randomAvatar()
let username = RandomTool.randomName()
// 无注册则增加个用户数据
let user = null
if (openidRes.length === 0) {
  let resData = await DB.Account.create({ username, head_img, openid })
  user = { head_img, username, id: resData.toJSON().id }
} else {
  user = {
    head_img: openidRes.head_img,
    username: openidRes.username,
    id: openidRes.id
  }
}

let token = SecretTool.jwtSign(user, '168h')

let key = `wechat:ticket:${ticket}`
const existsKey = await redisConfig.exists(key)
if (existsKey) {
  redisConfig.set(key, JSON.stringify({ isScan: 'yes', token }), 120)
}

let content = ''
if (msgObj.MsgType == 'event') {
  // 扫码
  if (msgObj.Event == 'SCAN') {
    content = '欢迎回来，讲师微信：xdclass6'
  } else if (msgObj.Event == 'subscribe') {
    // 订阅
    content = '感谢关注，讲师微信：xdclass6'
  }
  // 根据来时的信息格式，重组返回。(注意中间不能有空格)
  let msgStr = `<xml>
    <ToUserName><![CDATA[${lastData.FromUserName}]]></ToUserName>
    <FromUserName><![CDATA[${lastData.ToUserName}]]></FromUserName>
    <CreateTime>${Date.now()}</CreateTime>
    <MsgType><![CDATA[text]]></MsgType>
    <Content><![CDATA[${content}]]></Content>
  </xml>`
  return msgStr
}

http://127.0.0.1:8081/api/wx_login/v1/check_scan
请求方法：get
请求参数：ticket

let { ticket } = req.query
let key = `wechat:ticket:${ticket}`
let redisData = JSON.parse(await redisConfig.get(key))

if (redisData && redisData.isScan == 'yes') {
  let token = redisData.token
  return JsonData.buildSuccessAndData(`Bearer ${token}`)
} else {
  return JsonData.buildResult(CodeEnum.WECHAT_WAIT_SCAN)
}