业务日志添加

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

@@ -56,7 +56,7 @@ public class AccessMessageConsumerListener {
     }
 
     @RabbitHandler
-    public void onMessage(@Payload List<String> messages) throws Exception {
+    public void onMessage(List<String> messages) throws Exception {
         log.info("[Access onMessage][线程编号:{} 消息数量：{}]", Thread.currentThread().getName() + Thread.currentThread().getId(), messages.size());
 
         List<AccessLogEntity> collect = messages.stream().map(message -> {

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

@@ -42,12 +42,10 @@ public class ErrorMessageConsumerListener {
     @RabbitHandler
     public void onMessage(List<String> messages) throws Exception {
         log.info("[Error onMessage][线程编号:{} 消息数量：{}]", Thread.currentThread().getName()+Thread.currentThread().getId(), messages.size());
-
         messages.stream().peek(str -> {
             ErrorLogEntity entity = JSON.parseObject(str, ErrorLogEntity.class);
             entity.setCreateUserId(1L);
             entity.setCreateTime(new Date());
-
             if (!ObjectUtils.isEmpty(entity.getFingerprint())) {
              //// TODO: 2022/8/24 指纹匹配
             } else {
@@ -56,7 +54,6 @@ public class ErrorMessageConsumerListener {
                 errorLogQuery.setAppName(entity.getAppName());
                 errorLogQuery.setPlatform(entity.getPlatform());
                 errorLogQuery.setMessage(entity.getMessage());
-
                 ErrorLogEntity errorLogEntity = errorLogService.selectOne(errorLogQuery, null);
                 if (!ObjectUtils.isEmpty(errorLogEntity)) {
                     errorLogEntity.setCheckNum(errorLogEntity.getCheckNum()+1);

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

@@ -3,6 +3,7 @@ package com.mortals.xhx.base.framework.listener;
 import cn.hutool.core.util.IdUtil;
 import com.alibaba.fastjson.JSON;
 import com.mortals.xhx.common.key.QueueKey;
+import com.mortals.xhx.module.access.model.AccessLogEntity;
 import com.mortals.xhx.module.error.model.ErrorLogEntity;
 import com.mortals.xhx.module.error.service.ErrorLogService;
 import com.mortals.xhx.module.operate.model.OperateLogEntity;
@@ -38,9 +39,9 @@ public class OperateMessageConsumerListener {
     @Autowired
     private OperateLogService operateLogService;
 
-    @RabbitHandler
+   /* @RabbitHandler
     public void onMessage(@Payload List<String> messages, Channel channel) throws Exception {
-        log.info("[Oper onMessage][线程编号:{} 消息数量：{}]", Thread.currentThread().getName()+Thread.currentThread().getId(), messages.size());
+        log.info("[Oper onMessage][线程编号:{} 消息数量：{}]", Thread.currentThread().getName() + Thread.currentThread().getId(), messages.size());
 
         List<OperateLogEntity> collect = messages.stream().map(str -> {
             OperateLogEntity entity = JSON.parseObject(str, OperateLogEntity.class);
@@ -50,5 +51,24 @@ public class OperateMessageConsumerListener {
             return entity;
         }).collect(Collectors.toList());
         operateLogService.save(collect);
+    }*/
+
+    @RabbitHandler
+    public void onMessage(List<String> messages){
+        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);
+                entity.setId(IdUtil.getSnowflake(0, 1).nextId());
+                entity.setCreateUserId(1L);
+                entity.setCreateTime(new Date());
+                return entity;
+            } catch (Exception e) {
+                log.info("反序列化异常", e);
+                return null;
+            }
+        }).filter(f -> f != null).collect(Collectors.toList());
+        operateLogService.save(collect);
     }
 }