11

app/controllers/admin/forumThread.js

@@ -17,6 +17,7 @@ var httpService = require('../../service/httpService');
 
 var userUtil = require('../../utils/user');
 var async = require('async');
+var _ = require('lodash');
 
 module.exports = function(app) {
     app.use('/admin/forum', router);
@@ -670,3 +671,81 @@ var getClientIP = function(req) {
     }
     return ipAddress;
 };
+
+
+//给以前的已一级评论添加楼层
+router.get('/thread/:ent_code/updateConmentFloor', function(req, res, next) {
+    var ent_code = req.params.ent_code || null;
+    if(ent_code){
+        var conditions = {
+            ent_code: ent_code
+        }; 
+        async.waterfall([
+            function(callback) { // 查找文章的总数
+                forumThreadService.getAllCountByFid(conditions,function(err, count){
+                    if(err){
+                        callback(err, null);
+                    }else{
+                        callback(null, count);
+                    }
+                }); 
+            },
+            function(count, callback) { //查找所有文章
+                forumThreadService.getAllThreadByFidNoLimit(conditions, 1, count, null, function(err, datas){
+                    if(err){
+                        callback(err, null);
+                    }else{
+                        callback(null, datas);
+                    }
+                });
+            }
+        ], function (err, result) {
+            var asyncTasks = [];
+            result.items.forEach(function(doc) { //遍历文章
+                asyncTasks.push(function(callback) {
+                    // console.log(doc);
+                    //获取文章所有一级评论,倒数排列
+                    async.waterfall([
+                        function(callback) {
+                            var comments = doc.comments;
+                            comments = _.sortBy(comments, function(comment){ 
+                                return comment.created;
+                            });
+                            if(comments.length > 0){
+                                // 给每一个评论添加楼层
+                                comments.forEach(function(comment,i){
+                                    forumCommentService.updateCommentFloorById(comment._id, i + 1, function(err,docc){
+                                        if (err) {
+                                            console.error(err);
+                                            // callback(err,null);
+                                        } else {
+                                            // callback(null,null);
+                                        }
+                                    })
+                                });
+                            }
+                        }
+                    ], function(err, resultsss) {
+                        if (err) {
+                            console.error(err);
+                            // callback(err,null);
+                        } else {
+                            // callback(null,null);
+                        }
+                    });
+                });
+
+            });
+            async.parallel(asyncTasks, function(err, results) {
+                if (err) {
+                    console.error(err);
+                    res.json(returnCode.BUSY);
+                } else {
+                    res.json(returnCode.SUCCESS);
+                }
+            });
+        });
+    }else{
+        res.json(returnCode.BUSY);
+    }
+});