diff --git a/order-management-consumer/src/main/java/com/dxhy/order/consumer/openapi/service/impl/SDEnregyServiceImpl.java b/order-management-consumer/src/main/java/com/dxhy/order/consumer/openapi/service/impl/SDEnregyServiceImpl.java index 05118375..3c9aef50 100644 --- a/order-management-consumer/src/main/java/com/dxhy/order/consumer/openapi/service/impl/SDEnregyServiceImpl.java +++ b/order-management-consumer/src/main/java/com/dxhy/order/consumer/openapi/service/impl/SDEnregyServiceImpl.java @@ -448,11 +448,11 @@ public class SDEnregyServiceImpl extends SDEnregyServiceAbstract { String resp = response.body(); log.info("[MDM主动同步物料]响应结果:{}", resp); if(StringUtils.isBlank(resp)){ - return R.error("未查询到数据!"); + return R.error("获取物料信息失败,请检查客户编码是否正确"); } SDEnergyMdmBaseBO baseBO = JSONObject.parseObject(resp, SDEnergyMdmBaseBO.class); if(baseBO == null || baseBO.getESB() == null || !"S".equals(baseBO.getESB().getRESULT())){ - return R.error("未查询到数据!"); + return R.error("获取物料信息失败,请检查客户编码是否正确"); } List mdmGmfxxtbReqBOS = (List) Optional.of(baseBO) .map(SDEnergyMdmBaseBO::getESB) @@ -469,7 +469,7 @@ public class SDEnregyServiceImpl extends SDEnregyServiceAbstract { AjaxResult syncResult = this.syncMdmGroupTax(mdmGmfxxtbReqBOS, resp); if (syncResult.isSuccess()) { - return R.ok(); + return R.ok("获取物料信息成功"); } else { return R.error(syncResult.getMsg()); } @@ -536,8 +536,13 @@ public class SDEnregyServiceImpl extends SDEnregyServiceAbstract { .execute(); String resp = response.body(); log.info("[MDM主动同步客商]响应结果:{}", resp); - + if(StringUtils.isBlank(resp)){ + return R.error("获取客户信息失败,请检查客户编码是否正确"); + } SDEnergyMdmBaseBO baseBO = JSONObject.parseObject(resp, SDEnergyMdmBaseBO.class); + if(baseBO == null || baseBO.getESB() == null || !"S".equals(baseBO.getESB().getRESULT())){ + return R.error("获取客户信息失败,请检查客户编码是否正确"); + } List mdmGmfxxtbReqBOS = (List) Optional.of(baseBO) .map(SDEnergyMdmBaseBO::getESB) .map(ESBBO::getDATA) @@ -553,7 +558,7 @@ public class SDEnregyServiceImpl extends SDEnregyServiceAbstract { AjaxResult syncResult = this.syncBuyerMessage(mdmGmfxxtbReqBOS, resp); if (syncResult.isSuccess()) { - return R.ok(); + return R.ok("获取客户信息成功"); } else { return R.error(syncResult.getMsg()); }