Răsfoiți Sursa

add 测试通过代码

GITZYY 8 luni în urmă
părinte
comite
b0e501c609

+ 1 - 2
egress-gateway-service-app/src/main/java/com/hrsk/cloud/eg/app/threedocking/impl/GexinjinfuCreditService.java

@@ -88,8 +88,7 @@ public class GexinjinfuCreditService implements LoanDockingApi {
             try{
                 Map<String, String> head = new HashMap<>();
                 head.put("Content-Type", "application/x-www-form-urlencoded; charset=UTF-8");
-                String httpResponse = httpRestTemplate.restTemplate().getForObject(url, String.class,head);
-                response = JSONObject.parseObject(httpResponse,ResultHt.class);
+                 response = httpRestTemplate.restTemplate().getForObject(url, ResultHt.class,head);
             }catch (Exception e){
                 log.error("格鑫金服准入异常,异常信息:{}", e.getMessage(), e);
             }

+ 1 - 0
egress-gateway-service-app/src/main/java/com/hrsk/cloud/eg/app/threedocking/impl/HuirongCrmCreditService.java

@@ -82,6 +82,7 @@ public class HuirongCrmCreditService implements LoanDockingApi {
                HttpHeaders headers = new HttpHeaders();
                headers.set("Content-Type", "application/json");
                HttpEntity httpEntity = new HttpEntity<>(requestJson,headers);
+               //post方式如果出现对接 请求体 为空参考这种方式
                 response = httpRestTemplate.restTemplate().postForObject(url,httpEntity,ResultHt.class);
               log.info("hui ron result {}",JSONObject.toJSONString(response));
             } catch (Exception e) {

+ 7 - 5
egress-gateway-service-app/src/main/java/com/hrsk/cloud/eg/app/threedocking/impl/XinluCreditService.java

@@ -12,6 +12,8 @@ import com.hrsk.cloud.eg.infrastructure.service.ProductBusinessApiInfoService;
 import com.hrsk.cloud.eg.vo.response.DataVo;
 import lombok.Data;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.http.HttpEntity;
+import org.springframework.http.HttpHeaders;
 import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
@@ -72,7 +74,7 @@ public class XinluCreditService implements LoanDockingApi {
             String configJson = apiInfo.getThreeSystemConfig();
             JSONObject xinluJointDTO = JSONObject.parseObject(configJson);
             log.info("鑫鹿对接参数:{}", JSONObject.toJSONString(xinluJointDTO));
-            String url = xinluJointDTO.getString("url");
+            String url = xinluJointDTO.getString("checkUrl");
             CheckData checkData = new CheckData();
             checkData.setPhone(userInfo.getPhoneMd5());
             checkData.setType(2);
@@ -81,10 +83,10 @@ public class XinluCreditService implements LoanDockingApi {
             log.info("credit qualityCheck XinluCreditService request userId:{}, url:{},requestParam",userInfo.getUserId(), url,requestJson);
             ResultHt response = null;
             try{
-                Map<String, String> head = new HashMap<>();
-                head.put("Content-Type", "application/json");
-                String httpResponse = httpRestTemplate.restTemplate().postForObject(url, head, String.class,requestJson );
-                response = JSONObject.parseObject(httpResponse,ResultHt.class);
+                HttpHeaders headers = new HttpHeaders();
+                headers.set("Content-Type", "application/json");
+                HttpEntity httpEntity = new HttpEntity<>(requestJson,headers);
+                 response = httpRestTemplate.restTemplate().postForObject(url,httpEntity, ResultHt.class );
             }catch (Exception e){
                 log.error("鑫鹿准入异常,异常信息:{}", e.getMessage(), e);
             }

+ 5 - 5
start/src/test/java/StartApiTest.java

@@ -383,19 +383,19 @@ public class StartApiTest {
         user.setUserMobile("18385143735");
 
         CheckIntoParamDto checkin =new CheckIntoParamDto();
-        ProductBusinessApiInfoDo apiInfoByRedis = productBusinessApiInfoService.getApiInfoByRedis(1492);
-//        List<ProductBusinessApiInfoDo> productBusinessApiInfoDos = productBusinessApiInfoService.apiList();
-//        for (ProductBusinessApiInfoDo productBusinessApiInfoDo : productBusinessApiInfoDos) {
+//        ProductBusinessApiInfoDo apiInfoByRedis = productBusinessApiInfoService.getApiInfoByRedis(750);
+        List<ProductBusinessApiInfoDo> productBusinessApiInfoDos = productBusinessApiInfoService.apiList();
+        for (ProductBusinessApiInfoDo productBusinessApiInfoDo : productBusinessApiInfoDos) {
 //        ExecutorService executorService= Executors.newFixedThreadPool(75);
 //            executorService.execute(()->{
                 PlanDto  plan =new PlanDto();
-                plan.setApiId(apiInfoByRedis.getId());
+                plan.setApiId(productBusinessApiInfoDo.getId());
                 plan.setBid("aff1c7b30d8b240826030235business");
                 checkin.setPlan(plan);
                 checkin.setUser(user);
                 apiRouteService.loanCheckInto(checkin);
 //            });
-//        }
+        }
 
     }