Skip to content

P
pisns-forum-api
Commit e45b377b authored by 陈家荣's avatar 陈家荣
Browse files
Options

1

parent b50a286f
Hide whitespace changes
Inline Side-by-side
Showing with 368 additions and 248 deletions
app/controllers/mobile/forumShare.js
View file @ e45b377b
......@@ -216,9 +216,22 @@ router.get('/:ent_code/share/timeline', function(req, res, next) {
var mid = req.session.openUser.mid,
action = 'share_timeline',
ent_code = req.session.user.ent_code;
httpService.createShareLog(req,1);
httpService.sendRequest(ent_code,mid,action);
res.status(200).end();
forumLimitActionRefService.checkLimitActionProhibitionAddIntegral(mid, function(err, flag){
if(err){
console.error(err);
res.json(returnCode.PROHIBITION_OF_SPEECH);
}else{
if(flag){
res.json(returnCode.PROHIBITION_OF_SPEECH);
}else{
httpService.createShareLog(req,1);
httpService.sendRequest(ent_code,mid,action);
res.status(200).end();
}
}
});
});
//微信分享单人接口
......@@ -226,7 +239,20 @@ router.get('/:ent_code/share/singlemessage', function(req, res, next) {
var mid = req.session.openUser.mid,
action = 'share_singlemessage',
ent_code = req.session.user.ent_code;
httpService.createShareLog(req,2);
httpService.sendRequest(ent_code,mid,action);
res.status(200).end();
forumLimitActionRefService.checkLimitActionProhibitionAddIntegral(mid, function(err, flag){
if(err){
console.error(err);
res.json(returnCode.PROHIBITION_OF_SPEECH);
}else{
if(flag){
res.json(returnCode.PROHIBITION_OF_SPEECH);
}else{
httpService.createShareLog(req,2);
httpService.sendRequest(ent_code,mid,action);
res.status(200).end();
}
}
});
});
app/controllers/mobile/forumThread.js
View file @ e45b377b
......@@ -13,6 +13,7 @@ var forumPraiseLogService = require('../../service/forumPraiseLogService');
var forumShareLogService = require('../../service/forumShareLogService');
var forumCommentService = require('../../service/forumCommentService');
var forumUserThreadControlService = require('../../service/forumUserThreadControlService');
var forumLimitActionRefService = require('../../service/forumLimitActionRefService');
var httpService = require('../../service/httpService');
......@@ -130,27 +131,49 @@ router.get('/thread/searchComment', function(req, res, next) {
//新增论坛文章
router.post('/thread/create', function(req, res, next) {
var integral = req.session.openUser.integral || 0;
var exp = req.session.openUser.exp || 0;
forumRolePermissionService.checkRolePermiss(req.session.user.ent_code, 'create', integral, exp, function(err, result) {
if (err) {
res.json(returnCode.BUSY);
} else {
if (result) { //有操作权限
create(req, function(err, thread) {
var mid = req.session.openUser.mid;
forumLimitActionRefService.checkLimitActionProhibitionOfSpeech(mid, function(err, isProhibition){
if(err){
console.error(err);
res.json(returnCode.PROHIBITION_OF_SPEECH);
}else{
if(isProhibition){
res.json(returnCode.PROHIBITION_OF_SPEECH);
}else{
var integral = req.session.openUser.integral || 0;
var exp = req.session.openUser.exp || 0;
forumRolePermissionService.checkRolePermiss(req.session.user.ent_code, 'create', integral, exp, function(err, result) {
if (err) {
res.json(returnCode.BUSY);
} else {
httpService.sendRequest(req.session.user.ent_code, req.session.openUser.mid, 'post');
var rs = {};
rs.data = {
'id': thread._id
};
res.json(_.assign(rs, returnCode.SUCCESS));
if (result) { //有操作权限
create(req, function(err, thread) {
if (err) {
res.json(returnCode.BUSY);
} else {
forumLimitActionRefService.checkLimitActionProhibitionAddIntegral(mid, function(err, flag){
if(err){
console.error(err);
}else{
if(!flag){
httpService.sendRequest(req.session.user.ent_code, req.session.openUser.mid, 'post');
}
}
});
// httpService.sendRequest(req.session.user.ent_code, req.session.openUser.mid, 'post');
var rs = {};
rs.data = {
'id': thread._id
};
res.json(_.assign(rs, returnCode.SUCCESS));
}
});
} else {
res.json(returnCode.ACTION_NOT_PERMISSION);
}
}
});
} else {
res.json(returnCode.ACTION_NOT_PERMISSION);
}
}
});
......@@ -244,6 +267,7 @@ router.post('/thread/:tid/delete', function(req, res, next) {
//文章点赞
router.post('/thread/:tid/raise', function(req, res, next) {
var mid = req.session.openUser.mid;
var tid = req.params.tid || null;
if (tid) {
var integral = req.session.openUser.integral || 0;
......@@ -306,7 +330,19 @@ router.post('/thread/:tid/raise', function(req, res, next) {
console.error(err);
res.json(returnCode.BUSY);
} else {
httpService.sendRequest(req.session.user.ent_code, req.session.openUser.mid, 'thread_praise');
forumLimitActionRefService.checkLimitActionProhibitionAddIntegral(mid, function(err, flag){
if(err){
console.error(err);
}else{
if(!flag){
httpService.sendRequest(req.session.user.ent_code, req.session.openUser.mid, 'thread_praise');
}
}
});
forumThreadService.getThreadById(tid, function(err, doc) {
if (err) {
console.error(err);
......@@ -408,257 +444,304 @@ router.post('/thread/:tid/share', function(req, res, next) {
//新增文章评论
router.post('/thread/:tid/comment/create', function(req, res, next) {
var tid = req.params.tid || null;
if (tid) {
var integral = req.session.openUser.integral || 0;
var exp = req.session.openUser.exp || 0;
var destination = req.body.destination || '1';
//1.检查是否有权限
forumRolePermissionService.checkRolePermiss(req.session.user.ent_code, 'comment', integral, exp, function(err, result) {
if (err) {
console.error(err);
res.json(returnCode.BUSY);
} else {
if (result) { //有操作权限
var content = req.body.content;
if (content) { //评论不能为空
//2.获取论坛文章
forumThreadService.getThreadById(tid, function(err, thread) {
if (err) {
res.json(returnCode.BUSY);
} else {
async.parallel([
function(callback) {
var floor = 1;
var entity = {
ent_code: req.session.user.ent_code,
from: user.getMobileUser(req),
content: content,
ip: req.ip,
thread: thread,
level: '1',
floor: floor
};
var conditions = {
thread: thread._id,
level: '1'
};
forumCommentService.count(conditions, function(err, count) {
if (err) {
console.log(err);
callback(err, null);
} else {
// callback(null, count);
if(count){
entity.floor = count + 1;
}
//4.创建文章评论
forumCommentService.createComment(entity, function(err, newComment) {
if (err) {
callback(err, null);
} else {
var comments = thread.comments;
// console.log('=========');
// console.log(comments);
// console.log('=========');
var array = [];
if (comments && comments.items && comments.items.length > 0) {
array = comments.items;
var mid = req.session.openUser.mid;
forumLimitActionRefService.checkLimitActionProhibitionOfSpeech(mid, function(err, isProhibition){
if(err){
console.error(err);
res.json(returnCode.PROHIBITION_OF_SPEECH);
}else{
if(isProhibition){
res.json(returnCode.PROHIBITION_OF_SPEECH);
}else{
var tid = req.params.tid || null;
if (tid) {
var integral = req.session.openUser.integral || 0;
var exp = req.session.openUser.exp || 0;
var destination = req.body.destination || '1';
//1.检查是否有权限
forumRolePermissionService.checkRolePermiss(req.session.user.ent_code, 'comment', integral, exp, function(err, result) {
if (err) {
console.error(err);
res.json(returnCode.BUSY);
} else {
if (result) { //有操作权限
var content = req.body.content;
if (content) { //评论不能为空
//2.获取论坛文章
forumThreadService.getThreadById(tid, function(err, thread) {
if (err) {
res.json(returnCode.BUSY);
} else {
async.parallel([
function(callback) {
var floor = 1;
var entity = {
ent_code: req.session.user.ent_code,
from: user.getMobileUser(req),
content: content,
ip: req.ip,
thread: thread,
level: '1',
floor: floor
};
var conditions = {
thread: thread._id,
level: '1'
};
forumCommentService.count(conditions, function(err, count) {
if (err) {
console.log(err);
callback(err, null);
} else {
// callback(null, count);
if(count){
entity.floor = count + 1;
}
//4.创建文章评论
forumCommentService.createComment(entity, function(err, newComment) {
if (err) {
callback(err, null);
} else {
var comments = thread.comments;
// console.log('=========');
// console.log(comments);
// console.log('=========');
var array = [];
if (comments && comments.items && comments.items.length > 0) {
array = comments.items;
}
array.push(newComment._id);
forumThreadService.updateThreadById(tid, {
comments: array
}, function(err, result) {
if (err) {
callback(err, null);
} else {
callback(null, null);
}
});
}
});
}
array.push(newComment._id);
forumThreadService.updateThreadById(tid, {
comments: array
}, function(err, result) {
});
},
function(callback) {
//3.更新文章统计数据(评论数)
if (thread) {
forumThreadService.updateThreadCommentCountInc(tid, function(err, results) {
if (err) {
console.log(err);
callback(err, null);
} else {
callback(null, null);
}
});
} else {
callback('cannot find thread by id', null);
}
});
}
});
},
function(callback) {
//3.更新文章统计数据(评论数)
if (thread) {
forumThreadService.updateThreadCommentCountInc(tid, function(err, results) {
}
], function(err, results) {
if (err) {
console.log(err);
callback(err, null);
console.error(err);
res.json(returnCode.BUSY);
} else {
callback(null, null);
forumLimitActionRefService.checkLimitActionProhibitionAddIntegral(mid, function(err, flag){
if(err){
console.error(err);
}else{
if(!flag){
httpService.sendRequest(req.session.user.ent_code, req.session.openUser.mid, 'comment');
}
}
});
async.parallel([
function(callback) {
//获取最新5条评论
var conditions = {
thread: tid,
level: '1'
};
forumCommentService.getAllComment(conditions, 1, 5, function(err, results) {
if (err) {
console.log(err);
callback(err, null);
} else {
callback(null, results);
}
});
},
function(callback) {
forumThreadService.getThreadById(tid, function(err, thread) {
if (err) {
console.log(err);
callback(err, null);
} else {
callback(null, thread);
}
});
}
], function(err, results) {
if (err) {
res.json(returnCode.BUSY);
} else {
var rs = {};
rs.comments = results[0].items;
rs.commentCount = results[1].comment_count;
res.json(_.assign(rs, returnCode.SUCCESS));
}
});
}
});
} else {
callback('cannot find thread by id', null);
}
}
], function(err, results) {
if (err) {
console.error(err);
res.json(returnCode.BUSY);
} else {
httpService.sendRequest(req.session.user.ent_code, req.session.openUser.mid, 'comment');
async.parallel([
function(callback) {
//获取最新5条评论
var conditions = {
thread: tid,
level: '1'
};
forumCommentService.getAllComment(conditions, 1, 5, function(err, results) {
if (err) {
console.log(err);
callback(err, null);
} else {
callback(null, results);
}
});
},
function(callback) {
forumThreadService.getThreadById(tid, function(err, thread) {
if (err) {
console.log(err);
callback(err, null);
} else {
callback(null, thread);
}
});
}
], function(err, results) {
if (err) {
res.json(returnCode.BUSY);
} else {
var rs = {};
rs.comments = results[0].items;
rs.commentCount = results[1].comment_count;
res.json(_.assign(rs, returnCode.SUCCESS));
}
});
}
});
});
} else {
res.json(returnCode.WRONG_PARAM);
}
} else {
res.json(returnCode.ACTION_NOT_PERMISSION);
}
});
} else {
res.json(returnCode.WRONG_PARAM);
}
}
});
} else {
res.json(returnCode.ACTION_NOT_PERMISSION);
res.json(returnCode.WRONG_PARAM);
}
}
});
} else {
res.json(returnCode.WRONG_PARAM);
}
}
});
});
//新建文章评论的子评论
router.post('/thread/:tid/comment/:cid/create', function(req, res, next) {
var tid = req.params.tid || null;
var cid = req.params.cid || null;
if (tid && cid) {
var integral = req.session.openUser.integral || 0;
var exp = req.session.openUser.exp || 0;
var destination = req.body.destination || '1';
req.body.from = user.getMobileUser(req);
var mid = req.session.openUser.mid;
forumLimitActionRefService.checkLimitActionProhibitionOfSpeech(mid, function(err, isProhibition){
if(err){
console.error(err);
res.json(returnCode.PROHIBITION_OF_SPEECH);
}else{
if(isProhibition){
res.json(returnCode.PROHIBITION_OF_SPEECH);
}else{
var tid = req.params.tid || null;
var cid = req.params.cid || null;
if (tid && cid) {
var integral = req.session.openUser.integral || 0;
var exp = req.session.openUser.exp || 0;
var destination = req.body.destination || '1';
req.body.from = user.getMobileUser(req);
//1.检查是否有权限
forumRolePermissionService.checkRolePermiss(req.session.user.ent_code, 'reply', integral, exp, function(err, result) {
if (err) {
console.error(err);
res.json(returnCode.BUSY);
} else {
if (result) { //有操作权限
var content = req.body.content;
if (content) { //评论不能为空
//2.获取论坛评论
forumCommentService.getCommentById(cid, function(err, comment) {
if (err) {
res.json(returnCode.BUSY);
} else {
async.parallel([
function(callback) {
var entity = {
ent_code: req.session.user.ent_code,
from: user.getMobileUser(req),
to: req.body.to,
content: content,
ip: req.ip,
thread: tid,
level: '2'
};
//4.创建文章评论
forumCommentService.createComment(entity, function(err, newComment) {
if (err) {
callback(err, null);
} else {
var comments = comment.comments;
var array = [];
if (comments && comments.length > 0) {
array = comments;
//1.检查是否有权限
forumRolePermissionService.checkRolePermiss(req.session.user.ent_code, 'reply', integral, exp, function(err, result) {
if (err) {
console.error(err);
res.json(returnCode.BUSY);
} else {
if (result) { //有操作权限
var content = req.body.content;
if (content) { //评论不能为空
//2.获取论坛评论
forumCommentService.getCommentById(cid, function(err, comment) {
if (err) {
res.json(returnCode.BUSY);
} else {
async.parallel([
function(callback) {
var entity = {
ent_code: req.session.user.ent_code,
from: user.getMobileUser(req),
to: req.body.to,
content: content,
ip: req.ip,
thread: tid,
level: '2'
};
//4.创建文章评论
forumCommentService.createComment(entity, function(err, newComment) {
if (err) {
callback(err, null);
} else {
var comments = comment.comments;
var array = [];
if (comments && comments.length > 0) {
array = comments;
}
array.push(newComment._id);
forumCommentService.updateCommentById(cid, {
comments: array
}, function(err, result) {
if (err) {
callback(err, null);
} else {
callback(null, newComment);
}
});
}
});
},
function(callback) {
forumCommentService.updateCommentCount(cid, function(err, results) {
if (err) {
console.log(err);
callback(err, null);
} else {
callback(null, null);
}
});
}
array.push(newComment._id);
forumCommentService.updateCommentById(cid, {
comments: array
}, function(err, result) {
if (err) {
callback(err, null);
} else {
callback(null, newComment);
}
});
}
});
},
function(callback) {
forumCommentService.updateCommentCount(cid, function(err, results) {
if (err) {
console.log(err);
callback(err, null);
} else {
callback(null, null);
}
});
}
], function(err, results) {
if (err) {
console.error(err);
res.json(returnCode.BUSY);
} else {
httpService.sendRequest(req.session.user.ent_code, req.session.openUser.mid, 'reply');
ForumComment.populate(results[0], {
path: 'from to',
select: 'uid nickName icon comments'
}, function(err, c) {
if (err) {
res.json(returnCode.BUSY);
} else {
], function(err, results) {
if (err) {
console.error(err);
res.json(returnCode.BUSY);
} else {
forumLimitActionRefService.checkLimitActionProhibitionAddIntegral(mid, function(err, flag){
if(err){
console.error(err);
}else{
if(!flag){
httpService.sendRequest(req.session.user.ent_code, req.session.openUser.mid, 'reply');
}
}
});
var rs = {};
rs.data = results[0];
res.json(_.assign(rs, returnCode.SUCCESS));
}
});
// res.json(returnCode.SUCCESS);
}
});
// httpService.sendRequest(req.session.user.ent_code, req.session.openUser.mid, 'reply');
ForumComment.populate(results[0], {
path: 'from to',
select: 'uid nickName icon comments'
}, function(err, c) {
if (err) {
res.json(returnCode.BUSY);
} else {
var rs = {};
rs.data = results[0];
res.json(_.assign(rs, returnCode.SUCCESS));
}
});
// res.json(returnCode.SUCCESS);
}
});
}
});
} else {
res.json(returnCode.WRONG_PARAM);
}
} else {
res.json(returnCode.ACTION_NOT_PERMISSION);
}
});
} else {
res.json(returnCode.WRONG_PARAM);
}
}
});
} else {
res.json(returnCode.ACTION_NOT_PERMISSION);
res.json(returnCode.WRONG_PARAM);
}
}
});
} else {
res.json(returnCode.WRONG_PARAM);
}
}
});
});
//更改评论状态为3(删除)
......@@ -773,7 +856,7 @@ router.get('/thread/:tid/comment/list', function(req, res, next) {
router.post('/thread/:tid/comment/:cid/raise', function(req, res, next) {
var tid = req.params.tid || null;
var cid = req.params.cid || null;
var mid = req.session.openUser.mid;
if (tid && cid) {
var integral = req.session.openUser.integral || 0;
......@@ -831,7 +914,18 @@ router.post('/thread/:tid/comment/:cid/raise', function(req, res, next) {
console.error(err);
res.json(returnCode.BUSY);
} else {
httpService.sendRequest(req.session.user.ent_code, req.session.openUser.mid, 'comment_praise');
forumLimitActionRefService.checkLimitActionProhibitionAddIntegral(mid, function(err, flag){
if(err){
console.error(err);
}else{
if(!flag){
httpService.sendRequest(req.session.user.ent_code, req.session.openUser.mid, 'comment_praise');
}
}
});
//返回点赞总数
forumCommentService.getCommentById(cid, function(err, doc) {
if (err) {
......
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