微信小步伐订阅消息提醒-云函数

微信小步伐消息订阅分2种：
1.一次性订阅：用户订阅一次就可以推送一次，如果需要多次提醒需要多次订阅。
2.长期订阅：只有公共服务领域，如政务、医疗、交通、金融和教导等。‌在用户订阅后，在很长一段时间内多次推送消息。
步骤：
1.微信公众平台选择消息模板，选用后，我的模板-查看详情里会有模板id，消息格式等信息，代码里会用到

2.微信开辟者工具
（1）订阅消息按钮

1. // index.wxml
3. <button bindtap="requestMessage" type="default" disabled="{{isAdded}}">{{isAdded ? '已订阅新任务提醒':'订阅新任务提醒'}}</button>

复制代码

（2）点击按钮变乱引导用户授权

1. async requestMessage() {
2.       wx.requestSubscribeMessage({
3.       tmplIds: ['xxxxxx'],   // xxxxxx填选用的模板ID
4.       success: (res) => {
5.           if (res[templateId] === 'accept') {
6.             // 用户同意
7.             this.saveOpenId() // 记录用户openId，页面可以以此判断用户有无订阅消息
8.             
9.             wx.showToast({
10.               title: '授权成功'
11.             })
12.           } else if (res[templateId] === 'reject'){
13.             // 用户拒绝，弹窗和用户确认是否取消订阅（防止用户误操作）引导用户去设置界面重新订阅
14.             this.setData({
15.               showSetModel: true // 自定义弹窗
16.             })
17.           } else {
18.             wx.showToast({
19.               title: '授权订阅信息有误'
20.             })
21.           }
22.          
23.       },
24.       fail: (err) => {
25.           // 20004:用户关闭了主开关，无法进行订阅,引导开启
26.           if(err.errCode === 20004) {
27.             this.setData({
28.               showSetModel: true
29.             })
30.           } else {
31.             wx.showModal({
32.               title: '提示',
33.               content: err.errMsg,
34.               showCancel: false
35.             })
36.           }
37.       },
38.       })
39.   },

复制代码

如果用户点击拒绝，引导用户去设置页打开开关

1. // index.wxml
3. <view class="jumpSetModel" wx:if="{{showSetModel}}">
4.       <view class="box">
5.       <view class="title">提示</view>
6.         <view class="content">您已取消订阅通知消息，如果想重新订阅该消息可以点击去设置开启</view>
7.         <view class="button">
8.           <button class="cancel" catchtap="closeSetModel">不了</button>
9.           <button class="confirm" open-type="openSetting" bindopensetting="openSetCallback">去设置</button>
10.         </view>
11.       </view>
12.     </view>

复制代码

1. // 用户从设置页返回会触发下面的事件，从而得知用户有没有打开开关
4. openSetCallback (callback) {
5.   wx.getSetting({
6.     withSubscriptions: true,
7.     success: res => {
8.       const tempId = 'xxx' //templateId
10.             // 判断用户允许或拒绝总是保持是否推送消息的选择, 如果选择过的话再点击就不显示了，判断有没有itemSettings并且有没有这个订阅消息的模板id
11.             if (res.subscriptionsSetting.itemSettings && res.subscriptionsSetting.itemSettings[tempId]) {
12.               if (res.subscriptionsSetting.itemSettings[tempId] == 'accept') {
13.                 // 打开开关
14.                 this.saveOpenId()
15.               } else {
16.                 // 未打开开关
17.               }
18.             } else {
19.               // 没有对应templateId的数据
20.             }
21.     }
22.   })
23. },

复制代码

如果想表现用户是否订阅过消息，需要记载用户openid，在页面进来时查询一下数据库

1. // index.js
3. onLoad() {
4.   this.checkStatus()
5. },
6. async checkStatus() {
7.   const currentUser = await wx.cloud.callFunction({name: 'getOpenId'})
8.   const currentOpenId = currentUser.result // 当前用户openid
9.   wx.cloud.database().collection('user-list').where({_openid: getApp().globalData.currentOpenId}).get().then(res => {
10.     this.setData({
11.       isAdded: res.data.length > 0 // 如果查询到数据就代表订阅过
12.     })
13.   })
14. }

