如何仅监听Firebase Firestore集合的新增记录并触发音效？

你当前通过记录集合总数量变化触发音效的方式存在几个局限：

• 若出现「删除旧文档+新增新文档」的情况，总数量不变，无法检测到新增记录
• 依赖本地存储的计数，一旦本地数据异常（比如Hive存储被清除），逻辑会出现误判或失效

更可靠的方式是直接利用Firestore快照提供的docChanges属性，精准识别新增的文档，同时结合Hive记录最后处理过的文档标记，避免重复触发。

优化后的实现代码 #

final Stream<QuerySnapshot> stream = FirebaseFirestore.instance
    .collection('myItems')
    .where(
      "date",
      isGreaterThanOrEqualTo: DateTime.now().add(const Duration(hours: -12)),
    )
    .snapshots();

stream.listen((event) async {
  // 获取上次处理到的最新文档ID（首次为null）
  final lastProcessedDocId = HiveService.getLastProcessedDocId();
  
  for (final change in event.docChanges) {
    // 只处理新增的文档
    if (change.type == DocumentChangeType.added) {
      final newDocId = change.doc.id;
      
      // 过滤掉重启APP后重新监听时收到的历史文档
      if (lastProcessedDocId == null || newDocId != lastProcessedDocId) {
        final AudioPlayer player = AudioPlayer();
        final AssetSource audioasset = AssetSource('sound/beep.wav');
        await player.play(audioasset);
        
        // 更新Hive中记录的最新文档ID
        HiveService.setLastProcessedDocId(newDocId);
        break; // 每次只处理一条新增记录，避免多条同时新增时重复播放
      }
    }
  }
});

补充说明 #

1. 用文档ID标记而非计数：通过记录最后处理的文档ID，能精准区分新老记录，不受文档删除、排序变化的影响
2. 过滤历史文档：当APP重启重新监听流时，Firestore会返回符合条件的所有现有文档，通过对比上次记录的文档ID，可以避免对历史文档重复触发音效
3. 按需调整播放逻辑：如果需要支持多条新增记录同时播放音效，可以去掉break，但建议添加播放间隔控制，避免音效重叠

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