Function runBatchRefreshTask

static/js/accounts.js:1103–1195

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

}

async function runBatchRefreshTask(payload, count, sourceLabel, options = {}) {
    const showToast = options.showToast !== false;
    const reloadAfter = options.reloadAfter !== false;
    const onProgress = typeof options.onProgress === 'function' ? options.onProgress : null;
    isBatchRefreshing = true;
    updateBatchButtons();

    try {
        const task = await api.post('/accounts/batch-refresh/async', payload, {
            timeoutMs: 20000,
            retry: 0,
            requestKey: 'accounts:batch-refresh',
            cancelPrevious: true,
        });
        const taskId = task?.id;
        if (!taskId) {
            throw new Error('任务创建失败：未返回任务 ID');
        }
        trackBatchTask('refresh', {
            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('refresh', {
                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.batchRefreshBtn.textContent = paused ? `已暂停 ${completed}/${total}` : `刷新中 ${completed}/${total}`;
            if (elements.quickRefreshBtn && !isQuickWorkflowRunning) {
                elements.quickRefreshBtn.textContent = paused ? `⚡ 已暂停 ${completed}/${total}` : `⚡ 刷新中 ${completed}/${total}`;
            }
            if (onProgress) {
                onProgress({ completed, total, task: progressTask });
            }
        });
        patchBatchTask('refresh', {
            status: finalTask?.status || 'completed',
            paused: false,
            pause_requested: false,
        });
        const result = finalTask?.result || {};
        const status = String(finalTask?.status || '').toLowerCase();
        if (status === 'completed') {
            if (showToast) {
                toast.success(`成功刷新 ${result.success_count || 0} 个，失败 ${result.failed_count || 0} 个`);
            }
        } else if (status === 'cancelled') {