From 2e98b20bea4463e4465e3c19059d0744a09aec06 Mon Sep 17 00:00:00 2001
From: zhongrj <646384940@qq.com>
Date: Tue, 27 Jun 2023 14:34:41 +0800
Subject: [PATCH] gb28181版本升级-补充
---
src/main/java/com/genersoft/iot/vmp/vmanager/gb28181/gbStream/GbStreamController.java | 103 +++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 103 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/genersoft/iot/vmp/vmanager/gb28181/gbStream/GbStreamController.java b/src/main/java/com/genersoft/iot/vmp/vmanager/gb28181/gbStream/GbStreamController.java
new file mode 100644
index 0000000..3ba032a
--- /dev/null
+++ b/src/main/java/com/genersoft/iot/vmp/vmanager/gb28181/gbStream/GbStreamController.java
@@ -0,0 +1,103 @@
+package com.genersoft.iot.vmp.vmanager.gb28181.gbStream;
+
+import com.genersoft.iot.vmp.gb28181.bean.GbStream;
+import com.genersoft.iot.vmp.storager.IVideoManagerStorage;
+import com.genersoft.iot.vmp.vmanager.gb28181.gbStream.bean.GbStreamParam;
+import com.genersoft.iot.vmp.service.IGbStreamService;
+import com.github.pagehelper.PageInfo;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.Parameter;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.util.ObjectUtils;
+import org.springframework.util.StringUtils;
+import org.springframework.web.bind.annotation.*;
+
+@Tag(name = "视频流关联到级联平台")
+@CrossOrigin
+@RestController
+@RequestMapping("/api/gbStream")
+public class GbStreamController {
+
+ private final static Logger logger = LoggerFactory.getLogger(GbStreamController.class);
+
+ @Autowired
+ private IGbStreamService gbStreamService;
+
+ @Autowired
+ private IVideoManagerStorage storager;
+
+
+ /**
+ * 查询国标通道
+ * @param page 当前页
+ * @param count 每页条数
+ * @param platformId 平台ID
+ * @return
+ */
+ @Operation(summary = "查询国标通道")
+ @Parameter(name = "page", description = "当前页", required = true)
+ @Parameter(name = "count", description = "每页条数", required = true)
+ @Parameter(name = "platformId", description = "平台ID", required = true)
+ @Parameter(name = "catalogId", description = "目录ID")
+ @Parameter(name = "query", description = "查询内容")
+ @Parameter(name = "mediaServerId", description = "流媒体ID")
+ @GetMapping(value = "/list")
+ @ResponseBody
+ public PageInfo<GbStream> list(@RequestParam(required = true)Integer page,
+ @RequestParam(required = true)Integer count,
+ @RequestParam(required = true)String platformId,
+ @RequestParam(required = false)String catalogId,
+ @RequestParam(required = false)String query,
+ @RequestParam(required = false)String mediaServerId){
+ if (ObjectUtils.isEmpty(catalogId)) {
+ catalogId = null;
+ }
+ if (ObjectUtils.isEmpty(query)) {
+ query = null;
+ }
+ if (ObjectUtils.isEmpty(mediaServerId)) {
+ mediaServerId = null;
+ }
+
+ // catalogId 为null 查询未在平台下分配的数据
+ // catalogId 不为null 查询平台下这个，目录下的通道
+ return gbStreamService.getAll(page, count, platformId, catalogId, query, mediaServerId);
+ }
+
+
+ /**
+ * 移除国标关联
+ * @param gbStreamParam
+ * @return
+ */
+ @Operation(summary = "移除国标关联")
+ @DeleteMapping(value = "/del")
+ @ResponseBody
+ public Object del(@RequestBody GbStreamParam gbStreamParam){
+ if (gbStreamService.delPlatformInfo(gbStreamParam.getPlatformId(), gbStreamParam.getGbStreams())) {
+ return "success";
+ }else {
+ return "fail";
+ }
+
+ }
+
+ /**
+ * 保存国标关联
+ * @param gbStreamParam
+ * @return
+ */
+ @Operation(summary = "保存国标关联")
+ @PostMapping(value = "/add")
+ @ResponseBody
+ public Object add(@RequestBody GbStreamParam gbStreamParam){
+ if (gbStreamService.addPlatformInfo(gbStreamParam.getGbStreams(), gbStreamParam.getPlatformId(), gbStreamParam.getCatalogId())) {
+ return "success";
+ }else {
+ return "fail";
+ }
+ }
+}
--
Gitblit v1.9.3