From bb95bfaecd139e440d21bdcdd5fc578625a7b912 Mon Sep 17 00:00:00 2001
From: chenyao <1219716595@qq.com>
Date: Mon, 14 Apr 2025 17:47:41 +0800
Subject: [PATCH] Merge branch 'master' of http://139.196.74.78:10010/r/drone/command-center-dashboard

---
 src/views/TaskManage/TaskIntermediateContent/CurrentTaskDetails/CurrentTaskDetails.vue |  156 ++++++++++++++++++++++++++++++++-------------------
 1 files changed, 97 insertions(+), 59 deletions(-)

diff --git a/src/views/TaskManage/TaskIntermediateContent/CurrentTaskDetails/CurrentTaskDetails.vue b/src/views/TaskManage/TaskIntermediateContent/CurrentTaskDetails/CurrentTaskDetails.vue
index 9c0173f..fba05d6 100644
--- a/src/views/TaskManage/TaskIntermediateContent/CurrentTaskDetails/CurrentTaskDetails.vue
+++ b/src/views/TaskManage/TaskIntermediateContent/CurrentTaskDetails/CurrentTaskDetails.vue
@@ -1,104 +1,142 @@
 <!--当前任务详情-->
 <template>
-  <el-dialog
+	<el-dialog
 		modal-class="current-task-details"
 		v-model="isShow"
 		title="当前任务详情"
 		:width="pxToRem(1500)"
 		:close-on-click-modal="false"
-		:destroy-on-close="true">
+		:destroy-on-close="true"
+	>
 		<div class="content-container" v-if="isShow">
-      <!-- 视频直播 -->
-      <div class="video-container">
-        <LiveVideo :videoUrl="machineNestUrl"/>
-      </div>
+			<!-- 视频直播 -->
+			<div class="video-container">
+				<LiveVideo :videoUrl="currentLiveUrl" />
+			</div>
 			<!-- 展示地图 -->
 			<RealTimeMap />
-    </div>
-  </el-dialog>
+		</div>
+	</el-dialog>
 </template>
 
 <script setup>
-import { pxToRem } from '@/utils/rem';
-import LiveVideo from '@/components/LiveVideo.vue';
-import { liveStart } from '@/api/home/machineNest';
-import { getJobDetails } from '@/api/home/task';
+import { pxToRem } from '@/utils/rem'
+import LiveVideo from '@/components/LiveVideo.vue'
+import { liveStart } from '@/api/home/machineNest'
+import { getJobDetails } from '@/api/home/task'
 
 import RealTimeMap from '@/views/TaskManage/TaskIntermediateContent/CurrentTaskDetails/RealTimeMap.vue'
 import { getWebsocketUrl } from '@/websocket/util/config'
 import { useConnectWebSocket } from '@/utils/websocket/connect-websocket'
+import { EBizCode } from '@/utils/staticData/enums'
 
-
-const isShow = defineModel('show');
+const isShow = defineModel('show')
 const props = defineProps({
-  rowData: { // 任务列表row数据
-    type: Object,
-    default: () => ({})
-  }
-});
+	rowData: {
+		// 任务列表row数据
+		type: Object,
+		default: () => ({}),
+	},
+})
 let taskDetails = ref({})
-const machineNestUrl = ref('');
-provide('taskDetails', taskDetails);
+const currentLiveUrl = ref('')
+const machineNestUrl = ref('')
+const dockLiveUrl = ref('')
+provide('taskDetails', taskDetails)
 
-// 获取机巢直播地址
-const getVideoUrl = (deviceSn) => {
-  liveStart(deviceSn).then(res => {
-    if (res.data.code !== 0) return;
-    machineNestUrl.value = res.data.data.rtcs_url;
-  });
-};
+const deviceOsdInfo = ref({})
+provide('deviceOsdInfo', deviceOsdInfo)
+
+// 机巢直播
+const getDeviceLiveUrl = async () => {
+	if (machineNestUrl.value) return machineNestUrl.value
+	const res = await liveStart(taskDetails.value.device_sns[0])
+	machineNestUrl.value = res.data.data.rtcs_url
+	return machineNestUrl.value
+}
+
+// 无人机直播
+const getDockLiveUrl = async dockSn => {
+	if (dockLiveUrl.value) return dockLiveUrl.value
+	const res = await liveStart(dockSn)
+	dockLiveUrl.value = res.data.data.rtcs_url
+	return dockLiveUrl.value
+}
+
+// 设置当前直播地址
+const setCurrentLiveUrl = async () => {
+	const data = deviceOsdInfo.value?.data
+	const deviceInfo = data?.host
+	const dockSn = data?.sn
+	if ([14, 0].includes(deviceInfo.mode_code)) {
+		currentLiveUrl.value = await getDeviceLiveUrl()
+	} else {
+		currentLiveUrl.value = await getDockLiveUrl(dockSn)
+	}
+}
+
 // 获取任务详情获取航线文件
 const getTaskDetails = () => {
-	getJobDetails({ wayLineJobInfoId: props.rowData.id }).then(res => {
+	getJobDetails({ wayLineJobInfoId: props.rowData.id }).then(async res => {
 		taskDetails.value = res.data.data
-		getVideoUrl(taskDetails.value.device_sns[0]);
-		console.log('taskDetails', taskDetails.value)
+		currentLiveUrl.value = await getDeviceLiveUrl()
 		createWsConnect(taskDetails.value.way_lines[0].workspace_id)
 	})
 }
-const messageHandler = (result) => {
+
+const messageHandler = result => {
 	let payload = JSON.parse(result) // 为了兼容聊天消息
-	console.log('result,6666666', payload)
+	switch (payload.biz_code) {
+		case EBizCode.DeviceOsd: {
+			deviceOsdInfo.value = payload
+			// console.log(deviceOsdInfo.value,'osd信息')
+			setCurrentLiveUrl()
+			break
+		}
+		default:
+			break
+	}
 }
 let connectWs
-const createWsConnect = (workspaceId) => {
-	let webSocketUrl = getWebsocketUrl() + '&workspace-id=' + workspaceId;
+const createWsConnect = workspaceId => {
+	let webSocketUrl = getWebsocketUrl() + '&workspace-id=' + workspaceId
 	// 监听ws 消息
-	connectWs = useConnectWebSocket(messageHandler, webSocketUrl);
-};
+	connectWs = useConnectWebSocket(messageHandler, webSocketUrl)
+}
 
+const removeEvent = () => {
+	connectWs?.close()
+	deviceOsdInfo.value = {}
+}
 
 // 监听 rowData 变化
-watch(isShow, (newVal) => {
-  if (newVal) {
-    getTaskDetails();
-  }else{
-		connectWs?.close();
+watch(isShow, newVal => {
+	if (newVal) {
+		getTaskDetails()
+	} else {
+		removeEvent()
 	}
-});
-
-onBeforeUnmount(() => {
-	connectWs?.close();
 })
 
-onMounted(() => {
-});
+onBeforeUnmount(() => {
+	removeEvent()
+})
 </script>
 
 <style lang="scss" scoped>
 .current-task-details {
-  display: flex;
-  justify-content: space-between;
-  .content-container {
-    display: flex;
-    // gap: 20px;
-    height: 600px;
+	display: flex;
+	justify-content: space-between;
 
-    .video-container {
-      width: 50%;
-      padding-right: 10px;
-    }
-  }
+	.content-container {
+		display: flex;
+		// gap: 20px;
+		height: 600px;
 
+		.video-container {
+			width: 50%;
+			padding-right: 10px;
+		}
+	}
 }
 </style>

--
Gitblit v1.9.3