Function runBatchCheckSubscriptionTask

static/js/accounts.js:1311–1403

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

}

async function runBatchCheckSubscriptionTask(payload, count, sourceLabel, options = {}) {
    const showToast = options.showToast !== false;
    const reloadAfter = options.reloadAfter !== false;
    const onProgress = typeof options.onProgress === 'function' ? options.onProgress : null;
    isBatchCheckingSubscription = true;
    updateBatchButtons();
    elements.batchCheckSubBtn.textContent = '检测中...';

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

        if (showToast) {
            toast.info(`${sourceLabel}任务已启动（${taskId.slice(0, 8)}）`);
        }
        const finalTask = await watchPaymentTask(taskId, (progressTask) => {
            patchBatchTask('subscription', {
                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.batchCheckSubBtn.textContent = paused ? `已暂停 ${completed}/${total}` : `检测中 ${completed}/${total}`;
            if (onProgress) {
                onProgress({ completed, total, task: progressTask });
            }
        });
        patchBatchTask('subscription', {
            status: finalTask?.status || 'completed',
            paused: false,
            pause_requested: false,
        });

        const result = finalTask?.result || {};
        const status = String(finalTask?.status || '').toLowerCase();
        if (status === 'completed') {
            if (showToast) {
                let message = `成功: ${result.success_count || 0}`;
                if ((result.failed_count || 0) > 0) message += `, 失败: ${result.failed_count || 0}`;
                toast.success(message);
            }