Nodejs 微信小程序消息推送的实现

下面我将为你介绍“Nodejs 微信小程序消息推送的实现”的完整攻略。

一、前置条件

在进行微信小程序消息推送的实现前，你需要先做好以下准备工作：

1.拥有一个微信小程序
2.已申请并获得微信小程序的 AppID 和 AppSecret
3.已在微信小程序后台配置了消息模板，并获得消息模板 ID
4.已搭建 Node.js 开发环境，安装了相关模块（如 request 等）

二、实现步骤

1.获取 access_token

在进行消息推送前，你需要先获取 access_token。access_token 是调用微信小程序 API 的重要凭证，有效时长为 2 小时。

示例代码：

const request = require('request');

const APPID = '你的小程序 AppID';
const APPSECRET = '你的小程序 AppSecret';

// 获取 access_token
const getAccessToken = () => {
  return new Promise((resolve, reject) => {
    const url = `https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=${APPID}&secret=${APPSECRET}`;
    request(url, (error, response, body) => {
      if (!error && response.statusCode === 200) {
        const result = JSON.parse(body);
        resolve(result.access_token);
      } else {
        reject(error);
      }
    });
  });
}

2.发送模板消息

获取到 access_token 后，你就可以使用模板消息接口发送消息了。示例代码如下：

const sendTemplateMsg = (access_token, openid, templateId, formId, data) => {
  return new Promise((resolve, reject) => {
    const url = `https://api.weixin.qq.com/cgi-bin/message/wxopen/template/send?access_token=${access_token}`;
    const options = {
      method: 'POST',
      url: url,
      json: true,
      headers: {
        'content-type': 'application/json'
      },
      body: {
        touser: openid,
        template_id: templateId,
        form_id: formId,
        data: data
      }
    };
    request(options, (error, response, body) => {
      if (!error && response.statusCode === 200) {
        resolve(body);
      } else {
        reject(error);
      }
    });
  });
}

以上代码通过 request 模块调用微信小程序模板消息接口，具体参数详解如下：

• access_token：上一步获取到的 access_token；
• touser：要推送的用户的 openid；
• template_id：在小程序后台配置的消息模板 ID；
• form_id：用户提交的表单 ID；
• data：模板消息的数据，格式为键值对。

三、示例说明

下面我们通过两个示例演示上述实现步骤。

示例 1：推送订单支付成功消息

在用户支付成功后，我们可以通过小程序向用户发送订单支付成功的消息。

示例代码：

const APPID = '你的小程序 AppID';
const APPSECRET = '你的小程序 AppSecret';
const OPENID = '要推送的用户 openid';
const TEMPLATE_ID = '微信小程序消息模板 ID';
const FORM_ID = '用户提交的表单 ID';

// 订单支付成功消息数据
const data = {
  keyword1: {
    value: '订单号123456789'
  },
  keyword2: {
    value: '¥9.99'
  },
  keyword3: {
    value: '支付成功'
  },
  keyword4: {
    value: '2022-01-01 00:00:00'
  }
};

// 获取 access_token
getAccessToken().then(access_token => {
  // 发送模板消息
  sendTemplateMsg(access_token, OPENID, TEMPLATE_ID, FORM_ID, data).then(result => {
    console.log(result);
  }).catch(error => {
    console.error(error);
  });
}).catch(error => {
  console.error(error);
});

以上代码中，我们设置了要推送的用户 openid、消息模板 ID、用户提交的表单 ID 和消息模板数据，然后通过 getAccessToken 函数获取 access_token 并调用 sendTemplateMsg 函数推送消息。

示例 2：推送会员到期提醒消息

当用户会员即将到期时，我们可以通过小程序向用户发送会员到期提醒的消息。

示例代码：

// 会员到期提醒消息数据
const data = {
  keyword1: {
    value: 'VIP会员'
  },
  keyword2: {
    value: '到期时间：2022-01-01'
  },
  keyword3: {
    value: '请尽快续费'
  }
};

// 获取 access_token
getAccessToken().then(access_token => {
  // 获取所有用户 openid
  const users = getAllUsers(); // 假设 getAllUsers 函数可以获取所有用户的 openid

  // 使用 Promise.all 实现并行发送模板消息
  Promise.all(users.map(openid => {
    return sendTemplateMsg(access_token, openid, TEMPLATE_ID, FORM_ID, data);
  })).then(results => {
    console.log(results);
  }).catch(error => {
    console.error(error);
  });
}).catch(error => {
  console.error(error);
});

以上代码中，我们通过 getAllUsers 函数获取所有用户的 openid，并使用 Promise.all 实现并行发送模板消息。这样可以大大提高消息发送效率。