电信接口

.gitignore

+.idea
+/out
+/node_modules
+/test
+/public
+/logs
+/video
+*test*
+*.logs
+*.zip
\ No newline at end of file

.vscode/launch.json

+{
+    // Use IntelliSense to learn about possible attributes.
+    // Hover to view descriptions of existing attributes.
+    // For more information, visit: https://go.microsoft.com/fwlink/?linkid=830387
+    "version": "0.2.0",
+    "configurations": [
+    
+        {
+            "type": "node",
+            "request": "launch",
+            "name": "启动程序",
+            "program": "${workspaceFolder}/src/main.ts",
+            "outFiles": [
+                "${workspaceFolder}/**/*.js"
+            ]
+        }
+    ]
+}
\ No newline at end of file

package.json

+{
+  "name": "screen",
+  "version": "1.0.0",
+  "description": "",
+  "main": "main.ts",
+  "dependencies": {
+    "@alicloud/sms-sdk": "^1.1.6",
+    "@types/node": "^10.12.18",
+    "compression": "^1.7.4",
+    "express": "^4.17.1",
+    "express-async-handler": "^1.1.4",
+    "express-history-api-fallback": "^2.2.1",
+    "formidable": "^1.2.1",
+    "log4js": "^6.6.1",
+    "lru-cache": "^4.1.5",
+    "md5": "^2.2.1",
+    "moment": "^2.24.0",
+    "mongoose": "^5.4.0",
+    "mysql": "^2.18.1",
+    "mysql2": "^3.1.2",
+    "node-xlsx": "^0.16.1",
+    "nodemailer": "^6.1.1",
+    "qs": "^6.11.0",
+    "request": "^2.88.0",
+    "sequelize": "^6.32.1",
+    "svg-captcha": "^1.3.12",
+    "ws": "^5.2.2",
+    "xml2js": "^0.4.23"
+  },
+  "devDependencies": {},
+  "scripts": {
+    "test": "echo \"Error: no test specified\" && exit 1"
+  },
+  "author": "cjj",
+  "license": "ISC",
+  "bin": "./out/main.js",
+  "pkg": {
+    "scripts": "out/**/*.js",
+    "assets": [
+      "public/**/*",
+      "res/**/*",
+      "images/**/*",
+      "video/**/*"
+    ],
+    "outputPath": "dist"
+  }
+}

serverConfig.xml

+<config>
+    <port>40301</port>
+</config>

src/config/enum.ts

+
+

src/config/errorEnum.ts

+
+export enum ERRORENUM {
+   身份验证失败 = 1,
+   非法登录,
+   身份验证过期,
+   表单校验失败,
+   参数错误
+}
+
+/**
+ * 只用做code码定义
+ */
+export enum ERRORCODEENUM {
+    身份验证失败 = 401,
+    非法登录 = 402,
+    身份验证过期 = 403
+}
+
+let bizErrorMsgMap = {};
+for (let key in ERRORENUM) {
+    bizErrorMsgMap[ERRORENUM[key]] = key;
+}
+
+export function getBizMsg(param) {
+    return bizErrorMsgMap[param];
+}
\ No newline at end of file

src/config/serverConfig.ts

+const path = require('path');
+import * as fs from "fs";
+import { BizError } from "../util/bizError";
+import { analysisXml } from "../util/myXML";
+import { ServerConfig } from "../config/systemClass";
+export let systemConfig =  new ServerConfig;
+
+const ConfigName = "serverConfig.xml";
+export async function initConfig() {
+    try {
+        let buff = fs.readFileSync(path.join(__dirname.substring(0,__dirname.indexOf("out")), ConfigName));
+        let configStr = buff.toString();
+        let configInfo:any = await analysisXml(configStr);
+		if (!configInfo || !configInfo.config) throw new BizError('xml中无配置');
+		else {
+            
+            let {port } = configInfo.config;
+            systemConfig.port = parseInt(port[0]);
+
+		}
+        
+        console.log("config init success");
+
+    } catch(err) {
+        console.log('ERROR => 服务器配置解析错误 请检查根目录下 serverConfig.xml 文件是否正确');
+        console.log(err);
+        throw new BizError("服务器配置解析错误 请检查根目录下 serverConfig.xml 文件是否正确");
+    }
+}
+
+function analysisMongoConnectStr(path, port, dataBase, w, timeOutMs) {
+    return `mongodb://${path}:${port}/${dataBase}?w=${w}&wtimeoutMS=${timeOutMs}`
+}

