From 853fcbb7f34daa481e8141df8adb72cfaba6f144 Mon Sep 17 00:00:00 2001
From: 罗广辉 <guanghui.luo@foxmail.com>
Date: Fri, 18 Apr 2025 15:49:12 +0800
Subject: [PATCH] feat: 控制台ai直播功能
---
src/components/CurrentTaskDetails/CurrentTaskDetails.vue | 87 +++++++++++++++++++++++++++++++++++--------
1 files changed, 70 insertions(+), 17 deletions(-)
diff --git a/src/components/CurrentTaskDetails/CurrentTaskDetails.vue b/src/components/CurrentTaskDetails/CurrentTaskDetails.vue
index 649f760..cc4fe6f 100644
--- a/src/components/CurrentTaskDetails/CurrentTaskDetails.vue
+++ b/src/components/CurrentTaskDetails/CurrentTaskDetails.vue
@@ -23,7 +23,7 @@
<!-- 控制面板，里面有方法需要立即执行，不可用v-if -->
<ControlPanel v-show="!isAutoControl" />
- <img alt="" :src="amplifyImg" class="amplify" @click="amplify" />
+ <img alt="" :src="amplifyImg" class="amplify" @click="isMaxMap = !isMaxMap" />
</div>
</el-dialog>
</template>
@@ -45,18 +45,21 @@
import amplifyImg from '@/assets/images/taskManagement/taskIntermediateContent/amplifyImg.png'
import { ElMessage } from 'element-plus'
import EventBus from '@/event-bus'
+import { updateDroneQualityApi } from '@/api/drc'
+import { getLiveAiLinkApi } from '@/api/payload'
+import { CURRENT_CONFIG } from '@/utils/http/config'
const isAutoControl = ref(true)
const lineQuality = ref(1) //1流畅，2标清
provide('isAutoControl', isAutoControl)
provide('lineQuality', lineQuality)
-const isShow = defineModel('show')
-const props = defineProps(['id'])
-const currentLiveUrl = ref('')
+const taskDetailsViewer = ref(null)
+provide('taskDetailsViewer', taskDetailsViewer)
+
let taskDetails = ref({})
-const deviceOsdInfo = ref({})
provide('taskDetails', taskDetails)
+const deviceOsdInfo = ref({})
provide('deviceOsdInfo', deviceOsdInfo)
const dockSn = computed(() => taskDetails?.value?.device_sns?.[0])
@@ -64,24 +67,44 @@
provide('dockSn', dockSn)
provide('droneSn', droneSn)
-const isMaxMap = ref(false)
-const amplify = () => {
- isMaxMap.value = !isMaxMap.value
-}
+const isAiLive = ref(false)
+provide('isAiLive', isAiLive)
-// 机巢直播
+const isShow = defineModel('show')
+const props = defineProps(['id'])
+const currentLiveUrl = ref('')
+const isTakeOff = ref(false)
+const isMaxMap = ref(false)
+let droneWebSocket //WS实例
+
+const video_id = ref('')
+provide('video_id', video_id)
+
+// 获取机巢直播
const getDeviceLiveUrl = async () => {
const res = await liveStart(dockSn.value, 2)
currentLiveUrl.value = res.data.data.rtcs_url
}
-// 无人机直播画质切换
-const changeLineQuality = async () => {
- const res = await liveStart(droneSn.value, lineQuality.value)
+const getAiLiveUrl = ()=>{
+ const res = getLiveAiLinkApi({ original_stream_url: `${CURRENT_CONFIG.rtmpURL}${video_id.value}`, video_id:video_id.value })
currentLiveUrl.value = res.data.data.rtcs_url
+ isAiLive.value = true
}
-const isTakeOff = ref(false)
+// 获取无人机直播url
+async function getDroneLiveUrl() {
+ const res = await liveStart(droneSn.value, lineQuality.value)
+ currentLiveUrl.value = res.data.data.rtcs_url
+ video_id.value = res.data.data.video_id
+ isAiLive.value = false
+}
+
+// 无人机直播画质切换
+const changeLineQuality = async () => {
+ const res = await updateDroneQualityApi({ video_id: video_id.value, video_quality: lineQuality.value })
+ ElMessage.success('切换画质成功')
+}
// 设置当前直播地址
const setCurrentLiveUrl = async () => {
@@ -91,7 +114,7 @@
// 如果还是之前的状态，不切换
if (isTakeOff.value === currentIsTakeOff) return
isTakeOff.value = currentIsTakeOff
- isTakeOff.value ? await changeLineQuality() : await getDeviceLiveUrl()
+ isTakeOff.value ? await getDroneLiveUrl() : await getDeviceLiveUrl()
}
// 获取任务详情获取航线文件
@@ -105,14 +128,41 @@
})
}
+const dockOsdInfo = ref({})
+provide('dockOsdInfo', dockOsdInfo)
+
+const wsInfo = ref({})
+provide('wsInfo', wsInfo)
// websocket 的消息回调
const messageHandler = result => {
let payload = JSON.parse(result)
+ wsInfo.value[payload.biz_code] = payload
switch (payload.biz_code) {
+ // 无人机
case EBizCode.DeviceOsd: {
deviceOsdInfo.value = payload
setCurrentLiveUrl()
- console.log(deviceOsdInfo.value, 'device_osd信息')
+ console.log(payload, 'DeviceOsd--信息')
+ break
+ }
+ // 遥控器
+ case EBizCode.GatewayOsd: {
+ console.log(payload, 'GatewayOsd--信息')
+ break
+ }
+ // 机巢
+ case EBizCode.DockOsd: {
+ console.log(payload, 'DockOsd--信息')
+ break
+ }
+ // PsdkWidgetValues
+ case EBizCode.PsdkWidgetValues: {
+ console.log(payload, 'PsdkWidgetValues--信息')
+ break
+ }
+ // VideoSurveillance
+ case EBizCode.VideoSurveillance: {
+ console.log(payload, 'VideoSurveillance--信息')
break
}
default:
@@ -120,7 +170,6 @@
}
}
-let droneWebSocket
// 创建ws连接
const createWsConnect = () => {
const workspaceId = taskDetails.value.workspace_id
@@ -133,6 +182,8 @@
onMounted(() => {
getTaskDetails()
EventBus.on('CurrentTaskDetails-timeStop', changeLineQuality)
+ EventBus.on('CurrentTaskDetails-getAiLiveUrl', getAiLiveUrl)
+ EventBus.on('CurrentTaskDetails-getDroneLiveUrl', getDroneLiveUrl)
})
onBeforeUnmount(() => {
@@ -140,6 +191,8 @@
deviceOsdInfo.value = {}
droneWebSocket = null
EventBus.off('CurrentTaskDetails-timeStop', changeLineQuality)
+ EventBus.off('CurrentTaskDetails-getAiLiveUrl', getAiLiveUrl)
+ EventBus.off('CurrentTaskDetails-getDroneLiveUrl', getDroneLiveUrl)
})
</script>
--
Gitblit v1.9.3