diff --git a/mhd_oms/src/main/java/com/mhd/oms/application/service/businessDocumentOrder/BusinessDocumentOrderApplicationService.java b/mhd_oms/src/main/java/com/mhd/oms/application/service/businessDocumentOrder/BusinessDocumentOrderApplicationService.java
index b0d93950f..cfb40e274 100644
--- a/mhd_oms/src/main/java/com/mhd/oms/application/service/businessDocumentOrder/BusinessDocumentOrderApplicationService.java
+++ b/mhd_oms/src/main/java/com/mhd/oms/application/service/businessDocumentOrder/BusinessDocumentOrderApplicationService.java
@@ -251,11 +251,27 @@ public class BusinessDocumentOrderApplicationService {
                 gwLog.setResponseBody(responseString);
 
                 if (response.getStatusLine().getStatusCode() == 200) {
-                    gwLog.setStatus(2);
-                    if (pushData.getId() != null) {
+//                    gwLog.setStatus(2);
+//                    if (pushData.getId() != null) {
+//                        updatePushStatus(pushData.getId(), 3, new Date(), String.valueOf(pushBy), pushByName);
+//                    }
+//                    successCount++;
+
+                    JSONObject responseJson = JSONObject.parseObject(responseString);
+
+                    Integer dataCode = responseJson.getInteger("code");
+
+                    if (dataCode != null && dataCode == 200) {
+                        gwLog.setStatus(2);
                         updatePushStatus(pushData.getId(), 3, new Date(), String.valueOf(pushBy), pushByName);
+                        successCount++;
+                    } else {
+                        gwLog.setStatus(3);
+                        gwLog.setErrorMsg(responseString);
+                        updatePushStatus(pushData.getId(), 4, new Date(), String.valueOf(pushBy), pushByName);
+                        failCount++;
+                        failMsg.append("物料编码:").append(pushData.getMaterialCode()).append("失败;");
                     }
-                    successCount++;
                 } else {
                     gwLog.setStatus(3);
                     gwLog.setErrorMsg(responseString);
diff --git a/mhd_oms/src/main/java/com/mhd/oms/application/service/erpCountry/ErpCountryApplicationService.java b/mhd_oms/src/main/java/com/mhd/oms/application/service/erpCountry/ErpCountryApplicationService.java
index ada4c5b42..04cbd0e98 100644
--- a/mhd_oms/src/main/java/com/mhd/oms/application/service/erpCountry/ErpCountryApplicationService.java
+++ b/mhd_oms/src/main/java/com/mhd/oms/application/service/erpCountry/ErpCountryApplicationService.java
@@ -153,9 +153,21 @@ public class ErpCountryApplicationService{
                 gwLog.setResponseBody(responseString);
 
                 if (response.getStatusLine().getStatusCode() == 200) {
-                    gwLog.setStatus(2);
-                    updatePushStatus(dto.getId(), 3, new Date(), pushBy,pushByName);
-                    successCount++;
+                    JSONObject responseJson = JSONObject.parseObject(responseString);
+
+                    Integer dataCode = responseJson.getInteger("code");
+
+                    if (dataCode != null && dataCode == 200) {
+                        gwLog.setStatus(2);
+                        updatePushStatus(dto.getId(), 3, new Date(), pushBy, pushByName);
+                        successCount++;
+                    } else {
+                        gwLog.setStatus(3);
+                        gwLog.setErrorMsg(responseString);
+                        updatePushStatus(dto.getId(), 4, new Date(), pushBy, pushByName);
+                        failCount++;
+                        failMsg.append("erpCountryCode:").append(dto.getErpCountryCode()).append("失败;");
+                    }
                 } else {
                     gwLog.setStatus(3);
                     gwLog.setErrorMsg(responseString);
diff --git a/mhd_oms/src/main/java/com/mhd/oms/application/service/erpEnterpriseUnit/ErpEnterpriseUnitApplicationService.java b/mhd_oms/src/main/java/com/mhd/oms/application/service/erpEnterpriseUnit/ErpEnterpriseUnitApplicationService.java
index cf645126e..9d2964bd6 100644
--- a/mhd_oms/src/main/java/com/mhd/oms/application/service/erpEnterpriseUnit/ErpEnterpriseUnitApplicationService.java
+++ b/mhd_oms/src/main/java/com/mhd/oms/application/service/erpEnterpriseUnit/ErpEnterpriseUnitApplicationService.java
@@ -159,9 +159,21 @@ public class ErpEnterpriseUnitApplicationService {
                 gwLog.setResponseBody(responseString);
 
                 if (response.getStatusLine().getStatusCode() == 200) {
-                    gwLog.setStatus(2);
-                    updatePushStatus(dto.getId(), 3, new Date(), pushBy,pushByName);
-                    successCount++;
+                    JSONObject responseJson = JSONObject.parseObject(responseString);
+
+                    Integer dataCode = responseJson.getInteger("code");
+
+                    if (dataCode != null && dataCode == 200) {
+                        gwLog.setStatus(2);
+                        updatePushStatus(dto.getId(), 3, new Date(), pushBy, pushByName);
+                        successCount++;
+                    } else {
+                        gwLog.setStatus(3);
+                        gwLog.setErrorMsg(responseString);
+                        updatePushStatus(dto.getId(), 4, new Date(), pushBy, pushByName);
+                        failCount++;
+                        failMsg.append("erpUnitCode:").append(dto.getErpCode()).append("失败;");
+                    }
                 } else {
                     gwLog.setStatus(3);
                     gwLog.setErrorMsg(responseString);
diff --git a/mhd_oms/src/main/java/com/mhd/oms/application/service/exchangeRate/ExchangeRateApplicationService.java b/mhd_oms/src/main/java/com/mhd/oms/application/service/exchangeRate/ExchangeRateApplicationService.java
index 7649e424d..9e66acf70 100644
--- a/mhd_oms/src/main/java/com/mhd/oms/application/service/exchangeRate/ExchangeRateApplicationService.java
+++ b/mhd_oms/src/main/java/com/mhd/oms/application/service/exchangeRate/ExchangeRateApplicationService.java
@@ -136,9 +136,22 @@ public class ExchangeRateApplicationService {
                 gwLog.setResponseBody(responseString);
 
                 if (response.getStatusLine().getStatusCode() == 200) {
-                    gwLog.setStatus(2);
-                    updateExchangeRatePushStatus(dto.getId(), 3, new Date(), pushBy, pushByName);
-                    successCount++;
+                    JSONObject responseJson = JSONObject.parseObject(responseString);
+
+                    // 判断业务状态：data.code = 200 成功，data.code = 500 或其他 失败
+                    Integer dataCode = responseJson.getInteger("code");
+
+                    if (dataCode != null && dataCode == 200) {  // 业务也成功
+                        gwLog.setStatus(2);
+                        updateExchangeRatePushStatus(dto.getId(), 3, new Date(), pushBy, pushByName);
+                        successCount++;
+                    } else {
+                        gwLog.setStatus(3);
+                        gwLog.setErrorMsg(responseString);
+                        updateExchangeRatePushStatus(dto.getId(), 4, new Date(), pushBy, pushByName);
+                        failCount++;
+                        failMsg.append("erpCurrCode:").append(dto.getErpCurrCode()).append("失败;");
+                    }
                 } else {
                     gwLog.setStatus(3);
                     gwLog.setErrorMsg(responseString);
diff --git a/mhd_oms/src/main/java/com/mhd/oms/application/service/materialInfo/MaterialInfoApplicationService.java b/mhd_oms/src/main/java/com/mhd/oms/application/service/materialInfo/MaterialInfoApplicationService.java
index 46bb9f600..2e669264d 100644
--- a/mhd_oms/src/main/java/com/mhd/oms/application/service/materialInfo/MaterialInfoApplicationService.java
+++ b/mhd_oms/src/main/java/com/mhd/oms/application/service/materialInfo/MaterialInfoApplicationService.java
@@ -126,9 +126,21 @@ public class MaterialInfoApplicationService {
                 gwLog.setResponseBody(responseString);
 
                 if (response.getStatusLine().getStatusCode() == 200) {
-                    gwLog.setStatus(2);
-                    updatePushStatus(dto.getMaterialBaseInfoId(), 3, new Date(), pushBy, pushByName);
-                    successCount++;
+                    JSONObject responseJson = JSONObject.parseObject(responseString);
+
+                    Integer dataCode = responseJson.getInteger("code");
+
+                    if (dataCode != null && dataCode == 200) {
+                        gwLog.setStatus(2);
+                        updatePushStatus(dto.getMaterialBaseInfoId(), 3, new Date(), pushBy, pushByName);
+                        successCount++;
+                    } else {
+                        gwLog.setStatus(3);
+                        gwLog.setErrorMsg(responseString);
+                        updatePushStatus(dto.getMaterialBaseInfoId(), 4, new Date(), pushBy, pushByName);
+                        failCount++;
+                        failMsg.append("materialCode:").append(dto.getMaterialCode()).append("失败;");
+                    }
                 } else {
                     gwLog.setStatus(3);
                     gwLog.setErrorMsg(responseString);