业务日志添加

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

@@ -17,7 +17,9 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.messaging.handler.annotation.Headers;
 import org.springframework.messaging.handler.annotation.Payload;
 import org.springframework.stereotype.Component;
+import org.springframework.util.ObjectUtils;
 
+import java.util.ArrayList;
 import java.util.Date;
 import java.util.List;
 import java.util.Map;
@@ -55,8 +57,29 @@ public class OperateMessageConsumerListener {
 
     @RabbitHandler
     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 -> {
+        log.info("[operate onMessage][线程编号:{} 消息数量：{}]", Thread.currentThread().getName() + Thread.currentThread().getId(), messages.size());
+        ArrayList<OperateLogEntity> list = new ArrayList<>();
+        for (String message : messages) {
+            OperateLogEntity entity = null;
+            try {
+                log.info("message:{}", message);
+                entity = JSON.parseObject(message, OperateLogEntity.class);
+                entity.setId(IdUtil.getSnowflake(0, 1).nextId());
+                entity.setCreateUserId(1L);
+                entity.setCreateTime(new Date());
+            } catch (Exception e) {
+                log.info("反序列化异常", e);
+            }
+            if (entity != null) {
+                list.add(entity);
+            }
+        }
+
+        if(!ObjectUtils.isEmpty(list)){
+            operateLogService.save(list);
+        }
+
+      /*  List<OperateLogEntity> collect = messages.stream().map(message -> {
             try {
                 log.info("message:{}", message);
                 OperateLogEntity entity = JSON.parseObject(message, OperateLogEntity.class);
@@ -70,6 +93,6 @@ public class OperateMessageConsumerListener {
             }
         }).filter(f -> f != null).collect(Collectors.toList());
         log.info("save collect size==>{}", collect.size());
-        operateLogService.save(collect);
+        operateLogService.save(collect);*/
     }
 }