Skip to content

Z
zhichan
Commit 05260404 by 宋毅
Options

tj

parent 0ce9a094
Showing with 161 additions and 98 deletions
igirl-channel-jdweb/app/base/controller/impl/trademark/tmqueryCtl.js
......@@ -10,6 +10,8 @@ class tmqueryCtl extends CtlBase {
jd: { appkey: "201911251551", secret: "56006077354d48858026c80c0e10bef6" }
};
this.execClient = system.getObject("util.execClient");
this.logClient = system.getObject("util.logClient");
}
async doPost(pobj, obj, req) {
if (["subTmOrder", "getTmOrderList", "getTmOrderInfo", "getTmApplyInfo", "getTmNclList",
......@@ -209,6 +211,7 @@ class tmqueryCtl extends CtlBase {
if (req.session.userPinInfo) {
return system.getResultSuccess({ encryptChannelUserId: req.session.userPinInfo.encryptChannelUserId });
}
this.logClient.info("jd","getUserInfo----->req参数：" + JSON.parse(pobj));
var authUrl = pobj.authUrl;
var authToken = pobj.authToken;
var actionProcess = pobj.actionProcess;
......@@ -222,10 +225,12 @@ class tmqueryCtl extends CtlBase {
return system.getResult(null, "actionProcess不能为空");
}
var result = await this.execClient.execPostJDTK("", authUrl, authToken);
this.logClient.info("jd","getUserInfo----->execPostJDTK----authUrl--->result：" + JSON.parse(result));
if (!result || !result.account) {
return system.getResult(null, "处理用户请求失败,msg:" + result.error_description);
}
var tokenInfo = await this.getToken(actionProcess);
this.logClient.info("jd","getUserInfo----->tokenInfo：" + JSON.parse(tokenInfo));
if (tokenInfo.status != 0) {
return tokenInfo;
}
......@@ -238,13 +243,14 @@ class tmqueryCtl extends CtlBase {
};
var reqUrl = this.channelApiUrl + "/action/tmTools/springBoard";
var resultUser = await this.execClient.execPostTK(param, reqUrl, tokenInfo.data.token);
this.logClient.info("jd","getUserInfo----->resultUser：" + JSON.parse(resultUser));
if (!resultUser) {
return system.getResult(null, "处理请求失败");
}
req.session.userPinInfo = resultUser.data;
return resultUser;
} catch (error) {
console.log(error.stack, "操作error...................");
this.logClient.error("jd","req---->getUserInfo---->error:" + error.stack);
return system.getResultFail(-200, "操作error");
}
}
......
igirl-channel-jdweb/app/base/utils/logClient.js
// var log4js = require('log4js');
var settings=require("../../config/settings");
class LogClient{
constructor(){
// log4js.configure(settings.basepath+"/app/config/log4js.json");
// this.logerApp=log4js.getLogger("app");
// this.logerHttp=log4js.getLogger("http");
}
var log4js = require('log4js');
var settings = require("../../config/settings");
class LogClient {
constructor() {
log4js.configure(settings.basepath + "/app/config/log4js.json");
this.logerInfo = log4js.getLogger("info_file");
// this.logerError = log4js.getLogger("error_file");
// this.logerHttp=log4js.getLogger("http");
}
async info(channelCode, msg) {
this.logerInfo.info("_______________________________________________________________________________________________________________________________________________________________________________________________________________________________________");
this.logerInfo.info("渠道：" + channelCode + "....................info...................." + msg);
}
async error(channelCode, msg) {
this.logerInfo.info("_______________________________________________________________________________________________________________________________________________________________________________________________________________________________________");
this.logerInfo.error("渠道：" + channelCode + "...................error...................." + msg);
}
}
module.exports=LogClient;
module.exports = LogClient;
igirl-channel-jdweb/app/config/environment.js
......@@ -4,6 +4,7 @@ var favicon = require('serve-favicon');
var methodOverride = require('method-override');
var cookierParser = require('cookie-parser');
var session = require('express-session');
var log4js = require('log4js');
var RedisStore = require('connect-redis')(session);
var bodyParser = require('body-parser');
var multer = require('multer');
......@@ -11,76 +12,74 @@ var errorHandler = require('errorhandler');
var settings = require('./settings');
var System = require('../base/system');
var routes = require('./routes');
const logCtl=System.getObject("web.common.oplogCtl");
const clientRedis= System.getObject("util.redisClient").client;
const logCtl = System.getObject("web.common.oplogCtl");
const clientRedis = System.getObject("util.redisClient").client;
//const tm=System.getObject("db.taskManager");
module.exports = function (app) {
app.set('port', settings.port);
app.set('views', settings.basepath + '/app/front/entry');
app.set('view engine', 'ejs');
app.use(methodOverride());
app.use(cookierParser());
app.use(bodyParser.json({limit:'50mb'}));
app.use(bodyParser.urlencoded({limit:'50mb',extended:true}));
routes(app);//初始化路由
app.use(express.static(path.join(settings.basepath, '/app/front/entry/public')));
app.all('*',function (req, res, next) {
req.objs=System;
res.header('Access-Control-Allow-Origin', '*');
res.header('Access-Control-Allow-Headers', 'Content-Type, Content-Length, Authorization, Accept, X-Requested-With , yourHeaderFeild');
res.header('Access-Control-Allow-Methods', 'PUT, POST, GET, DELETE, OPTIONS');
// res.header('Access-Control-Allow-Credentials', 'true');
if (req.method == 'OPTIONS') {
res.send(200); //让options请求快速返回/
}
else {
next();
}
　});
if(settings.env=="dev"){
app.set('port', settings.port);
app.set('views', settings.basepath + '/app/front/entry');
app.set('view engine', 'ejs');
app.use(methodOverride());
app.use(cookierParser());
app.use(bodyParser.json({ limit: '50mb' }));
app.use(bodyParser.urlencoded({ limit: '50mb', extended: true }));
routes(app);//初始化路由
app.use(express.static(path.join(settings.basepath, '/app/front/entry/public')));
app.all('*', function (req, res, next) {
req.objs = System;
res.header('Access-Control-Allow-Origin', '*');
res.header('Access-Control-Allow-Headers', 'Content-Type, Content-Length, Authorization, Accept, X-Requested-With , yourHeaderFeild');
res.header('Access-Control-Allow-Methods', 'PUT, POST, GET, DELETE, OPTIONS');
// res.header('Access-Control-Allow-Credentials', 'true');
if (req.method == 'OPTIONS') {
res.send(200); //让options请求快速返回/
}
else {
next();
}
});
if (settings.env == "dev") {
app.use(session(
{
name:'userPinInfo',
cookie: {maxAge: 3600000},
rolling:true,
name: 'userPinInfo',
cookie: { maxAge: 3600000 },
rolling: true,
resave: false,
saveUninitialized: false,
secret: 'uwotm8',
store: new RedisStore({
client:clientRedis,
client: clientRedis,
}),
}));
}else{
app.use(session(
{
name:'userPinInfo',
cookie: {maxAge: 3600000},
rolling:true,
resave: false,
saveUninitialized: false,
secret: 'uwotm8',
store: new RedisStore({
client:clientRedis,
}),
}));
}));
} else {
app.use(session(
{
name: 'userPinInfo',
cookie: { maxAge: 3600000 },
rolling: true,
resave: false,
saveUninitialized: false,
secret: 'uwotm8',
store: new RedisStore({
client: clientRedis,
}),
}));
}
// development only
if ('development' == app.get('env')) {
app.use(errorHandler());
} else {
app.use(function (err, req, res) {
logCtl.error({
optitle: "environment 调用异常error:",
op: classPath + "/" + methodName,
content: e.toString(),
clientIp: System.get_client_ip(req),
agent: req.headers["user-agent"],
});
//logerApp.error("prod error handler",err);
res.send("link admin");
});
}
// development only
if ('development' == app.get('env')) {
app.use(errorHandler());
}else{
app.use(function(err,req,res){
console.log("prod error handler................................>>>>>>>>>>>>>>>>>");
console.log(err);
logCtl.error({
optitle:"environment 调用异常error:",
op:classPath+"/"+methodName,
content:e.toString(),
clientIp:System.get_client_ip(req),
agent:req.headers["user-agent"],
});
//logerApp.error("prod error handler",err);
res.send("link admin");
});
}
};
igirl-channel-jdweb/app/config/log4js.json 0 → 100644
{
"appenders": {
"access": {
"type": "dateFile",
"filename": "logs/access.log",
"pattern": "-yyyy-MM-dd",
"category": "http"
},
"info_file": {
"type": "file",
"filename": "logs/infoFile/info",
"encoding": "utf-8",
"maxLogSize": 100000000,
"backups": 5,
"pattern": "-yyyy-MM-dd-hh.log",
"category": "info_file"
},
"error_file": {
"type": "file",
"filename": "logs/errorFile/error",
"encoding": "utf-8",
"maxLogSize": 100000000,
"backups": 5,
"pattern": "-yyyy-MM-dd-hh.log",
"category": "error_file"
}
},
"categories": {
"default": {
"appenders": [
"info_file"
],
"level": "DEBUG"
},
"http": {
"appenders": [
"access"
],
"level": "DEBUG"
}
}
}
\ No newline at end of file
igirl-channel-jdweb/app/config/routes/web.js
var url = require("url");
var System = require("../../base/system");
var metaCtl = System.getObject("web.common.metaCtl");
var tmqueryCtl = System.getObject("web.trademark.tmqueryCtl");
var system = require("../../base/system");
var metaCtl = system.getObject("web.common.metaCtl");
var tmqueryCtl = system.getObject("web.trademark.tmqueryCtl");
var logClient = system.getObject("util.logClient");
module.exports = function (app) {
app.get("/jdtm/getUser", async function (req, res) {
console.log(req.query, "/jdtm/getUser....................");
var params = req.query;
if (!params.state) {
res.redirect("/#/jd/jdtrademark");
return;
}
var getUserparams = {
actionProcess: "jd",
authUrl: "https://oauth2.jdcloud.com/userinfo",
authToken: params.token_type + " " + params.access_token,
tmpchannelUserId: params.tmpchannelUserId
};
var userItemResult = await tmqueryCtl.getUserInfo(getUserparams, req.query, req);
if (userItemResult.status != 0) {
res.redirect("/#/jd/jdtrademark");
return;
}
if (!userItemResult.data.encryptChannelUserId || userItemResult.data.encryptChannelUserId == "undefined") {
userItemResult = await tmqueryCtl.getUserInfo(getUserparams, req.query, req);
try {
var params = req.query;
if (!params.state) {
res.redirect("/#/jd/jdtrademark");
return;
}
var getUserparams = {
actionProcess: "jd",
authUrl: "https://oauth2.jdcloud.com/userinfo",
authToken: params.token_type + " " + params.access_token,
tmpchannelUserId: params.tmpchannelUserId
};
var userItemResult = await tmqueryCtl.getUserInfo(getUserparams, req.query, req);
if (userItemResult.status != 0) {
res.redirect("/#/jd/jdtrademark");
return;
}
if (!userItemResult.data.encryptChannelUserId || userItemResult.data.encryptChannelUserId == "undefined") {
userItemResult = await tmqueryCtl.getUserInfo(getUserparams, req.query, req);
if (userItemResult.status != 0) {
res.redirect("/#/jd/jdtrademark");
return;
}
}
var skipUrl = "/#/jd/" + params.state + "?channelUserId=" + encodeURIComponent(userItemResult.data.encryptChannelUserId);
res.redirect(skipUrl);
} catch (error) {
this.logClient.error("jd", "req---->/jdtm/getUser---->error:" + error.stack);
}
var skipUrl = "/#/jd/" + params.state + "?channelUserId=" + encodeURIComponent(userItemResult.data.encryptChannelUserId);
res.redirect(skipUrl);
});
app.get("/jdtm/getUserTest", async function (req, res) {
console.log(req.query, "/jdtm/getUser....................");
......@@ -114,7 +118,7 @@ module.exports = function (app) {
params.push(req.query);
params.push(req);
var p = null;
var invokeObj = System.getObject("web." + classPath);
var invokeObj = system.getObject("web." + classPath);
if (invokeObj["doexec"]) {
p = invokeObj["doexec"].apply(invokeObj, params);
}
......@@ -133,7 +137,7 @@ module.exports = function (app) {
var gname = req.params["gname"];
var params = [];
classPath = gname + "." + classPath;
var tClientIp = System.get_client_ip(req);
var tClientIp = system.get_client_ip(req);
req.body.clientIp = tClientIp;
req.body.agent = req.headers["user-agent"];
req.body.classname = classPath;
......@@ -143,7 +147,7 @@ module.exports = function (app) {
params.push(req.query);
params.push(req);
var p = null;
var invokeObj = System.getObject("web." + classPath);
var invokeObj = system.getObject("web." + classPath);
if (invokeObj["doexec"]) {
p = invokeObj["doexec"].apply(invokeObj, params);
}
......
igirl-channel-jdweb/package.json
......@@ -36,6 +36,7 @@
"gulp-sass": "^4.0.2",
"http-proxy-middleware": "^0.20.0",
"jdcloud-sdk-signer": "^2.0.1",
"log4js": "^6.1.0",
"method-override": "^2.3.10",
"morgan": "^1.9.0",
"multer": "^1.3.0",
......
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