Node.js异步编程：正确处理HTTP请求与数据同步

app.post("/getWeather",(req,res,next)=>{
    console.log(req.body.cities);
    const cities=req.body.cities;
    const result={}; // 初始化结果对象

    cities.map((city)=>{
        // 发起异步HTTPS请求
        https.get(url,(response)=>{
            response.on("data",(data)=>{
                const wdata=JSON.parse(data);
                const temperature=wdata.main.temp;
                result[city]=temperature; // 在回调中更新result
            });
        }).on("error",(err)=>{
            console.log(err);
            result[city]="NA"; // 在错误回调中更新result
        });
    });

    // 问题所在：这里立即返回result，而https.get请求尚未完成
    return res.json(result);
});

// 假设url变量已经根据city动态生成
function fetchWeather(city) {
    return new Promise((resolve, reject) => {
        // 构建每个城市的URL
        const cityUrl = `https://api.openweathermap.org/data/2.5/weather?q=${city}&appid=YOUR_API_KEY&units=metric`; // 示例URL，请替换为实际URL和API Key

        https.get(cityUrl, (response) => {
            let rawData = '';
            response.on('data', (chunk) => {
                rawData += chunk;
            });
            response.on('end', () => {
                try {
                    const wdata = JSON.parse(rawData);
                    const temperature = wdata.main.temp;
                    resolve({ city, temperature }); // 成功时解决Promise，并返回城市和温度
                } catch (e) {
                    console.error(`解析${city}天气数据失败:`, e.message);
                    resolve({ city, temperature: "NA" }); // 解析失败也解决Promise，但标记为NA
                }
            });
            response.on('error', (err) => {
                console.error(`获取${city}天气数据失败:`, err.message);
                resolve({ city, temperature: "NA" }); // 网络错误也解决Promise，标记为NA
            });
        }).on('error', (err) => { // https.get本身也可能触发error
            console.error(`发起${city}请求失败:`, err.message);
            resolve({ city, temperature: "NA" });
        });
    });
}

app.post("/getWeather", async (req, res, next) => {
    console.log(req.body.cities);
    const cities = req.body.cities;
    const result = {};

    // 创建一个Promise数组，每个Promise负责一个城市的天气获取
    const weatherPromises = cities.map(city => fetchWeather(city));

    try {
        // 等待所有Promise完成
        const weatherResults = await Promise.all(weatherPromises);

        // 遍历所有结果，填充最终的result对象
        weatherResults.forEach(data => {
            result[data.city] = data.temperature;
        });

        // 所有异步操作完成后，安全地返回result
        return res.json(result);
    } catch (error) {
        // Promise.all()只有在所有Promise都resolve时才会resolve
        // 如果任何一个Promise reject，Promise.all()就会立即reject
        // 但在我们的fetchWeather实现中，即使有错误也是resolve并返回"NA"
        // 所以这里的catch块主要用于捕获Promise.all()自身可能抛出的错误，
        // 或者fetchWeather函数内部未被捕获的同步错误。
        console.error("处理天气请求时发生错误:", error);
        return res.status(500).json({ error: "无法获取部分或全部城市的天气数据" });
    }
});