src/config/systemClass.ts

+/**
+ * 系统配置类
+ * 
+ */
+
+export class ServerConfig {
+    /**系统配置 */
+    port:number;
+   
+}
\ No newline at end of file

src/main.ts

+
+import { initConfig, systemConfig} from "./config/serverConfig";
+import { httpServer } from "./net/http_server";
+
+async function lanuch() {
+    /**初始化配置解析 */
+    await initConfig();
+    /**创建http服务 */
+    httpServer.createServer(systemConfig.port);
+    // await smsTask();
+    console.log('This indicates that the server is started successfully.');
+}
+
+
+
+
+lanuch();
\ No newline at end of file

src/middleware/httpErrorHandler.ts

+import { ERRORCODEENUM } from "../config/errorEnum";
+
+/**
+ * 中间件 错误返回
+ * @param err 
+ * @param req 
+ * @param res 
+ * @param next 
+ */
+export function httpErrorHandler(err, req, res, next) {
+    console.log("in httpErrorHandler");
+    console.log(err);
+    //todo 自定义错误编码
+    if (err) {
+        if ( ERRORCODEENUM[err.message] ) {
+            res.success({success:false, msg:err.message, code:ERRORCODEENUM[err.message]});
+            next();
+        }
+        else {
+            res.success({success:false, msg:err.message, code:500});
+            next();
+        }
+    }
+} 
\ No newline at end of file

src/middleware/user.ts

+
+import { ERRORENUM } from "../config/errorEnum";
+import { BizError } from "../util/bizError";
+
+/**
+ * 中间件 校验token
+ * @param req 
+ * @param res 
+ * @param next 
+ * @returns 
+ */
+export async function checkFuHuaQiToken(req, res, next) {
+    if (!req.headers) req.headers = {};
+
+    next();
+}

src/middleware/watch.ts

+export function watch(req, res, next) {
+    res.success = success.bind({res:res, req:req});
+    res.packageRes = packageRes.bind({res:res, req:req});
+    return next();
+}
+
+/**
+ * 中间件正确返回方法
+ * @param data 
+ */
+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);
+}
+
+
+
+/**
+ * 中间件包装第三方api返回方法
+ * @param data 
+ */
+function packageRes(data) {
+    this.res.send(data);
+}

src/net/http_server.ts

+import express = require('express');
+import bodyParser = require('body-parser');
+import routers = require('../routers/router');
+import compression = require('compression');
+import { watch } from '../middleware/watch';
+import { httpErrorHandler } from '../middleware/httpErrorHandler';
+import * as path from "path";
+import * as fallback from 'express-history-api-fallback';
+
+export class httpServer {
+    static createServer(port:number) {
+        var httpServer = express();
+
+        httpServer.all('*', (req, res, next) => {
+            res.header('Access-Control-Allow-Origin', req.headers.origin);
+            res.header("Access-Control-Allow-Headers", "X-Requested-With");
+            res.header('Access-Control-Allow-Headers', 'Content-Type,request-origin,userid,token');
+            res.header("Access-Control-Allow-Methods", "PUT,POST,GET,DELETE,OPTIONS");
+            res.header('Access-Control-Allow-Credentials', true);
+            res.header("X-Powered-By", ' 3.2.1');
+            next();
+            // if(req.method === 'OPTIONS'){
+            //     res.statusCode = 200;
+            //     res.end();
+            //   }else{
+            //       next();
+            //   }
+        });
+
+        // httpServer.use(bodyParser.json({limit:'5mb'}));
+        // httpServer.use(bodyParser.urlencoded({limit:'5mb', extends:true}));
+
+        httpServer.use(express.static("./static") );
+        httpServer.use(express.static("./files") );
+        const root = path.join(__dirname, "../../public");
+        httpServer.use(express.static(root));
+        httpServer.use(fallback('index.html', { root }));
+        httpServer.use(compression());
+        httpServer.use(watch);
+        httpServer.use(bodyParser.json({limit:"5000kb"}));
+        httpServer.use(bodyParser.urlencoded({limit:'5mb', extends:true}));
+        routers.setRouter(httpServer);
+        httpServer.use(httpErrorHandler);
+
+        httpServer.listen(port);
+        console.log('server listen on port:'+port);
+    }
+}
\ No newline at end of file

