lihongjie/coal
1
0
Fork 0
mirror of https://codeup.aliyun.com/64f7d6b8ce01efaafef1e678/coal/coal.git synced 2026-01-25 07:46:40 +08:00
Code Issues Packages Projects Releases Wiki Activity

性能优化

Browse Source
This commit is contained in:
lihongjie0209
2024-04-01 17:47:19 +08:00
parent d08835e32e
commit d6281c6764
1 changed files with 9 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
src/main/java/cn/lihongjie/coal/dataCollector/listener/DataCollectorListener.java
View File

@@ -29,8 +29,7 @@ public class DataCollectorListener {
@Autowired DataCollectorService dataCollectorService;
@Autowired
DataCollectorLogService dataCollectorLogService;
@Autowired DataCollectorLogService dataCollectorLogService;
@RabbitListener(
bindings = {
@@ -68,24 +67,24 @@ public class DataCollectorListener {
DataCollectorLogEntity log = new DataCollectorLogEntity();
log.setDataCollector(dataCollector);
log.setOrganizationId(dataCollector.getOrganizationId() );
log.setOrganizationId(dataCollector.getOrganizationId());
log.setLogTime(LocalDateTime.now());
Object rk = headers.get(AmqpHeaders.RECEIVED_ROUTING_KEY);
switch (rk.toString()) {
case "dataCollector.online":
dataCollector.setLastLoginTime(LocalDateTime.now());
log.setContent("online");
log.setType("online");
break;
case "dataCollector.offline":
dataCollector.setLastLogoutTime(LocalDateTime.now());
log.setContent("offline");
log.setType("offline");
break;
case "dataCollector.heartbeat":
dataCollector.setHeartbeatTime(LocalDateTime.now());
log.setContent("heartbeat");
log.setType("heartbeat");
break;
default:
@@ -94,6 +93,9 @@ public class DataCollectorListener {
}
dataCollectorService.save(dataCollector);
dataCollectorLogService.save(log);
// 心跳不记录日志
if (!StringUtils.equals(rk.toString(), "dataCollector.heartbeat")) {
dataCollectorLogService.save(log);
}
}
}