// Callback 風(fēng)格調(diào)用
wx.cloud.callFunction({
 // 要調(diào)用的云函數(shù)名稱
 name: 'add',
 // 傳遞給云函數(shù)的參數(shù)
 data: {
 x: 1,
 y: 2,
 },
 success: res => {
 // output: res.result === 3
 },
 fail: err => {
 // handle error
 },
 complete: () => {
 // ...
 }
})
 
// Promise 風(fēng)格調(diào)用
wx.cloud.callFunction({
 // 要調(diào)用的云函數(shù)名稱
 name: 'add',
 // 傳遞給云函數(shù)的event參數(shù)
 data: {
 x: 1,
 y: 2,
 }
}).then(res => {
 // output: res.result === 3
}).catch(err => {
 // handle error
})

// 1. 獲取數(shù)據(jù)庫(kù)引用
const db = wx.cloud.database()
// 2. 構(gòu)造查詢語(yǔ)句
// collection 方法獲取一個(gè)集合的引用
// where 方法傳入一個(gè)對(duì)象，數(shù)據(jù)庫(kù)返回集合中字段等于指定值的 JSON 文檔。API 也支持高級(jí)的查詢條件（比如大于、小于、in 等），具體見文檔查看支持列表
// get 方法會(huì)觸發(fā)網(wǎng)絡(luò)請(qǐng)求，往數(shù)據(jù)庫(kù)取數(shù)據(jù)
db.collection('books').where({
publishInfo: {
country: 'United States'
}
}).get({
success: function(res) {
// 輸出 [{ "title": "The Catcher in the Rye", ... }]
console.log(res)
}
})

// 讓用戶選擇一張圖片
wx.chooseImage({
success: chooseResult => {
// 將圖片上傳至云存儲(chǔ)空間
wx.cloud.uploadFile({
// 指定上傳到的云路徑
cloudPath: 'my-photo.png',
// 指定要上傳的文件的小程序臨時(shí)文件路徑
filePath: chooseResult.tempFilePaths[0],
// 成功回調(diào)
success: res => {
console.log('上傳成功', res)
},
})
},
})

// index.js 是入口文件，云函數(shù)被調(diào)用時(shí)會(huì)執(zhí)行該文件導(dǎo)出的 main 方法
// event 包含了調(diào)用端（小程序端）調(diào)用該函數(shù)時(shí)傳過(guò)來(lái)的參數(shù)，同時(shí)還包含了可以通過(guò) getWXContext 方法獲取的用戶登錄態(tài) `openId` 和小程序 `appId` 信息
const cloud = require('wx-server-sdk')
exports.main = (event, context) => {
const {userInfo, a, b} = event
const {OPENID, APPID} = cloud.getWXContext() // 這里獲取到的 openId 和 appId 是可信的
const sum = a + b
 
return {
OPENID,
APPID,
sum
}
}

const cloud = require('wx-server-sdk')
cloud.init()
const db = cloud.database()

const cloud = require('wx-server-sdk')
cloud.init()
const testDB = cloud.database({
env: 'test'
})

const cloud = require('wx-server-sdk')
cloud.init({
env: 'test'
})
const testDB = cloud.database()

const cloud = require('wx-server-sdk')
cloud.init()
const db = cloud.database()
const todosCollection = db.collection('todos') // 獲取todos集合

//app.js
App({
 onLaunch: function () {
 const _this = this
 // 初始化云函數(shù)
 if (!wx.cloud) {
 console.error('請(qǐng)使用 2.2.3 或以上的基礎(chǔ)庫(kù)以使用云能力')
 } else {
 wx.cloud.init({
 traceUser: true,
 })
 }
 // 獲取用戶信息(針對(duì)已經(jīng)授權(quán)過(guò)的用戶,直接獲取用戶信息)
 wx.getSetting({
 success: res => {
 if (res.authSetting['scope.userInfo']) {
  // 已經(jīng)授權(quán)，可以直接調(diào)用 getUserInfo 獲取頭像昵稱，不會(huì)彈框
  wx.getUserInfo({
  success: res => {
  _this.globalData.avatarUrl = res.userInfo.avatarUrl
  _this.globalData.userInfo = res.userInfo
  if (_this.userInfoCallback) {
  _this.userInfoCallback()
  }
  }
  })
 }
 }
 })
 this.globalData = {
 userInfo: {}, // 微信用戶信息
 userRole: '', // 當(dāng)前用戶角色
 registerUser: {}, // 微信用戶綁定的用戶信息
 userindex: '', // 編輯設(shè)備和添加設(shè)備頁(yè)面,index索引選擇的值name
 userindexId: '',// 編輯設(shè)備和添加設(shè)備頁(yè)面,index索引選擇的值id
 currentQuerys: {
 type: ['iphone', 'android', 'ble'],
 user: []
 } // 設(shè)備管理篩選框篩選的結(jié)果
 }
 }
})

