微信公众号_订阅号_源码_用户管理_自定义菜单_自动回复用户消息_素材上传与下载

 一个公众号，最多可以创建 100 个标签

查看手册，根据 请求 url，以及参数说明，请求体格式，进行编程 。

// 前端面试题：
// 每当执行栈为空时，就检查微任务，有则进栈执行
// 当检查无微任务了，再检查宏任务，有则取一个宏任务进栈执行，执行完了，再检查有没有微任务......repeat

// 微任务：

// 1. process.nextTick （nodejs）
// 2. Promise.then catch

// 宏任务：

// 1. I/O （click事件、fs.writeFile）
// 2. setTimeout
// 3. setInterval
// 4. setImmediate （nodejs）
// 5. requestAnimationFrame

实例源代码：

config/index.js

•  

  const prefix = ‘https://api.weixin.qq.com/cgi-bin/‘;
  module.exports = {
      SERVER_IP: ‘localhost‘,
      SERVER_PORT: ‘3000‘,
      DB_PORT: ‘27017‘,
      
      token: ‘FinnKou‘,
      APPID: ‘wxba159db33d7d22c1d32d‘,
      APPSECRET: ‘62ad175995d2f246680fcb6218d77b24e31‘,
      
      prefix : prefix,
      ACCESSTOKEN: `${prefix}token?grant_type=client_credential&`,
  };

   

WeChat/index.js

•  

  /****
   *  access_token 对象____中控服务器----公众号的全局唯一接口调用凭据
   *
   *  {
   *      access_token: ‘17_Nq3M5HMdnX3Xwkbi48uPEaVZ4qnh_H5B8HOzBy-DnXqLz6s9h3ALAPd6sk11K0zclzu0Ap3cZciBVp2aml9EuJGmSZ-iGKe7gFOwVUEYGhOB70Il9GeCMWtppgpXcdMzm7YaqVE_W55L1bgfBEQcAHAGJV‘,
   *      expires_in: 7200
   *  }
   ****/
  const promiseRequest = require(‘request-promise-native‘);
  const {APPID, APPSECRET, ACCESSTOKEN} = require(‘../config‘);
  const {writeFile, readFile} = require(‘fs‘);
  
  class WeChat{
      getValidAccessToken(){
          // 1. 判断 wechat 对象里的  access_token
          if(this.access_token && this.isValidAccessToken(this)){
              return Promise.resolve({
                  access_token: this.access_token,
                  expires_in: this.expires_in
              });
          }else{
              return this.readAccessToken().then(async objAccessToken=>{
                  if  (this.isValidAccessToken(objAccessToken)){
                      return objAccessToken;    //
                  }else{
                      const newObjAccessToken = await this.requestAccessToken();
                      await this.saveAccessToken(newObjAccessToken);
                      return newObjAccessToken;
                  }
              }).catch(async err=>{
                  const newObjAccessToken = await this.requestAccessToken();
                  await this.saveAccessToken(newObjAccessToken);
                  return newObjAccessToken;
              }).then(objAccessToken=>{
                  // 更新 WeChat
                  this.access_token = objAccessToken.access_token;
                  this.expires_in = objAccessToken.expires_in;
                  
                  // 返回 Promise 的 access_token
                  return Promise.resolve(objAccessToken);
              });
          };
      }
      
      readAccessToken(){    // 一、读取access_token的方法
          return new Promise((resolve, reject)=>{
              readFile(‘./access_token.txt‘, (err, buffer)=>{
                  if(err){
                      reject(‘Read ./access_token.txt‘ + err);
                  }else{
                      resolve(JSON.parse(buffer.toString()));
                  }
              });
          });
      }
      
      isValidAccessToken({expires_in}){    // 二、判断 access_token 是可用的吗？
          return expires_in > Date.now();
      };
      
      async requestAccessToken(){    // 三、发送请求 getAccessToken() 获取 access_token
          // 1. access_token 请求 url
          const url = `${ACCESSTOKEN}appid=${APPID}&secret=${APPSECRET}`;
          
          // 2. POST 请求 access_token 对象
          const objAccessToken = await promiseRequest({
              method: ‘POST‘,
              url,
              json: true
          });
          
          // 重写过期时间，提前 5 分钟刷新
          objAccessToken.expires_in = Date.now() - (7200 - 300)*1000;
          return objAccessToken;
      }
      
      saveAccessToken(objAccessToken){    // 四、保存 access_token 到文件
          return new Promise((resolve, reject)=>{    // 异步执行文件写完
              writeFile(‘./access_token.txt‘, JSON.stringify(objAccessToken), err=>{
                  if(err){
                      reject("Write Success.");
                  }else{
                      resolve(‘access_token 最新已保存‘);
                  };
              });
          });
      }
  };
  
  const wechat = new WeChat();
  
  module.exports = {
      wechat
  };

   

