更新登录页面鉴权

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

@@ -72,7 +72,7 @@ public class AccessMessageConsumerListener {
     @RabbitHandler
     public void onMessage(List<AccessLogEntity> messages) {
 
-        List<AccessLogEntity> collect = messages.stream().map(entity -> {
+     /*   List<AccessLogEntity> collect = messages.stream().map(entity -> {
             try {
                 // AccessLogEntity entity =null;
                 //entity = JSON.parseObject(message, AccessLogEntity.class);
@@ -94,7 +94,7 @@ public class AccessMessageConsumerListener {
 
         }).filter(f -> f != null).collect(Collectors.toList());
         log.info("[Access onMessage][消息数量：{}]", collect.size());
-        accessLogService.save(collect);
+        accessLogService.save(collect);*/
     }
 
 

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

@@ -37,7 +37,7 @@ public class BizMessageConsumerListener {
     @RabbitHandler
     public void onMessage(List<BizLogEntity> messages) {
         log.info("[Biz onMessage][消息数量：{}]",  messages.size());
-        List<BizLogEntity> collect = messages.stream().map(entity -> {
+/*        List<BizLogEntity> collect = messages.stream().map(entity -> {
             try {
            // BizLogEntity entity = JSON.parseObject(new String(str, Charset.defaultCharset()), BizLogEntity.class);
             entity.setLogTime(entity.getLogTime()==null?new Date():entity.getLogTime());
@@ -50,7 +50,7 @@ public class BizMessageConsumerListener {
             }
             return entity;
         }).filter(f -> f != null).collect(Collectors.toList());
-        bizLogService.save(collect);
+        bizLogService.save(collect);*/
     }
 
 }

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

@@ -67,7 +67,7 @@ public class ErrorMessageConsumerListener {
             }*/
 
 
-            errorLogService.save(entity);
+          //  errorLogService.save(entity);
         }).count();
     }
 }

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

@@ -55,7 +55,7 @@ public class OperateMessageConsumerListener {
     @RabbitHandler
     public void onMessage(List<OperateLogEntity> messages) {
         log.info("[Oper onMessage][消息数量：{}]", messages.size());
-        List<OperateLogEntity> collect = messages.stream().map(entity -> {
+/*        List<OperateLogEntity> collect = messages.stream().map(entity -> {
             //OperateLogEntity entity = JSON.parseObject(new String(str), OperateLogEntity.class);
 
             entity.setId(IdUtil.getSnowflake(0, 1).nextId());
@@ -63,6 +63,6 @@ public class OperateMessageConsumerListener {
             entity.setCreateTime(new Date());
             return entity;
         }).collect(Collectors.toList());
-        operateLogService.save(collect);
+        operateLogService.save(collect);*/
     }
 }

log-manager/src/main/resources/bootstrap.yml

@@ -58,6 +58,11 @@ spring:
     url: @profiles.datasource.uri@
     username: @profiles.datasource.username@
     password: @profiles.datasource.password@
+    initial-size: 5
+    min-idle: 5
+    max-active: 20
+    # 配置获取连接等待超时的时间
+    max-wait: 60000
 
 mybatis:
   root-path: com.mortals