Commit a181b8fe authored by 赵啸非's avatar 赵啸非

添加服务检测拉起脚本

parent ced9ce9f
...@@ -39,6 +39,7 @@ public class BizMessageConsumerListener { ...@@ -39,6 +39,7 @@ public class BizMessageConsumerListener {
log.info("[Biz onMessage][消息数量:{}]", messages.size()); log.info("[Biz onMessage][消息数量:{}]", messages.size());
List<BizLogEntity> collect = messages.stream().map(entity -> { List<BizLogEntity> collect = messages.stream().map(entity -> {
// BizLogEntity entity = JSON.parseObject(new String(str, Charset.defaultCharset()), BizLogEntity.class); // 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.setId(IdUtil.getSnowflake(0, 1).nextId());
entity.setCreateUserId(1L); entity.setCreateUserId(1L);
entity.setCreateTime(new Date()); entity.setCreateTime(new Date());
......
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