WeChat/fans.js

•  

  const {prefix} = require(‘../config‘);
  const promiseRequest = require(‘request-promise-native‘);
  
  const tagsCreate = `${prefix}tags/create?`;
  const tagsGet = `${prefix}tags/get?`;
  const tagsUpdate = `${prefix}tags/update?`;
  const tagsDelete = `${prefix}tags/delete?`;
  
  const usersGet = `${prefix}user/tag/get?`;
  const usersBatch = `${prefix}tags/members/batchtagging?`;
  
  const allUserGet = `${prefix}user/get?`;
  
  const userInfo = `${prefix}user/info?`;
  
  const sendall = `${prefix}message/mass/sendall?`;
  
  module.exports = {
  /**** 标签操作 ****/
      // 增：根据 idName 创建一个标签
      async createTag(wechat, idName){
          const {access_token} = await wechat.getValidAccessToken();
          const url = `${tagsCreate}access_token=${access_token}`;
          return await promiseRequest({method: ‘POST‘, url, json: true, body:{"tag":{"name": idName}}});
      },
      
      // 查：根据 idNumber idName 获取一个标签
      async getTag(wechat){
          const {access_token} = await wechat.getValidAccessToken();
          const url = `${tagsGet}access_token=${access_token}`;
          return await promiseRequest({method: ‘GET‘, url, json: true});
      },
      
      // 改：根据 idNumber newName 修改一个标签
      async updateTag(wechat, idNumber, newName){
          const {access_token} = await wechat.getValidAccessToken();
          const url = `${tagsUpdate}access_token=${access_token}`;
          return await promiseRequest({method: ‘POST‘, url, json: true, body:{"tag":{"id": idNumber, "name": newName}}});
      },
      
      // 删：根据 idNumber 删除一个标签
      async deleteTag(wechat, idNumber){
          const {access_token} = await wechat.getValidAccessToken();
          const url = `${tagsDelete}access_token=${access_token}`;
          return await promiseRequest({method: ‘POST‘, url, json: true, body:{"tag":{"id": idNumber}}});
      },
      
  /**** 根据标签 操作用户 ****/
      // 查：根据 idNumber 获取用户
      async getUsersByTag(wechat, idNumber, next_openid=‘‘){
          const {access_token} = await wechat.getValidAccessToken();
          const url = `${usersGet}access_token=${access_token}`;
          return await promiseRequest({method: ‘POST‘, url, json: true, body:{id:idNumber, next_openid}});
      },
      
      // 增：给一个标签 idNumber 添加用户 openid_list
      async addUsersToTag(wechat, idNumber, openid_list){
          const {access_token} = await wechat.getValidAccessToken();
          const url = `${usersBatch}access_token=${access_token}`;
          return await promiseRequest({method: ‘POST‘, url, json: true, body:{id:idNumber, openid_list}});
      },
      
  /**** 获取公众号所有 用户 ****/
      async getAllUser(wechat, next_openid=‘‘){
          const {access_token} = await wechat.getValidAccessToken();
          const url = `${allUserGet}access_token=${access_token}&next_openid=${next_openid}`;
          return await promiseRequest({method: ‘GET‘, url, json: true});
      },
  
  /**** 根据 openid 操作用户 ****/
      // 查：根据 openid 获取用户信息
      async getUserInfo(wechat, openid){
          const {access_token} = await wechat.getValidAccessToken();
          const url = `${userInfo}access_token=${access_token}&openid=${openid}`;
          return await promiseRequest({method: ‘GET‘, url, json: true});
      },
  /**** 群发消息给 标签 下的粉丝 ****/
      async sendToAllByTag(wechat, body){
          const {access_token} = await wechat.getValidAccessToken();
          const url = `${sendall}access_token=${access_token}`;
          return await promiseRequest({method: ‘POST‘, url, json:true, body});
      }
  };

   

WeChat/menu.js

