Commit c307bc77 by chenjinjing

no message

parent a769bc8a
...@@ -753,16 +753,24 @@ export async function getiprDetails(eId:string) { ...@@ -753,16 +753,24 @@ export async function getiprDetails(eId:string) {
知识产权Map[key].forEach( info => { 知识产权Map[key].forEach( info => {
let iprUrl = []; let iprUrl = [];
let iprUrlList = JSON.parse(info[iprConf[3]]); let iprUrlList = [];
if (info[iprConf[3]]) iprUrlList = JSON.parse(info[iprConf[3]]);
for (let i = 0; i < iprUrlList.length; i++) { for (let i = 0; i < iprUrlList.length; i++) {
let url = `${systemConfig.imgFileUrl}${iprUrlList[i]}`; let url = ``;
if (iprUrlList[i].indexOf("http") > -1) {
url = `${iprUrlList[i]}`;
} else url =`${systemConfig.imgFileUrl}${iprUrlList[i]}`;
iprUrl.push(url); iprUrl.push(url);
} }
let iprTime = "";
if (info[iprConf[2]]) iprTime = moment(info[iprConf[2]]).format("YYYY-MM-DD");
dataList.push({ dataList.push({
iprId:info[iprConf[0]], iprId:info[iprConf[0]],
iprName:info[iprConf[1]], iprName:info[iprConf[1]],
iprTime:moment(info[iprConf[2]]).format("YYYY-MM-DD"), iprTime,
iprUrl, iprUrl,
timeNumber:new Date(info[iprConf[2]]).valueOf() timeNumber:new Date(info[iprConf[2]]).valueOf()
}) })
......
...@@ -241,7 +241,10 @@ export async function getOperateData(year) { ...@@ -241,7 +241,10 @@ export async function getOperateData(year) {
let industryMap = {}; let industryMap = {};
fhdbList.forEach(info => { fhdbList.forEach(info => {
let { industry } = info; let { industry, enterprise_fuhuas } = info;
let startYear = moment(enterprise_fuhuas[0].startTime).format("YYYY");
let endYear = moment(enterprise_fuhuas[0].endTime).format("YYYY");
if (moment(startYear).format("YYYY") <= year && moment(endYear).format("YYYY") >= year) {
//行业领域分布 //行业领域分布
if (industry) { if (industry) {
let industryList = JSON.parse(industry); let industryList = JSON.parse(industry);
...@@ -251,6 +254,8 @@ export async function getOperateData(year) { ...@@ -251,6 +254,8 @@ export async function getOperateData(year) {
industryMap[industryStr] += 1; industryMap[industryStr] += 1;
} }
} }
}
}) })
for (let key in INDUSTRY) { for (let key in INDUSTRY) {
let anyKey: any = key; let anyKey: any = key;
......
...@@ -112,6 +112,9 @@ async function 工商信息(uscc, eId) { ...@@ -112,6 +112,9 @@ async function 工商信息(uscc, eId) {
let 工商信息:any = await getQcc('https://api.qichacha.com/ECIInfoVerify/GetInfo', query, header);//获取工商信息 let 工商信息:any = await getQcc('https://api.qichacha.com/ECIInfoVerify/GetInfo', query, header);//获取工商信息
let khsfsb = getReqParam(uscc);
let 客户身份识别:any = await getQcc('https://api.qichacha.com/CustomerDueDiligence/KYC', khsfsb.query, khsfsb.header);//获取工商信息
let pinyinName = getPinyinInitials(工商信息.Name); let pinyinName = getPinyinInitials(工商信息.Name);
let industryList = []; //Industry let industryList = []; //Industry
let TermStart = moment(工商信息.TermStart).format("YYYY-MM-DD"); let TermStart = moment(工商信息.TermStart).format("YYYY-MM-DD");
...@@ -138,9 +141,15 @@ async function 工商信息(uscc, eId) { ...@@ -138,9 +141,15 @@ async function 工商信息(uscc, eId) {
guanWang = 工商信息.ContactInfo.WebSite[0].Url || ""; guanWang = 工商信息.ContactInfo.WebSite[0].Url || "";
} }
let qiYeGuiMo = ""; let qiYeGuiMo = "";
if (工商信息.TagList && 工商信息.TagList[0]) { if (客户身份识别.Data && 客户身份识别.Data.Scale) {
guanWang = 工商信息.TagList[0].Name || ""; switch (客户身份识别.Data.Scale) {
case "L": qiYeGuiMo = "大型"; break;
case "M": qiYeGuiMo = "中型"; break;
case "S": qiYeGuiMo = "小型"; break;
case "XS": qiYeGuiMo = "微型"; break;
}
} }
let baseInfo = { let baseInfo = {
enterpriseName: 工商信息.Name, enterpriseName: 工商信息.Name,
pinyinName, pinyinName,
...@@ -236,7 +245,6 @@ async function 工商信息(uscc, eId) { ...@@ -236,7 +245,6 @@ async function 工商信息(uscc, eId) {
* 4.企查查以前有现在没有,小程序没有,不删除之前的 * 4.企查查以前有现在没有,小程序没有,不删除之前的
*/ */
if (工商信息.TagList) { if (工商信息.TagList) {
for (let i = 0; i < 工商信息.TagList.length; i++) { for (let i = 0; i < 工商信息.TagList.length; i++) {
let info = 工商信息.TagList[i]; let info = 工商信息.TagList[i];
let {Type, Name} = info; let {Type, Name} = info;
...@@ -407,6 +415,8 @@ async function 知识产权(uscc, eId) { ...@@ -407,6 +415,8 @@ async function 知识产权(uscc, eId) {
let item = await selectData(OPERATIONALDATATYPE.查询单个, TABLENAME.商标, {qccId:info.ID}, ["qccId"]); let item = await selectData(OPERATIONALDATATYPE.查询单个, TABLENAME.商标, {qccId:info.ID}, ["qccId"]);
if (!item || !item.qccId) { if (!item || !item.qccId) {
let qcc商标详情 = await 商标详情查询(uscc, info.ID); let qcc商标详情 = await 商标详情查询(uscc, info.ID);
let imageUrl = [];
if (info.ImageUrl) imageUrl.push(info.ImageUrl);
//添加新的 //添加新的
let addItemInfo:any = { let addItemInfo:any = {
tmId:randomId(TABLEID.商标), tmId:randomId(TABLEID.商标),
...@@ -417,7 +427,7 @@ async function 知识产权(uscc, eId) { ...@@ -417,7 +427,7 @@ async function 知识产权(uscc, eId) {
categoryId:info.CategoryId, categoryId:info.CategoryId,
category:info.Category, category:info.Category,
person:info.Person, person:info.Person,
imageUrl:info.ImageUrl, imageUrl:JSON.stringify(imageUrl),
flowStatusDesc:info.FlowStatusDesc, flowStatusDesc:info.FlowStatusDesc,
}; };
if (qcc商标详情.RegDate) addItemInfo.RegDate = getMySqlMs(qcc商标详情.RegDate) if (qcc商标详情.RegDate) addItemInfo.RegDate = getMySqlMs(qcc商标详情.RegDate)
......
...@@ -162,6 +162,7 @@ export async function enterprisePolicyUpdate(poId:string, param) { ...@@ -162,6 +162,7 @@ export async function enterprisePolicyUpdate(poId:string, param) {
return {isSuccess:true}; return {isSuccess:true};
} }
export async function enterprisePolicyAdd( param) { export async function enterprisePolicyAdd( param) {
const FuncName = "添加政策表" const FuncName = "添加政策表"
eccFormParam(FuncName, PolicyUpdateConfig, param ); eccFormParam(FuncName, PolicyUpdateConfig, param );
......
import { initConfig, systemConfig } from "./config/serverConfig"; import { initConfig, systemConfig } from "./config/serverConfig";
import { initApiDataStorage } from "./data/dataInterfaceWithCache";
import { httpServer } from "./net/http_server"; import { httpServer } from "./net/http_server";
async function lanuch() { async function lanuch() {
await initConfig(); await initConfig();
httpServer.createServer(systemConfig.port); httpServer.createServer(systemConfig.port);
console.log('This indicates that the server is started successfully.'); console.log('This indicates that the server is started successfully.');
await initApiDataStorage();
} }
......
...@@ -9,6 +9,7 @@ import { OPERATIONALDATATYPE, TABLEID, TABLENAME } from '../config/enum/dbEnum'; ...@@ -9,6 +9,7 @@ import { OPERATIONALDATATYPE, TABLEID, TABLENAME } from '../config/enum/dbEnum';
import { CHANGESTATE, DEGREE, FUHUASTATE, IPRALLTYPE, ZZMM } from '../config/enum/enum'; import { CHANGESTATE, DEGREE, FUHUASTATE, IPRALLTYPE, ZZMM } from '../config/enum/enum';
import { operationalData } from '../data/operationalData'; import { operationalData } from '../data/operationalData';
import { initApiDataStorage } from '../data/dataInterfaceWithCache'; import { initApiDataStorage } from '../data/dataInterfaceWithCache';
import { updateQCCDataTask } from '../biz/qccInit';
const xlsx = require('node-xlsx'); const xlsx = require('node-xlsx');
const path = require('path'); const path = require('path');
const fs = require('fs'); const fs = require('fs');
...@@ -224,23 +225,23 @@ export async function data1210(req, res) { ...@@ -224,23 +225,23 @@ export async function data1210(req, res) {
await operationalData(OPERATIONALDATATYPE.增加, TABLENAME.法人信息表, enterprise_legal_personInfo, {}); await operationalData(OPERATIONALDATATYPE.增加, TABLENAME.法人信息表, enterprise_legal_personInfo, {});
await operationalData(OPERATIONALDATATYPE.增加, TABLENAME.企业用户表, enterprise_userInfo, {}); await operationalData(OPERATIONALDATATYPE.增加, TABLENAME.企业用户表, enterprise_userInfo, {});
if(qccInfo.canbaoYear && qccInfo.canbaoNumber) { // if(qccInfo.canbaoYear && qccInfo.canbaoNumber) {
let enterprise_canbaoInfo = { // let enterprise_canbaoInfo = {
cId:randomId(TABLEID.参保记录), // cId:randomId(TABLEID.参保记录),
eId, // eId,
annual:getMySqlMs(`${ qccInfo.canbaoYear.match(/\d+/g)[0]}-01-01 00:00:00`), // annual:getMySqlMs(`${ qccInfo.canbaoYear.match(/\d+/g)[0]}-01-01 00:00:00`),
zhuanKe:0, // zhuanKe:0,
benKe:0, // benKe:0,
shuoshi:0, // shuoshi:0,
boShi:0, // boShi:0,
boshiyishang:0, // boshiyishang:0,
qiTa:qccInfo.canbaoNumber // qiTa:qccInfo.canbaoNumber
} // }
await operationalData(OPERATIONALDATATYPE.增加, TABLENAME.参保记录, enterprise_canbaoInfo, {}); // await operationalData(OPERATIONALDATATYPE.增加, TABLENAME.参保记录, enterprise_canbaoInfo, {});
} // }
if (subList[31]) { // if (subList[31]) {
// for(let i = 0; i < parseInt(subList[31]); i++) { // for(let i = 0; i < parseInt(subList[31]); i++) {
// let enterprise_2022iprInfo = { // let enterprise_2022iprInfo = {
// iprId:randomId(TABLEID.知识产权), // iprId:randomId(TABLEID.知识产权),
...@@ -260,8 +261,8 @@ export async function data1210(req, res) { ...@@ -260,8 +261,8 @@ export async function data1210(req, res) {
// } // }
// await operationalData(OPERATIONALDATATYPE.增加, TABLENAME.知识产权, enterprise_2022iprInfo, {}); // await operationalData(OPERATIONALDATATYPE.增加, TABLENAME.知识产权, enterprise_2022iprInfo, {});
// } // }
} // }
if (subList[32]) { // if (subList[32]) {
// for(let i = 0; i < parseInt(subList[32]); i++) { // for(let i = 0; i < parseInt(subList[32]); i++) {
// let enterprise_2023iprInfo = { // let enterprise_2023iprInfo = {
// iprId:randomId(TABLEID.知识产权), // iprId:randomId(TABLEID.知识产权),
...@@ -281,8 +282,8 @@ export async function data1210(req, res) { ...@@ -281,8 +282,8 @@ export async function data1210(req, res) {
// await operationalData(OPERATIONALDATATYPE.增加, TABLENAME.知识产权, enterprise_2023iprInfo, {}); // await operationalData(OPERATIONALDATATYPE.增加, TABLENAME.知识产权, enterprise_2023iprInfo, {});
// } // }
} // }
if (subList[33]) { // if (subList[33]) {
// for(let i = 0; i < parseInt(subList[33]); i++) { // for(let i = 0; i < parseInt(subList[33]); i++) {
// let enterprise_2022patent = { // let enterprise_2022patent = {
// iprId:randomId(TABLEID.知识产权), // iprId:randomId(TABLEID.知识产权),
...@@ -296,8 +297,8 @@ export async function data1210(req, res) { ...@@ -296,8 +297,8 @@ export async function data1210(req, res) {
// } // }
// await operationalData(OPERATIONALDATATYPE.增加, TABLENAME.知识产权, enterprise_2022patent, {}); // await operationalData(OPERATIONALDATATYPE.增加, TABLENAME.知识产权, enterprise_2022patent, {});
// } // }
} // }
if (subList[34]) { // if (subList[34]) {
// for(let i = 0; i < parseInt(subList[34]); i++) { // for(let i = 0; i < parseInt(subList[34]); i++) {
// let enterprise_2022patent = { // let enterprise_2022patent = {
// iprId:randomId(TABLEID.知识产权), // iprId:randomId(TABLEID.知识产权),
...@@ -311,7 +312,7 @@ export async function data1210(req, res) { ...@@ -311,7 +312,7 @@ export async function data1210(req, res) {
// } // }
// await operationalData(OPERATIONALDATATYPE.增加, TABLENAME.知识产权, enterprise_2022patent, {}); // await operationalData(OPERATIONALDATATYPE.增加, TABLENAME.知识产权, enterprise_2022patent, {});
// } // }
} // }
// if (subList[35] || subList[36] || subList[37] || subList[38]) { // if (subList[35] || subList[36] || subList[37] || subList[38]) {
// let enterprise_qualification:any = { // let enterprise_qualification:any = {
...@@ -335,7 +336,7 @@ export async function data1210(req, res) { ...@@ -335,7 +336,7 @@ export async function data1210(req, res) {
export async function qccDatat0519(req, res) { export async function qccDatat0519(req, res) {
console.log("开始清洗企查查数据"); console.log("开始清洗企查查数据");
// qccData(); // qccData();
await initApiDataStorage(); updateQCCDataTask();
res.success({isSuccess:true}) res.success({isSuccess:true})
} }
......
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