6 changed files with 136 additions and 38 deletions

No files matched your search

+6 -3
View File
@@ -532,16 +532,19 @@ export default {
title: 'Batch upload episodes', title: 'Batch upload episodes',
entry: 'Batch upload', entry: 'Batch upload',
selectFiles: 'Select videos', selectFiles: 'Select videos',
startUpload: 'Start upload',
uploadingAction: 'Uploading',
pause: 'Pause', pause: 'Pause',
resume: 'Resume', resume: 'Resume',
retry: 'Retry', retry: 'Retry',
retryAll: 'Retry all', retryAll: 'Retry all',
remove: 'Remove', remove: 'Remove',
hint: 'Supports MP4 / MOV / MKV / WEBM, max 500MB each', hint: 'Supports MP4 / MOV / MKV / WEBM, max 500MB each. Files stay queued until you click Start upload.',
invalidType: 'Only MP4, MOV, MKV, WEBM are allowed', invalidType: 'Only MP4, MOV, MKV, WEBM are allowed',
oversize: 'File exceeds 500MB and was not queued', oversize: 'File exceeds 500MB and was not queued',
overallProgress: 'Overall progress', overallProgress: 'Overall progress',
empty: 'No videos selected', empty: 'No videos selected',
resultSummary: 'Upload finished: {done} succeeded, {failed} failed',
createEpisodes: 'Create episodes', createEpisodes: 'Create episodes',
closeWhileUploading: closeWhileUploading:
'Uploads are still in progress. Closing will stop dispatching new tasks. Continue?', 'Uploads are still in progress. Closing will stop dispatching new tasks. Continue?',
@@ -551,7 +554,7 @@ export default {
resumeYes: 'Pick files to resume', resumeYes: 'Pick files to resume',
resumeNo: 'Discard', resumeNo: 'Discard',
resumeAbandoned: 'Unfinished uploads discarded', resumeAbandoned: 'Unfinished uploads discarded',
resumeMatched: 'Matched {count} file(s) and resumed', resumeMatched: 'Matched {count} file(s). Click Start upload to continue.',
resumeUnmatched: '{count} session(s) could not match local files; pick again manually', resumeUnmatched: '{count} session(s) could not match local files; pick again manually',
createTitle: 'Create episodes in batch', createTitle: 'Create episodes in batch',
createHint: createHint:
@@ -571,7 +574,7 @@ export default {
submitCreate: 'Create', submitCreate: 'Create',
retryFailed: 'Retry failed', retryFailed: 'Retry failed',
status: { status: {
waiting: 'Waiting', waiting: 'Pending',
uploading: 'Uploading', uploading: 'Uploading',
merging: 'Merging', merging: 'Merging',
done: 'Done', done: 'Done',
+6 -3
View File
@@ -526,16 +526,19 @@ export default {
title: '批量上传剧集', title: '批量上传剧集',
entry: '批量上传', entry: '批量上传',
selectFiles: '选择视频', selectFiles: '选择视频',
startUpload: '开始上传',
uploadingAction: '上传中',
pause: '暂停', pause: '暂停',
resume: '继续', resume: '继续',
retry: '重试', retry: '重试',
retryAll: '全部重试', retryAll: '全部重试',
remove: '移除', remove: '移除',
hint: '支持 MP4 / MOV / MKV / WEBM,单文件不超过 500MB', hint: '支持 MP4 / MOV / MKV / WEBM,单文件不超过 500MB;选完文件后点击「开始上传」才会真正上传',
invalidType: '仅支持 MP4、MOV、MKV、WEBM', invalidType: '仅支持 MP4、MOV、MKV、WEBM',
oversize: '文件超过 500MB,未入队', oversize: '文件超过 500MB,未入队',
overallProgress: '总进度', overallProgress: '总进度',
empty: '尚未选择视频', empty: '尚未选择视频',
resultSummary: '上传结束:成功 {done} 个,失败 {failed} 个',
createEpisodes: '批量创建分集', createEpisodes: '批量创建分集',
closeWhileUploading: '仍有未完成上传,关闭后将暂停派发新任务,确定关闭吗?', closeWhileUploading: '仍有未完成上传,关闭后将暂停派发新任务,确定关闭吗?',
resumeTitle: '发现未完成上传', resumeTitle: '发现未完成上传',
@@ -543,7 +546,7 @@ export default {
resumeYes: '选择文件续传', resumeYes: '选择文件续传',
resumeNo: '放弃', resumeNo: '放弃',
resumeAbandoned: '已放弃未完成上传', resumeAbandoned: '已放弃未完成上传',
resumeMatched: '已匹配 {count} 个文件并开始续传', resumeMatched: '已匹配 {count} 个文件,请点击「开始上传」继续',
resumeUnmatched: '有 {count} 个会话无法匹配本地文件,请手动重选', resumeUnmatched: '有 {count} 个会话无法匹配本地文件,请手动重选',
createTitle: '批量创建分集', createTitle: '批量创建分集',
createHint: createHint:
@@ -563,7 +566,7 @@ export default {
submitCreate: '创建', submitCreate: '创建',
retryFailed: '重试失败项', retryFailed: '重试失败项',
status: { status: {
waiting: '等待中', waiting: '待上传',
uploading: '上传中', uploading: '上传中',
merging: '合并中', merging: '合并中',
done: '已完成', done: '已完成',
@@ -50,11 +50,6 @@ const existingEpisodeNumbers = computed(() =>
snapshotEpisodes.value.map((item) => Number(item.number)).filter((n) => Number.isFinite(n)) snapshotEpisodes.value.map((item) => Number(item.number)).filter((n) => Number.isFinite(n))
) )
const showPagination = computed(() => {
if (total.value <= 0) return false
return Math.ceil(total.value / pageSize.value) > 1
})
const showEmpty = computed(() => !loading.value && episodes.value.length === 0) const showEmpty = computed(() => !loading.value && episodes.value.length === 0)
async function loadDramas() { async function loadDramas() {
@@ -441,7 +436,7 @@ onMounted(async () => {
></el-table-column ></el-table-column
> >
</el-table> </el-table>
<div v-if="showPagination" class="pagination" <div class="pagination"
><el-pagination ><el-pagination
v-model:current-page="pageIndex" v-model:current-page="pageIndex"
v-model:page-size="pageSize" v-model:page-size="pageSize"
@@ -1,5 +1,5 @@
<!-- Author: fruit.com.cn --> <!-- Author: fruit.com.cn -->
<!-- 剧集批量上传弹窗:多选、队列、总进度、续传与批量建集入口 --> <!-- 剧集批量上传弹窗:先入队待上传,点「开始上传」后再执行 -->
<script setup lang="ts"> <script setup lang="ts">
import { computed, onBeforeUnmount, ref, watch } from 'vue' import { computed, onBeforeUnmount, ref, watch } from 'vue'
@@ -60,6 +60,10 @@ watch(
const canCreateEpisodes = computed(() => queue.doneItems.value.length > 0) const canCreateEpisodes = computed(() => queue.doneItems.value.length > 0)
const startButtonLabel = computed(() =>
queue.isUploading.value ? t('episodeBatch.uploadingAction') : t('episodeBatch.startUpload')
)
function extensionOf(fileName: string): string { function extensionOf(fileName: string): string {
const parts = String(fileName || '').split('.') const parts = String(fileName || '').split('.')
return (parts.pop() || '').toLowerCase() return (parts.pop() || '').toLowerCase()
@@ -92,14 +96,19 @@ function onPickFiles(event: Event): void {
} }
rejectedNames.value = rejected rejectedNames.value = rejected
if (!accepted.length) return if (!accepted.length) return
// 只入队,不发起上传;等用户点「开始上传」
queue.enqueue(accepted) queue.enqueue(accepted)
queue.start()
} }
function openFilePicker(): void { function openFilePicker(): void {
fileInputRef.value?.click() fileInputRef.value?.click()
} }
function onStartUpload(): void {
if (!queue.canStart.value) return
queue.start()
}
function onBeforeUnload(event: BeforeUnloadEvent): void { function onBeforeUnload(event: BeforeUnloadEvent): void {
if (!queue.hasActiveUpload.value) return if (!queue.hasActiveUpload.value) return
event.preventDefault() event.preventDefault()
@@ -158,7 +167,6 @@ async function onResumeFiles(event: Event): Promise<void> {
} }
if (matched.length) { if (matched.length) {
ElMessage.success(t('episodeBatch.resumeMatched', { count: matched.length })) ElMessage.success(t('episodeBatch.resumeMatched', { count: matched.length }))
queue.start()
} }
} }
@@ -229,10 +237,13 @@ function onEpisodesCreated(): void {
<AppIcon :icon="AppIcons.upload" /> <AppIcon :icon="AppIcons.upload" />
{{ t('episodeBatch.selectFiles') }} {{ t('episodeBatch.selectFiles') }}
</el-button> </el-button>
<el-button :disabled="!queue.items.value.length" @click="queue.pause()"> <el-button
:disabled="!queue.started.value || !queue.items.value.length"
@click="queue.pause()"
>
{{ t('episodeBatch.pause') }} {{ t('episodeBatch.pause') }}
</el-button> </el-button>
<el-button :disabled="!queue.items.value.length" @click="queue.start()"> <el-button :disabled="!queue.canStart.value" @click="queue.start()">
{{ t('episodeBatch.resume') }} {{ t('episodeBatch.resume') }}
</el-button> </el-button>
<el-button <el-button
@@ -254,11 +265,22 @@ function onEpisodesCreated(): void {
<el-progress :percentage="queue.overallPercent.value" :stroke-width="12" /> <el-progress :percentage="queue.overallPercent.value" :stroke-width="12" />
</div> </div>
<p v-if="queue.showResultSummary.value" class="batch-upload-summary">
{{
t('episodeBatch.resultSummary', {
done: queue.doneItems.value.length,
failed: queue.failedCount.value
})
}}
</p>
<div class="batch-upload-list"> <div class="batch-upload-list">
<UploadTaskRow <UploadTaskRow
v-for="item in queue.items.value" v-for="(item, index) in queue.items.value"
:key="item.id" :key="item.id"
:item="item" :item="item"
:index="index + 1"
:allow-remove="!queue.started.value && item.status === 'waiting'"
@retry="queue.retry" @retry="queue.retry"
@remove="queue.remove" @remove="queue.remove"
/> />
@@ -267,7 +289,15 @@ function onEpisodesCreated(): void {
<template #footer> <template #footer>
<el-button @click="visible = false">{{ t('common.cancel') }}</el-button> <el-button @click="visible = false">{{ t('common.cancel') }}</el-button>
<el-button type="primary" :disabled="!canCreateEpisodes" @click="openCreateDialog"> <el-button
type="primary"
:disabled="!queue.canStart.value"
:loading="queue.isUploading.value"
@click="onStartUpload"
>
{{ startButtonLabel }}
</el-button>
<el-button type="success" :disabled="!canCreateEpisodes" @click="openCreateDialog">
{{ t('episodeBatch.createEpisodes') }} {{ t('episodeBatch.createEpisodes') }}
</el-button> </el-button>
</template> </template>
@@ -317,6 +347,15 @@ function onEpisodesCreated(): void {
margin-bottom: 12px; margin-bottom: 12px;
} }
.batch-upload-summary {
margin: 0 0 12px;
padding: 8px 12px;
border-radius: 6px;
background: color-mix(in srgb, var(--el-color-success) 10%, transparent);
color: var(--el-text-color-primary);
font-size: 13px;
}
.batch-upload-list { .batch-upload-list {
max-height: 360px; max-height: 360px;
overflow: auto; overflow: auto;
@@ -1,5 +1,5 @@
<!-- Author: fruit.com.cn --> <!-- Author: fruit.com.cn -->
<!-- 批量上传队列单行:文件名、大小、进度、状态与操作 --> <!-- 批量上传队列单行:序号、文件名、大小、进度、状态与操作 -->
<script setup lang="ts"> <script setup lang="ts">
import { computed } from 'vue' import { computed } from 'vue'
@@ -8,6 +8,10 @@ import type { UploadQueueItem } from './useUploadQueue'
const props = defineProps<{ const props = defineProps<{
item: UploadQueueItem item: UploadQueueItem
/** 自然排序后的展示序号(从 1 起) */
index: number
/** 选择阶段才允许移除 */
allowRemove: boolean
}>() }>()
const emit = defineEmits<{ const emit = defineEmits<{
@@ -47,14 +51,12 @@ const statusType = computed(() => {
}) })
const canRetry = computed(() => props.item.status === 'failed') const canRetry = computed(() => props.item.status === 'failed')
const canRemove = computed(
() => props.item.status !== 'uploading' && props.item.status !== 'merging'
)
</script> </script>
<template> <template>
<div class="upload-task-row" :class="{ 'is-failed': item.status === 'failed' }"> <div class="upload-task-row" :class="{ 'is-failed': item.status === 'failed' }">
<div class="upload-task-row__meta"> <div class="upload-task-row__meta">
<span class="upload-task-row__index">{{ index }}</span>
<b class="upload-task-row__name" :title="item.fileName">{{ item.fileName }}</b> <b class="upload-task-row__name" :title="item.fileName">{{ item.fileName }}</b>
<small>{{ sizeLabel }}</small> <small>{{ sizeLabel }}</small>
<el-tag :type="statusType" effect="light" size="small">{{ statusLabel }}</el-tag> <el-tag :type="statusType" effect="light" size="small">{{ statusLabel }}</el-tag>
@@ -71,7 +73,13 @@ const canRemove = computed(
<el-button v-if="canRetry" size="small" type="primary" @click="emit('retry', item.id)"> <el-button v-if="canRetry" size="small" type="primary" @click="emit('retry', item.id)">
{{ t('episodeBatch.retry') }} {{ t('episodeBatch.retry') }}
</el-button> </el-button>
<el-button v-if="canRemove" size="small" type="danger" text @click="emit('remove', item.id)"> <el-button
v-if="allowRemove"
size="small"
type="danger"
text
@click="emit('remove', item.id)"
>
{{ t('episodeBatch.remove') }} {{ t('episodeBatch.remove') }}
</el-button> </el-button>
</div> </div>
@@ -91,6 +99,14 @@ const canRemove = computed(
margin-bottom: 8px; margin-bottom: 8px;
} }
.upload-task-row__index {
flex: 0 0 auto;
min-width: 1.5em;
color: var(--el-text-color-secondary);
font-size: 13px;
font-variant-numeric: tabular-nums;
}
.upload-task-row__name { .upload-task-row__name {
flex: 1; flex: 1;
overflow: hidden; overflow: hidden;
@@ -1,5 +1,5 @@
// Author: fruit.com.cn // Author: fruit.com.cn
/** 剧集批量上传队列:文件并发、进度加权、断点会话、失败隔离 */ /** 剧集批量上传队列:手动开始、文件并发、进度加权、断点会话、失败隔离 */
import { computed, ref } from 'vue' import { computed, ref } from 'vue'
import { getUploadProgressApi } from '@/api/admin/media' import { getUploadProgressApi } from '@/api/admin/media'
@@ -58,6 +58,11 @@ function isHttpNotFound(error: unknown): boolean {
return status === 404 return status === 404
} }
/** 文件名自然排序(数字感知),保证队列序号稳定。 */
function compareFileName(a: string, b: string): number {
return a.localeCompare(b, undefined, { numeric: true, sensitivity: 'base' })
}
/** /**
* 创建上传队列控制器。 * 创建上传队列控制器。
* @param options dramaId 与可选 bizType * @param options dramaId 与可选 bizType
@@ -65,6 +70,8 @@ function isHttpNotFound(error: unknown): boolean {
export function useUploadQueue(options: UseUploadQueueOptions) { export function useUploadQueue(options: UseUploadQueueOptions) {
const items = ref<UploadQueueItem[]>([]) const items = ref<UploadQueueItem[]>([])
const paused = ref(false) const paused = ref(false)
/** 用户是否已点过「开始上传」;选文件阶段不派发、不占用并发。 */
const started = ref(false)
const bizType = options.bizType || DEFAULT_BIZ_TYPE const bizType = options.bizType || DEFAULT_BIZ_TYPE
let running = 0 let running = 0
@@ -77,18 +84,36 @@ export function useUploadQueue(options: UseUploadQueueOptions) {
return Math.min(MAX_PERCENT, Math.round(weighted / totalBytes)) return Math.min(MAX_PERCENT, Math.round(weighted / totalBytes))
}) })
const hasActiveUpload = computed(() => const isUploading = computed(() =>
items.value.some( items.value.some((item) => item.status === 'uploading' || item.status === 'merging')
)
/** 关闭弹窗需二次确认:仅在已开始且仍有未完成任务时。 */
const hasActiveUpload = computed(() => {
if (!started.value) return false
return items.value.some(
(item) => (item) =>
item.status === 'waiting' || item.status === 'waiting' ||
item.status === 'uploading' || item.status === 'uploading' ||
item.status === 'merging' || item.status === 'merging' ||
item.status === 'paused' item.status === 'paused'
) )
) })
const canStart = computed(() => {
if (isUploading.value) return false
return items.value.some((item) => item.status === 'waiting' || item.status === 'paused')
})
const doneItems = computed(() => items.value.filter((item) => item.status === 'done')) const doneItems = computed(() => items.value.filter((item) => item.status === 'done'))
const failedCount = computed(() => items.value.filter((item) => item.status === 'failed').length)
/** 已开始且队列已无进行中任务时,可展示结果汇总。 */
const showResultSummary = computed(
() => started.value && items.value.length > 0 && !hasActiveUpload.value
)
function persistSession(item: UploadQueueItem, uploadId: string): void { function persistSession(item: UploadQueueItem, uploadId: string): void {
item.uploadId = uploadId item.uploadId = uploadId
upsertUploadSession({ upsertUploadSession({
@@ -106,6 +131,10 @@ export function useUploadQueue(options: UseUploadQueueOptions) {
if (uploadId) removeUploadSession(uploadId) if (uploadId) removeUploadSession(uploadId)
} }
function sortItemsByName(): void {
items.value.sort((a, b) => compareFileName(a.fileName, b.fileName))
}
async function runOne(item: UploadQueueItem, resumeId?: string): Promise<void> { async function runOne(item: UploadQueueItem, resumeId?: string): Promise<void> {
item.status = 'uploading' item.status = 'uploading'
item.error = '' item.error = ''
@@ -140,7 +169,7 @@ export function useUploadQueue(options: UseUploadQueueOptions) {
} }
function pump(): void { function pump(): void {
if (paused.value) return if (!started.value || paused.value) return
while (running < FILE_CONCURRENCY && !paused.value) { while (running < FILE_CONCURRENCY && !paused.value) {
const next = items.value.find((item) => item.status === 'waiting') const next = items.value.find((item) => item.status === 'waiting')
if (!next) return if (!next) return
@@ -155,9 +184,10 @@ export function useUploadQueue(options: UseUploadQueueOptions) {
} }
} }
/** 入队本地文件(调用方已完成类型/大小校验)。 */ /** 入队本地文件(调用方已完成类型/大小校验);只展示待上传,不发起请求。 */
function enqueue(files: File[]): void { function enqueue(files: File[]): void {
for (const file of files) { const sorted = [...files].sort((a, b) => compareFileName(a.name, b.name))
for (const file of sorted) {
items.value.push({ items.value.push({
id: nextItemId(), id: nextItemId(),
file, file,
@@ -165,15 +195,18 @@ export function useUploadQueue(options: UseUploadQueueOptions) {
fileSize: file.size, fileSize: file.size,
lastModified: file.lastModified, lastModified: file.lastModified,
percent: 0, percent: 0,
status: paused.value ? 'paused' : 'waiting', status: 'waiting',
error: '', error: '',
uploadId: '' uploadId: ''
}) })
} }
sortItemsByName()
} }
/** 开始或继续派发。 */ /** 开始或继续派发(含断点续传项上的 uploadId)。 */
function start(): void { function start(): void {
if (!items.value.length) return
started.value = true
paused.value = false paused.value = false
for (const item of items.value) { for (const item of items.value) {
if (item.status === 'paused') item.status = 'waiting' if (item.status === 'paused') item.status = 'waiting'
@@ -183,6 +216,7 @@ export function useUploadQueue(options: UseUploadQueueOptions) {
/** 暂停:不派新任务;进行中分片跑完。 */ /** 暂停:不派新任务;进行中分片跑完。 */
function pause(): void { function pause(): void {
if (!started.value) return
paused.value = true paused.value = true
for (const item of items.value) { for (const item of items.value) {
if (item.status === 'waiting') item.status = 'paused' if (item.status === 'waiting') item.status = 'paused'
@@ -196,7 +230,7 @@ export function useUploadQueue(options: UseUploadQueueOptions) {
item.error = '' item.error = ''
item.percent = item.uploadId ? item.percent : 0 item.percent = item.uploadId ? item.percent : 0
item.status = paused.value ? 'paused' : 'waiting' item.status = paused.value ? 'paused' : 'waiting'
if (!paused.value) void pump() if (started.value && !paused.value) void pump()
} }
/** 重试全部失败项。 */ /** 重试全部失败项。 */
@@ -207,11 +241,12 @@ export function useUploadQueue(options: UseUploadQueueOptions) {
item.status = paused.value ? 'paused' : 'waiting' item.status = paused.value ? 'paused' : 'waiting'
} }
} }
if (!paused.value) void pump() if (started.value && !paused.value) void pump()
} }
/** 移除单项并清理会话。 */ /** 仅选择阶段可移除;已开始上传后禁止直接移除,避免脏会话。 */
function remove(id: string): void { function remove(id: string): void {
if (started.value) return
const index = items.value.findIndex((row) => row.id === id) const index = items.value.findIndex((row) => row.id === id)
if (index < 0) return if (index < 0) return
const [removed] = items.value.splice(index, 1) const [removed] = items.value.splice(index, 1)
@@ -225,6 +260,7 @@ export function useUploadQueue(options: UseUploadQueueOptions) {
} }
items.value = [] items.value = []
paused.value = false paused.value = false
started.value = false
running = 0 running = 0
} }
@@ -234,7 +270,7 @@ export function useUploadQueue(options: UseUploadQueueOptions) {
} }
/** /**
* 用本地重选文件匹配会话并入队续传。 * 用本地重选文件匹配会话并入队(待上传);不自动开始,由用户点「开始上传」续传。
* @returns matched / unmatched 会话列表 * @returns matched / unmatched 会话列表
*/ */
async function resumeFromSessions( async function resumeFromSessions(
@@ -267,7 +303,7 @@ export function useUploadQueue(options: UseUploadQueueOptions) {
fileSize: file.size, fileSize: file.size,
lastModified: file.lastModified, lastModified: file.lastModified,
percent: Math.min(MERGING_PERCENT, Number(progress.percent) || 0), percent: Math.min(MERGING_PERCENT, Number(progress.percent) || 0),
status: paused.value ? 'paused' : 'waiting', status: 'waiting',
error: '', error: '',
uploadId: session.uploadId uploadId: session.uploadId
}) })
@@ -280,6 +316,7 @@ export function useUploadQueue(options: UseUploadQueueOptions) {
} }
} }
} }
sortItemsByName()
return { matched, unmatched } return { matched, unmatched }
} }
@@ -294,7 +331,12 @@ export function useUploadQueue(options: UseUploadQueueOptions) {
items, items,
overallPercent, overallPercent,
hasActiveUpload, hasActiveUpload,
isUploading,
canStart,
doneItems, doneItems,
failedCount,
showResultSummary,
started,
paused, paused,
enqueue, enqueue,
start, start,