feat: 控制台ai直播功能

罗广辉

2025-04-18 853fcbb7f34daa481e8141df8adb72cfaba6f144

 src/components/CurrentTaskDetails/CurrentTaskDetails.vue

@@ -18,8 +18,8 @@
         <TaskDetailsRight v-if="isAutoControl" />
         <template v-else>
            <TaskDetailsHead />
            <TaskDetailsLeft />
         </template>
         <TaskDetailsLeft />

         <!--   控制面板，里面有方法需要立即执行，不可用v-if      -->
         <ControlPanel v-show="!isAutoControl" />
@@ -45,16 +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 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])
@@ -62,23 +67,43 @@
provide('dockSn', dockSn)
provide('droneSn', droneSn)

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实例
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 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
}

// 获取无人机直播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('切换画质成功')
}

// 设置当前直播地址
@@ -89,7 +114,7 @@
   // 如果还是之前的状态，不切换
   if (isTakeOff.value === currentIsTakeOff) return
   isTakeOff.value = currentIsTakeOff
   isTakeOff.value ? await changeLineQuality() : await getDeviceLiveUrl()
   isTakeOff.value ? await getDroneLiveUrl() : await getDeviceLiveUrl()
}

// 获取任务详情获取航线文件
@@ -103,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:
@@ -130,6 +182,8 @@
onMounted(() => {
   getTaskDetails()
   EventBus.on('CurrentTaskDetails-timeStop', changeLineQuality)
   EventBus.on('CurrentTaskDetails-getAiLiveUrl', getAiLiveUrl)
   EventBus.on('CurrentTaskDetails-getDroneLiveUrl', getDroneLiveUrl)
})

onBeforeUnmount(() => {
@@ -137,6 +191,8 @@
   deviceOsdInfo.value = {}
   droneWebSocket = null
   EventBus.off('CurrentTaskDetails-timeStop', changeLineQuality)
   EventBus.off('CurrentTaskDetails-getAiLiveUrl', getAiLiveUrl)
   EventBus.off('CurrentTaskDetails-getDroneLiveUrl', getDroneLiveUrl)
})
</script>