|--- 微信相關| |--- 0. 處理微信推過來的一些消息| |--- 1. 獲取微信SDK配置參數| |--- 2. 微信鑒權登陸| |--- 3. 獲取微信用戶信息| |--- 4. 獲取AccessToken| |--- 5. 批量發送模版消息| |--- 6. 獲取模版消息列表| |--- 7. 批量發送客服消息

$ npm install -g think-cli

$ thinkjs new demo;$ cd demo;$ npm install; $ npm start; 

|--- development.js  //開發環境下的入口文件|--- nginx.conf //nginx 配置文件|--- package.json|--- pm2.json //pm2 配置文件|--- production.js //生產環境下的入口文件|--- README.md|--- src| |--- bootstrap //啟動自動執行目錄 | | |--- master.js //Master 進程下自動執行| | |--- worker.js //Worker 進程下自動執行| |--- config //配置文件目錄| | |--- adapter.js // adapter 配置文件 | | |--- config.js // 默認配置文件 | | |--- config.production.js //生產環境下的默認配置文件，和 config.js 合并 | | |--- extend.js //extend 配置文件 | | |--- middleware.js //middleware 配置文件 | | |--- router.js //自定義路由配置文件| |--- controller //控制器目錄 | | |--- base.js| | |--- index.js| |--- logic //logic 目錄| | |--- index.js| |--- model //模型目錄| | |--- index.js|--- view //模板目錄| |--- index_index.html

$ npm install think-wechat --save

$ cnpm install think-wechat --save

