Express中处理嵌套异步数据：解决res.json()返回空对象问题

router.get('/movies/data/:imdbID', function(req, res, next) {
  const queryMovie = req.db.from('basics').select(
      'primaryTitle',
      'year',
      'runtimeMinutes',
      'genres',
      'country',
      'boxoffice',
      'poster',
      'plot'
    ).where('tconst', req.params.imdbID);

  const queryPrincipals = req.db.from('principals').select('nconst', 'category', 'name', 'characters').where('tconst', req.params.imdbID);

  queryMovie.then((movieData) => {
    const movie = movieData.map(data => {
      return {
        title: data.tconst, // 注意：此处原代码可能存在字段映射错误，tconst通常是ID，primaryTitle是标题
        year: data.year,
        runtime: data.runtimeMinutes,
        country: data.country,
        // 问题所在：principals的获取是一个异步操作，但在此处被同步处理
        principals: queryPrincipals.then((principals) => {
          // 这个then块内部的map操作会在Promise解析后执行
          // 但外部的map函数已经返回，无法捕获到这里的异步结果
          principals.map(principal => {
            return {
              id: principal.nconst,
              category: principal.category,
              name: principal.name,
              characters: principal.characters
            }
          })
        }),
        boxoffice: data.genres, // 字段映射错误，应为data.boxoffice
        poster: data.genres,    // 字段映射错误，应为data.poster
        plot: data.plot
      }
    });
    res.json(movie);
  });
});

router.get('/movies/data/:imdbID', async function(req, res, next) {
  try {
    // 1. 定义数据库查询
    // Knex查询构建器本身是thenable的，可以直接await，也可以通过.then()或.catch()处理
    const movieQuery = req.db.from('basics')
      .select(
        'primaryTitle',
        'year',
        'runtimeMinutes',
        'genres', // 假设genres存储为JSON字符串，需要解析
        'country',
        'boxoffice',
        'poster',
        'plot'
      )
      .where('tconst', req.params.imdbID);

    const principalsQuery = req.db.from('principals')
      .select('nconst', 'category', 'name', 'characters') // 假设characters存储为JSON字符串，需要解析
      .where('tconst', req.params.imdbID);

    // 2. 并行执行查询以提高效率
    // 使用 Promise.all() 同时发起两个独立的数据库查询，等待它们全部完成
    const [movieDataArray, rawPrincipalsArray] = await Promise.all([
      movieQuery,
      principalsQuery
    ]);

    // 3. 检查电影数据是否存在
    if (!movieDataArray || movieDataArray.length === 0) {
      return res.status(404).json({ message: 'Movie not found.' });
    }

    // 假设imdbID对应唯一电影，取第一个结果
    const rawMovie = movieDataArray[0];

    // 4. 处理principals数据
    // 确保rawPrincipalsArray是数组，并进行映射转换
    const principals = rawPrincipalsArray.map(principal => ({
      id: principal.nconst,
      category: principal.category,
      name: principal.name,
      characters: principal.characters ? JSON.parse(principal.characters) : [] // 解析JSON字符串，如果为空则返回空数组
    }));

    // 5. 组合最终响应对象
    const movieResponse = {
      title: rawMovie.primaryTitle,
      year: rawMovie.year,
      runtime: rawMovie.runtimeMinutes,
      genres: rawMovie.genres ? JSON.parse(rawMovie.genres) : [], // 解析JSON字符串，如果为空则返回空数组
      country: rawMovie.country,
      principals: principals, // 此时principals已是解析后的数据数组
      boxoffice: rawMovie.boxoffice,
      poster: rawMovie.poster,
      plot: rawMovie.plot
    };

    // 6. 发送JSON响应
    res.json(movieResponse);

  } catch (error) {
    // 7. 错误处理
    console.error('Error fetching movie data:', error);
    res.status(500).json({ message: 'Internal server error.' });
  }
});