From 45161fc9bbd809c5c678fe6770fed2ae83c831d8 Mon Sep 17 00:00:00 2001 From: "feng.li" Date: Fri, 20 Oct 2023 10:32:15 +0800 Subject: [PATCH] =?UTF-8?q?MDM=E8=AF=B7=E6=B1=82=E5=A2=9E=E5=8A=A0?= =?UTF-8?q?=E5=93=8D=E5=BA=94=E6=A0=A1=E9=AA=8C?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/cool/store/http/MDMHttpRequest.java | 13 +++++++++++++ 1 file changed, 13 insertions(+) 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()); + } + } }