资质查询 综合

center-channel/app/base/api/impl/action/icbcTools.js

@@ -36,8 +36,11 @@ class IcbcToolsAPI extends WEBBase {
             case "getCompanyIcpByName"://工商icp证照查询
                 opResult = await this.icbcSve.getCompanyIcpByName(action_body, req);
                 break;
-            case "searchCertification"://企业证书查询
-                opResult = await this.icbcSve.searchCertification(action_body,req);
+            // case "searchCertification"://企业证书查询
+            //     opResult = await this.icbcSve.searchCertification(action_body,req);
+            //     break;
+            case "searchCertification"://企业证书查询（综合）
+                opResult = await this.icbcSve.getLicenseList(action_body,req);
                 break;
             default:
                 opResult = system.getResult(null, "action_type参数错误");

center-channel/app/base/service/impl/trademark/icbcSve.js

@@ -85,6 +85,7 @@ class IcbcService extends AppServiceBase {
             "accessKey": "111",
             "accessSecret": "222"
         }
+        req.headers.token='sss'
         let ret = await this.opReqResult(url, params, req);
         if (ret.status != 1) {
             return system.getResultFail(-1, '获取开放平台token失败');
@@ -94,8 +95,10 @@ class IcbcService extends AppServiceBase {
         url = settings.icNameUrl() + "openPlatform/busenterprise/cloudapi";
         //资质查询
         let data = {
+            // "path": "/apis/dst/patents/getLicense",
             "path": "/apis/dst/patents/certificate",
-            "name": queryobj.companyName
+            "name": queryobj.companyName,
+            "pageNum":1
         };
         let rtn = await this.execClient.restGetWithHAuthorizationUrl(token, url, data);
         if (!rtn || !rtn.stdout) {
@@ -121,6 +124,94 @@ class IcbcService extends AppServiceBase {
     }
 
 
+    /**
+     * 获取资质证书（集合）
+     * @param obj
+     * @param req
+     * @returns {Promise<void>}
+     */
+    async getLicenseList(obj,req){
+        let companyName = obj.companyName;
+        let url = settings.icNameUrl() + 'openPlatform/platform/getToken';
+        let params = {
+            "accessKey": "111",
+            "accessSecret": "222"
+        }
+        req.headers.token='sss'
+        let ret = await this.opReqResult(url, params, req);
+        if (ret.status != 1) {
+            return system.getResultFail(-1, '获取开放平台token失败');
+        }
+        let token = ret.data;
+        let url2 = settings.icNameUrl() + "/openPlatform/busenterprise/cloudapi";
+        let params1 = {
+            "path": "/apis/dst/patents/certificate",
+            "name": companyName,
+            "pageNum":1
+        }
+        let params2 = {
+            "path": "/apis/dst/patents/getLicense",
+            "name": companyName,
+            "pageNum":1
+        }
+        let params3 = {
+            "companyName":companyName
+        }
+        let funcs = [];
+        funcs.push(this.execClient.restGetWithHAuthorizationUrl(token, url2, params1));
+        funcs.push(this.execClient.restGetWithHAuthorizationUrl(token, url2, params2));
+        funcs.push(this.getCompanyIcpByName(params3,req));
+        let results = await Promise.all(funcs);
+        if(results.length==0){
+            return system.getResultFail(-1,'查询失败，请稍后再试');
+        }
+        let ret1 = JSON.parse(results[0].stdout);
+        let ret2 = JSON.parse(results[1].stdout);
+        let ret3 = results[2];
+        let resultData = [];
+        if(ret1.error_code == 0 && ret1.result.items.length >0){
+            for(let i =0;i<ret1.result.items.length;i++){
+                let d = ret1.result.items[i];
+                let obj = {
+                    licencenumber:d.certNo,
+                    licencename:d.certificateName,
+                    startDate:d.startDate,
+                    endDate:d.endDate,
+                    detail:d.detail
+                };
+                resultData.push(obj);
+            }
+        }
+        if(ret2.error_code == 0 && ret2.result.items.length >0){
+            for(let i =0;i<ret2.result.items.length;i++){
+                let d = ret2.result.items[i];
+                let obj = {
+                    licencenumber:d.licencenumber,
+                    licencename:d.licencename,
+                    startDate:d.fromdate,
+                    endDate:d.todate,
+                    detail:d.detail
+                };
+                if(!resultData.includes(obj)){
+                    resultData.push(obj);
+                }
+            }
+        }
+        if(ret3.status == 0 && ret3.data.list.length>0){
+            for(let i =0;i<ret3.data.list.length;i++){
+                let d = ret3.data.list[i];
+                let obj = {
+                    licencenumber:d.liscense,
+                    licencename:"icp备案",
+                    examine_date:d.examine_date
+                };
+                resultData.push(obj);
+            }
+        }
+        return system.getResultSuccess(resultData);
+    }
+
+