Skip to content

P
pisns-forum-api
Commit 4a079002 authored by 张淼's avatar 张淼
Browse files
Options

1

parent 364fbce9
Show whitespace changes
Inline Side-by-side
Showing with 300 additions and 260 deletions
app/controllers/admin/forumGroup.js
View file @ 4a079002
...@@ -118,7 +118,7 @@ router.get('/group/:gid/forumInfos', function(req, res, next) { ...@@ -118,7 +118,7 @@ router.get('/group/:gid/forumInfos', function(req, res, next) {
var gid=req.params.gid; var gid=req.params.gid;
if(gid){ if(gid){
forumInfoService.getAll(req.session.user.ent_code,gid,pageNo,pageSize,function(err,results){ forumInfoService.getAllByGid(req.session.user.ent_code,gid,pageNo,pageSize,function(err,results){
if(err){ if(err){
console.error(err); console.error(err);
res.json(returnCode.BUSY); res.json(returnCode.BUSY);
......
app/controllers/admin/forumInfo.js
View file @ 4a079002
...@@ -93,7 +93,11 @@ router.get('/info/:fid/threads', function(req, res, next) { ...@@ -93,7 +93,11 @@ router.get('/info/:fid/threads', function(req, res, next) {
var fid=req.params.fid; var fid=req.params.fid;
if(fid){ if(fid){
forumThreadService.getAllThreadByFid(req.session.user.ent_code,fid,pageNo,pageSize,function(err,results){ var conditions={
ent_code:req.session.user.ent_code,
info:fid
};
forumThreadService.getAllThreadByFid(conditions,pageNo,pageSize,function(err,results){
if(err){ if(err){
console.error(err); console.error(err);
res.json(returnCode.BUSY); res.json(returnCode.BUSY);
...@@ -113,11 +117,12 @@ router.get('/info/:fid/threads', function(req, res, next) { ...@@ -113,11 +117,12 @@ router.get('/info/:fid/threads', function(req, res, next) {
* @param {[type]} * @param {[type]}
* @return {[type]} * @return {[type]}
*/ */
router.get('/threads/list', function(req, res, next) { router.get('/infos/list', function(req, res, next) {
var pageNo = req.query.pageNo || 1; var pageNo = req.query.pageNo || 1;
var pageSize = req.query.pageSize || 10; var pageSize = req.query.pageSize || 10;
var groupId=req.query.groupId || null;
forumThreadService.getAllThread(req.session.user.ent_code,pageNo,pageSize,function(err,results){ forumInfoService.getAllByGid(req.session.user.ent_code,groupId,pageNo,pageSize,function(err,results){
if(err){ if(err){
console.error(err); console.error(err);
res.json(returnCode.BUSY); res.json(returnCode.BUSY);
......
app/controllers/admin/forumTag.js
View file @ 4a079002
...@@ -5,7 +5,9 @@ var express = require('express'), ...@@ -5,7 +5,9 @@ var express = require('express'),
_ = require('lodash'); _ = require('lodash');
var mongoose = require('mongoose'); var mongoose = require('mongoose');
var ForumTag = mongoose.model('ForumTag'); var ForumTag = mongoose.model('ForumTag');
var ForumThread = mongoose.model('ForumThread');
var forumTagService=require('../../service/forumTagService');
module.exports = function(app) { module.exports = function(app) {
app.use('/admin/forum', router); app.use('/admin/forum', router);
}; };
...@@ -14,13 +16,12 @@ module.exports = function(app) { ...@@ -14,13 +16,12 @@ module.exports = function(app) {
router.post('/tag/create', function(req, res, next) { router.post('/tag/create', function(req, res, next) {
var rs = {}; var rs = {};
req.body.ent_code=req.session.user.ent_code; req.body.ent_code=req.session.user.ent_code;
var forum = new ForumTag(req.body); forumTagService.createTag(req.body,function(err,entity){
forum.save(function(err, forum) {
if (err) { if (err) {
console.error(err); console.error(err);
res.json(returnCode.BUSY); res.json(returnCode.BUSY);
} else { } else {
rs.data = {'id':forum._id}; rs.data = {'id':entity._id};
res.json(_.assign(rs, returnCode.SUCCESS)); res.json(_.assign(rs, returnCode.SUCCESS));
} }
}); });
...@@ -29,8 +30,8 @@ router.post('/tag/create', function(req, res, next) { ...@@ -29,8 +30,8 @@ router.post('/tag/create', function(req, res, next) {
//删除论坛标签 //删除论坛标签
router.post('/tag/:tid/delete', function(req, res, next) { router.post('/tag/:tid/delete', function(req, res, next) {
var tid=req.params.tid; var tid=req.params.tid;
if(tid){
ForumTag.remove({ _id: tid},function(err,result){ forumTagService.deleteTagById(tid,function(err,entity){
if (err) { if (err) {
console.error(err); console.error(err);
res.json(returnCode.BUSY); res.json(returnCode.BUSY);
...@@ -38,13 +39,16 @@ router.post('/tag/:tid/delete', function(req, res, next) { ...@@ -38,13 +39,16 @@ router.post('/tag/:tid/delete', function(req, res, next) {
res.json(returnCode.SUCCESS); res.json(returnCode.SUCCESS);
} }
}); });
}else{
res.json(returnCode.WRONG_PARAM);
}
}); });
//更新论坛标签 //更新论坛标签
router.post('/tag/:tid/update', function(req, res, next) { router.post('/tag/:tid/update', function(req, res, next) {
var tid=req.params.tid; var tid=req.params.tid;
if(tid){
ForumTag.update({ _id: tid}, req.body,null,function(err,result){ forumTagService.updateTagById(tid,req.body,function(err,entity){
if (err) { if (err) {
console.error(err); console.error(err);
res.json(returnCode.BUSY); res.json(returnCode.BUSY);
...@@ -52,19 +56,22 @@ router.post('/tag/:tid/update', function(req, res, next) { ...@@ -52,19 +56,22 @@ router.post('/tag/:tid/update', function(req, res, next) {
res.json(returnCode.SUCCESS); res.json(returnCode.SUCCESS);
} }
}); });
}else{
res.json(returnCode.WRONG_PARAM);
}
}); });
//获取论坛标签 //获取论坛标签
router.get('/tag/:tid/get', function(req, res, next) { router.get('/tag/:tid/get', function(req, res, next) {
var tid = req.params.tid || null; var tid = req.params.tid || null;
var rs = {}; var rs = {};
if (fid) { if (tid) {
ForumTag.findById(tid, function(err, thread) { forumTagService.getTagById(tid,function(err,entity){
if (err) { if (err) {
console.error(err); console.error(err);
res.json(returnCode.BUSY); res.json(returnCode.BUSY);
} else { } else {
rs.data = thread; rs.data = entity;
res.json(_.assign(rs, returnCode.SUCCESS)); res.json(_.assign(rs, returnCode.SUCCESS));
} }
}); });
...@@ -78,58 +85,12 @@ router.get('/tag/list', function(req, res, next) { ...@@ -78,58 +85,12 @@ router.get('/tag/list', function(req, res, next) {
var pageNo = req.query.pageNo || 1; var pageNo = req.query.pageNo || 1;
var pageSize = req.query.pageSize || 10; var pageSize = req.query.pageSize || 10;
var rs = {}; forumTagService.getAllTag(req.session.user.ent_code,pageNo,pageSize,function(err,results){
var group = new ForumGroup(req.body);
ForumTag.count({ent_code:req.session.user.ent_code}, function (err, count) {
if(err){
console.error(err);
res.json(returnCode.BUSY);
}else{
var skip = (pageNo - 1) * pageSize;
var limit = count - skip > pageSize ? pageSize : (count - skip);
ForumTag.find({ent_code:req.session.user.ent_code}, null, {skip: skip,limit:limit},function(err,docs){
if (err) {
console.error(err);
res.json(returnCode.BUSY);
} else {
rs.total=count;
rs.pageNo=pageNo;
rs.pageSize=pageSize;
rs.items=docs;
res.json(_.assign(rs, returnCode.SUCCESS));
}
});
}
});
});
//查询标签下的文章列表
router.get('/tag/:tid/threads', function(req, res, next) {
var pageNo = req.query.pageNo || 1;
var pageSize = req.query.pageSize || 10;
var tid=req.params.tid;
var rs = {};
var group = new ForumGroup(req.body);
ForumThread.count({ent_code:req.session.user.ent_code,tag:tid}, function (err, count) {
if(err){ if(err){
console.error(err); console.error(err);
res.json(returnCode.BUSY); res.json(returnCode.BUSY);
}else{ }else{
var skip = (pageNo - 1) * pageSize; res.json(_.assign(results, returnCode.SUCCESS));
var limit = count - skip > pageSize ? pageSize : (count - skip);
ForumThread.find({ent_code:req.session.user.ent_code,tag:tid}, null, {skip: skip,limit:limit},function(err,docs){
if (err) {
console.error(err);
res.json(returnCode.BUSY);
} else {
rs.total=count;
rs.pageNo=pageNo;
rs.pageSize=pageSize;
rs.items=docs;
res.json(_.assign(rs, returnCode.SUCCESS));
}
});
} }
}); });
}); });
\ No newline at end of file
app/controllers/admin/forumThread.js
View file @ 4a079002
...@@ -82,3 +82,47 @@ router.post('/thread/:tid/delete', function(req, res, next) { ...@@ -82,3 +82,47 @@ router.post('/thread/:tid/delete', function(req, res, next) {
res.json(returnCode.WRONG_PARAM); res.json(returnCode.WRONG_PARAM);
} }
}); });
//文章置顶
router.post('/thread/:tid/:fid/top', function(req, res, next) {
var tid=req.params.tid;
var fid=req.params.fid;
if(tid && fid){
forumThreadService.updateTopByThreadId(fid,tid,function(err,thread){
if(err){
res.json(returnCode.BUSY);
}else{
res.json(returnCode.SUCCESS);
}
});
}else{
res.json(returnCode.WRONG_PARAM);
}
});
/**
* [description]
* @param {[type]}
* @param {[type]}
* @param {[type]}
* @return {[type]}
*/
router.get('/threads/list', function(req, res, next) {
var pageNo = req.query.pageNo || 1;
var pageSize = req.query.pageSize || 10;
var infoId=req.query.infoId;
var conditions={
ent_code:req.session.user.ent_code,
};
if(infoId){
conditions.info=infoId;
}
forumThreadService.getAllThreadByFid(conditions,pageNo,pageSize,function(err,results){
if(err){
console.error(err);
res.json(returnCode.BUSY);
}else{
res.json(_.assign(results, returnCode.SUCCESS));
}
});
});
\ No newline at end of file
app/controllers/mobile/forumGroup.js
View file @ 4a079002
...@@ -87,7 +87,7 @@ router.get('/group/:gid/forumInfos', function(req, res, next) { ...@@ -87,7 +87,7 @@ router.get('/group/:gid/forumInfos', function(req, res, next) {
var gid=req.params.gid; var gid=req.params.gid;
if(gid){ if(gid){
forumInfoService.getAll(req.session.user.ent_code,gid,pageNo,pageSize,function(err,results){ forumInfoService.getAllByGid(req.session.user.ent_code,gid,pageNo,pageSize,function(err,results){
if(err){ if(err){
console.error(err); console.error(err);
res.json(returnCode.BUSY); res.json(returnCode.BUSY);
......
app/controllers/mobile/forumInfo.js
View file @ 4a079002
...@@ -91,9 +91,14 @@ router.get('/info/:fid/threads', function(req, res, next) { ...@@ -91,9 +91,14 @@ router.get('/info/:fid/threads', function(req, res, next) {
var pageNo = req.query.pageNo || 1; var pageNo = req.query.pageNo || 1;
var pageSize = req.query.pageSize || 10; var pageSize = req.query.pageSize || 10;
var fid=req.params.fid; var fid=req.params.fid;
var conditions={
ent_code:req.session.user.ent_code,
};
if(fid){
conditions.info=fid;
}
if(fid){ if(fid){
forumThreadService.getAll(req.session.user.ent_code,fid,pageNo,pageSize,function(err,results){ forumThreadService.getAllThreadByFid(conditions,pageNo,pageSize,function(err,results){
if(err){ if(err){
console.error(err); console.error(err);
res.json(returnCode.BUSY); res.json(returnCode.BUSY);
......
app/controllers/mobile/forumTag.js
View file @ 4a079002
...@@ -4,101 +4,27 @@ var express = require('express'), ...@@ -4,101 +4,27 @@ var express = require('express'),
returnCode = require('../../utils/returnCode'), returnCode = require('../../utils/returnCode'),
_ = require('lodash'); _ = require('lodash');
var mongoose = require('mongoose'); var mongoose = require('mongoose');
var ForumTag = mongoose.model('ForumTag');
var ForumThread = mongoose.model('ForumThread'); var forumTagService=require('../../service/forumTagService');
var forumThreadService=require('../../service/forumThreadService');
module.exports = function(app) { module.exports = function(app) {
app.use('/v1/forum', router); app.use('/v1/forum', router);
}; };
//新增论坛标签
router.post('/tag/create', function(req, res, next) {
var rs = {};
req.body.ent_code=req.session.user.ent_code;
var forum = new ForumTag(req.body);
forum.save(function(err, forum) {
if (err) {
console.error(err);
res.json(returnCode.BUSY);
} else {
rs.data = {'id':forum._id};
res.json(_.assign(rs, returnCode.SUCCESS));
}
});
});
//删除论坛标签
router.post('/tag/:tid/delete', function(req, res, next) {
var tid=req.params.tid;
ForumTag.remove({ _id: tid},function(err,result){
if (err) {
console.error(err);
res.json(returnCode.BUSY);
} else {
res.json(returnCode.SUCCESS);
}
});
});
//更新论坛标签
router.post('/tag/:tid/update', function(req, res, next) {
var tid=req.params.tid;
ForumTag.update({ _id: tid}, req.body,null,function(err,result){
if (err) {
console.error(err);
res.json(returnCode.BUSY);
} else {
res.json(returnCode.SUCCESS);
}
});
});
//获取论坛标签
router.get('/tag/:tid/get', function(req, res, next) {
var tid = req.params.tid || null;
var rs = {};
if (fid) {
ForumTag.findById(tid, function(err, thread) {
if (err) {
console.error(err);
res.json(returnCode.BUSY);
} else {
rs.data = thread;
res.json(_.assign(rs, returnCode.SUCCESS));
}
});
} else {
res.json(returnCode.WRONG_PARAM);
}
});
//查询所有标签 //查询所有标签
router.get('/tag/list', function(req, res, next) { router.get('/tag/list', function(req, res, next) {
var pageNo = req.query.pageNo || 1; var pageNo = req.query.pageNo || 1;
var pageSize = req.query.pageSize || 10; var pageSize = req.query.pageSize || 10;
var rs = {}; forumTagService.getAllTag(req.session.user.ent_code,pageNo,pageSize,function(err,results){
var group = new ForumGroup(req.body);
ForumTag.count({ent_code:req.session.user.ent_code}, function (err, count) {
if(err){ if(err){
console.error(err); console.error(err);
res.json(returnCode.BUSY); res.json(returnCode.BUSY);
}else{ }else{
var skip = (pageNo - 1) * pageSize; res.json(_.assign(results, returnCode.SUCCESS));
var limit = count - skip > pageSize ? pageSize : (count - skip);
ForumTag.find({ent_code:req.session.user.ent_code}, null, {skip: skip,limit:limit},function(err,docs){
if (err) {
console.error(err);
res.json(returnCode.BUSY);
} else {
rs.total=count;
rs.pageNo=pageNo;
rs.pageSize=pageSize;
rs.items=docs;
res.json(_.assign(rs, returnCode.SUCCESS));
}
});
} }
}); });
}); });
...@@ -108,28 +34,16 @@ router.get('/tag/:tid/threads', function(req, res, next) { ...@@ -108,28 +34,16 @@ router.get('/tag/:tid/threads', function(req, res, next) {
var pageNo = req.query.pageNo || 1; var pageNo = req.query.pageNo || 1;
var pageSize = req.query.pageSize || 10; var pageSize = req.query.pageSize || 10;
var tid=req.params.tid; var tid=req.params.tid;
var conditions={
ent_code:req.session.user.ent_code
};
var rs = {}; forumThreadService.getAllThreadByFid(conditions,pageNo,pageSize,function(err,results){
var group = new ForumGroup(req.body);
ForumThread.count({ent_code:req.session.user.ent_code,tag:tid}, function (err, count) {
if(err){ if(err){
console.error(err); console.error(err);
res.json(returnCode.BUSY); res.json(returnCode.BUSY);
}else{ }else{
var skip = (pageNo - 1) * pageSize; res.json(_.assign(results, returnCode.SUCCESS));
var limit = count - skip > pageSize ? pageSize : (count - skip);
ForumThread.find({ent_code:req.session.user.ent_code,tag:tid}, null, {skip: skip,limit:limit},function(err,docs){
if (err) {
console.error(err);
res.json(returnCode.BUSY);
} else {
rs.total=count;
rs.pageNo=pageNo;
rs.pageSize=pageSize;
rs.items=docs;
res.json(_.assign(rs, returnCode.SUCCESS));
}
});
} }
}); });
}); });
\ No newline at end of file
app/controllers/mobile/forumThread.js
View file @ 4a079002
...@@ -43,8 +43,12 @@ router.post('/thread/create', function(req, res, next) { ...@@ -43,8 +43,12 @@ router.post('/thread/create', function(req, res, next) {
router.get('/threads/list', function(req, res, next) { router.get('/threads/list', function(req, res, next) {
var pageNo = req.query.pageNo || 1; var pageNo = req.query.pageNo || 1;
var pageSize = req.query.pageSize || 10; var pageSize = req.query.pageSize || 10;
var conditions={
ent_code:req.session.user.ent_code,
status:1
};
forumThreadService.getAllThread(req.session.user.ent_code,pageNo,pageSize,function(err,results){ forumThreadService.getAllThreadByFid(conditions,pageNo,pageSize,function(err,results){
if(err){ if(err){
console.error(err); console.error(err);
res.json(returnCode.BUSY); res.json(returnCode.BUSY);
......
app/models/forumInfo.js
View file @ 4a079002
...@@ -41,6 +41,11 @@ var ForumInfoSchema = new Schema({ ...@@ -41,6 +41,11 @@ var ForumInfoSchema = new Schema({
type: Number, type: Number,
require: true, require: true,
default: 1 default: 1
},
created: {
type: Date,
required: true,
default:Date.now
} }
}, { }, {
......
app/models/forumTag.js
View file @ 4a079002
...@@ -30,6 +30,11 @@ var ForumTagSchema = new Schema({ ...@@ -30,6 +30,11 @@ var ForumTagSchema = new Schema({
type: Number, type: Number,
require: true, require: true,
default: 1 default: 1
},
created: {
type: Date,
required: true,
default:Date.now
} }
}, { }, {
......
app/service/forumInfoService.js
View file @ 4a079002
...@@ -52,8 +52,13 @@ exports.deleteInfoById=function(fid,callback){ ...@@ -52,8 +52,13 @@ exports.deleteInfoById=function(fid,callback){
}; };
//获取数量 //获取数量
function countAll(ent_code,gid,callback) { function countAllByGid(ent_code,gid,callback) {
ForumInfo.count({ent_code:ent_code,group:gid}, function (err, count) { var condition={};
condition.ent_code=ent_code;
if(gid){
condition.group=gid;
}
ForumInfo.count(condition, function (err, count) {
if(err){ if(err){
console.error(err); console.error(err);
callback(err,null); callback(err,null);
...@@ -64,15 +69,20 @@ function countAll(ent_code,gid,callback) { ...@@ -64,15 +69,20 @@ function countAll(ent_code,gid,callback) {
} }
//获取全部列表数据 //获取全部列表数据
exports.getAll= function(ent_code,gid,pageNo,pageSize,callback) { exports.getAllByGid= function(ent_code,gid,pageNo,pageSize,callback) {
countAll(ent_code,gid,function(err,count){ countAllByGid(ent_code,gid,function(err,count){
if(err){ if(err){
console.error(err); console.error(err);
callback(err,null); callback(err,null);
}else{ }else{
var skip = (pageNo - 1) * pageSize; var skip = (pageNo - 1) * pageSize;
var limit = count - skip > pageSize ? pageSize : (count - skip); var limit = count - skip > pageSize ? pageSize : (count - skip);
ForumInfo.find({ent_code:ent_code,group:gid}, null, {skip: skip,limit:limit},function(err,docs){ var condition={};
condition.ent_code=ent_code;
if(gid){
condition.group=gid;
}
ForumInfo.find(condition, null, {skip: skip,limit:limit,sort:'created'},function(err,docs){
if (err) { if (err) {
console.error(err); console.error(err);
callback(err,null); callback(err,null);
......
app/service/forumTagService.js 0 → 100644
View file @ 4a079002
'use strict';
var mongoose = require('mongoose');
var ForumTag = mongoose.model('ForumTag');
//创建
exports.createTag=function(entity,callback){
var forum = new ForumTag(entity);
forum.save(function(err, forum) {
if (err) {
console.error(err);
callback(err,null);
} else {
callback(null,forum);
}
});
};
//根据ID获取论坛板块
exports.getTagById=function(tid,callback){
ForumTag.findById(tid, function(err, tag) {
if (err) {
console.error(err);
callback(err,null);
} else {
callback(null,tag);
}
});
};
//根据ID更新论坛板块
exports.updateTagById=function(tid,entity,callback){
ForumTag.update({ _id: tid}, entity,null,function(err,result){
if (err) {
console.error(err);
callback(err,null);
} else {
callback(null,null);
}
});
};
//根据ID删除标签
exports.deleteTagById=function(tid,callback){
ForumTag.remove({ _id: tid},function(err,result){
if (err) {
console.error(err);
callback(err,null);
} else {
callback(null,null);
}
});
};
//获取数量
function countAll(ent_code,callback) {
ForumTag.count({ent_code:ent_code}, function (err, count) {
if(err){
console.error(err);
callback(err,null);
}else{
callback(null,count);
}
});
}
//获取全部列表数据
exports.getAllTag= function(ent_code,pageNo,pageSize,callback) {
countAll(ent_code,function(err,count){
if(err){
console.error(err);
callback(err,null);
}else{
var skip = (pageNo - 1) * pageSize;
var limit = count - skip > pageSize ? pageSize : (count - skip);
ForumTag.find({ent_code:ent_code}, null, {skip: skip,limit:limit,sort:'created'},function(err,docs){
if (err) {
console.error(err);
callback(err,null);
} else {
var obj={};
obj.total=count;
obj.pageNo=pageNo;
obj.pageSize=pageSize;
obj.items=docs;
callback(null,obj);
}
});
}
});
};
app/service/forumThreadService.js
View file @ 4a079002
...@@ -19,14 +19,42 @@ exports.createThread=function(entity,callback){ ...@@ -19,14 +19,42 @@ exports.createThread=function(entity,callback){
//根据ID获取文章 //根据ID获取文章
exports.getThreadById=function(tid,callback){ exports.getThreadById=function(tid,callback){
ForumThread.findById(tid, function(err, thread) { var conditions={
_id:tid
};
ForumThread.find(conditions).populate('from').populate('info').populate({path:'comments',options:{limit:5}, select:'from to created content'}).exec(function(err, docs) {
if (err) { if (err) {
console.error(err); console.error(err);
callback(err,null); callback(err,null);
} else {
var thread={};
if (docs && docs.length > 0) {
thread=docs[0];
populateComment(thread, function(err,results){
if (err) {
console.log(err);
callback(null, null);
} else { } else {
callback(null,thread); callback(null,thread);
} }
}); });
}else{
callback(null,thread);
}
}
});
// ForumThread.findById(tid, function(err, thread) {
// if (err) {
// console.error(err);
// callback(err,null);
// } else {
// callback(null,thread);
// }
// });
}; };
//根据ID更新文章 //根据ID更新文章
...@@ -86,8 +114,8 @@ function populateComment(doc, callback){ ...@@ -86,8 +114,8 @@ function populateComment(doc, callback){
} }
//获取数量 //获取数量
function countAllByFid(ent_code,fid,callback) { function countAllByFid(conditions,callback) {
ForumThread.count({ent_code:ent_code,info:fid}, function (err, count) { ForumThread.count(conditions, function (err, count) {
if(err){ if(err){
console.error(err); console.error(err);
callback(err,null); callback(err,null);
...@@ -98,54 +126,16 @@ function countAllByFid(ent_code,fid,callback) { ...@@ -98,54 +126,16 @@ function countAllByFid(ent_code,fid,callback) {
} }
//获取全部列表数据 //获取全部列表数据
exports.getAllThreadByFid= function(ent_code,fid,pageNo,pageSize,callback) { exports.getAllThreadByFid= function(conditions,pageNo,pageSize,callback) {
countAllByFid(ent_code,function(err,count){ countAllByFid(conditions,function(err,count){
if(err){ if(err){
console.error(err); console.error(err);
callback(err,null); callback(err,null);
}else{ }else{
var skip = (pageNo - 1) * pageSize; var skip = (pageNo - 1) * pageSize;
var limit = count - skip > pageSize ? pageSize : (count - skip); var limit = count - skip > pageSize ? pageSize : (count - skip);
ForumThread.find({ent_code:ent_code,info:fid}, null, {skip: skip,limit:limit},function(err,docs){
if (err) {
console.error(err);
callback(err,null);
} else {
var obj={};
obj.total=count;
obj.pageNo=pageNo;
obj.pageSize=pageSize;
obj.items=docs;
callback(null,obj);
}
});
}
});
};
//获取数量
function countAll(ent_code,callback) {
ForumThread.count({ent_code:ent_code}, function (err, count) {
if(err){
console.error(err);
callback(err,null);
}else{
callback(null,count);
}
});
}
ForumThread.find(conditions).populate('from').populate('info').populate({path:'comments',options:{limit:5}, select:'from to created content'}).limit(limit).skip(skip).sort('-top created').exec(function(err, docs) {
//获取全部列表数据
exports.getAllThread= function(ent_code,pageNo,pageSize,callback) {
countAll(ent_code,function(err,count){
if(err){
console.error(err);
callback(err,null);
}else{
var skip = (pageNo - 1) * pageSize;
var limit = count - skip > pageSize ? pageSize : (count - skip);
ForumThread.find({ent_code:ent_code}).populate('from').populate({path:'comments',options:{limit:5}, select:'from to created content'}).limit(limit).skip(skip).exec(function(err, docs) {
if (err) { if (err) {
console.error(err); console.error(err);
callback(err,null); callback(err,null);
...@@ -172,22 +162,28 @@ exports.getAllThread= function(ent_code,pageNo,pageSize,callback) { ...@@ -172,22 +162,28 @@ exports.getAllThread= function(ent_code,pageNo,pageSize,callback) {
} }
}); });
}else{
callback(null,obj);
} }
} }
}); });
// ForumThread.find({ent_code:ent_code}, null, {skip: skip,limit:limit},function(err,docs){ }
// if (err) { });
// console.error(err); };
// callback(err,null);
// } else { //根据板块ID更新板块下的top为0,并把当前文章的top设为1（置顶）
// var obj={}; exports.updateTopByThreadId=function(infoId,threadId,callback){
// obj.total=count; ForumThread.update({info:infoId}, {top:0},{multi:true}, function(err, doc) {
// obj.pageNo=pageNo; if(err){
// obj.pageSize=pageSize; callback(err,null);
// obj.items=docs; }else{
// callback(null,obj); ForumThread.findOneAndUpdate({_id:threadId}, {top:1}, function(err, doc) {
// } if(err){
// }); callback(err,null);
}else{
callback(null,null);
}
});
} }
}); });
}; };
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