// 云函数入口文件

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

// 初始化 cloud

cloud.init({

  traceUser:true,

  env: 'zjb981'

})

const db = cloud.database()//调用获取默认环境的数据库的引用

//const todosCollection = db.collection()//定义集合

const _ = db.command//数据库操作符

const $ = db.command.aggregate//定义聚合操作符

exports.main = async (event, context) => {// 云函数入口函数

  var  wxContext = cloud.getWXContext()//包含OPENID等信息

   //return开始一

   var promise= new Promise((resolve,reject)=>{

    //集合操作开始

 db.collection('offerprice').aggregate()

    .match({

      useropenid:wxContext.OPENID,

          dataType:event.DataType,

         "values.offerYear":event.YearMonthDate.year,

         "values.offerMonth":event.YearMonthDate.month,

         "values.offerDate":event.YearMonthDate.date,

    })

    .skip(event.pageskip)

    .limit(20)

           .end()

              //集合操作结束 

              .then(res=>{//where成功后执行then开始

              resolve(res)

           })//where成功后执行then结束

           .catch((err=>{//where失败后执行

              reject(err)

           }))

          //集合操作结束 

         }

          )

  //return结束一

  //return开始二

var countResult=[]

  var countResult= new Promise((resolve,reject)=>{

    //集合操作开始

 db.collection('offerprice').aggregate()

    .match({

      useropenid:wxContext.OPENID,

          dataType:event.DataType,

         "values.offerYear":event.YearMonthDate.year,

         "values.offerMonth":event.YearMonthDate.month,

         "values.offerDate":event.YearMonthDate.date,

    })

    .count('expensiveCount')

           .end()

              //集合操作结束 

              .then(res=>{//where成功后执行then开始

              resolve(res)

           })//where成功后执行then结束

           .catch((err=>{//where失败后执行

              reject(err)

           }))

          //集合操作结束 

         }

          )

  //return结束二

  var all ={

    wxContext,

    promise,

    countResult

  }

// 等待所有

return all