Angular/Firestore获取集合最高seqNr存变量并生成自增序号的方法

你当前定义的this.lastTodoSeqNr是AngularFire封装的集合查询实例，需要通过对应方法获取查询返回的数据流后才能提取seqNr值，以下是两种常用的实现方式：

方式1：订阅Observable直接处理 #

适合单次查询后立即执行新增操作的场景：

import { first } from 'rxjs/operators';

this.db.collection<any>('todosonserver', ref => ref.orderBy('seqNr', 'desc').limit(1))
  .valueChanges() // 获取查询结果的可观察对象
  .pipe(first()) // 仅获取一次当前结果，避免持续监听造成内存泄漏
  .subscribe({
    next: (todos) => {
      // 集合为空时默认seqNr从1开始
      const newSeqNr = todos.length ? todos[0].seqNr + 1 : 1;
      // 此处编写新增文档逻辑，将newSeqNr写入新文档字段
      this.db.collection('todosonserver').add({
        // 你的其他todo字段，例如title、completed等
        seqNr: newSeqNr
      });
    },
    error: (err) => console.error('查询最高seqNr失败：', err)
  })

方式2：async/await异步写法 #

适合多异步流程嵌套的场景，代码可读性更高：

import { first } from 'rxjs/operators';

async addNewTodo() {
  try {
    const todos = await this.db.collection<any>('todosonserver', ref => ref.orderBy('seqNr', 'desc').limit(1))
      .valueChanges()
      .pipe(first())
      .toPromise();
    
    const newSeqNr = todos.length ? todos[0].seqNr + 1 : 1;
    // 新增文档逻辑
    await this.db.collection('todosonserver').add({
      title: '示例待办',
      completed: false,
      seqNr: newSeqNr
    });
  } catch (err) {
    console.error('操作失败：', err);
  }
}

• 上述先查后写的逻辑在高并发场景下会出现竞态问题，可能生成重复的seqNr，如果你的业务存在高并发需求，建议改用Firestore分布式计数器、或者通过云函数触发器统一生成seqNr。
• 首次执行查询前需要给seqNr字段添加索引，Firestore控制台会自动抛出索引创建入口，点击即可完成创建。

内容的提问来源于stack exchange，提问作者andi-koler