var log4js = require('log4js')
|
var logsConfig = require('../config/logs.js')
|
const uuid = require('node-uuid')
|
const mysql = require('../utils/mysql_db')
|
const jwt = require('jsonwebtoken')
|
const util = require('util')
|
const verify = util.promisify(jwt.verify)
|
let secret = 'FM_Monitor'
|
const dbhandle = require('../utils/handle_db')
|
//加载配置文件
|
log4js.configure(logsConfig)
|
//调用预先定义的日志名称
|
var resLogger = log4js.getLogger('resLogger')
|
var errorLogger = log4js.getLogger('errorLogger')
|
var handleLogger = log4js.getLogger('handleLogger')
|
var consoleLogger = log4js.getLogger()
|
|
// 格式化日志文本 加上日志头尾和换行方便查看 ==> 普通日志、请求日志、响应日志、操作日志、错误日志
|
var formatText = {
|
info: function(info) {
|
var logText = new String()
|
//响应日志头信息
|
logText += '\n' + '***************info log start ***************' + '\n'
|
//响应内容
|
logText += 'info detail: ' + '\n' + JSON.stringify(info) + '\n'
|
//响应日志结束信息
|
logText += '*************** info log end ***************' + '\n'
|
return logText
|
},
|
request: function(req, resTime) {
|
var logText = new String()
|
var method = req.method
|
//访问方法
|
logText += 'request method: ' + method + '\n'
|
//请求原始地址
|
logText += 'request originalUrl: ' + req.originalUrl + '\n'
|
//客户端ip
|
logText += 'request client ip: ' + req.ip + '\n'
|
//开始时间
|
var startTime
|
//请求参数
|
if (method === 'GET') {
|
logText += 'request query: ' + JSON.stringify(req.query) + '\n'
|
// startTime = req.query.requestStartTime;
|
} else {
|
logText += 'request body: ' + '\n' + JSON.stringify(req.body) + '\n'
|
// startTime = req.body.requestStartTime;
|
}
|
//服务器响应时间
|
logText += 'response time: ' + resTime + '\n'
|
return logText
|
},
|
response: function(ctx, resTime) {
|
console.log(ctx)
|
var logText = new String()
|
//响应日志开始
|
logText +=
|
'\n' + '*************** response log start ***************' + '\n'
|
//添加请求日志
|
logText += formatText.request(ctx.request, resTime)
|
//响应状态码
|
logText += 'response status: ' + ctx.status + '\n'
|
//响应内容
|
logText += 'response body: ' + '\n' + JSON.stringify(ctx.body) + '\n'
|
//响应日志结束
|
logText += '*************** response log end ***************' + '\n'
|
|
if (ctx.body) {
|
if (
|
Object.prototype.toString.apply(ctx.body.data) !== '[object Array]' &&
|
ctx.request.originalUrl.split('?')[0].indexOf('/user/') == -1
|
) {
|
logInsert(ctx, resTime, '响应日志')
|
}
|
}
|
|
return logText
|
},
|
handle: function(info) {
|
var logText = new String()
|
//响应日志开始
|
logText += '\n' + '***************info log start ***************' + '\n'
|
//响应内容
|
logText +=
|
'handle info detail: ' +
|
'\n' +
|
JSON.stringify(info).replace(/\\n/g, '\n') +
|
'\n'
|
//响应日志结束
|
logText += '*************** info log end ***************' + '\n'
|
return logText
|
},
|
error: function(ctx, err, resTime) {
|
var logText = new String()
|
//错误信息开始
|
logText += '\n' + '*************** error log start ***************' + '\n'
|
//添加请求日志
|
logText += formatText.request(ctx.request, resTime)
|
//错误名称
|
logText += 'err name: ' + err.name + '\n'
|
//错误信息
|
logText += 'err message: ' + err.message + '\n'
|
//错误详情
|
logText += 'err stack: ' + err.stack + '\n'
|
//错误信息结束
|
logText += '*************** error log end ***************' + '\n'
|
console.log(logText)
|
logErrorInsert(ctx, err, resTime)
|
return logText
|
}
|
}
|
|
let logInsert = async function(ctx, resTime, log_type) {
|
// const token = ctx.request.header.authorization.split(' ')[1]
|
// let payload = await verify(token, secret)
|
|
let author = ctx.request.header.authorization
|
let payload = {}
|
if (typeof author == 'undefined') {
|
payload = {}
|
} else {
|
payload = await verify(author.split(' ')[1], secret)
|
}
|
|
let sql = `INSERT INTO sys_log
|
(id,user,ip_address,response_time,response_status,response_method,originalUrl,message,create_time,log_type,params,logDes) VALUES
|
('${uuid.v4()}',
|
'${payload.user_name}',
|
'${ctx.request.ip}',
|
'${resTime}',
|
'${ctx.status}',
|
'${ctx.request.method}',
|
'${ctx.request.originalUrl.split('?')[0]}',
|
'${ctx.message}',
|
'${dbhandle.date_format(new Date(), 'YY-MM-DD hh:mm:ss')}',
|
'${log_type}',
|
'${
|
ctx.request.method == 'GET'
|
? querysour(JSON.stringify(ctx.request.query))
|
: querysour(JSON.stringify(ctx.request.body))
|
}',
|
'${
|
ctx.request.method == 'GET'
|
? ctx.request.query.logDes
|
? ctx.request.query.logDes
|
: '无描述'
|
: ctx.request.body.logDes
|
? ctx.request.body.logDes
|
: '无描述'
|
}')`
|
await mysql.query(sql)
|
}
|
|
let logErrorInsert = async function(ctx, err, resTime) {
|
let author = ctx.request.header.authorization
|
if (!typeof author == 'undefined') {
|
let payload = await verify(author.split(' ')[1], secret)
|
let sql = `INSERT INTO sys_log
|
(id,user,ip_address,response_time,response_status,response_method,originalUrl,message,create_time,log_type,params,logDes) VALUES
|
('${uuid.v4()}',
|
'${payload.user_name}',
|
'${ctx.request.ip}',
|
'${resTime}',
|
'${ctx.status}',
|
'${ctx.request.method}',
|
'${ctx.request.originalUrl.split('?')[0]}',
|
'${querysour(err.message.split(';')[0])}',
|
'${dbhandle.date_format(new Date(), 'YY-MM-DD hh:mm:ss')}',
|
'错误日志',
|
'${
|
ctx.request.method == 'GET'
|
? querysour(JSON.stringify(ctx.request.query))
|
: querysour(JSON.stringify(ctx.request.body))
|
}',
|
'${querysour(err.message.split(';')[0])}');`
|
await mysql.query(sql)
|
}
|
}
|
|
let logLogin = async function(ctx, resTime, user) {
|
let sql = `INSERT INTO sys_log
|
(id,user,ip_address,response_time,response_status,response_method,originalUrl,message,create_time,log_type,params,logDes) VALUES
|
('${uuid.v4()}',
|
'${user}',
|
'${ctx.request.ip}',
|
'${resTime}',
|
'${ctx.status}',
|
'${ctx.request.method}',
|
'${ctx.request.originalUrl.split('?')[0]}',
|
'${ctx.message}',
|
'${dbhandle.date_format(new Date(), 'YY-MM-DD hh:mm:ss')}',
|
'登入登出',
|
'--',
|
'${ctx.request.body.logDes}');`
|
await mysql.query(sql)
|
}
|
|
function querysour(e) {
|
e = e.replace(/(^\s*)|(\s*$)/g, '') //先过滤掉字符串中的空格
|
//用test函数判断字符串中有没有定义的特殊字符
|
if (/(\"|\'|\~|\*|\?|\\)/g.test(e)) {
|
//把匹配到的特殊字符替换成'////',再加上原来的字符
|
e = e.replace(
|
/(\"|\'|\~|\*|\?|\\)/g,
|
'/\\' + e.match(/(\"|\'|\~|\*|\?|\\)/g)[0]
|
)
|
}
|
return e
|
}
|
|
//封装普通日志
|
let logInfo = function(info) {
|
if (info) {
|
consoleLogger.info(formatText.info(info))
|
}
|
}
|
//封装响应日志
|
let logResponse = function(ctx, resTime) {
|
if (ctx) {
|
resLogger.info(formatText.response(ctx, resTime))
|
}
|
}
|
//封装操作日志
|
let logHandle = function(res) {
|
if (res) {
|
handleLogger.info(formatText.handle(res))
|
}
|
}
|
//封装错误日志
|
let logError = function(ctx, error, resTime) {
|
if (ctx && error) {
|
errorLogger.error(formatText.error(ctx, error, resTime))
|
}
|
}
|
module.exports = {
|
logInfo,
|
logResponse,
|
logHandle,
|
logError,
|
logLogin
|
}
|