•  

  const {prefix} = require(‘../config‘);
  const promiseRequest = require(‘request-promise-native‘);
  
  const menuDelete = `${prefix}menu/delete?`;
  const menuCreate = `${prefix}menu/create?`;
  
  module.exports = {
      async deleteMenu(wechat){
          const {access_token} = await wechat.getValidAccessToken();
          const url = `${menuDelete}access_token=${access_token}`;
          return await promiseRequest({method: ‘Get‘, url, json: true});
      },
      
      async createMenu(wechat, menu){
          const {access_token} = await wechat.getValidAccessToken();
          const url = `${menuCreate}access_token=${access_token}`;
          return await promiseRequest({method: ‘POST‘, url, json: true, body: menu});
      },
      
      menu: {
          "button":[
              {
                  "type":"click",
                  "name":"一级菜单?",
                  "key":"click"
              },
              {
                  "name":"一级菜单?",
                  "sub_button":[
                      {
                          "name":"百度",
                          "url":"http://www.baidu.com/",
                          "type":"view"
                      },
                      {
                          "name": "扫码带提示??",
                          "type": "scancode_waitmsg",
                          "key": "rselfmenu_0_0"
                      },
                      {
                          "name": "扫码推事件",
                          "type": "scancode_push",
                          "key": "rselfmenu_0_1"
                      },
                      {
                          "name": "系统拍照发图",
                          "type": "pic_sysphoto",
                          "key": "rselfmenu_1_0",
                          "sub_button": [ ]
                      },
                      {
                          "name": "拍照或者相册发图",
                          "type": "pic_photo_or_album",
                          "key": "rselfmenu_1_1",
                          "sub_button": [ ]
                      },
                  ]
              },
              {
                  "name":"一级菜单??",
                  "sub_button":[
                      {
                          "name": "微信相册发图",
                          "type": "pic_weixin",
                          "key": "rselfmenu_1_2"
                      },
                      {
                          "name": "发送位置",
                          "type": "location_select",
                          "key": "rselfmenu_2_0"
                      },
                      // {
                      //   "type": "media_id",
                      //   "name": "图片",
                      //   "media_id": "MEDIA_ID1"
                      // },
                      // {
                      //   "type": "view_limited",
                      //   "name": "图文消息",
                      //   "media_id": "MEDIA_ID2"
                      // }
                  ]
              }
          ]
      }
  };

   

WeChat/mediaSpace.js

