出运单增加过滤发货通知单和物流状态

wangyi

2026-04-02 74feb99b1b4e2eb3706bbb503d07fb087ca39d4a

 src/utils/healthCheck.js

@@ -13,35 +13,75 @@
];

/**
 * 检测单个服务健康状态
 * 带超时控制的 fetch 请求封装
 * @param {string} url 请求地址
 * @param {Object} options fetch 配置
 * @param {number} timeout 超时时间（毫秒），默认 3000ms
 * @returns {Promise<Response>} 请求响应
 */
const fetchWithTimeout = async (url, options = {}, timeout = 3000) => {
    // 1. 创建中止控制器，用于超时取消请求
    const controller = new AbortController();
    const signal = controller.signal;

    // 2. 超时定时器：到时间后中止请求并抛出错误
    const timeoutTimer = setTimeout(() => {
        controller.abort();
        throw new Error(`请求超时（${timeout}ms）`);
    }, timeout);

    try {
        // 3. 绑定中止信号到 fetch 请求
        const response = await fetch(url, {
            ...options,
            signal, // 关键：关联中止控制器
        });
        clearTimeout(timeoutTimer); // 请求成功，清除超时定时器
        return response;
    } catch (error) {
        clearTimeout(timeoutTimer); // 出错/超时，清除定时器
        // 区分中止错误（超时）和其他错误
        if (error.name === 'AbortError') {
            throw new Error(`请求超时：${url} 超过 ${timeout}ms 未响应`);
        }
        throw error; // 抛出其他错误（如网络错误）
    }
};

/**
 * 检测单个服务健康状态（新增超时控制）
 * @param {Object} service - 服务配置（baseUrl + healthPath）
 * @returns {Promise<String|null>} 可用的 baseUrl，失败返回 null
 */
export const checkServiceHealth = async (service) => {
    const { baseUrl, healthPath } = service;
    if (!baseUrl) return null;
    return new Promise(async (resolve, reject) => {
        try {
            // 健康检查请求（超时 3 秒，不携带 Token，避免未登录拦截）
            const response = await fetch(`${baseUrl}${healthPath}`, {
    
    try {
        // 健康检查请求（使用封装的带超时的 fetch，3秒超时）
        const response = await fetchWithTimeout(
            `${baseUrl}${healthPath}`,
            {
                method: "GET",
                timeout: 3000,
                headers: {
                    "Content-Type": "application/json",
                },
            });
            if (response.ok) {
                console.log(`服务 ${service.name} 健康，地址：${baseUrl}`);
                resolve(baseUrl)
                // return baseUrl;
            }
        } catch (error) {
            console.error(`服务 ${service.name} 连接失败：`, error.message);
            resolve(null)
            // return null;
        }
    })
            },
            3000 // 明确配置 3 秒超时
        );

        if (response.ok) {
            console.log(`服务 ${service.name} 健康，地址：${baseUrl}`);
            return baseUrl;
        } else {
            // 响应状态码非 2xx，视为服务不可用
            console.warn(`服务 ${service.name} 响应异常，状态码：${response.status}`);
            return null;
        }
    } catch (error) {
        console.error(`服务 ${service.name} 连接失败：`, error.message);
        return null;
    }
};

/**
@@ -52,21 +92,20 @@
    // 并行检测所有服务（提高效率）
    try {
        const healthCheckPromises = serviceList.map((item) => {
            return checkServiceHealth(item)
            return checkServiceHealth(item);
        });
        const healthResult = await Promise.all(healthCheckPromises); // 检测到健康的链接就立刻返回
        const healthResult = await Promise.all(healthCheckPromises);
        // 筛选可用的 baseUrl
        console.log(healthResult)
        const availableBaseUrl = healthResult.filter((item)=>item!=null)[0]
        console.log("健康检查结果：", healthResult);
        const availableBaseUrl = healthResult.filter((item) => item != null)[0];

        if (availableBaseUrl) {
            return availableBaseUrl;
        } else {
            // 所有服务均不可用，抛出异常（后续在初始化时捕获）
            // 所有服务均不可用，抛出异常
            throw new Error("所有服务健康检查失败，请检查服务状态或网络配置");
        }
    }catch(err) {
    } catch (err) {
        throw err;
    }
    
};