src/routers/dianXin.ts

+
+
+
+import * as asyncHandler from 'express-async-handler';
+import { get, post, postForm } from '../util/request';
+var formidable = require("formidable");
+
+const ApiConfig = {
+    token:{type:"post", url:'/oauth/token', name:"获取token"},
+    statistics:{type:"post", url:'/service/api/nmzx/statistics', name:"教师总数"},
+    teachersex_count:{type:"post", url:'/service/api/nmzx/teachersex_count', name:"男女比例"},
+    teacherage_count:{type:"post", url:'/service/api/nmzx/teacherage_count', name:"年龄分布"},
+    teacherzzmm_count:{type:"post", url:'/service/api/nmzx/teacherzzmm_count', name:"教师政治面貌"},
+    teacherzc_count:{type:"post", url:'/service/api/nmzx/teacherzc_count', name:"职称分布"},
+    ggteacher_count:{type:"post", url:'/service/api/nmzx/ggteacher_count', name:"教师专业建设&组织部署"},
+    teacher_hj:{type:"post", url:'/service/api/nmzx/teacher_hj', name:"国家级奖项，市级奖项，区级奖项，镇级奖项，校级奖项"},
+    teacher_attendance:{type:"post", url:'/service/api/nmzx/teacher_attendance', name:"出勤考核"},
+    teacher_score:{type:"post", url:'/service/api/nmzx/teacher_score', name:"学分管理"},
+    subjects:{type:"post", url:'/service/api/nmzx/subject', name:"学科下拉数据"},
+    teacher_info_get:{type:"get", url:'/service/api/nmzx/teacher_info_get', name:"教师基础信息 数据"},
+    teacher_open:{type:"post", url:'/service/api/nmzx/teacher_open', name:"教师个人信息 公开课记录"},
+    teacher_jyhd:{type:"post", url:'/service/api/nmzx/teacher_jyhd', name:"教师个人信息 教师教研活动"},
+    teacher_kt:{type:"post", url:'/service/api/nmzx/teacher_kt', name:"教师个人信息 课题研究"},
+    teacher_lw:{type:"post", url:'/service/api/nmzx/teacher_lw', name:"教师个人信息 论文论著"},
+    teacher_hjry:{type:"post", url:'/service/api/nmzx/teacher_hjry', name:"教师个人信息 教师获奖荣誉"},
+    teacher_hdlb:{type:"post", url:'/service/api/nmzx/teacher_hdlb', name:"教育培训 活动项目"},
+    teacher_hdjb_yxlb:{type:"post", url:'/service/api/nmzx/teacher_hdjb_yxlb', name:"教育培训 活动项目 饼图类别"},
+    teacher_leavetrend:{type:"post", url:'/service/api/nmzx/teacher_leavetrend', name:"绩效考核 请假趋势"}
+};
+
+export function setDianXinRouter(httpServer) {
+    for (let key in ApiConfig) {
+        let {url, name, type} = ApiConfig[key];
+        
+        if (type == "post") {
+            httpServer.post(url, asyncHandler( async (req, res) => {
+                const UrlStr = `http://61.171.4.98:9090${url}`;
+                let result;
+                if (key == "token") {
+                    let param = req.body;
+                    result = await postForm(UrlStr, param, {});
+                } else {
+                    let param = req.body;
+                    result = await post(UrlStr, param, {});
+                }
+                   
+                res.packageRes(result);
+    
+            } ));
+        } 
+        else {
+            httpServer.get(url, asyncHandler( t));
+        }
+    }
+}
+
+async function t(req, res) {
+    let url = '/service/api/nmzx/teacher_info_get';
+    const UrlStr = `http://61.171.4.98:9090${url}`;
+    let param = req.query;
+    let result = await get(UrlStr, param, {});
+
+    res.packageRes(result);
+}
\ No newline at end of file