const wechat = require('think-wechat')module.exports = [  ...   {    handle: wechat,    match: '/index',    options: {      token: '', // 令牌，和公眾號/基本配置/服務器配置里面寫一樣的即可      appid: '', // 這里貌似可以隨便填，因為我們后面要用數據庫配置多個公眾號      encodingAESKey: '',      checkSignature: false    }  }, {    handle: 'payload', // think-wechat 必須要在 payload 中間件前面加載，它會代替 payload 處理微信發過來的 post 請求中的數據。    options: {      keepExtensions: true,      limit: '5mb'    }  },]

/src/controller/index.js

module.exports = class extends think.Controller {  /*  * 入口：驗證開發者服務器  * 驗證開發者服務器，這里只是演示，所以沒做簽名校驗，實際上應該要根據微信要求進行簽名校驗  */  async indexAction() {    let that = this;    if (that.method != 'REPLY') {      return that.json({code: 1, msg: '非法請求', data: null})    }    const {echostr} = that.get();    return that.end(echostr);  }     /*  * 文字  * 用于處理微信推過來的文字消息  */  async textAction() {    let that = this;    let {id, signature, timestamp, nonce, openid} = that.get();    let {ToUserName, FromUserName, CreateTime, MsgType, Content, MsgId} = that.post();    .....    that.success('')  }    /*  * 事件  * 用于處理微信推過來的事件消息，例如點擊菜單等  */  async eventAction() {    let that = this;    let {id, signature, timestamp, nonce, openid} = that.get();    let {ToUserName, FromUserName, CreateTime, MsgType, Event, EventKey, Ticket, Latitude, Longitude, Precision} = that.post();    switch (Event) {      case 'subscribe': // 關注公眾號        ...        break;      case 'unsubscribe': // 取消關注公眾號        ...        break;      case 'SCAN': // 已關注掃碼        ...        break;      case 'LOCATION': // 地理位置        ...        break;      case 'CLICK': // 自定義菜菜單        ...        break;      case 'VIEW': // 跳轉        ...        break;      case 'TEMPLATESENDJOBFINISH':// 模版消息發送完畢        ...        break;    }     that.success('')  }}

|--- src| |--- controller //控制器目錄 | | |--- index.js // 處理微信推送的消息，上面有寫到| | |--- common.js // 一些公共方法| | |--- open // 開放給其他業務服務的api接口| | | |--- wx.js| | |--- private // 放一些內部調用的方法，調用微信api的方法主要在這里面| | | |--- wx.js

// src/controller/common.jsimport axios from 'axios'import {baseSql} from "./unit";module.exports = class extends think.Controller {  // 獲取appinfo  async getWxConfigById(id) {    let that = this;    let data = await that.cache(`wx_config:wxid_${id}`, async () => {      // 數據庫內取      let info = await that.model('wx_config', baseSql).where({id: id}).find();      if (!think.isEmpty(info)) {        return info      }    })    return data || {}  }  // 獲取access_token  async getAccessToken(id) {    let that = this;    let accessToken = await that.cache(`wx_access_token:wxid_${id}`, async () => {      let {appid, secret} = await that.getWxConfigById(id);      let {data} = await axios({        method: 'get',        url: `https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=${appid}&secret=${secret}`      });      return data.access_token    });    return accessToken  }}

// src/controller/open/wx.jsasync __before() {  let that = this;  let wxid = that.get('wxid');  if (think.isEmpty(wxid)) {    return that.json({code: 1, msg: 'wxid不存在'})  }  that.wxConfig = await that.controller('common').getWxConfigById(wxid);  if (think.isEmpty(that.wxConfig)) {    return that.json({code: 1, msg: 'wxid不存在'})  }}

// src/controller/open/wx.jsasync get_access_tokenAction() {  let that = this;  let accessToken = await that.controller('common').getAccessToken(that.wxConfig.id);  return that.json({code: 0, msg: '', data: {access_token: accessToken}})}

// src/controller/open/wx.jsasync get_wxsdk_configAction() {  let that = this;  let {url} = that.get();  if (think.isEmpty(url)) {    return that.json({code: 1, msg: '參數不正確'})  }  let sdkConfig = await that.controller('private/wx').getSdkConfig(that.wxConfig.id, url);  return that.json({code: 0, msg: '', data: sdkConfig})}// src/controller/private/wx.jsconst sha1 = require('sha1');const getTimestamp = () => parseInt(Date.now() / 1000)const getNonceStr = () => Math.random().toString(36).substr(2, 15)const getSignature = (params) => sha1(Object.keys(params).sort().map(key => `${key.toLowerCase()}=${params[key]}`).join('&'));async getSdkConfig(id, url) {  let that = this;  let {appid} = await that.controller('common').getWxConfigById(id);  let shareConfig = {    nonceStr: getNonceStr(),    jsapi_ticket: await that.getJsapiTicket(id),    timestamp: getTimestamp(),    url: url  }  return {    appId: appid,    timestamp: shareConfig.timestamp,    nonceStr: shareConfig.nonceStr,    signature: getSignature(shareConfig)  }}

// src/controller/open/wx.jsasync get_userinfoAction() {  let that = this;  let {openid} = that.get();  if (think.isEmpty(openid)) {    return that.json({code: 1, msg: '參數不正確'})  }  let userInfo = await that.controller('private/wx').getUserInfo(that.wxConfig.id, openid);  if (think.isEmpty(userInfo)) {    return that.json({code: 1, msg: 'openid不存在', data: null})  }  return that.json({code: 0, msg: '', data: userInfo})}// src/controller/private/wx.jsasync getUserInfo(id, openid) {  let that = this;  let userInfo = await that.cache(`wx_userinfo:wxid_${id}:${openid}`, async () => {    //先取數據庫    let model = that.model('wx_userinfo', baseSql);    let userInfo = await model.where({wx_config_id: id, openid: openid}).find();    if (!think.isEmpty(userInfo) && userInfo.subscribe == 1 && userInfo.unionid != null) {      return userInfo    }    //如果數據庫內沒有，取新的存入數據庫    let accessToken = await that.controller('common').getAccessToken(id);    let url = `https://api.weixin.qq.com/cgi-bin/user/info?access_token=${accessToken}&openid=${openid}&lang=zh_CN`;    let {data} = await axios({method: 'get', url: url});    if (data.openid) {      //命中修改，沒有命中添加      let resId = await model.thenUpdate(        Object.assign(data, {wx_config_id: id}),        {openid: openid, wx_config_id: id});      return await model.where({id: resId}).find();    }  })  return userInfo}

// src/controller/open/wx.jsasync send_msg_textAction() {  let that = this;  let {list} = that.post();  if (think.isEmpty(list)) {    return that.json({code: 1, msg: '參數不正確'})  }  that._sendMsgTextList(that.wxConfig.id, list);  return that.json({code: 0, msg: '', data: null}) }  async _sendMsgTextList(wxid, list) {  let that = this;  let apiWxController = that.controller('private/wx');  for (let item of list) {    let data = await apiWxController.sendMsgText(wxid, item.openid, item.text)  }}// src/controller/private/wx.jsasync sendMsgText(id, openid, content) {  let that = this;  let accessToken = await that.controller('common').getAccessToken(id);  let url = `https://api.weixin.qq.com/cgi-bin/message/custom/send?access_token=${accessToken}`  let {data} = await axios({    method: 'post', url: url, data: {"msgtype": 'text', "touser": openid, "text": {"content": content}}  })  return data;}