From a14aa010851dfc7d9957cabda474f32a58be6e82 Mon Sep 17 00:00:00 2001
From: liusuyi <1951119284@qq.com>
Date: Wed, 21 Jan 2026 13:20:50 +0800
Subject: [PATCH] 退出增加事件监听
---
ard-vtdu/src/main/java/com/ard/vtdu/service/impl/ArdVtduServiceImpl.java | 30 +++++++++++++++++++++++++-----
1 files changed, 25 insertions(+), 5 deletions(-)
diff --git a/ard-vtdu/src/main/java/com/ard/vtdu/service/impl/ArdVtduServiceImpl.java b/ard-vtdu/src/main/java/com/ard/vtdu/service/impl/ArdVtduServiceImpl.java
index f144994..62f3855 100644
--- a/ard-vtdu/src/main/java/com/ard/vtdu/service/impl/ArdVtduServiceImpl.java
+++ b/ard-vtdu/src/main/java/com/ard/vtdu/service/impl/ArdVtduServiceImpl.java
@@ -13,6 +13,8 @@
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.security.authentication.event.AuthenticationSuccessEvent;
import com.ard.common.core.domain.model.LoginUser;
+import org.springframework.security.authentication.event.LogoutSuccessEvent;
+import org.springframework.security.core.Authentication;
import org.springframework.stereotype.Service;
import javax.annotation.PostConstruct;
@@ -140,6 +142,9 @@
public void clearAllArdVtdu() {
ardVtduMapper.clearAllArdVtdu();
}
+
+
+
//需要更新的（流媒体和vtdu相同）
@Override
@@ -270,16 +275,31 @@
if (principal instanceof LoginUser) {
LoginUser loginUser = (LoginUser) principal; // 传统强制类型转换
Long userId = loginUser.getUser().getUserId();
- String username = loginUser.getUsername();
+ String name="user_" + userId;
+ // 1️⃣ 判断数据库是否已存在
+ ArdVtdu existing = ardVtduMapper.selectArdVtduByName(name);
+ if (existing != null) {
+ log.info("流媒体【{}】已存在，跳过插入", name);
+ return;
+ }
ArdVtdu ardVtdu = ArdVtdu.builder()
- .name("user_" + userId) // 用 userId 作为流名称
+ .name(name) // 用 userId 作为流名称
.rtspSource("publisher") // 或 "publisher"，按业务区分
.build();
// 本地库插入
insertArdVtdu(ardVtdu);
- log.info("用户【{}】登录，立即加入流媒体", username);
- } else {
- log.warn("登录事件 principal 不是 LoginUser，无法获取 userId");
+ log.info("用户【{}】登录，立即加入流媒体", name);
+ }
+ }
+ @EventListener
+ public void handleLogout(LogoutSuccessEvent event) {
+ Object principal = event.getAuthentication().getPrincipal();
+ if (principal instanceof LoginUser) {
+ LoginUser loginUser = (LoginUser) principal; // 传统强制类型转换
+ Long userId = loginUser.getUser().getUserId();
+ String name="user_" + userId;
+ deleteArdVtduByName(name);
+ log.info("用户【{}】注销，立即移除流媒体", name);
}
}
}
--
Gitblit v1.9.3