通过setInterval调用Apex返回重复结果，进度条无法更新

问题根源 #

核心问题是Apex方法的缓存机制导致重复返回旧数据：默认情况下，若Apex方法未明确设置cacheable=false，Salesforce会缓存其响应结果，无论用setInterval还是wire调用，都会拿到缓存的初始值，不会去服务器拉取最新进度。另外，用wire时若未正确使用refreshApex，也无法触发重新获取数据。

解决方案 #

第一步：修正Apex方法，禁用缓存 #

给获取进度的Apex方法添加cacheable=false注解，确保每次调用都直接从服务器查询最新的Job状态：

public with sharing class JobProgressController {
    @AuraEnabled(cacheable=false) // 关键：禁用响应缓存
    public static Decimal getAsyncJobProgress(String jobId) {
        AsyncApexJob targetJob = [
            SELECT Id, JobItemsProcessed, TotalJobItems, Status 
            FROM AsyncApexJob 
            WHERE Id = :jobId
        ];
        
        if (targetJob.TotalJobItems == 0) {
            return 0;
        }
        
        // 计算进度百分比
        return (Decimal)targetJob.JobItemsProcessed / targetJob.TotalJobItems * 100;
    }
}

第二步：LWC实现（两种可选方式） #

方式1：用Imperative Apex + setInterval

直接在轮询中调用Apex方法，每次请求都会获取最新数据：

import { LightningElement, api } from 'lwc';
import getAsyncJobProgress from '@salesforce/apex/JobProgressController.getAsyncJobProgress';

export default class JobProgressBar extends LightningElement {
    @api jobId;
    progress = 0;
    pollingInterval;

    connectedCallback() {
        this.startProgressPolling();
    }

    disconnectedCallback() {
        // 组件销毁时清除轮询，避免内存泄漏
        if (this.pollingInterval) {
            clearInterval(this.pollingInterval);
        }
    }

    startProgressPolling() {
        this.pollingInterval = setInterval(() => {
            getAsyncJobProgress({ jobId: this.jobId })
                .then(result => {
                    this.progress = result;
                    // 进度完成后停止轮询
                    if (this.progress >= 100) {
                        clearInterval(this.pollingInterval);
                    }
                })
                .catch(error => {
                    console.error('进度查询失败:', error);
                    clearInterval(this.pollingInterval);
                });
        }, 4000); // 每4秒轮询一次
    }
}

方式2：用Wire + refreshApex

如果想用wire机制，必须保存wire返回的完整结果，再通过refreshApex强制刷新数据：

import { LightningElement, api, wire } from 'lwc';
import getAsyncJobProgress from '@salesforce/apex/JobProgressController.getAsyncJobProgress';
import { refreshApex } from '@salesforce/apex';

export default class JobProgressBar extends LightningElement {
    @api jobId;
    progress = 0;
    pollingInterval;
    _wiredProgressResult; // 保存wire的完整结果，用于refreshApex

    @wire(getAsyncJobProgress, { jobId: '$jobId' })
    wiredJobProgress(result) {
        this._wiredProgressResult = result;
        if (result.data) {
            this.progress = result.data;
            // 进度完成后停止轮询
            if (this.progress >= 100 && this.pollingInterval) {
                clearInterval(this.pollingInterval);
            }
        } else if (result.error) {
            console.error('进度查询失败:', result.error);
            if (this.pollingInterval) {
                clearInterval(this.pollingInterval);
            }
        }
    }

    connectedCallback() {
        this.startProgressPolling();
    }

    disconnectedCallback() {
        if (this.pollingInterval) {
            clearInterval(this.pollingInterval);
        }
    }

    startProgressPolling() {
        this.pollingInterval = setInterval(() => {
            // 强制刷新wire数据
            refreshApex(this._wiredProgressResult);
        }, 4000);
    }
}

关键注意事项 #

• 必须禁用Apex缓存：如果cacheable设为true，Salesforce会缓存响应，无论怎么轮询都拿不到新数据。
• 清理轮询定时器：在组件销毁时调用clearInterval，避免不必要的服务器请求和内存泄漏。
• 进度完成后停止轮询：不需要一直请求，当进度达到100%时立即停止，减少资源消耗。

内容的提问来源于stack exchange，提问作者Himanshu Joshi