Flutter Firebase认证：流查询返回null致已有用户重复创建的解决

你的核心问题是并发场景下的竞态条件，加上查询可靠性不足，导致多个请求同时查询到空结果，进而重复创建相同firebase_id的用户。即便用了asyncMap，流的首次触发仍可能因为网络延迟、索引未生效等原因漏查已存在用户，无法从根本上解决并发冲突。以下是几个关键解决方案：

1. 利用Firestore文档ID的唯一性（最直接的方案） #

把firebase_id直接设为customers集合的文档ID，这样Firestore会天然保证每个firebase_id对应唯一文档，从底层杜绝重复创建的可能。同时查询效率也会更高，无需使用where条件：

Future<Customer> getOrCreateCustomer({
  required String firebaseId,
  String? email,
  String? phoneNumber,
}) async {
  final docRef = FirebaseFirestore.instance.collection('customers').doc(firebaseId);
  
  return FirebaseFirestore.instance.runTransaction((transaction) async {
    final docSnapshot = await transaction.get(docRef);
    
    // 检查文档是否存在且状态为active
    if (docSnapshot.exists && docSnapshot['status'] == 'active') {
      return Customer.fromSnapshot(docSnapshot);
    } else {
      // 创建或更新用户
      final customer = Customer(
        firebaseId: firebaseId,
        status: 'active',
        email: email,
        mobile: phoneNumber,
        authenticationEmail: email,
        averageRating: 5,
        updatedAt: DateTime.now().toUtc(),
        createdAt: DateTime.now().toUtc(),
      );
      await transaction.set(docRef, customer.toMap());
      customer.reference = docRef;
      return customer;
    }
  });
}

// 如果需要实时流，先确保用户存在，再监听文档变化
Stream<Customer> getCustomerStream({
  required String firebaseId,
  String? email,
  String? phoneNumber,
}) async* {
  final customer = await getOrCreateCustomer(
    firebaseId: firebaseId,
    email: email,
    phoneNumber: phoneNumber,
  );
  yield* customer.reference!.snapshots().map((snap) => Customer.fromSnapshot(snap));
}

2. 使用事务确保原子性 #

如果不能修改文档ID，必须用where查询，那么一定要用事务包裹查询和创建操作。事务会锁定相关资源，确保同一时间只有一个请求能完成"查询-创建"的流程，彻底避免竞态条件：

Future<Customer> getOrCreateCustomer({
  required String firebaseId,
  String? email,
  String? phoneNumber,
}) async {
  return FirebaseFirestore.instance.runTransaction((transaction) async {
    // 事务内执行查询，确保看到最新数据
    final querySnap = await transaction.get(
      FirebaseFirestore.instance
          .collection('customers')
          .where('firebase_id', isEqualTo: firebaseId)
          .where('status', isEqualTo: 'active')
          .limit(1),
    );

    if (querySnap.docs.isNotEmpty) {
      return Customer.fromSnapshot(querySnap.docs[0]);
    } else {
      final docRef = FirebaseFirestore.instance.collection('customers').doc();
      final customer = Customer(
        firebaseId: firebaseId,
        status: 'active',
        email: email,
        mobile: phoneNumber,
        authenticationEmail: email,
        averageRating: 5,
        updatedAt: DateTime.now().toUtc(),
        createdAt: DateTime.now().toUtc(),
      );
      await transaction.set(docRef, customer.toMap());
      customer.reference = docRef;
      return customer;
    }
  });
}

3. 添加唯一索引兜底 #

在Firebase控制台给customers集合的firebase_id字段添加唯一索引（如果需要结合status，可以创建firebase_id + status的复合唯一索引），这样即使代码出现疏漏，Firestore也会直接拒绝重复写入，抛出错误，你可以在代码中捕获错误并重新查询用户。

操作步骤：

• 打开Firebase控制台 -> Firestore数据库 -> 索引
• 点击"添加索引"，选择customers集合，添加firebase_id字段，勾选"唯一"
• 若需要限制active状态的唯一性，可添加复合索引：字段选firebase_id和status，勾选"唯一"

4. 确保查询索引生效 #

你的原查询使用了where+orderBy，必须确保对应的复合索引已创建。如果Firestore返回查询错误，控制台会提供一个自动创建索引的链接，点击创建即可，否则查询可能返回不完整的结果，导致误判用户不存在。

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