如何在Firestore的Where条件变更时生成更新的查询快照？

你的现有代码存在核心问题：favItems变量更新后，不会触发Item集合的查询重新执行——因为你返回的是初始创建的固定查询流，后续favItems的变化无法传递给已创建的where条件。

要实现查询条件变更时自动刷新快照，关键是将用户文档的快照流转换为Item集合的动态查询流，这里可以用Dart Stream API中的switchMap操作符实现：

修正后的代码 #

import 'package:rxdart/rxdart.dart'; // 依赖rxdart简化流转换逻辑

static Stream<QuerySnapshot<Item>> favItem(String userID) {
  // 监听用户文档的快照流
  return FirebaseFirestore.instance
      .collection('User')
      .withConverter(
        fromFirestore: User.fromFirestore,
        toFirestore: (user, options) => user.toFirestore(),
      )
      .doc(userID)
      .snapshots()
      // 每当用户快照更新时，切换为新的Item查询流
      .switchMap((userSnapshot) {
        final favItems = userSnapshot.data()?.favItemsID ?? [];
        
        // 处理空列表：Firestore不允许whereIn传入空数组，返回空快照避免异常
        if (favItems.isEmpty) {
          return Stream.value(QuerySnapshot<Item>.empty());
        }

        // 根据最新的favItems创建并返回新的查询流
        return FirebaseFirestore.instance
            .collection('Item')
            .withConverter(
              fromFirestore: Item.fromFirestore,
              toFirestore: (item, options) => item.toFirestore(),
            )
            .where('itemID', whereIn: favItems)
            .snapshots();
      });
}

关键说明 #

1. switchMap的作用：它会监听用户文档的快照流，每当favItemsID更新时，自动取消之前的Item查询订阅，创建并返回使用最新favItems的查询流，实现动态更新。
2. 空列表处理：Firestore的whereIn不接受空数组，因此需要判断favItems是否为空，此时返回空快照避免抛出异常。
3. 类型安全：保持withConverter的使用，确保数据模型的类型转换正确。

如果你不想依赖rxdart，也可以用原生Dart的async*生成器实现相同逻辑：

static Stream<QuerySnapshot<Item>> favItem(String userID) async* {
  final userStream = FirebaseFirestore.instance
      .collection('User')
      .withConverter(
        fromFirestore: User.fromFirestore,
        toFirestore: (user, options) => user.toFirestore(),
      )
      .doc(userID)
      .snapshots();
  
  await for (final userSnapshot in userStream) {
    final favItems = userSnapshot.data()?.favItemsID ?? [];
    
    if (favItems.isEmpty) {
      yield QuerySnapshot<Item>.empty();
      continue;
    }

    final itemStream = FirebaseFirestore.instance
        .collection('Item')
        .withConverter(
          fromFirestore: Item.fromFirestore,
          toFirestore: (item, options) => item.toFirestore(),
        )
        .where('itemID', whereIn: favItems)
        .snapshots();
    
    await for (final itemSnapshot in itemStream) {
      yield itemSnapshot;
    }
  }
}

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