huiting/cloudfunctions/createMessage/index.js

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

cloud.init()
const db = cloud.database()

// 云函数入口函数
exports.main = async (event, context) => {
  let {
    OPENID
  } = cloud.getWXContext()

  const manage_check = await db.collection('manager').where({
    pub_id: event.pub_id,
    user_id: OPENID
  }).get()
  if (manage_check.data.length === 0) {
    return {
      errMsg: '只有管理员可以发布'
    }
  }
  if (manage_check.data[0].role !== '拥有者' && manage_check.data[0].role !== '发布者') {
    return {
      errMsg: '没有发布权限'
    }
  }

  const message = await db.collection('message').add({
    data: {
      pub_id: '',
      name: '',
      type: '',
      brief: '',
      poster: '',
      photo: '',
      tag: '',
      orient: '',
      time: '',
      place: '',
      contact: '',
      detail: '',
      publish_time: new Date()
    }
  })

  return message
}