Browse Source

查询结果优化

liuam 7 years ago
parent
commit
df4a62fcf1

+ 18 - 12
src/main/java/com/uas/credit/controller/ErpQueryController.java

@@ -2,6 +2,12 @@ package com.uas.credit.controller;
 
 
 import com.uas.credit.model.EnterpriseQuery;
 import com.uas.credit.model.EnterpriseQuery;
 import com.uas.credit.model.PersonQuery;
 import com.uas.credit.model.PersonQuery;
+import com.uas.credit.model.abnormalinfo.AbnormalRoot;
+import com.uas.credit.model.corpcreditinfo.EncreditinfoRoot;
+import com.uas.credit.model.corpriskinfo.EnRiskInfoRoot;
+import com.uas.credit.model.debtinfo.EndeptinfoRoot;
+import com.uas.credit.model.personCorporation.PersonCorporationRoot;
+import com.uas.credit.model.personal.PoliceCheckRoot;
 import com.uas.credit.service.*;
 import com.uas.credit.service.*;
 import com.uas.credit.util.FlexJsonUtils;
 import com.uas.credit.util.FlexJsonUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -45,17 +51,17 @@ public class ErpQueryController {
         ModelMap modelMap = new ModelMap();
         ModelMap modelMap = new ModelMap();
         if (erpQuery != null) {
         if (erpQuery != null) {
             // 查询企业债务信息
             // 查询企业债务信息
-            String endept = enterpriseDeptService.queryAndSave(erpQuery);
+            EndeptinfoRoot endeptinfoRoot = enterpriseDeptService.queryAndSave(erpQuery);
             // 查询企业经营异常信息
             // 查询企业经营异常信息
-            String enexception = enexceptionService.queryAndSave(erpQuery);
+            AbnormalRoot abnormalRoot = enexceptionService.queryAndSave(erpQuery);
             // 查询企业信用信息
             // 查询企业信用信息
-            String encredit = creditInfoService.queryAndSave(erpQuery);
+            EncreditinfoRoot encreditinfoRoot = creditInfoService.queryAndSave(erpQuery);
             // 查询企业风险信息
             // 查询企业风险信息
-            String enrisk = enRiskInfoService.queryAndSave(erpQuery);
-            modelMap.put("endept", endept);
-            modelMap.put("enexception", enexception);
-            modelMap.put("enrisk", enrisk);
-            modelMap.put("encredit", encredit);
+            EnRiskInfoRoot enRiskInfoRoot = enRiskInfoService.queryAndSave(erpQuery);
+            modelMap.put("endept", endeptinfoRoot);
+            modelMap.put("enexception", abnormalRoot);
+            modelMap.put("enrisk", encreditinfoRoot);
+            modelMap.put("encredit", enRiskInfoRoot);
         }
         }
         return modelMap;
         return modelMap;
     }
     }
@@ -69,11 +75,11 @@ public class ErpQueryController {
         ModelMap modelMap = new ModelMap();
         ModelMap modelMap = new ModelMap();
         if (erpQuery != null) {
         if (erpQuery != null) {
             // 查询个人身份信息
             // 查询个人身份信息
-            String pnidentity = personalService.queryAndSave(erpQuery);
+            PoliceCheckRoot policeCheckRoot = personalService.queryAndSave(erpQuery);
             // 查询个人股东信息
             // 查询个人股东信息
-            String pnshareholder = personCorporationService.queryAndSave(erpQuery);
-            modelMap.put("pnidentity", pnidentity);
-            modelMap.put("pnshareholder", pnshareholder);
+            PersonCorporationRoot personCorporationRoot = personCorporationService.queryAndSave(erpQuery);
+            modelMap.put("pnidentity", policeCheckRoot);
+            modelMap.put("pnshareholder", personCorporationRoot);
         }
         }
         return modelMap;
         return modelMap;
     }
     }

+ 2 - 1
src/main/java/com/uas/credit/service/EnCreditInfoService.java

@@ -1,6 +1,7 @@
 package com.uas.credit.service;
 package com.uas.credit.service;
 
 
 import com.uas.credit.model.EnterpriseQuery;
 import com.uas.credit.model.EnterpriseQuery;
+import com.uas.credit.model.corpcreditinfo.EncreditinfoRoot;
 
 
 /**
 /**
  * 企业信用接口类
  * 企业信用接口类
@@ -8,5 +9,5 @@ import com.uas.credit.model.EnterpriseQuery;
  **/
  **/
 public interface EnCreditInfoService {
 public interface EnCreditInfoService {
 
 
-    String queryAndSave(EnterpriseQuery query);
+    EncreditinfoRoot queryAndSave(EnterpriseQuery query);
 }
 }

+ 2 - 1
src/main/java/com/uas/credit/service/EnRiskInfoService.java

@@ -1,6 +1,7 @@
 package com.uas.credit.service;
 package com.uas.credit.service;
 
 
 import com.uas.credit.model.EnterpriseQuery;
 import com.uas.credit.model.EnterpriseQuery;
+import com.uas.credit.model.corpriskinfo.EnRiskInfoRoot;
 
 
 /**
 /**
  * 企业风险信息接口层
  * 企业风险信息接口层
@@ -8,6 +9,6 @@ import com.uas.credit.model.EnterpriseQuery;
  **/
  **/
 public interface EnRiskInfoService {
 public interface EnRiskInfoService {
 
 
-    String queryAndSave(EnterpriseQuery query);
+    EnRiskInfoRoot queryAndSave(EnterpriseQuery query);
 
 
 }
 }

+ 2 - 1
src/main/java/com/uas/credit/service/EnexceptionService.java

@@ -1,6 +1,7 @@
 package com.uas.credit.service;
 package com.uas.credit.service;
 
 
 import com.uas.credit.model.EnterpriseQuery;
 import com.uas.credit.model.EnterpriseQuery;
+import com.uas.credit.model.abnormalinfo.AbnormalRoot;
 
 
 /**
 /**
  * 企业异常信息接口层
  * 企业异常信息接口层
@@ -8,5 +9,5 @@ import com.uas.credit.model.EnterpriseQuery;
  **/
  **/
 public interface EnexceptionService {
 public interface EnexceptionService {
 
 
-    String queryAndSave(EnterpriseQuery query);
+    AbnormalRoot queryAndSave(EnterpriseQuery query);
 }
 }

+ 2 - 1
src/main/java/com/uas/credit/service/EnterpriseDeptService.java

@@ -1,6 +1,7 @@
 package com.uas.credit.service;
 package com.uas.credit.service;
 
 
 import com.uas.credit.model.EnterpriseQuery;
 import com.uas.credit.model.EnterpriseQuery;
+import com.uas.credit.model.debtinfo.EndeptinfoRoot;
 
 
 /**
 /**
  * 企业债务信息接口
  * 企业债务信息接口
@@ -8,5 +9,5 @@ import com.uas.credit.model.EnterpriseQuery;
  **/
  **/
 public interface EnterpriseDeptService {
 public interface EnterpriseDeptService {
 
 
-    String queryAndSave(EnterpriseQuery query);
+    EndeptinfoRoot queryAndSave(EnterpriseQuery query);
 }
 }

+ 2 - 1
src/main/java/com/uas/credit/service/PersonCorporationService.java

@@ -1,6 +1,7 @@
 package com.uas.credit.service;
 package com.uas.credit.service;
 
 
 import com.uas.credit.model.PersonQuery;
 import com.uas.credit.model.PersonQuery;
+import com.uas.credit.model.personCorporation.PersonCorporationRoot;
 
 
 /**
 /**
  * 个人股东信息
  * 个人股东信息
@@ -9,5 +10,5 @@ import com.uas.credit.model.PersonQuery;
 public interface PersonCorporationService {
 public interface PersonCorporationService {
 
 
 
 
-    String queryAndSave(PersonQuery query);
+    PersonCorporationRoot queryAndSave(PersonQuery query);
 }
 }

+ 2 - 1
src/main/java/com/uas/credit/service/PersonalService.java

@@ -2,6 +2,7 @@ package com.uas.credit.service;
 
 
 
 
 import com.uas.credit.model.PersonQuery;
 import com.uas.credit.model.PersonQuery;
+import com.uas.credit.model.personal.PoliceCheckRoot;
 
 
 /**
 /**
  * 个人身份查询接口
  * 个人身份查询接口
@@ -9,5 +10,5 @@ import com.uas.credit.model.PersonQuery;
  **/
  **/
 public interface PersonalService {
 public interface PersonalService {
 
 
-    String queryAndSave(PersonQuery query);
+    PoliceCheckRoot queryAndSave(PersonQuery query);
 }
 }

+ 3 - 3
src/main/java/com/uas/credit/service/impl/EnCreditInfoServiceImpl.java

@@ -46,7 +46,7 @@ public class EnCreditInfoServiceImpl implements EnCreditInfoService {
      * @return
      * @return
      */
      */
     @Override
     @Override
-    public String queryAndSave(EnterpriseQuery query) {
+    public EncreditinfoRoot queryAndSave(EnterpriseQuery query) {
         //拼装查询的json
         //拼装查询的json
         String encredit = QueryConditionUtil.getEnterpriseQuery(query, ENTERPRISE_CREDIT, SubreportIDs, QueryReasonID);
         String encredit = QueryConditionUtil.getEnterpriseQuery(query, ENTERPRISE_CREDIT, SubreportIDs, QueryReasonID);
 
 
@@ -54,7 +54,7 @@ public class EnCreditInfoServiceImpl implements EnCreditInfoService {
         String encreditResult = erpQueryService.requestApi(pyConfig.getHost(), pyConfig.getPathUnZip(), encredit);
         String encreditResult = erpQueryService.requestApi(pyConfig.getHost(), pyConfig.getPathUnZip(), encredit);
         //保存返回的结果
         //保存返回的结果
         EncreditinfoRoot encreditinfoRoot = JSON.parseObject(encreditResult, EncreditinfoRoot.class);
         EncreditinfoRoot encreditinfoRoot = JSON.parseObject(encreditResult, EncreditinfoRoot.class);
-        EncreditinfoRoot encreditReport1 = creditDao.save(encreditinfoRoot);
-        return encreditResult;
+        creditDao.save(encreditinfoRoot);
+        return encreditinfoRoot;
     }
     }
 }
 }

+ 3 - 3
src/main/java/com/uas/credit/service/impl/EnRiskInfoServiceImpl.java

@@ -45,14 +45,14 @@ public class EnRiskInfoServiceImpl implements EnRiskInfoService {
      * @return
      * @return
      */
      */
     @Override
     @Override
-    public String queryAndSave(EnterpriseQuery query) {
+    public EnRiskInfoRoot queryAndSave(EnterpriseQuery query) {
         //拼装查询的json
         //拼装查询的json
         String enrisk = QueryConditionUtil.getEnterpriseQuery(query, ENTERPRISE_RISK, SubreportIDs, QueryReasonID);
         String enrisk = QueryConditionUtil.getEnterpriseQuery(query, ENTERPRISE_RISK, SubreportIDs, QueryReasonID);
         //发起鹏元征信的请求
         //发起鹏元征信的请求
         String enriskResult = erpQueryService.requestApi(pyConfig.getHost(), pyConfig.getPathUnZip(), enrisk);
         String enriskResult = erpQueryService.requestApi(pyConfig.getHost(), pyConfig.getPathUnZip(), enrisk);
         //保存返回的结果
         //保存返回的结果
         EnRiskInfoRoot enRiskInfoRoot = JSON.parseObject(enriskResult, EnRiskInfoRoot.class);
         EnRiskInfoRoot enRiskInfoRoot = JSON.parseObject(enriskResult, EnRiskInfoRoot.class);
-        EnRiskInfoRoot enRiskInfoRoot1 = enRiskInfoDao.save(enRiskInfoRoot);
-        return enriskResult;
+        enRiskInfoDao.save(enRiskInfoRoot);
+        return enRiskInfoRoot;
     }
     }
 }
 }

+ 3 - 3
src/main/java/com/uas/credit/service/impl/EnexceptionServiceImpl.java

@@ -44,7 +44,7 @@ public class EnexceptionServiceImpl implements EnexceptionService {
      * @return
      * @return
      */
      */
     @Override
     @Override
-    public String queryAndSave(EnterpriseQuery query) {
+    public AbnormalRoot queryAndSave(EnterpriseQuery query) {
         //拼装查询的json
         //拼装查询的json
         String enexception = QueryConditionUtil.getEnterpriseQuery(query, ENTERPRISE_EXCEPTION, SubreportIDs, QueryReasonID);
         String enexception = QueryConditionUtil.getEnterpriseQuery(query, ENTERPRISE_EXCEPTION, SubreportIDs, QueryReasonID);
 
 
@@ -52,7 +52,7 @@ public class EnexceptionServiceImpl implements EnexceptionService {
         String enexceptionResult = erpQueryService.requestApi(pyConfig.getHost(), pyConfig.getPathUnZip(), enexception);
         String enexceptionResult = erpQueryService.requestApi(pyConfig.getHost(), pyConfig.getPathUnZip(), enexception);
         //保存返回的结果
         //保存返回的结果
         AbnormalRoot abnormalRoot = JSON.parseObject(enexceptionResult, AbnormalRoot.class);
         AbnormalRoot abnormalRoot = JSON.parseObject(enexceptionResult, AbnormalRoot.class);
-        AbnormalRoot abnormalReport1 = enexceptionDao.save(abnormalRoot);
-        return enexceptionResult;
+        enexceptionDao.save(abnormalRoot);
+        return abnormalRoot;
     }
     }
 }
 }

+ 3 - 3
src/main/java/com/uas/credit/service/impl/EnterpriseDeptServiceImpl.java

@@ -44,12 +44,12 @@ public class EnterpriseDeptServiceImpl implements EnterpriseDeptService {
      * @return
      * @return
      */
      */
     @Override
     @Override
-    public String queryAndSave(EnterpriseQuery query) {
+    public EndeptinfoRoot queryAndSave(EnterpriseQuery query) {
         String endept = QueryConditionUtil.getEnterpriseQuery(query, ENTERPRISE_DEPT, SubreportIDs, QueryReasonID);
         String endept = QueryConditionUtil.getEnterpriseQuery(query, ENTERPRISE_DEPT, SubreportIDs, QueryReasonID);
 
 
         String endeptResult = erpQueryService.requestApi(pyConfig.getHost(), pyConfig.getPathUnZip(), endept);
         String endeptResult = erpQueryService.requestApi(pyConfig.getHost(), pyConfig.getPathUnZip(), endept);
         EndeptinfoRoot endeptinfoRoot = JSON.parseObject(endeptResult, EndeptinfoRoot.class);
         EndeptinfoRoot endeptinfoRoot = JSON.parseObject(endeptResult, EndeptinfoRoot.class);
-        EndeptinfoRoot endeptinfoRoot1 = enterpriseDeptDao.save(endeptinfoRoot);
-        return endeptResult;
+        enterpriseDeptDao.save(endeptinfoRoot);
+        return endeptinfoRoot;
     }
     }
 }
 }

+ 3 - 3
src/main/java/com/uas/credit/service/impl/PersonCorporationServiceImpl.java

@@ -47,15 +47,15 @@ public class PersonCorporationServiceImpl implements PersonCorporationService {
      * @return
      * @return
      */
      */
     @Override
     @Override
-    public String queryAndSave(PersonQuery query) {
+    public PersonCorporationRoot queryAndSave(PersonQuery query) {
         //拼装查询的json
         //拼装查询的json
         String corporation = QueryConditionUtil.getPersonQuery(query, PERSONAL_SHAREHOLDER, SubreportIDs, QueryReasonID);
         String corporation = QueryConditionUtil.getPersonQuery(query, PERSONAL_SHAREHOLDER, SubreportIDs, QueryReasonID);
         //发起鹏元征信的请求
         //发起鹏元征信的请求
         String corporationResult = erpQueryService.requestApi(pyConfig.getHost(), pyConfig.getPathUnZip(), corporation);
         String corporationResult = erpQueryService.requestApi(pyConfig.getHost(), pyConfig.getPathUnZip(), corporation);
         //保存返回的结果
         //保存返回的结果
         PersonCorporationRoot personCorporationRoot = JSON.parseObject(corporationResult, PersonCorporationRoot.class);
         PersonCorporationRoot personCorporationRoot = JSON.parseObject(corporationResult, PersonCorporationRoot.class);
-        PersonCorporationRoot personCorporationReport1 = personCorporationDao.save(personCorporationRoot);
-        return corporationResult;
+        personCorporationDao.save(personCorporationRoot);
+        return personCorporationRoot;
 
 
     }
     }
 }
 }

+ 3 - 3
src/main/java/com/uas/credit/service/impl/PersonalServiceImpl.java

@@ -46,14 +46,14 @@ public class PersonalServiceImpl implements PersonalService {
      * @return
      * @return
      */
      */
     @Override
     @Override
-    public String queryAndSave(PersonQuery query) {
+    public PoliceCheckRoot queryAndSave(PersonQuery query) {
         //拼装查询的json
         //拼装查询的json
         String person = QueryConditionUtil.getPersonQuery(query, PERSONAL_IDENTITY, SubreportIDs, QueryReasonID);
         String person = QueryConditionUtil.getPersonQuery(query, PERSONAL_IDENTITY, SubreportIDs, QueryReasonID);
         //发起鹏元征信的请求
         //发起鹏元征信的请求
         String prsonResult = erpQueryService.requestApi(pyConfig.getHost(), pyConfig.getPathUnZip(), person);
         String prsonResult = erpQueryService.requestApi(pyConfig.getHost(), pyConfig.getPathUnZip(), person);
         //保存返回的结果
         //保存返回的结果
         PoliceCheckRoot policeCheckRoot = JSON.parseObject(prsonResult, PoliceCheckRoot.class);
         PoliceCheckRoot policeCheckRoot = JSON.parseObject(prsonResult, PoliceCheckRoot.class);
-        PoliceCheckRoot policeCheckRoot1 = personDao.save(policeCheckRoot);
-        return prsonResult;
+        personDao.save(policeCheckRoot);
+        return policeCheckRoot;
     }
     }
 }
 }

+ 4 - 1
src/main/resources/application.yml

@@ -1,3 +1,4 @@
+
 spring:
 spring:
     application:
     application:
         name: credit
         name: credit
@@ -14,4 +15,6 @@ spring:
       multipart:
       multipart:
         enabled: true
         enabled: true
         max-file-size: 512MB
         max-file-size: 512MB
-        max-request-size: 512MB
+        max-request-size: 512MB
+server:
+  port: 8989

File diff suppressed because it is too large
+ 3 - 0
src/main/test/NormalTest.java


Some files were not shown because too many files changed in this diff