// 云函数入口文件
const cloud = require('wx-server-sdk')
cloud.init({
env: cloud.DYNAMIC_CURRENT_ENV
}) // 使用当前云环境
const db = cloud.database()
const _ = db.command
const $ = db.command.aggregate
// 云函数入口函数
exports.main = async (event, context) => {
const res = await db.collection('login_users')
.aggregate()
.group({
// 按 myTeamName 字段分组
_id: '$myTeamName',
users: $.push({ //返回一组中表达式指定列与对应的值，一起组成数组
user_level: '$user_level',
})
})
.limit(100)
.project({
_id: 1,
// users:1,
teamerCount: $.size('$users'),
kingCount: $.size($.filter({
input: '$users',
as: 'item',
cond: $.eq(['$$item.user_level', 4])
})),
golderCount: $.size($.filter({ //计算该战队黄金斗士的人数
input: '$users',
as: 'item',
cond: $.eq(['$$item.user_level', 3])
})),
silverCount: $.size($.filter({
input: '$users',
as: 'item',
cond: $.eq(['$$item.user_level', 2])
})),
bronzeCount: $.size($.filter({
input: '$users',
as: 'item',
cond: $.eq(['$$item.user_level', 1])
})),
rookieCount: $.size($.filter({
input: '$users',
as: 'item',
cond: $.eq(['$$item.user_level', 0])
})),
})
.end()
// return res.list.length
//将每条数据更新至teams集合
for (var i = 0; i < res.list.length; i++) {
const upd = db.collection('teams')
.where({
teamName: res.list[i]._id
})
.update({
data: {
bronzeCount: res.list[i].bronzeCount,
golderCount: res.list[i].golderCount,
kingCount: res.list[i].kingCount,
rookieCount: res.list[i].rookieCount,
silverCount: res.list[i].silverCount,
teamerCount: res.list[i].teamerCount
}
});
console.log(event)
// return upd
}
}