// 云函數(shù)入口文件
const cloud = require('wx-server-sdk')
cloud.init()
// 云函數(shù)入口函數(shù)
exports.main = async (event, context) => {
 const wxContext = cloud.getWXContext()
 // 調(diào)用數(shù)據(jù)庫(kù)獲取所有設(shè)備列表
 const db = cloud.database() // 獲取數(shù)據(jù)庫(kù)
 const _ = db.command // 獲取查詢指令
 const usersCollection = db.collection('users') // 獲取users集合
 const user = (await usersCollection.where({
 open_id: wxContext.OPENID // 根據(jù)唯一open_id在user集合中查找已綁定的用戶
 }).get())
 return {
 event,
 data: user,
 openid: wxContext.OPENID,
 appid: wxContext.APPID,
 unionid: wxContext.UNIONID,
 }
}

// 云函數(shù)入口文件
const cloud = require('wx-server-sdk')
cloud.init()
// 云函數(shù)入口函數(shù)
exports.main = async (event, context) => {
 const wxContext = cloud.getWXContext()
 // 調(diào)用數(shù)據(jù)庫(kù)獲取所有設(shè)備列表
 const db = cloud.database() // 獲取數(shù)據(jù)庫(kù)
 const _ = db.command // 獲取查詢指令
 const usersCollection = db.collection('users') // 獲取users集合
 // 查詢條件
 let query = _.eq(event.id)
 // 
 try {
 await usersCollection.doc(event.id).update({
 // data 傳入需要局部更新的數(shù)據(jù)
 data: {
 open_id: wxContext.OPENID
 }
 })
 } catch (e) {
 console.log(e)
 }
 
 return {
 event,
 openid: wxContext.OPENID,
 appid: wxContext.APPID,
 unionid: wxContext.UNIONID,
 }
}

// 云函數(shù)入口文件
const cloud = require('wx-server-sdk')
cloud.init()
// 云函數(shù)入口函數(shù)
exports.main = async (event, context) => {
 const wxContext = cloud.getWXContext()
 // 調(diào)用數(shù)據(jù)庫(kù)獲取所有設(shè)備列表
 const db = cloud.database() // 獲取數(shù)據(jù)庫(kù)
 const _ = db.command // 獲取查詢指令
 const equipmentCollection = db.collection('equipment') // 獲取equipment集合
 // 取所有集合中符合條件的數(shù)據(jù)(因?yàn)橛心J(rèn) limit 100 條的限制,需要做特殊操作)
 const MAX_LIMIT = 100
 // 先取出集合記錄總數(shù)
 const countResult = await equipmentCollection.count()
 const total = countResult.total
 // 計(jì)算需分幾次取
 const batchTimes = Math.ceil(total / 100)
 // 承載所有讀操作的 promise 的數(shù)組
 const tasks = []
 let query = {}
 // 封裝設(shè)備類型查詢條件(直接通過(guò)reduce直接拼接方法)
 query.eq_type = event.queryList['type'].reduce((acc, cur) => {
 if (!acc) {
 return _.eq(cur)
 } else {
 return acc.or(_.eq(cur))
 }
 }, null)
 // 用戶名查詢條件
 if (event.queryList['user'].length>0) {
 query.eq_user = event.queryList['user'][0]
 }
 for (let i = 0; i < batchTimes; i++) {
 const promise = equipmentCollection.where(query).skip(i * MAX_LIMIT).limit(MAX_LIMIT).get()
 tasks.push(promise)
 }
 // 等待所有數(shù)據(jù)讀取完成
 const equipmentList = (await Promise.all(tasks)).reduce((acc, cur) => ({
 data: acc.data.concat(cur.data),
 errMsg: acc.errMsg,
 }))
 
 return {
 event,
 data: equipmentList,
 openid: wxContext.OPENID,
 appid: wxContext.APPID,
 unionid: wxContext.UNIONID,
 }
}

// 云函數(shù)入口文件
const cloud = require('wx-server-sdk')
 
cloud.init()
 
// 云函數(shù)入口函數(shù)
exports.main = async (event, context) => {
 const wxContext = cloud.getWXContext()
 // 調(diào)用數(shù)據(jù)庫(kù)獲取所有設(shè)備列表
 const db = cloud.database() // 獲取數(shù)據(jù)庫(kù)
 const _ = db.command // 獲取查詢指令
 const equipmentCollection = db.collection('equipment') // 獲取equipment集合
 
 try{
 await equipmentCollection.doc(event.id).remove()
 } catch(e){
 console.error(e)
 }
 
 return {
 event,
 openid: wxContext.OPENID,
 appid: wxContext.APPID,
 unionid: wxContext.UNIONID,
 }
}