Commit 98a887e2 authored by 邓军's avatar 邓军

优化LOG接口

parent 8cd71c2a
......@@ -41,44 +41,9 @@ router.post('/info/create', function(req, res, next) {
router.get('/info/:fid/get', function(req, res, next) {
var fid = req.params.fid || null;
//模拟数据
/*req.session.user.ent_code = 100001;
req.session.openUser = {};
req.session.openUser.mid=1;
req.session.mobileForumUser = {
openId: '54c9e321d5037010b44d4b1f',
userId: '54c9e321d5037010b44d4b1f'
};*/
var ip = '';
var userAgent = '';
var getClientIP = function(req) {
var ipAddress;
var headers = req.headers;
var forwardedIpsStr = headers['x-real-ip'] || headers['x-forwarded-for'];
if (forwardedIpsStr) {
ipAddress = forwardedIpsStr;
} else {
ipAddress = null;
}
if (!ipAddress) {
ipAddress = req.connection.remoteAddress;
}
return ipAddress;
};
ip = getClientIP(req);
userAgent = req.headers['user-agent'];
var log = {
ent_code: req.session.user,
mid: req.session.openUser.mid,
forumInfo: fid,
open_id: req.session.mobileForumUser.openId,
user: req.session.mobileForumUser.userId,
type: 2,
ip: ip,
userAgent: userAgent
};
httpService.createLog(log);
httpService.createLog(req,2,null);
if (fid) {
......
......@@ -108,50 +108,19 @@ router.get('/thread/:tid/get', function(req, res, next) {
},
function(data, callback) {
forumThreadService.getThreadById(tid, function(err, thread) {
var ip = '';
var userAgent = '';
var getClientIP = function(req) {
var ipAddress;
var headers = req.headers;
var forwardedIpsStr = headers['x-real-ip'] || headers['x-forwarded-for'];
if (forwardedIpsStr) {
ipAddress = forwardedIpsStr;
} else {
ipAddress = null;
}
if (!ipAddress) {
ipAddress = req.connection.remoteAddress;
}
return ipAddress;
};
ip = getClientIP(req);
userAgent = req.headers['user-agent'];
var log = {
ent_code: req.session.user,
mid: req.session.openUser.mid,
forumInfo: tid,
open_id: req.session.mobileForumUser.openId,
user: req.session.mobileForumUser.userId,
type: 3,
thread_type: 2,
ip:ip,
userAgent: userAgent
};
//文章类型 1、文章 2、话题 3、照片墙
if (thread.type == 1) {
log.thread_type = 2;
httpService.createLog(log);
httpService.createLog(req,3,2,tid);
} else if (thread.type == 2 && thread.level == 1) {
log.thread_type = 1;
httpService.createLog(log);
httpService.createLog(req,3,1,tid);
} else if (thread.type == 2 && thread.level == 2) {
log.thread_type = 4;
httpService.createLog(log);
httpService.createLog(req,3,4,tid);
} else if (thread.type == 3) {
log.thread_type = 3;
httpService.createLog(log);
httpService.createLog(req,3,3,tid);
}
if (err) {
callback(err, null);
} else {
......
......@@ -34,8 +34,37 @@ exports.sendRequest = function(ent_code, mid, action, messageid, integral, exp)
}
});
};
var getClientIP = function(req) {
var ipAddress;
var headers = req.headers;
var forwardedIpsStr = headers['x-real-ip'] || headers['x-forwarded-for'];
if (forwardedIpsStr) {
ipAddress = forwardedIpsStr;
} else {
ipAddress = null;
}
if (!ipAddress) {
ipAddress = req.connection.remoteAddress;
}
return ipAddress;
};
exports.createLog = function(log) {
exports.createLog = function(req, type, thread_type,id) {
var ip = getClientIP(req);
var userAgent = req.headers['user-agent'];
var log = {
ent_code: req.session.user.ent_code,
mid: req.session.openUser.mid,
forumInfo: id,
open_id: req.session.mobileForumUser.openId,
user: req.session.mobileForumUser.userId,
type: type,
thread_type: thread_type,
ip: ip,
userAgent: userAgent
};
if (log) {
var forumPVLog = new ForumPVLog(log);
var forumUVLog = new ForumUVLog(log);
......@@ -52,17 +81,16 @@ exports.createLog = function(log) {
'$gte': startTime,
'$lte': entTime
},
user:log.fid
user: log.fid
};
ForumUVLog.find(q, function(err, uv) {
if (err) {
console.error(err);
} else if (uv.length == 0 ) {
console.log(ForumUVLog);
forumUVLog.save(function(err,uv){
if(err){
console.error(err);
}
} else if (uv.length == 0) {
forumUVLog.save(function(err, uv) {
if (err) {
console.error(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