统一消息接收打印返回消息

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("需要重试！");
             }
         }