src/routers/router.ts

+/**
+ * 总路由入口
+ */
+
+import { setDianXinRouter } from "./dianXin";
+
+
+export function setRouter(httpServer){
+    setDianXinRouter(httpServer);
+}
\ No newline at end of file

src/tools/eccParam.ts

+import { ERRORENUM } from "../config/errorEnum";
+import { BizError } from "../util/bizError";
+
+/**
+ * 根据conf配置校验请求参数
+ * @param conf 配置  
+ * @param param 表单  
+ * @param skipKeys []不必填的字段
+ */
+export function eccReqParamater(conf:object, param, skipKeys?) {
+    skipKeys = skipKeys || [];
+
+    let skipMap = {};
+    skipKeys.forEach(keyName => {
+        skipMap[keyName] = 1;
+    });
+
+    /**校验多余字段 */
+    for (let key in param) {
+        if (!conf[key]) throw new BizError(ERRORENUM.参数错误, `多余${key}字段`);
+    }
+
+    /**校验必填和缺失字段 */
+    for (let key in conf) {
+        let confType = conf[key];
+        let value = param[key];
+        let valueType = typeof value;
+        
+        if ( value == null || value == undefined ) {
+            if (!skipMap[key]) throw new BizError(ERRORENUM.参数错误, `缺失${key}字段`);
+        } else {
+            let isError = false;
+            let errorStr = "";
+            switch(confType) {
+                case 'Number':
+                    if ( confType.toLowerCase() != valueType ) isError = true;
+                    else {
+                        if ((""+param[key]).indexOf('.') > -1) {
+                            param[key] = parseInt(`${param[key] *100}`)/100;
+                        }
+                    }
+                break;
+                case 'String':
+                case 'Boolean':
+                case 'Object':
+                    if ( confType.toLowerCase() != valueType ) isError = true;
+                break;
+                case '[Number]':
+                    if ( !Array.isArray(param[key]) ) isError = true;
+                    for (let i =0; i <  param[key].length; i++) {
+                        let item = param[key][i];
+                        if ( typeof item != 'number' ) {
+                            isError = true;
+                            errorStr = `${key}应是number型数组其中下标${i}是${typeof item}`;
+                        }
+                    }
+                break;
+                case '[Object]':
+                    if ( !Array.isArray(param[key]) ) isError = true;
+                    for (let i =0; i <  param[key].length; i++) {
+                        let item = param[key][i];
+                        if ( typeof item != 'object' ) {
+                            isError = true;
+                            errorStr = `${key}应是object型数组其中下标${i}是${typeof item}`;
+                        }
+                    }
+                break;
+                case '[String]':
+                    if ( !Array.isArray(param[key]) ) isError = true;
+                    for (let i =0; i <  param[key].length; i++) {
+                        let item = param[key][i];
+                        if ( typeof item != 'string' ) {
+                            isError = true;
+                            errorStr = `${key}应是String型数组其中下标${i}是${typeof item}`;
+                        }
+                    }
+                break;
+                // case 'Address':
+                //     /**地址类型 基本数据类型为数组字符串但是要判断层级关系 */
+                //     if ( !Array.isArray(param[key]) ) {
+                //         isError = true;
+                //         errorStr = `${key}应是数组形`;
+                //     }
+                //     if ( param[key].length != 4) {
+                //         isError = true;
+                //         errorStr = `${key}超过特定长度4 目前长度 ${param[key].length}`;
+                //     }
+                //     for (let i =0; i <  param[key].length; i++) {
+                //         let item = param[key][i];
+                //         if ( typeof item != 'string' ) {
+                //             isError = true;
+                //             errorStr = `${key}应是string型数组其中下标${i}是${typeof item}`;
+                //         }
+                //     }
+                //     /** 不符合规则的 */
+                //     let nullIndex = -1;
+                //     for (let i = 0; i < param[key].length; i++) {
+                //         if (nullIndex != -1) {//出现过空 第一次出现后的位置 都不能有值
+                //             if (param[key]) {
+                //                 //做一个特化
+                //                 throw new BizError(ERRORENUM.地址数据不完整, `${key} 下标 ${nullIndex} 为空 `);
+                //             }
+                //         }
+                //         if (nullIndex == -1 && !param[key][i]) {
+                //             /**按顺序第一次赋值 */
+                //             nullIndex = i;
+                //         }
+                //     }
+    
+                // break;
+            }
+            errorStr = isError && errorStr == "" ? `${key}应该是${confType}型 而不是${valueType}`: errorStr;
+            if (isError) throw new BizError(ERRORENUM.参数错误, errorStr);
+        }
+
+    }
+
+    return param;
+}
+
+/**
+ * 校验value是否符合传入的枚举
+ * @param name 被掉用名称 用于输出异常日志
+ * @param key 目标字段  用于输出异常日志
+ * @param enumConf 目标枚举
+ * @param value 目标值
+ * 无返回 有异常直接报错
+ */
+export function eccEnumValue(name:string, key:string, enumConf, value:any) {
+    let eccSuccess = true;
+    if ( typeof value == 'number' ) {
+        if (!enumConf[value] ) eccSuccess = false;
+    } else if (Array.isArray(value)) {
+        value.forEach(item => {
+            if ( !enumConf[item] ) eccSuccess = false;
+        });
+    }
+    
+    if (!eccSuccess) throw new BizError(ERRORENUM.表单校验失败, `${name} 下的 ${key} 字段值为 ${value} 不满足枚举范围`);
+}

