话题查询增加10秒缓存

app/service/forumThreadService.js

@@ -348,6 +348,8 @@ exports.getThreadById = function(tid, callback) {
                             cb(null, null);
                             return;
                         }
+
+
                         getAllThreadByFidHelp(conditions, 1, 10, null, function(err, threads) {
                             if (err) {
                                 console.error(err);
@@ -401,6 +403,11 @@ exports.getThreadById = function(tid, callback) {
                     },
                     function(cb) {
                         //获取发帖人数
+                        var key = 'pisns-forum-thread:' + tid + ':amount';
+                        redis.get(key,function(err,value){
+                            if (value) {
+                                cb(null, Number(value));
+                            } else {
                                 ForumThread.aggregate({
                                     $match: {
                                         pid: mongoose.Types.ObjectId(tid)
@@ -418,10 +425,35 @@ exports.getThreadById = function(tid, callback) {
                                     if (err) {
                                         cb(err, null);
                                     } else {
+                                        redis.set(key, data.length);
+                                        redis.expire(key, 10);
                                         cb(null, data.length);
                                     }
                                 });
                             }
+                        }
+
+                        // ForumThread.aggregate({
+                        //     $match: {
+                        //         pid: mongoose.Types.ObjectId(tid)
+                        //     }
+                        // }, {
+                        //     $group: {
+                        //         _id: {
+                        //             from: '$from'
+                        //         },
+                        //         count: {
+                        //             $sum: 1
+                        //         }
+                        //     }
+                        // }, function(err, data) {
+                        //     if (err) {
+                        //         cb(err, null);
+                        //     } else {
+                        //         cb(null, data.length);
+                        //     }
+                        // });
+                    }
                 ], function(err, results) {
                     if (err) {
                         callback(err, null);