// 引入云开发初始化模块
const cloud = wx.cloud;

// 初始化云开发
cloud.init({
  env: 'your-environment-id'  // 将 your-environment-id 替换为你的云开发环境 ID
});

// 在小程序中调用云函数进行数据库聚合操作
wx.cloud.callFunction({
  name: 'aggregateData',  // 替换为你的云函数名称
  data: {
    // 传递给云函数的参数
    collection: 'your-collection',  // 替换为你的数据库集合名称
    pipeline: [
      {
        $group: {
          _id: '$category',
          total: {
            $sum: '$quantity'
          }
        }
      }
    ]
  },
  success: res => {
    console.log('聚合成功', res.result.list);
    // 处理聚合结果
  },
  fail: err => {
    console.error('聚合失败', err);
    // 处理聚合失败的情况
  }
});

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

// 云函数入口函数
exports.main = async (event, context) => {
  const db = cloud.database();
  const collection = db.collection(event.collection);

  try {
    // 聚合操作
    const result = await collection.aggregate().match({
      // 可以添加匹配条件
      // 例如，如果只想统计特定条件的数据：
      // conditionField: 'conditionValue'
    }).end();

    return {
      list: result.list
    };
  } catch (err) {
    console.error(err);
    return err;
  }
};