diff --git a/coolstore-partner-service/src/main/java/com/cool/store/http/MDMHttpRequest.java b/coolstore-partner-service/src/main/java/com/cool/store/http/MDMHttpRequest.java index 5a53404b6..d3e40f036 100644 --- a/coolstore-partner-service/src/main/java/com/cool/store/http/MDMHttpRequest.java +++ b/coolstore-partner-service/src/main/java/com/cool/store/http/MDMHttpRequest.java @@ -80,6 +80,8 @@ public class MDMHttpRequest { RpcCreateQualifyVerifyReq.Data dataBody = new RpcCreateQualifyVerifyReq().new Data(); rpcRequest.setData(dataBody); responseEntity = RestTemplateUtil.post(url, headers, rpcRequest, MDMResultDTO.class); + log.info("url:{}, header:{}, response:{}", url, JSONObject.toJSONString(headers), JSONObject.toJSONString(responseEntity)); + checkResponse(responseEntity); return responseEntity; } catch (Exception e) { log.info("调用MDM接口出错 url{}, e{}", url, e); @@ -99,6 +101,7 @@ public class MDMHttpRequest { headers.put("Authorization",getMdmAccessToken()); responseEntity = RestTemplateUtil.get(url, headers, MDMResultDTO.class); log.info("url:{}, header:{}, response:{}", url, JSONObject.toJSONString(headers), JSONObject.toJSONString(responseEntity)); + checkResponse(responseEntity); if (Objects.nonNull(responseEntity.getBody()) && responseEntity.getBody().isSuccess()) { return responseEntity; } @@ -124,6 +127,8 @@ public class MDMHttpRequest { RpcCreateQualifyVerifyReq.Data dataBody = new RpcCreateQualifyVerifyReq().new Data(); rpcRequest.setData(dataBody); responseEntity = RestTemplateUtil.post(url, headers, rpcRequest, MDMResultDTO.class); + log.info("url:{}, header:{}, request:{} response:{}", url, JSONObject.toJSONString(headers), JSONObject.toJSONString(rpcRequest), JSONObject.toJSONString(responseEntity)); + checkResponse(responseEntity); return responseEntity; } catch (Exception e) { log.info("调用MDM接口出错 url{}, e{}", url, e); @@ -144,6 +149,7 @@ public class MDMHttpRequest { try { responseEntity = RestTemplateUtil.post(url, headers, rpcRequest, MDMResultDTO.class); log.info("url:{}, header:{}, request:{} response:{}", url, JSONObject.toJSONString(headers), JSONObject.toJSONString(rpcRequest), JSONObject.toJSONString(responseEntity)); + checkResponse(responseEntity); if (Objects.nonNull(responseEntity.getBody()) && responseEntity.getBody().isSuccess()) { return JSONObject.toJSONString(responseEntity.getBody().getData()); } @@ -169,6 +175,7 @@ public class MDMHttpRequest { param.add("file", resource); ResponseEntity responseEntity = RestTemplateUtil.post(url, headers, param, MDMResultDTO.class); log.info("url:{}, header:{}, response statusCode:{}", url, JSONObject.toJSONString(headers), JSONObject.toJSONString(responseEntity.getStatusCode())); + checkResponse(responseEntity); return responseEntity; } catch (Exception e) { log.info("调用MDM接口出错 url{}, e{}", url, e); @@ -176,5 +183,11 @@ public class MDMHttpRequest { } } + private void checkResponse(ResponseEntity MDMResp) throws ApiException { + int code = Objects.requireNonNull(MDMResp.getBody()).getCode(); + if (code != 200) { + throw new ApiException(MDMResp.getBody().getMessage()); + } + } }