const users = await userDb.where({
openId: OPENID,
}).get();
const currentUser = users.data[0] || {}
const where = {
active: true,
openId: $.neq(OPENID),
}
if (taskType === 'taskRecord') {
if (users.data && users.data.length) {
where.accessApp = _.in(currentUser.accessApp)
console.log('查询点过的', currentUser)
}
} else {
where.flowers = $.gt(0);
if (users.data && users.data.length) {
where.accessApp = _.nin(currentUser.accessApp)
console.log('查询最新笔记', currentUser)
}
}
const lookup = {
from: 'user',
localField: 'openId',
foreignField: 'openId',
as: 'userInfo',
}
const addFields = {
flowers: '$userInfo.flowers',
accessApp: "$userInfo.accessApp"
}
const countAggregateInstance = task.aggregate().lookup(lookup);
const totalCount = await countAggregateInstance.addFields(addFields).match(where).count('totalCount').end();
const data = await task
.aggregate()
.lookup(lookup)
.addFields(addFields)
.match(where)
.skip((pageIndex - 1) * pageSize)
.limit(pageSize)
.end()