Commit 4282072b authored by strong's avatar strong

Merge branch 'Notice' into SANDBOX

parents 2d9cb4e1 ed71dc9d
'use strict'; 'use strict';
var express = require('express'), var express = require('express'),
router = express.Router(), router = express.Router(),
user = require('../../utils/user'),
returnCode = require('../../utils/returnCode'), returnCode = require('../../utils/returnCode'),
commentTips = require('../../utils/commentTips'), commentTips = require('../../utils/commentTips'),
_ = require('lodash'); _ = require('lodash');
...@@ -10,8 +11,9 @@ module.exports = function(app) { ...@@ -10,8 +11,9 @@ module.exports = function(app) {
}; };
router.get('/commentTips', function(req, res, next) { router.get('/commentTips', function(req, res, next) {
var openId = req.session.openUser.openId; var userId = user.getMobileUser(req);
commentTips.get(openId,function(err,result){ var entcode = req.session.user.ent_code;
commentTips.get(entcode,userId,function(err,result){
if(err){ if(err){
res.json(returnCode.UNCHECK_ERROR(err)); res.json(returnCode.UNCHECK_ERROR(err));
}else{ }else{
...@@ -20,9 +22,10 @@ router.get('/commentTips', function(req, res, next) { ...@@ -20,9 +22,10 @@ router.get('/commentTips', function(req, res, next) {
}); });
}); });
router.put('/commentTips', function(req, res, next) { router.put('/commentTips/:id', function(req, res, next) {
var openId = req.session.openUser.openId; var userId = req.params.id;
commentTips.incrTips(openId,function(err,result){ var entcode = req.session.user.ent_code;
commentTips.incrTips(entcode,userId,function(err,result){
if(err){ if(err){
res.json(returnCode.UNCHECK_ERROR(err)); res.json(returnCode.UNCHECK_ERROR(err));
}else{ }else{
...@@ -32,8 +35,9 @@ router.put('/commentTips', function(req, res, next) { ...@@ -32,8 +35,9 @@ router.put('/commentTips', function(req, res, next) {
}); });
router.put('/commentTips/del', function(req, res, next) { router.put('/commentTips/del', function(req, res, next) {
var openId = req.session.openUser.openId; var userId = user.getMobileUser(req);
commentTips.clear(openId,function(err,result){ var entcode = req.session.user.ent_code;
commentTips.clear(entcode,userId,function(err,result){
if(err){ if(err){
res.json(returnCode.UNCHECK_ERROR(err)); res.json(returnCode.UNCHECK_ERROR(err));
}else{ }else{
......
...@@ -14,7 +14,7 @@ var forumShareLogService = require('../../service/forumShareLogService'); ...@@ -14,7 +14,7 @@ var forumShareLogService = require('../../service/forumShareLogService');
var forumCommentService = require('../../service/forumCommentService'); var forumCommentService = require('../../service/forumCommentService');
var forumUserThreadControlService = require('../../service/forumUserThreadControlService'); var forumUserThreadControlService = require('../../service/forumUserThreadControlService');
var forumLimitActionRefService = require('../../service/forumLimitActionRefService'); var forumLimitActionRefService = require('../../service/forumLimitActionRefService');
var commentTips = require('../../utils/commentTips');
var httpService = require('../../service/httpService'); var httpService = require('../../service/httpService');
var user = require('../../utils/user'); var user = require('../../utils/user');
...@@ -505,6 +505,8 @@ router.post('/thread/:tid/comment/create', function(req, res, next) { ...@@ -505,6 +505,8 @@ router.post('/thread/:tid/comment/create', function(req, res, next) {
if (err) { if (err) {
callback(err, null); callback(err, null);
} else { } else {
//
commentTips.incrTips(req.session.user.ent_code,thread.from);
var comments = thread.comments; var comments = thread.comments;
// console.log('========='); // console.log('=========');
// console.log(comments); // console.log(comments);
...@@ -664,6 +666,7 @@ router.post('/thread/:tid/comment/:cid/create', function(req, res, next) { ...@@ -664,6 +666,7 @@ router.post('/thread/:tid/comment/:cid/create', function(req, res, next) {
if (err) { if (err) {
callback(err, null); callback(err, null);
} else { } else {
commentTips.incrTips(req.session.user.ent_code,req.body.to);
var comments = comment.comments; var comments = comment.comments;
var array = []; var array = [];
if (comments && comments.length > 0) { if (comments && comments.length > 0) {
......
'use strict'; 'use strict';
var redis=global.redis; var redis=global.redis;
var prefix = 'comment-tips-'; var prefix = '_forum_comment_count_';
var expire = 60*60*24*180;
function getKey(openId){ function getKey(entcode,userId){
return prefix + openId; return entcode + prefix + userId;
} }
exports.clear = function(openId,callback){ exports.clear = function(entcode,userId,callback){
var key = getKey(openId); var key = getKey(entcode,userId);
if(!redis){ if(!redis){
console.log('redis error'); console.log('redis error');
return callback && callback('error'); return callback && callback('error');
...@@ -18,19 +18,21 @@ exports.clear = function(openId,callback){ ...@@ -18,19 +18,21 @@ exports.clear = function(openId,callback){
}); });
}; };
exports.incrTips=function(openId,callback){ exports.incrTips=function(entcode,userId,callback){
var key = getKey(openId); var key = getKey(entcode,userId);
if(!redis){ if(!redis){
console.log('redis error'); console.log('redis error');
return callback && callback('error'); return callback && callback('error');
} }
redis.incr(key, function(error, res){ redis.incr(key, function(error, res){
redis.expire(key, expire);
return callback && callback(error, !!res); return callback && callback(error, !!res);
}); });
}; };
exports.get=function(openId,callback){ exports.get=function(entcode,userId,callback){
var key = getKey(openId); var key = getKey(entcode,userId);
if(!redis){ if(!redis){
console.log('redis error'); console.log('redis error');
return callback && callback('error'); return callback && callback('error');
......
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