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); }