aunix/wvp-GB28181-pro
1
0
Fork 0
mirror of https://gitee.com/pan648540858/wvp-GB28181-pro.git synced 2026-05-06 14:07:49 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

修复时间统计列表处理逻辑并增强心跳记录更新的异常处理

Browse Source
This commit is contained in:
lin 2026-03-30 14:28:52 +08:00
parent 2b090bbf23
commit 0dc297bf02
2 changed files with 10 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/main/java/com/genersoft/iot/vmp/gb28181/service/impl/DeviceServiceImpl.java
View File

@ -1307,7 +1307,9 @@ public class DeviceServiceImpl implements IDeviceService, CommandLineRunner {
} }
timeStatisticsList.add(timeStatistics); timeStatisticsList.add(timeStatistics);
} }
if (timeStatisticsList.size() > count) { // 第一个数据由于没有上一个时间戳，无法计算时间差，去掉
timeStatisticsList.removeFirst();
if (timeStatisticsList.size() - 1 > count) {
timeStatisticsList = timeStatisticsList.subList(timeStatisticsList.size() - count, timeStatisticsList.size()); timeStatisticsList = timeStatisticsList.subList(timeStatisticsList.size() - count, timeStatisticsList.size());
} }
return timeStatisticsList; return timeStatisticsList;

10
src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/notify/cmd/KeepaliveNotifyMessageHandler.java
View File

@ -94,9 +94,13 @@ public class KeepaliveNotifyMessageHandler extends SIPRequestProcessorParent imp
} }
@Scheduled(fixedDelay = 10, timeUnit = TimeUnit.SECONDS) @Scheduled(fixedDelay = 10, timeUnit = TimeUnit.SECONDS)
public void executeUpdateDeviceList() { public void executeUpdateDeviceList() {
if (!taskQueue.isEmpty()) { try {
redisCatchStorage.updateDeviceKeepaliveTimeStamp(taskQueue.stream().toList()); if (!taskQueue.isEmpty()) {
taskQueue.clear(); redisCatchStorage.updateDeviceKeepaliveTimeStamp(taskQueue.stream().toList());
taskQueue.clear();
}
} catch (Exception e) {
log.error("[定时任务] 更新心跳记录 执行异常", e);
} }
} }