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

cloud.init({ env: cloud.DYNAMIC_CURRENT_ENV }) // 使用当前云环境

// 云函数入口函数
exports.main = async (event, context) => {
  // const wxContext = cloud.getWXContext()
  // return {
  //   event,
  //   openid: wxContext.OPENID,
  //   appid: wxContext.APPID,
  //   unionid: wxContext.UNIONID,
  // }
  let {userInfo,productId} = event
  return cloud.database().collection("productFlowList").aggregate()
    .lookup({
      from: "userList",
      localField: 'create_id',
      foreignField: 'id',
      as: 'user'
    })
    .unwind({
      path: "$user",
      preserveNullAndEmptyArrays: true
    })
    .lookup({
      from: "departmentList",
      localField: "user.depart_id",
      foreignField: "id",
      as: "user.department"
    })
    .unwind({
      path: "$user.department",
      preserveNullAndEmptyArrays: true
    })
    .lookup({
      from: "productBasic",
      localField: 'basic_id',
      foreignField: 'id',
      as: 'productBasic'
    })
    .unwind({
      path: "$productBasic",
      preserveNullAndEmptyArrays: true
    })
    .lookup({
      from: "productList",
      localField: 'product_id',
      foreignField: 'id',
      as: 'codeTemp'
    })
    .addFields({
      code: { $arrayElemAt: ["$codeTemp.code", 0] }
    })
    .project({
      codeTemp: 0
    })
    .match({
      product_id: productId
    })
    .end({
      success: function (res) {
        return res;
      },
      fail(error) {
        return error;
      }
    })
}