点赞的云函数

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

cloud.init({
    
    env: cloud.DYNAMIC_CURRENT_ENV
})

const db = cloud.database()
const formatTime = date => {
    
    const year = date.getFullYear()
    const month = date.getMonth() + 1
    const day = date.getDate()
    const hour = date.getHours()
    const minute = date.getMinutes()
    const second = date.getSeconds()
  
    return `${
      [year, month, day].map(formatNumber).join('-')} ${
      [hour, minute, second].map(formatNumber).join(':')}`
  }
  
  const formatNumber = n => {
    
    n = n.toString()
    return n[1] ? n : `0${
      n}`
  }
// 云函数入口函数
exports.main = async (event, context) => {
    
    const wxContext = cloud.getWXContext()
    let dz = db.collection('movie_zan_collect')
    let {
    total} = await new Promise( (resolve, reject)=>{
    
        dz.where({
     member_openid: wxContext.OPENID,movie_id: event.movieId  }).count().then( res=>{
    
            resolve(res)
        })
    })
    let data = {
    
        member_openid: wxContext.OPENID,
        movie_id:event.movieId,
        like:event.like,
        collection:event.collection,
        _updateTime:formatTime(new Date()),
    }
  
    if( total == 0 ){
    
      console.log(data)
        data._createTime = formatTime(new Date())
        return await dz.add({
     data }).then( res=>{
    
            console.log('新增成功->', res)
            return res
        }).catch( err=>{
    
            console.log('新增失败',err)
        })
    }else{
    
        return await dz.where({
     member_openid: wxContext.OPENID,movie_id: event.movieId }).update({
     data }).then( res=>{
    
            console.log('更新成功->', res)
            return res
        }).catch( err=>{
    
            console.log('更新失败',err)
        })
    }
}

多研究研究

再来看另一个接口

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

cloud.init({
    
    env: cloud.DYNAMIC_CURRENT_ENV
})

const db = cloud.database()

// 云函数入口函数
exports.main = async (event, context) => {
    
    const wxContext = cloud.getWXContext()
    return db.collection('movie_zan_collect').where({
    
        movie_id:event.movieId,
        member_openid:wxContext.OPENID
        
    }).get()

    
}

实现这个逻辑，需要两个接口