- 云开发轮询实现定时推送订阅消息
前言 受众:已有小程序和云开发经验(没有的话照着流程和官方文档也应该可以实现) 关于小程序的消息推送,我了解到的有以下几种实现方式 1、模板消息,已于2020 年 1 月 10 日下线 2、通过服务端的统一服务消息下发推送,[代码]因为模板消息现已下线,现只支持公众号[代码]。统一服务消息官方文档 2、通过关注公众号通过公众号实现长期的消息推送 3、订阅消息,包含一次性订阅消息和长期订阅消息 订阅消息官方文档 关于技术实现的选择 关于小程序的消息推送的几种实现方式,先简单说一下各自的优缺点: 1、统一服务消息 优点:可以长期多次发送 缺点:因为模板消息现已下线,现只支持公众号 2、通过公众号实现 优点:可以长期多次发送 缺点:需要引导关注公众号,没有公众号还得注册一个,以下还有一些注意事项 1、公众号和小程序需要在同一个微信开放平台下,保证拿到相同的UnionID 2、如果需要在消息模板上加上小程序的入口,需要微信公众号和小程序做关联 3、小程序和公众号都必须是认证过的 4、小程序需要提前知道公众号的appid和appsecret 5、发送消息之前需要拿到用户对应于公众号的openid 3、订阅消息实现 订阅消息,包含一次性订阅消息和长期订阅消息,可惜[代码]长期订阅消息只对指定类目开放[代码] 一次性订阅消息 优点:服务端,云开发都可以实现推送 缺点:每次需要授权,每次授权同意只推送一次 哎,没什么可挑的,[代码]最终选择的是订阅消息的一次性订阅消息[代码],下面是微信官方介绍 小程序订阅消息 功能介绍 消息能力是小程序能力中的重要组成,我们为开发者提供了订阅消息能力,以便实现服务的闭环和更优的体验。 订阅消息推送位置:服务通知 订阅消息下发条件:用户自主订阅 订阅消息卡片跳转能力:点击查看详情可跳转至该小程序的页面 [图片] 消息类型 1. 一次性订阅消息 一次性订阅消息用于解决用户使用小程序后,后续服务环节的通知问题。用户自主订阅后,开发者可不限时间地下发一条对应的服务消息;每条消息可单独订阅或退订。 2. 长期订阅消息 一次性订阅消息可满足小程序的大部分服务场景需求,但线下公共服务领域存在一次性订阅无法满足的场景,如航班延误,需根据航班实时动态来多次发送消息提醒。为便于服务,我们提供了长期性订阅消息,用户订阅一次后,开发者可长期下发多条消息。 [代码]目前长期性订阅消息仅向政务民生、医疗、交通、金融、教育等线下公共服务开放,后期将逐步支持到其他线下公共服务业务。[代码] 3. 设备订阅消息 设备订阅消息是一种特殊类型的订阅消息,它属于长期订阅消息类型,且需要完成「设备接入」才能使用。 设备订阅消息用于在设备触发某些需要人工介入的事件时(例如设备发生故障、设备耗材不足等),向用户发送消息通知。详见设备订阅消息文档。 使用说明 步骤一:获取模板 ID 在微信公众平台手动配置获取模板 ID: 登录 https://mp.weixin.qq.com 获取模板,如果没有合适的模板,可以申请添加新模板,审核通过后可使用。 [图片] 步骤二:获取下发权限 一次性订阅消息、长期订阅消息,详见接口 wx.requestSubscribeMessage 设备订阅消息,详见接口 wx.requestSubscribeDeviceMessage 步骤三:调用接口下发订阅消息 一次性订阅消息、长期订阅消息,详见服务端接口 subscribeMessage.send 设备订阅消息,详见服务端接口 hardwareDevice.send 注意事项 用户勾选 “总是保持以上选择,不再询问” 之后,下次订阅调用 wx.requestSubscribeMessage 不会弹窗,保持之前的选择,修改选择需要打开小程序设置进行修改。 实现 设计思路 我这里的需求是纪念日的推送,到用户设置的纪念日当天或者前几天,需要给用户推送一条消息,提醒用户纪念日已到。因为是一次性授权,首先要考虑授权的时机,因此考虑是在用户新增或者编辑纪念日信息那里,设置一个开关,开启时判断通知权限,无权限提醒到设置页开启通知,有权限请求授权,授权成功开关开启,失败或者未开启通知权限开关关闭,最后提交信息到数据库,推送的接口会每天轮询一次,根据这个状态和是否到纪念日提醒时间判断是否进行推送,推送成功重置状态。推送之后用户再次开启推送开关可实现下一次推送,形成一个闭环。 [图片] 实现流程 首先要去小程序后台选择一个模板 然后在新增编辑页面实现设计的逻辑(包含通知权限的判断,请求一次性订阅,失败关闭开关状态,保存数据到数据库) 云开发轮询推送消息(先查出需要推送的数据,然后对应模板的数据格式发送推送) 具体实现 1、选择模板 登录小程序开发后台 - 订阅消息 - 公共模板库搜索选择一个合适的模板,然后在我的模板那里可以查看模板详情,[代码]模板id[代码]和[代码]详情里的字段[代码]在云开发那里需要使用 [图片] [图片] [图片] 2、编辑页代码实现 首先先把开关相关的页面和逻辑实现,这里就不细说。 然后是判断通知权限和请求一次性订阅 2.1、判断通知权限 判断通知权限使用的是wx.getSetting [代码]wx.getSetting({ withSubscriptions: true, success (res) { console.log(res.authSetting) // res.authSetting = { // "scope.userInfo": true, // "scope.userLocation": true // } console.log(res.subscriptionsSetting) // res.subscriptionsSetting = { // mainSwitch: true, // 订阅消息总开关 // itemSettings: { // 每一项开关 // SYS_MSG_TYPE_INTERACTIVE: 'accept', // 小游戏系统订阅消息 // SYS_MSG_TYPE_RANK: 'accept' // zun-LzcQyW-edafCVvzPkK4de2Rllr1fFpw2A_x0oXE: 'reject', // 普通一次性订阅消息 // ke_OZC_66gZxALLcsuI7ilCJSP2OJ2vWo2ooUPpkWrw: 'ban', // } // } } }) [代码] 2.2、请求一次性订阅 请求一次性订阅使用的是wx.requestSubscribeMessage [代码]wx.requestSubscribeMessage({ tmplIds: [''], // 模板id success (res) { } }) [代码] 2.3、把数据存储到云数据库 每个项目数据结构不一样,这里也不展开说 核心代码 [代码] // 是否提醒 onSwitchChange: function (event) { this.setData({ ["dict.isPush"]: event.detail.value }) if (!event.detail.value) { this.setData({ ["dict.pushTime"]: '' }) } if (event.detail.value) { this.checkAndRequestSubscribeMessage() } }, // 检查订阅消息权限,未开启提示前往开启,已开启请求订阅消息 checkAndRequestSubscribeMessage() { let that = this wx.getSetting({ withSubscriptions: true, success(res) { console.log(res.subscriptionsSetting) // 订阅消息总开关是否开启 if (!res.subscriptionsSetting.mainSwitch) { that.subscriptionFailed() wx.showModal({ title: '提示', content: '当前暂未开启接消息提醒,是否前往设置页开启?', success(res) { if (res.confirm) { wx.openSetting() } } }) } else { let templateId = 'c64Gp5-89xyD55rnDr0oBWQNphWlNm_l4MX-Sduuj2c' // 模板ID wx.requestSubscribeMessage({ tmplIds: [templateId], success(res) { console.log(res) // 申请订阅成功,将订阅信息调用云函数存入云开发数据 if (res.errMsg === 'requestSubscribeMessage:ok') { // res[templateId]: 'accept'、'reject'、'ban'、'filter' if (res[templateId] == 'accept') {} else { that.subscriptionFailed() } } }, fail(err) { console.log(err) that.subscriptionFailed() wx.showToast({ title: '订阅失败', icon: 'none' }) } }) } } }) }, // 订阅失败 subscriptionFailed() { this.setData({ ["dict.isPush"]: false }) }, [代码] 3、云开发轮询推送 这里才是重点!!!首先在项目中选择云函数目录右键新建一个云函数,然后就需要在这个云函数中实现轮询推送的代码了,我这里建的云函数是[代码]push[代码] [图片] 3.1、推送 推送使用的是服务端的subscribeMessage.send方法。 这里是的是云调用进行推送,这样可以使用云开发 [代码]subscribeMessage.send[代码]使用需要在云函数代码的[代码]config.json[代码]文件中配置 [代码]subscribeMessage.send[代码] API 的权限,详情 配置如下 [代码] "permissions": { "openapi": ["subscribeMessage.send"] }, [代码] [图片] 请求参数 属性 类型 默认值 必填 说明 touser string 是 接收者(用户)的 openid templateId string 是 所需下发的订阅模板id page string 否 点击模板卡片后的跳转页面,仅限本小程序内的页面。支持带参数,(示例index?foo=bar)。该字段不填则模板无跳转。 data Object 是 模板内容,格式形如 { “key1”: { “value”: any }, “key2”: { “value”: any } } miniprogramState string 否 跳转小程序类型:developer为开发版;trial为体验版;formal为正式版;默认为正式版 lang string 否 进入小程序查看”的语言类型,支持zh_CN(简体中文)、en_US(英文)、zh_HK(繁体中文)、zh_TW(繁体中文),默认为zh_CN 官方请求示例 [代码]const cloud = require('wx-server-sdk') cloud.init({ env: cloud.DYNAMIC_CURRENT_ENV, }) exports.main = async (event, context) => { try { const result = await cloud.openapi.subscribeMessage.send({ "touser": 'OPENID', "page": 'index', "lang": 'zh_CN', "data": { "number01": { "value": '339208499' }, "date01": { "value": '2015年01月05日' }, "site01": { "value": 'TIT创意园' }, "site02": { "value": '广州市新港中路397号' } }, "templateId": 'TEMPLATE_ID', "miniprogramState": 'developer' }) return result } catch (err) { return err } } [代码] [代码]miniprogramState[代码]在正式环境要换成[代码]formal[代码]或注释掉这行 3.2、轮询 轮询使用的云开发的定时触发器 [图片] 定时触发器官方介绍 该功能需开发者工具 1.02.1811270 及以上版本方可使用 从开发者工具 1.02.1910182 开始,新上传的定时触发器内支持使用云调用 如果云函数需要定时 / 定期执行,也就是定时触发,我们可以使用云函数定时触发器。配置了定时触发器的云函数,会在相应时间点被自动触发,函数的返回结果不会返回给调用方。 在需要添加触发器的云函数目录下新建文件 [代码]config.json[代码],格式如下: [代码]{ // triggers 字段是触发器数组,目前仅支持一个触发器,即数组只能填写一个,不可添加多个 "triggers": [ { // name: 触发器的名字,规则见下方说明 "name": "myTrigger", // type: 触发器类型,目前仅支持 timer (即 定时触发器) "type": "timer", // config: 触发器配置,在定时触发器下,config 格式为 cron 表达式,规则见下方说明 "config": "0 0 2 1 * * *" } ] } [代码] 官方示例 下面展示了一些 Cron 表达式和相关含义的示例: */5 * * * * * * 表示每5秒触发一次 0 0 2 1 * * * 表示在每月的1日的凌晨2点触发 0 15 10 * * MON-FRI * 表示在周一到周五每天上午10:15触发 0 0 10,14,16 * * * * 表示在每天上午10点,下午2点,4点触发 0 */30 9-17 * * * * 表示在每天上午9点到下午5点内每半小时触发 0 0 12 * * WED * 表示在每个星期三中午12点触发 [代码]triggers[代码]中的[代码]config[代码]字段可以控制触发的频率,具体开发测试时我使用的是50秒调用一次 [代码] "config": "*/50 * * * * * *" [代码] [代码]这里有个坑,如果代码实现上传并部署云函数之后,左等右等在日志中看不到日志,因为少了一个步骤,在上传并部署云函数之后,需要右键云函数上传触发器,这样才生效,想关闭可以删除触发器[代码] 轮询推送完整代码 config.json [代码]{ "permissions": { "openapi": ["subscribeMessage.send"] }, "triggers": [{ "name": "myTimer", "type": "timer", "config": "0 0 8 * * * *" }] } [代码] index.js [代码]// 云函数入口文件 const cloud = require('wx-server-sdk') // 初始化 cloud cloud.init({ // API 调用都保持和云函数当前所在环境一致 env: cloud.DYNAMIC_CURRENT_ENV }) const db = cloud.database() const _ = db.command const $ = db.command.aggregate const kTableName = '换成自己的表名' // 云函数入口函数 exports.main = async (event, context) => { try { // 从云开发数据库中查询等待发送的消息列表 const msgArr = await db .collection(kTableName) // 查询条件,已开启推送,并且提醒时间为今天 .where({ A_IsPush: true, A_PushTime: timeStampToTime(new Date().getTime(), '{y}/{m}/{d}') }) .get() // 循环消息列表 const sendPromises = msgArr.data.map(async msgData => { try { // 发送订阅消息 await cloud.openapi.subscribeMessage.send({ touser: msgData._openid, // 要发送用户的openid page: 'pages/home/home', // 用户通过消息通知点击进入小程序的页面 lang: 'zh_CN', templateId: 'c64Gp5-89xyD55rnDr0oBWQNphWlNm_l4MX-Sduuj2c', // 订阅消息模板ID // 跳转小程序类型:developer为开发版;trial为体验版;formal为正式版;默认为正式版 // miniprogramState: 'developer', // 要发送的数据,要和模板一致 data: { // 纪念日名称 thing5: { value: msgData.A_Title }, // 纪念日时间 time2: { value: msgData.A_Time }, // 备注 thing4: { value: msgData.A_Remarks ? msgData.A_Remarks : '无' }, } }) // 发送成功后将数据状态重置 return db .collection(kTableName) .doc(msgData._id) .update({ data: { A_IsPush: false, A_PushTime: '', A_NextTime: '', }, }) } catch (e) { return e } }) return Promise.all(sendPromises) } catch (err) { console.log(err) return err } } function timeStampToTime(time, cFormat) { if (arguments.length === 0) { return null } const format = cFormat || '{y}-{m}-{d} {h}:{i}:{s}' let date if (typeof time === 'object') {} else { if (('' + time).length === 10) time = parseInt(time) * 1000 date = new Date(time) } const formatObj = { y: date.getFullYear(), m: date.getMonth() + 1, d: date.getDate(), h: date.getHours(), i: date.getMinutes(), s: date.getSeconds(), w: date.getDay() } const time_str = format.replace(/{(y|m|d|h|i|s|w)+}/g, (result, key) => { let value = formatObj[key] if (key === 'w') { return ['日', '一', '二', '三', '四', '五', '六'][value] } if (result.length > 0 && value < 10) { value = '0' + value } return value || 0 }) return time_str } // 定时触发器 // https://developers.weixin.qq.com/miniprogram/dev/wxcloud/guide/functions/triggers.html // 50秒一次 // "config": "*/50 * * * * * *" // 每天上午8点一次 // "config": "0 0 8 * * * *" [代码] package.json [代码]{ "name": "push", "version": "1.0.0", "description": "", "main": "index.js", "scripts": { "test": "echo \"Error: no test specified\" && exit 1" }, "author": "", "license": "ISC", "dependencies": { "wx-server-sdk": "~2.6.1" } } [代码] 3.3、上传并部署云函数 所有代码实现之后,可以先把项目环境设置为开发环境,然后右键上传并部署云函数,然后上传触发器 [图片] 然后打开云函数控制台,选择云函数-日志,进行查看状态,如果成功并且有需要推送的数据,手机会收到推送消息,失败的话根据日志进行修改。 [图片] 至此结束 最后推荐一下我的小程序,[代码]我的纪念日小助手[代码] [图片]
2022-05-16 - 利用云数据库和云函数实现一个签到日历
本文基于开源库实现 https://github.com/treadpit/wx_calendar #0 大家在使用小程序的时候,都会遇到各式各样的签到。 签到抽奖、签到得积分、签到得会员权益等。 签到不管是对于 APP 、WEB 还是小程序,在提高日活和增加回流都有着非常重要的作用。 作为开发者,我们怎么来实现这样的签到功能? 首先,我们需要一个数据库来存用户的历史签到数据。 再次,我们还需要一个后台服务器来响应用户的签到请求,判断用户当次签到是否有效并向数据库新增加。 很高兴,小程序云开发 (https://developers.weixin.qq.com/miniprogram/dev/wxcloud/basis/getting-started.html) 为开发者提供了开箱即用的云数据库和能代替后台服务器的云函数。 所以,接下来,我们就利用小程序云开发提供的云数据库和云函数来实现小程序里面的签到日历。 #1 先看一下完成实现后的效果动图 [图片] 通过动图,可以看到我们需要实现的功能包括: 1、历史签到数据展示(连续签到天数、累计签到天数、每月签到明细) 2、历史签到查询(通过点击前、后不同的按钮来跳转到不同的月份并展示当月的签到明细) 3、签到 那我们接下来一一去实现这三个大功能点 #2 历史签到数据展示和查询都需要用到日历卡片,我们就先整理出这个卡片的实现逻辑。 2.1 、取出所选月份的1日是星期几,然后根据取出的星期来计算日历卡片前面需要留下几个空白 [图片] 2.2 获取所选月份有多少天,然后初始化一个日期数组。每项包含两个值(天、是否签到,因为是初始化,所以统一设置为未签到) [图片] #3 整理出日历卡片后,就是获取历史签到数据比对然后渲染到页面上。 3.1 获取历史签到数据 [图片] 3.2 根据日历卡片的年、月得出当月所有天数后和历史签到数据比对来决定页面的渲染。 [图片] #4 用户肯定需要查到他自己之前的签到数据,我们通过提供前、后两个按钮来让用户选择。 [图片] #4 历史签到数据的展示、查询结束后,我们继续处理用户的新签到。 签到的动作放在小程序,而处理逻辑我们放在云函数里面。 毕竟我们不可能让用户重复签到或者做一些其他预料外的动作。 [图片] #5 不知道结束后,你对前面的两个问题(1、为什么把年、月、日分开?2、为什么只取历史签到数据的其中一条就可以知道用户的连续签到天数?)是否有了答案? 其实这两个问题的答案都非常简单,之所以我把它们单独摘出来,只是为了增加文章字数 [doge] 。也就是常说的故弄玄虚。。。 首先第一个问题:因为日历卡片渲染时是月份的 day ,而不是年-月-日,如果我们把年月日连在一起,不方便渲染处理。 第二个问题:因为我们在处理签到逻辑时,这个 continue_sign_days 是根据前一天的 continue_sign_days 得出,所以我们只需要按签到时间倒序排序然后最第一个就可以了。 #6 关注公众号,发送 源码 获取 [图片]
2020-04-25