•  

  /****
   图片（image）    2M    支持PNG\JPEG\JPG\GIF格式
   语音（voice）    2M    播放长度不超过60s，支持AMR\MP3格式
   视频（video）    10MB    支持MP4格式 ---- http GET 方式获取
   缩略图（thumb）    64KB    支持JPG格式
   ****/
  
  const {prefix} = require(‘../config‘);
  
  const promiseRequest = require(‘request-promise-native‘);
  const request = require(‘request‘);
  const {createReadStream, createWriteStream} = require(‘fs‘);
  
  const mediaUpload = `${prefix}media/upload?`;
  const mediaGet = `${prefix}media/get?`;
  
  const materialNews = `${prefix}material/add_news?`;
  const materialNewsPic = `${prefix}media/uploadimg?`;
  const materialOthers = `${prefix}material/add_material?`;
  
  const materialGet = `${prefix}material/get_material?`;
  
  module.exports = {
      mediaSpace: {
      
      /*------------------------ 临时素材 ------------------------*/
          // async upload(wechat, type, filePath){
          //     const {access_token} = await wechat.getValidAccessToken();
          //     const url = `${mediaUpload}access_token=${access_token}&type=${type}`;
          //
          //     // 以 form 表单方式 发送 post 请求上传 文件流
          //     return await promiseRequest({method: ‘POST‘, url, json: true, formData:{"media": createReadStream(filePath)}});
          // },
          
          // async download(wechat, media_id, type, filePath){
          //     const {access_token} = await wechat.getValidAccessToken();
          //     let url = `${mediaGet}access_token=${access_token}&media_id=${media_id}`;
          //
          //     if(type === ‘video‘){
          //         url.replace(‘https‘, ‘http‘);
          //         return await promiseRequest({method: ‘GET‘, url, json:true});
          //     }else{
          //         await new Promise((resolve, reject)=>{
          //             request(url)    // 返回一个可读流，使用管道写入文件
          //                 .pipe(createWriteStream(filePath))
          //                 .once(‘close‘, err=>{
          //                     resolve(err);
          //                 });
          //         });
          //     };
          // },
          
      /*------------------------- 素材 ---------------------------*/
          async upload(wechat, type, filePathOrNewsBody, isMeterialOrVideoBody = true){
              const {access_token} = await wechat.getValidAccessToken();
              let options = {method: ‘POST‘, json: true};
              
              if(isMeterialOrVideoBody === false){
                  options.url = `${mediaUpload}access_token=${access_token}&type=${type}`;
                  // 以 form 表单方式 发送 post 请求上传 文件流
                  options.formData = {media:createReadStream(filePathOrNewsBody)};
              }else if(type === ‘news‘){
                  options.url = `${materialNews}access_token=${access_token}`;
                  options.body = filePathOrNewsBody;
              }else if(type === ‘newsImage‘){
                  options.url = `${materialNewsPic}access_token=${access_token}`;
                  options.formData = {media:createReadStream(filePathOrNewsBody)};
              }else{
                  options.url = `${materialOthers}access_token=${access_token}&type=${type}`;
                  console.log(options.url);
                  options.formData = {media:createReadStream(filePathOrNewsBody)};
                  if(type === ‘video‘){
                      options.body = isMeterialOrVideoBody;
                  };
              };
              return await promiseRequest(options);
          },
          
          async download(wechat, media_id, type, filePath, isMeterial = true){
              const {access_token} = await wechat.getValidAccessToken();
              let url = `${materialGet}access_token=${access_token}`;
              
              if(isMeterial === false){
                  url = `${mediaGet}access_token=${access_token}&media_id=${media_id}`;
                  if(type === ‘video‘){
                      url.replace(‘https‘, ‘http‘);
                      return await promiseRequest({method: ‘GET‘, url, json:true});
                  }else{
                      return await new Promise((resolve, reject)=>{
                          request(url)    // 返回一个可读流，使用管道写入文件
                              .pipe(createWriteStream(filePath))
                              .once(‘close‘, err=>{
                                  resolve(err);
                              });
                      });
                  }
              }else if(type === ‘video‘ || type ===  ‘news‘){
                  return await promiseRequest({method: ‘POST‘, url, json: true,
                      body: {media_id}
                  });
              }else{
                  await new Promise((resolve, reject)=>{
                      console.log(url);
                      request({method: ‘POST‘, url, json: true, body: {media_id}})
                          .pipe(createWriteStream(filePath))    // 返回一个可读流， 使用管道写入文件
                          .once(‘close‘, resolve);
                  });
              };
          },
      }
  };

   

app.js        

