云开发·多次订阅一次性订阅消息后定时发送

用户头像
Yukun
关注
发布于: 2020 年 10 月 27 日
云开发·多次订阅一次性订阅消息后定时发送



小程序一次性订阅消息,订阅1次可以发送1条消息,订阅10次可以发送10条消息



1. 前情提要,完成订阅到发送的过程

订阅部分参考 实战分享: 小程序云开发玩转订阅消息 就可以完成从小程序订阅、存入云开发数据库、利用定时触发器定期发送消息了。



完成上面的步骤,你应该已经在云端做到了:

  1. 定时任务

  2. 查询所有订阅消息

  3. 循环发送消息

  4. 发送后根据_id标记状态为已发送



但是上文的订阅消息,适用于只订阅一次的情况,查看github的源码,甚至为了避免重复,同一个用户不能订阅多次。



我们要做的逻辑是,同一个一次性订阅消息,用户可以订阅多次,订阅几次就发送几次。



2. 改造查询,支持每个用户只发送一条



保存处代码不用修改,用户多次订阅就会插入多条记录。查询代码需要做修改,目前的查询代码是这样的:



const messages = await db
.collection('messages')
.where({
done: false,
})
.get();



查询到了所有未发送的消息,此时一个用户订阅2次,都会查出来,并收到2条订阅消息。



我们使用 aggregate 把这里改为类似MySQL中的 distinct 查询:



db.collection('messages')
.aggregate()
.match({
done: false,
})
.group({
"_id": '$touser',
"idList": $.addToSet("$_id")
})
.end()



注意这里的 addToSet 是把前面查询的结果,根据touser(也就是用户的openid)重新聚合,把每条消息的 _id 放到一个列表中,看起来如下:



[
{
"_id": "oiRsI0RKU8IG2Y9Z_Y6Y5aC9JGt0",// openid
"idList": [
"112557505f9001d1001f90eb23d5894b", // 数据库_id
"2c9645925f8f097d001dd5170f0b7727" // 数据库_id
]
},
{
"_id": "oiRsI0d8Zp8e1edtDlPeuNUZWB68",
"idList": [
"2c9645925f900210001eb0814df399fc",
"d9ea4cfd5f90020c001b5ab04fc0ed01",
"8f29e52a5f8f0972001b9015226aaad9"
]
}
]

这样我们发送时,从 idList 中取一个_id标记为已发送,就能实现每次只消耗1次“资格”了。



3. 分页与循环查询



官方文档指出云端函数Collection.limit 最多 1000 条,但是实际上有人测试过Aggregate 聚合操作可以[ 最多查询 10000 条!](https://developers.weixin.qq.com/community/develop/article/doc/000624c67c8b48611dba2b12058c13)。具体限制各位自己测试。如果你的订阅非常多的话,就需要加入循环也分页了。



先查询记录总数,再分页查询,然后再聚合。



注意上面的顺序,因为是先分页再聚合,所以最终出来的结果可能会少于每页条数,不过我们都是汇总再发送,对我们影响不大了。



4. 附加说明

因为我的需求比较简单,前面的查询代码没有区分模板消息种类,有需要的同学可以增加查询条件,如果需要在集合里展示更多字段,addToSet可以这样写:



$.addToSet({'id':"$_id","templateId":"$templateId"});



演示小程序

外卖先领优惠券



以上小程序已开源,欢迎围观[4]



5. 参考资料

[1]

实战分享: 小程序云开发玩转订阅消息: https://developers.weixin.qq.com/community/develop/article/doc/000608a12b07b8ea81599420e56013

[2]

官方文档: https://developers.weixin.qq.com/miniprogram/dev/wxcloud/reference-sdk-api/database/collection/Collection.limit.html#%E8%AF%B4%E6%98%8E

[3]

最多查询 10000 条!: https://developers.weixin.qq.com/community/develop/article/doc/000624c67c8b48611dba2b12058c13

[4]

欢迎围观: https://github.com/PlayerYK/coupon_open



发布于: 2020 年 10 月 27 日 阅读数: 16
用户头像

Yukun

关注

半栈程序员,微信 Player404 2017.12.07 加入

playerYK

评论

发布
暂无评论
云开发·多次订阅一次性订阅消息后定时发送