From 252e5230703e4355d25274d21b84f2d060907416 Mon Sep 17 00:00:00 2001
From: liusuyi <13324259@qq.com>
Date: 星期五, 14 七月 2023 21:49:39 +0800
Subject: [PATCH] 提交拉流取流查询接口
---
ard-work/src/main/java/com/ruoyi/media/service/impl/MediaService.java | 45 +++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 45 insertions(+), 0 deletions(-)
diff --git a/ard-work/src/main/java/com/ruoyi/media/service/impl/MediaService.java b/ard-work/src/main/java/com/ruoyi/media/service/impl/MediaService.java
index 73a8650..00e5413 100644
--- a/ard-work/src/main/java/com/ruoyi/media/service/impl/MediaService.java
+++ b/ard-work/src/main/java/com/ruoyi/media/service/impl/MediaService.java
@@ -8,6 +8,7 @@
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
+import java.util.ArrayList;
import java.util.List;
/**
@@ -77,4 +78,48 @@
JsonsRoot jsonsRoot = JSONObject.parseObject(list, JsonsRoot.class);
return jsonsRoot.getItems();
}
+
+ @Override
+ public RtspSession getRtspSessionById(String sessionId) {
+ String apiUrl="http://"+mediamtxHost+":9997/v2";
+ String list = mediaClient.getRtspsessionById(apiUrl,sessionId);
+ RtspSession rtspSession = JSONObject.parseObject(list, RtspSession.class);
+ return rtspSession;
+ }
+
+ @Override
+ public List<RtspSession> getPushStreams() {
+ List<RtspSession> rtspSessions=new ArrayList<>();
+ String apiUrl="http://"+mediamtxHost+":9997/v2";
+ String list = mediaClient.paths(apiUrl);
+ JsonsRoot jsonsRoot = JSONObject.parseObject(list, JsonsRoot.class);
+ List<Items> items = jsonsRoot.getItems();
+ for(Items item:items)
+ {
+ Source source = item.getSource();
+ RtspSession rtspSession = getRtspSessionById(source.getId());
+ rtspSession.setCameraId(item.getName());
+ rtspSessions.add(rtspSession);
+ }
+ return rtspSessions;
+ }
+
+ @Override
+ public List<RtspSession> getPullStreams() {
+ List<RtspSession> rtspSessions=new ArrayList<>();
+ String apiUrl="http://"+mediamtxHost+":9997/v2";
+ String list = mediaClient.paths(apiUrl);
+ JsonsRoot jsonsRoot = JSONObject.parseObject(list, JsonsRoot.class);
+ List<Items> items = jsonsRoot.getItems();
+ for(Items item:items)
+ {
+ List<Readers> readers = item.getReaders();
+ for(Readers reader:readers) {
+ RtspSession rtspSession = getRtspSessionById(reader.getId());
+ rtspSession.setCameraId(item.getName());
+ rtspSessions.add(rtspSession);
+ }
+ }
+ return rtspSessions;
+ }
}
--
Gitblit v1.9.3