复制代码

使用到的云函数：

1. // getOpenId  获取用户openId
3. // 云函数入口文件
4. const cloud = require('wx-server-sdk')
6. cloud.init({ // 初始化云开发环境
7.   env: cloud.DYNAMIC_CURRENT_ENV // 当前环境的常量
8. })
10. // 云函数入口函数
11. exports.main = async (event, context) => {
12.   // 返回当前用户的身份信息，用于数据库记录和查询
13.   return cloud.getWXContext().OPENID
14. }

复制代码

1. // saveOpenId  保存用户openId
3. // 云函数入口文件
4. const cloud = require('wx-server-sdk')
6. cloud.init({ env: cloud.DYNAMIC_CURRENT_ENV }) // 使用当前云环境
8. // 云函数入口函数
9. exports.main = async (event, context) => {
10.   const wxContext = cloud.getWXContext()
11.   const db = cloud.database()
13.   return await db.collection('user-list').add({
14.     data: {
15.       _openid: wxContext.OPENID
16.     }
17.   })
18. }

复制代码

当满足需求，发送订阅消息，可以是按钮触发或者别的逻辑，下面列出设置订阅消息表现的云函数

1. // signMessage  订阅消息设置
4. // 云函数入口文件
5. const cloud = require('wx-server-sdk')
6. cloud.init()
8. exports.main = async (event, context) => {
9.   try {
10.    
11.     await cloud.openapi.subscribeMessage.send({
12.       touser: event._openid, // 发送通知给谁的openid
13.       data: {
14.         thing1: {
15.           value: event.name // 调用云函数可传参进来
16.         },
17.         thing3: {
18.           value: event.title
19.         }
20.       },
21.       
22.       templateId: 'xxx', // 模板ID
23.       page: 'pages/home/index' // 这个是发送完服务通知用户点击消息后跳转的页面
24.     })
25.     // 发送完毕就清空记录用户openId的表，再次查询的时候，显示未订阅，按钮可再次点击进行订阅
26.     return await cloud.callFunction({name: 'clearTable', data: {tableName: 'user-list'}})
27.   } catch (err) {
28.     console.log("Error while sending message:", err);
29.     return err
30.   }
31. }

复制代码

1. // clearTable  清空数据库中的表
3. // 云函数入口文件
4. const cloud = require('wx-server-sdk')
6. cloud.init({ env: cloud.DYNAMIC_CURRENT_ENV }) // 使用当前云环境
8. // 云函数入口函数
9. exports.main = async (event, context) => {
10.   const db = cloud.database()
11.   const _ = db.command
13.   return await db.collection(event.tableName).where({
14.     _id: _.neq(null)
15.   })
16.   .remove()
18. }

复制代码

手动触发消息推送，就写一个按钮就好，如果需要定时，比如每日签到提醒就需要用到定时器

1. // index.wxml
4. <view class="save" bindtap="sendMessage">发送消息</view>
9. // index.js
11. //发送消息
12.   sendMessage() {
13.           wx.cloud.callFunction({
14.             name: 'signMessage',
15.             //data是用来传给云函数event的数据，你可以把你当前页面获取消息填写到服务通知里面
16.             data: {
17.                 action: 'sendSubscribeMessage',
18.                 title:'xxx',
19.                 name:'xxx',
20.                 _openid: user._id, //需要发送用户的openid
21.             },
22.             success: res => {
23.                 wx.showToast({
24.                 title: '发送成功',
25.                 })
26.                 resolve(res);
27.             },
28.             fail: err => {
29.                 wx.showToast({
30.                 icon: 'none',
31.                 title: '调用失败',
32.                 })
33.                 reject(new Error('[云函数] [openapi] subscribeMessage.send 调用失败'))
34.             }
35.           })
36.   }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。