From 54d39ae37ff245776b79ea4be4a1d6ed14feaf7e Mon Sep 17 00:00:00 2001
From: wyb <1977763549@qq.com>
Date: Fri, 24 Nov 2023 10:19:21 +0800
Subject: [PATCH] =?UTF-8?q?=E7=BB=9F=E4=B8=80=E6=B6=88=E6=81=AF=E6=8E=A5?=
 =?UTF-8?q?=E6=94=B6=E6=89=93=E5=8D=B0=E8=BF=94=E5=9B=9E=E6=B6=88=E6=81=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/impl/UnifyMessageServiceImpl.java     | 15 +++++++++++----
 1 file changed, 11 insertions(+), 4 deletions(-)

diff --git a/src/main/java/com/docus/server/message/service/impl/UnifyMessageServiceImpl.java b/src/main/java/com/docus/server/message/service/impl/UnifyMessageServiceImpl.java
index 50d2cc2..2da0034 100644
--- a/src/main/java/com/docus/server/message/service/impl/UnifyMessageServiceImpl.java
+++ b/src/main/java/com/docus/server/message/service/impl/UnifyMessageServiceImpl.java
@@ -48,24 +48,31 @@ public class UnifyMessageServiceImpl implements UnifyMessageService {
 
     @Override
     public String pushInformation(String method, String message) {
-        log.info("收到消息，方法：{}，消息为：{}",method,message);
+        String uuid = Func.randomUUID();
+        log.info("[{}] 收到消息，方法：{}，消息为：{}", uuid, method, message);
         MessageForwardConfig.MessageForward messageForward = MessageForwardConfig.wsMessageForward(method);
         if (messageForward == null || Func.isEmpty(messageForward.getUrls())) {
+            log.info("[{}] 返回消息：方法匹配错误！", uuid);
             return "方法匹配错误！";
         }
         DataFormatEnum dataFormatEnum = DataFormatEnum.fromValue(messageForward.getMessageDataType());
         if (dataFormatEnum == null) {
+            log.info("[{}] 返回消息：格式匹配错误！", uuid);
             return "格式匹配错误！";
         }
         UnifyMessage unifyMessage = saveMessage(method, message);
         try {
             List<MessageResponse> responseLis = messageCarrier.send(new Message(method, message), messageForward);
-            return verifyMessageResponseAndGetReturnMessage(responseLis);
+            String returnMessage = verifyMessageResponseAndGetReturnMessage(responseLis);
+            log.info("[{}] 返回消息：{}", uuid, returnMessage);
+            return returnMessage;
         } catch (Exception ex) {
             log.error(ex.getMessage(), ex);
             messageFailed(unifyMessage);
             MessageInfo messageInfo = new MessageInfo(dataFormatEnum, message);
-            return ResultUtil.dynamicParameterReplace(messageInfo, messageForward.getErrorResult());
+            String returnMessage = ResultUtil.dynamicParameterReplace(messageInfo, messageForward.getErrorResult());
+            log.info("[{}] 返回消息：{}", uuid, returnMessage);
+            return returnMessage;
         }
     }
 
@@ -78,7 +85,7 @@ public class UnifyMessageServiceImpl implements UnifyMessageService {
 
     private String verifyMessageResponseAndGetReturnMessage(List<MessageResponse> responseLis) {
         for (MessageResponse response : responseLis) {
-            if (response.getRetry()==1) {
+            if (response.getRetry() == 1) {
                 throw new RuntimeException("需要重试！");
             }
         }