Express 中嵌套异步数据查询并正确响应 JSON

router.get('/movies/data/:imdbID', function(req, res, next) {
  const queryMovie = req.db.from('basics').select(/* ... */).where('tconst', req.params.imdbID);
  const queryPrincipals = req.db.from('principals').select(/* ... */).where('tconst', req.params.imdbID);

  queryMovie.then((movieData) => {
    const movie = movieData.map(data => {
      return {
        // ...其他电影数据
        principals: queryPrincipals.then((principals) => { // 错误：map不会等待这个Promise
          return principals.map(principal => { /* ... */ });
        }),
        // ...
      }
    });
    res.json(movie); // 此时principals可能还是一个未解析的Promise或空对象
  });
});

router.get('/movies/data/:imdbID', async function(req, res, next) {
  try {
    // 1. 定义电影基本信息查询
    const queryMovie = req.db.from('basics')
      .select(
        'primaryTitle',
        'year',
        'runtimeMinutes',
        'genres',
        'country',
        'boxoffice',
        'poster',
        'plot'
      )
      .where('tconst', req.params.imdbID);

    // 2. 定义演职人员信息查询
    const queryPrincipals = req.db.from('principals')
      .select('nconst', 'category', 'name', 'characters')
      .where('tconst', req.params.imdbID);

    // 3. 等待电影基本信息查询结果
    const movieData = await queryMovie; // Knex查询本身返回Promise

    // 4. 映射电影数据，并在内部处理演职人员数据
    // 注意：如果movieData是数组，且我们只期望一个结果，可以考虑使用.first()或直接处理第一个元素
    const result = await Promise.all(movieData.map(async ({
      primaryTitle: title,
      year,
      runtimeMinutes: runtime,
      genres,
      country,
      boxoffice,
      poster,
      plot
    }) => {
      // 在map回调内部，等待演职人员查询结果
      // 注意：这里queryPrincipals()调用后，需要await等待其结果
      const principalsRaw = await queryPrincipals; // Knex查询本身返回Promise
      const principals = principalsRaw.map(
        ({
          nconst: id,
          category,
          name,
          characters
        }) => ({
          id,
          category,
          name,
          // characters字段在数据库中可能是字符串，如果需要数组，可能需要进一步处理
          characters: characters ? JSON.parse(characters) : []
        })
      );

      return {
        title,
        year,
        runtime,
        genres: genres ? JSON.parse(genres) : [], // 假设genres在数据库中是JSON字符串
        country,
        principals,
        boxoffice,
        poster,
        plot
      };
    }));

    // 5. 发送JSON响应
    // 如果movieData通常只返回一个电影，可以直接返回result[0]
    res.json(result.length > 0 ? result[0] : {});

  } catch (error) {
    // 6. 错误处理
    console.error('获取电影数据失败:', error);
    next(error); // 将错误传递给Express错误处理中间件
  }
});