src/util/analysisExcel.ts

+const xlsx = require('node-xlsx');
+const path = require('path');
+
+/**
+ *   onceSheetBecomeOfblockData 将excel文件的指定sheet解析成数据块数据
+ * @param fileName 文件名称
+ * @param sheetName 表名称
+ * @returns [ {blockData:数据块(二维数组), blockTitle:"数据标题"}]
+ */
+export function onceSheetBecomeOfblockData(fileName, sheetName) {
+    let {sheetMap} = getExcel( path.join(__dirname.substring(0,__dirname.indexOf("out")), "res", fileName ));
+    // return sheetMap;
+    let thisBlockData = getBlockData(sheetMap[sheetName]);
+    return thisBlockData;
+}
+
+/**
+ * excelBecomeOfBlockData 将excel所有的sheet解析成数据块
+ * @param fileName 文件名称
+ * @returns {"sheetName1":[ {blockData:数据块(二维数组), blockTitle:"数据标题"}], ...}
+ */
+export function excelBecomeOfBlockData(fileName) {
+    let {sheetMap} = getExcel( path.join(__dirname.substring(0,__dirname.indexOf("out")), "res", fileName ));
+    let result = {};
+    for (let sheetName in sheetMap) {
+        result[sheetName] = getBlockData(sheetMap[sheetName]);
+    }
+    return result;
+}
+
+/**
+ *  planaryArrayBecomeOfBlockData  将符合excel规则的sheet二维数组转为 数据块
+ * @param dataList excel解出来的数据
+ * @returns thisBlockData 返回数据块集合 格式：blockList = [ {blockData:数据块(二维数组), blockTitle:"数据标题"}]
+ */
+export function planaryArrayBecomeOfBlockData(planaryArray) {
+    return getBlockData(planaryArray);;
+}
+
+
+//===
+
+/**
+ * getBlockData 数据分块 
+ * @param dataList  解析出来的excel二维数组
+ * @returns 返回数据块集合 格式：blockList = [ {blockData:数据块(二维数组), blockTitle:"数据标题"}]
+ */
+function getBlockData(dataList) {
+    let blockList = [];
+    for (let i = 0; i < 999; i++) {
+        let {blockData, blockTitle, notItem, delDataList} = checkBlock(dataList);
+        if (notItem) break;
+        dataList = delDataList;
+        if (blockTitle) blockList.push({blockData, blockTitle});
+    }
+    return blockList;
+}
+
+function getListFristNotNullItemIndex(list) { //获取起始坐标
+    if (!list.length) return null;
+    for (let i = 0; i < list.length; i++) {
+        if (list[i]) return i;
+    }
+}
+
+
+function getListFirstNullItemIndex(startX, list) { //获取第一个为空的坐标
+    if (!list.length) return null;
+    let checkItem = false;
+    let firstItemIndex = 0;
+    for (let i = startX; i <= list.length; i++) {
+        let item = list[i];
+        if (!checkItem && item) checkItem = true;
+        
+        if (checkItem && !item) {
+            firstItemIndex = i;
+            break;
+        }
+    }
+    return firstItemIndex;
+}
+function listRegionIsNull(list, startX, endX) { //指定区间内数据是否未空
+    let isNull = true;
+    if ( !list.length ) return isNull;
+
+    for (let i = startX; i < endX; i++) {
+        let item = list[i];
+        if (item) {
+            isNull = false;
+            break;
+        }
+    }
+    return isNull;
+}
+
+function thisListNotItem(list) {
+    for (let i = 0; i < list.length; i++) {
+        if (list[i]) return false;
+    }
+    return true
+}
+
+function checkBlock(dataList) {
+    //纵向有效起始点
+    let startY = 0;
+    let startX = 0;
+    let isNotBlockTitle = false; //没有块标题
+    let isLook = false;
+    let endX = 0;//x轴最长结束下标 【包括下标】
+    
+
+    let blockTitle = ''; //标题块名称
+
+    let notItem = true;
+
+    for (let i = 0; i < dataList.length; i++) {
+        let childList = dataList[i] || [];
+
+        if (!thisListNotItem(childList)) {
+            
+            if ( !isLook ) {
+                let thisRoowStartX = getListFristNotNullItemIndex(childList);
+                let thisRoowLastItem = childList[thisRoowStartX + 1];
+                let LastList = dataList[i+1] || [];
+                // let lastRoowStartX = getListFristNotNullItemIndex(LastList);
+                let lastRoowHaveItem = LastList[thisRoowStartX];
+                if ( thisRoowLastItem || (LastList.length && lastRoowHaveItem)  ) {
+                    
+                    if (lastRoowHaveItem && thisRoowLastItem ) {
+                        isNotBlockTitle = true; //不存在标题块
+                        blockTitle = `${thisRoowStartX}_${i}`;
+                        startY = i;
+                        startX = thisRoowStartX;
+                    }
+                    else {
+                        blockTitle = dataList[i][thisRoowStartX];
+                        dataList[i][thisRoowStartX] = null;
+
+                        if ( thisRoowLastItem ) { // 同行存在元素 标题在y轴上
+                            startY = i;
+                            startX = thisRoowStartX + 1;
+                        } else {  // 同行存在元素 标题在x轴上
+                            startY = i + 1;
+                            startX = thisRoowStartX;
+                        }
+                    }
+                    
+                    isLook = true;
+                } else { //只有标题 无内容
+                    console.log(dataList[i][thisRoowStartX]);
+                    dataList[i][thisRoowStartX] = null;
+                }
+                
+            } else {
+                //测量最大连续长度
+                let firstNullX = getListFirstNullItemIndex(startX, childList);
+                if (firstNullX) endX = Math.max(endX, firstNullX-1);
+                break;
+            }
+            notItem = false;
+        }
+    }
+    let endY = 0;//y轴连续下标 【包括下标】
+
+    let yInfoStart = false;
+    let yInfoEnd = false;
+
+    for (let y = startY; y < dataList.length; y++) {
+        //纵向找连续性
+        let thisRoow = dataList[y];
+        let regionIsNull = listRegionIsNull(thisRoow, startX, endX);
+        if (!regionIsNull) {
+            endY = y;
+            if (!yInfoStart) yInfoStart = true;
+        }
+        if (yInfoStart && regionIsNull) yInfoEnd = true;
+        if (yInfoEnd) break;
+    }
+    
+    let blockData = [];
+    for (let y = startY; y <= endY; y++) {
+        let onceList = [];
+        for (let x = startX; x <= endX; x++) {
+            onceList.push(dataList[y][x]);
+            dataList[y][x] = null;
+        }
+        blockData.push(onceList);
+    }
+
+    return {blockData, blockTitle, delDataList:dataList,notItem};
+}
+
+
+
+//获取单个excel文件的数据
+function getExcel(filePath) {
+    const workSheetsFromFile = xlsx.parse(filePath);
+    let sheetMap = {};
+    let sheetList = [];
+
+    for (let i = 0; i < workSheetsFromFile.length; i++) {
+        let sheetInfo = workSheetsFromFile[i];
+        sheetMap[sheetInfo.name] = sheetInfo.data;
+        sheetList.push(sheetInfo);
+    }
+
+    return {sheetMap, sheetList}  
+}
\ No newline at end of file

