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 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 responseLis) { for (MessageResponse response : responseLis) { - if (response.getRetry()==1) { + if (response.getRetry() == 1) { throw new RuntimeException("需要重试!"); } }