业务日志添加

log-manager/src/main/java/com/mortals/xhx/base/framework/listener/OperateMessageConsumerListener.java

@@ -54,11 +54,11 @@ public class OperateMessageConsumerListener {
     }*/
 
     @RabbitHandler
-    public void onMessage(List<String> messages){
-        log.info("[operate onMessage][线程编号:{} 消息数量：{}]", Thread.currentThread().getName() + Thread.currentThread().getId(), messages.size());
+    public void onMessage(List<String> messages) {
+        log.info("[operate onMessage][线程编号:{} 消息数量：{},消息类型:{},消息内容:{}]", Thread.currentThread().getName() + Thread.currentThread().getId(), messages.size(), messages.toString(), JSON.toJSONString(messages));
         List<OperateLogEntity> collect = messages.stream().map(message -> {
             try {
-                log.info("message:{}",message);
+                log.info("message:{}", message);
                 OperateLogEntity entity = JSON.parseObject(message, OperateLogEntity.class);
                 entity.setId(IdUtil.getSnowflake(0, 1).nextId());
                 entity.setCreateUserId(1L);
@@ -69,7 +69,7 @@ public class OperateMessageConsumerListener {
                 return null;
             }
         }).filter(f -> f != null).collect(Collectors.toList());
-        log.info("save collect size==>{}",collect.size());
+        log.info("save collect size==>{}", collect.size());
         operateLogService.save(collect);
     }
 }