涉及到mdm的全部加报文日志

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)

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)