From c1655bdeb5cb215ac0f49716f99d7f764abf143d Mon Sep 17 00:00:00 2001 From: shikong <919411476@qq.com> Date: Tue, 17 Oct 2023 17:20:53 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=AD=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../gb28181/wvp/service/gb28181/Gb28181DownloadService.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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)->