Commit 4be09bba authored by 陈家荣's avatar 陈家荣

update

parent 33d3f3ba
......@@ -967,7 +967,7 @@ router.get('/info/getUserFavorInfo', function(req, res, next) {
from: userId
};
forumFollowInfoService.findAll(q, null, function(err, doc){
forumFollowInfoService.findAll(q, null, null, function(err, doc){
if(err || !doc){
console.error(err);
res.json(returnCode.BUSY);
......@@ -1039,4 +1039,29 @@ router.get('/info/getUserFavorInfo', function(req, res, next) {
}
});
});
//获取用户收藏的板块的ID return Map
router.get('/info/getUserFavorInfoIds', function(req, res, next) {
var userId = user.getMobileUser(req);
var ent_code = req.session.user.ent_code;
var q = {
ent_code: ent_code,
from: userId
};
forumFollowInfoService.findAll(q, null, 'info', function(err, results){
if(err || !results){
console.error(err);
res.json(returnCode.BUSY);
}else {
var map = { //返回map对象,方便前端查找
data:{}
};
_.forEach(results, function(d){
map.data[d.info] = 1;
});
res.json(_.assign(map, returnCode.SUCCESS));
}
});
});
\ No newline at end of file
......@@ -336,7 +336,36 @@ router.get('/user/getUserFavorUser', function(req, res, next) {
res.json(returnCode.BUSY);
}else{
util.loadLevel(ent_code, results.items, function() {
res.json(_.assign(results, returnCode.SUCCESS));
var asyncTasks = [];
_.forEach(results.items, function(d, i) {
asyncTasks.push(function(cont) {
var conditions = {
ent_code: ent_code,
from: d.to._id,
status: 1
};
forumThreadService.getByConditionsSelectyFieldWithOpentions(conditions, 'title', 1, 0, '-_id', function(err, thread) {
if (err) {
console.error(err);
cont(err, null);
} else {
if(d.toObject){
d = d.toObject();
}
d.thread = thread;
cont(null, d);
}
});
});
});
async.parallel(asyncTasks, function(err, datas){
if(err){
console.error(err);
res.json( returnCode.BUSY);
}else{
res.json(_.assign(datas, returnCode.SUCCESS));
}
});
});
}
});
......@@ -345,6 +374,7 @@ router.get('/user/getUserFavorUser', function(req, res, next) {
//查看用户信息
router.get('/user/getUserInfo/:userId', function(req, res, next) {
var userId = req.params.userId;
var my_userID = user.getMobileUser(req);
var ent_code = req.session.user.ent_code;
async.waterfall([function(callback) {
......@@ -375,24 +405,17 @@ router.get('/user/getUserInfo/:userId', function(req, res, next) {
forumFollowUserService.count(follow_by_conditions, callback);
},
function(callback) {
//获取用户经验值,积分
// var url = API_ADDRESS + '/v1.0/internal/member/infoAndRankInfo';
// request.post({
// url: url,
// json: {
// entCode:ent_code,
// ids:[forumUser.mid]
// }
// }, function(e, r, body) {
// if (e) {
// console.log(e)
// callback(e, null);
// }else{
// callback(null, body.data);
// }
// });
user.findMember(ent_code, forumUser.mid, callback);
},
function(callback) {
//是否已关注当前用户
forumFollowUserService.isNotFollow({from: my_userID, to: userId, ent_code: ent_code}, function(result){
if(result){
callback(null, true);
}else{
callback(null, false);
}
});
}
], function(err, results) {
if (err) {
......@@ -407,7 +430,13 @@ router.get('/user/getUserInfo/:userId', function(req, res, next) {
forumUser.exp = results[2][0].exp;
forumUser.rankName = results[2][0].rankName;
}
callback(null, forumUser)
var object = {
forumUser : forumUser,
isFollow : results[3]
}
callback(null, object)
}
});
}], function(err, result) {
......@@ -416,7 +445,7 @@ router.get('/user/getUserInfo/:userId', function(req, res, next) {
res.json(returnCode.BUSY);
}else{
var rs = {
data: result
data: result
};
res.json(_.assign(rs, returnCode.SUCCESS));
}
......
......@@ -70,12 +70,12 @@ exports.find= function(pageNo, pageSize, conditions, sort, callback) {
};
//获取列表
exports.findAll=function(conditions, sort, callback){
exports.findAll=function(conditions, sort, fields, callback){
var sortby = "-_id";
if(sort){
sortby = sort;
}
ForumFollowInfo.find(conditions).sort(sortby).exec(function(err, docs){
ForumFollowInfo.find(conditions).select(fields).sort(sortby).exec(function(err, docs){
if (err) {
console.error(err);
callback(err,null);
......
......@@ -260,6 +260,18 @@ exports.getByConditionsSelectyField = function(conditions, fields, callback) {
});
}
//根据ID获取文章,选择字段
exports.getByConditionsSelectyFieldWithOpentions = function(conditions, fields, limit, skip, sort, callback) {
ForumThread.findOne(conditions).select(fields).limit(limit).skip(skip).sort(sort).exec(function(err,result){
if (err) {
console.error(err);
callback(err, null);
} else {
callback(null, result);
}
});
}
//根据ID获取文章记录,不查评论,子话题
exports.getById = function(id, callback) {
ForumThread.findOne({
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment