liutao 2 zile în urmă
părinte
comite
78528f9a45
79 a modificat fișierele cu 364 adăugiri și 183 ștergeri
  1. 2 2
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/AnHuiHengDaoCreditService.java
  2. 5 1
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/ChuanjinCreditService.java
  3. 15 5
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/DeLuoXuanAesCreditService.java
  4. 14 6
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/DeLuoXuanCreditService.java
  5. 15 4
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/DeZhouXinYiRongCreditService.java
  6. 13 3
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/DeZhouXinYiRongV2CreditService.java
  7. 10 1
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/DfrzwCreditService.java
  8. 8 0
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/FangxinwangiCreditService.java
  9. 8 0
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/FuChengCreditService.java
  10. 11 10
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/FuZhouBeiJiuCreditService.java
  11. 13 3
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/FuZhouBeiYinJinRongCreditService.java
  12. 8 0
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/GexinjinfuCreditService.java
  13. 14 3
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/GuanZhouPuHuiCreditService.java
  14. 14 6
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/GuangDongHaoEnCreditService.java
  15. 14 3
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/GuangDongHongZhanCreditService.java
  16. 16 5
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/GuangZhouHuaXinCreditService.java
  17. 7 0
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/HamiguaCreditService.java
  18. 8 0
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/HaohanwuyinCreditService.java
  19. 7 2
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/HeFeiShenDaiCreditService.java
  20. 4 3
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/HeZeRongXinCreditService.java
  21. 6 1
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/HengYangJiuZhenCreditService.java
  22. 1 1
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/HongShengJinFuCreditService.java
  23. 1 1
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/HongXinPuHuiCreditService.java
  24. 4 3
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/HuNanDiShuiYanCreditService.java
  25. 4 3
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/JilingHuiRongCreditService.java
  26. 6 5
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/JinDieV4CreditService.java
  27. 4 3
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/JinZhuLiCreditService.java
  28. 5 4
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/JindieCreditService.java
  29. 6 5
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/JiuXinKeCreditService.java
  30. 5 4
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/KuaiYiRongCreditService.java
  31. 4 3
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/LeXiangRongCreditService.java
  32. 1 1
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/LianKeYunKongCreditService.java
  33. 4 3
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/LiaoChengXinYiDaiCreditService.java
  34. 1 1
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/MoGuTouCreditService.java
  35. 1 1
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/NanTongXingChengCreditService.java
  36. 5 4
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/NiYouKeCreditService.java
  37. 4 3
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/NingBoTianChengCreditService.java
  38. 1 1
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/PingDingShanCreditService.java
  39. 1 1
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/QingDaoAoSengCreditService.java
  40. 2 2
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/QingDaoAoSengV2CreditService.java
  41. 4 3
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/RongChuangJinFuCreditService.java
  42. 4 3
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/RongXiangDaChangShaCreditService.java
  43. 4 3
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/RongXiangKeBuShuCreditService.java
  44. 4 3
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/RongXiangKeV2CreditService.java
  45. 1 1
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/RongYiDaCreditService.java
  46. 1 1
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/RongxiziCreditService.java
  47. 4 3
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/RunMeiXinYiRongCreditService.java
  48. 1 1
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/ShanDongBangBangDaiCreditService.java
  49. 6 5
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/ShanXiMingDePuHuiCreditService.java
  50. 1 1
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/ShangHaiHanGeCreditService.java
  51. 4 3
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/ShangHaiJuHuiRongCreditService.java
  52. 1 1
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/ShenYangHengXinCreditService.java
  53. 4 3
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/ShenYangXinYiRongCreditService.java
  54. 1 1
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/ShiYueCreditService.java
  55. 4 3
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/ShuRongCreditService.java
  56. 4 3
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/SiChuangRuiCreditService.java
  57. 1 1
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/SouYuJinFuCreditService.java
  58. 4 3
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/SuZhouJianYiRongCreditService.java
  59. 1 1
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/SuzhouchangshuoCreditService.java
  60. 6 5
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/TangShanRongYangCreditService.java
  61. 4 3
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/TianJingJiaYiCreditService.java
  62. 1 1
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/TianShuiShuYiRongCreditService.java
  63. 4 3
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/WeiFangYouYiCreditService.java
  64. 1 1
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/WenZhouGaoShenCreditService.java
  65. 1 1
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/WenZhouYueShangXiangCreditService.java
  66. 1 1
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/WuHanDongYuanCreditService.java
  67. 2 2
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/WuHanJingChengCreditService.java
  68. 1 1
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/XiaMenYiJieZhuDaiCreditService.java
  69. 1 1
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/XinChuangYinHuiCreditService.java
  70. 4 3
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/XinJiangWanHeCreditService.java
  71. 1 1
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/XinZheChangZhiCreditService.java
  72. 1 1
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/XuzhoufuliV2CreditService.java
  73. 1 1
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/YangZhouWanKeCreditService.java
  74. 1 1
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/YiLianRongCreditService.java
  75. 1 1
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/YiRongCreditService.java
  76. 1 1
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/YiZhanShiShuZhiPingTaiCreditService.java
  77. 1 1
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/YukuaihuaCreditService.java
  78. 1 1
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/YunHaiLianDongCreditService.java
  79. 4 3
      egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/ZhaoZhuangXinYiRongCreditService.java

+ 2 - 2
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/AnHuiHengDaoCreditService.java

@@ -76,10 +76,10 @@ public class AnHuiHengDaoCreditService implements LoanDockingApi {
      * @param product
      * @return
      */
-    public DataVo qualityCheck(UserBaseInfoCmd userInfo, PlanCmd product, EgLoanApiConfigInfoCmd    configInfo, Function<HttpApiRequest, HttpApiResponse> httpClientFunc) {
+    public DataVo qualityCheck(UserBaseInfoCmd userInfo, PlanCmd product, EgLoanApiConfigInfoCmd configInfo, Function<HttpApiRequest, HttpApiResponse> httpClientFunc) {
         try {
             log.info("credit AnHuiHengDaoCreditService qualityCheck begin...userId:{}",userInfo.getUserId());
-           
+
             byte[] requestConfig = configInfo.getRequestConfig();
             Object deserialize = HessianUtils.deserialize(requestConfig);
             JSONObject config = JSONObject.parseObject(deserialize.toString());

+ 5 - 1
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/ChuanjinCreditService.java

@@ -3,12 +3,16 @@ package com.hrsk.cloud.eg.domain.api.channel.customized.threedocking.impl;
 
 import com.alibaba.fastjson2.JSON;
 import com.alibaba.fastjson2.JSONObject;
+import com.google.common.base.Function;
 import com.hrsk.cloud.eg.client.dto.plan.command.EgLoanApiConfigInfoCmd;
 import com.hrsk.cloud.eg.client.dto.plan.command.PlanCmd;
 import com.hrsk.cloud.eg.client.dto.user.command.UserBaseInfoCmd;
 import com.hrsk.cloud.eg.client.vo.DataVo;
 import com.hrsk.cloud.eg.domain.api.channel.customized.common.ServerCodeEnums;
 import com.hrsk.cloud.eg.domain.api.channel.customized.threedocking.LoanDockingApi;
+import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiRequest;
+import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiResponse;
+import com.hrsk.cloud.eg.domain.common.HessianUtils;
 import lombok.Data;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
@@ -62,7 +66,7 @@ public class ChuanjinCreditService implements LoanDockingApi {
     }
 
 
-    public DataVo qualityCheck(UserBaseInfoCmd userInfo, PlanCmd product, EgLoanApiConfigInfoCmd    configInfo, Function<HttpApiRequest, HttpApiResponse> httpClientFunc)  {
+    public DataVo qualityCheck(UserBaseInfoCmd userInfo, PlanCmd product, EgLoanApiConfigInfoCmd configInfo, Function<HttpApiRequest, HttpApiResponse> httpClientFunc)  {
         try {
             log.info("credit ChuanjinCreditService qualityCheck begin...userId:{}", userInfo.getUserId());
 

+ 15 - 5
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/DeLuoXuanAesCreditService.java

@@ -2,10 +2,19 @@ package com.hrsk.cloud.eg.domain.api.channel.customized.threedocking.impl;
 
 import com.alibaba.fastjson2.JSON;
 import com.alibaba.fastjson2.JSONObject;
+import com.google.common.base.Function;
 import com.hrsk.cloud.eg.client.dto.plan.command.EgLoanApiConfigInfoCmd;
 import com.hrsk.cloud.eg.client.dto.plan.command.PlanCmd;
 import com.hrsk.cloud.eg.client.dto.user.command.UserBaseInfoCmd;
 
+import com.hrsk.cloud.eg.client.vo.DataVo;
+import com.hrsk.cloud.eg.domain.api.channel.customized.common.ServerCodeEnums;
+import com.hrsk.cloud.eg.domain.api.channel.customized.threedocking.LoanDockingApi;
+import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiRequest;
+import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiRequestConfig;
+import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiResponse;
+import com.hrsk.cloud.eg.domain.common.HessianUtils;
+import com.hrsk.cloud.eg.domain.common.Md5Util;
 import lombok.Data;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
@@ -58,7 +67,7 @@ public class DeLuoXuanAesCreditService implements LoanDockingApi {
         private Integer platform_id;//不需要回传值为 0,回传必传(平台提供)
     }
 
-    public DataVo qualityCheck(UserBaseInfoCmd userInfo, PlanCmd product, EgLoanApiConfigInfoCmd    configInfo, Function<HttpApiRequest, HttpApiResponse> httpClientFunc)  {
+    public DataVo qualityCheck(UserBaseInfoCmd userInfo, PlanCmd product, EgLoanApiConfigInfoCmd configInfo, Function<HttpApiRequest, HttpApiResponse> httpClientFunc)  {
         try {
             log.info("credit DeLuoXuanAesCreditService qualityCheck begin...userId:{}",userInfo.getUserId());
 
@@ -72,9 +81,10 @@ public class DeLuoXuanAesCreditService implements LoanDockingApi {
             checkInfo.setCompany_id(config.getInteger("company_id"));
             String url = config.getString("checkUrl");
             log.info("credit qualityCheck DeLuoXuanAesCreditService request userId:{}, url:{}, CheckInfo:{}",userInfo.getUserId(), url, phoneMd5);
-            String response = null;
-            try{
-                response =httpRestTemplate.restTemplate().postForObject(url,checkInfo, String.class);
+            HttpApiResponse response = null;
+            try {
+                HttpApiRequest request=new HttpApiRequest(HttpApiRequestConfig.postRequest(JSON.toJSONString(checkInfo),"post",url));
+                response =httpClientFunc.apply(request);
             }catch (Exception e){
                 log.error("德诺轩AES准入异常,异常信息:{}", e.getMessage(), e);
             }
@@ -82,7 +92,7 @@ public class DeLuoXuanAesCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(),product.getPlanName());
             }
-            JSONObject jsonObject=JSONObject.parseObject(response);
+            JSONObject jsonObject = JSONObject.parseObject(response.getData().toString());
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());
             }

+ 14 - 6
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/DeLuoXuanCreditService.java

@@ -2,15 +2,22 @@ package com.hrsk.cloud.eg.domain.api.channel.customized.threedocking.impl;
 
 import com.alibaba.fastjson2.JSON;
 import com.alibaba.fastjson2.JSONObject;
+import com.google.common.base.Function;
 import com.hrsk.cloud.eg.client.dto.plan.command.EgLoanApiConfigInfoCmd;
 import com.hrsk.cloud.eg.client.dto.plan.command.PlanCmd;
 import com.hrsk.cloud.eg.client.dto.user.command.UserBaseInfoCmd;
+import com.hrsk.cloud.eg.client.vo.DataVo;
+import com.hrsk.cloud.eg.domain.api.channel.customized.common.ServerCodeEnums;
 import com.hrsk.cloud.eg.domain.api.channel.customized.threedocking.LoanDockingApi;
+import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiRequest;
+import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiRequestConfig;
+import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiResponse;
+import com.hrsk.cloud.eg.domain.common.HessianUtils;
+import com.hrsk.cloud.eg.domain.common.Md5Util;
 import lombok.Data;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
 
-import javax.annotation.Resource;
 
 /**
  * @Author Liu Tao
@@ -58,7 +65,7 @@ public class DeLuoXuanCreditService implements LoanDockingApi {
 
     }
 
-    public DataVo qualityCheck(UserBaseInfoCmd userInfo, PlanCmd product, EgLoanApiConfigInfoCmd    configInfo, Function<HttpApiRequest, HttpApiResponse> httpClientFunc)  {
+    public DataVo qualityCheck(UserBaseInfoCmd userInfo, PlanCmd product, EgLoanApiConfigInfoCmd configInfo, Function<HttpApiRequest, HttpApiResponse> httpClientFunc)  {
         try {
             log.info("credit DeLuoXuanCreditService qualityCheck begin...userId:{}",userInfo.getUserId());
 
@@ -71,9 +78,10 @@ public class DeLuoXuanCreditService implements LoanDockingApi {
             checkInfo.setMd5Phone(phoneMd5);
             String url = config.getString("checkUrl");
             log.info("credit qualityCheck DeLuoXuanCreditService request userId:{}, url:{}, CheckInfo:{}",userInfo.getUserId(), url, phoneMd5);
-            String response = null;
-            try{
-                response =httpRestTemplate.restTemplate().postForObject(url,checkInfo, String.class);
+            HttpApiResponse response = null;
+            try {
+                HttpApiRequest request=new HttpApiRequest(HttpApiRequestConfig.postRequest(JSON.toJSONString(checkInfo),"post",url));
+                response =httpClientFunc.apply(request);
             }catch (Exception e){
                 log.error("德诺轩准入异常,异常信息:{}", e.getMessage(), e);
             }
@@ -81,7 +89,7 @@ public class DeLuoXuanCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(),product.getPlanName());
             }
-            JSONObject jsonObject=JSONObject.parseObject(response);
+            JSONObject jsonObject = JSONObject.parseObject(response.getData().toString());
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());
             }

+ 15 - 4
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/DeZhouXinYiRongCreditService.java

@@ -1,10 +1,20 @@
 package com.hrsk.cloud.eg.domain.api.channel.customized.threedocking.impl;
 
+import com.alibaba.fastjson2.JSON;
 import com.alibaba.fastjson2.JSONObject;
+import com.google.common.base.Function;
 import com.hrsk.cloud.eg.client.dto.plan.command.EgLoanApiConfigInfoCmd;
 import com.hrsk.cloud.eg.client.dto.plan.command.PlanCmd;
 import com.hrsk.cloud.eg.client.dto.user.command.UserBaseInfoCmd;
 
+import com.hrsk.cloud.eg.client.vo.DataVo;
+import com.hrsk.cloud.eg.domain.api.channel.customized.common.ServerCodeEnums;
+import com.hrsk.cloud.eg.domain.api.channel.customized.threedocking.LoanDockingApi;
+import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiRequest;
+import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiRequestConfig;
+import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiResponse;
+import com.hrsk.cloud.eg.domain.common.HessianUtils;
+import com.hrsk.cloud.eg.domain.common.Md5Util;
 import lombok.Data;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
@@ -63,7 +73,7 @@ public class DeZhouXinYiRongCreditService implements LoanDockingApi {
         private Integer fund;//公积金 1:有 2:无
     }
 
-    public DataVo qualityCheck(UserBaseInfoCmd userInfo, PlanCmd product, EgLoanApiConfigInfoCmd    configInfo)  {
+    public DataVo qualityCheck(UserBaseInfoCmd userInfo, PlanCmd product, EgLoanApiConfigInfoCmd    configInfo, Function<HttpApiRequest, HttpApiResponse> httpClientFunc)  {
         try {
             log.info("credit DeZhouXinYiRongCreditService qualityCheck begin...userId:{}",userInfo.getUserId());
 
@@ -77,9 +87,10 @@ public class DeZhouXinYiRongCreditService implements LoanDockingApi {
             checkInfo.setWxapp_id(config.getString("wxapp_id"));
             String url=config.getString("http")+config.getString("index")+config.getString("parameter1")+config.getString("parameter2")+config.getString("parameter3")+config.getString("checkParmeter");
             log.info("credit qualityCheck DeZhouXinYiRongCreditService request userId:{}, url:{}, CheckInfo:{}",userInfo.getUserId(), url, checkInfo);
-            String response = null;
+            HttpApiResponse response = null;
             try{
-                response =httpRestTemplate.restTemplate().postForObject(url,checkInfo, String.class);
+                HttpApiRequest request=new HttpApiRequest(HttpApiRequestConfig.postRequest(JSON.toJSONString(checkInfo),"post",url));
+                response =httpClientFunc.apply(request);
             }catch (Exception e){
                 log.error("德州鑫易融准入异常,异常信息:{}", e.getMessage(), e);
             }
@@ -87,7 +98,7 @@ public class DeZhouXinYiRongCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(),product.getPlanName());
             }
-            JSONObject jsonObject=JSONObject.parseObject(response);
+            JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
 
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());

+ 13 - 3
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/DeZhouXinYiRongV2CreditService.java

@@ -2,10 +2,19 @@ package com.hrsk.cloud.eg.domain.api.channel.customized.threedocking.impl;
 
 import com.alibaba.fastjson2.JSON;
 import com.alibaba.fastjson2.JSONObject;
+import com.google.common.base.Function;
 import com.hrsk.cloud.eg.client.dto.plan.command.EgLoanApiConfigInfoCmd;
 import com.hrsk.cloud.eg.client.dto.plan.command.PlanCmd;
 import com.hrsk.cloud.eg.client.dto.user.command.UserBaseInfoCmd;
 
+import com.hrsk.cloud.eg.client.vo.DataVo;
+import com.hrsk.cloud.eg.domain.api.channel.customized.common.ServerCodeEnums;
+import com.hrsk.cloud.eg.domain.api.channel.customized.threedocking.LoanDockingApi;
+import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiRequest;
+import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiRequestConfig;
+import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiResponse;
+import com.hrsk.cloud.eg.domain.common.HessianUtils;
+import com.hrsk.cloud.eg.domain.common.Md5Util;
 import lombok.Data;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
@@ -74,9 +83,10 @@ public class DeZhouXinYiRongV2CreditService implements LoanDockingApi {
             checkInfo.setMobile_md5(phoneMd5);
             String url=config.getString("checkUrl")+"?company="+config.getString("company")+"&mobile_md5="+checkInfo.getMobile_md5();
             log.info("credit qualityCheck DeZhouXinYiRongV2CreditService request userId:{}, url:{}, CheckInfo:{}",userInfo.getUserId(), url, checkInfo);
-            String response = null;
+            HttpApiResponse response = null;
             try{
-                response =httpRestTemplate.restTemplate().postForObject(url,checkInfo, String.class);
+                HttpApiRequest request=new HttpApiRequest(HttpApiRequestConfig.postRequest(JSON.toJSONString(checkInfo),"post",url));
+                response =httpClientFunc.apply(request);
             }catch (Exception e){
                 log.error("德州鑫易融V2准入异常,异常信息:{}", e.getMessage(), e);
             }
@@ -84,7 +94,7 @@ public class DeZhouXinYiRongV2CreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(),product.getPlanName());
             }
-            JSONObject jsonObject=JSONObject.parseObject(response);
+             JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
 
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());

+ 10 - 1
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/DfrzwCreditService.java

@@ -1,10 +1,19 @@
 package com.hrsk.cloud.eg.domain.api.channel.customized.threedocking.impl;
 
 import com.alibaba.fastjson2.JSONObject;
+import com.google.common.base.Function;
 import com.hrsk.cloud.eg.client.dto.plan.command.EgLoanApiConfigInfoCmd;
 import com.hrsk.cloud.eg.client.dto.plan.command.PlanCmd;
 import com.hrsk.cloud.eg.client.dto.user.command.UserBaseInfoCmd;
+import com.hrsk.cloud.eg.client.vo.DataVo;
 import com.hrsk.cloud.eg.clinet.vo.DataVo;
+import com.hrsk.cloud.eg.domain.api.channel.customized.common.ServerCodeEnums;
+import com.hrsk.cloud.eg.domain.api.channel.customized.threedocking.LoanDockingApi;
+import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiRequest;
+import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiResponse;
+import com.hrsk.cloud.eg.domain.common.DateUtil;
+import com.hrsk.cloud.eg.domain.common.HessianUtils;
+import com.hrsk.cloud.eg.domain.common.Md5Util;
 import com.hrsk.cloud.eg.infrastructure.config.client.HessianUtils;
 import com.hrsk.cloud.eg.infrastructure.loanMannager.threedocking.LoanDockingApi;
 import com.hrsk.cloud.eg.infrastructure.service.EgApiService;
@@ -81,7 +90,7 @@ public class DfrzwCreditService implements LoanDockingApi {
             String response = httpRestTemplate.restTemplate().postForObject(url + ISREGISTERED, body.toJSONString(), String.class);
             log.info("credit qualityCheck DfrzwCreditService userId:{}, response:{}", userInfo.getUserId(), response);
             if (!StringUtils.isBlank(response)) {
-                JSONObject jsonObject = JSONObject.parseObject(response);
+                  JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
                 if (jsonObject.getIntValue("Code") == 0) {
                     Boolean isRegistered = jsonObject.getBoolean("IsRegistered");
                     if (!isRegistered) {

+ 8 - 0
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/FangxinwangiCreditService.java

@@ -2,10 +2,18 @@ package com.hrsk.cloud.eg.domain.api.channel.customized.threedocking.impl;
 
 import com.alibaba.fastjson2.JSON;
 import com.alibaba.fastjson2.JSONObject;
+import com.google.common.base.Function;
 import com.hrsk.cloud.eg.client.dto.plan.command.EgLoanApiConfigInfoCmd;
 import com.hrsk.cloud.eg.client.dto.plan.command.PlanCmd;
 import com.hrsk.cloud.eg.client.dto.user.command.UserBaseInfoCmd;
 
+import com.hrsk.cloud.eg.client.vo.DataVo;
+import com.hrsk.cloud.eg.domain.api.channel.customized.common.ServerCodeEnums;
+import com.hrsk.cloud.eg.domain.api.channel.customized.threedocking.LoanDockingApi;
+import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiRequest;
+import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiResponse;
+import com.hrsk.cloud.eg.domain.common.HessianUtils;
+import com.hrsk.cloud.eg.domain.common.Md5Util;
 import lombok.Data;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.http.HttpResponse;

+ 8 - 0
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/FuChengCreditService.java

@@ -2,10 +2,18 @@ package com.hrsk.cloud.eg.domain.api.channel.customized.threedocking.impl;
 
 import com.alibaba.fastjson2.JSON;
 import com.alibaba.fastjson2.JSONObject;
+import com.google.common.base.Function;
 import com.hrsk.cloud.eg.client.dto.plan.command.EgLoanApiConfigInfoCmd;
 import com.hrsk.cloud.eg.client.dto.plan.command.PlanCmd;
 import com.hrsk.cloud.eg.client.dto.user.command.UserBaseInfoCmd;
 
+import com.hrsk.cloud.eg.client.vo.DataVo;
+import com.hrsk.cloud.eg.domain.api.channel.customized.common.ServerCodeEnums;
+import com.hrsk.cloud.eg.domain.api.channel.customized.threedocking.LoanDockingApi;
+import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiRequest;
+import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiResponse;
+import com.hrsk.cloud.eg.domain.common.HessianUtils;
+import com.hrsk.cloud.eg.domain.common.Md5Util;
 import lombok.Data;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.codec.binary.Base64;

+ 11 - 10
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/FuZhouBeiJiuCreditService.java

@@ -3,19 +3,19 @@ package com.hrsk.cloud.eg.domain.api.channel.customized.threedocking.impl;
 import com.alibaba.fastjson2.JSON;
 import com.alibaba.fastjson2.JSONArray;
 import com.alibaba.fastjson2.JSONObject;
+import com.google.common.base.Function;
 import com.hrsk.cloud.eg.client.dto.plan.command.PlanCmd;
 import com.hrsk.cloud.eg.client.dto.user.command.UserBaseInfoCmd;
 import com.hrsk.cloud.eg.client.vo.DataVo;
-import com.hrsk.cloud.eg.clinet.vo.DataVo;
 import com.hrsk.cloud.eg.domain.api.channel.customized.common.ServerCodeEnums;
 import com.hrsk.cloud.eg.domain.api.channel.customized.threedocking.LoanDockingApi;
+import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiRequest;
+import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiRequestConfig;
+import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiResponse;
 import com.hrsk.cloud.eg.domain.common.HessianUtils;
-import com.hrsk.cloud.eg.infrastructure.config.client.HessianUtils;
-import com.hrsk.cloud.eg.infrastructure.loanMannager.threedocking.LoanDockingApi;
-import com.hrsk.cloud.eg.infrastructure.service.EgApiService;
-import com.hrsk.cloud.eg.infrastructure.utils.Md5Util;
 import com.hrsk.cloud.eg.client.dto.plan.command.EgLoanApiConfigInfoCmd;
 
+import com.hrsk.cloud.eg.domain.common.Md5Util;
 import lombok.Data;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
@@ -47,7 +47,7 @@ public class FuZhouBeiJiuCreditService implements LoanDockingApi {
     }
 
 
-    public DataVo qualityCheck(UserBaseInfoCmd userInfo, PlanCmd product, EgLoanApiConfigInfoCmd    configInfo)  {
+    public DataVo qualityCheck(UserBaseInfoCmd userInfo, PlanCmd product, EgLoanApiConfigInfoCmd configInfo, Function<HttpApiRequest, HttpApiResponse> httpClientFunc)  {
         try {
             log.info("credit FuZhouBeiJiuCreditService qualityCheck begin...userId:{}",userInfo.getUserId());
 
@@ -63,9 +63,10 @@ public class FuZhouBeiJiuCreditService implements LoanDockingApi {
                 put("data", jsonArray);
             }};
             log.info("credit qualityCheck FuZhouBeiJiuCreditService request userId:{}, url:{}, CheckInfo:{}",userInfo.getUserId(), url, json);
-            String response = null;
-            try {
-                response = httpRestTemplate.restTemplate().postForObject(url, json, String.class);
+            HttpApiResponse response = null;
+            try{
+                HttpApiRequest request=new HttpApiRequest(HttpApiRequestConfig.postRequest(JSON.toJSONString(json),"post",url));
+                response =httpClientFunc.apply(request);
             } catch (Exception e) {
                 log.error("福州北久准入异常,异常信息:{}", e.getMessage(), e);
             }
@@ -73,7 +74,7 @@ public class FuZhouBeiJiuCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());
             }
-            JSONObject jsonObject = JSONObject.parseObject(response);
+              JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());
             }

+ 13 - 3
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/FuZhouBeiYinJinRongCreditService.java

@@ -2,10 +2,19 @@ package com.hrsk.cloud.eg.domain.api.channel.customized.threedocking.impl;
 
 import com.alibaba.fastjson2.JSON;
 import com.alibaba.fastjson2.JSONObject;
+import com.google.common.base.Function;
 import com.hrsk.cloud.eg.client.dto.plan.command.EgLoanApiConfigInfoCmd;
 import com.hrsk.cloud.eg.client.dto.plan.command.PlanCmd;
 import com.hrsk.cloud.eg.client.dto.user.command.UserBaseInfoCmd;
 
+import com.hrsk.cloud.eg.client.vo.DataVo;
+import com.hrsk.cloud.eg.domain.api.channel.customized.common.ServerCodeEnums;
+import com.hrsk.cloud.eg.domain.api.channel.customized.threedocking.LoanDockingApi;
+import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiRequest;
+import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiRequestConfig;
+import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiResponse;
+import com.hrsk.cloud.eg.domain.common.HessianUtils;
+import com.hrsk.cloud.eg.domain.common.Md5Util;
 import lombok.Data;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
@@ -95,9 +104,10 @@ public class FuZhouBeiYinJinRongCreditService implements LoanDockingApi {
             checkInfo.setChannelCode(config.getString("channelCode"));
             String url = config.getString("checkUrl");
             log.info("credit qualityCheck FuZhouBeiYinJinRongCreditService request userId:{}, url:{}, CheckInfo:{}",userInfo.getUserId(), url, checkInfo);
-            String response = null;
+            HttpApiResponse response = null;
             try{
-                response =httpRestTemplate.restTemplate().postForObject(url,checkInfo, String.class);
+                HttpApiRequest request=new HttpApiRequest(HttpApiRequestConfig.postRequest(JSON.toJSONString(checkInfo),"post",url));
+                response =httpClientFunc.apply(request);
             }catch (Exception e){
                 log.error("福州北银金融准入异常,异常信息:{}", e.getMessage(), e);
             }
@@ -105,7 +115,7 @@ public class FuZhouBeiYinJinRongCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(),product.getPlanName());
             }
-            JSONObject jsonObject=JSONObject.parseObject(response);
+             JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
 
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());

+ 8 - 0
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/GexinjinfuCreditService.java

@@ -2,10 +2,18 @@ package com.hrsk.cloud.eg.domain.api.channel.customized.threedocking.impl;
 
 import com.alibaba.fastjson2.JSON;
 import com.alibaba.fastjson2.JSONObject;
+import com.google.common.base.Function;
 import com.hrsk.cloud.eg.client.dto.plan.command.EgLoanApiConfigInfoCmd;
 import com.hrsk.cloud.eg.client.dto.plan.command.PlanCmd;
 import com.hrsk.cloud.eg.client.dto.user.command.UserBaseInfoCmd;
 
+import com.hrsk.cloud.eg.client.vo.DataVo;
+import com.hrsk.cloud.eg.domain.api.channel.customized.common.ServerCodeEnums;
+import com.hrsk.cloud.eg.domain.api.channel.customized.threedocking.LoanDockingApi;
+import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiRequest;
+import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiResponse;
+import com.hrsk.cloud.eg.domain.common.HessianUtils;
+import com.hrsk.cloud.eg.domain.common.Md5Util;
 import lombok.Data;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;

+ 14 - 3
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/GuanZhouPuHuiCreditService.java

@@ -1,10 +1,20 @@
 package com.hrsk.cloud.eg.domain.api.channel.customized.threedocking.impl;
 
+import com.alibaba.fastjson2.JSON;
 import com.alibaba.fastjson2.JSONObject;
+import com.google.common.base.Function;
 import com.hrsk.cloud.eg.client.dto.plan.command.EgLoanApiConfigInfoCmd;
 import com.hrsk.cloud.eg.client.dto.plan.command.PlanCmd;
 import com.hrsk.cloud.eg.client.dto.user.command.UserBaseInfoCmd;
 
+import com.hrsk.cloud.eg.client.vo.DataVo;
+import com.hrsk.cloud.eg.domain.api.channel.customized.common.ServerCodeEnums;
+import com.hrsk.cloud.eg.domain.api.channel.customized.threedocking.LoanDockingApi;
+import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiRequest;
+import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiRequestConfig;
+import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiResponse;
+import com.hrsk.cloud.eg.domain.common.HessianUtils;
+import com.hrsk.cloud.eg.domain.common.Md5Util;
 import lombok.Data;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
@@ -65,9 +75,10 @@ public class GuanZhouPuHuiCreditService  implements LoanDockingApi {
             checkInfo.setMobile(Phone_md5);
             String url = config.getString("checkUrl");
             log.info("credit qualityCheck GuanZhouPuHuiCreditService request userId:{}, url:{}, CheckInfo:{}",userInfo.getUserId(), url, checkInfo);
-            String response = null;
+            HttpApiResponse response = null;
             try{
-                response =httpRestTemplate.restTemplate().postForObject(url,checkInfo, String.class);
+                HttpApiRequest request=new HttpApiRequest(HttpApiRequestConfig.postRequest(JSON.toJSONString(checkInfo),"post",url));
+                response =httpClientFunc.apply(request);
             }catch (Exception e){
                 log.error("广州普惠准入异常,异常信息:{}", e.getMessage(), e);
             }
@@ -75,7 +86,7 @@ public class GuanZhouPuHuiCreditService  implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(),product.getPlanName());
             }
-            JSONObject jsonObject=JSONObject.parseObject(response);
+             JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
             log.info("credit qualityCheck GuanZhouPuHuiCreditService response md5Phone:{}, jsonObject:{}",userInfo.getUserId(), jsonObject);
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());

+ 14 - 6
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/GuangDongHaoEnCreditService.java

@@ -1,16 +1,23 @@
 package com.hrsk.cloud.eg.domain.api.channel.customized.threedocking.impl;
 
+import com.alibaba.fastjson2.JSON;
 import com.alibaba.fastjson2.JSONObject;
+import com.google.common.base.Function;
 import com.hrsk.cloud.eg.client.dto.plan.command.EgLoanApiConfigInfoCmd;
 import com.hrsk.cloud.eg.client.dto.plan.command.PlanCmd;
 import com.hrsk.cloud.eg.client.dto.user.command.UserBaseInfoCmd;
-
+import com.hrsk.cloud.eg.client.vo.DataVo;
+import com.hrsk.cloud.eg.domain.api.channel.customized.common.ServerCodeEnums;
+import com.hrsk.cloud.eg.domain.api.channel.customized.threedocking.LoanDockingApi;
+import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiRequest;
+import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiRequestConfig;
+import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiResponse;
+import com.hrsk.cloud.eg.domain.common.HessianUtils;
+import com.hrsk.cloud.eg.domain.common.Md5Util;
 import lombok.Data;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
 
-import javax.annotation.Resource;
-
 /**
  * @Author Liu Tao
  * @Date 2023 09 22 17 08
@@ -68,9 +75,10 @@ public class GuangDongHaoEnCreditService implements LoanDockingApi {
             checkInfo.setAppid(config.getString("appid"));
             String url = config.getString("checkUrl");
             log.info("credit qualityCheck GuangDongHaoEnCreditService request userId:{}, url:{}, CheckInfo:{}",userInfo.getUserId(), url, checkInfo);
-            String response = null;
+            HttpApiResponse response = null;
             try{
-                response =httpRestTemplate.restTemplate().postForObject(url,checkInfo, String.class);
+                HttpApiRequest request=new HttpApiRequest(HttpApiRequestConfig.postRequest(JSON.toJSONString(checkInfo),"post",url));
+                response =httpClientFunc.apply(request);
             }catch (Exception e){
                 log.error("广东昊恩准入异常,异常信息:{}", e.getMessage(), e);
             }
@@ -78,7 +86,7 @@ public class GuangDongHaoEnCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(),product.getPlanName());
             }
-            JSONObject jsonObject=JSONObject.parseObject(response);
+             JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
 
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());

+ 14 - 3
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/GuangDongHongZhanCreditService.java

@@ -1,10 +1,20 @@
 package com.hrsk.cloud.eg.domain.api.channel.customized.threedocking.impl;
 
+import com.alibaba.fastjson2.JSON;
 import com.alibaba.fastjson2.JSONObject;
+import com.google.common.base.Function;
 import com.hrsk.cloud.eg.client.dto.plan.command.EgLoanApiConfigInfoCmd;
 import com.hrsk.cloud.eg.client.dto.plan.command.PlanCmd;
 import com.hrsk.cloud.eg.client.dto.user.command.UserBaseInfoCmd;
 
+import com.hrsk.cloud.eg.client.vo.DataVo;
+import com.hrsk.cloud.eg.domain.api.channel.customized.common.ServerCodeEnums;
+import com.hrsk.cloud.eg.domain.api.channel.customized.threedocking.LoanDockingApi;
+import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiRequest;
+import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiRequestConfig;
+import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiResponse;
+import com.hrsk.cloud.eg.domain.common.HessianUtils;
+import com.hrsk.cloud.eg.domain.common.Md5Util;
 import lombok.Data;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
@@ -54,9 +64,10 @@ import javax.annotation.Resource;
             String url = config.getString("checkUrl");
 
             log.info("credit qualityCheck GuangDongHongZhanCreditService request userId:{}, url:{}, checkInfo:{}",userInfo.getUserId(), url, checkInfo);
-            String response = null;
+            HttpApiResponse response = null;
             try{
-                response =httpRestTemplate.restTemplate().postForObject(url,checkInfo, String.class);
+                HttpApiRequest request=new HttpApiRequest(HttpApiRequestConfig.postRequest(JSON.toJSONString(checkInfo),"post",url));
+                response =httpClientFunc.apply(request);
             }catch (Exception e){
                 log.error("广东鸿展准入异常,异常信息:{}", e.getMessage(), e);
             }
@@ -64,7 +75,7 @@ import javax.annotation.Resource;
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(),product.getPlanName());
             }
-            JSONObject jsonObject=JSONObject.parseObject(response);
+             JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
 
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());

+ 16 - 5
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/GuangZhouHuaXinCreditService.java

@@ -1,10 +1,20 @@
 package com.hrsk.cloud.eg.domain.api.channel.customized.threedocking.impl;
 
+import com.alibaba.fastjson2.JSON;
 import com.alibaba.fastjson2.JSONObject;
+import com.google.common.base.Function;
 import com.hrsk.cloud.eg.client.dto.plan.command.EgLoanApiConfigInfoCmd;
 import com.hrsk.cloud.eg.client.dto.plan.command.PlanCmd;
 import com.hrsk.cloud.eg.client.dto.user.command.UserBaseInfoCmd;
 
+import com.hrsk.cloud.eg.client.vo.DataVo;
+import com.hrsk.cloud.eg.domain.api.channel.customized.common.ServerCodeEnums;
+import com.hrsk.cloud.eg.domain.api.channel.customized.threedocking.LoanDockingApi;
+import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiRequest;
+import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiRequestConfig;
+import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiResponse;
+import com.hrsk.cloud.eg.domain.common.HessianUtils;
+import com.hrsk.cloud.eg.domain.common.Md5Util;
 import lombok.Data;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
@@ -95,17 +105,18 @@ public class GuangZhouHuaXinCreditService implements LoanDockingApi {
             checkInfo.setAppKey(config.getString("AppKey"));
             checkInfo.setSign(sign);
             log.info("credit qualityCheck GuangZhouHuaXinCreditService request userId:{}, url:{}, CheckInfo:{}",userInfo.getUserId(), url, checkInfo);
-            String response = null;
-            try {
-                response = httpRestTemplate.restTemplate().postForObject(url, checkInfo, String.class);
-            } catch (Exception e) {
+            HttpApiResponse response = null;
+            try{
+                HttpApiRequest request=new HttpApiRequest(HttpApiRequestConfig.postRequest(JSON.toJSONString(checkInfo),"post",url));
+                response =httpClientFunc.apply(request);
+            }catch (Exception e) {
                 log.error("广州华鑫准入异常,异常信息:{}", e.getMessage(), e);
             }
             log.info("credit qualityCheck GuangZhouHuaXinCreditService response userId:{}, result:{}", userInfo.getUserId(), response);
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());
             }
-            JSONObject jsonObject = JSONObject.parseObject(response);
+              JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());
             }

+ 7 - 0
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/HamiguaCreditService.java

@@ -2,10 +2,17 @@ package com.hrsk.cloud.eg.domain.api.channel.customized.threedocking.impl;
 
 import com.alibaba.fastjson2.JSON;
 import com.alibaba.fastjson2.JSONObject;
+import com.google.common.base.Function;
 import com.hrsk.cloud.eg.client.dto.plan.command.EgLoanApiConfigInfoCmd;
 import com.hrsk.cloud.eg.client.dto.plan.command.PlanCmd;
 import com.hrsk.cloud.eg.client.dto.user.command.UserBaseInfoCmd;
+import com.hrsk.cloud.eg.client.vo.DataVo;
 import com.hrsk.cloud.eg.clinet.vo.DataVo;
+import com.hrsk.cloud.eg.domain.api.channel.customized.common.ServerCodeEnums;
+import com.hrsk.cloud.eg.domain.api.channel.customized.threedocking.LoanDockingApi;
+import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiRequest;
+import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiResponse;
+import com.hrsk.cloud.eg.domain.common.HessianUtils;
 import com.hrsk.cloud.eg.infrastructure.config.client.HessianUtils;
 import com.hrsk.cloud.eg.infrastructure.loanMannager.threedocking.LoanDockingApi;
 import com.hrsk.cloud.eg.infrastructure.service.EgApiService;

+ 8 - 0
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/HaohanwuyinCreditService.java

@@ -2,10 +2,18 @@ package com.hrsk.cloud.eg.domain.api.channel.customized.threedocking.impl;
 
 import com.alibaba.fastjson2.JSON;
 import com.alibaba.fastjson2.JSONObject;
+import com.google.common.base.Function;
 import com.hrsk.cloud.eg.client.dto.plan.command.EgLoanApiConfigInfoCmd;
 import com.hrsk.cloud.eg.client.dto.plan.command.PlanCmd;
 import com.hrsk.cloud.eg.client.dto.user.command.UserBaseInfoCmd;
 
+import com.hrsk.cloud.eg.client.vo.DataVo;
+import com.hrsk.cloud.eg.domain.api.channel.customized.common.ServerCodeEnums;
+import com.hrsk.cloud.eg.domain.api.channel.customized.threedocking.LoanDockingApi;
+import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiRequest;
+import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiResponse;
+import com.hrsk.cloud.eg.domain.common.HessianUtils;
+import com.hrsk.cloud.eg.domain.common.Md5Util;
 import lombok.Data;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;

+ 7 - 2
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/HeFeiShenDaiCreditService.java

@@ -5,6 +5,11 @@ import com.hrsk.cloud.eg.client.dto.plan.command.EgLoanApiConfigInfoCmd;
 import com.hrsk.cloud.eg.client.dto.plan.command.PlanCmd;
 import com.hrsk.cloud.eg.client.dto.user.command.UserBaseInfoCmd;
 
+import com.hrsk.cloud.eg.client.vo.DataVo;
+import com.hrsk.cloud.eg.domain.api.channel.customized.common.ServerCodeEnums;
+import com.hrsk.cloud.eg.domain.api.channel.customized.threedocking.LoanDockingApi;
+import com.hrsk.cloud.eg.domain.common.HessianUtils;
+import com.hrsk.cloud.eg.domain.common.Md5Util;
 import lombok.Data;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
@@ -46,7 +51,7 @@ public class HeFeiShenDaiCreditService implements LoanDockingApi {
     }
 
 
-    public DataVo qualityCheck(UserBaseInfoCmd userInfo, PlanCmd product,EgLoanApiConfigInfoCmd configInfoDo) {
+    public DataVo qualityCheck(UserBaseInfoCmd userInfo, PlanCmd product, EgLoanApiConfigInfoCmd configInfoDo) {
         try {
             log.info("credit HeFeiShenDaiCreditService qualityCheck begin...userId:{}",userInfo.getUserId());
             byte[] requestConfig = configInfoDo.getRequestConfig();
@@ -66,7 +71,7 @@ public class HeFeiShenDaiCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(),product.getPlanName());
             }
-            JSONObject jsonObject=JSONObject.parseObject(response);
+             JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
             log.info("credit qualityCheck HeFeiShenDaiCreditService response md5Phone:{}, jsonObject:{}",userInfo.getUserId(), jsonObject);
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());

+ 4 - 3
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/HeZeRongXinCreditService.java

@@ -61,9 +61,10 @@ public class HeZeRongXinCreditService implements LoanDockingApi {
             String checkUrl = config.getString("checkUrl");
             String url=checkUrl+"?company="+config.getInteger("checkCompany")+"&mobile_md5="+checkInfo.getMobile_md5();
             log.info("credit qualityCheck HeZeRongXinCreditService request userId:{}, url:{}, CheckInfo:{}",userInfo.getUserId(), url, checkInfo);
-            String response = null;
+            HttpApiResponse response = null;
             try{
-                response =httpRestTemplate.restTemplate().postForObject(url,checkInfo, String.class);
+                HttpApiRequest request=new HttpApiRequest(HttpApiRequestConfig.postRequest(JSON.toJSONString(checkInfo),"post",url));
+                response =httpClientFunc.apply(request);
             }catch (Exception e){
                 log.error("菏泽融信准入异常,异常信息:{}", e.getMessage(), e);
             }
@@ -71,7 +72,7 @@ public class HeZeRongXinCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(),product.getPlanName());
             }
-            JSONObject jsonObject=JSONObject.parseObject(response);
+             JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
 
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());

+ 6 - 1
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/HengYangJiuZhenCreditService.java

@@ -1,11 +1,16 @@
 package com.hrsk.cloud.eg.domain.api.channel.customized.threedocking.impl;
 
 import com.alibaba.fastjson2.JSONObject;
+import com.google.common.base.Function;
 import com.hrsk.cloud.eg.client.dto.plan.command.EgLoanApiConfigInfoCmd;
 import com.hrsk.cloud.eg.client.dto.user.command.UserBaseInfoCmd;
+import com.hrsk.cloud.eg.client.vo.DataVo;
 import com.hrsk.cloud.eg.clinet.vo.DataVo;
 import com.hrsk.cloud.eg.client.dto.plan.command.PlanCmd;
 
+import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiRequest;
+import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiResponse;
+import com.hrsk.cloud.eg.domain.common.HessianUtils;
 import com.hrsk.cloud.eg.infrastructure.config.client.HessianUtils;
 import com.hrsk.cloud.eg.infrastructure.loanMannager.threedocking.LoanDockingApi;
 import com.hrsk.cloud.eg.infrastructure.service.EgApiService;
@@ -99,7 +104,7 @@ public class HengYangJiuZhenCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());
             }
-            JSONObject jsonObject = JSONObject.parseObject(response);
+              JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
 //            log.info("credit qualityCheck YunHaiLianDongCreditService response userId:{}, jsonObject:{}", userInfo.getUserId(), jsonObject);
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());

+ 1 - 1
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/HongShengJinFuCreditService.java

@@ -84,7 +84,7 @@ public class HongShengJinFuCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());
             }
-            JSONObject jsonObject = JSONObject.parseObject(response);
+              JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
             if (jsonObject.getString("code").equals("12")) {
                 return DataVo.success(0, "弘盛金服撞库成功", product.getPlanId());
             } else {

+ 1 - 1
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/HongXinPuHuiCreditService.java

@@ -60,7 +60,7 @@ public class HongXinPuHuiCreditService implements LoanDockingApi {
         private Integer is_encrypt;//是否加密(1:是 0:否)
     }
 
-    public DataVo qualityCheck(UserBaseInfoCmd userInfo, PlanCmd product, EgLoanApiConfigInfoCmd    configInfo)  {
+    public DataVo qualityCheck(UserBaseInfoCmd userInfo, PlanCmd product, EgLoanApiConfigInfoCmd configInfo, Function<HttpApiRequest, HttpApiResponse> httpClientFunc)  {
         try {
             log.info("credit HongXinPuHuiCreditService qualityCheck begin...userId:{}",userInfo.getUserId());
 

+ 4 - 3
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/HuNanDiShuiYanCreditService.java

@@ -62,9 +62,10 @@ public class HuNanDiShuiYanCreditService implements LoanDockingApi {
             checkInfo.setChannel(config.getString("channel"));
             String url = config.getString("checkUrl");
             log.info("credit qualityCheck HuNanDiShuiYanCreditService request userId:{}, url:{}, CheckInfo:{}",userInfo.getUserId(), url, checkInfo);
-            String response = null;
+            HttpApiResponse response = null;
             try{
-                response =httpRestTemplate.restTemplate().postForObject(url,checkInfo, String.class);
+                HttpApiRequest request=new HttpApiRequest(HttpApiRequestConfig.postRequest(JSON.toJSONString(checkInfo),"post",url));
+                response =httpClientFunc.apply(request);
             }catch (Exception e){
                 log.error("湖南滴水岩准入异常,异常信息:{}", e.getMessage(), e);
             }
@@ -72,7 +73,7 @@ public class HuNanDiShuiYanCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(),product.getPlanName());
             }
-            JSONObject jsonObject=JSONObject.parseObject(response);
+             JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());
             }

+ 4 - 3
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/JilingHuiRongCreditService.java

@@ -57,9 +57,10 @@ public class JilingHuiRongCreditService implements LoanDockingApi {
             checkInfo.setChannel_secret_key(config.getString("channel_secret_key"));
             String url = config.getString("checkUrl");
             log.info("credit qualityCheck JilingHuiRongCreditService request userId:{}, url:{}, CheckInfo:{}",userInfo.getUserId(), url, checkInfo);
-            String response = null;
+            HttpApiResponse response = null;
             try{
-                response =httpRestTemplate.restTemplate().postForObject(url,checkInfo, String.class);
+                HttpApiRequest request=new HttpApiRequest(HttpApiRequestConfig.postRequest(JSON.toJSONString(checkInfo),"post",url));
+                response =httpClientFunc.apply(request);
             }catch (Exception e){
                 log.error("济宁惠融准入异常,异常信息:{}", e.getMessage(), e);
             }
@@ -67,7 +68,7 @@ public class JilingHuiRongCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(),product.getPlanName());
             }
-            JSONObject jsonObject=JSONObject.parseObject(response);
+             JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
 
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());

+ 6 - 5
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/JinDieV4CreditService.java

@@ -48,17 +48,18 @@ public class JinDieV4CreditService implements LoanDockingApi {
             checkInfo.setTel(phoneMd5);
             String url = config.getString("checkUrl");
             log.info("credit qualityCheck JinDieV4CreditService request userId:{}, url:{}, CheckInfo:{}", userInfo.getUserId(), url, phoneMd5);
-            String response = null;
-            try {
-                response = httpRestTemplate.restTemplate().postForObject(url, checkInfo, String.class);
-            } catch (Exception e) {
+            HttpApiResponse response = null;
+            try{
+                HttpApiRequest request=new HttpApiRequest(HttpApiRequestConfig.postRequest(JSON.toJSONString(checkInfo),"post",url));
+                response =httpClientFunc.apply(request);
+            }catch (Exception e) {
                 log.error("锦蝶v4准入异常,异常信息:{}", e.getMessage(), e);
             }
             log.info("credit qualityCheck JinDieV4CreditService response userId:{}, result:{}", userInfo.getUserId(), response);
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());
             }
-            JSONObject jsonObject = JSONObject.parseObject(response);
+              JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
             if (jsonObject.getString("code").equals("500")) {
                 return DataVo.success(0, "锦蝶v4撞库成功", product.getPlanId());
             } else {

+ 4 - 3
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/JinZhuLiCreditService.java

@@ -85,9 +85,10 @@ public class JinZhuLiCreditService  implements LoanDockingApi {
             String url = config.getString("checkUrl");
 
             log.info("credit qualityCheck JinZhuLiCreditService request userId:{}, url:{}, CheckInfo:{}",userInfo.getUserId(), url, phoneMd5);
-            String response = null;
+            HttpApiResponse response = null;
             try{
-                response =httpRestTemplate.restTemplate().postForObject(url,checkInfo, String.class);
+                HttpApiRequest request=new HttpApiRequest(HttpApiRequestConfig.postRequest(JSON.toJSONString(checkInfo),"post",url));
+                response =httpClientFunc.apply(request);
             }catch (Exception e){
                 log.error("金助理准入异常,异常信息:{}", e.getMessage(), e);
             }
@@ -95,7 +96,7 @@ public class JinZhuLiCreditService  implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(),product.getPlanName());
             }
-            JSONObject jsonObject=JSONObject.parseObject(response);
+             JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());
             }

+ 5 - 4
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/JindieCreditService.java

@@ -55,10 +55,11 @@ public class JindieCreditService implements LoanDockingApi {
             checkInfo.setUserphone(userInfo.getUserMobileMD5());
             String url = config.getString("url") + qualityCheckPath;
             log.info("credit qualityCheck JindieCreditService request userId:{}, url:{}, CheckInfo:{}", userInfo.getUserId(), url, checkInfo);
-            String response = null;
-            try {
-                response = httpRestTemplate.restTemplate().postForObject(url, checkInfo, String.class);
-            } catch (Exception e) {
+            HttpApiResponse response = null;
+            try{
+                HttpApiRequest request=new HttpApiRequest(HttpApiRequestConfig.postRequest(JSON.toJSONString(checkInfo),"post",url));
+                response =httpClientFunc.apply(request);
+            }catch (Exception e) {
                 log.error("锦蝶准入异常,异常信息:{}", e.getMessage(), e);
             }
             log.info("credit qualityCheck JindieCreditService response userId:{}, result:{}", userInfo.getUserId(), response);

+ 6 - 5
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/JiuXinKeCreditService.java

@@ -58,17 +58,18 @@ public class JiuXinKeCreditService implements LoanDockingApi {
             checkInfo.setPromotion(config.getString("promotion"));
             checkInfo.setFile_id(config.getInteger("file_id"));
             log.info("credit qualityCheck JiuXinKeCreditService request userId:{}, url:{}, CheckInfo:{}",userInfo.getUserId(), url, checkInfo);
-            String response = null;
-            try {
-                response = httpRestTemplate.restTemplate().postForObject(url, checkInfo, String.class);
-            } catch (Exception e) {
+            HttpApiResponse response = null;
+            try{
+                HttpApiRequest request=new HttpApiRequest(HttpApiRequestConfig.postRequest(JSON.toJSONString(checkInfo),"post",url));
+                response =httpClientFunc.apply(request);
+            }catch (Exception e) {
                 log.error("玖欣客准入异常,异常信息:{}", e.getMessage(), e);
             }
             log.info("credit qualityCheck JiuXinKeCreditService response userId:{}, result:{}", userInfo.getUserId(), response);
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());
             }
-            JSONObject jsonObject = JSONObject.parseObject(response);
+              JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());
             }

+ 5 - 4
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/KuaiYiRongCreditService.java

@@ -48,7 +48,7 @@ public class KuaiYiRongCreditService implements LoanDockingApi {
     public DataVo qualityCheck(UserBaseInfoCmd userInfo, PlanCmd product, EgLoanApiConfigInfoCmd configInfo)  {
         try {
             log.info("credit KuaiYiRongCreditService qualityCheck begin...userId:{}",userInfo.getUserId());
-          
+
             byte[] requestConfig = configInfo.getRequestConfig();
             Object deserialize = HessianUtils.deserialize(requestConfig);
             JSONObject config = JSONObject.parseObject(deserialize.toString());
@@ -59,9 +59,10 @@ public class KuaiYiRongCreditService implements LoanDockingApi {
             checkInfo.setChannel_secret_key(config.getString("channel_secret_key"));
             String url = config.getString("checkUrl");
             log.info("credit qualityCheck KuaiYiRongCreditService request userId:{}, url:{}, CheckInfo:{}",userInfo.getUserId(), url, checkInfo);
-            String response = null;
+            HttpApiResponse response = null;
             try{
-                response =httpRestTemplate.restTemplate().postForObject(url,checkInfo, String.class);
+                HttpApiRequest request=new HttpApiRequest(HttpApiRequestConfig.postRequest(JSON.toJSONString(checkInfo),"post",url));
+                response =httpClientFunc.apply(request);
             }catch (Exception e){
                 log.error("快易融准入异常,异常信息:{}", e.getMessage(), e);
             }
@@ -69,7 +70,7 @@ public class KuaiYiRongCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(),product.getPlanName());
             }
-            JSONObject jsonObject=JSONObject.parseObject(response);
+             JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
 
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());

+ 4 - 3
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/LeXiangRongCreditService.java

@@ -47,9 +47,10 @@ public class LeXiangRongCreditService implements LoanDockingApi {
             checkInfo.setPhone(phoneMd5);
             String url = config.getString("checkUrl");
             log.info("credit qualityCheck LeXiangRongCreditService request userId:{}, url:{}, checkInfo:{}",userInfo.getUserId(), url, checkInfo);
-            String response = null;
+            HttpApiResponse response = null;
             try{
-                response =httpRestTemplate.restTemplate().postForObject(url,checkInfo, String.class);
+                HttpApiRequest request=new HttpApiRequest(HttpApiRequestConfig.postRequest(JSON.toJSONString(checkInfo),"post",url));
+                response =httpClientFunc.apply(request);
             }catch (Exception e){
                 log.error("乐享融准入异常,异常信息:{}", e.getMessage(), e);
             }
@@ -57,7 +58,7 @@ public class LeXiangRongCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(),product.getPlanName());
             }
-            JSONObject jsonObject=JSONObject.parseObject(response);
+             JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
 
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());

+ 1 - 1
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/LianKeYunKongCreditService.java

@@ -103,7 +103,7 @@ public class LianKeYunKongCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());
             }
-            JSONObject jsonObject = JSONObject.parseObject(response);
+              JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());
             }

+ 4 - 3
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/LiaoChengXinYiDaiCreditService.java

@@ -65,9 +65,10 @@ public class LiaoChengXinYiDaiCreditService implements LoanDockingApi {
             checkInfo.setCity(userInfo.getCompanyCity());
             String url = config.getString("checkUrl");
             log.info("credit qualityCheck LiaoChengXinYiDaiService request userId:{}, url:{}, CheckInfo:{}",userInfo.getUserId(), url, checkInfo);
-            String response = null;
+            HttpApiResponse response = null;
             try{
-                response =httpRestTemplate.restTemplate().postForObject(url,checkInfo, String.class);
+                HttpApiRequest request=new HttpApiRequest(HttpApiRequestConfig.postRequest(JSON.toJSONString(checkInfo),"post",url));
+                response =httpClientFunc.apply(request);
             }catch (Exception e){
                 log.error("聊城鑫易代准入异常,异常信息:{}", e.getMessage(), e);
             }
@@ -75,7 +76,7 @@ public class LiaoChengXinYiDaiCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(),product.getPlanName());
             }
-            JSONObject jsonObject=JSONObject.parseObject(response);
+             JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
 
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());

+ 1 - 1
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/MoGuTouCreditService.java

@@ -70,7 +70,7 @@ public class MoGuTouCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());
             }
-            JSONObject jsonObject = JSONObject.parseObject(response);
+              JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
             log.info("credit qualityCheck MoGuTouCreditService response userId:{}, jsonObject:{}", userInfo.getUserId(), jsonObject);
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());

+ 1 - 1
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/NanTongXingChengCreditService.java

@@ -80,7 +80,7 @@ public class NanTongXingChengCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(),product.getPlanName());
             }
-            JSONObject jsonObject=JSONObject.parseObject(response);
+             JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());
             }

+ 5 - 4
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/NiYouKeCreditService.java

@@ -33,7 +33,7 @@ public class NiYouKeCreditService implements LoanDockingApi {
     }
 
     @Override
-    public DataVo qualityCheck(UserBaseInfoCmd userInfo, PlanCmd product, EgLoanApiConfigInfoCmd    configInfo)  {
+    public DataVo qualityCheck(UserBaseInfoCmd userInfo, PlanCmd product, EgLoanApiConfigInfoCmd configInfo, Function<HttpApiRequest, HttpApiResponse> httpClientFunc)  {
         try {
             log.info("credit NiYouKeCreditService qualityCheck begin...userId:{}",userInfo.getUserId());
 
@@ -50,9 +50,10 @@ public class NiYouKeCreditService implements LoanDockingApi {
             checkInfo.setSign(Md5Util.encoderByMd5(sign));
             String url = config.getString("checkUrl");
             log.info("credit qualityCheck NiYouKeCreditService request userId:{}, url:{}, CheckInfo:{}",userInfo.getUserId(), url, checkInfo);
-            String response = null;
+            HttpApiResponse response = null;
             try{
-                response =httpRestTemplate.restTemplate().postForObject(url,checkInfo, String.class);
+                HttpApiRequest request=new HttpApiRequest(HttpApiRequestConfig.postRequest(JSON.toJSONString(checkInfo),"post",url));
+                response =httpClientFunc.apply(request);
             }catch (Exception e){
                 log.error("尼优客准入异常,异常信息:{}", e.getMessage(), e);
             }
@@ -60,7 +61,7 @@ public class NiYouKeCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(),product.getPlanName());
             }
-            JSONObject jsonObject=JSONObject.parseObject(response);
+             JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
 
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());

+ 4 - 3
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/NingBoTianChengCreditService.java

@@ -64,9 +64,10 @@ public class NingBoTianChengCreditService implements LoanDockingApi {
             checkInfo.setFile_id(config.getString("file_id"));
             String url = config.getString("checkUrl");
             log.info("credit qualityCheck NingBoTianChengCreditService request userId:{}, url:{}, CheckInfo:{}",userInfo.getUserId(), url, checkInfo);
-            String response = null;
+            HttpApiResponse response = null;
             try{
-                response =httpRestTemplate.restTemplate().postForObject(url,checkInfo, String.class);
+                HttpApiRequest request=new HttpApiRequest(HttpApiRequestConfig.postRequest(JSON.toJSONString(checkInfo),"post",url));
+                response =httpClientFunc.apply(request);
             }catch (Exception e){
                 log.error("宁波天澄准入异常,异常信息:{}", e.getMessage(), e);
             }
@@ -74,7 +75,7 @@ public class NingBoTianChengCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(),product.getPlanName());
             }
-            JSONObject jsonObject=JSONObject.parseObject(response);
+             JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
 
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());

+ 1 - 1
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/PingDingShanCreditService.java

@@ -86,7 +86,7 @@ public class PingDingShanCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(),product.getPlanName());
             }
-            JSONObject jsonObject=JSONObject.parseObject(response);
+             JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
             if (jsonObject.getInteger("code")==1) {
                     return DataVo.success(0, "平顶山撞库成功", product.getPlanId());
             } else {

+ 1 - 1
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/QingDaoAoSengCreditService.java

@@ -53,7 +53,7 @@ public class QingDaoAoSengCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());
             }
-            JSONObject jsonObject = JSONObject.parseObject(response);
+              JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
 //            log.info("credit qualityCheck YunHaiLianDongCreditService response userId:{}, jsonObject:{}", userInfo.getUserId(), jsonObject);
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());

+ 2 - 2
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/QingDaoAoSengV2CreditService.java

@@ -31,7 +31,7 @@ public class QingDaoAoSengV2CreditService implements LoanDockingApi {
 
 
     @Override
-    public DataVo qualityCheck(UserBaseInfoCmd userInfo, PlanCmd product, EgLoanApiConfigInfoCmd    configInfo)  {
+    public DataVo qualityCheck(UserBaseInfoCmd userInfo, PlanCmd product, EgLoanApiConfigInfoCmd configInfo, Function<HttpApiRequest, HttpApiResponse> httpClientFunc)  {
         try {
 //            log.info("credit YunHaiLianDongCreditService qualityCheck begin...userId:{}", userInfo.getUserId());
           
@@ -54,7 +54,7 @@ public class QingDaoAoSengV2CreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());
             }
-            JSONObject jsonObject = JSONObject.parseObject(response);
+              JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
 //            log.info("credit qualityCheck YunHaiLianDongCreditService response userId:{}, jsonObject:{}", userInfo.getUserId(), jsonObject);
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());

+ 4 - 3
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/RongChuangJinFuCreditService.java

@@ -52,9 +52,10 @@ public class RongChuangJinFuCreditService implements LoanDockingApi {
             checkInfo.setMobile(phoneMd5);
             String url = config.getString("checkUrl");
             log.info("credit qualityCheck RongChuangJinFuCreditService request userId:{}, url:{}, CheckInfo:{}",userInfo.getUserId(), url, phoneMd5);
-            String response = null;
+            HttpApiResponse response = null;
             try{
-                response =httpRestTemplate.restTemplate().postForObject(url,checkInfo, String.class);
+                HttpApiRequest request=new HttpApiRequest(HttpApiRequestConfig.postRequest(JSON.toJSONString(checkInfo),"post",url));
+                response =httpClientFunc.apply(request);
             }catch (Exception e){
                 log.error("融创金服准入异常,异常信息:{}", e.getMessage(), e);
             }
@@ -62,7 +63,7 @@ public class RongChuangJinFuCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(),product.getPlanName());
             }
-            JSONObject jsonObject=JSONObject.parseObject(response);
+             JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());
             }

+ 4 - 3
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/RongXiangDaChangShaCreditService.java

@@ -70,9 +70,10 @@ public class RongXiangDaChangShaCreditService implements LoanDockingApi {
             checkInfo.setSourceCode(config.getString("sourcecode"));
             String url = config.getString("checkUrl");
             log.info("credit qualityCheck RongXiangDaChangShaCreditService request userId:{}, url:{}, CheckInfo:{}",userInfo.getUserId(), url, checkInfo);
-            String response = null;
+            HttpApiResponse response = null;
             try{
-                response =httpRestTemplate.restTemplate().postForObject(url,checkInfo, String.class);
+                HttpApiRequest request=new HttpApiRequest(HttpApiRequestConfig.postRequest(JSON.toJSONString(checkInfo),"post",url));
+                response =httpClientFunc.apply(request);
             }catch (Exception e){
                 log.error("融享达长沙准入异常,异常信息:{}", e.getMessage(), e);
             }
@@ -80,7 +81,7 @@ public class RongXiangDaChangShaCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(),product.getPlanName());
             }
-            JSONObject jsonObject=JSONObject.parseObject(response);
+             JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
 
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());

+ 4 - 3
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/RongXiangKeBuShuCreditService.java

@@ -73,9 +73,10 @@ public class RongXiangKeBuShuCreditService implements LoanDockingApi {
             checkInfo.setSourceCode(config.getString("sourcecode"));
             String url = config.getString("checkUrl");
             log.info("credit qualityCheck RongXiangKeBuShuCreditService request userId:{}, url:{}, CheckInfo:{}",userInfo.getUserId(), url, checkInfo);
-            String response = null;
+            HttpApiResponse response = null;
             try{
-                response =httpRestTemplate.restTemplate().postForObject(url,checkInfo, String.class);
+                HttpApiRequest request=new HttpApiRequest(HttpApiRequestConfig.postRequest(JSON.toJSONString(checkInfo),"post",url));
+                response =httpClientFunc.apply(request);
             }catch (Exception e){
                 log.error("融享客部署模式准入异常,异常信息:{}", e.getMessage(), e);
             }
@@ -83,7 +84,7 @@ public class RongXiangKeBuShuCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(),product.getPlanName());
             }
-            JSONObject jsonObject=JSONObject.parseObject(response);
+             JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
 
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());

+ 4 - 3
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/RongXiangKeV2CreditService.java

@@ -70,9 +70,10 @@ public class RongXiangKeV2CreditService implements LoanDockingApi {
             checkInfo.setSourceCode(config.getString("sourcecode"));
             String url = config.getString("checkUrl");
             log.info("credit qualityCheck RongXiangKeV2CreditService request userId:{}, url:{}, CheckInfo:{}",userInfo.getUserId(), url, checkInfo);
-            String response = null;
+            HttpApiResponse response = null;
             try{
-                response =httpRestTemplate.restTemplate().postForObject(url,checkInfo, String.class);
+                HttpApiRequest request=new HttpApiRequest(HttpApiRequestConfig.postRequest(JSON.toJSONString(checkInfo),"post",url));
+                response =httpClientFunc.apply(request);
             }catch (Exception e){
                 log.error("融享客V2准入异常,异常信息:{}", e.getMessage(), e);
             }
@@ -80,7 +81,7 @@ public class RongXiangKeV2CreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(),product.getPlanName());
             }
-            JSONObject jsonObject=JSONObject.parseObject(response);
+             JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
 
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());

+ 1 - 1
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/RongYiDaCreditService.java

@@ -85,7 +85,7 @@ public class RongYiDaCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());
             }
-            JSONObject jsonObject = JSONObject.parseObject(response);
+              JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());
             }

+ 1 - 1
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/RongxiziCreditService.java

@@ -57,7 +57,7 @@ public class RongxiziCreditService implements LoanDockingApi {
      * {"token":"UWDSdzJHCq3KnrLwuBaPBBGX8Hs0oEY3","vender_name":"birong","appid":"20076","appkey":"05xduuQdn6r46giJji91aXDlzEeOT5Be"}
      */
     @Override
-    public DataVo qualityCheck(UserBaseInfoCmd userInfo, PlanCmd product, EgLoanApiConfigInfoCmd    configInfo)  {
+    public DataVo qualityCheck(UserBaseInfoCmd userInfo, PlanCmd product, EgLoanApiConfigInfoCmd configInfo, Function<HttpApiRequest, HttpApiResponse> httpClientFunc)  {
         try {
             log.info("credit RongxiziCreditService qualityCheck begin...userId:{}",userInfo.getUserId());
 //            XdProductJointConfig xdProductJointConfig = xdProductJointConfigMapper.selectById(product.getJointType());

+ 4 - 3
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/RunMeiXinYiRongCreditService.java

@@ -52,9 +52,10 @@ public class RunMeiXinYiRongCreditService implements LoanDockingApi {
             checkInfo.setSign(Md5Util.encoderByMd5(sign));
             String url = config.getString("checkUrl");
             log.info("credit qualityCheck RunMeiXinYiRongCreditService request userId:{}, url:{}, CheckInfo:{}",userInfo.getUserId(), url, checkInfo);
-            String response = null;
+            HttpApiResponse response = null;
             try{
-                response =httpRestTemplate.restTemplate().postForObject(url,checkInfo, String.class);
+                HttpApiRequest request=new HttpApiRequest(HttpApiRequestConfig.postRequest(JSON.toJSONString(checkInfo),"post",url));
+                response =httpClientFunc.apply(request);
             }catch (Exception e){
                 log.error("润美准入异常,异常信息:{}", e.getMessage(), e);
             }
@@ -62,7 +63,7 @@ public class RunMeiXinYiRongCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(),product.getPlanName());
             }
-            JSONObject jsonObject=JSONObject.parseObject(response);
+             JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
 
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());

+ 1 - 1
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/ShanDongBangBangDaiCreditService.java

@@ -59,7 +59,7 @@ public class ShanDongBangBangDaiCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(),product.getPlanName());
             }
-            JSONObject jsonObject=JSONObject.parseObject(response);
+             JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
 
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());

+ 6 - 5
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/ShanXiMingDePuHuiCreditService.java

@@ -64,17 +64,18 @@ public class ShanXiMingDePuHuiCreditService implements LoanDockingApi {
             checkInfo.setTel(phoneMd5);
 
             log.info("credit qualityCheck ShanXiMingDePuHuiCreditService request userId:{}, url:{}, CheckInfo:{}", userInfo.getUserId(), url, checkInfo);
-            String response = null;
-            try {
-                response = httpRestTemplate.restTemplate().postForObject(url, checkInfo, String.class);
-            } catch (Exception e) {
+            HttpApiResponse response = null;
+            try{
+                HttpApiRequest request=new HttpApiRequest(HttpApiRequestConfig.postRequest(JSON.toJSONString(checkInfo),"post",url));
+                response =httpClientFunc.apply(request);
+            }catch (Exception e) {
                 log.error("陕西明德普惠准入异常,异常信息:{}", e.getMessage(), e);
             }
             log.info("credit qualityCheck ShanXiMingDePuHuiCreditService response userId:{}, result:{}", userInfo.getUserId(), response);
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());
             }
-            JSONObject jsonObject = JSONObject.parseObject(response);
+              JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());
             }

+ 1 - 1
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/ShangHaiHanGeCreditService.java

@@ -61,7 +61,7 @@ public class ShangHaiHanGeCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());
             }
-            JSONObject jsonObject = JSONObject.parseObject(response);
+              JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
             if (jsonObject.getString("Ret").equals("0")&&jsonObject.getString("Code").equals("100")) {
                 return DataVo.success(0, "上海晗各撞库成功", product.getPlanId());
             } else {

+ 4 - 3
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/ShangHaiJuHuiRongCreditService.java

@@ -46,9 +46,10 @@ public class ShangHaiJuHuiRongCreditService implements LoanDockingApi {
             checkInfo.setDitchCode(config.getString("ditchCode"));
             String url = config.getString("checkUrl");
             log.info("credit qualityCheck ShangHaiJuHuiRongCreditService request userId:{}, url:{}, CheckInfo:{}",userInfo.getUserId(), url, phoneMd5);
-            String response = null;
+            HttpApiResponse response = null;
             try{
-                response =httpRestTemplate.restTemplate().postForObject(url,checkInfo, String.class);
+                HttpApiRequest request=new HttpApiRequest(HttpApiRequestConfig.postRequest(JSON.toJSONString(checkInfo),"post",url));
+                response =httpClientFunc.apply(request);
             }catch (Exception e){
                 log.error("上海聚汇融准入异常,异常信息:{}", e.getMessage(), e);
             }
@@ -56,7 +57,7 @@ public class ShangHaiJuHuiRongCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(),product.getPlanName());
             }
-            JSONObject jsonObject=JSONObject.parseObject(response);
+             JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());
             }

+ 1 - 1
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/ShenYangHengXinCreditService.java

@@ -40,7 +40,7 @@ public class ShenYangHengXinCreditService implements LoanDockingApi {
 
 
     @Override
-    public DataVo qualityCheck(UserBaseInfoCmd userInfo, PlanCmd product, EgLoanApiConfigInfoCmd    configInfo)  {
+    public DataVo qualityCheck(UserBaseInfoCmd userInfo, PlanCmd product, EgLoanApiConfigInfoCmd configInfo, Function<HttpApiRequest, HttpApiResponse> httpClientFunc)  {
         try {
             log.info("credit ShenYangHengXinCreditService qualityCheck begin...userId:{}",userInfo.getUserId());
           

+ 4 - 3
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/ShenYangXinYiRongCreditService.java

@@ -51,9 +51,10 @@ public class ShenYangXinYiRongCreditService implements LoanDockingApi {
             String checkUrl = config.getString("checkUrl");
             String url=checkUrl+"?company="+config.getInteger("checkCompany")+"&mobile_md5="+checkInfo.getMobile_md5();
             log.info("credit qualityCheck ShenYangXinYiRongCreditService request userId:{}, url:{}, CheckInfo:{}",userInfo.getUserId(), url, checkInfo);
-            String response = null;
+            HttpApiResponse response = null;
             try{
-                response =httpRestTemplate.restTemplate().postForObject(url,checkInfo, String.class);
+                HttpApiRequest request=new HttpApiRequest(HttpApiRequestConfig.postRequest(JSON.toJSONString(checkInfo),"post",url));
+                response =httpClientFunc.apply(request);
             }catch (Exception e){
                 log.error("沈阳信易融准入异常,异常信息:{}", e.getMessage(), e);
             }
@@ -61,7 +62,7 @@ public class ShenYangXinYiRongCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(),product.getPlanName());
             }
-            JSONObject jsonObject=JSONObject.parseObject(response);
+             JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
 
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());

+ 1 - 1
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/ShiYueCreditService.java

@@ -78,7 +78,7 @@ public class ShiYueCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(),product.getPlanName());
             }
-            JSONObject jsonObject=JSONObject.parseObject(response);
+             JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
 
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());

+ 4 - 3
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/ShuRongCreditService.java

@@ -57,9 +57,10 @@ public class ShuRongCreditService implements LoanDockingApi {
             checkInfo.setCity(userInfo.getCityAllName());
             String url = config.getString("checkUrl");
             log.info("credit qualityCheck ShuRongCreditService request userId:{}, url:{}, CheckInfo:{}",userInfo.getUserId(), url, phoneMd5);
-            String response = null;
+            HttpApiResponse response = null;
             try{
-                response =httpRestTemplate.restTemplate().postForObject(url,checkInfo, String.class);
+                HttpApiRequest request=new HttpApiRequest(HttpApiRequestConfig.postRequest(JSON.toJSONString(checkInfo),"post",url));
+                response =httpClientFunc.apply(request);
             }catch (Exception e){
                 log.error("速融准入异常,异常信息:{}", e.getMessage(), e);
             }
@@ -67,7 +68,7 @@ public class ShuRongCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(),product.getPlanName());
             }
-            JSONObject jsonObject=JSONObject.parseObject(response);
+             JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());
             }

+ 4 - 3
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/SiChuangRuiCreditService.java

@@ -64,9 +64,10 @@ public class SiChuangRuiCreditService implements LoanDockingApi {
             checkInfo.setPhone(phoneMd5);
             String url = config.getString("checkUrl");
             log.info("credit qualityCheck SiChuangRuiCreditService request userId:{}, url:{}, CheckInfo:{}",userInfo.getUserId(), url, checkInfo);
-            String response = null;
+            HttpApiResponse response = null;
             try{
-                response =httpRestTemplate.restTemplate().postForObject(url,checkInfo, String.class);
+                HttpApiRequest request=new HttpApiRequest(HttpApiRequestConfig.postRequest(JSON.toJSONString(checkInfo),"post",url));
+                response =httpClientFunc.apply(request);
             }catch (Exception e){
                 log.error("思创瑞准入异常,异常信息:{}", e.getMessage(), e);
             }
@@ -74,7 +75,7 @@ public class SiChuangRuiCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(),product.getPlanName());
             }
-            JSONObject jsonObject=JSONObject.parseObject(response);
+             JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
 
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());

+ 1 - 1
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/SouYuJinFuCreditService.java

@@ -62,7 +62,7 @@ public class SouYuJinFuCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());
             }
-            JSONObject jsonObject = JSONObject.parseObject(response);
+              JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
             log.info("credit qualityCheck SouYuJinFuCreditService response userId:{}, jsonObject:{}", userInfo.getUserId(), jsonObject);
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());

+ 4 - 3
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/SuZhouJianYiRongCreditService.java

@@ -57,9 +57,10 @@ public class SuZhouJianYiRongCreditService implements LoanDockingApi {
             String url = config.getString("checkUrl");
 
             log.info("credit qualityCheck SuZhouJianYiRongCreditService request userId:{}, url:{}, checkInfo:{}",userInfo.getUserId(), url, checkInfo);
-            String response = null;
+            HttpApiResponse response = null;
             try{
-                response =httpRestTemplate.restTemplate().postForObject(url,checkInfo, String.class);
+                HttpApiRequest request=new HttpApiRequest(HttpApiRequestConfig.postRequest(JSON.toJSONString(checkInfo),"post",url));
+                response =httpClientFunc.apply(request);
             }catch (Exception e){
                 log.error("苏州简易融准入异常,异常信息:{}", e.getMessage(), e);
             }
@@ -67,7 +68,7 @@ public class SuZhouJianYiRongCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(),product.getPlanName());
             }
-            JSONObject jsonObject=JSONObject.parseObject(response);
+             JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
 
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());

+ 1 - 1
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/SuzhouchangshuoCreditService.java

@@ -90,7 +90,7 @@ public class SuzhouchangshuoCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(),product.getPlanName());
             }
-            JSONObject jsonObject=JSONObject.parseObject(response);
+             JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
 
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());

+ 6 - 5
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/TangShanRongYangCreditService.java

@@ -44,17 +44,18 @@ public class TangShanRongYangCreditService implements LoanDockingApi {
             CheckInfo checkInfo = new CheckInfo();
             checkInfo.setMd5_phone(phoneMd5);
             log.info("credit qualityCheck TangShanRongYangCreditService request userId:{}, url:{}, CheckInfo:{}",userInfo.getUserId(), url, checkInfo);
-            String response = null;
-            try {
-                response = httpRestTemplate.restTemplate().postForObject(url, checkInfo, String.class);
-            } catch (Exception e) {
+            HttpApiResponse response = null;
+            try{
+                HttpApiRequest request=new HttpApiRequest(HttpApiRequestConfig.postRequest(JSON.toJSONString(checkInfo),"post",url));
+                response =httpClientFunc.apply(request);
+            }catch (Exception e) {
                 log.error("唐山融扬准入异常,异常信息:{}", e.getMessage(), e);
             }
             log.info("credit qualityCheck TangShanRongYangCreditService response userId:{}, result:{}", userInfo.getUserId(), response);
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());
             }
-            JSONObject jsonObject = JSONObject.parseObject(response);
+              JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());
             }

+ 4 - 3
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/TianJingJiaYiCreditService.java

@@ -59,9 +59,10 @@ public class TianJingJiaYiCreditService implements LoanDockingApi {
             checkInfo.setChannel_secret_key(config.getString("channelSecretKey"));//渠道密钥
             String url = config.getString("checkUrl");
             log.info("credit qualityCheck TianJingJiaYiCreditService request userId:{}, url:{}, checkInfo:{}",userInfo.getUserId(), url, checkInfo);
-            String response = null;
+            HttpApiResponse response = null;
             try{
-                response =httpRestTemplate.restTemplate().postForObject(url,checkInfo, String.class);
+                HttpApiRequest request=new HttpApiRequest(HttpApiRequestConfig.postRequest(JSON.toJSONString(checkInfo),"post",url));
+                response =httpClientFunc.apply(request);
             }catch (Exception e){
                 log.error("天津佳亿准入异常,异常信息:{}", e.getMessage(), e);
             }
@@ -69,7 +70,7 @@ public class TianJingJiaYiCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(),product.getPlanName());
             }
-            JSONObject jsonObject=JSONObject.parseObject(response);
+             JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
 
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());

+ 1 - 1
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/TianShuiShuYiRongCreditService.java

