From 6cc8c00bf5676c4ab247f2fcd9ce365aaa5644c9 Mon Sep 17 00:00:00 2001 From: "zhenghaiyang@ele-cloud.com" Date: Fri, 14 Apr 2023 21:56:56 +0800 Subject: [PATCH] =?UTF-8?q?feature=201.=E4=BF=AE=E6=94=B9=E6=8F=90?= =?UTF-8?q?=E7=A4=BA=E6=96=87=E6=A1=88?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../openapi/service/impl/SDEnregyServiceImpl.java | 15 ++++++++++----- 1 file changed, 10 insertions(+), 5 deletions(-) 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()); }