From b80ee8c883f279e843071e6b53ab9cddec3f88a0 Mon Sep 17 00:00:00 2001
From: 胡思旗 <931347610@qq.com>
Date: Tue, 29 Aug 2023 15:07:13 +0800
Subject: [PATCH] 登录流程对接、项目列表组件封装
---
src/components/task/TaskPanel.vue | 182 +++++++++++++++++++++++++++++++++++++--------
1 files changed, 149 insertions(+), 33 deletions(-)
diff --git a/src/components/task/TaskPanel.vue b/src/components/task/TaskPanel.vue
index 339c189..fd6a204 100644
--- a/src/components/task/TaskPanel.vue
+++ b/src/components/task/TaskPanel.vue
@@ -5,18 +5,16 @@
:pagination="paginationProp" :scroll="{ x: '100%', y: 600 }" @change="refreshData">
<!-- 执行时间 -->
<template #duration="{ record }">
- <div>
- <div>{{ formatTaskTime(record.execute_time) }}</div>
- <div>{{ formatTaskTime(record.end_time) }}</div>
+ <div class="flex-row" style="white-space: pre-wrap">
+ <div>
+ <div>{{ formatTaskTime(record.begin_time) }}</div>
+ <div>{{ formatTaskTime(record.end_time) }}</div>
+ </div>
+ <div class="ml10">
+ <div>{{ formatTaskTime(record.execute_time) }}</div>
+ <div>{{ formatTaskTime(record.completed_time) }}</div>
+ </div>
</div>
- </template>
- <!-- 任务类型 -->
- <template #taskType="{ record }">
- <div>{{ formatTaskType(record) }}</div>
- </template>
- <!-- 失控动作 -->
- <template #lostAction="{ record }">
- <div>{{ formatLostAction(record) }}</div>
</template>
<!-- 状态 -->
<template #status="{ record }">
@@ -36,9 +34,35 @@
</div>
</div>
</template>
+ <!-- 任务类型 -->
+ <template #taskType="{ record }">
+ <div>{{ formatTaskType(record) }}</div>
+ </template>
+ <!-- 失控动作 -->
+ <template #lostAction="{ record }">
+ <div>{{ formatLostAction(record) }}</div>
+ </template>
+ <!-- 媒体上传状态 -->
+ <template #media_upload="{ record }">
+ <div>
+ <div class="flex-display flex-align-center">
+ <span class="circle-icon" :style="{backgroundColor: formatMediaTaskStatus(record).color}"></span>
+ {{ formatMediaTaskStatus(record).text }}
+ </div>
+ <div class="pl15">
+ {{ formatMediaTaskStatus(record).number }}
+ <a-tooltip v-if="formatMediaTaskStatus(record).status === MediaStatus.ToUpload" placement="bottom" arrow-point-at-center >
+ <template #title>
+ <div>Upload now</div>
+ </template>
+ <UploadOutlined class="ml5" :style="{color: commonColor.BLUE, fontSize: '16px' }" @click="onUploadMediaFileNow(record.job_id)"/>
+ </a-tooltip>
+ </div>
+ </div>
+ </template>
<!-- 操作 -->
<template #action="{ record }">
- <span class="action-area">
+ <div class="action-area">
<a-popconfirm
v-if="record.status === TaskStatus.Wait"
title="Are you sure you want to delete flight task?"
@@ -48,7 +72,25 @@
>
<a-button type="primary" size="small">Delete</a-button>
</a-popconfirm>
- </span>
+ <a-popconfirm
+ v-if="record.status === TaskStatus.Carrying"
+ title="Are you sure you want to suspend?"
+ ok-text="Yes"
+ cancel-text="No"
+ @confirm="onSuspendTask(record.job_id)"
+ >
+ <a-button type="primary" size="small">Suspend</a-button>
+ </a-popconfirm>
+ <a-popconfirm
+ v-if="record.status === TaskStatus.Paused"
+ title="Are you sure you want to resume?"
+ ok-text="Yes"
+ cancel-text="No"
+ @confirm="onResumeTask(record.job_id)"
+ >
+ <a-button type="primary" size="small">Resume</a-button>
+ </a-popconfirm>
+ </div>
</template>
</a-table>
</div>
@@ -60,15 +102,15 @@
import { TableState } from 'ant-design-vue/lib/table/interface'
import { onMounted } from 'vue'
import { IPage } from '/@/api/http/type'
-import { deleteTask, getWaylineJobs, Task } from '/@/api/wayline'
+import { deleteTask, updateTaskStatus, UpdateTaskStatus, getWaylineJobs, Task, uploadMediaFileNow } from '/@/api/wayline'
import { useMyStore } from '/@/store'
import { ELocalStorageKey } from '/@/types/enums'
import { useFormatTask } from './use-format-task'
-import { TaskStatus, TaskProgressInfo, TaskProgressStatus, TaskProgressWsStatusMap } from '/@/types/task'
-import { useTaskProgressEvent } from './use-task-progress-event'
+import { TaskStatus, TaskProgressInfo, TaskProgressStatus, TaskProgressWsStatusMap, MediaStatus, MediaStatusProgressInfo, TaskMediaHighestPriorityProgressInfo } from '/@/types/task'
+import { useTaskWsEvent } from './use-task-ws-event'
import { getErrorMessage } from '/@/utils/error-code/index'
import { commonColor } from '/@/utils/color'
-import { ExclamationCircleOutlined } from '@ant-design/icons-vue'
+import { ExclamationCircleOutlined, UploadOutlined } from '@ant-design/icons-vue'
const store = useMyStore()
const workspaceId = localStorage.getItem(ELocalStorageKey.WorkspaceId)!
@@ -91,38 +133,41 @@
{
title: 'Planned/Actual Time',
dataIndex: 'duration',
- width: 180,
+ width: 200,
slots: { customRender: 'duration' },
+ },
+ {
+ title: 'Status',
+ key: 'status',
+ width: 150,
+ slots: { customRender: 'status' }
},
{
title: 'Plan Name',
dataIndex: 'job_name',
- width: 150,
- ellipsis: true
+ width: 100,
},
{
title: 'Type',
dataIndex: 'taskType',
- width: 120,
+ width: 100,
slots: { customRender: 'taskType' },
},
{
title: 'Flight Route Name',
dataIndex: 'file_name',
- width: 150,
- ellipsis: true
+ width: 100,
},
{
title: 'Dock Name',
dataIndex: 'dock_name',
- width: 120,
+ width: 100,
ellipsis: true
},
{
title: 'RTH Altitude Relative to Dock (m)',
dataIndex: 'rth_altitude',
width: 120,
- ellipsis: true
},
{
title: 'Lost Action',
@@ -136,10 +181,10 @@
width: 120,
},
{
- title: 'Status',
- key: 'status',
- width: 200,
- slots: { customRender: 'status' }
+ title: 'Media File Upload',
+ key: 'media_upload',
+ width: 160,
+ slots: { customRender: 'media_upload' }
},
{
title: 'Action',
@@ -153,7 +198,7 @@
data: [] as Task[]
})
-const { formatTaskType, formatTaskTime, formatLostAction, formatTaskStatus } = useFormatTask()
+const { formatTaskType, formatTaskTime, formatLostAction, formatTaskStatus, formatMediaTaskStatus } = useFormatTask()
// 设备任务执行进度更新
function onTaskProgressWs (data: TaskProgressInfo) {
@@ -174,11 +219,44 @@
}
}
+// 媒体上传进度更新
+function onTaskMediaProgressWs (data: MediaStatusProgressInfo) {
+ const { media_count: mediaCount, uploaded_count: uploadedCount, job_id: jobId } = data
+ if (isNaN(mediaCount) || isNaN(uploadedCount) || !jobId) {
+ return
+ }
+ const taskItem = plansData.data.find(task => task.job_id === jobId)
+ if (!taskItem) return
+ if (mediaCount === uploadedCount) {
+ taskItem.uploading = false
+ } else {
+ taskItem.uploading = true
+ }
+ taskItem.media_count = mediaCount
+ taskItem.uploaded_count = uploadedCount
+}
+
+function onoTaskMediaHighestPriorityWS (data: TaskMediaHighestPriorityProgressInfo) {
+ const { pre_job_id: preJobId, job_id: jobId } = data
+ const preTaskItem = plansData.data.find(task => task.job_id === preJobId)
+ const taskItem = plansData.data.find(task => task.job_id === jobId)
+ if (preTaskItem) {
+ preTaskItem.uploading = false
+ }
+ if (taskItem) {
+ taskItem.uploading = true
+ }
+}
+
function getCodeMessage (code: number) {
return getErrorMessage(code) + `（code: ${code}）`
}
-useTaskProgressEvent(onTaskProgressWs)
+useTaskWsEvent({
+ onTaskProgressWs,
+ onTaskMediaProgressWs,
+ onoTaskMediaHighestPriorityWS,
+})
onMounted(() => {
getPlans()
@@ -211,6 +289,39 @@
getPlans()
}
}
+
+// 挂起任务
+async function onSuspendTask (jobId: string) {
+ const { code } = await updateTaskStatus(workspaceId, {
+ job_id: jobId,
+ status: UpdateTaskStatus.Suspend
+ })
+ if (code === 0) {
+ message.success('Suspended successfully')
+ getPlans()
+ }
+}
+
+// 解除挂起任务
+async function onResumeTask (jobId: string) {
+ const { code } = await updateTaskStatus(workspaceId, {
+ job_id: jobId,
+ status: UpdateTaskStatus.Resume
+ })
+ if (code === 0) {
+ message.success('Resumed successfully')
+ getPlans()
+ }
+}
+
+// 立即上传媒体
+async function onUploadMediaFileNow (jobId: string) {
+ const { code } = await uploadMediaFileNow(workspaceId, jobId)
+ if (code === 0) {
+ message.success('Upload Media File successfully')
+ getPlans()
+ }
+}
</script>
<style lang="scss" scoped>
@@ -222,8 +333,13 @@
margin-top: 10px;
}
.action-area {
- color: $primary;
- cursor: pointer;
+
+ &::v-deep {
+ .ant-btn {
+ margin-right: 10px;
+ margin-bottom: 10px;
+ }
+ }
}
.circle-icon {
--
Gitblit v1.9.3