|
|
@ -26,6 +26,8 @@ module.exports = {
|
|
|
|
});
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|
|
|
async.each(posts, function (post, next) {
|
|
|
|
async.each(posts, function (post, next) {
|
|
|
|
|
|
|
|
progress.incr();
|
|
|
|
|
|
|
|
|
|
|
|
async.parallel({
|
|
|
|
async.parallel({
|
|
|
|
uids: async.apply(db.getSortedSetRangeWithScores, 'pid:' + post.pid + ':flag:uids', 0, -1),
|
|
|
|
uids: async.apply(db.getSortedSetRangeWithScores, 'pid:' + post.pid + ':flag:uids', 0, -1),
|
|
|
|
reasons: async.apply(db.getSortedSetRange, 'pid:' + post.pid + ':flag:uid:reason', 0, -1),
|
|
|
|
reasons: async.apply(db.getSortedSetRange, 'pid:' + post.pid + ':flag:uid:reason', 0, -1),
|
|
|
@ -81,8 +83,6 @@ module.exports = {
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
next(err);
|
|
|
|
next(err);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
progress.incr();
|
|
|
|
|
|
|
|
});
|
|
|
|
});
|
|
|
|
});
|
|
|
|
});
|
|
|
|
}, next);
|
|
|
|
}, next);
|
|
|
|