diff --git a/gb28181-wvp-proxy-service/src/main/java/cn/skcks/docking/gb28181/wvp/service/gb28181/Gb28181DownloadService.java b/gb28181-wvp-proxy-service/src/main/java/cn/skcks/docking/gb28181/wvp/service/gb28181/Gb28181DownloadService.java index 3cc0d41..3d4dfaa 100644 --- a/gb28181-wvp-proxy-service/src/main/java/cn/skcks/docking/gb28181/wvp/service/gb28181/Gb28181DownloadService.java +++ b/gb28181-wvp-proxy-service/src/main/java/cn/skcks/docking/gb28181/wvp/service/gb28181/Gb28181DownloadService.java @@ -186,10 +186,10 @@ public class Gb28181DownloadService { return result; } download(deviceCode, startTime, endTime).whenComplete((videoInfo, e)->{ - log.info("到达结束时间 发送 bye 关闭"); String cacheKey = CacheUtil.getKey(docking.getGbDeviceId(), device.getGbDeviceChannelId()); String existCallId = RedisUtil.StringOps.get(cacheKey); scheduledExecutorService.schedule(()->{ + log.info("到达结束时间 发送 bye 关闭"); String deviceIp = docking.getIp(); int devicePort = Integer.parseInt(docking.getPort()); sender.sendRequest((provider,localIp,localPort)->