添加日志
This commit is contained in:
+1
-1
@@ -171,7 +171,7 @@ function errorHandler(err: Error, msg: any, resp: any,
|
|||||||
session: FrontendOrBackendSession, cb: HandlerCallback) {
|
session: FrontendOrBackendSession, cb: HandlerCallback) {
|
||||||
const errCode = genCode(10);
|
const errCode = genCode(10);
|
||||||
if(err.message == 'globalFilter') {
|
if(err.message == 'globalFilter') {
|
||||||
infologger.debug('global after ', msg && JSON.stringify(msg), resp && JSON.stringify(resp), session && session.get('roleId'));
|
infologger.debug('global after ', msg && msg.logCode, msg && JSON.stringify(msg), resp && JSON.stringify(resp), session && session.get('roleId'));
|
||||||
} else {
|
} else {
|
||||||
errlogger.error(`${pinus.app.serverId} error handler \n msg[${JSON.stringify(msg)}] \n resp[${JSON.stringify(resp)}] \n sessionId:${JSON.stringify(session.export())} \n error 【${errCode}】 stack: ${err.stack}`);
|
errlogger.error(`${pinus.app.serverId} error handler \n msg[${JSON.stringify(msg)}] \n resp[${JSON.stringify(resp)}] \n sessionId:${JSON.stringify(session.export())} \n error 【${errCode}】 stack: ${err.stack}`);
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -37,6 +37,8 @@ class Filter {
|
|||||||
// console.log('*********** global before ip', ip)
|
// console.log('*********** global before ip', ip)
|
||||||
let guildCode = session.get('guildCode');
|
let guildCode = session.get('guildCode');
|
||||||
let blockType = session.get('blockType');
|
let blockType = session.get('blockType');
|
||||||
|
const logCode = genCode(10);
|
||||||
|
infologger.debug('global before', logCode, routeRecord.route, session && session.get('roleId'));
|
||||||
|
|
||||||
if(!this.checkPassEncrypt(routeRecord.route)) {
|
if(!this.checkPassEncrypt(routeRecord.route)) {
|
||||||
msg = this.decryptMsg(msg, session);
|
msg = this.decryptMsg(msg, session);
|
||||||
@@ -45,7 +47,7 @@ class Filter {
|
|||||||
if(!this.checkTimeStamp(msg)) return next(new Error('globalFilter'), resResult(STATUS.TIMESTAMP_ERR, { route: routeRecord.route }));
|
if(!this.checkTimeStamp(msg)) return next(new Error('globalFilter'), resResult(STATUS.TIMESTAMP_ERR, { route: routeRecord.route }));
|
||||||
if(!this.checkDuplicateAccess(msg)) return next(new Error('globalFilter'), resResult(STATUS.DUPLICATE_ACCESS, { route: routeRecord.route }))
|
if(!this.checkDuplicateAccess(msg)) return next(new Error('globalFilter'), resResult(STATUS.DUPLICATE_ACCESS, { route: routeRecord.route }))
|
||||||
}
|
}
|
||||||
|
msg = this.setMsg(msg, { logCode });
|
||||||
// 访问频率控制
|
// 访问频率控制
|
||||||
if(!this.checkFrequency(routeRecord.route, msg, roleId)) {
|
if(!this.checkFrequency(routeRecord.route, msg, roleId)) {
|
||||||
return next(new Error('globalFilter'), resResult(STATUS.ACCESS_BUSY, { route: routeRecord.route }));
|
return next(new Error('globalFilter'), resResult(STATUS.ACCESS_BUSY, { route: routeRecord.route }));
|
||||||
@@ -88,7 +90,7 @@ class Filter {
|
|||||||
//刷新
|
//刷新
|
||||||
await refresh(session);
|
await refresh(session);
|
||||||
|
|
||||||
infologger.debug('global after ', routeRecord.route, msg && JSON.stringify(msg), resp && JSON.stringify(resp), session && session.get('roleId'));
|
infologger.debug('global after', msg && msg.logCode, routeRecord.route, msg && JSON.stringify(msg), resp && JSON.stringify(resp), session && session.get('roleId'));
|
||||||
if(!this.checkPassEncrypt(routeRecord.route)) {
|
if(!this.checkPassEncrypt(routeRecord.route)) {
|
||||||
let data = this.encryptMsg(resp, session);
|
let data = this.encryptMsg(resp, session);
|
||||||
if(!data) return next(new Error('response data err'));
|
if(!data) return next(new Error('response data err'));
|
||||||
|
|||||||
Reference in New Issue
Block a user