@@ -51,7 +51,7 @@ public class TianShuiShuYiRongCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());
             }
-            JSONObject jsonObject = JSONObject.parseObject(response);
+              JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
             if (jsonObject.getInteger("code") == 0) {
                 return DataVo.success(0, "天水速易融撞库成功", product.getPlanId());
             } else {

+ 4 - 3
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/WeiFangYouYiCreditService.java

@@ -56,9 +56,10 @@ public class WeiFangYouYiCreditService implements LoanDockingApi {
             checkInfo.setChannel_secret_key(config.getString("channel_secret_key"));
             String url = config.getString("checkUrl");
             log.info("credit qualityCheck WeiFangYouYiCreditService request userId:{}, url:{}, CheckInfo:{}",userInfo.getUserId(), url, checkInfo);
-            String response = null;
+            HttpApiResponse response = null;
             try{
-                response =httpRestTemplate.restTemplate().postForObject(url,checkInfo, String.class);
+                HttpApiRequest request=new HttpApiRequest(HttpApiRequestConfig.postRequest(JSON.toJSONString(checkInfo),"post",url));
+                response =httpClientFunc.apply(request);
             }catch (Exception e){
                 log.error("潍坊优易准入异常,异常信息:{}", e.getMessage(), e);
             }
@@ -66,7 +67,7 @@ public class WeiFangYouYiCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(),product.getPlanName());
             }
-            JSONObject jsonObject=JSONObject.parseObject(response);
+             JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
 
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());

+ 1 - 1
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/WenZhouGaoShenCreditService.java

@@ -66,7 +66,7 @@ public class WenZhouGaoShenCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());
             }
-            JSONObject jsonObject = JSONObject.parseObject(response);
+              JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
             log.info("credit qualityCheck WenZhouGaoShenCreditService response userId:{}, jsonObject:{}", userInfo.getUserId(), jsonObject);
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());

+ 1 - 1
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/WenZhouYueShangXiangCreditService.java

@@ -64,7 +64,7 @@ public class WenZhouYueShangXiangCreditService  implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(),product.getPlanName());
             }
-            JSONObject jsonObject=JSONObject.parseObject(response);
+             JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
 
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());

+ 1 - 1
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/WuHanDongYuanCreditService.java

@@ -44,7 +44,7 @@ public class WuHanDongYuanCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(),product.getPlanName());
             }
-            JSONObject jsonObject=JSONObject.parseObject(response);
+             JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());
             }

+ 2 - 2
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/WuHanJingChengCreditService.java

@@ -34,7 +34,7 @@ public class WuHanJingChengCreditService implements LoanDockingApi {
 
 
     @Override
-    public DataVo qualityCheck(UserBaseInfoCmd userInfo, PlanCmd product, EgLoanApiConfigInfoCmd    configInfo)  {
+    public DataVo qualityCheck(UserBaseInfoCmd userInfo, PlanCmd product, EgLoanApiConfigInfoCmd configInfo, Function<HttpApiRequest, HttpApiResponse> httpClientFunc)  {
         try {
             log.info("credit WuHanJingChengCreditService qualityCheck begin...userId:{}", userInfo.getUserId());
           
@@ -58,7 +58,7 @@ public class WuHanJingChengCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());
             }
-            JSONObject jsonObject = JSONObject.parseObject(response);
+              JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
             if (jsonObject.getString("code").equals("1")) {
                 return DataVo.success(0, "武汉锦城撞库成功", product.getPlanId());
             } else {

+ 1 - 1
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/XiaMenYiJieZhuDaiCreditService.java

@@ -85,7 +85,7 @@ public class XiaMenYiJieZhuDaiCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(),product.getPlanName());
             }
-            JSONObject jsonObject=JSONObject.parseObject(response);
+             JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
 
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());

+ 1 - 1
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/XinChuangYinHuiCreditService.java

@@ -59,7 +59,7 @@ public class XinChuangYinHuiCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());
             }
-            JSONObject jsonObject = JSONObject.parseObject(response);
+              JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
 
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());

+ 4 - 3
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/XinJiangWanHeCreditService.java

@@ -48,9 +48,10 @@ public class XinJiangWanHeCreditService implements LoanDockingApi {
             checkInfo.setName(phoneMd5);
             String url = config.getString("checkUrl");
             log.info("credit qualityCheck XinJiangWanHeCreditService request userId:{}, url:{}, CheckInfo:{}",userInfo.getUserId(), url, phoneMd5);
-            String response = null;
+            HttpApiResponse response = null;
             try{
-                response =httpRestTemplate.restTemplate().postForObject(url,checkInfo, String.class);
+                HttpApiRequest request=new HttpApiRequest(HttpApiRequestConfig.postRequest(JSON.toJSONString(checkInfo),"post",url));
+                response =httpClientFunc.apply(request);
             }catch (Exception e){
                 log.error("新疆万合准入异常,异常信息:{}", e.getMessage(), e);
             }
@@ -58,7 +59,7 @@ public class XinJiangWanHeCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(),product.getPlanName());
             }
-            JSONObject jsonObject=JSONObject.parseObject(response);
+             JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());
             }

+ 1 - 1
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/XinZheChangZhiCreditService.java

@@ -78,7 +78,7 @@ public class XinZheChangZhiCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());
             }
-            JSONObject jsonObject = JSONObject.parseObject(response);
+              JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
             if (jsonObject == null || StringUtils.isBlank(jsonObject.getString("data"))) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());
             }

+ 1 - 1
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/XuzhoufuliV2CreditService.java

@@ -97,7 +97,7 @@ public class XuzhoufuliV2CreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(),product.getPlanName());
             }
-            JSONObject jsonObject=JSONObject.parseObject(response);
+             JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
 
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());

+ 1 - 1
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/YangZhouWanKeCreditService.java

@@ -59,7 +59,7 @@ public class YangZhouWanKeCreditService implements LoanDockingApi {
     }
      */
     @Override
-    public DataVo qualityCheck(UserBaseInfoCmd userInfo, PlanCmd product, EgLoanApiConfigInfoCmd    configInfo)  {
+    public DataVo qualityCheck(UserBaseInfoCmd userInfo, PlanCmd product, EgLoanApiConfigInfoCmd configInfo, Function<HttpApiRequest, HttpApiResponse> httpClientFunc)  {
         try {
             log.info("credit YangZhouWanKeCreditService qualityCheck begin...userId:{}",userInfo.getUserId());
           

+ 1 - 1
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/YiLianRongCreditService.java

@@ -77,7 +77,7 @@ public class YiLianRongCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());
             }
-            JSONObject jsonObject = JSONObject.parseObject(response);
+              JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
             log.info("credit qualityCheck YiLianRongCreditService response userId:{}, jsonObject:{}", userInfo.getUserId(), jsonObject);
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());

+ 1 - 1
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/YiRongCreditService.java

@@ -78,7 +78,7 @@ public class YiRongCreditService implements LoanDockingApi {
                 log.error("壹融准入异常,异常信息:{}", e.getMessage(), e);
             }
             log.info("credit qualityCheck YiRongCreditService response userId:{}, result:{}", userInfo.getUserId(), response);
-            JSONObject jsonObject = JSONObject.parseObject(response);
+              JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());
             }

+ 1 - 1
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/YiZhanShiShuZhiPingTaiCreditService.java

@@ -48,7 +48,7 @@ public class YiZhanShiShuZhiPingTaiCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());
             }
-            JSONObject jsonObject = JSONObject.parseObject(response);
+              JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());
             }

+ 1 - 1
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/YukuaihuaCreditService.java

@@ -48,7 +48,7 @@ public class YukuaihuaCreditService implements LoanDockingApi {
     }
 
     @Override
-    public DataVo qualityCheck(UserBaseInfoCmd userInfo, PlanCmd product, EgLoanApiConfigInfoCmd    configInfo)  {
+    public DataVo qualityCheck(UserBaseInfoCmd userInfo, PlanCmd product, EgLoanApiConfigInfoCmd configInfo, Function<HttpApiRequest, HttpApiResponse> httpClientFunc)  {
         try {
             log.info("credit YukuaihuaCreditService qualityCheck begin...userId:{}", userInfo.getUserId());
 //            XdProductJointConfig xdProductJointConfig = xdProductJointConfigMapper.selectById(product.getJointType());

+ 1 - 1
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/YunHaiLianDongCreditService.java

@@ -67,7 +67,7 @@ public class YunHaiLianDongCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());
             }
-            JSONObject jsonObject = JSONObject.parseObject(response);
+              JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
 //            log.info("credit qualityCheck YunHaiLianDongCreditService response userId:{}, jsonObject:{}", userInfo.getUserId(), jsonObject);
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());

+ 4 - 3
egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/ZhaoZhuangXinYiRongCreditService.java

@@ -43,9 +43,10 @@ public class ZhaoZhuangXinYiRongCreditService implements LoanDockingApi {
             String checkUrl = config.getString("checkUrl");
             String url=checkUrl+"?company="+config.getInteger("checkCompany")+"&mobile_md5="+checkInfo.getMobile_md5();
             log.info("credit qualityCheck ZhaoZhuangXinYiRongCreditService request userId:{}, url:{}, CheckInfo:{}",userInfo.getUserId(), url, checkInfo);
-            String response = null;
+            HttpApiResponse response = null;
             try{
-                response =httpRestTemplate.restTemplate().postForObject(url,checkInfo, String.class);
+                HttpApiRequest request=new HttpApiRequest(HttpApiRequestConfig.postRequest(JSON.toJSONString(checkInfo),"post",url));
+                response =httpClientFunc.apply(request);
             }catch (Exception e){
                 log.error("枣庄信易融准入异常,异常信息:{}", e.getMessage(), e);
             }
@@ -53,7 +54,7 @@ public class ZhaoZhuangXinYiRongCreditService implements LoanDockingApi {
             if (response == null) {
                 return DataVo.timeout(product.getPlanId(),product.getPlanName());
             }
-            JSONObject jsonObject=JSONObject.parseObject(response);
+             JSONObject jsonObject=JSONObject.parseObject(response.getData().toString());
 
             if (jsonObject == null) {
                 return DataVo.timeout(product.getPlanId(), product.getPlanName());