Function runBatchValidateTask

static/js/accounts.js:1209–1309

(payload, count, sourceLabel, options = {})

}

async function runBatchValidateTask(payload, count, sourceLabel, options = {}) {
    const showToast = options.showToast !== false;
    const reloadAfter = options.reloadAfter !== false;
    const onProgress = typeof options.onProgress === 'function' ? options.onProgress : null;
    isBatchValidating = true;
    updateBatchButtons();
    elements.batchValidateBtn.textContent = '验证中...';

    try {
        const task = await api.post('/accounts/batch-validate/async', payload, {
            timeoutMs: 20000,
            retry: 0,
            requestKey: 'accounts:batch-validate:async',
            cancelPrevious: true,
        });
        const taskId = task?.id;
        if (!taskId) {
            throw new Error('任务创建失败：未返回任务 ID');
        }
        trackBatchTask('validate', {
            id: taskId,
            domain: 'accounts',
            status: task?.status || 'pending',
            paused: Boolean(task?.paused),
        });

        if (showToast) {
            toast.info(`${sourceLabel}任务已启动（${taskId.slice(0, 8)}）`);
        }

        const finalTask = await watchAccountTask(taskId, (progressTask) => {
            patchBatchTask('validate', {
                status: progressTask?.status || 'running',
                paused: Boolean(progressTask?.paused),
                pause_requested: Boolean(progressTask?.pause_requested),
            });
            const progress = progressTask?.progress || {};
            const completed = Number(progress.completed || 0);
            const total = Number(progress.total || count);
            const paused = Boolean(progressTask?.paused) || String(progressTask?.status || '').toLowerCase() === 'paused';
            elements.batchValidateBtn.textContent = paused ? `已暂停 ${completed}/${total}` : `验证中 ${completed}/${total}`;
            applyValidatedStatuses(progressTask);
            if (onProgress) {
                onProgress({ completed, total, task: progressTask });
            }
        });
        patchBatchTask('validate', {
            status: finalTask?.status || 'completed',
            paused: false,
            pause_requested: false,
        });

        const result = finalTask?.result || {};
        const status = String(finalTask?.status || '').toLowerCase();
        if (status === 'completed') {
            if (showToast) {
                const workers = Number(result.worker_count || 0);
                const retries = Number(result.retry_count || 0);