Angular 5与Firebase/AngularFire：用户课程关联查询问题求助

我看你现在卡在两个核心问题上：一是getCourseKeys的异步逻辑写得不对，导致返回“非法返回”错误；二是后续用户与课程Key匹配的循环逻辑有问题。咱们一步步拆解修复：

1. 先修复getCourseKeys的异步处理（根源问题） #

你原来的getCourseKeys犯了两个常见的异步错误：

• 直接把subscribe()的返回值（Subscription对象）赋值给了this.courses，这根本不是你要的课程Key数组
• 手动写的Promise完全无效——你没调用resolve()，而且return的时候异步请求还没完成，courseKeys还是空的

重构方案（用RxJS，更符合Angular/Firebase的生态） #

既然项目里用的是Firebase的Observable，直接用RxJS操作符处理就行，不用绕Promise：

// 返回Observable<string[]>，直接给出课程Key的数组
private getCourseKeys(course): Observable<string[]> {
  return this.adminService.getUsersCourses(course).pipe(
    // 把snapshots数组转换成只包含$key的数组
    map(snapshots => snapshots.map(snapshot => snapshot.$key))
  );
}

如果一定要用Promise（不推荐，Angular更适合RxJS），可以转成Promise：

private getCourseKeys(course): Promise<string[]> {
  return this.adminService.getUsersCourses(course).pipe(
    map(snapshots => snapshots.map(snapshot => snapshot.$key))
  ).toPromise();
}

2. 重构getCourses函数，正确处理异步+简化筛选逻辑 #

你原来的循环逻辑完全没必要——snapshot.$key是单个用户的Key字符串，不是数组，嵌套的for (let i = 0; i < usersLength; i++)完全是多余的，而且会导致重复添加用户。

用RxJS组合流的方案（推荐） #

getCourses(course) { 
  this.getCourseKeys(course).pipe(
    // 先拿到课程Key数组，再去请求用户列表
    switchMap(courseKeys => {
      // 如果没有课程Key，直接返回空数组
      if (courseKeys.length === 0) {
        return of([]);
      }
      // 拿到用户列表后，过滤出Key在courseKeys里的用户
      return this.adminService.getUsers().pipe(
        map(users => users.filter(user => courseKeys.includes(user.$key)))
      );
    })
  ).subscribe({
    next: (filteredUsers) => {
      console.log('匹配课程权限的用户：', filteredUsers);
      // 这里把结果赋值给你的变量，比如this.test = filteredUsers;
    },
    error: (err) => {
      console.error('获取数据出错：', err);
    }
  });
}

如果用Promise+async/await的方案 #

async getCourses(course) { 
  try {
    const courseKeys = await this.getCourseKeys(course);
    if (courseKeys.length === 0) {
      console.log('没有匹配的课程Key');
      return;
    }
    // 注意：getUsers返回的是Observable，要转成Promise才能await
    const users = await this.adminService.getUsers().toPromise();
    const filteredUsers = users.filter(user => courseKeys.includes(user.$key));
    console.log('匹配课程权限的用户：', filteredUsers);
    this.test = filteredUsers;
  } catch (err) {
    console.error('获取数据出错：', err);
  }
}

3. 额外注意点 #

• 内存泄漏：如果组件销毁时还在订阅Observable，记得用takeUntil或者手动取消订阅，避免内存泄漏
• Firebase查询优化：如果用户量很大，不要全量拉取用户再过滤——可以直接在Firebase端用orderByKey()+in查询（不过Firebase的in最多支持10个Key，超过的话要分批处理）
• 变量命名：你原来的代码里this.courses和this.courseKeys有点混淆，建议统一命名，比如courseKeys专门存课程Key数组

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