Commit 3f25b0e3 authored by 赵啸非's avatar 赵啸非

异常日志前端展示添加

parent cd22cc96
...@@ -17,7 +17,7 @@ module.exports = { ...@@ -17,7 +17,7 @@ module.exports = {
hot: true,//自动保存 hot: true,//自动保存
proxy: { proxy: {
'/logservice': { '/logservice': {
target: 'http://192.168.0.98:18225', target: 'http://127.0.0.1:18225',
changeOrigin: true, changeOrigin: true,
secure: false, secure: false,
cookieDomainRewrite: 'plm.testnew.com', cookieDomainRewrite: 'plm.testnew.com',
......
...@@ -48,7 +48,7 @@ public class AccessMessageConsumerListener { ...@@ -48,7 +48,7 @@ public class AccessMessageConsumerListener {
@RabbitHandler @RabbitHandler
public void onMessage(@Payload List<String> messages, Channel channel) throws Exception { public void onMessage(@Payload List<String> messages, Channel channel) throws Exception {
log.info("[onMessage][线程编号:{} 消息数量:{}]", Thread.currentThread().getId(), messages.size()); log.info("[Access onMessage][线程编号:{} 消息数量:{}]", Thread.currentThread().getName()+Thread.currentThread().getId(), messages.size());
// messages.forEach(entity -> { // messages.forEach(entity -> {
// entity.setId(IdUtil.getSnowflake(0, 1).nextId()); // entity.setId(IdUtil.getSnowflake(0, 1).nextId());
......
...@@ -34,7 +34,7 @@ public class BizMessageConsumerListener { ...@@ -34,7 +34,7 @@ public class BizMessageConsumerListener {
@RabbitHandler @RabbitHandler
public void onMessage(List<String> messages) { public void onMessage(List<String> messages) {
log.info("[onMessage][线程编号:{} 消息数量:{}]", Thread.currentThread().getId(), messages.size()); log.info("[Biz onMessage][线程编号:{} 消息数量:{}]", Thread.currentThread().getName()+Thread.currentThread().getId(), messages.size());
List<BizLogEntity> collect = messages.stream().map(str -> { List<BizLogEntity> collect = messages.stream().map(str -> {
BizLogEntity entity = JSON.parseObject(str, BizLogEntity.class); BizLogEntity entity = JSON.parseObject(str, BizLogEntity.class);
entity.setCreateUserId(1L); entity.setCreateUserId(1L);
......
...@@ -41,7 +41,7 @@ public class ErrorMessageConsumerListener { ...@@ -41,7 +41,7 @@ public class ErrorMessageConsumerListener {
@RabbitHandler @RabbitHandler
public void onMessage(List<String> messages) throws Exception { public void onMessage(List<String> messages) throws Exception {
log.info("[onMessage][线程编号:{} 消息数量:{}]", Thread.currentThread().getId(), messages.size()); log.info("[Error onMessage][线程编号:{} 消息数量:{}]", Thread.currentThread().getName()+Thread.currentThread().getId(), messages.size());
messages.stream().peek(str -> { messages.stream().peek(str -> {
ErrorLogEntity entity = JSON.parseObject(str, ErrorLogEntity.class); ErrorLogEntity entity = JSON.parseObject(str, ErrorLogEntity.class);
......
...@@ -40,7 +40,7 @@ public class OperateMessageConsumerListener { ...@@ -40,7 +40,7 @@ public class OperateMessageConsumerListener {
@RabbitHandler @RabbitHandler
public void onMessage(@Payload List<String> messages, Channel channel) throws Exception { public void onMessage(@Payload List<String> messages, Channel channel) throws Exception {
log.info("[OperateLog onMessage][线程编号:{} 消息数量:{}]", Thread.currentThread().getId(), messages.size()); log.info("[Oper onMessage][线程编号:{} 消息数量:{}]", Thread.currentThread().getName()+Thread.currentThread().getId(), messages.size());
List<OperateLogEntity> collect = messages.stream().map(str -> { List<OperateLogEntity> collect = messages.stream().map(str -> {
OperateLogEntity entity = JSON.parseObject(str, OperateLogEntity.class); OperateLogEntity entity = JSON.parseObject(str, OperateLogEntity.class);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment