// 云函数入口文件

const cloud = require('wx-server-sdk')

cloud.init({

  env: cloud.DYNAMIC_CURRENT_ENV

})

const db = cloud.database()

const _ = db.command

const MAX_LIMIT = 100

// 云函数入口函数

exports.main = async (event, context) => {

    const countResult = await db.collection(database19).count()

    const total = countResult.total

    // 计算需分几次取

    const batchTimes = Math.ceil(total / 100)

    // 承载所有读操作的 promise 的数组

    const tasks = []

    for (let i = 0; i < batchTimes; i++) {

      const promise = db.collection(database19).where({

        name: db.RegExp({

          regexp: '.*' + '思科'})

      }).skip(i * MAX_LIMIT).limit(MAX_LIMIT).get({

        success: console.log,

        fail: console.error

      })

      console.log(tasks)

      tasks.push(promise)

    }

    // 等待所有

    return(await Promise.all(tasks)).reduce((acc, cur) => {

      return {

        data: acc.data.concat(cur.data),

        errMsg: acc.errMsg,

      }

    })

}