Shikong/gb28181-docking-platform-proxy
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

修正

Browse Source
This commit is contained in:
shikong 2023-10-17 17:20:53 +08:00
parent 81822ff553
commit c1655bdeb5
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
gb28181-wvp-proxy-service/src/main/java/cn/skcks/docking/gb28181/wvp/service/gb28181/Gb28181DownloadService.java
View File

@ -186,10 +186,10 @@ public class Gb28181DownloadService {
return result; return result;
} }
download(deviceCode, startTime, endTime).whenComplete((videoInfo, e)->{ download(deviceCode, startTime, endTime).whenComplete((videoInfo, e)->{
log.info("到达结束时间 发送 bye 关闭");
String cacheKey = CacheUtil.getKey(docking.getGbDeviceId(), device.getGbDeviceChannelId()); String cacheKey = CacheUtil.getKey(docking.getGbDeviceId(), device.getGbDeviceChannelId());
String existCallId = RedisUtil.StringOps.get(cacheKey); String existCallId = RedisUtil.StringOps.get(cacheKey);
scheduledExecutorService.schedule(()->{ scheduledExecutorService.schedule(()->{
log.info("到达结束时间 发送 bye 关闭");
String deviceIp = docking.getIp(); String deviceIp = docking.getIp();
int devicePort = Integer.parseInt(docking.getPort()); int devicePort = Integer.parseInt(docking.getPort());
sender.sendRequest((provider,localIp,localPort)-> sender.sendRequest((provider,localIp,localPort)->