From f45078451d37f568f900e93b71d46caab5f02a04 Mon Sep 17 00:00:00 2001
From: gongquanlin <1025081659@qq.com>
Date: Wed, 29 Mar 2023 16:12:18 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B6=89=E5=8F=8A=E5=88=B0mdm=E7=9A=84?=
 =?UTF-8?q?=E5=85=A8=E9=83=A8=E5=8A=A0=E6=8A=A5=E6=96=87=E6=97=A5=E5=BF=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../order/consumer/openapi/api/InvoiceRestSDEnregy.java     | 6 +++---
 .../consumer/openapi/service/impl/SDEnregyServiceImpl.java  | 5 ++++-
 2 files changed, 7 insertions(+), 4 deletions(-)

diff --git a/order-management-consumer/src/main/java/com/dxhy/order/consumer/openapi/api/InvoiceRestSDEnregy.java b/order-management-consumer/src/main/java/com/dxhy/order/consumer/openapi/api/InvoiceRestSDEnregy.java
index 63fde1e6..43eecfc4 100644
--- a/order-management-consumer/src/main/java/com/dxhy/order/consumer/openapi/api/InvoiceRestSDEnregy.java
+++ b/order-management-consumer/src/main/java/com/dxhy/order/consumer/openapi/api/InvoiceRestSDEnregy.java
@@ -60,7 +60,7 @@ public class InvoiceRestSDEnregy {
     @PostMapping("/sync_buyer_message")
     public String syncBuyerMessage(@RequestBody String requestBody) {
         String logUUID = UUID.randomUUID().toString();
-        log.info("{}[syncBuyerMessage]，uuid:{},收到请求报文:{}", LOGGER_MSG, logUUID, requestBody);
+        log.info("{}[MDM客商同步接口]，uuid:{},收到请求报文:{}", LOGGER_MSG, logUUID, requestBody);
         // 接收请求报文，然后进行入库
         SDEnergyMdmBaseBO baseBO = JSONObject.parseObject(requestBody, SDEnergyMdmBaseBO.class);
         List<MdmGmfxxtbReqBO> mdmGmfxxtbReqBOS = (List<MdmGmfxxtbReqBO>) Optional.of(baseBO)
@@ -95,7 +95,7 @@ public class InvoiceRestSDEnregy {
     @PostMapping("/sync_group_tax")
     public String syncMdmGroupTax(@RequestBody String requestBody) {
         String logUUID = UUID.randomUUID().toString();
-        log.info("{}[syncMdmGroupTax]，uuid:{},收到请求报文:{}", LOGGER_MSG, logUUID, requestBody);
+        log.info("{}[MDM物料同步接口]，uuid:{},收到请求报文:{}", LOGGER_MSG, logUUID, requestBody);
         // 接收请求报文，然后进行入库
         SDEnergyMdmBaseBO baseBO = JSONObject.parseObject(requestBody, SDEnergyMdmBaseBO.class);
         List<MdmSyncGroupTaxCodeReqBO> mdmGmfxxtbReqBOS = (List<MdmSyncGroupTaxCodeReqBO>) Optional.of(baseBO)
@@ -129,7 +129,7 @@ public class InvoiceRestSDEnregy {
     @PostMapping("/sync_user")
     public String syncUser(@RequestBody String requestBody) {
         String logUUID = UUID.randomUUID().toString();
-        log.info("{}[syncMdmUser]，uuid:{},收到请求报文:{}", LOGGER_MSG, logUUID, requestBody);
+        log.info("{}[MDM人员同步接口]，uuid:{},收到请求报文:{}", LOGGER_MSG, logUUID, requestBody);
         // 接收请求报文，然后进行入库
         SDEnergyMdmBaseBO baseBO = JSONObject.parseObject(requestBody, SDEnergyMdmBaseBO.class);
         List<MdmSyncUserReqBO> mdmSyncUserReqBO = (List<MdmSyncUserReqBO>) Optional.of(baseBO)
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 281d7a44..47a7cc72 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
@@ -358,6 +358,7 @@ public class SDEnregyServiceImpl extends SDEnregyServiceAbstract {
                 "}";
 
         // 发送POST请求
+        log.info("[MDM主动同步物料]请求地址：{}，请求参数：{}", buyerUrl, requestBody);
         HttpResponse response = HttpRequest.post(groupTaxCodeUrl)
                 .timeout(20000)  // 设置请求超时时间
                 .header("Content-Type", "application/json")
@@ -366,6 +367,7 @@ public class SDEnregyServiceImpl extends SDEnregyServiceAbstract {
                 .body(requestBody)  // 设置请求体内容
                 .execute();
         String resp = response.body();
+        log.info("[MDM主动同步物料]响应结果：{}", resp);
 
         SDEnergyMdmBaseBO baseBO = JSONObject.parseObject(resp, SDEnergyMdmBaseBO.class);
         List<MdmSyncGroupTaxCodeReqBO> mdmGmfxxtbReqBOS = (List<MdmSyncGroupTaxCodeReqBO>) Optional.of(baseBO)
@@ -485,6 +487,7 @@ public class SDEnregyServiceImpl extends SDEnregyServiceAbstract {
                 "}";
 
         // 发送POST请求
+        log.info("[MDM主动同步人员]请求地址：{}，请求参数：{}", buyerUrl, requestBody);
         HttpResponse response = HttpRequest.post(groupTaxCodeUrl)
                 .timeout(20000)  // 设置请求超时时间
                 .header("Content-Type", "application/json")
@@ -493,7 +496,7 @@ public class SDEnregyServiceImpl extends SDEnregyServiceAbstract {
                 .body(requestBody)  // 设置请求体内容
                 .execute();
         String resp = response.body();
-        log.debug("同步人员信息返回结果：{}", resp);
+        log.info("[MDM主动同步人员]响应结果：{}", resp);
 
         SDEnergyMdmBaseBO baseBO = JSONObject.parseObject(resp, SDEnergyMdmBaseBO.class);
         List<MdmSyncUserReqBO> mdmSyncUserReqBO = (List<MdmSyncUserReqBO>) Optional.of(baseBO)