From f4f4fc53260eb67483dce406a963628273786a61 Mon Sep 17 00:00:00 2001
From: liusuyi <1951119284@qq.com>
Date: Sat, 30 May 2026 17:22:17 +0800
Subject: [PATCH] 优化
---
ard-modules/ard-modules-zlm/src/main/java/com/ard/zlm/service/impl/MediaServiceImpl.java | 108 +++++++++++++++++++++++++++---------------------------
1 files changed, 54 insertions(+), 54 deletions(-)
diff --git a/ard-modules/ard-modules-zlm/src/main/java/com/ard/zlm/service/impl/MediaServiceImpl.java b/ard-modules/ard-modules-zlm/src/main/java/com/ard/zlm/service/impl/MediaServiceImpl.java
index 5386cb5..cad5265 100644
--- a/ard-modules/ard-modules-zlm/src/main/java/com/ard/zlm/service/impl/MediaServiceImpl.java
+++ b/ard-modules/ard-modules-zlm/src/main/java/com/ard/zlm/service/impl/MediaServiceImpl.java
@@ -51,60 +51,60 @@
@Override
public boolean closeStreamOnNoneReader(String mediaServerId, String app, String stream, String schema) {
- R<QsDevice> r = remoteQsDeviceService.getQsDeviceStream(stream, SecurityConstants.INNER);
- if (r.getCode() != Constants.SUCCESS) {
- return false;
- }
-
- QsDevice data = r.getData();
- if (data == null) {
- return false;
- }
-
- // 拉流代理
- if ("rtsp".equals(app) || "rtmp".equals(app) || "flv".equals(app) || "hls".equals(app)) {
- if ("1".equals(data.getEnableDisableNoneReader())) {
- // 无人观看停用
- // 修改数据
- StreamPullPlay streamPullPlay = new StreamPullPlay();
- streamPullPlay.setDeviceId(data.getId());
- streamPullPlay.setStreamKey(data.getStreamKey());
- streamPullPlay.setMediaServerId(data.getMediaServerId());
-
- mediaServerService.stopStreamPullPlay(streamPullPlay);
- return true;
- } else {
- return false;
- }
- } else if ("haikang".equals(app) || "haikang_isup".equals(app) || "dahua".equals(app)) {
- if ("1".equals(data.getEnableDisableNoneReader())) {
- // 无人观看停用
- RTPServerParam rtpServerParam = new RTPServerParam();
- rtpServerParam.setId(data.getId());
- rtpServerParam.setType(data.getType());
- rtpServerParam.setStreamId(stream);
- mediaServerService.stopRtpPlay(rtpServerParam);
- return true;
- } else {
- return false;
- }
- } else if ("push".equals(app)) {
- if ("1".equals(data.getEnableDisableNoneReader())) {
- return true;
- } else {
- return false;
- }
- } else if ("gb28181".equals(app)) {
- if ("1".equals(data.getEnableDisableNoneReader())) {
- R<Device> deviceR = remoteGb28181Service.getDeviceByDeviceId(data.getGbDeviceId(), SecurityConstants.INNER);
- if (deviceR.getCode() == Constants.SUCCESS && deviceR.getData() != null) {
- mediaServerService.stopGb28181Play(InviteSessionType.PLAY, data, deviceR.getData(), data.getDeviceCode());
- }
- return true;
- } else {
- return false;
- }
- }
+// R<QsDevice> r = remoteQsDeviceService.getQsDeviceStream(stream, SecurityConstants.INNER);
+// if (r.getCode() != Constants.SUCCESS) {
+// return false;
+// }
+//
+// QsDevice data = r.getData();
+// if (data == null) {
+// return false;
+// }
+//
+// // 拉流代理
+// if ("rtsp".equals(app) || "rtmp".equals(app) || "flv".equals(app) || "hls".equals(app)) {
+// if ("1".equals(data.getEnableDisableNoneReader())) {
+// // 无人观看停用
+// // 修改数据
+// StreamPullPlay streamPullPlay = new StreamPullPlay();
+// streamPullPlay.setDeviceId(data.getId());
+// streamPullPlay.setStreamKey(data.getStreamKey());
+// streamPullPlay.setMediaServerId(data.getMediaServerId());
+//
+// mediaServerService.stopStreamPullPlay(streamPullPlay);
+// return true;
+// } else {
+// return false;
+// }
+// } else if ("haikang".equals(app) || "haikang_isup".equals(app) || "dahua".equals(app)) {
+// if ("1".equals(data.getEnableDisableNoneReader())) {
+// // 无人观看停用
+// RTPServerParam rtpServerParam = new RTPServerParam();
+// rtpServerParam.setId(data.getId());
+// rtpServerParam.setType(data.getType());
+// rtpServerParam.setStreamId(stream);
+// mediaServerService.stopRtpPlay(rtpServerParam);
+// return true;
+// } else {
+// return false;
+// }
+// } else if ("push".equals(app)) {
+// if ("1".equals(data.getEnableDisableNoneReader())) {
+// return true;
+// } else {
+// return false;
+// }
+// } else if ("gb28181".equals(app)) {
+// if ("1".equals(data.getEnableDisableNoneReader())) {
+// R<Device> deviceR = remoteGb28181Service.getDeviceByDeviceId(data.getGbDeviceId(), SecurityConstants.INNER);
+// if (deviceR.getCode() == Constants.SUCCESS && deviceR.getData() != null) {
+// mediaServerService.stopGb28181Play(InviteSessionType.PLAY, data, deviceR.getData(), data.getDeviceCode());
+// }
+// return true;
+// } else {
+// return false;
+// }
+// }
return true;
}
--
Gitblit v1.9.3