From d7837a1975780c21387c8b566be41eb94f04a6fa Mon Sep 17 00:00:00 2001 From: shikong <919411476@qq.com> Date: Tue, 17 Oct 2023 19:56:40 +0800 Subject: [PATCH] =?UTF-8?q?=E8=B0=83=E6=95=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../gb28181/wvp/service/gb28181/Gb28181DownloadService.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 3d4dfaa..8d9c3ac 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 @@ -189,7 +189,7 @@ public class Gb28181DownloadService { String cacheKey = CacheUtil.getKey(docking.getGbDeviceId(), device.getGbDeviceChannelId()); String existCallId = RedisUtil.StringOps.get(cacheKey); scheduledExecutorService.schedule(()->{ - log.info("到达结束时间 发送 bye 关闭"); + log.info("到达结束时间 发送 bye 关闭 {} {}", videoInfo.getDevice(), videoInfo.getCallId()); String deviceIp = docking.getIp(); int devicePort = Integer.parseInt(docking.getPort()); sender.sendRequest((provider,localIp,localPort)-> @@ -326,7 +326,7 @@ public class Gb28181DownloadService { sender.sendRequest((provider,localIp,localPort)-> SipRequestBuilder.createByeRequest(deviceIp, devicePort, device.getGbDeviceChannelId(), SipUtil.generateFromTag(), null, existCallId)); RedisUtil.KeyOps.delete(cacheKey); - log.info("关闭已存在的 点播请求 {} {}", cacheKey,existCallId); + log.info("关闭已存在的 点播请求 {} {}", cacheKey, existCallId); Thread.sleep(500); }