小程序消息订阅-uniapp实现

// 订阅消息授权async function requestSubscribeMessage() {  try {    const res = await uni.requestSubscribeMessage({      tmplIds: ['模板ID1', '模板ID2'], // 需要订阅的模板ID列表      success: (res) => {        console.log('订阅成功', res);        // 处理订阅成功的逻辑      },      fail: (err) => {        console.log('订阅失败', err);        // 处理订阅失败的逻辑      }    });    return res;  } catch (error) {    console.log('订阅消息失败', error);    return false;  }}

// 后端发送订阅消息示例（Node.js）const axios = require('axios');async function sendSubscribeMessage(openid, templateId, data, page) {  try {    // 获取access_token    const tokenRes = await axios.get(`https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=${appid}&secret=${secret}`);    const accessToken = tokenRes.data.access_token;    // 发送订阅消息    const sendRes = await axios.post(      `https://api.weixin.qq.com/cgi-bin/message/subscribe/send?access_token=${accessToken}`,      {        touser: openid, // 用户openid        template_id: templateId, // 模板ID        page: page, // 点击消息跳转的页面        data: data // 模板数据      }    );    return sendRes.data;  } catch (error) {    console.log('发送订阅消息失败', error);    return false;  }}

<viewclass="container">    <button @click="checkAndSubscribe"type="primary">订阅消息</button></view>

// 检查并订阅消息async checkAndSubscribe() {  try {    // 1. 尝试请求订阅    const subscribeRes = await this.requestSubscribe();    // 2. 根据订阅结果处理    if (subscribeRes) {      console.log('订阅成功');    } else {      // 3. 订阅失败，检查权限状态      await this.checkPermissionStatus();    }  } catch (error) {    console.log('订阅流程出错', error);    uni.showToast({      title: '操作失败，请重试',      icon: 'none'    });  }},// 请求订阅消息async requestSubscribe() {  return new Promise((resolve, reject) => {    uni.requestSubscribeMessage({      tmplIds: [this.templateId],      success: (res) => {        console.log('订阅结果', res);        if (res[this.templateId] === 'accept') {          uni.showToast({            title: '订阅成功',            icon: 'success'          });          resolve(true);        } else if (res[this.templateId] === 'reject') {          console.log('用户拒绝订阅');          resolve(false);        } else if (res[this.templateId] === 'ban') {          console.log('用户被禁止订阅');          uni.showToast({            title: '您已被禁止订阅消息',            icon: 'none'          });          resolve(false);        } else {          console.log('订阅状态未知', res[this.templateId]);          resolve(false);        }      },      fail: (err) => {        console.log('请求订阅失败', err);        resolve(false);      }    });  });},// 检查权限状态async checkPermissionStatus() {  return new Promise((resolve) => {    uni.getSetting({      success: (res) => {        console.log('当前权限设置', res.authSetting);        // 检查订阅消息权限        const hasSubscribePermission = res.authSetting['scope.subscribeMessage'];        if (hasSubscribePermission === false) {          // 权限被拒绝，引导用户去设置页面          this.guideToSetting();        } else {          // 权限未设置或已允许，可能是其他原因导致订阅失败          uni.showToast({            title: '订阅失败，请稍后重试',            icon: 'none'          });        }        resolve();      },      fail: (err) => {        console.log('获取设置失败', err);        resolve();      }    });  });},// 引导用户去设置页面guideToSetting() {  uni.showModal({    title: '需要权限',    content: `您需要开启${this.templateTitle}的订阅权限才能接收相关通知，是否前往设置页面开启？`,    confirmText: '去设置',    cancelText: '暂不开启',    success: (modalRes) => {      if (modalRes.confirm) {        this.openSetting();      }    }  });},// 打开设置页面openSetting() {  uni.openSetting({    success: (settingRes) => {      console.log('设置页面操作结果', settingRes.authSetting);      // 检查用户是否开启了订阅消息权限      if (settingRes.authSetting['scope.subscribeMessage']) {        uni.showToast({          title: '权限开启成功',          icon: 'success'        });        // 可以再次尝试订阅        this.requestSubscribe();      } else {        uni.showToast({          title: '权限未开启',          icon: 'none'        });      }    },    fail: (err) => {      console.log('打开设置页面失败', err);      uni.showToast({        title: '打开设置页面失败',        icon: 'none'      });    }  });}