//app.js onLaunch 中注册
initWatchGoodsCollection(){
    let that = this;
    const db = wx.cloud.database({
      env: 'commodity-display-ckxt7',
    });
    const watcher = db.collection('goods').watch({
      onChange: snapshot=> {
        console.log(111);
        console.log('snapshot', snapshot)
        //初始化时会触发一次
        if (snapshot.type!="init"){
          that.initGoodsList();
        }
      },
      onError: err=> {
        console.error('the watch closed because of error', err)
      },
  
    })
  },

更新和删除在均在云函数中调用

// 云函数入口文件
const cloud = require('wx-server-sdk')

// 初始化 cloud
cloud.init({
  // API 调用都保持和云函数当前所在环境一致
  env: cloud.DYNAMIC_CURRENT_ENV
})

//初始化数据库
const db = cloud.database();
//初始化商品表
const GoodsCollection = db.collection("goods");

// 云函数入口函数
exports.main = async (event, context) => {
  let status = "";
  let errMsg = "";

  const goodsObj = event.goodsObj;
  let goods = await GoodsCollection.where({
    uuid: goodsObj["uuid"],
  }).update({
    data: { 
      name: goodsObj["name"],
      kind: goodsObj["kind"],
      price: goodsObj["price"],
      origin_price: goodsObj["origin_price"],
      description: goodsObj["description"],
      deliver_price: goodsObj["deliver_price"],
      departure_place: goodsObj["departure_place"],
    }
  }).then(res => {
    status = "success";
    errMsg = "";
  }).catch(e => {
    status = "failed";
    errMsg = e;
  })

  return {
    status: status,
    errMsg: errMsg
  }
}