微信小程序开发：云函数定时推送消息

// cloudfunctions/pushNotify/index.js

const cloud = require('wx-server-sdk')
// 初始化 cloud
cloud.init({
  // API 调用都保持和云函数当前所在环境一致
  // 不加此参数就默认为第一个创建的云环境
  env: cloud.DYNAMIC_CURRENT_ENV
})

const db = cloud.database()
const kTableName = 'todo'

// 云函数入口函数
exports.main = async (event, context) => {
  try {
    // --- 步骤1 ---
    // 从云开发数据库中查询等待发送的消息列表
    const msgArr = await db
      .collection(kTableName)
      // 查询条件
      .where({
        checked: false,
        pushed: false,
      })
      .get()

    // --- 步骤2 ---
    for (const msgData of msgArr.data) {
      // 发送订阅消息
      await cloud.openapi.subscribeMessage.send({
        touser: msgData._openid, // 要发送用户的openid
        page: 'pages/index/index', // 用户通过消息通知点击进入小程序的页面
        lang: 'zh_CN',
        // 订阅消息模板ID
        // 替换为你的模板id!
        templateId: 'FHKU0kt...xxx...zgH_VEerY',
        // 跳转小程序类型：developer为开发版；trial为体验版；formal为正式版；默认为正式版
        // 正式版删除此行
        miniprogramState: 'developer',
        // 要发送的数据，要和模板一致
        data: {
          // 待办的主题
          thing1: {
            value: msgData.content === '' ? '无' : sliceBodyStr(msgData.content, 16)
          },
          // 待办的详情
          thing4: {
            value: '别忘了待办事项哟'
          },
        }
      })

      // --- 步骤3 ---
      // 发送成功后将pushed数据状态重置
      db
        .collection(kTableName)
        .doc(msgData._id)
        .update({
          data: {
            pushed: true
          },
        })
    }

    // --- 步骤4 ---
    return msgArr
  } catch (e) {
    return e
  }
}

// 将太长的文本截短
function sliceBodyStr(str, length) {
  if (str.length <= length) {
    return str
  } else {
    return str.slice(0, length) + '...'
  }
}

// pages/index/index.js

Component({
  // ...

  methods: {
    // 修改已有的inputSubmit()方法
    // 点击提交按钮
    inputSubmit() {
      // ...
      const newItem = {
        // ...
        // 新增代码
        pushed: false
      }
      // ...
      // 新增代码
      // 订阅服务
      this.subscribe()
    },

    // 新增方法
    // 向用户申请推送服务
    subscribe() {
      // 填写你自己的模板id
      const templateId = 'FHKU..xxx..H_VEerY'
      // 仅展示了主流程
      // 正式环境中，需考虑到用户可能会点击‘拒绝’、‘永久拒绝’等情况
      // 并弹出对应的反馈，如弹窗等
      wx.requestSubscribeMessage({
        tmplIds: [templateId],
        success (res) {
          console.log('订阅成功 ', res)
        },
        fail (err) {
          console.log('订阅失败 ', err)
        }
      })
    },
  },

  // ...
})

{
  "permissions": {
    "openapi": ["subscribeMessage.send"]
  },
  "triggers": [{
    "name": "myTimer",
    "type": "timer",
    "config": "*/50 * * * * * *"
  }]
}

// 50秒一次
// "config": "*/50 * * * * * *"

// 每天上午8点一次
// "config": "0 0 8 * * * *"