Flutter从Firestore两个集合关联获取数据时变量为空的问题排查

嘿，我一眼就看出问题出在哪了——异步操作的执行顺序搞反了！matchCollections()是异步函数，它得花点时间去Firestore拉取用户数据，但你调用test()的时候完全没等它完成，这就导致test()执行时village还是初始的null值。另外你的代码还有些可以简化的地方，比如没必要把所有用户都存到items列表里，我们只需要当前登录用户的村庄信息就行。

下面给你两个修正方案，直接就能用：

方案1：规范异步顺序，先拿村庄信息再查数据 #

我们把获取村庄信息的逻辑改成返回值的异步函数，确保test()执行前已经拿到了村庄名称：

AuthController authController = AuthController();
String? village;

// 改写为直接返回当前用户村庄的异步函数
Future<String?> getCurrentUserVillage() async {
  final currentUserEmail = authController.auth.currentUser?.email;
  if (currentUserEmail == null) {
    print("用户未登录或邮箱为空");
    return null;
  }

  final userSnapshot = await userCollectionRef
      .where('email', isEqualTo: currentUserEmail)
      .get();
  
  // 邮箱是唯一标识，直接取第一个文档就行
  if (userSnapshot.docs.isNotEmpty) {
    final user = UserModel.fromMap(userSnapshot.docs.first);
    village = user.village;
    print("当前用户所属村庄：$village");
    return village;
  }
  print("未找到对应用户数据");
  return null;
}

// 确保先拿到村庄信息再执行查询
Future<void> test() async {
  final currentVillage = await getCurrentUserVillage();
  if (currentVillage == null) return;

  villagesCollectionRef
      .where('name', isEqualTo: currentVillage)
      .snapshots()
      .listen((event) {
    for (var doc in event.docs) {
      print("匹配到的村庄文档ID：${doc.id}");
      // 这里可以直接获取该村庄的子集合，比如：
      // doc.reference.collection("你的子集合名").get().then((subSnap) { ... })
    }
  });
}

方案2：合并逻辑，一步到位获取目标数据 #

如果你的最终目标就是拿到当前用户所属村庄的（含子集合）数据，完全可以把两步逻辑合并，减少变量传递的麻烦：

AuthController authController = AuthController();

Future<void> listenToUserVillageData() async {
  final currentUser = authController.auth.currentUser;
  if (currentUser == null || currentUser.email == null) {
    print("用户未登录");
    return;
  }

  // 第一步：获取当前用户的村庄名称
  final userQuery = await userCollectionRef
      .where('email', isEqualTo: currentUser.email)
      .get();
  
  if (userQuery.docs.isEmpty) {
    print("未找到当前用户信息");
    return;
  }

  final userVillage = UserModel.fromMap(userQuery.docs.first).village;
  if (userVillage == null) {
    print("该用户未绑定村庄");
    return;
  }

  // 第二步：监听对应村庄的文档及子集合
  villagesCollectionRef
      .where('name', isEqualTo: userVillage)
      .snapshots()
      .listen((villageSnap) {
    for (var villageDoc in villageSnap.docs) {
      print("村庄ID：${villageDoc.id}，名称：${villageDoc['name']}");
      
      // 示例：获取该村庄的子集合数据（比如子集合叫"activities"）
      villageDoc.reference.collection("activities").get().then((subSnap) {
        print("该村庄的子集合数据：${subSnap.docs.map((d) => d.data())}");
      });
    }
  });
}

几个关键注意事项 #

• 异步操作必须等：Firestore的get()、snapshots()都是异步操作，一定要用await等待完成，不然永远拿不到最新数据。
• 利用唯一性简化代码：用户邮箱是唯一的，查询后直接取第一个文档就行，不用遍历所有结果。
• 空值安全不能少：增加用户未登录、未找到用户、未绑定村庄的判断，避免运行时崩溃。

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