业务日志添加

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

@@ -58,8 +58,8 @@ public class OperateMessageConsumerListener {
         log.info("[operate onMessage][线程编号:{} 消息数量：{}]", Thread.currentThread().getName() + Thread.currentThread().getId(), messages.size());
         List<OperateLogEntity> collect = messages.stream().map(message -> {
             try {
-                OperateLogEntity entity = null;
-                entity = JSON.parseObject(message, OperateLogEntity.class);
+                log.info("message:{}",message);
+                OperateLogEntity entity = JSON.parseObject(message, OperateLogEntity.class);
                 entity.setId(IdUtil.getSnowflake(0, 1).nextId());
                 entity.setCreateUserId(1L);
                 entity.setCreateTime(new Date());
@@ -69,6 +69,7 @@ public class OperateMessageConsumerListener {
                 return null;
             }
         }).filter(f -> f != null).collect(Collectors.toList());
+        log.info("save collect size==>{}",collect.size());
         operateLogService.save(collect);
     }
 }