•  

  const express = require(‘express‘);
  const {SERVER_PORT} = require(‘./config‘);
  const handleRequest = require(‘./handleRequest‘);
  const {wechat} = require(‘./WeChat‘);
  
  const app = express();
  
  // app.use(express.urlencoded({extended: true}));
  
  // app.use(handleRequest());
  
  app.listen(
      SERVER_PORT,
      err=>console.log(err?err:‘\n\n服务器已启动\n\t\tHunting Happy!‘)
  );
  
  
  /****************************** 自定义菜单 ***************************************/
  // const {menu, deleteMenu, createMenu} = require(‘./WeChat/menu‘);
  //
  // (async ()=>{
  //     console.log(‘---- 先删除菜单 ----‘);    // 如果有 
  //     const deleteRet = await deleteMenu(wechat);
  //     console.log(deleteRet);
  //
  //     console.log(‘---- 再创建菜单 ----‘);
  //     const createRet = await createMenu(wechat, menu);
  //     console.log(createRet);
  // })();
  
  /****************************** 标签 与 用户 *************************************/
  const {
      createTag, getTag, updateTag, deleteTag,    // 标签的 增删改查
      getUsersByTag, addUsersToTag,    // 使用 标签
      getAllUser,    // 获取所有用户
      getUserInfo,    // 获取用户信息
      sendToAllByTag    // 标签 群发
  } = require(‘./WeChat/fans‘);
  
  (async ()=>{
      let ret = await createTag(wechat, ‘0940_HTML5‘);    // 45157 重名
      console.log(‘创建一个标签： ‘);
      console.log(ret);
  
      const {tags} = await getTag(wechat);
      console.log(‘获取所有标签对象： ‘);
      console.log(tags);
      /**
       * [
       { id: 2, name: ‘星标组‘, count: 0 },    // 默认就有的 标签
       { id: 100, name: ‘0920_class‘, count: 0 },
       { id: 101, name: ‘beijing‘, count: 0 }
       ] * */
      if(tags[2]){
          ret = await updateTag(wechat, tags[2].id, ‘BeiPiao‘);
          console.log(‘改标签名字： ‘);
          console.log(ret);
      };
  
      // ret = await deleteTag(wechat, tags[1].id);
      // console.log(‘删除一个标签： ‘);
      // console.log(ret);
  
      const {data: usersId, next_openid} = await getAllUser(wechat);
      console.log(‘获取所有用户： ‘);
      console.log(usersId);
      console.log(next_openid);
  
      ret = await getUserInfo(wechat, usersId.openid[0]);
      console.log(‘查询 usersId[0] 的用户信息： ‘);
      console.log(ret);
      
      // oSX3Z1aufrhsCwuEKXbVRfqOC1Wo 我的 openid
      ret = await sendToAllByTag({
          filter:{
              is_to_all: false,
              tag_id: ‘oSX3Z1aufrhsCwuEKXbVRfqOC1Wo‘
          },
          text:{
              content: ‘元旦快乐！‘
          },
          msgtype: ‘text‘
      });
  })();
  
  /****************************** 素材上传下载 *************************************/
  // const {mediaSpace} = require(‘./WeChat/mediaSpace‘);
  // const {resolve} = require(‘path‘);
  //
  // (async ()=>{
  //     // console.log(‘---- 上传临时媒体素材 ----‘);
  //     // const moose = await mediaSpace.upload(wechat, ‘image‘, resolve(__dirname, ‘./1.jpg‘), false);
  //     // console.log(moose);
  //     /*
  //         {
  //             type: ‘image‘,
  //             media_id: ‘liuEDUcNu68MuWndCSopvv3Qr-d1qdgOKwkefKLVeRTZXdfhUVoC4q6I5viOStT_‘,
  //             created_at: 1545979479
  //         }
  //      */
  //     // console.log(‘---- 下载临时媒体素材 ----‘);
  //     // await mediaSpace.download(
  //     //     wechat,
  //     //     ‘liuEDUcNu68MuWndCSopvv3Qr-d1qdgOKwkefKLVeRTZXdfhUVoC4q6I5viOStT_‘,
  //     //     ‘image‘,
  //     //     ‘./2.jpg‘,
  //     //     false
  //     // );
  //     /*-------------------------------------- 永久素材 ----------------------------------------------*/
  //     // console.log(‘---- 上传永久媒体素材 ----‘);
  //     // const moose = await mediaSpace.upload(wechat, ‘image‘, resolve(__dirname, ‘./1.jpg‘));
  //     // console.log(moose);
  //         /*
  //         *   {
  //                 media_id: ‘bfzYrEwXqmeYiJIdBvbZ1E7Ox7UH8DfiSo66kKWZ4FM‘,
  //                 url: ‘http://mmbiz.qpic.cn/mmbiz_jpg/8hj96GVnlibDVib3LJoyZSJFNpa7aIITL6nvCXrOszRiahQkPoZSQUS5Lpw8RiaibrAGia03JMkeKcibY9B6jcyuAcIhA/0?wx_fmt=jpeg‘
  //             }
  //         * */
  //     console.log(‘---- 下载永久媒体素材 ----‘);
  //     await mediaSpace.download(
  //         wechat,
  //         ‘bfzYrEwXqmeYiJIdBvbZ1JrCiKteRvzzqLK-_hZlBYg‘,
  //         ‘image‘,
  //         ‘./3.jpg‘,
  //     );
  // })();
  // 前端面试题：
  // 每当执行栈为空时，就检查微任务，有则进栈执行
  // 当检查无微任务了，再检查宏任务，有则取一个宏任务进栈执行，执行完了，再检查有没有微任务......repeat
      // 微任务：
          // 1. process.nextTick    （nodejs）
          // 2. Promise.then catch
  
      // 宏任务：
          // 1. I/O （click事件、fs.writeFile）
          // 2. setTimeout
          // 3. setInterval
          // 4. setImmediate （nodejs）
          // 5. requestAnimationFrame

原文：https://www.cnblogs.com/baixiaoxiao/p/10573466.html