Skip to content

Z
zhichan
Commit 0e8d8537 by wangyong
Options

feat: (icbcSve.js) 资质查询接口添加商标查询

parent d3a84303
Showing with 187 additions and 116 deletions
center-channel/app/base/service/impl/trademark/icbcSve.js
......@@ -3,129 +3,149 @@ var settings = require("../../../../config/settings");
const AppServiceBase = require("../../app.base");
class IcbcService extends AppServiceBase {
constructor() {
super();
this.zcApiUrl = settings.reqZcApi();
this.certificationUrl = settings.certificationUrl();
this.restClient = system.getObject("util.redisClient");
//处理企业资质证书数据
this.disposeCertificationData = "disposeCertificationData";
//企业资质证书查询
this.searchCertificationData = "searchCertificationData";
}
//企业模糊查询
async getCompanyListByVague(obj, req) {
var url = this.zcApiUrl + "api/tool/toolApi/getCompanyListByVague";
return await this.opReqResult(url, obj, req);
}
//企业详情
async getDetailByCompanyName(queryobj, req) {
var url = this.zcApiUrl + "api/tool/toolApi/getDetailByCompanyName";
return await this.opReqResult(url, queryobj, req);
}
//企业变更记录查询
async getCompanyChangeByName(queryobj, req) {
var url = this.zcApiUrl + "api/tool/toolApi/getCompanyChangeByName";
return await this.opReqResult(url, queryobj, req);
}
//工商icp证照查询
async getCompanyIcpByName(queryobj, req) {
var url = this.zcApiUrl + "api/tool/toolApi/getCompanyIcpByName";
return await this.opReqResult(url, queryobj, req);
}
constructor() {
super();
this.zcApiUrl = settings.reqZcApi();
this.certificationUrl = settings.certificationUrl();
this.restClient = system.getObject("util.redisClient");
//处理企业资质证书数据
this.disposeCertificationData = "disposeCertificationData";
//企业资质证书查询
this.searchCertificationData = "searchCertificationData";
//result工具类
this.utilsResultSve = system.getObject("service.utilsSve.utilsResultSve");
}
//企业模糊查询
async getCompanyListByVague(obj, req) {
var url = this.zcApiUrl + "api/tool/toolApi/getCompanyListByVague";
return await this.opReqResult(url, obj, req);
}
//企业详情
async getDetailByCompanyName(queryobj, req) {
var url = this.zcApiUrl + "api/tool/toolApi/getDetailByCompanyName";
return await this.opReqResult(url, queryobj, req);
}
//企业变更记录查询
async getCompanyChangeByName(queryobj, req) {
var url = this.zcApiUrl + "api/tool/toolApi/getCompanyChangeByName";
return await this.opReqResult(url, queryobj, req);
}
//工商icp证照查询
async getCompanyIcpByName(queryobj, req) {
var url = this.zcApiUrl + "api/tool/toolApi/getCompanyIcpByName";
return await this.opReqResult(url, queryobj, req);
}
//企业证书查询
// async searchCertification(queryobj, req) {
// if (!queryobj.companyName) {
// return system.getResultFail(-1, 'companyName can not be empty');
// }
// var hashValue = await this.restClient.hget(this.searchCertificationData, queryobj.companyName);
// if (hashValue) {
// return system.getResultSuccess(JSON.parse(hashValue));
// }
// let url = this.certificationUrl + "gsb/SearchCertification";
// let data = {
// "company_name": queryobj.companyName,
// "pageSize": 20,
// "pageIndex": 1,
// "isExactlySame": "True"
// }
// let result = await this.opReqResult(url, data, req);
// if (!result) {
// return system.getResultFail(-1, '查询失败！！！');
// }
// if (result.Status != 200) {
// return system.getResultFail(-1, '查询失败');
// }
// //对结果处理
// // "Tag": 1为qichacha,0为gsb
// var setValue = {};
// setValue[queryobj.companyName] = JSON.stringify(result.Result);
// if (result.Tag == 1) {
// this.restClient.hmset(this.disposeCertificationData, setValue);
// }
// this.restClient.hmset(this.searchCertificationData, setValue);
// return system.getResult(result.Result);
// }
//企业证书查询
// async searchCertification(queryobj, req) {
// if (!queryobj.companyName) {
// return system.getResultFail(-1, 'companyName can not be empty');
// }
// var hashValue = await this.restClient.hget(this.searchCertificationData, queryobj.companyName);
// if (hashValue) {
// return system.getResultSuccess(JSON.parse(hashValue));
// }
// let url = this.certificationUrl + "gsb/SearchCertification";
// let data = {
// "company_name": queryobj.companyName,
// "pageSize": 20,
// "pageIndex": 1,
// "isExactlySame": "True"
// }
// let result = await this.opReqResult(url, data, req);
// if (!result) {
// return system.getResultFail(-1, '查询失败！！！');
// }
// if (result.Status != 200) {
// return system.getResultFail(-1, '查询失败');
// }
// //对结果处理
// // "Tag": 1为qichacha,0为gsb
// var setValue = {};
// setValue[queryobj.companyName] = JSON.stringify(result.Result);
// if (result.Tag == 1) {
// this.restClient.hmset(this.disposeCertificationData, setValue);
// }
// this.restClient.hmset(this.searchCertificationData, setValue);
// return system.getResult(result.Result);
// }
//企业证书查询 用友数据源
async searchCertification(queryobj, req) {
if (!queryobj.companyName) {
return system.getResultFail(-1, 'companyName can not be empty');
}
var hashValue = await this.restClient.hget(this.searchCertificationData, queryobj.companyName);
if (hashValue) {
return system.getResultSuccess(JSON.parse(hashValue));
}
//获取token
let url = settings.icNameUrl() + 'openPlatform/platform/getToken';
let params = {
"accessKey":"111",
"accessSecret":"222"
}
let ret = await this.opReqResult(url,params,req);
if(ret.status != 1){
system.getResultFail(-1,'获取开放平台token失败');
}
let token = ret.data;
//企业证书查询 用友数据源
async searchCertification(queryobj, req) {
if (!queryobj.companyName) {
return system.getResultFail(-1, 'companyName can not be empty');
}
var hashValue = await this.restClient.hget(this.searchCertificationData, queryobj.companyName);
if (hashValue) {
return system.getResultSuccess(JSON.parse(hashValue));
}
//获取token
let url = settings.icNameUrl() + 'openPlatform/platform/getToken';
let params = {
"accessKey": "111",
"accessSecret": "222"
}
let ret = await this.opReqResult(url, params, req);
if (ret.status != 1) {
system.getResultFail(-1, '获取开放平台token失败');
}
let token = ret.data;
url = settings.icNameUrl() + "openPlatform/busenterprise/cloudapi";
let data = {
"path":"/apis/dst/patents/certificate",
"name": queryobj.companyName
}
let rtn = await this.execClient.restGetWithHAuthorizationUrl(token,url, data);
if (!rtn || !rtn.stdout) {
return system.getResult(null, "restPostWithHAuthorizationUrl data is empty");
}
var result = JSON.parse(rtn.stdout);
if (!result) {
return system.getResultFail(-1, '查询失败！！！');
}
if (result.error_code != 0) {
return system.getResultFail(-1, '查询失败');
url = settings.icNameUrl() + "openPlatform/busenterprise/cloudapi";
let tmUrl = settings.icNameUrl() + "openPlatform/busservices/cloudApi"
//资质查询
let data = {
"path": "/apis/dst/patents/certificate",
"name": queryobj.companyName
};
//商标查询
let tmData = {
"path": "getTrademarkInfo",
"entName": queryobj.companyName,
"pageNo": 1, //页码
"pageSize": 10 //每页显示最大数量，最大100
};
let rtn = await this.execClient.restGetWithHAuthorizationUrl(token, url, data);
let tmrtn = await this.execClient.restGetWithHAuthorizationUrl(token, tmUrl, tmData);
if (!rtn || !rtn.stdout) {
return system.getResult(null, "restPostWithHAuthorizationUrl data is empty");
};
let tmArray = [];
if (tmrtn.status == 1 && tmrtn.data) {
var tmResult = JSON.parse(tmrtn.data);
tmArray = this.utilsResultSve.formulaContinued(tmResult);
}
var result = JSON.parse(rtn.stdout);
if (!result) {
return system.getResultFail(-1, '查询失败！！！');
}
if (result.error_code != 0) {
return system.getResultFail(-1, '查询失败');
}
let item = result.result.items;
//对结果处理
// "Tag": 1为qichacha,0为gsb
var setValue = {};
setValue[queryobj.companyName] = JSON.stringify(item);
setValue[tm] = JSON.stringify(tmArray);
// if (result.Tag == 1) {
// this.restClient.hmset(this.disposeCertificationData, setValue);
// }
this.restClient.hmset(this.searchCertificationData, setValue);
return system.getResult(item);
}
let item = result.result.items;
//对结果处理
// "Tag": 1为qichacha,0为gsb
var setValue = {};
setValue[queryobj.companyName] = JSON.stringify(item);
// if (result.Tag == 1) {
// this.restClient.hmset(this.disposeCertificationData, setValue);
// }
this.restClient.hmset(this.searchCertificationData, setValue);
return system.getResult(item);
}
async opReqResult(reqUrl, queryobj, req) {
var rtn = await this.execClient.execPushDataPost(queryobj, reqUrl, req.headers["token"], req.headers["request-id"]);
var data = JSON.parse(rtn.stdout);
return data;
}
async opReqResult(reqUrl, queryobj, req) {
var rtn = await this.execClient.execPushDataPost(queryobj, reqUrl, req.headers["token"], req.headers["request-id"]);
var data = JSON.parse(rtn.stdout);
return data;
}
}
module.exports = IcbcService;
module.exports = IcbcService;
\ No newline at end of file
center-channel/app/base/service/impl/utilsSve/utilsResultSve.js 0 → 100644
var system = require("../../../system");
const AppServiceBase = require("../../app.base");
//外部请求结果校验以及相应工具处理类
class utilsTlBankSve extends AppServiceBase {
constructor() {
super();
}
//格式化时间
convertDate(time) {
if (time == null) {
return "";
}
var date = new Date(Number(time * 1000));
var y = 1900 + date.getYear();
var m = "0" + (date.getMonth() + 1);
var d = "0" + date.getDate();
return y + "-" + m.substring(m.length - 2, m.length) + "-" + d.substring(d.length - 2, d.length);
}
//计算并返回指定字段
formulaContinued(tms) {
let result = [];
for (let i = 0; i < tms.length; i++) {
let tmInfo = tms[i];
if (!tmInfo.REGDATE) { //注册公告日期
continue;
}
let zcrqFormat = new Date(tmInfo.REGDATE * 1000); //注册日期
zcrqFormat.setFullYear(zcrqFormat.getFullYear() + 10); //专用起始日期计算
zcrqFormat.setMonth(zcrqFormat.getMonth()); //专用起始日期计算
zcrqFormat.setDate(zcrqFormat.getDate()); //专用起始日期计算
let tmObject = {
"tm_comName": tmInfo.AGENTNAME, //代理机构
"tm_img": tmInfo.MARKIMAGE, //商标图片
"tm_name": tmInfo.MARKNAME, //商标名称
"tm_appDate": tmInfo.APPDATE, //申请日期
"tm_isInvalid": tmInfo.ISINVALID, //状态
"tm_expiry": this.convertDate(zcrqFormat) //商标到期日
}
result.push(tmObject);
}
return result;
}
}
module.exports = utilsTlBankSve;
\ No newline at end of file
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