Commit b2fab29d by lixinming

no message

parent 2896c2cd
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.getData = void 0;
exports.getJHJD = exports.getData = void 0;
const jhjdData_1 = require("../data/table/jhjdData");
const inFrontOut_1 = require("../dataPackage/inFrontOut");
const out_1 = require("../dataPackage/out");
......@@ -23,4 +23,8 @@ function getData(req, res) {
res.send(ret);
}
exports.getData = getData;
function getJHJD(req, res) {
let {} = req;
}
exports.getJHJD = getJHJD;
//# sourceMappingURL=jhjd.js.map
\ No newline at end of file
{"version":3,"file":"jhjd.js","sourceRoot":"","sources":["../../src/biz/jhjd.ts"],"names":[],"mappings":";;;AACA,qDAAuD;AACvD,0DAAoI;AACpI,4CAA6G;AAE7G,wDAAwD;AAExD,SAAgB,OAAO,CAAC,GAAG,EAAE,GAAG;IAC5B,IAAI,SAAS,GAAG,wBAAa,EAAE,CAAC;IAEhC,IAAI,GAAG,GAAO,EAAE,CAAC;IAEjB,IAAI,eAAe,GAAG,4BAAe,CAAC,SAAS,CAAC,MAAM,CAAC,CAAC,QAAQ,CAAC,CAAC;IAClE,GAAG,CAAC,MAAM,CAAC,GAAG,oBAAc,CAAC,MAAM,EAAE,eAAe,CAAC,CAAC;IAEtD,IAAI,mBAAmB,GAAG,4BAAe,CAAC,SAAS,CAAC,UAAU,CAAC,CAAC,QAAQ,CAAC,CAAC;IAC1E,GAAG,CAAC,UAAU,CAAC,GAAG,oBAAc,CAAC,UAAU,EAAE,mBAAmB,CAAC,CAAC;IAElE,IAAI,aAAa,GAAG,4BAAe,CAAC,SAAS,CAAC,IAAI,CAAC,CAAC,QAAQ,CAAC,CAAC;IAC9D,GAAG,CAAC,IAAI,CAAC,GAAG,oBAAc,CAAC,IAAI,EAAE,aAAa,CAAC,CAAC;IAEhD,IAAI,iBAAiB,GAAG,4BAAe,CAAC,SAAS,CAAC,QAAQ,CAAC,CAAC,QAAQ,CAAC,CAAC;IACtE,GAAG,CAAC,QAAQ,CAAC,GAAG,oBAAc,CAAC,QAAQ,EAAE,iBAAiB,CAAC,CAAC;IAE5D,IAAI,aAAa,GAAG,4BAAe,CAAC,SAAS,CAAC,IAAI,CAAC,CAAC,QAAQ,CAAC,CAAC;IAC9D,GAAG,CAAC,IAAI,CAAC,GAAG,oBAAc,CAAC,IAAI,EAAE,aAAa,CAAC,CAAC;IAEhD,IAAI,iBAAiB,GAAG,4BAAe,CAAC,SAAS,CAAC,QAAQ,CAAC,CAAC,QAAQ,CAAC,CAAC;IACtE,GAAG,CAAC,QAAQ,CAAC,GAAG,oBAAc,CAAC,QAAQ,EAAE,iBAAiB,CAAC,CAAC;IAE5D,GAAG,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC;AAClB,CAAC;AAxBD,0BAwBC"}
\ No newline at end of file
{"version":3,"file":"jhjd.js","sourceRoot":"","sources":["../../src/biz/jhjd.ts"],"names":[],"mappings":";;;AACA,qDAAuD;AACvD,0DAAoI;AACpI,4CAA6G;AAE7G,wDAAwD;AAExD,SAAgB,OAAO,CAAC,GAAG,EAAE,GAAG;IAC5B,IAAI,SAAS,GAAG,wBAAa,EAAE,CAAC;IAEhC,IAAI,GAAG,GAAO,EAAE,CAAC;IAEjB,IAAI,eAAe,GAAG,4BAAe,CAAC,SAAS,CAAC,MAAM,CAAC,CAAC,QAAQ,CAAC,CAAC;IAClE,GAAG,CAAC,MAAM,CAAC,GAAG,oBAAc,CAAC,MAAM,EAAE,eAAe,CAAC,CAAC;IAEtD,IAAI,mBAAmB,GAAG,4BAAe,CAAC,SAAS,CAAC,UAAU,CAAC,CAAC,QAAQ,CAAC,CAAC;IAC1E,GAAG,CAAC,UAAU,CAAC,GAAG,oBAAc,CAAC,UAAU,EAAE,mBAAmB,CAAC,CAAC;IAElE,IAAI,aAAa,GAAG,4BAAe,CAAC,SAAS,CAAC,IAAI,CAAC,CAAC,QAAQ,CAAC,CAAC;IAC9D,GAAG,CAAC,IAAI,CAAC,GAAG,oBAAc,CAAC,IAAI,EAAE,aAAa,CAAC,CAAC;IAEhD,IAAI,iBAAiB,GAAG,4BAAe,CAAC,SAAS,CAAC,QAAQ,CAAC,CAAC,QAAQ,CAAC,CAAC;IACtE,GAAG,CAAC,QAAQ,CAAC,GAAG,oBAAc,CAAC,QAAQ,EAAE,iBAAiB,CAAC,CAAC;IAE5D,IAAI,aAAa,GAAG,4BAAe,CAAC,SAAS,CAAC,IAAI,CAAC,CAAC,QAAQ,CAAC,CAAC;IAC9D,GAAG,CAAC,IAAI,CAAC,GAAG,oBAAc,CAAC,IAAI,EAAE,aAAa,CAAC,CAAC;IAEhD,IAAI,iBAAiB,GAAG,4BAAe,CAAC,SAAS,CAAC,QAAQ,CAAC,CAAC,QAAQ,CAAC,CAAC;IACtE,GAAG,CAAC,QAAQ,CAAC,GAAG,oBAAc,CAAC,QAAQ,EAAE,iBAAiB,CAAC,CAAC;IAE5D,GAAG,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC;AAClB,CAAC;AAxBD,0BAwBC;AAED,SAAgB,OAAO,CAAC,GAAG,EAAE,GAAG;IAC5B,IAAI,EAAE,GAAG,GAAG,CAAC;AACjB,CAAC;AAFD,0BAEC"}
\ No newline at end of file
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.INTERFACErEQUESTTYPEENUM = void 0;
var INTERFACErEQUESTTYPEENUM;
(function (INTERFACErEQUESTTYPEENUM) {
INTERFACErEQUESTTYPEENUM[INTERFACErEQUESTTYPEENUM["\u5373\u65F6\u66F4\u65B0"] = 1] = "\u5373\u65F6\u66F4\u65B0";
INTERFACErEQUESTTYPEENUM[INTERFACErEQUESTTYPEENUM["\u5B9A\u65F6\u66F4\u65B0"] = 2] = "\u5B9A\u65F6\u66F4\u65B0";
})(INTERFACErEQUESTTYPEENUM = exports.INTERFACErEQUESTTYPEENUM || (exports.INTERFACErEQUESTTYPEENUM = {}));
exports.INTERFACEREQUESTTYPEENUM = void 0;
var INTERFACEREQUESTTYPEENUM;
(function (INTERFACEREQUESTTYPEENUM) {
INTERFACEREQUESTTYPEENUM[INTERFACEREQUESTTYPEENUM["\u5373\u65F6\u66F4\u65B0"] = 1] = "\u5373\u65F6\u66F4\u65B0";
INTERFACEREQUESTTYPEENUM[INTERFACEREQUESTTYPEENUM["\u5B9A\u65F6\u66F4\u65B0"] = 2] = "\u5B9A\u65F6\u66F4\u65B0";
})(INTERFACEREQUESTTYPEENUM = exports.INTERFACEREQUESTTYPEENUM || (exports.INTERFACEREQUESTTYPEENUM = {}));
//# sourceMappingURL=enum.js.map
\ No newline at end of file
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.getSysMsg = exports.getBizMsg = exports.SYSTEMERRORENUM = exports.ERRORENUM = void 0;
var ERRORENUM;
(function (ERRORENUM) {
ERRORENUM[ERRORENUM["\u672A\u627E\u5230\u6570\u636E"] = 0] = "\u672A\u627E\u5230\u6570\u636E";
})(ERRORENUM = exports.ERRORENUM || (exports.ERRORENUM = {}));
var SYSTEMERRORENUM;
(function (SYSTEMERRORENUM) {
SYSTEMERRORENUM[SYSTEMERRORENUM["\u521D\u59CB\u5316\u914D\u7F6E\u5931\u8D25"] = 1] = "\u521D\u59CB\u5316\u914D\u7F6E\u5931\u8D25";
SYSTEMERRORENUM[SYSTEMERRORENUM["\u83B7\u53D6\u7B2C\u4E09\u65B9\u63A5\u53E3\u6570\u636E\u5931\u8D25"] = 2] = "\u83B7\u53D6\u7B2C\u4E09\u65B9\u63A5\u53E3\u6570\u636E\u5931\u8D25";
SYSTEMERRORENUM[SYSTEMERRORENUM["\u672A\u6309\u63A5\u53E3\u534F\u8BAE\u8FD4\u56DE"] = 3] = "\u672A\u6309\u63A5\u53E3\u534F\u8BAE\u8FD4\u56DE";
SYSTEMERRORENUM[SYSTEMERRORENUM["\u8BF7\u6C42\u672A\u9274\u6743"] = 401] = "\u8BF7\u6C42\u672A\u9274\u6743";
SYSTEMERRORENUM[SYSTEMERRORENUM["\u8BF7\u6C42\u8DEF\u5F84\u4E0D\u5B58\u5728"] = 404] = "\u8BF7\u6C42\u8DEF\u5F84\u4E0D\u5B58\u5728";
SYSTEMERRORENUM[SYSTEMERRORENUM["\u8BF7\u6C42\u9891\u7387\u8FC7\u9AD8"] = 503] = "\u8BF7\u6C42\u9891\u7387\u8FC7\u9AD8";
})(SYSTEMERRORENUM = exports.SYSTEMERRORENUM || (exports.SYSTEMERRORENUM = {}));
let bizErrorMsgMap = {};
for (let key in ERRORENUM) {
bizErrorMsgMap[ERRORENUM[key]] = key;
}
let systemErrorMsgMap = {};
for (let key in SYSTEMERRORENUM) {
systemErrorMsgMap[SYSTEMERRORENUM[key]] = key;
}
function getBizMsg(param) {
return bizErrorMsgMap[param];
}
exports.getBizMsg = getBizMsg;
function getSysMsg(param) {
return systemErrorMsgMap[param];
}
exports.getSysMsg = getSysMsg;
//# sourceMappingURL=errorEnum.js.map
\ No newline at end of file
{"version":3,"file":"errorEnum.js","sourceRoot":"","sources":["../../src/config/errorEnum.ts"],"names":[],"mappings":";;;AAAA,IAAY,SAEX;AAFD,WAAY,SAAS;IACjB,6FAAK,CAAA;AACT,CAAC,EAFW,SAAS,GAAT,iBAAS,KAAT,iBAAS,QAEpB;AACD,IAAY,eAOX;AAPD,WAAY,eAAe;IACvB,iIAAW,CAAA;IACX,iLAAW,CAAA;IACX,6IAAQ,CAAA;IACR,2GAAW,CAAA;IACX,mIAAa,CAAA;IACb,uHAAY,CAAA;AAChB,CAAC,EAPW,eAAe,GAAf,uBAAe,KAAf,uBAAe,QAO1B;AAED,IAAI,cAAc,GAAG,EAAE,CAAC;AACxB,KAAK,IAAI,GAAG,IAAI,SAAS,EAAE;IACvB,cAAc,CAAC,SAAS,CAAC,GAAG,CAAC,CAAC,GAAG,GAAG,CAAC;CACxC;AAED,IAAI,iBAAiB,GAAG,EAAE,CAAC;AAC3B,KAAK,IAAI,GAAG,IAAI,eAAe,EAAE;IAC7B,iBAAiB,CAAC,eAAe,CAAC,GAAG,CAAC,CAAC,GAAG,GAAG,CAAC;CACjD;AAED,SAAgB,SAAS,CAAC,KAAK;IAC3B,OAAO,cAAc,CAAC,KAAK,CAAC,CAAC;AACjC,CAAC;AAFD,8BAEC;AAED,SAAgB,SAAS,CAAC,KAAK;IAC3B,OAAO,iBAAiB,CAAC,KAAK,CAAC,CAAC;AACpC,CAAC;AAFD,8BAEC"}
\ No newline at end of file
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.Config = void 0;
// 请把 "INTERFACErEQUESTTYPEENUM.即时更新" 改成 INTERFACErEQUESTTYPEENUM.即时更新 把引号去掉 【定时更新同理 】
exports.Config = { "计划进度": { "type": "INTERFACErEQUESTTYPEENUM.即时更新", "time": 3600000, "url": "url地址", "reqType": "post", "header": {}, "body": {} }, "形象进度": { "type": "INTERFACErEQUESTTYPEENUM.即时更新", "time": 3600000, "url": "url地址", "reqType": "post", "header": {}, "body": {} }, "里程碑节点完成情况": { "type": "INTERFACErEQUESTTYPEENUM.即时更新", "time": 3600000, "url": "url地址", "reqType": "post", "header": {}, "body": {} }, "致命性风险分布": { "type": "INTERFACErEQUESTTYPEENUM.即时更新", "time": 3600000, "url": "url地址", "reqType": "post", "header": {}, "body": {} }, "当前风险节点": { "type": "INTERFACErEQUESTTYPEENUM.即时更新", "time": 3600000, "url": "url地址", "reqType": "post", "header": {}, "body": {} }, "工程 安全状态": { "type": "INTERFACErEQUESTTYPEENUM.即时更新", "time": 3600000, "url": "url地址", "reqType": "post", "header": {}, "body": {} } };
// 请把 "INTERFACEREQUESTTYPEENUM.即时更新" 改成 INTERFACEREQUESTTYPEENUM.即时更新 把引号去掉 【定时更新同理 】
exports.Config = { "计划进度": { "type": "INTERFACEREQUESTTYPEENUM.即时更新", "time": 3600000, "url": "url地址", "reqType": "post", "header": {}, "body": {} }, "形象进度": { "type": "INTERFACEREQUESTTYPEENUM.即时更新", "time": 3600000, "url": "url地址", "reqType": "post", "header": {}, "body": {} }, "里程碑节点完成情况": { "type": "INTERFACEREQUESTTYPEENUM.即时更新", "time": 3600000, "url": "url地址", "reqType": "post", "header": {}, "body": {} }, "致命性风险分布": { "type": "INTERFACEREQUESTTYPEENUM.即时更新", "time": 3600000, "url": "url地址", "reqType": "post", "header": {}, "body": {} }, "当前风险节点": { "type": "INTERFACEREQUESTTYPEENUM.即时更新", "time": 3600000, "url": "url地址", "reqType": "post", "header": {}, "body": {} }, "工程 安全状态": { "type": "INTERFACEREQUESTTYPEENUM.即时更新", "time": 3600000, "url": "url地址", "reqType": "post", "header": {}, "body": {} } };
//# sourceMappingURL=interfaceConfig.js.map
\ No newline at end of file
......@@ -40,7 +40,7 @@ async function taskUpdate() {
continue;
}
const ThisConfig = interfaceConfig_1.Config[interfaceName];
if (ThisConfig.type == enum_1.INTERFACErEQUESTTYPEENUM.即时更新)
if (ThisConfig.type == enum_1.INTERFACEREQUESTTYPEENUM.即时更新)
continue;
let lastTaskInfo = updateInfo[interfaceName];
if (!lastTaskInfo)
......@@ -99,7 +99,7 @@ async function initRealTime() {
let initSuccess = true;
for (let interfaceName in interfaceConfig_1.Config) {
const ThisConfig = interfaceConfig_1.Config[interfaceName];
if (ThisConfig.type == enum_1.INTERFACErEQUESTTYPEENUM.定时更新)
if (ThisConfig.type == enum_1.INTERFACEREQUESTTYPEENUM.定时更新)
continue;
let reqRes;
switch (ThisConfig.reqType) {
......@@ -125,7 +125,7 @@ exports.initRealTime = initRealTime;
async function getInterfaceByInterfaceName(name) {
const ThisConfig = interfaceConfig_1.Config[name];
let data;
if (ThisConfig.type == enum_1.INTERFACErEQUESTTYPEENUM.即时更新) {
if (ThisConfig.type == enum_1.INTERFACEREQUESTTYPEENUM.即时更新) {
let reqRes;
switch (ThisConfig.reqType) {
case "get":
......
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
var os = require("os");
const http_server_1 = require("./net/http_server");
const serverConfig_1 = require("./config/serverConfig");
async function lanuch() {
test();
// test();
// return
await serverConfig_1.initConfig();
// initInterfaceData();
http_server_1.httpServer.createServer(serverConfig_1.port);
console.log('This indicates that the server is started successfully.');
}
function test() {
console.log(os.platform());
console.log(os.networkInterfaces());
}
lanuch();
//# sourceMappingURL=main.js.map
\ No newline at end of file
{"version":3,"file":"main.js","sourceRoot":"","sources":["../src/main.ts"],"names":[],"mappings":";;AAEA,mDAA+C;AAC/C,wDAAyD;AAEzD,KAAK,UAAU,MAAM;IACjB,IAAI,EAAE,CAAC;IACP,MAAM,yBAAU,EAAE,CAAC;IACnB,uBAAuB;IACvB,wBAAU,CAAC,YAAY,CAAE,mBAAI,CAAE,CAAC;IAEhC,OAAO,CAAC,GAAG,CAAC,yDAAyD,CAAC,CAAC;AAC3E,CAAC;AAED,SAAS,IAAI;AACb,CAAC;AAED,MAAM,EAAE,CAAC"}
\ No newline at end of file
{"version":3,"file":"main.js","sourceRoot":"","sources":["../src/main.ts"],"names":[],"mappings":";;AAEA,IAAI,EAAE,GAAG,OAAO,CAAC,IAAI,CAAC,CAAA;AACtB,mDAA+C;AAC/C,wDAAyD;AAEzD,KAAK,UAAU,MAAM;IACjB,UAAU;IACV,UAAU;IACV,MAAM,yBAAU,EAAE,CAAC;IACnB,uBAAuB;IACvB,wBAAU,CAAC,YAAY,CAAE,mBAAI,CAAE,CAAC;IAEhC,OAAO,CAAC,GAAG,CAAC,yDAAyD,CAAC,CAAC;AAC3E,CAAC;AAED,SAAS,IAAI;IACV,OAAO,CAAC,GAAG,CAAC,EAAE,CAAC,QAAQ,EAAE,CAAC,CAAC;IAC3B,OAAO,CAAC,GAAG,CAAC,EAAE,CAAC,iBAAiB,EAAE,CAAC,CAAC;AACvC,CAAC;AAED,MAAM,EAAE,CAAC"}
\ No newline at end of file
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.checkToken = void 0;
async function checkToken(req, res, next) {
next();
}
exports.checkToken = checkToken;
//# sourceMappingURL=checkToken.js.map
\ No newline at end of file
{"version":3,"file":"checkToken.js","sourceRoot":"","sources":["../../src/middleware/checkToken.ts"],"names":[],"mappings":";;;AACO,KAAK,UAAU,UAAU,CAAC,GAAG,EAAE,GAAG,EAAE,IAAI;IAC3C,IAAI,EAAE,CAAC;AACX,CAAC;AAFD,gCAEC"}
\ No newline at end of file
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.encryptionReturn = void 0;
async function encryptionReturn(req, res, next) {
res.on('end', function () {
console.log(res.body);
});
let resSend = res.send;
res.send = (obj) => {
changeNumber(obj);
//递归修改number型
resSend.call(res, obj);
};
next();
}
exports.encryptionReturn = encryptionReturn;
function changeNumber(obj) {
if (Array.isArray(obj)) {
for (let i = 0; i < obj.length; i++) {
let arrItem = obj[i];
if (typeof arrItem == "number") {
obj[i] = getSameLenNumber(arrItem);
}
else if (typeof arrItem == "object") {
changeNumber(arrItem);
}
}
}
else {
for (let key in obj) {
let objItem = obj[key];
if (typeof objItem == "number") {
if (key == "x" || key == "y")
continue;
obj[key] = getSameLenNumber(objItem);
}
else if (typeof objItem == "object") {
changeNumber(objItem);
}
}
}
}
function getSameLenNumber(num) {
let numStr = String(num);
//疑似年份的不做加密
if (numStr.length == 4 && (numStr.indexOf("19") == 0 || numStr.indexOf("20") == 0))
return num;
let str = "";
for (let i = 0; i < numStr.length; i++) {
if (numStr[i] == '.')
str += numStr[i];
else
str += "6";
}
return Number(str);
}
//# sourceMappingURL=encryptionReturn.js.map
\ No newline at end of file
{"version":3,"file":"encryptionReturn.js","sourceRoot":"","sources":["../../src/middleware/encryptionReturn.ts"],"names":[],"mappings":";;;AAAO,KAAK,UAAU,gBAAgB,CAAC,GAAG,EAAE,GAAG,EAAE,IAAI;IACjD,GAAG,CAAC,EAAE,CAAC,KAAK,EAAE;QACV,OAAO,CAAC,GAAG,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;IAC1B,CAAC,CAAC,CAAC;IAEH,IAAI,OAAO,GAAG,GAAG,CAAC,IAAI,CAAC;IACvB,GAAG,CAAC,IAAI,GAAG,CAAC,GAAG,EAAC,EAAE;QACd,YAAY,CAAC,GAAG,CAAC,CAAC;QAClB,aAAa;QACb,OAAO,CAAC,IAAI,CAAC,GAAG,EAAE,GAAG,CAAC,CAAC;IAC3B,CAAC,CAAC;IAEF,IAAI,EAAE,CAAC;AACX,CAAC;AAbD,4CAaC;AAED,SAAS,YAAY,CAAC,GAAG;IACrB,IAAI,KAAK,CAAC,OAAO,CAAC,GAAG,CAAC,EAAE;QACpB,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,GAAG,CAAC,MAAM,EAAE,CAAC,EAAE,EAAE;YACjC,IAAI,OAAO,GAAG,GAAG,CAAC,CAAC,CAAC,CAAC;YACrB,IAAI,OAAO,OAAO,IAAI,QAAQ,EAAE;gBAC5B,GAAG,CAAC,CAAC,CAAC,GAAG,gBAAgB,CAAC,OAAO,CAAC,CAAC;aACtC;iBACI,IAAI,OAAO,OAAO,IAAI,QAAQ,EAAE;gBACjC,YAAY,CAAC,OAAO,CAAC,CAAC;aACzB;SACJ;KACJ;SACI;QACD,KAAK,IAAI,GAAG,IAAI,GAAG,EAAE;YACjB,IAAI,OAAO,GAAG,GAAG,CAAC,GAAG,CAAC,CAAC;YACvB,IAAI,OAAO,OAAO,IAAI,QAAQ,EAAE;gBAC5B,IAAI,GAAG,IAAI,GAAG,IAAI,GAAG,IAAI,GAAG;oBAAE,SAAS;gBAEvC,GAAG,CAAC,GAAG,CAAC,GAAG,gBAAgB,CAAC,OAAO,CAAC,CAAC;aACxC;iBACI,IAAI,OAAO,OAAO,IAAI,QAAQ,EAAE;gBACjC,YAAY,CAAC,OAAO,CAAC,CAAC;aACzB;SACJ;KACJ;AACL,CAAC;AAED,SAAS,gBAAgB,CAAC,GAAG;IACzB,IAAI,MAAM,GAAG,MAAM,CAAC,GAAG,CAAC,CAAC;IACzB,WAAW;IACX,IAAI,MAAM,CAAC,MAAM,IAAI,CAAC,IAAI,CAAC,MAAM,CAAC,OAAO,CAAC,IAAI,CAAC,IAAI,CAAC,IAAI,MAAM,CAAC,OAAO,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;QAAE,OAAO,GAAG,CAAC;IAC/F,IAAI,GAAG,GAAG,EAAE,CAAC;IACb,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,MAAM,CAAC,MAAM,EAAE,CAAC,EAAE,EAAE;QACpC,IAAI,MAAM,CAAC,CAAC,CAAC,IAAI,GAAG;YAAE,GAAG,IAAI,MAAM,CAAC,CAAC,CAAC,CAAC;;YAClC,GAAG,IAAI,GAAG,CAAC;KACnB;IAED,OAAO,MAAM,CAAC,GAAG,CAAC,CAAC;AACvB,CAAC"}
\ No newline at end of file
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.httpErrorHandler = void 0;
function httpErrorHandler(err, req, res, next) {
console.log("in httpErrorHandler");
console.log(err);
//todo 自定义错误编码
if (err) {
if (err.message == "您的登录已失效") {
res.success({ success: false, msg: err.message, code: 501 });
next();
}
else if (err.message == "您的账户没有访问权限") {
res.success({ success: false, msg: "非常抱歉,您没有权限,请联系工作人员!", code: 502 });
next();
}
else if (err.message == "token已过期") {
res.success({ success: false, msg: "token失效", code: 503 });
next();
}
else {
res.success({ success: false, msg: err.message, code: 500 });
next();
}
}
}
exports.httpErrorHandler = httpErrorHandler;
//# sourceMappingURL=httpErrorHandler.js.map
\ No newline at end of file
{"version":3,"file":"httpErrorHandler.js","sourceRoot":"","sources":["../../src/middleware/httpErrorHandler.ts"],"names":[],"mappings":";;;AAAA,SAAgB,gBAAgB,CAAC,GAAG,EAAE,GAAG,EAAE,GAAG,EAAE,IAAI;IAChD,OAAO,CAAC,GAAG,CAAC,qBAAqB,CAAC,CAAC;IACnC,OAAO,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC;IACjB,cAAc;IACd,IAAI,GAAG,EAAE;QACL,IAAI,GAAG,CAAC,OAAO,IAAI,SAAS,EAAG;YAC3B,GAAG,CAAC,OAAO,CAAC,EAAC,OAAO,EAAC,KAAK,EAAE,GAAG,EAAC,GAAG,CAAC,OAAO,EAAE,IAAI,EAAC,GAAG,EAAC,CAAC,CAAC;YACxD,IAAI,EAAE,CAAC;SACV;aACI,IAAI,GAAG,CAAC,OAAO,IAAI,YAAY,EAAE;YAClC,GAAG,CAAC,OAAO,CAAC,EAAC,OAAO,EAAC,KAAK,EAAE,GAAG,EAAC,qBAAqB,EAAE,IAAI,EAAC,GAAG,EAAC,CAAC,CAAC;YAClE,IAAI,EAAE,CAAC;SACV;aAAM,IAAK,GAAG,CAAC,OAAO,IAAI,UAAU,EAAE;YACnC,GAAG,CAAC,OAAO,CAAC,EAAC,OAAO,EAAC,KAAK,EAAE,GAAG,EAAC,SAAS,EAAE,IAAI,EAAC,GAAG,EAAC,CAAC,CAAC;YACtD,IAAI,EAAE,CAAC;SACV;aACK;YACF,GAAG,CAAC,OAAO,CAAC,EAAC,OAAO,EAAC,KAAK,EAAE,GAAG,EAAC,GAAG,CAAC,OAAO,EAAE,IAAI,EAAC,GAAG,EAAC,CAAC,CAAC;YACxD,IAAI,EAAE,CAAC;SACV;KACJ;AACL,CAAC;AArBD,4CAqBC"}
\ No newline at end of file
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.watch = void 0;
function watch(req, res, next) {
res.success = success.bind({ res: res, req: req });
return next();
}
exports.watch = watch;
function success(data) {
let resultPack;
if (data) {
if (data.success === undefined || data.success === true) {
resultPack = { data, success: true, code: 200 };
}
else {
resultPack = data;
}
}
else {
resultPack = { code: 500, success: false, msg: 'result is null' };
}
this.res.send(resultPack);
}
//# sourceMappingURL=watch.js.map
\ No newline at end of file
{"version":3,"file":"watch.js","sourceRoot":"","sources":["../../src/middleware/watch.ts"],"names":[],"mappings":";;;AAAA,SAAgB,KAAK,CAAC,GAAG,EAAE,GAAG,EAAE,IAAI;IAChC,GAAG,CAAC,OAAO,GAAG,OAAO,CAAC,IAAI,CAAC,EAAC,GAAG,EAAC,GAAG,EAAE,GAAG,EAAC,GAAG,EAAC,CAAC,CAAC;IAE/C,OAAO,IAAI,EAAE,CAAC;AAClB,CAAC;AAJD,sBAIC;AAED,SAAS,OAAO,CAAC,IAAI;IACjB,IAAI,UAAU,CAAC;IACf,IAAI,IAAI,EAAG;QACP,IAAK,IAAI,CAAC,OAAO,KAAK,SAAS,IAAI,IAAI,CAAC,OAAO,KAAK,IAAI,EAAG;YACvD,UAAU,GAAG,EAAC,IAAI,EAAE,OAAO,EAAC,IAAI,EAAE,IAAI,EAAC,GAAG,EAAC,CAAC;SAC/C;aACI;YACD,UAAU,GAAG,IAAI,CAAC;SACrB;KACJ;SAAK;QACF,UAAU,GAAG,EAAC,IAAI,EAAC,GAAG,EAAE,OAAO,EAAC,KAAK,EAAE,GAAG,EAAC,gBAAgB,EAAC,CAAC;KAChE;IACD,IAAI,CAAC,GAAG,CAAC,IAAI,CAAC,UAAU,CAAC,CAAC;AAC9B,CAAC"}
\ No newline at end of file
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.httpErrorHandler = void 0;
function httpErrorHandler(err, req, res, next) {
console.log("in httpErrorHandler");
console.log(err);
//todo 自定义错误编码
if (err) {
if (err.message == "您的登录已失效") {
res.success({ success: false, msg: err.message, code: 501 });
next();
}
else if (err.message == "您的账户没有访问权限") {
res.success({ success: false, msg: "非常抱歉,您没有权限,请联系工作人员!", code: 502 });
next();
}
else if (err.message == "token已过期") {
res.success({ success: false, msg: "token失效", code: 503 });
next();
}
else {
res.success({ success: false, msg: err.message, code: 500 });
next();
}
}
}
exports.httpErrorHandler = httpErrorHandler;
//# sourceMappingURL=httpErrorHandler.js.map
\ No newline at end of file
{"version":3,"file":"httpErrorHandler.js","sourceRoot":"","sources":["../../src/net/httpErrorHandler.ts"],"names":[],"mappings":";;;AAAA,SAAgB,gBAAgB,CAAC,GAAG,EAAE,GAAG,EAAE,GAAG,EAAE,IAAI;IAChD,OAAO,CAAC,GAAG,CAAC,qBAAqB,CAAC,CAAC;IACnC,OAAO,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC;IACjB,cAAc;IACd,IAAI,GAAG,EAAE;QACL,IAAI,GAAG,CAAC,OAAO,IAAI,SAAS,EAAG;YAC3B,GAAG,CAAC,OAAO,CAAC,EAAC,OAAO,EAAC,KAAK,EAAE,GAAG,EAAC,GAAG,CAAC,OAAO,EAAE,IAAI,EAAC,GAAG,EAAC,CAAC,CAAC;YACxD,IAAI,EAAE,CAAC;SACV;aACI,IAAI,GAAG,CAAC,OAAO,IAAI,YAAY,EAAE;YAClC,GAAG,CAAC,OAAO,CAAC,EAAC,OAAO,EAAC,KAAK,EAAE,GAAG,EAAC,qBAAqB,EAAE,IAAI,EAAC,GAAG,EAAC,CAAC,CAAC;YAClE,IAAI,EAAE,CAAC;SACV;aAAM,IAAK,GAAG,CAAC,OAAO,IAAI,UAAU,EAAE;YACnC,GAAG,CAAC,OAAO,CAAC,EAAC,OAAO,EAAC,KAAK,EAAE,GAAG,EAAC,SAAS,EAAE,IAAI,EAAC,GAAG,EAAC,CAAC,CAAC;YACtD,IAAI,EAAE,CAAC;SACV;aACK;YACF,GAAG,CAAC,OAAO,CAAC,EAAC,OAAO,EAAC,KAAK,EAAE,GAAG,EAAC,GAAG,CAAC,OAAO,EAAE,IAAI,EAAC,GAAG,EAAC,CAAC,CAAC;YACxD,IAAI,EAAE,CAAC;SACV;KACJ;AACL,CAAC;AArBD,4CAqBC"}
\ No newline at end of file
......@@ -7,6 +7,8 @@ const routers = require("../routers/router");
const compression = require("compression");
const fallback = require("express-history-api-fallback");
const path = require("path");
const watch_1 = require("../middleware/watch");
const httpErrorHandler_1 = require("../middleware/httpErrorHandler");
class httpServer {
static createServer(port) {
var httpServer = express();
......@@ -25,10 +27,11 @@ class httpServer {
next();
}
});
httpServer.use(express.static('public'));
httpServer.use(bodyParser.json({ limit: "10kb" }));
httpServer.use(compression());
httpServer.use(watch_1.watch);
routers.setRouter(httpServer);
httpServer.use(httpErrorHandler_1.httpErrorHandler);
const root = path.join(__dirname, "../../public/");
httpServer.use(express.static(root));
httpServer.use(fallback('index.html', { root }));
......
{"version":3,"file":"http_server.js","sourceRoot":"","sources":["../../src/net/http_server.ts"],"names":[],"mappings":";;;AAAA,mCAAoC;AACpC,0CAA2C;AAE3C,6CAA8C;AAC9C,2CAA4C;AAC5C,yDAAyD;AACzD,6BAA6B;AAG7B,MAAa,UAAU;IACpB,MAAM,CAAC,YAAY,CAAC,IAAW;QAC9B,IAAI,UAAU,GAAG,OAAO,EAAE,CAAC;QAE3B,UAAU,CAAC,GAAG,CAAC,GAAG,EAAC,UAAU,GAAG,EAAE,GAAG,EAAE,IAAI;YACzC,GAAG,CAAC,MAAM,CAAC,6BAA6B,EAAE,GAAG,CAAC,OAAO,CAAC,MAAM,CAAC,CAAC;YAC9D,GAAG,CAAC,MAAM,CAAC,8BAA8B,EAAE,kBAAkB,CAAC,CAAC;YAC/D,GAAG,CAAC,MAAM,CAAC,8BAA8B,EAAE,cAAc,CAAC,CAAC;YAC3D,GAAG,CAAC,MAAM,CAAC,8BAA8B,EAAE,6BAA6B,CAAC,CAAC;YAC1E,GAAG,CAAC,MAAM,CAAC,kCAAkC,EAAE,IAAI,CAAC,CAAC;YACrD,GAAG,CAAC,MAAM,CAAC,cAAc,EAAE,QAAQ,CAAC,CAAC;YACrC,IAAG,GAAG,CAAC,MAAM,KAAK,SAAS,EAAC;gBACxB,GAAG,CAAC,UAAU,GAAG,GAAG,CAAC;gBACrB,GAAG,CAAC,GAAG,EAAE,CAAC;aACX;iBAAI;gBACD,IAAI,EAAE,CAAC;aACV;QACL,CAAC,CAAC,CAAC;QAEH,UAAU,CAAC,GAAG,CAAC,OAAO,CAAC,MAAM,CAAC,QAAQ,CAAC,CAAE,CAAC;QAE1C,UAAU,CAAC,GAAG,CAAC,UAAU,CAAC,IAAI,CAAC,EAAC,KAAK,EAAC,MAAM,EAAC,CAAC,CAAC,CAAC;QAChD,UAAU,CAAC,GAAG,CAAC,WAAW,EAAE,CAAC,CAAA;QAC7B,OAAO,CAAC,SAAS,CAAC,UAAU,CAAC,CAAC;QAE9B,MAAM,IAAI,GAAG,IAAI,CAAC,IAAI,CAAC,SAAS,EAAE,eAAe,CAAC,CAAA;QAClD,UAAU,CAAC,GAAG,CAAC,OAAO,CAAC,MAAM,CAAC,IAAI,CAAC,CAAC,CAAA;QACpC,UAAU,CAAC,GAAG,CAAC,QAAQ,CAAC,YAAY,EAAE,EAAE,IAAI,EAAE,CAAC,CAAC,CAAA;QAChD,OAAO,CAAC,GAAG,CAAC,qBAAqB,GAAC,IAAI,CAAC,CAAC;QAGxC,UAAU,CAAC,MAAM,CAAC,IAAI,CAAC,CAAC;QACxB,OAAO,CAAC,GAAG,CAAC,wBAAwB,GAAC,IAAI,CAAC,CAAC;QAE3C,OAAO,UAAU,CAAC;IACpB,CAAC;CACF;AApCD,gCAoCC"}
\ No newline at end of file
{"version":3,"file":"http_server.js","sourceRoot":"","sources":["../../src/net/http_server.ts"],"names":[],"mappings":";;;AAAA,mCAAoC;AACpC,0CAA2C;AAC3C,6CAA8C;AAC9C,2CAA4C;AAC5C,yDAAyD;AACzD,6BAA6B;AAC7B,+CAA4C;AAC5C,qEAAkE;AAGlE,MAAa,UAAU;IACpB,MAAM,CAAC,YAAY,CAAC,IAAW;QAC9B,IAAI,UAAU,GAAG,OAAO,EAAE,CAAC;QAE3B,UAAU,CAAC,GAAG,CAAC,GAAG,EAAC,UAAU,GAAG,EAAE,GAAG,EAAE,IAAI;YACzC,GAAG,CAAC,MAAM,CAAC,6BAA6B,EAAE,GAAG,CAAC,OAAO,CAAC,MAAM,CAAC,CAAC;YAC9D,GAAG,CAAC,MAAM,CAAC,8BAA8B,EAAE,kBAAkB,CAAC,CAAC;YAC/D,GAAG,CAAC,MAAM,CAAC,8BAA8B,EAAE,cAAc,CAAC,CAAC;YAC3D,GAAG,CAAC,MAAM,CAAC,8BAA8B,EAAE,6BAA6B,CAAC,CAAC;YAC1E,GAAG,CAAC,MAAM,CAAC,kCAAkC,EAAE,IAAI,CAAC,CAAC;YACrD,GAAG,CAAC,MAAM,CAAC,cAAc,EAAE,QAAQ,CAAC,CAAC;YACrC,IAAG,GAAG,CAAC,MAAM,KAAK,SAAS,EAAC;gBACxB,GAAG,CAAC,UAAU,GAAG,GAAG,CAAC;gBACrB,GAAG,CAAC,GAAG,EAAE,CAAC;aACX;iBAAI;gBACD,IAAI,EAAE,CAAC;aACV;QACL,CAAC,CAAC,CAAC;QAGH,UAAU,CAAC,GAAG,CAAC,UAAU,CAAC,IAAI,CAAC,EAAC,KAAK,EAAC,MAAM,EAAC,CAAC,CAAC,CAAC;QAChD,UAAU,CAAC,GAAG,CAAC,WAAW,EAAE,CAAC,CAAA;QAE7B,UAAU,CAAC,GAAG,CAAC,aAAK,CAAC,CAAC;QACtB,OAAO,CAAC,SAAS,CAAC,UAAU,CAAC,CAAC;QAC9B,UAAU,CAAC,GAAG,CAAC,mCAAgB,CAAC,CAAC;QAEjC,MAAM,IAAI,GAAG,IAAI,CAAC,IAAI,CAAC,SAAS,EAAE,eAAe,CAAC,CAAA;QAClD,UAAU,CAAC,GAAG,CAAC,OAAO,CAAC,MAAM,CAAC,IAAI,CAAC,CAAC,CAAA;QACpC,UAAU,CAAC,GAAG,CAAC,QAAQ,CAAC,YAAY,EAAE,EAAE,IAAI,EAAE,CAAC,CAAC,CAAA;QAChD,OAAO,CAAC,GAAG,CAAC,qBAAqB,GAAC,IAAI,CAAC,CAAC;QAGxC,UAAU,CAAC,MAAM,CAAC,IAAI,CAAC,CAAC;QACxB,OAAO,CAAC,GAAG,CAAC,wBAAwB,GAAC,IAAI,CAAC,CAAC;QAE3C,OAAO,UAAU,CAAC;IACpB,CAAC;CACF;AAtCD,gCAsCC"}
\ No newline at end of file
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.watch = void 0;
function watch(req, res, next) {
res.success = success.bind({ res: res, req: req });
return next();
}
exports.watch = watch;
function success(data) {
let resultPack;
if (data) {
if (data.success === undefined || data.success === true) {
resultPack = { data, success: true, code: 200 };
}
else {
resultPack = data;
}
}
else {
resultPack = { code: 500, success: false, msg: 'result is null' };
}
this.res.send(resultPack);
}
//# sourceMappingURL=watch.js.map
\ No newline at end of file
{"version":3,"file":"watch.js","sourceRoot":"","sources":["../../src/net/watch.ts"],"names":[],"mappings":";;;AAAA,SAAgB,KAAK,CAAC,GAAG,EAAE,GAAG,EAAE,IAAI;IAChC,GAAG,CAAC,OAAO,GAAG,OAAO,CAAC,IAAI,CAAC,EAAC,GAAG,EAAC,GAAG,EAAE,GAAG,EAAC,GAAG,EAAC,CAAC,CAAC;IAE/C,OAAO,IAAI,EAAE,CAAC;AAClB,CAAC;AAJD,sBAIC;AAED,SAAS,OAAO,CAAC,IAAI;IACjB,IAAI,UAAU,CAAC;IACf,IAAI,IAAI,EAAG;QACP,IAAK,IAAI,CAAC,OAAO,KAAK,SAAS,IAAI,IAAI,CAAC,OAAO,KAAK,IAAI,EAAG;YACvD,UAAU,GAAG,EAAC,IAAI,EAAE,OAAO,EAAC,IAAI,EAAE,IAAI,EAAC,GAAG,EAAC,CAAC;SAC/C;aACI;YACD,UAAU,GAAG,IAAI,CAAC;SACrB;KACJ;SAAK;QACF,UAAU,GAAG,EAAC,IAAI,EAAC,GAAG,EAAE,OAAO,EAAC,KAAK,EAAE,GAAG,EAAC,gBAAgB,EAAC,CAAC;KAChE;IACD,IAAI,CAAC,GAAG,CAAC,IAAI,CAAC,UAAU,CAAC,CAAC;AAC9B,CAAC"}
\ No newline at end of file
......@@ -9,20 +9,13 @@ const zmxfxfbBiz = require("../biz/zmxfxfb");
const dqfxjdBiz = require("../biz/dqfxjd");
const gcaqztBiz = require("../biz/gcaqzt");
function setRouter(httpServer) {
//======post
httpServer.post('/jhjd', asyncHandler(jhjdBiz.getData));
httpServer.post('/xxjd', asyncHandler(xxjdBiz.getData));
httpServer.post('/lcbjdwcqk', asyncHandler(lcbjdwcqkBiz.getData));
httpServer.post('/zmxfxfb', asyncHandler(zmxfxfbBiz.getData));
httpServer.post('/dqfxjd', asyncHandler(dqfxjdBiz.getData));
httpServer.post('/gcaqzt', asyncHandler(gcaqztBiz.getData));
//======get
httpServer.get('/jhjd', asyncHandler(jhjdBiz.getData));
httpServer.get('/xxjd', asyncHandler(xxjdBiz.getData));
httpServer.get('/lcbjdwcqk', asyncHandler(lcbjdwcqkBiz.getData));
httpServer.get('/zmxfxfb', asyncHandler(zmxfxfbBiz.getData));
httpServer.get('/dqfxjd', asyncHandler(dqfxjdBiz.getData));
httpServer.get('/gcaqzt', asyncHandler(gcaqztBiz.getData));
httpServer.get('/aaa', asyncHandler(jhjdBiz.getJHJD));
}
exports.setRouter = setRouter;
//# sourceMappingURL=router.js.map
\ No newline at end of file
{"version":3,"file":"router.js","sourceRoot":"","sources":["../../src/routers/router.ts"],"names":[],"mappings":";;;AACA,sDAAqD;AAErD,uCAAuC;AAEvC,uCAAuC;AAEvC,iDAAiD;AAEjD,6CAA6C;AAE7C,2CAA2C;AAE3C,2CAA2C;AAE3C,SAAgB,SAAS,CAAC,UAAU;IAEhC,YAAY;IAEZ,UAAU,CAAC,IAAI,CAAC,OAAO,EAAE,YAAY,CAAC,OAAO,CAAC,OAAO,CAAC,CAAC,CAAC;IAExD,UAAU,CAAC,IAAI,CAAC,OAAO,EAAE,YAAY,CAAC,OAAO,CAAC,OAAO,CAAC,CAAC,CAAC;IAExD,UAAU,CAAC,IAAI,CAAC,YAAY,EAAE,YAAY,CAAC,YAAY,CAAC,OAAO,CAAC,CAAC,CAAC;IAElE,UAAU,CAAC,IAAI,CAAC,UAAU,EAAE,YAAY,CAAC,UAAU,CAAC,OAAO,CAAC,CAAC,CAAC;IAE9D,UAAU,CAAC,IAAI,CAAC,SAAS,EAAE,YAAY,CAAC,SAAS,CAAC,OAAO,CAAC,CAAC,CAAC;IAE5D,UAAU,CAAC,IAAI,CAAC,SAAS,EAAE,YAAY,CAAC,SAAS,CAAC,OAAO,CAAC,CAAC,CAAC;IAG5D,WAAW;IAEX,UAAU,CAAC,GAAG,CAAC,OAAO,EAAE,YAAY,CAAC,OAAO,CAAC,OAAO,CAAC,CAAC,CAAC;IAEvD,UAAU,CAAC,GAAG,CAAC,OAAO,EAAE,YAAY,CAAC,OAAO,CAAC,OAAO,CAAC,CAAC,CAAC;IAEvD,UAAU,CAAC,GAAG,CAAC,YAAY,EAAE,YAAY,CAAC,YAAY,CAAC,OAAO,CAAC,CAAC,CAAC;IAEjE,UAAU,CAAC,GAAG,CAAC,UAAU,EAAE,YAAY,CAAC,UAAU,CAAC,OAAO,CAAC,CAAC,CAAC;IAE7D,UAAU,CAAC,GAAG,CAAC,SAAS,EAAE,YAAY,CAAC,SAAS,CAAC,OAAO,CAAC,CAAC,CAAC;IAE3D,UAAU,CAAC,GAAG,CAAC,SAAS,EAAE,YAAY,CAAC,SAAS,CAAC,OAAO,CAAC,CAAC,CAAC;AAE/D,CAAC;AA/BD,8BA+BC"}
\ No newline at end of file
{"version":3,"file":"router.js","sourceRoot":"","sources":["../../src/routers/router.ts"],"names":[],"mappings":";;;AACA,sDAAqD;AAErD,uCAAuC;AAEvC,uCAAuC;AAEvC,iDAAiD;AAEjD,6CAA6C;AAE7C,2CAA2C;AAE3C,2CAA2C;AAE3C,SAAgB,SAAS,CAAC,UAAU;IAChC,UAAU,CAAC,GAAG,CAAC,OAAO,EAAE,YAAY,CAAC,OAAO,CAAC,OAAO,CAAC,CAAC,CAAC;IACvD,UAAU,CAAC,GAAG,CAAC,OAAO,EAAE,YAAY,CAAC,OAAO,CAAC,OAAO,CAAC,CAAC,CAAC;IACvD,UAAU,CAAC,GAAG,CAAC,YAAY,EAAE,YAAY,CAAC,YAAY,CAAC,OAAO,CAAC,CAAC,CAAC;IACjE,UAAU,CAAC,GAAG,CAAC,UAAU,EAAE,YAAY,CAAC,UAAU,CAAC,OAAO,CAAC,CAAC,CAAC;IAC7D,UAAU,CAAC,GAAG,CAAC,SAAS,EAAE,YAAY,CAAC,SAAS,CAAC,OAAO,CAAC,CAAC,CAAC;IAC3D,UAAU,CAAC,GAAG,CAAC,SAAS,EAAE,YAAY,CAAC,SAAS,CAAC,OAAO,CAAC,CAAC,CAAC;IAE3D,UAAU,CAAC,GAAG,CAAC,MAAM,EAAE,YAAY,CAAC,OAAO,CAAC,OAAO,CAAC,CAAC,CAAC;AAC1D,CAAC;AATD,8BASC"}
\ No newline at end of file
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.BizError = void 0;
exports.SysError = exports.BizError = void 0;
const errorEnum_1 = require("../config/errorEnum");
const log_1 = require("./log");
class BizError extends Error {
constructor(...msgs) {
let reqErrorMsg = '';
let logErrorMsg = '';
for (let i = 0; i < msgs.length; i++) {
if (!i) {
let msg = errorEnum_1.getBizMsg(msgs[i]);
reqErrorMsg = msg;
logErrorMsg = msg;
}
else {
logErrorMsg += ` | ${msgs[i]} `;
}
}
log_1.logError(logErrorMsg);
super(reqErrorMsg);
}
}
exports.BizError = BizError;
class SysError extends Error {
constructor(...msgs) {
let reqErrorMsg = '';
let logErrorMsg = '';
for (let i = 0; i < msgs.length; i++) {
if (!i) {
let msg = errorEnum_1.getSysMsg(msgs[i]);
reqErrorMsg = msg;
logErrorMsg = msg;
}
else {
if (typeof msgs[i] == 'object')
logErrorMsg += ` | ${JSON.stringify(msgs[i])} `;
else
logErrorMsg += ` | ${msgs[i]} `;
}
}
log_1.logError(logErrorMsg);
super(reqErrorMsg);
}
}
exports.SysError = SysError;
//# sourceMappingURL=bizError.js.map
\ No newline at end of file
{"version":3,"file":"bizError.js","sourceRoot":"","sources":["../../src/util/bizError.ts"],"names":[],"mappings":";;;AAAA,MAAa,QAAS,SAAQ,KAAK;CAElC;AAFD,4BAEC"}
\ No newline at end of file
{"version":3,"file":"bizError.js","sourceRoot":"","sources":["../../src/util/bizError.ts"],"names":[],"mappings":";;;AAAA,mDAA2D;AAC3D,+BAAiC;AAEjC,MAAa,QAAS,SAAQ,KAAK;IAC/B,YAAY,GAAG,IAAI;QACf,IAAI,WAAW,GAAG,EAAE,CAAC;QACrB,IAAI,WAAW,GAAG,EAAE,CAAC;QACrB,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAE,IAAI,CAAC,MAAM,EAAE,CAAC,EAAE,EAAE;YACjC,IAAI,CAAC,CAAC,EAAE;gBACJ,IAAI,GAAG,GAAG,qBAAS,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC,CAAC;gBAC7B,WAAW,GAAG,GAAG,CAAC;gBAClB,WAAW,GAAG,GAAG,CAAC;aACrB;iBAAM;gBACH,WAAW,IAAI,MAAM,IAAI,CAAC,CAAC,CAAC,GAAG,CAAC;aACnC;SACJ;QAED,cAAQ,CAAC,WAAW,CAAC,CAAC;QACtB,KAAK,CAAC,WAAW,CAAC,CAAC;IACvB,CAAC;CACJ;AAjBD,4BAiBC;AAED,MAAa,QAAS,SAAQ,KAAK;IAC/B,YAAY,GAAG,IAAI;QACf,IAAI,WAAW,GAAG,EAAE,CAAC;QACrB,IAAI,WAAW,GAAG,EAAE,CAAC;QACrB,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAE,IAAI,CAAC,MAAM,EAAE,CAAC,EAAE,EAAE;YACjC,IAAI,CAAC,CAAC,EAAE;gBACJ,IAAI,GAAG,GAAE,qBAAS,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC,CAAC;gBAC5B,WAAW,GAAG,GAAG,CAAC;gBAClB,WAAW,GAAG,GAAG,CAAC;aACrB;iBAAM;gBACH,IAAI,OAAO,IAAI,CAAC,CAAC,CAAC,IAAI,QAAQ;oBAAE,WAAW,IAAI,MAAM,IAAI,CAAC,SAAS,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC,GAAG,CAAC;;oBAC3E,WAAW,IAAI,MAAM,IAAI,CAAC,CAAC,CAAC,GAAG,CAAC;aACxC;SACJ;QAED,cAAQ,CAAC,WAAW,CAAC,CAAC;QACtB,KAAK,CAAC,WAAW,CAAC,CAAC;IACvB,CAAC;CACJ;AAlBD,4BAkBC"}
\ No newline at end of file
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.logConsole = exports.logHandle = exports.logError = exports.systemLogPath = void 0;
let log4js = require('log4js');
let path = require('path');
//log路径
exports.systemLogPath = {
errorLogFile: "error",
errorLogDir: "error",
handleLogFile: "handle",
handleLogDir: "handle"
};
//日志根目录
let baseLogPath = path.resolve(__dirname.substring(0, __dirname.indexOf("out")), 'logs');
// let baseLogPath = path.resolve('./', 'logs');
let errFile = path.resolve(baseLogPath, exports.systemLogPath.errorLogDir, exports.systemLogPath.errorLogFile);
let handFile = path.resolve(baseLogPath, exports.systemLogPath.handleLogDir, exports.systemLogPath.handleLogFile);
let config = {
appenders: {
"rule-console": { "type": "console" },
"errorLogger": {
"type": "dateFile",
"filename": errFile,
"pattern": "-yyyy-MM-dd.log",
"alwaysIncludePattern": true,
"encoding": "utf-8",
"maxLogSize": 1000,
"numBackups": 3,
"path": `/${exports.systemLogPath.errorLogDir}`
},
"handleLogger": {
"type": "dateFile",
"filename": handFile,
"pattern": "-yyyy-MM-dd.log",
"alwaysIncludePattern": true,
"encoding": "utf-8",
"maxLogSize": 1000,
"numBackups": 3,
"path": `/${exports.systemLogPath.handleLogDir}`
}
},
categories: {
"default": { "appenders": ["rule-console"], "level": "all" },
"errorLogger": { "appenders": ["errorLogger"], "level": "error" },
"handleLogger": { "appenders": ["handleLogger"], "level": "all" }
},
"baseLogPath": path.resolve(baseLogPath, exports.systemLogPath.handleLogDir, exports.systemLogPath.handleLogFile)
};
log4js.configure(config); //加载配置文件
//调用预先定义的日志名称
let errorLogger = log4js.getLogger("errorLogger");
let handleLogger = log4js.getLogger("handleLogger");
let consoleLogger = log4js.getLogger("rule-console");
//错误日志
function logError(...errStrs) {
let str = "";
errStrs.forEach(item => {
str += item + " | ";
});
errorLogger.error(`errorInfo => ${str}`);
}
exports.logError = logError;
//普通日志
function logHandle(msgStr) {
handleLogger.info(`logInfo => ${msgStr}`);
}
exports.logHandle = logHandle;
//输出日志
function logConsole(logStr) {
consoleLogger.info(`logInfo => ${logStr}`);
}
exports.logConsole = logConsole;
//# sourceMappingURL=log.js.map
\ No newline at end of file
{"version":3,"file":"log.js","sourceRoot":"","sources":["../../src/util/log.ts"],"names":[],"mappings":";;;AAAA,IAAI,MAAM,GAAG,OAAO,CAAC,QAAQ,CAAC,CAAC;AAC/B,IAAI,IAAI,GAAG,OAAO,CAAC,MAAM,CAAC,CAAC;AAE3B,OAAO;AACM,QAAA,aAAa,GAAG;IACzB,YAAY,EAAC,OAAO;IACpB,WAAW,EAAC,OAAO;IACnB,aAAa,EAAC,QAAQ;IACtB,YAAY,EAAC,QAAQ;CACxB,CAAA;AAED,OAAO;AACP,IAAI,WAAW,GAAG,IAAI,CAAC,OAAO,CAAC,SAAS,CAAC,SAAS,CAAC,CAAC,EAAE,SAAS,CAAC,OAAO,CAAC,KAAK,CAAC,CAAC,EAAE,MAAM,CAAC,CAAC;AACzF,gDAAgD;AAChD,IAAI,OAAO,GAAG,IAAI,CAAC,OAAO,CAAC,WAAW,EAAE,qBAAa,CAAC,WAAW,EAAE,qBAAa,CAAC,YAAY,CAAC,CAAC;AAC/F,IAAI,QAAQ,GAAE,IAAI,CAAC,OAAO,CAAC,WAAW,EAAE,qBAAa,CAAC,YAAY,EAAE,qBAAa,CAAC,aAAa,CAAC,CAAC;AACjG,IAAI,MAAM,GAAG;IACT,SAAS,EACL;QACI,cAAc,EAAE,EAAC,MAAM,EAAE,SAAS,EAAC;QACnC,aAAa,EAAE;YACX,MAAM,EAAE,UAAU;YAClB,UAAU,EAAE,OAAO;YACnB,SAAS,EAAE,iBAAiB;YAC5B,sBAAsB,EAAE,IAAI;YAC5B,UAAU,EAAE,OAAO;YACnB,YAAY,EAAE,IAAI;YAClB,YAAY,EAAE,CAAC;YACf,MAAM,EAAE,IAAI,qBAAa,CAAC,WAAW,EAAE;SAC1C;QACD,cAAc,EAAE;YACZ,MAAM,EAAE,UAAU;YAClB,UAAU,EAAG,QAAQ;YACrB,SAAS,EAAE,iBAAiB;YAC5B,sBAAsB,EAAE,IAAI;YAC5B,UAAU,EAAE,OAAO;YACnB,YAAY,EAAE,IAAI;YAClB,YAAY,EAAE,CAAC;YACf,MAAM,EAAE,IAAI,qBAAa,CAAC,YAAY,EAAE;SAC3C;KAEJ;IACL,UAAU,EAAE;QACR,SAAS,EAAE,EAAC,WAAW,EAAE,CAAC,cAAc,CAAC,EAAE,OAAO,EAAE,KAAK,EAAC;QAC1D,aAAa,EAAE,EAAC,WAAW,EAAE,CAAC,aAAa,CAAC,EAAE,OAAO,EAAE,OAAO,EAAC;QAC/D,cAAc,EAAE,EAAC,WAAW,EAAE,CAAC,cAAc,CAAC,EAAE,OAAO,EAAE,KAAK,EAAC;KAClE;IACD,aAAa,EAAE,IAAI,CAAC,OAAO,CAAC,WAAW,EAAE,qBAAa,CAAC,YAAY,EAAE,qBAAa,CAAC,aAAa,CAAC;CACpG,CAAC;AAEF,MAAM,CAAC,SAAS,CAAC,MAAM,CAAC,CAAC,CAAE,QAAQ;AAEnC,aAAa;AACb,IAAI,WAAW,GAAG,MAAM,CAAC,SAAS,CAAC,aAAa,CAAC,CAAC;AAClD,IAAI,YAAY,GAAG,MAAM,CAAC,SAAS,CAAC,cAAc,CAAC,CAAC;AACpD,IAAI,aAAa,GAAG,MAAM,CAAC,SAAS,CAAC,cAAc,CAAC,CAAC;AAErD,MAAM;AACN,SAAgB,QAAQ,CAAC,GAAG,OAAO;IAC/B,IAAI,GAAG,GAAG,EAAE,CAAC;IACb,OAAO,CAAC,OAAO,CAAC,IAAI,CAAC,EAAE;QACnB,GAAG,IAAI,IAAI,GAAG,MAAM,CAAC;IACzB,CAAC,CAAC,CAAC;IACH,WAAW,CAAC,KAAK,CAAC,kBAAkB,GAAG,EAAE,CAAC,CAAC;AAC/C,CAAC;AAND,4BAMC;AAED,MAAM;AACN,SAAgB,SAAS,CAAC,MAAa;IACnC,YAAY,CAAC,IAAI,CAAC,iBAAiB,MAAM,EAAE,CAAC,CAAC;AACjD,CAAC;AAFD,8BAEC;AAED,MAAM;AACN,SAAgB,UAAU,CAAC,MAAa;IACpC,aAAa,CAAC,IAAI,CAAC,gBAAgB,MAAM,EAAE,CAAC,CAAC;AACjD,CAAC;AAFD,gCAEC"}
\ No newline at end of file
......@@ -374,6 +374,11 @@
"assert-plus": "^1.0.0"
}
},
"date-format": {
"version": "4.0.14",
"resolved": "https://registry.npmjs.org/date-format/-/date-format-4.0.14.tgz",
"integrity": "sha512-39BOQLs9ZjKh0/patS9nrT8wc3ioX3/eA/zgbKNopnF2wCqJEoxywwwElATYvRsXdnOxA/OQeQoFZ3rFjVajhg=="
},
"debug": {
"version": "2.6.9",
"resolved": "https://registry.npm.taobao.org/debug/download/debug-2.6.9.tgz?cache=0&sync_timestamp=1607566580543&other_urls=https%3A%2F%2Fregistry.npm.taobao.org%2Fdebug%2Fdownload%2Fdebug-2.6.9.tgz",
......@@ -529,6 +534,11 @@
"unpipe": "~1.0.0"
}
},
"flatted": {
"version": "3.2.7",
"resolved": "https://registry.npmjs.org/flatted/-/flatted-3.2.7.tgz",
"integrity": "sha512-5nqDSxl8nn5BSNxyR3n4I6eDmbolI6WT+QqR547RwxQapgjQBmtktdP+HTBb/a/zLsbzERTONyUB5pefh5TtjQ=="
},
"forever-agent": {
"version": "0.6.1",
"resolved": "https://registry.npm.taobao.org/forever-agent/download/forever-agent-0.6.1.tgz",
......@@ -564,6 +574,16 @@
"resolved": "https://registry.npmjs.org/fresh/-/fresh-0.5.2.tgz",
"integrity": "sha1-PYyt2Q2XZWn6g1qx+OSyOhBWBac="
},
"fs-extra": {
"version": "8.1.0",
"resolved": "https://registry.npmjs.org/fs-extra/-/fs-extra-8.1.0.tgz",
"integrity": "sha512-yhlQgA6mnOJUKOsRUFsgJdQCvkKhcz8tlZG5HBQfReYZy46OwLcY+Zia0mtdHsOo9y/hP+CxMN0TU9QxoOtG4g==",
"requires": {
"graceful-fs": "^4.2.0",
"jsonfile": "^4.0.0",
"universalify": "^0.1.0"
}
},
"getpass": {
"version": "0.1.7",
"resolved": "https://registry.npm.taobao.org/getpass/download/getpass-0.1.7.tgz",
......@@ -572,6 +592,11 @@
"assert-plus": "^1.0.0"
}
},
"graceful-fs": {
"version": "4.2.10",
"resolved": "https://registry.npmjs.org/graceful-fs/-/graceful-fs-4.2.10.tgz",
"integrity": "sha512-9ByhssR2fPVsNZj478qUUbKfmL0+t5BDVyjShtyZZLiK7ZDAArFFfopyOTj0M05wE2tJPisA4iTnnXl2YoPvOA=="
},
"har-schema": {
"version": "2.0.0",
"resolved": "https://registry.npm.taobao.org/har-schema/download/har-schema-2.0.0.tgz",
......@@ -708,6 +733,14 @@
"resolved": "https://registry.npm.taobao.org/json-stringify-safe/download/json-stringify-safe-5.0.1.tgz",
"integrity": "sha1-Epai1Y/UXxmg9s4B1lcB4sc1tus="
},
"jsonfile": {
"version": "4.0.0",
"resolved": "https://registry.npmjs.org/jsonfile/-/jsonfile-4.0.0.tgz",
"integrity": "sha512-m6F1R3z8jjlf2imQHS2Qez5sjKWQzbuuhuJ/FKYFRZvPE3PuHcSMVZzfsLhGVOkfd20obL5SWEBew5ShlquNxg==",
"requires": {
"graceful-fs": "^4.1.6"
}
},
"jsprim": {
"version": "1.4.1",
"resolved": "https://registry.npm.taobao.org/jsprim/download/jsprim-1.4.1.tgz",
......@@ -729,6 +762,33 @@
"resolved": "https://registry.npm.taobao.org/kitx/download/kitx-1.3.0.tgz",
"integrity": "sha1-qz7nxZjSsdYp/VVWj4aMREDCAOo="
},
"log4js": {
"version": "6.7.0",
"resolved": "https://registry.npmjs.org/log4js/-/log4js-6.7.0.tgz",
"integrity": "sha512-KA0W9ffgNBLDj6fZCq/lRbgR6ABAodRIDHrZnS48vOtfKa4PzWImb0Md1lmGCdO3n3sbCm/n1/WmrNlZ8kCI3Q==",
"requires": {
"date-format": "^4.0.14",
"debug": "^4.3.4",
"flatted": "^3.2.7",
"rfdc": "^1.3.0",
"streamroller": "^3.1.3"
},
"dependencies": {
"debug": {
"version": "4.3.4",
"resolved": "https://registry.npmjs.org/debug/-/debug-4.3.4.tgz",
"integrity": "sha512-PRWFHuSU3eDtQJPvnNY7Jcket1j0t5OuOsFzPPzsekD52Zl8qUfFIPEiswXqIvHWGVHOgX+7G/vCNNhehwxfkQ==",
"requires": {
"ms": "2.1.2"
}
},
"ms": {
"version": "2.1.2",
"resolved": "https://registry.npmjs.org/ms/-/ms-2.1.2.tgz",
"integrity": "sha512-sGkPx+VjMtmA6MX27oA4FBFELFCZZ4S4XqeGOXCv68tT+jb3vk/RyaKWP0PTKyWtmLSM0b+adUTEvbs1PEaH2w=="
}
}
},
"lru-cache": {
"version": "4.1.5",
"resolved": "https://registry.npm.taobao.org/lru-cache/download/lru-cache-4.1.5.tgz",
......@@ -1022,6 +1082,11 @@
"uuid": "^3.3.2"
}
},
"rfdc": {
"version": "1.3.0",
"resolved": "https://registry.npmjs.org/rfdc/-/rfdc-1.3.0.tgz",
"integrity": "sha512-V2hovdzFbOi77/WajaSMXk2OLm+xNIeQdMMuB7icj7bk6zi2F8GGAxigcnDFpJHbNyNcgyJDiP+8nOrY5cZGrA=="
},
"safe-buffer": {
"version": "5.1.2",
"resolved": "https://registry.npm.taobao.org/safe-buffer/download/safe-buffer-5.1.2.tgz",
......@@ -1146,6 +1211,31 @@
"resolved": "https://registry.npmjs.org/statuses/-/statuses-1.5.0.tgz",
"integrity": "sha1-Fhx9rBd2Wf2YEfQ3cfqZOBR4Yow="
},
"streamroller": {
"version": "3.1.3",
"resolved": "https://registry.npmjs.org/streamroller/-/streamroller-3.1.3.tgz",
"integrity": "sha512-CphIJyFx2SALGHeINanjFRKQ4l7x2c+rXYJ4BMq0gd+ZK0gi4VT8b+eHe2wi58x4UayBAKx4xtHpXT/ea1cz8w==",
"requires": {
"date-format": "^4.0.14",
"debug": "^4.3.4",
"fs-extra": "^8.1.0"
},
"dependencies": {
"debug": {
"version": "4.3.4",
"resolved": "https://registry.npmjs.org/debug/-/debug-4.3.4.tgz",
"integrity": "sha512-PRWFHuSU3eDtQJPvnNY7Jcket1j0t5OuOsFzPPzsekD52Zl8qUfFIPEiswXqIvHWGVHOgX+7G/vCNNhehwxfkQ==",
"requires": {
"ms": "2.1.2"
}
},
"ms": {
"version": "2.1.2",
"resolved": "https://registry.npmjs.org/ms/-/ms-2.1.2.tgz",
"integrity": "sha512-sGkPx+VjMtmA6MX27oA4FBFELFCZZ4S4XqeGOXCv68tT+jb3vk/RyaKWP0PTKyWtmLSM0b+adUTEvbs1PEaH2w=="
}
}
},
"svg-captcha": {
"version": "1.4.0",
"resolved": "https://registry.npm.taobao.org/svg-captcha/download/svg-captcha-1.4.0.tgz",
......@@ -1203,6 +1293,11 @@
"mime-types": "~2.1.24"
}
},
"universalify": {
"version": "0.1.2",
"resolved": "https://registry.npmjs.org/universalify/-/universalify-0.1.2.tgz",
"integrity": "sha512-rBJeI5CXAlmy1pV+617WB9J63U6XcazHHF2f2dbJix4XzpUF0RS3Zbj0FGIOCAva5P/d/GBOYaACQ1w+0azUkg=="
},
"unpipe": {
"version": "1.0.0",
"resolved": "https://registry.npmjs.org/unpipe/-/unpipe-1.0.0.tgz",
......
......@@ -11,6 +11,7 @@
"express-async-handler": "^1.1.4",
"express-history-api-fallback": "^2.2.1",
"formidable": "^1.2.1",
"log4js": "^6.7.0",
"lru-cache": "^4.1.5",
"md5": "^2.2.1",
"moment": "^2.24.0",
......
No preview for this file type
......@@ -29,4 +29,8 @@ export function getData(req, res) {
ret['yjxxxl'] = getKeyValueOut('移交详细线路', yjxxxlPackageData);
res.send(ret);
}
\ No newline at end of file
}
export function getJHJD(req, res) {
let {} = req;
}
\ No newline at end of file
export enum INTERFACErEQUESTTYPEENUM {
export enum INTERFACEREQUESTTYPEENUM {
即时更新 = 1,
定时更新
}
\ No newline at end of file
export enum ERRORENUM {
未找到数据,
}
export enum SYSTEMERRORENUM {
初始化配置失败 = 1,
获取第三方接口数据失败,
未按接口协议返回,
请求未鉴权 = 401,
请求路径不存在 = 404,
请求频率过高 = 503
}
let bizErrorMsgMap = {};
for (let key in ERRORENUM) {
bizErrorMsgMap[ERRORENUM[key]] = key;
}
let systemErrorMsgMap = {};
for (let key in SYSTEMERRORENUM) {
systemErrorMsgMap[SYSTEMERRORENUM[key]] = key;
}
export function getBizMsg(param) {
return bizErrorMsgMap[param];
}
export function getSysMsg(param) {
return systemErrorMsgMap[param];
}
\ No newline at end of file
import { INTERFACErEQUESTTYPEENUM } from "./enum";
// 请把 "INTERFACErEQUESTTYPEENUM.即时更新" 改成 INTERFACErEQUESTTYPEENUM.即时更新 把引号去掉 【定时更新同理 】
export const Config = {"计划进度":{"type":"INTERFACErEQUESTTYPEENUM.即时更新","time":3600000,"url":"url地址","reqType":"post","header":{},"body":{}},"形象进度":{"type":"INTERFACErEQUESTTYPEENUM.即时更新","time":3600000,"url":"url地址","reqType":"post","header":{},"body":{}},"里程碑节点完成情况":{"type":"INTERFACErEQUESTTYPEENUM.即时更新","time":3600000,"url":"url地址","reqType":"post","header":{},"body":{}},"致命性风险分布":{"type":"INTERFACErEQUESTTYPEENUM.即时更新","time":3600000,"url":"url地址","reqType":"post","header":{},"body":{}},"当前风险节点":{"type":"INTERFACErEQUESTTYPEENUM.即时更新","time":3600000,"url":"url地址","reqType":"post","header":{},"body":{}},"工程 安全状态":{"type":"INTERFACErEQUESTTYPEENUM.即时更新","time":3600000,"url":"url地址","reqType":"post","header":{},"body":{}}};
import { INTERFACEREQUESTTYPEENUM } from "./enum";
// 请把 "INTERFACEREQUESTTYPEENUM.即时更新" 改成 INTERFACEREQUESTTYPEENUM.即时更新 把引号去掉 【定时更新同理 】
export const Config = {"计划进度":{"type":"INTERFACEREQUESTTYPEENUM.即时更新","time":3600000,"url":"url地址","reqType":"post","header":{},"body":{}},"形象进度":{"type":"INTERFACEREQUESTTYPEENUM.即时更新","time":3600000,"url":"url地址","reqType":"post","header":{},"body":{}},"里程碑节点完成情况":{"type":"INTERFACEREQUESTTYPEENUM.即时更新","time":3600000,"url":"url地址","reqType":"post","header":{},"body":{}},"致命性风险分布":{"type":"INTERFACEREQUESTTYPEENUM.即时更新","time":3600000,"url":"url地址","reqType":"post","header":{},"body":{}},"当前风险节点":{"type":"INTERFACEREQUESTTYPEENUM.即时更新","time":3600000,"url":"url地址","reqType":"post","header":{},"body":{}},"工程 安全状态":{"type":"INTERFACEREQUESTTYPEENUM.即时更新","time":3600000,"url":"url地址","reqType":"post","header":{},"body":{}}};
\ No newline at end of file
//接口任务 定期更新
import { INTERFACErEQUESTTYPEENUM } from "../../config/enum";
import { INTERFACEREQUESTTYPEENUM } from "../../config/enum";
import { Config } from "../../config/interfaceConfig";
import { BizError } from "../../util/bizError";
import { get, post, postForm } from "../../util/request";
......@@ -45,7 +45,7 @@ async function taskUpdate() {
}
const ThisConfig = Config[interfaceName];
if (ThisConfig.type == INTERFACErEQUESTTYPEENUM.即时更新) continue;
if (ThisConfig.type == INTERFACEREQUESTTYPEENUM.即时更新) continue;
let lastTaskInfo = updateInfo[interfaceName];
if ( !lastTaskInfo ) thisTaskInfo.push({name:defaultUseTime, useTime:defaultUseTime});
......@@ -98,7 +98,7 @@ export async function initRealTime() {
let initSuccess = true;
for (let interfaceName in Config) {
const ThisConfig = Config[interfaceName];
if (ThisConfig.type == INTERFACErEQUESTTYPEENUM.定时更新) continue;
if (ThisConfig.type == INTERFACEREQUESTTYPEENUM.定时更新) continue;
let reqRes;
switch(ThisConfig.reqType) {
case "get": reqRes = await get(ThisConfig.url, ThisConfig.body, ThisConfig.header); break;
......@@ -117,7 +117,7 @@ export async function initRealTime() {
export async function getInterfaceByInterfaceName(name) {
const ThisConfig = Config[name];
let data:any;
if (ThisConfig.type == INTERFACErEQUESTTYPEENUM.即时更新) {
if (ThisConfig.type == INTERFACEREQUESTTYPEENUM.即时更新) {
let reqRes;
switch(ThisConfig.reqType) {
case "get": reqRes = await get(ThisConfig.url, ThisConfig.body, ThisConfig.header); break;
......
import { initInterfaceData } from "./data/interface/cronJob";
var os = require("os")
import { httpServer } from "./net/http_server";
import { initConfig, port } from "./config/serverConfig";
async function lanuch() {
test();
// test();
// return
await initConfig();
// initInterfaceData();
httpServer.createServer( port );
......@@ -13,6 +15,8 @@ async function lanuch() {
}
function test() {
console.log(os.platform());
console.log(os.networkInterfaces());
}
lanuch();
export async function checkToken(req, res, next) {
next();
}
\ No newline at end of file
export async function encryptionReturn(req, res, next) {
res.on('end', function(){
console.log(res.body);
});
let resSend = res.send;
res.send = (obj)=>{
changeNumber(obj);
//递归修改number型
resSend.call(res, obj);
};
next();
}
function changeNumber(obj) {
if (Array.isArray(obj)) {
for (let i = 0; i < obj.length; i++) {
let arrItem = obj[i];
if (typeof arrItem == "number") {
obj[i] = getSameLenNumber(arrItem);
}
else if (typeof arrItem == "object") {
changeNumber(arrItem);
}
}
}
else {
for (let key in obj) {
let objItem = obj[key];
if (typeof objItem == "number") {
if (key == "x" || key == "y") continue;
obj[key] = getSameLenNumber(objItem);
}
else if (typeof objItem == "object") {
changeNumber(objItem);
}
}
}
}
function getSameLenNumber(num) {
let numStr = String(num);
//疑似年份的不做加密
if (numStr.length == 4 && (numStr.indexOf("19") == 0 || numStr.indexOf("20") == 0)) return num;
let str = "";
for (let i = 0; i < numStr.length; i++) {
if (numStr[i] == '.') str += numStr[i];
else str += "6";
}
return Number(str);
}
\ No newline at end of file
export function httpErrorHandler(err, req, res, next) {
console.log("in httpErrorHandler");
console.log(err);
//todo 自定义错误编码
if (err) {
if (err.message == "您的登录已失效" ) {
res.success({success:false, msg:err.message, code:501});
next();
}
else if (err.message == "您的账户没有访问权限") {
res.success({success:false, msg:"非常抱歉,您没有权限,请联系工作人员!", code:502});
next();
} else if ( err.message == "token已过期") {
res.success({success:false, msg:"token失效", code:503});
next();
}
else {
res.success({success:false, msg:err.message, code:500});
next();
}
}
}
\ No newline at end of file
export function watch(req, res, next) {
res.success = success.bind({res:res, req:req});
return next();
}
function success(data) {
let resultPack;
if (data ) {
if ( data.success === undefined || data.success === true ) {
resultPack = {data, success:true, code:200};
}
else {
resultPack = data;
}
}else {
resultPack = {code:500, success:false, msg:'result is null'};
}
this.res.send(resultPack);
}
import express = require('express');
import bodyParser = require('body-parser');
import sign = require('../middleware/sign');
import routers = require('../routers/router');
import compression = require('compression');
import * as fallback from 'express-history-api-fallback';
import * as path from "path";
import { watch } from '../middleware/watch';
import { httpErrorHandler } from '../middleware/httpErrorHandler';
export class httpServer {
......@@ -26,11 +27,13 @@ export class httpServer {
}
});
httpServer.use(express.static('public') );
httpServer.use(bodyParser.json({limit:"10kb"}));
httpServer.use(compression())
httpServer.use(watch);
routers.setRouter(httpServer);
httpServer.use(httpErrorHandler);
const root = path.join(__dirname, "../../public/")
httpServer.use(express.static(root))
......
......@@ -14,35 +14,13 @@ import * as dqfxjdBiz from '../biz/dqfxjd';
import * as gcaqztBiz from '../biz/gcaqzt';
export function setRouter(httpServer){
//======post
httpServer.post('/jhjd', asyncHandler(jhjdBiz.getData));
httpServer.post('/xxjd', asyncHandler(xxjdBiz.getData));
httpServer.post('/lcbjdwcqk', asyncHandler(lcbjdwcqkBiz.getData));
httpServer.post('/zmxfxfb', asyncHandler(zmxfxfbBiz.getData));
httpServer.post('/dqfxjd', asyncHandler(dqfxjdBiz.getData));
httpServer.post('/gcaqzt', asyncHandler(gcaqztBiz.getData));
//======get
httpServer.get('/jhjd', asyncHandler(jhjdBiz.getData));
httpServer.get('/xxjd', asyncHandler(xxjdBiz.getData));
httpServer.get('/lcbjdwcqk', asyncHandler(lcbjdwcqkBiz.getData));
httpServer.get('/zmxfxfb', asyncHandler(zmxfxfbBiz.getData));
httpServer.get('/dqfxjd', asyncHandler(dqfxjdBiz.getData));
httpServer.get('/gcaqzt', asyncHandler(gcaqztBiz.getData));
httpServer.get('/aaa', asyncHandler(jhjdBiz.getJHJD));
}
\ No newline at end of file
import { getBizMsg, getSysMsg } from "../config/errorEnum";
import { logError } from "./log";
export class BizError extends Error {
constructor(...msgs) {
let reqErrorMsg = '';
let logErrorMsg = '';
for (let i = 0; i <msgs.length; i++) {
if (!i) {
let msg = getBizMsg(msgs[i]);
reqErrorMsg = msg;
logErrorMsg = msg;
} else {
logErrorMsg += ` | ${msgs[i]} `;
}
}
logError(logErrorMsg);
super(reqErrorMsg);
}
}
export class SysError extends Error {
constructor(...msgs) {
let reqErrorMsg = '';
let logErrorMsg = '';
for (let i = 0; i <msgs.length; i++) {
if (!i) {
let msg= getSysMsg(msgs[i]);
reqErrorMsg = msg;
logErrorMsg = msg;
} else {
if (typeof msgs[i] == 'object') logErrorMsg += ` | ${JSON.stringify(msgs[i])} `;
else logErrorMsg += ` | ${msgs[i]} `;
}
}
logError(logErrorMsg);
super(reqErrorMsg);
}
}
\ No newline at end of file
let log4js = require('log4js');
let path = require('path');
//log路径
export const systemLogPath = {
errorLogFile:"error",
errorLogDir:"error",
handleLogFile:"handle",
handleLogDir:"handle"
}
//日志根目录
let baseLogPath = path.resolve(__dirname.substring(0, __dirname.indexOf("out")), 'logs');
// let baseLogPath = path.resolve('./', 'logs');
let errFile = path.resolve(baseLogPath, systemLogPath.errorLogDir, systemLogPath.errorLogFile);
let handFile =path.resolve(baseLogPath, systemLogPath.handleLogDir, systemLogPath.handleLogFile);
let config = {
appenders:
{
"rule-console": {"type": "console"},
"errorLogger": {
"type": "dateFile", // 日志类型
"filename": errFile, // 输出文件名
"pattern": "-yyyy-MM-dd.log", // 后缀
"alwaysIncludePattern": true, // 上面两个参数是否合并
"encoding": "utf-8", // 编码格式
"maxLogSize": 1000, // 最大存储内容
"numBackups": 3, // 当文件内容超过文件存储空间时,备份文件的数量
"path": `/${systemLogPath.errorLogDir}`
},
"handleLogger": {
"type": "dateFile",
"filename": handFile,
"pattern": "-yyyy-MM-dd.log",
"alwaysIncludePattern": true,
"encoding": "utf-8",
"maxLogSize": 1000,
"numBackups": 3,
"path": `/${systemLogPath.handleLogDir}`
}
},
categories: {
"default": {"appenders": ["rule-console"], "level": "all"}, //这个配置一定要有
"errorLogger": {"appenders": ["errorLogger"], "level": "error"},
"handleLogger": {"appenders": ["handleLogger"], "level": "all"}
},
"baseLogPath": path.resolve(baseLogPath, systemLogPath.handleLogDir, systemLogPath.handleLogFile)
};
log4js.configure(config); //加载配置文件
//调用预先定义的日志名称
let errorLogger = log4js.getLogger("errorLogger");
let handleLogger = log4js.getLogger("handleLogger");
let consoleLogger = log4js.getLogger("rule-console");
//错误日志
export function logError(...errStrs) {
let str = "";
errStrs.forEach(item => {
str += item + " | ";
});
errorLogger.error(`errorInfo => ${str}`);
}
//普通日志
export function logHandle(msgStr:string) {
handleLogger.info(`logInfo => ${msgStr}`);
}
//输出日志
export function logConsole(logStr:string) {
consoleLogger.info(`logInfo => ${logStr}`);
}
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