From 7bb0cc19f46bf388e8c0498ff473c96675933e34 Mon Sep 17 00:00:00 2001 From: 648540858 <648540858@qq.com> Date: Thu, 22 May 2025 07:09:20 +0800 Subject: [PATCH] =?UTF-8?q?=E9=87=8D=E6=9E=84=E5=B9=B3=E5=8F=B0=E4=BF=9D?= =?UTF-8?q?=E6=B4=BB=E9=80=BB=E8=BE=91-=E5=90=AF=E5=8A=A8=E5=AF=B9?= =?UTF-8?q?=E6=9C=AA=E7=A6=BB=E7=BA=BF=E7=9A=84=E5=B9=B3=E5=8F=B0=E6=B3=A8?= =?UTF-8?q?=E9=94=80?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../vmp/gb28181/service/impl/PlatformServiceImpl.java | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/genersoft/iot/vmp/gb28181/service/impl/PlatformServiceImpl.java b/src/main/java/com/genersoft/iot/vmp/gb28181/service/impl/PlatformServiceImpl.java index b8792d961..81d430ccb 100755 --- a/src/main/java/com/genersoft/iot/vmp/gb28181/service/impl/PlatformServiceImpl.java +++ b/src/main/java/com/genersoft/iot/vmp/gb28181/service/impl/PlatformServiceImpl.java @@ -123,12 +123,18 @@ public class PlatformServiceImpl implements IPlatformService, CommandLineRunner return; } for (PlatformRegisterTaskInfo taskInfo : registerTaskInfoList) { - + log.info("[国标级联] 启动服务是发现平台注册仍在有效期,注销: {}", taskInfo.getPlatformServerId()); + Platform platform = queryPlatformByServerGBId(taskInfo.getPlatformServerId()); + commanderForPlatform.unregister(platform, taskInfo.getSipTransactionInfo(), null, eventResult -> { + log.info("[国标级联] 注销成功, 平台:{}", taskInfo.getPlatformServerId()); + }); } } - // 每隔20秒检测,是否存在启用但是未注册的平台,存在则发起注册 + // TODO 每隔20秒检测,是否存在启用但是未注册的平台,存在则发起注册 + // TODO 平台注册成功通知处理 + // TODO 平台注销成功通知处理 // 定时监听国标级联所进行的WVP服务是否正常, 如果异常则选择新的wvp执行 @Scheduled(fixedDelay = 2, timeUnit = TimeUnit.SECONDS) //每3秒执行一次