Skip to content

Z
zjxcxServer
Commit 70941204 by lixinming
Options

no message

parent b6cbafba
Showing with 324 additions and 679 deletions
src/biz/enterprise/enterprise.ts
...@@ -5,32 +5,22 @@ ...@@ -5,32 +5,22 @@
* *
*/ */
import { MoveInEnterpriseParamConfig, RegisterEnterpriseParamConfig } from "../../config/checkParamConfig";
import { ERRORENUM } from "../../config/errorEnum"; import { ERRORENUM } from "../../config/errorEnum";
import { createEnterprise, findEnterpriseByUscc } from "../../data/enterprise/enterprise"; import { createEnterprise, findEnterpriseByUscc } from "../../data/enterprise/enterprise";
import { BizError } from "../../util/bizError"; import { BizError } from "../../util/bizError";
import { getTaskId } from "../../util/tools" import { checkChange, checkParamater, getTaskId } from "../../util/tools"
/** /**
* 新注册企业 * 新注册企业
* @param uscc 孵化器统一信用代码 * @param uscc 孵化器统一信用代码
* @param param 表单参数 * @param param 表单参数
* @returns {isSuccess:true/false}
*/ */
export async function registerEnterprise(uscc:string, param) { export async function registerEnterprise(uscc:string, param) {
const TaskId = getTaskId(uscc); const TaskId = getTaskId(uscc);
const TypeConf = { checkParamater("新注册企业", RegisterEnterpriseParamConfig, param);
name:"String", //企业名称
uscc:"String", //统一信用代码
industry:"[Number]",//领域
logonTime:"Number",//注册时间
firstIncubationTime:"Number",//首次入孵时间
isNaturalPersonHolding:"Boolean",//是否自然人控股企业
logonAdd:"String",//注册地址
operatingAdd:"String",//经营地址
leasedArea:"Number",//租赁面积（平方米）
};
checkParamater(param, TypeConf);
let dataBaseInfo = await findEnterpriseByUscc(param.uscc); let dataBaseInfo = await findEnterpriseByUscc(param.uscc);
if ( dataBaseInfo&& dataBaseInfo.uscc) throw new BizError(ERRORENUM.该企业已存在, `${param.uscc}已经在库中存在`); if ( dataBaseInfo&& dataBaseInfo.uscc) throw new BizError(ERRORENUM.该企业已存在, `${param.uscc}已经在库中存在`);
...@@ -40,29 +30,19 @@ export async function registerEnterprise(uscc:string, param) { ...@@ -40,29 +30,19 @@ export async function registerEnterprise(uscc:string, param) {
return {isSuccess:true}; return {isSuccess:true};
} }
/** /**
* 新注册企业表单修改 * 新注册企业表单修改
* @param uscc 孵化器统一信用代码 * @param uscc 孵化器统一信用代码
* @param param 表单参数 * @param param 表单参数
* @returns {isSuccess:true/false}
*/ */
export async function updateRegisterEnterprise(uscc:string, param) { export async function updateRegisterEnterprise(uscc:string, param) {
const TypeConf = { checkParamater("新注册企业表单修改", RegisterEnterpriseParamConfig, param);
name:"String", //企业名称
uscc:"String", //统一信用代码
industry:"[Number]",//领域
logonTime:"Number",//注册时间
firstIncubationTime:"Number",//首次入孵时间
isNaturalPersonHolding:"Boolean",//是否自然人控股企业
logonAdd:"String",//注册地址
operatingAdd:"String",//经营地址
leasedArea:"Number",//租赁面积（平方米）
};
checkParamater(param, TypeConf);
let dataBaseInfo = await findEnterpriseByUscc(param.uscc); let dataBaseInfo = await findEnterpriseByUscc(param.uscc);
if (!dataBaseInfo || !dataBaseInfo.uscc) throw new BizError(ERRORENUM.未找到数据, `库中不存在${param.uscc}这个企业`); if (!dataBaseInfo || !dataBaseInfo.uscc) throw new BizError(ERRORENUM.未找到数据, `库中不存在${param.uscc}这个企业`);
let changeList = checkChange(param, dataBaseInfo); let changeList = checkChange(param, dataBaseInfo);
if ( !changeList.length ) throw new BizError(ERRORENUM.数据无更新, `${param.uscc}数据无更新`); if ( !changeList.length ) throw new BizError(ERRORENUM.数据无更新, `${param.uscc}数据无更新`);
...@@ -76,29 +56,15 @@ export async function updateRegisterEnterprise(uscc:string, param) { ...@@ -76,29 +56,15 @@ export async function updateRegisterEnterprise(uscc:string, param) {
} }
/** /**
* 迁入企业登记 * 迁入企业登记
* @param uscc * @param uscc 孵化器统一信用代码
* @param param * @param param 表单参数
* @returns {isSuccess:true/false}
*/ */
export async function moveInEnterprise(uscc:string, param) { export async function moveInEnterprise(uscc:string, param) {
const TaskId = getTaskId(uscc); const TaskId = getTaskId(uscc);
const TypeConf = { checkParamater("迁入企业登记", MoveInEnterpriseParamConfig, param);
name:"String", //企业名称
uscc:"String", //统一信用代码
industry:"[Number]",//领域
logonTime:"Number",//注册时间
firstIncubationTime:"Number",//首次入孵时间
timeOfImmigration:"Number",//迁入时间
isNaturalPersonHolding:"Boolean",//是否自然人控股企业
oldLogonAdd:"String",//迁入前注册地址
logonAdd:"String",//注册地址
operatingAdd:"String",//经营地址
leasedArea:"Number",//租赁面积（平方米）
};
checkParamater(param, TypeConf);
let dataBaseInfo = await findEnterpriseByUscc(param.uscc); let dataBaseInfo = await findEnterpriseByUscc(param.uscc);
if ( dataBaseInfo&& dataBaseInfo.uscc) throw new BizError(ERRORENUM.该企业已存在, `${param.uscc}已经在库中存在`); if ( dataBaseInfo&& dataBaseInfo.uscc) throw new BizError(ERRORENUM.该企业已存在, `${param.uscc}已经在库中存在`);
...@@ -109,27 +75,14 @@ export async function moveInEnterprise(uscc:string, param) { ...@@ -109,27 +75,14 @@ export async function moveInEnterprise(uscc:string, param) {
} }
/** /**
* 修改迁入企业登记信息 * 修改迁入企业登记信息
* @param uscc * @param uscc 孵化器统一信用代码
* @param param * @param param 表单参数
* @returns {isSuccess:true/false}
*/ */
export async function updateMoveInEnterprise(uscc:string, param) { export async function updateMoveInEnterprise(uscc:string, param) {
const TypeConf = { checkParamater("修改迁入企业登记信息", MoveInEnterpriseParamConfig, param);
name:"String", //企业名称
uscc:"String", //统一信用代码
industry:"[Number]",//领域
logonTime:"Number",//注册时间
firstIncubationTime:"Number",//首次入孵时间
timeOfImmigration:"Number",//迁入时间
isNaturalPersonHolding:"Boolean",//是否自然人控股企业
oldLogonAdd:"String",//迁入前注册地址
logonAdd:"String",//注册地址
operatingAdd:"String",//经营地址
leasedArea:"Number",//租赁面积（平方米）
};
checkParamater(param, TypeConf);
let dataBaseInfo = await findEnterpriseByUscc(param.uscc); let dataBaseInfo = await findEnterpriseByUscc(param.uscc);
if (!dataBaseInfo || !dataBaseInfo.uscc) throw new BizError(ERRORENUM.未找到数据, `库中不存在${param.uscc}这个企业`); if (!dataBaseInfo || !dataBaseInfo.uscc) throw new BizError(ERRORENUM.未找到数据, `库中不存在${param.uscc}这个企业`);
...@@ -148,45 +101,3 @@ export async function updateMoveInEnterprise(uscc:string, param) { ...@@ -148,45 +101,3 @@ export async function updateMoveInEnterprise(uscc:string, param) {
} }
/**
* 校验参数
* @param param
*/
function checkParamater(param, keyTypeConf) {
for (let key in keyTypeConf ) {
if ( !param[key] ) throw new BizError(ERRORENUM.表单校验失败, '孵化器基础数据更新', `缺失${key}字段`);
let type = typeof param[key];
switch(keyTypeConf[key]) {
case 'Number':
if ( type != 'number' ) throw new BizError(ERRORENUM.表单校验失败, '孵化器基础数据更新', `${key}应是number型 而不是${type}`);
break;
case 'String':
if ( type != 'string' ) throw new BizError(ERRORENUM.表单校验失败, '孵化器基础数据更新', `${key}应是string型 而不是${type}`);
break;
case 'Boolean':
if ( type != 'boolean' ) throw new BizError(ERRORENUM.表单校验失败, '孵化器基础数据更新', `${key}应是boolean型 而不是${type}`);
break;
case '[Number]':
if ( !Array.isArray(param[key]) ) throw new BizError(ERRORENUM.表单校验失败, '孵化器基础数据更新', `${key}应是数组型 而不是${type}`);
for (let i =0; i < param[key].length; i++) {
let item = param[key][i];
if ( typeof item != 'number' ) {
throw new BizError(ERRORENUM.表单校验失败, '孵化器基础数据更新', `${key}应是number型数组其中下标${i}是${typeof item}`);
}
}
break;
}
}
for (let key in param) {
if (!keyTypeConf[key]) throw new BizError(ERRORENUM.表单校验失败, '孵化器基础数据更新', `多余${key}字段`);
}
}
function checkChange(newObj, oldObj) {
let changeKeyList = [];
for (let newKey in newObj) {
if (`${newObj[newKey]}` != `${oldObj[newKey]}`) changeKeyList.push(newKey);
}
return changeKeyList;
}
src/biz/enterprise/financing.ts
...@@ -5,66 +5,47 @@ ...@@ -5,66 +5,47 @@
* *
*/ */
import { FinancingParamConfig } from "../../config/checkParamConfig";
import { ERRORENUM } from "../../config/errorEnum"; import { ERRORENUM } from "../../config/errorEnum";
import { createFinancing, findFinancingInfoByTaskIdAndSucc } from "../../data/enterprise/financing"; import { createFinancing, findFinancingInfoByTaskIdAndSucc } from "../../data/enterprise/financing";
import { BizError } from "../../util/bizError"; import { BizError } from "../../util/bizError";
import { getTaskId } from "../../util/tools"; import { checkChange, checkParamater, getTaskId } from "../../util/tools";
/**
* 创建企业融资信息
* @param uscc 孵化器统一信用代码
* @param param 表单配置
* @returns {isSuccess:true/false}
*/
export async function createFinancingInfo(uscc, param) { export async function createFinancingInfo(uscc, param) {
const TaskId = getTaskId(uscc); const TaskId = getTaskId(uscc);
const TypeConf = {
uscc:"String", //统一信用代码 冗余字段 checkParamater("录入企业融资信息", FinancingParamConfig, param);
name:"String",//企业名称
taskId:"String", //任务id
logonAdd:"String",//注册地址
operatingAdd:"String",//经营地址
financingTime:"Number",//获得融资时间
financingAmount:"Number",//融资金额(万元)
investmentInstitutionsName:"String",//投资机构名称
timeToObtainInvestment:"Number",//获得投资时间
fuHuaQiInvestment:"Boolean", //孵化器是否投资
fuHuaQiInvestmentAmount:"Number",//孵化器投资金额(万元)
fuHuaQiInvestmentStyle:"Number",//孵化器投资方式
draftLock:"Boolean", //草稿锁，true为提交之后，false为草稿
createTime:"Number",//录入时间
};
checkParamater(param, TypeConf);
let dataBaseInfo = await findFinancingInfoByTaskIdAndSucc(TaskId, param.uscc); let dataBaseInfo = await findFinancingInfoByTaskIdAndSucc(TaskId, param.uscc);
if ( dataBaseInfo&& dataBaseInfo.uscc) throw new BizError(ERRORENUM.该企业已存在, `${param.uscc}的融资信息已经存在`); if ( dataBaseInfo&& dataBaseInfo.uscc) throw new BizError(ERRORENUM.该企业当月数据已存在, `${param.uscc}的融资信息已经存在`);
await createFinancing(uscc, TaskId, param); await createFinancing(uscc, TaskId, param);
return {isSuccess:true}; return {isSuccess:true};
} }
/**
* 更新融资企业信息
* @param uscc 孵化器统一信用代码
* @param param 表单配置
* @returns {isSuccess:true/false}
*/
export async function updateFinancingInfo(uscc, param) { export async function updateFinancingInfo(uscc, param) {
const TaskId = getTaskId(uscc); const TaskId = getTaskId(uscc);
const TypeConf = {
uscc:"String", //统一信用代码 冗余字段 checkParamater("录入企业融资信息", FinancingParamConfig, param);
name:"String",//企业名称
taskId:"String", //任务id
logonAdd:"String",//注册地址
operatingAdd:"String",//经营地址
financingTime:"Number",//获得融资时间
financingAmount:"Number",//融资金额(万元)
investmentInstitutionsName:"String",//投资机构名称
timeToObtainInvestment:"Number",//获得投资时间
fuHuaQiInvestment:"Boolean", //孵化器是否投资
fuHuaQiInvestmentAmount:"Number",//孵化器投资金额(万元)
fuHuaQiInvestmentStyle:"Number",//孵化器投资方式
draftLock:"Boolean", //草稿锁，true为提交之后，false为草稿
createTime:"Number",//录入时间
};
checkParamater(param, TypeConf);
let dataBaseInfo = await findFinancingInfoByTaskIdAndSucc(TaskId, param.uscc); let dataBaseInfo = await findFinancingInfoByTaskIdAndSucc(TaskId, param.uscc);
let changeList = checkChange(param, dataBaseInfo);
if (!dataBaseInfo || !dataBaseInfo.uscc) throw new BizError(ERRORENUM.未找到数据, `库中不存在${TaskId}的任务`); if (!dataBaseInfo || !dataBaseInfo.uscc) throw new BizError(ERRORENUM.未找到数据, `库中不存在${TaskId}的任务`);
let changeList = checkChange(param, dataBaseInfo);
if ( !changeList.length ) throw new BizError(ERRORENUM.数据无更新, `${param.uscc}数据无更新`); if ( !changeList.length ) throw new BizError(ERRORENUM.数据无更新, `${param.uscc}数据无更新`);
changeList.forEach(key => { changeList.forEach(key => {
...@@ -75,46 +56,3 @@ export async function updateFinancingInfo(uscc, param) { ...@@ -75,46 +56,3 @@ export async function updateFinancingInfo(uscc, param) {
return {isSuccess:true}; return {isSuccess:true};
} }
/**
* 校验参数
* @param param
*/
function checkParamater(param, keyTypeConf) {
for (let key in keyTypeConf ) {
if ( !param[key] ) throw new BizError(ERRORENUM.表单校验失败, '孵化器基础数据更新', `缺失${key}字段`);
let type = typeof param[key];
switch(keyTypeConf[key]) {
case 'Number':
if ( type != 'number' ) throw new BizError(ERRORENUM.表单校验失败, '孵化器基础数据更新', `${key}应是number型 而不是${type}`);
break;
case 'String':
if ( type != 'string' ) throw new BizError(ERRORENUM.表单校验失败, '孵化器基础数据更新', `${key}应是string型 而不是${type}`);
break;
case 'Boolean':
if ( type != 'boolean' ) throw new BizError(ERRORENUM.表单校验失败, '孵化器基础数据更新', `${key}应是boolean型 而不是${type}`);
break;
case '[Number]':
if ( !Array.isArray(param[key]) ) throw new BizError(ERRORENUM.表单校验失败, '孵化器基础数据更新', `${key}应是数组型 而不是${type}`);
for (let i =0; i < param[key].length; i++) {
let item = param[key][i];
if ( typeof item != 'number' ) {
throw new BizError(ERRORENUM.表单校验失败, '孵化器基础数据更新', `${key}应是number型数组其中下标${i}是${typeof item}`);
}
}
break;
}
}
for (let key in param) {
if (!keyTypeConf[key]) throw new BizError(ERRORENUM.表单校验失败, '孵化器基础数据更新', `多余${key}字段`);
}
}
function checkChange(newObj, oldObj) {
let changeKeyList = [];
for (let newKey in newObj) {
if (`${newObj[newKey]}` != `${oldObj[newKey]}`) changeKeyList.push(newKey);
}
return changeKeyList;
}
src/biz/fuHuqQi/task.ts
...@@ -9,7 +9,7 @@ import { TASKTYPEENUM } from "../../config/enum"; ...@@ -9,7 +9,7 @@ import { TASKTYPEENUM } from "../../config/enum";
import { ERRORENUM } from "../../config/errorEnum"; import { ERRORENUM } from "../../config/errorEnum";
import { findEnterpriseListByTaskId, updateEnterpriseDraftLock } from "../../data/enterprise/enterprise"; import { findEnterpriseListByTaskId, updateEnterpriseDraftLock } from "../../data/enterprise/enterprise";
import { findFinancingListByTaskId, updateFinancingDraftLock } from "../../data/enterprise/financing"; import { findFinancingListByTaskId, updateFinancingDraftLock } from "../../data/enterprise/financing";
import { findmonthTableByTaskId, findmonthTableListByTaskId } from "../../data/fuHuaQi/monthTable"; import { findmonthTableListByTaskId } from "../../data/fuHuaQi/monthTable";
import { createTaskData, findFuHuaQiTaskByKeyAndUscc } from "../../data/fuHuaQi/task"; import { createTaskData, findFuHuaQiTaskByKeyAndUscc } from "../../data/fuHuaQi/task";
import { BizError } from "../../util/bizError"; import { BizError } from "../../util/bizError";
import { getTaskId, getTimeKey } from "../../util/tools"; import { getTaskId, getTimeKey } from "../../util/tools";
...@@ -18,12 +18,9 @@ import { getTaskId, getTimeKey } from "../../util/tools"; ...@@ -18,12 +18,9 @@ import { getTaskId, getTimeKey } from "../../util/tools";
/** /**
* 获取孵化器的任务列表 * 获取孵化器的任务列表
* @param uscc 孵化器的信用标识 * @param uscc 孵化器的信用标识
* @returns * @returns [{type:1, title:'', enterpriseList:[] }]
*/ */
export async function fuHuaQiTaskList(uscc:string) { export async function fuHuaQiTaskList(uscc:string) {
/**
* 返回格式 [{type:1, title:'', enterpriseList:[] }]
*/
let result = []; let result = [];
const TimeKey = getTimeKey(); const TimeKey = getTimeKey();
...@@ -58,10 +55,13 @@ export async function fuHuaQiTaskList(uscc:string) { ...@@ -58,10 +55,13 @@ export async function fuHuaQiTaskList(uscc:string) {
return result; return result;
} }
/** /**
* 提交任务 * 提交任务
* @param uscc 孵化器的信用标识 * @param uscc 孵化器的信用标识
* @param taskType 任务类型 * @param taskType 任务类型
* @returns {isSuccess:true/false}
*/ */
export async function checkTask(uscc:string, taskType:number) { export async function checkTask(uscc:string, taskType:number) {
const TimeKey = getTimeKey(); const TimeKey = getTimeKey();
...@@ -73,8 +73,8 @@ export async function checkTask(uscc:string, taskType:number) { ...@@ -73,8 +73,8 @@ export async function checkTask(uscc:string, taskType:number) {
switch (taskType) { switch (taskType) {
case TASKTYPEENUM.孵化器月度填报: case TASKTYPEENUM.孵化器月度填报:
let tableInfo = await findmonthTableListByTaskId(TaskId); let tableInfo = await findmonthTableListByTaskId(TaskId);
if (!tableInfo) throw new BizError();//todo 没有做弹框 if (!tableInfo) throw new BizError(ERRORENUM.该报表需要填写本月内容后提交, uscc, taskType);
if (tableInfo.draftLock ) throw new BizError(ERRORENUM.不能重复提交任务, uscc, taskType, 'lock = true'); if ( tableInfo.draftLock ) throw new BizError(ERRORENUM.不能重复提交任务, uscc, taskType, 'lock = true');
tableInfo.draftLock = true; tableInfo.draftLock = true;
await tableInfo.save(); await tableInfo.save();
break; break;
......
src/config/checkParamConfig.ts
...@@ -24,5 +24,58 @@ export const BaseParamUpdateConfig = { ...@@ -24,5 +24,58 @@ export const BaseParamUpdateConfig = {
personInChargeAdd:"String", personInChargeAdd:"String",
siteAcreage:"Number", siteAcreage:"Number",
leasePrice:"Number" leasePrice:"Number"
} };
/**
* 新注册企业的表单配置
*/
export const RegisterEnterpriseParamConfig = {
name:"String", //企业名称
uscc:"String", //统一信用代码
industry:"[Number]",//领域
logonTime:"Number",//注册时间
firstIncubationTime:"Number",//首次入孵时间
isNaturalPersonHolding:"Boolean",//是否自然人控股企业
logonAdd:"String",//注册地址
operatingAdd:"String",//经营地址
leasedArea:"Number",//租赁面积（平方米）
};
/**
* 迁入企业登记表单配置
*/
export const MoveInEnterpriseParamConfig = {
name:"String", //企业名称
uscc:"String", //统一信用代码
industry:"[Number]",//领域
logonTime:"Number",//注册时间
firstIncubationTime:"Number",//首次入孵时间
timeOfImmigration:"Number",//迁入时间
isNaturalPersonHolding:"Boolean",//是否自然人控股企业
oldLogonAdd:"String",//迁入前注册地址
logonAdd:"String",//注册地址
operatingAdd:"String",//经营地址
leasedArea:"Number",//租赁面积（平方米）
};
/**
* 融资企业登记表单配置
*/
export const FinancingParamConfig = {
uscc:"String", //统一信用代码
name:"String",//企业名称
taskId:"String", //任务id
logonAdd:"String",//注册地址
operatingAdd:"String",//经营地址
financingTime:"Number",//获得融资时间
financingAmount:"Number",//融资金额(万元)
investmentInstitutionsName:"String",//投资机构名称
timeToObtainInvestment:"Number",//获得投资时间
fuHuaQiInvestment:"Boolean", //孵化器是否投资
fuHuaQiInvestmentAmount:"Number",//孵化器投资金额(万元)
fuHuaQiInvestmentStyle:"Number",//孵化器投资方式
};
src/config/enum.ts
/**
* 孵化器任务填报类型
*/
export enum TASKTYPEENUM { export enum TASKTYPEENUM {
孵化器月度填报=1, 孵化器月度填报=1,
融资企业填报, 融资企业填报,
新注册或迁入企业登记 新注册或迁入企业登记
} }
/**
* 孵化器级别
*/
export enum FUHUAQILV {
国家级 = 1,
市级,
区级
}
/**
* 孵化器机构性质
*/
export enum INSTITUTIONALNATURE {
国资为主 = 1,
民资为主,
外资为主
}
/**
* 孵化器孵化领域
*/
export enum FUHUAINDUSTRY{
综合型 = 1,
信息技术,
生物医药,
集成电路,
人工智能,
文化创意
}
/**
* 行业领域
*/
export enum INDUSTRY{
集成电路 =1,
生物医药,
人工智能,
新材料及新能源,
信息技术,
文化创意,
其他
}
src/config/errorEnum.ts
...@@ -7,6 +7,8 @@ export enum ERRORENUM { ...@@ -7,6 +7,8 @@ export enum ERRORENUM {
该企业已存在, 该企业已存在,
数据无更新, 数据无更新,
该孵化器月度填报已存在, 该孵化器月度填报已存在,
该企业当月数据已存在,
该报表需要填写本月内容后提交
} }
let bizErrorMsgMap = {}; let bizErrorMsgMap = {};
......
src/middleware/encryptionReturn.ts deleted 100644 → 0
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
src/middleware/fromParam.ts
var formidable = require("formidable"); var formidable = require("formidable");
const path = require('path');
export async function parseFormParam(req, res, next) { export async function parseFormParam(req, res, next) {
    var form = new formidable.IncomingForm(); var form = new formidable.IncomingForm();
    form.parse(req, (err, fields, files)=>{ form.uploadDir = path.join(__dirname.substring(0,__dirname.indexOf("out")), 'files');
        if (err) { form.parse(req, (err, fields, files)=>{
            next(err) if (err) {
        } next(err)
        else {
            req.fields = fields;
            req.files = files;
            next();
        }
    })
} }
else {
req.fields = fields;
req.files = files;
next();
}
})
}
\ No newline at end of file
src/middleware/httpErrorHandler.ts 0 → 100644
/**
* 中间件 错误返回
* @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 (err.message == "身份验证失败" || err.message == "身份验证过期") {
res.success({success:false, msg:err.message, code:501});
next();
}
else {
res.success({success:false, msg:err.message, code:500});
next();
}
}
}
\ No newline at end of file
src/middleware/sign.ts deleted 100644 → 0
import { BizError } from "../util/bizError";
const LRU = require("lru-cache")
, cacheOptions = { max: 500000
, maxAge: 1000 * 60 * 10 }
, cache = LRU(cacheOptions);
export async function checkSign(req, res, next) {
let signKey = "12345678asd!@#%DFFGa";
let userId = req.headers.userid;
let playerId = req.headers.playerid;
let token = req.headers.token;
let timeStamp = req.headers.timestamp;
let platform = req.headers.platform;
if (req.path != '/api/system/servertime' && req.path.indexOf('admin') < 0 && req.headers.sign != 'xxakdfwosaddf!@3sadfhDAse') {
let now = Date.now();
if (Math.abs(now - timeStamp) > 120000) {
console.log(req.path, new Date(now), "timeStamp", timeStamp);
return next(new BizError('timeStamp error time difference error'))
}
let sign = getSign([signKey, userId, playerId, token, timeStamp, platform, req.path, signKey]);
let cacheSign = cache.get(sign);
if (cacheSign) {
if (cacheSign > 5) return next(new BizError("sign error repetitive sign"));
else {
cacheSign++;
cache.set(sign,cacheSign);
}
}
else {
cache.set(sign,1);
}
if (sign != req.headers.sign) {
console.log(req.path, JSON.stringify(req.headers));
next(new BizError("sign error"))
}
}
next();
}
function getSign(...params) {
let s = "";
for (let i = 0; i < params.length; i++) {
if (!params[i]) continue;
s += params[i];
}
return new m().hex_md5(s);
}
export class m {
public constructor() {
}
private hexcase = 0; /* hex output format. 0 - lowercase; 1 - uppercase */
private b64pad = ""; /* base-64 pad character. "=" for strict RFC compliance */
/*
* These are the privates you'll usually want to call
* They take string arguments and return either hex or base-64 encoded strings
*/
public hex_md5(s) { return this.rstr2hex(this.rstr_md5(this.str2rstr_utf8(s))); }//这个函数就行了，
public b64_md5(s) { return this.rstr2b64(this.rstr_md5(this.str2rstr_utf8(s))); }
public any_md5(s,e) { return this.rstr2any(this.rstr_md5(this.str2rstr_utf8(s)),e); }
public hex_hmac_md5(k,d)
{ return this.rstr2hex(this.rstr_hmac_md5(this.str2rstr_utf8(k),this.str2rstr_utf8(d))); }
private b64_hmac_md5(k,d)
{ return this.rstr2b64(this.rstr_hmac_md5(this.str2rstr_utf8(k),this.str2rstr_utf8(d))); }
private any_hmac_md5(k,d,e)
{ return this.rstr2any(this.rstr_hmac_md5(this.str2rstr_utf8(k),this.str2rstr_utf8(d)),e); }
/*
* Perform a simple self-test to see if the VM is working
*/
public md5_vm_test() {
return this.hex_md5("abc").toLowerCase() == "900150983cd24fb0d6963f7d28e17f72";
}
/*
* Calculate the MD5 of a raw string
*/
public rstr_md5(s) {
return this.binl2rstr(this.binl_md5(this.rstr2binl(s),s.length * 8));
}
/*
* Calculate the HMAC-MD5, of a key and some data (raw strings)
*/
public rstr_hmac_md5(key,data) {
var bkey = this.rstr2binl(key);
if(bkey.length > 16) bkey = this.binl_md5(bkey,key.length * 8);
var ipad = Array(16),opad = Array(16);
for(var i = 0;i < 16;i++) {
ipad[i] = bkey[i] ^ 0x36363636;
opad[i] = bkey[i] ^ 0x5C5C5C5C;
}
var hash = this.binl_md5(ipad.concat(this.rstr2binl(data)),512 + data.length * 8);
return this.binl2rstr(this.binl_md5(opad.concat(hash),512 + 128));
}
/*
* Convert a raw string to a hex string
*/
public rstr2hex(input) {
try { this.hexcase } catch(e) { this.hexcase = 0; }
var hex_tab = this.hexcase ? "0123456789ABCDEF" : "0123456789abcdef";
var output = "";
var x;
for(var i = 0;i < input.length;i++) {
x = input.charCodeAt(i);
output += hex_tab.charAt((x >>> 4) & 0x0F)
+ hex_tab.charAt(x & 0x0F);
}
return output;
}
/*
* Convert a raw string to a base-64 string
*/
public rstr2b64(input) {
try { this.b64pad } catch(e) { this.b64pad = ''; }
var tab = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/";
var output = "";
var len = input.length;
for(var i = 0;i < len;i += 3) {
var triplet = (input.charCodeAt(i) << 16)
| (i + 1 < len ? input.charCodeAt(i + 1) << 8 : 0)
| (i + 2 < len ? input.charCodeAt(i + 2) : 0);
for(var j = 0;j < 4;j++) {
if(i * 8 + j * 6 > input.length * 8) output += this.b64pad;
else output += tab.charAt((triplet >>> 6 * (3 - j)) & 0x3F);
}
}
return output;
}
/*
* Convert a raw string to an arbitrary string encoding
*/
public rstr2any(input,encoding) {
var divisor = encoding.length;
var i,j,q,x,quotient;
/* Convert to an array of 16-bit big-endian values, forming the dividend */
var dividend = Array(Math.ceil(input.length / 2));
for(i = 0;i < dividend.length;i++) {
dividend[i] = (input.charCodeAt(i * 2) << 8) | input.charCodeAt(i * 2 + 1);
}
/*
* Repeatedly perform a long division. The binary array forms the dividend,
* the length of the encoding is the divisor. Once computed, the quotient
* forms the dividend for the next step. All remainders are stored for later
* use.
*/
var full_length = Math.ceil(input.length * 8 /
(Math.log(encoding.length) / Math.log(2)));
var remainders = Array(full_length);
for(j = 0;j < full_length;j++) {
quotient = Array();
x = 0;
for(i = 0;i < dividend.length;i++) {
x = (x << 16) + dividend[i];
q = Math.floor(x / divisor);
x -= q * divisor;
if(quotient.length > 0 || q > 0)
quotient[quotient.length] = q;
}
remainders[j] = x;
dividend = quotient;
}
/* Convert the remainders to the output string */
var output = "";
for(i = remainders.length - 1;i >= 0;i--)
output += encoding.charAt(remainders[i]);
return output;
}
/*
* Encode a string as utf-8.
* For efficiency, this assumes the input is valid utf-16.
*/
public str2rstr_utf8(input) {
var output = "";
var i = -1;
var x,y;
while(++i < input.length) {
/* Decode utf-16 surrogate pairs */
x = input.charCodeAt(i);
y = i + 1 < input.length ? input.charCodeAt(i + 1) : 0;
if(0xD800 <= x && x <= 0xDBFF && 0xDC00 <= y && y <= 0xDFFF) {
x = 0x10000 + ((x & 0x03FF) << 10) + (y & 0x03FF);
i++;
}
/* Encode output as utf-8 */
if(x <= 0x7F)
output += String.fromCharCode(x);
else if(x <= 0x7FF)
output += String.fromCharCode(0xC0 | ((x >>> 6) & 0x1F),
0x80 | (x & 0x3F));
else if(x <= 0xFFFF)
output += String.fromCharCode(0xE0 | ((x >>> 12) & 0x0F),
0x80 | ((x >>> 6) & 0x3F),
0x80 | (x & 0x3F));
else if(x <= 0x1FFFFF)
output += String.fromCharCode(0xF0 | ((x >>> 18) & 0x07),
0x80 | ((x >>> 12) & 0x3F),
0x80 | ((x >>> 6) & 0x3F),
0x80 | (x & 0x3F));
}
return output;
}
/*
* Encode a string as utf-16
*/
public str2rstr_utf16le(input) {
var output = "";
for(var i = 0;i < input.length;i++)
output += String.fromCharCode(input.charCodeAt(i) & 0xFF,
(input.charCodeAt(i) >>> 8) & 0xFF);
return output;
}
public str2rstr_utf16be(input) {
var output = "";
for(var i = 0;i < input.length;i++)
output += String.fromCharCode((input.charCodeAt(i) >>> 8) & 0xFF,
input.charCodeAt(i) & 0xFF);
return output;
}
/*
* Convert a raw string to an array of little-endian words
* Characters >255 have their high-byte silently ignored.
*/
public rstr2binl(input) {
var output = Array(input.length >> 2);
for(var i = 0;i < output.length;i++)
output[i] = 0;
for(var i = 0;i < input.length * 8;i += 8)
output[i >> 5] |= (input.charCodeAt(i / 8) & 0xFF) << (i % 32);
return output;
}
/*
* Convert an array of little-endian words to a string
*/
public binl2rstr(input) {
var output = "";
for(var i = 0;i < input.length * 32;i += 8)
output += String.fromCharCode((input[i >> 5] >>> (i % 32)) & 0xFF);
return output;
}
/*
* Calculate the MD5 of an array of little-endian words, and a bit length.
*/
public binl_md5(x,len) {
/* append padding */
x[len >> 5] |= 0x80 << ((len) % 32);
x[(((len + 64) >>> 9) << 4) + 14] = len;
var a = 1732584193;
var b = -271733879;
var c = -1732584194;
var d = 271733878;
for(var i = 0;i < x.length;i += 16) {
var olda = a;
var oldb = b;
var oldc = c;
var oldd = d;
a = this.md5_ff(a,b,c,d,x[i + 0],7,-680876936);
d = this.md5_ff(d,a,b,c,x[i + 1],12,-389564586);
c = this.md5_ff(c,d,a,b,x[i + 2],17,606105819);
b = this.md5_ff(b,c,d,a,x[i + 3],22,-1044525330);
a = this.md5_ff(a,b,c,d,x[i + 4],7,-176418897);
d = this.md5_ff(d,a,b,c,x[i + 5],12,1200080426);
c = this.md5_ff(c,d,a,b,x[i + 6],17,-1473231341);
b = this.md5_ff(b,c,d,a,x[i + 7],22,-45705983);
a = this.md5_ff(a,b,c,d,x[i + 8],7,1770035416);
d = this.md5_ff(d,a,b,c,x[i + 9],12,-1958414417);
c = this.md5_ff(c,d,a,b,x[i + 10],17,-42063);
b = this.md5_ff(b,c,d,a,x[i + 11],22,-1990404162);
a = this.md5_ff(a,b,c,d,x[i + 12],7,1804603682);
d = this.md5_ff(d,a,b,c,x[i + 13],12,-40341101);
c = this.md5_ff(c,d,a,b,x[i + 14],17,-1502002290);
b = this.md5_ff(b,c,d,a,x[i + 15],22,1236535329);
a = this.md5_gg(a,b,c,d,x[i + 1],5,-165796510);
d = this.md5_gg(d,a,b,c,x[i + 6],9,-1069501632);
c = this.md5_gg(c,d,a,b,x[i + 11],14,643717713);
b = this.md5_gg(b,c,d,a,x[i + 0],20,-373897302);
a = this.md5_gg(a,b,c,d,x[i + 5],5,-701558691);
d = this.md5_gg(d,a,b,c,x[i + 10],9,38016083);
c = this.md5_gg(c,d,a,b,x[i + 15],14,-660478335);
b = this.md5_gg(b,c,d,a,x[i + 4],20,-405537848);
a = this.md5_gg(a,b,c,d,x[i + 9],5,568446438);
d = this.md5_gg(d,a,b,c,x[i + 14],9,-1019803690);
c = this.md5_gg(c,d,a,b,x[i + 3],14,-187363961);
b = this.md5_gg(b,c,d,a,x[i + 8],20,1163531501);
a = this.md5_gg(a,b,c,d,x[i + 13],5,-1444681467);
d = this.md5_gg(d,a,b,c,x[i + 2],9,-51403784);
c = this.md5_gg(c,d,a,b,x[i + 7],14,1735328473);
b = this.md5_gg(b,c,d,a,x[i + 12],20,-1926607734);
a = this.md5_hh(a,b,c,d,x[i + 5],4,-378558);
d = this.md5_hh(d,a,b,c,x[i + 8],11,-2022574463);
c = this.md5_hh(c,d,a,b,x[i + 11],16,1839030562);
b = this.md5_hh(b,c,d,a,x[i + 14],23,-35309556);
a = this.md5_hh(a,b,c,d,x[i + 1],4,-1530992060);
d = this.md5_hh(d,a,b,c,x[i + 4],11,1272893353);
c = this.md5_hh(c,d,a,b,x[i + 7],16,-155497632);
b = this.md5_hh(b,c,d,a,x[i + 10],23,-1094730640);
a = this.md5_hh(a,b,c,d,x[i + 13],4,681279174);
d = this.md5_hh(d,a,b,c,x[i + 0],11,-358537222);
c = this.md5_hh(c,d,a,b,x[i + 3],16,-722521979);
b = this.md5_hh(b,c,d,a,x[i + 6],23,76029189);
a = this.md5_hh(a,b,c,d,x[i + 9],4,-640364487);
d = this.md5_hh(d,a,b,c,x[i + 12],11,-421815835);
c = this.md5_hh(c,d,a,b,x[i + 15],16,530742520);
b = this.md5_hh(b,c,d,a,x[i + 2],23,-995338651);
a = this.md5_ii(a,b,c,d,x[i + 0],6,-198630844);
d = this.md5_ii(d,a,b,c,x[i + 7],10,1126891415);
c = this.md5_ii(c,d,a,b,x[i + 14],15,-1416354905);
b = this.md5_ii(b,c,d,a,x[i + 5],21,-57434055);
a = this.md5_ii(a,b,c,d,x[i + 12],6,1700485571);
d = this.md5_ii(d,a,b,c,x[i + 3],10,-1894986606);
c = this.md5_ii(c,d,a,b,x[i + 10],15,-1051523);
b = this.md5_ii(b,c,d,a,x[i + 1],21,-2054922799);
a = this.md5_ii(a,b,c,d,x[i + 8],6,1873313359);
d = this.md5_ii(d,a,b,c,x[i + 15],10,-30611744);
c = this.md5_ii(c,d,a,b,x[i + 6],15,-1560198380);
b = this.md5_ii(b,c,d,a,x[i + 13],21,1309151649);
a = this.md5_ii(a,b,c,d,x[i + 4],6,-145523070);
d = this.md5_ii(d,a,b,c,x[i + 11],10,-1120210379);
c = this.md5_ii(c,d,a,b,x[i + 2],15,718787259);
b = this.md5_ii(b,c,d,a,x[i + 9],21,-343485551);
a = this.safe_add(a,olda);
b = this.safe_add(b,oldb);
c = this.safe_add(c,oldc);
d = this.safe_add(d,oldd);
}
return [a,b,c,d];
}
/*
* These privates implement the four basic operations the algorithm uses.
*/
public md5_cmn(q,a,b,x,s,t) {
return this.safe_add(this.bit_rol(this.safe_add(this.safe_add(a,q),this.safe_add(x,t)),s),b);
}
public md5_ff(a,b,c,d,x,s,t) {
return this.md5_cmn((b & c) | ((~b) & d),a,b,x,s,t);
}
public md5_gg(a,b,c,d,x,s,t) {
return this.md5_cmn((b & d) | (c & (~d)),a,b,x,s,t);
}
public md5_hh(a,b,c,d,x,s,t) {
return this.md5_cmn(b ^ c ^ d,a,b,x,s,t);
}
public md5_ii(a,b,c,d,x,s,t) {
return this.md5_cmn(c ^ (b | (~d)),a,b,x,s,t);
}
/*
* Add integers, wrapping at 2^32. This uses 16-bit operations internally
* to work around bugs in some JS interpreters.
*/
public safe_add(x,y) {
var lsw = (x & 0xFFFF) + (y & 0xFFFF);
var msw = (x >> 16) + (y >> 16) + (lsw >> 16);
return (msw << 16) | (lsw & 0xFFFF);
}
/*
* Bitwise rotate a 32-bit number to the left.
*/
public bit_rol(num,cnt) {
return (num << cnt) | (num >>> (32 - cnt));
}
}
src/middleware/user.ts 0 → 100644
import { BizError } from "../util/bizError";
/**
* 中间件 校验token
* @param req
* @param res
* @param next
* @returns
*/
export async function checkToken(req, res, next) {
if (!req.headers) req.headers = {};
const reqToken = req.headers.token;
const userId = req.headers.userid || "";
let isErr = false;
if (userInfo.token != reqToken) {
isErr = true;
return next(new BizError(SYSTEMERRORENUM.身份验证过期, userId, reqToken, req.url));
}
req.headers.userId = userId;
if (!isErr) next();
}
\ No newline at end of file
src/middleware/watch.ts 0 → 100644
export function watch(req, res, next) {
res.success = success.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);
}
src/net/http_server.ts
import express = require('express'); import express = require('express');
import bodyParser = require('body-parser'); import bodyParser = require('body-parser');
import sign = require('../middleware/sign');
import routers = require('../routers/router'); import routers = require('../routers/router');
import compression = require('compression'); import compression = require('compression');
import { encryptionReturn } from '../middleware/encryptionReturn'; import { watch } from '../middleware/watch';
import { httpErrorHandler } from '../middleware/httpErrorHandler';
import * as path from "path"; import * as path from "path";
import * as fallback from 'express-history-api-fallback'; import * as fallback from 'express-history-api-fallback';
export class httpServer { export class httpServer {
static createServer(port:number) { static createServer(port:number) {
var httpServer = express(); var httpServer = express();
httpServer.all('*',function (req, res, next) { httpServer.all('*', (req, res, next) => {
res.header('Access-Control-Allow-Origin', req.headers.origin); res.header('Access-Control-Allow-Origin', req.headers.origin);
res.header("Access-Control-Allow-Headers", "X-Requested-With"); res.header("Access-Control-Allow-Headers", "X-Requested-With");
res.header('Access-Control-Allow-Headers', 'Content-Type'); res.header('Access-Control-Allow-Headers', 'Content-Type');
res.header("Access-Control-Allow-Methods", "PUT,POST,GET,DELETE,OPTIONS"); res.header("Access-Control-Allow-Methods", "PUT,POST,GET,DELETE,OPTIONS");
res.header('Access-Control-Allow-Credentials', true); res.header('Access-Control-Allow-Credentials', true);
res.header("X-Powered-By", ' 3.2.1'); res.header("X-Powered-By", ' 3.2.1');
if(req.method === 'OPTIONS'){
res.statusCode = 200;
res.end();
}else{
next(); next();
} // if(req.method === 'OPTIONS'){
// res.statusCode = 200;
// res.end();
// }else{
// next();
// }
}); });
httpServer.use(express.static("./images") );
// httpServer.use(express.static(path.join(__dirname, "../../video")) );
httpServer.use(express.static("./video" ) );
httpServer.use(bodyParser.json({limit:"10kb"}));
httpServer.use(compression())
routers.setRouter(httpServer);
const root = path.join(__dirname, "../../public"); const root = path.join(__dirname, "../../public");
httpServer.use(express.static(root)); httpServer.use(express.static(root));
httpServer.use(fallback('index.html', { root })); httpServer.use(fallback('index.html', { root }));
httpServer.use(bodyParser.json({limit:"1000kb"}));
httpServer.use(compression());
httpServer.use(watch);
routers.setRouter(httpServer);
httpServer.use(httpErrorHandler);
httpServer.listen(port); httpServer.listen(port);
console.log('server listen on port:'+port); console.log('server listen on port:'+port);
return httpServer;
} }
} }
\ No newline at end of file
src/routers/public.ts 0 → 100644
import * as asyncHandler from 'express-async-handler';
import { FUHUAQILV, INSTITUTIONALNATURE, FUHUAINDUSTRY, INDUSTRY } from '../config/enum';
export function setRouter(httpServer) {
httpServer.post('/public/fuhuaqilv', asyncHandler(getFuHuaQiLv));
httpServer.post('/public/institutionalnature', asyncHandler(getInstitutionalNature));
httpServer.post('/public/fuhuaqiindustry', asyncHandler(getFuHuaQiIndustry));
httpServer.post('/public/industry', asyncHandler(getIndustry));
}
/**
* 获取孵化器等级列表
* @param req
* @param res
*/
async function getFuHuaQiLv(req, res) {
let lvList = [];
for (let key in FUHUAQILV) {
let anyKey:any = key;
if (isNaN(anyKey)) {
lvList.push({key, value:FUHUAQILV[key]});
}
}
res.success({lvList});
}
/**
* 获取孵化器机构性质列表
* @param req
* @param res
*/
async function getInstitutionalNature(req, res) {
let lvList = [];
for (let key in INSTITUTIONALNATURE) {
let anyKey:any = key;
if (isNaN(anyKey)) {
lvList.push({key, value:INSTITUTIONALNATURE[key]});
}
}
res.success({lvList});
}
/**
* 获取孵化器领域
* @param req
* @param res
*/
async function getFuHuaQiIndustry(req, res) {
let lvList = [];
for (let key in FUHUAINDUSTRY) {
let anyKey:any = key;
if (isNaN(anyKey)) {
lvList.push({key, value:FUHUAINDUSTRY[key]});
}
}
res.success({lvList});
}
/**
* 获取行业领域
* @param req
* @param res
*/
async function getIndustry(req, res) {
let lvList = [];
for (let key in INDUSTRY) {
let anyKey:any = key;
if (isNaN(anyKey)) {
lvList.push({key, value:INDUSTRY[key]});
}
}
res.success({lvList});
}
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