const cloud = require('wx-server-sdk')
cloud.init()
const db = cloud.database()
const wxContext = cloud.getWXContext()
async function addUserData(event, context) {
console.log('微信用户数据',wxContext)
const result = await db.collection('user').where({
'userInfo.openId': wxContext.OPENID
}).get()
if (result.data.length == 0) {
await db.collection('user').add({
data: event
})
return '新增记录成功'
} else {
await db.collection('user').doc(result.data[0]._id).update({
data: event
})
return result.data[0]._id + '更新成功'
}
}
exports.main = async (event, context) => {
return addUserData(event, context);
}
|