Firestore结合OR组合查询实现分页时数据重复问题排查

你的分页失效和continueWith()方法没有任何关系，完全是代码逻辑错误导致的，核心问题有3个：

• 排序规则不一致：第一页查询用Date字段倒序（DESCENDING），加载下一页时漏写了倒序参数，默认用升序查询，startAfter游标依赖的排序规则不匹配，游标直接失效。
• 任务列表传参错误：你专门构建了存下一页查询的nextTasks列表，实际调用Tasks.whenAllSuccess()时传入的还是第一页的旧tasks列表，每次触发加载都在重复请求第一页数据。
• 游标维护逻辑错误：你用单个全局lastVisible变量存所有用户查询的分页锚点，但每个子查询是按不同用户过滤的，拿A用户查询返回的文档当B用户查询的游标，分页位置完全错乱。

正确实现逻辑 #

1. 放弃单个全局游标，为每个关注的用户单独维护自己的分页锚点，每个子查询独立做分页。
2. 所有分页请求的查询条件、排序规则必须完全一致，仅游标和limit参数随分页变化。
3. 拿到所有子查询返回的结果后，在内存中按发布时间重新全局排序，避免列表时序混乱。
4. 只有当所有子查询都返回空结果时，才标记列表已经加载到末尾，不要单条子查询无数据就判定到底。

核心修正代码如下：

// 存储每个用户对应的分页游标，key为用户id，value为该用户当前查询到的最后一条文档
HashMap<String, DocumentSnapshot> userPageCursors = new HashMap<>();
boolean isLastPage = false;
boolean isUserScrolling = false;

// 加载第一页
private void loadFirstPagePosts() {
    ArrayList<Task<QuerySnapshot>> firstPageTasks = new ArrayList<>();
    for (String followUserId : following) {
        Query postQuery = postRef
                .whereEqualTo("publisher", followUserId)
                .orderBy("Date", Query.Direction.DESCENDING)
                .limit(1);
        firstPageTasks.add(postQuery.get());
    }

    Tasks.whenAllSuccess(firstPageTasks).addOnSuccessListener(taskResults -> {
        PostsDataHolder.clear();
        List<PostModel> firstPagePosts = new ArrayList<>();
        for (int i = 0; i < taskResults.size(); i++) {
            QuerySnapshot userPostSnap = (QuerySnapshot) taskResults.get(i);
            String currentUserId = following.get(i);
            if (!userPostSnap.isEmpty()) {
                // 更新对应用户的分页游标
                userPageCursors.put(currentUserId, userPostSnap.getDocuments().get(userPostSnap.size() - 1));
                for (QueryDocumentSnapshot doc : userPostSnap) {
                    firstPagePosts.add(doc.toObject(PostModel.class));
                }
            } else {
                // 该用户没有可加载的帖子，标记游标为空
                userPageCursors.put(currentUserId, null);
            }
        }
        // 所有帖子按时间倒序重排
        firstPagePosts.sort((post1, post2) -> Long.compare(post2.getDate(), post1.getDate()));
        PostsDataHolder.addAll(firstPagePosts);

        progressBar.setVisibility(View.GONE);
        recyclerView.setVisibility(View.VISIBLE);
        buildRecyclerView();
    });
}

// 滚动到底部时加载下一页
private void loadNextPagePosts() {
    ArrayList<Task<QuerySnapshot>> nextPageTasks = new ArrayList<>();
    // 同步维护任务和用户id的映射，避免后续匹配游标出错
    HashMap<Task<QuerySnapshot>, String> taskUserMap = new HashMap<>();
    for (String followUserId : following) {
        DocumentSnapshot cursor = userPageCursors.get(followUserId);
        // 该用户已经没有更多帖子，跳过
        if (cursor == null) continue;
        Query postQuery = postRef
                .whereEqualTo("publisher", followUserId)
                .orderBy("Date", Query.Direction.DESCENDING)
                .startAfter(cursor)
                .limit(1);
        Task<QuerySnapshot> task = postQuery.get();
        nextPageTasks.add(task);
        taskUserMap.put(task, followUserId);
    }

    // 所有用户都没有更多数据，标记到列表末尾
    if (nextPageTasks.isEmpty()) {
        isLastPage = true;
        return;
    }

    Tasks.whenAllSuccess(nextPageTasks).addOnSuccessListener(taskResults -> {
        List<PostModel> newPosts = new ArrayList<>();
        boolean allQueryEmpty = true;
        for (Object result : taskResults) {
            QuerySnapshot userPostSnap = (QuerySnapshot) result;
            // 匹配当前结果对应的用户id
            String currentUserId = taskUserMap.get(userPostSnap.getTask());
            if (!userPostSnap.isEmpty()) {
                allQueryEmpty = false;
                // 更新该用户的游标
                userPageCursors.put(currentUserId, userPostSnap.getDocuments().get(userPostSnap.size() - 1));
                for (QueryDocumentSnapshot doc : userPostSnap) {
                    newPosts.add(doc.toObject(PostModel.class));
                }
            } else {
                // 该用户没有更多数据了
                userPageCursors.put(currentUserId, null);
            }
        }
        isLastPage = allQueryEmpty;
        // 新数据排序后插入列表
        newPosts.sort((post1, post2) -> Long.compare(post2.getDate(), post1.getDate()));
        int insertStartPos = PostsDataHolder.size();
        PostsDataHolder.addAll(newPosts);
        adapter.notifyItemRangeInserted(insertStartPos, newPosts.size());
        isUserScrolling = false;
    });
}

// 滚动监听器里触发加载的逻辑直接调用loadNextPagePosts()即可

补充说明 #

continueWith()是Task框架提供的链式任务串联方法，适合处理「前一个任务的结果是后一个任务的输入」的串行任务场景，你当前的并行批量查询场景用Tasks.whenAllSuccess()已经完全满足需求，不需要额外添加continueWith()逻辑。

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