更新登录页面鉴权

log-manager/pom.xml

@@ -82,41 +82,6 @@
 				<skipDeploy>false</skipDeploy>
 			</properties>
 		</profile>
-
-		<profile>
-			<id>yibin-test</id>
-			<properties>
-				<profiles.active>yibin-test</profiles.active>
-				<profiles.server.ip>127.0.0.1</profiles.server.ip>
-				<profiles.server.port>18225</profiles.server.port>
-				<profiles.nginx.port>11092</profiles.nginx.port>
-				<profiles.server.gatewayport>11078</profiles.server.gatewayport>
-				<profiles.server.path>/logservice</profiles.server.path>
-				<profiles.publish.path>/home/publish</profiles.publish.path>
-				<profiles.datasource.uri>
-					<![CDATA[jdbc:mysql://127.0.0.1:3306/log-platform?useUnicode=true&characterEncoding=utf8&useSSL=false&serverTimezone=Hongkong]]></profiles.datasource.uri>
-				<profiles.datasource.username>root</profiles.datasource.username>
-				<profiles.datasource.password>nacos@2020</profiles.datasource.password>
-				<profiles.redis.uri>127.0.0.1</profiles.redis.uri>
-				<profiles.redis.port>6379</profiles.redis.port>
-				<profiles.redis.username></profiles.redis.username>
-				<profiles.redis.password>hotel@2020</profiles.redis.password>
-				<profiles.redis.database>9</profiles.redis.database>
-				<profiles.rabbitmq.host>127.0.0.1</profiles.rabbitmq.host>
-				<profiles.rabbitmq.port>5672</profiles.rabbitmq.port>
-				<profiles.rabbitmq.username>taxi_mq</profiles.rabbitmq.username>
-				<profiles.rabbitmq.password>admin@2020</profiles.rabbitmq.password>
-				<profiles.rabbitmq.virtualhost>/</profiles.rabbitmq.virtualhost>
-				<profiles.log.level>INFO</profiles.log.level>
-				<profiles.nacos.server-addr>127.0.0.1:8848</profiles.nacos.server-addr>
-				<profiles.nacos.group>DEFAULT_GROUP</profiles.nacos.group>
-				<profiles.nacos.namespace>smart-gov</profiles.nacos.namespace>
-				<profiles.log.path>/home/mortals/app/logs</profiles.log.path>
-				<profiles.filepath>/mortals/app/data</profiles.filepath>
-				<package.environment>test</package.environment>
-				<skipDeploy>false</skipDeploy>
-			</properties>
-		</profile>
 		<profile>
 			<id>product</id>
 			<properties>

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

@@ -85,6 +85,7 @@ public class AccessMessageConsumerListener {
                    // log.info("Duration:{}",entity.getDuration());
                     return null;
                 }
+                Thread.sleep(10);
                 return entity;
             } catch (Exception e) {
                 log.info("反序列化异常", e);

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

@@ -38,13 +38,18 @@ public class BizMessageConsumerListener {
     public void onMessage(List<BizLogEntity> messages) {
         log.info("[Biz onMessage][消息数量：{}]",  messages.size());
         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());
             entity.setId(IdUtil.getSnowflake(0, 1).nextId());
             entity.setCreateUserId(1L);
             entity.setCreateTime(new Date());
+            Thread.sleep(10);
+            } catch (Exception e) {
+                log.info("thread sleep ", e);
+            }
             return entity;
-        }).collect(Collectors.toList());
+        }).filter(f -> f != null).collect(Collectors.toList());
         bizLogService.save(collect);
     }