Firebase Firestore如何确认文档全部拉取完成 可否合并OR条件查询

你当前的排序结果异常本质是两个并行异步查询没有做同步等待：排序、UI渲染逻辑仅绑定在query2的完成回调中，没有等待query1的返回结果，当query2比query1先返回时，就会出现query1拉到的数据还没加入列表就提前排序、数据不全的问题。

• 单个Firestore查询的get()方法本身就会在拉取完该查询下所有匹配文档后才触发onComplete/onSuccess回调，不存在单个查询返回半批数据的情况，回调触发即代表该查询全量结果返回完成。
• 针对你这种多个并行查询的场景，安卓端可以用Firebase SDK自带的Tasks工具类做任务汇合：把两个查询的Task对象传入Tasks.whenAllComplete()/Tasks.whenAllSuccess()，等两个查询都触发完成回调后，再统一执行列表合并、排序、UI更新逻辑，从根源上避免提前执行后续逻辑的问题。

支持，Firebase Firestore从24.0.0版本的BoM开始就提供了OR查询能力，通过Filter.or()组合多个过滤条件即可，注意：

• 跨字段的OR+范围筛选+排序需要在Firebase控制台创建对应的复合索引，首次运行报错时控制台会打印索引创建的直接入口，按提示操作即可
• 合并为单个查询后可以直接在查询语句中指定orderBy("timeStamp", Query.Direction.DESCENDING)，Firestore会直接返回排好序的结果，不需要你再做本地排序，性能更好。

方案1：保留两个查询，用Tasks做任务同步（不需要改索引，改动最小） #

// 初始化线程安全的列表，避免多线程操作列表出现异常
List<TransferRecordClass> transferrecordlist = new CopyOnWriteArrayList<>();

CollectionReference doc = firebaseFirestore.collection("TransferRecord");
// 第一个查询：转出记录
Query query = doc.whereEqualTo("fromStudentID", StudentID)
        .whereGreaterThanOrEqualTo("timeStamp", previousDate)
        .whereLessThan("timeStamp", currentDate)
        .orderBy("timeStamp", Query.Direction.DESCENDING);
Task<QuerySnapshot> task1 = query.get();

// 第二个查询：转入记录
Query query2 = doc.whereEqualTo("toStudentID", StudentID)
        .whereGreaterThanOrEqualTo("timeStamp", previousDate)
        .whereLessThan("timeStamp", currentDate)
        .orderBy("timeStamp", Query.Direction.DESCENDING);
Task<QuerySnapshot> task2 = query2.get();

// 等两个查询全部完成后再执行后续逻辑
Tasks.whenAllComplete(task1, task2).addOnCompleteListener(new OnCompleteListener<List<Task<?>>>() {
    @Override
    public void onComplete(@NonNull Task<List<Task<?>>> task) {
        transferrecordlist.clear();
        // 处理第一个查询的结果
        if (task1.isSuccessful() && task1.getResult() != null) {
            for (DocumentSnapshot docSnap : task1.getResult()) {
                TransferRecordClass item = docSnap.toObject(TransferRecordClass.class);
                transferrecordlist.add(item);
            }
        }
        // 处理第二个查询的结果
        if (task2.isSuccessful() && task2.getResult() != null) {
            for (DocumentSnapshot docSnap : task2.getResult()) {
                TransferRecordClass item = docSnap.toObject(TransferRecordClass.class);
                transferrecordlist.add(item);
            }
        }

        // 后续排序、UI逻辑统一在这里执行
        if (transferrecordlist.isEmpty()) {
            Toast.makeText(TransferRecordActivity.this, "Empty", Toast.LENGTH_SHORT).show();
            ImageNoFound.setVisibility(View.VISIBLE);
            recyclerView.setVisibility(View.GONE);
        } else {
            ImageNoFound.setVisibility(View.GONE);
            recyclerView.setVisibility(View.VISIBLE);

            Collections.sort(transferrecordlist, new Comparator<TransferRecordClass>() {
                @Override
                public int compare(TransferRecordClass t1, TransferRecordClass t2) {
                    return t2.getTimeStamp().compareTo(t1.getTimeStamp());
                }
            });

            mytransferrecordadapter = new TransferRecordAdapter(transferrecordlist, TransferRecordActivity.this, StudentID);
            recyclerView.setAdapter(mytransferrecordadapter);
        }
    }
});

方案2：用OR查询合并为单个请求（代码更简洁，服务端排序） #

首先确保你的Firebase BoM版本不低于32.0.0（支持新版Filter API），实现代码如下：

CollectionReference ref = firebaseFirestore.collection("TransferRecord");
// 组合OR条件：要么是转出人匹配，要么是收入人匹配，同时满足时间范围
Query mergedQuery = ref.where(
        Filter.and(
            Filter.greaterThanOrEqualTo("timeStamp", previousDate),
            Filter.lessThan("timeStamp", currentDate),
            Filter.or(
                Filter.equalTo("fromStudentID", StudentID),
                Filter.equalTo("toStudentID", StudentID)
            )
        )
    ).orderBy("timeStamp", Query.Direction.DESCENDING);

mergedQuery.get().addOnCompleteListener(new OnCompleteListener<QuerySnapshot>() {
    @Override
    public void onComplete(@NonNull Task<QuerySnapshot> task) {
        if (!task.isSuccessful()) {
            // 处理错误，如果报索引缺失错误，按日志提示去控制台创建对应索引即可
            return;
        }
        List<TransferRecordClass> transferrecordlist = new ArrayList<>();
        for (DocumentSnapshot docSnap : task.getResult()) {
            transferrecordlist.add(docSnap.toObject(TransferRecordClass.class));
        }

        if (transferrecordlist.isEmpty()) {
            Toast.makeText(TransferRecordActivity.this, "Empty", Toast.LENGTH_SHORT).show();
            ImageNoFound.setVisibility(View.VISIBLE);
            recyclerView.setVisibility(View.GONE);
        } else {
            ImageNoFound.setVisibility(View.GONE);
            recyclerView.setVisibility(View.VISIBLE);
            // 服务端已经按时间倒序排好，不需要本地再排序
            mytransferrecordadapter = new TransferRecordAdapter(transferrecordlist, TransferRecordActivity.this, StudentID);
            recyclerView.setAdapter(mytransferrecordadapter);
        }
    }
});

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