suzhuhong/zxjp-web
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

MDM请求增加响应校验

Browse Source
This commit is contained in:
feng.li
2023-10-20 10:32:15 +08:00
parent f003392307
commit 45161fc9bb
1 changed files with 13 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
coolstore-partner-service/src/main/java/com/cool/store/http/MDMHttpRequest.java
View File

@@ -80,6 +80,8 @@ public class MDMHttpRequest {
RpcCreateQualifyVerifyReq.Data dataBody = new RpcCreateQualifyVerifyReq().new Data(); RpcCreateQualifyVerifyReq.Data dataBody = new RpcCreateQualifyVerifyReq().new Data();
rpcRequest.setData(dataBody); rpcRequest.setData(dataBody);
responseEntity = RestTemplateUtil.post(url, headers, rpcRequest, MDMResultDTO.class); responseEntity = RestTemplateUtil.post(url, headers, rpcRequest, MDMResultDTO.class);
log.info("url:{}, header:{}, response:{}", url, JSONObject.toJSONString(headers), JSONObject.toJSONString(responseEntity));
checkResponse(responseEntity);
return responseEntity; return responseEntity;
} catch (Exception e) { } catch (Exception e) {
log.info("调用MDM接口出错 url{}, e{}", url, e); log.info("调用MDM接口出错 url{}, e{}", url, e);
@@ -99,6 +101,7 @@ public class MDMHttpRequest {
headers.put("Authorization",getMdmAccessToken()); headers.put("Authorization",getMdmAccessToken());
responseEntity = RestTemplateUtil.get(url, headers, MDMResultDTO.class); responseEntity = RestTemplateUtil.get(url, headers, MDMResultDTO.class);
log.info("url:{}, header:{}, response:{}", url, JSONObject.toJSONString(headers), JSONObject.toJSONString(responseEntity)); log.info("url:{}, header:{}, response:{}", url, JSONObject.toJSONString(headers), JSONObject.toJSONString(responseEntity));
checkResponse(responseEntity);
if (Objects.nonNull(responseEntity.getBody()) && responseEntity.getBody().isSuccess()) { if (Objects.nonNull(responseEntity.getBody()) && responseEntity.getBody().isSuccess()) {
return responseEntity; return responseEntity;
} }
@@ -124,6 +127,8 @@ public class MDMHttpRequest {
RpcCreateQualifyVerifyReq.Data dataBody = new RpcCreateQualifyVerifyReq().new Data(); RpcCreateQualifyVerifyReq.Data dataBody = new RpcCreateQualifyVerifyReq().new Data();
rpcRequest.setData(dataBody); rpcRequest.setData(dataBody);
responseEntity = RestTemplateUtil.post(url, headers, rpcRequest, MDMResultDTO.class); 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; return responseEntity;
} catch (Exception e) { } catch (Exception e) {
log.info("调用MDM接口出错 url{}, e{}", url, e); log.info("调用MDM接口出错 url{}, e{}", url, e);
@@ -144,6 +149,7 @@ public class MDMHttpRequest {
try { try {
responseEntity = RestTemplateUtil.post(url, headers, rpcRequest, MDMResultDTO.class); responseEntity = RestTemplateUtil.post(url, headers, rpcRequest, MDMResultDTO.class);
log.info("url:{}, header:{}, request:{} response:{}", url, JSONObject.toJSONString(headers), JSONObject.toJSONString(rpcRequest), JSONObject.toJSONString(responseEntity)); 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()) { if (Objects.nonNull(responseEntity.getBody()) && responseEntity.getBody().isSuccess()) {
return JSONObject.toJSONString(responseEntity.getBody().getData()); return JSONObject.toJSONString(responseEntity.getBody().getData());
} }
@@ -169,6 +175,7 @@ public class MDMHttpRequest {
param.add("file", resource); param.add("file", resource);
ResponseEntity<MDMResultDTO> responseEntity = RestTemplateUtil.post(url, headers, param, MDMResultDTO.class); ResponseEntity<MDMResultDTO> responseEntity = RestTemplateUtil.post(url, headers, param, MDMResultDTO.class);
log.info("url:{}, header:{}, response statusCode:{}", url, JSONObject.toJSONString(headers), JSONObject.toJSONString(responseEntity.getStatusCode())); log.info("url:{}, header:{}, response statusCode:{}", url, JSONObject.toJSONString(headers), JSONObject.toJSONString(responseEntity.getStatusCode()));
checkResponse(responseEntity);
return responseEntity; return responseEntity;
} catch (Exception e) { } catch (Exception e) {
log.info("调用MDM接口出错 url{}, e{}", url, e); log.info("调用MDM接口出错 url{}, e{}", url, e);
@@ -176,5 +183,11 @@ public class MDMHttpRequest {
} }
} }
private void checkResponse(ResponseEntity<MDMResultDTO> MDMResp) throws ApiException {
int code = Objects.requireNonNull(MDMResp.getBody()).getCode();
if (code != 200) {
throw new ApiException(MDMResp.getBody().getMessage());
}
}
} }