src/util/bizError.ts

+/**
+ * 异常类
+ * 需要和log4js共同使用
+ */
+
+import { getBizMsg } 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);
+    }
+}

src/util/log.ts

+/**
+ * 日志类
+ * 包括错误日志 普通日志 
+ * 日志存放在根目录的logs内
+ */
+
+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}`);
+}

src/util/myTools.ts

+import moment = require("moment");
+const md5 = require("md5");
+
+/**
+ * 生成工时填报的dateKey
+ * @returns 
+ */
+export function generateDateKey(time?) {
+    if (time) {
+        return moment(time).format("YYYY-MM-DD")+ ' 18:00:00';
+    }
+    return moment().format("YYYY-MM-DD")+ ' 18:00:00'
+}
+
+/**
+ * 生成请假的id
+ * @param userId 
+ * @returns 
+ */
+export function generateAskForLeaveId(userId:number) {
+    return `al${userId}${new Date().valueOf()}${Math.ceil(Math.random() *100)}`
+}
+
+export function getClientTime(time:string) {
+    return moment(time).format("YYYY/MM/DD HH:mm");
+}
+
+export function getDBTime(time?) {
+    if (!time) return moment().format("YYYY-MM-DD HH:mm:ss");
+    return moment(time).format("YYYY-MM-DD HH:mm:ss");
+}
+
+/**
+ * 生成加班填报的id
+ * @param userId 
+ * @returns 
+ */
+export function getOvertimeId(userId:number) {
+    return `ot${userId}${new Date().valueOf()}${Math.ceil(Math.random() *100)}`
+}
+
+
+/**
+ * 获取token
+ * @param loginId 登录id
+ */
+export function getToken(loginId:string) {
+    return md5(`${loginId}${new Date().valueOf()}${Math.ceil(Math.random() *100)}`);
+}
+
+
+/**
+ * 生成工时填报的id
+ * @param userId 
+ * @returns 
+ */
+export function getWorkingLogId(userId:number) {
+    return `wl${userId}${new Date().valueOf()}${Math.ceil(Math.random() *100)}`
+}
\ No newline at end of file

src/util/myXML.ts

+/**
+ * 解析xml
+ */
+
+var xml2js = require("xml2js");
+
+
+/**
+ * 
+ * @param str 需要解析的xml文本
+ * @returns 解析好的对象
+ */
+export function analysisXml(str) {
+    return new Promise( (resolve, reject) => {
+        xml2js.parseString(str, (err, result) => {
+            if (err) return reject(err);
+            return resolve(result);
+        });
+    });
+   
+}
\ No newline at end of file

src/util/piecemeal.ts

+/**
+ * 零碎的通用工具
+ */
+
+import moment = require("moment");
+
+/**
+ * 匹配新旧对象变化
+ * 将newObj 与 oldObj 比对，将newObj中发生变化的key返回
+ * 使用前需要校验对象中的内容
+ * @param newObj 新对象
+ * @param oldObj 旧对象
+ * @returns [key] 发生变化的key
+ */
+export function checkChange(newObj, oldObj) {
+    let changeKeyList = [];
+    for (let newKey in newObj) {
+        if (`${newObj[newKey]}` != `${oldObj[newKey]}`) changeKeyList.push(newKey);
+    }
+    return changeKeyList;
+}
+
+/**
+ * 根据conf截取data中的数据
+ * @param conf 
+ * @param data 
+ * @returns 
+ */
+export function extractData(conf, data, isAdmin) {
+    let result = {};
+    for (let key in conf) {
+        let confInfo = conf[key];
+        if (confInfo.changeDate) {
+            if (isAdmin) result[key] = data[key] ? moment(data[key]).format("YYYY-MM-DD") : '-';
+            else result[key] = data[key] || 0;
+        } else if (confInfo.isAdd && isAdmin) {
+            let addStr = "";
+            data[key].forEach(str => {
+                addStr += str;
+            });
+            result[key] = addStr;
+        }
+        else {
+            result[key] = data[key];
+            if (typeof result[key] == 'string' && !result[key]) result[key] = '';
+        }
+    }
+    return result;
+}
+
+
+/**
+ * 校验数据对象是否有空
+ * @param data 
+ * @param sensitive  敏感校验  true时  0 和 ""会校验失败  false时 校验成功
+ * @returns true/false true = 有空值   false=无空值
+ */
+export function checkDataHaveNull(data:object, sensitive:boolean) {
+    if (Array.isArray(data)) return data.length == 0;
+    if (Object.keys(data).length == 0) return true;
+    
+    let success = false;
+    for (let key in data) {
+        if (data[key] == null || data[key] == undefined) success = true;
+        if (sensitive) {
+            if (data[key] === 0 || data[key] === "" ) success = true;
+        }
+    }
+    return success;
+}
+
+
+/**
+ * 将枚举值转换成对应的枚举名(key)
+ * @param enumConf 目标枚举
+ * @param value 目标值
+ * @returns string  返回字符串 如果传入多个枚举值，就拼接字符串
+ */
+export function changeEnumValue(enumConf, value:any) {
+    if (!value) return '';
+    if ( typeof value == 'number' ) {
+        return enumConf[value];
+    }
+    let str = "";
+    value.forEach((item, index) => {
+        str += enumConf[item];
+        if (index == value.length-1) str+="";
+        else str += ","
+    });
+
+    return str;
+}

src/util/request.ts

+/**
+ * 请求工具
+ */
+
+import * as request from 'request';
+import { BizError } from './bizError';
+
+/**
+ * 请求接口（get）
+ * @param url 路由
+ * @param query 请求参数
+ * @param headers 请求头
+ * @returns 
+ */
+export function get(url:string, query?, headers?) {
+    if (!url || (url.search(/http:/) && url.search(/https:/)) ) throw new BizError(!url ? "请求地址为空" : "请求地址错误");
+    return new Promise((resolve, reject)=>{
+        let paramater:any = { url, json:true };
+        if (query) paramater.qs = query;
+        if (headers) paramater.headers = headers;
+        request.get(paramater, function (err, r, body) {
+            resolve(body);
+        });
+    })
+}
+
+
+export function post(url, body, headers) {
+    if (!url || (url.search(/http:/) && url.search(/https:/)) ) throw new BizError(!url ? "请求地址为空" : "请求地址错误");
+    let header = {"content-type": "application/json"};  
+    return new Promise((resolve, reject)=>{
+        request({
+            url: url,
+            method: "POST",
+            json: true,
+            headers: Object.assign(header, headers),
+            body: body
+        }, function(error, response, body) {
+            resolve(body);
+        });
+    })
+}
+
+export function postForm(url, body, headers) {
+    if (!url || (url.search(/http:/) && url.search(/https:/)) ) throw new BizError(!url ? "请求地址为空" : "请求地址错误");
+    return new Promise((resolve, reject)=>{
+        request({
+            url: url,
+            method: "POST",
+            json: true,
+            form:body
+        }, function(error, response, res) {
+            resolve(res);
+        });
+    })
+}

tsconfig.json

+{
+  "compilerOptions": {
+    "module": "commonjs",
+    "target": "es2017",
+    "sourceMap": true,
+    "rootDir":"./src",
+    "outDir":"./out"
+  },
+  "exclude": [
+    "node_modules"
+  ]
+} 
\ No newline at end of file