From a0741df5a2cff792740d7d31f7101ba2339ba3ec Mon Sep 17 00:00:00 2001
From: zhaowenyu <35589726@qq.com>
Date: Tue, 09 Dec 2025 15:30:36 +0800
Subject: [PATCH] 2025-12-09 zwy 增加机场飞行器摄像头切换状态通道，增加LiveStatusTwoReceiver路由
---
ard-admin/src/main/java/com/ard/web/controller/sample/LiveStreamController.java | 31 +++++++++++++++++++++++++++++++
1 files changed, 31 insertions(+), 0 deletions(-)
diff --git a/ard-admin/src/main/java/com/ard/web/controller/sample/LiveStreamController.java b/ard-admin/src/main/java/com/ard/web/controller/sample/LiveStreamController.java
index 03a960e..5b20d0c 100644
--- a/ard-admin/src/main/java/com/ard/web/controller/sample/LiveStreamController.java
+++ b/ard-admin/src/main/java/com/ard/web/controller/sample/LiveStreamController.java
@@ -4,9 +4,13 @@
import com.ard.common.utils.SecurityUtils;
import com.ard.sample.common.model.ResponseResult;
import com.ard.sample.component.mqtt.model.ChannelName;
+import com.ard.sample.component.websocket.handler.LiveStreamHandler;
import com.ard.sample.manage.model.dto.CapacityDeviceDTO;
import com.ard.sample.manage.model.dto.LiveTypeDTO;
+import com.ard.sample.manage.model.param.RemoteDebugParam;
import com.ard.sample.manage.model.receiver.LiveCapacityReceiver;
+import com.ard.sample.manage.model.receiver.LiveStatusTwoReceiver;
+import com.ard.sample.manage.service.IDeviceService;
import com.ard.sample.manage.service.ILiveStreamService;
import com.fasterxml.jackson.databind.ObjectMapper;
import io.swagger.annotations.Api;
@@ -37,6 +41,9 @@
private ILiveStreamService liveStreamService;
@Autowired
+ private LiveStreamHandler _liveStreamHandler;
+
+ @Autowired
private ObjectMapper mapper;
/**
@@ -48,6 +55,15 @@
@ServiceActivator(inputChannel = ChannelName.INBOUND_STATE_CAPACITY)
public void stateCapacity(LiveCapacityReceiver liveCapacity, MessageHeaders headers) {
liveStreamService.saveLiveCapacity(liveCapacity, headers.getTimestamp());
+ }
+
+
+ /**
+ * 处理摄像头返回状态
+ * */
+ @ServiceActivator(inputChannel = ChannelName.INBOUND_STATE_STATUS)
+ public void LiveStateStatus(LiveStatusTwoReceiver liveReceiver, MessageHeaders headers) {
+ log.info("摄像头返回状态通道INBOUND_STATE_STATUS:{}", liveReceiver);
}
/**
@@ -66,6 +82,21 @@
return ResponseResult.success(liveCapacity);
}
+ @ApiOperation("获取video_id")
+ @PostMapping("/videoid/{sn}")
+ public ResponseResult<LiveTypeDTO> getVideoId(@PathVariable String sn) {
+ LiveTypeDTO liveTypeDTO = new LiveTypeDTO();
+ try{
+ liveTypeDTO = _liveStreamHandler.getLiveParam(sn);
+
+ }
+ catch (Exception e){
+ // videoId = e.getMessage();
+ e.printStackTrace();
+ }
+ return ResponseResult.success(liveTypeDTO);
+ }
+
/**
* Live streaming according to the parameters passed in from the web side.
*
--
Gitblit v1.9.3