Firestore嵌套回调实时监听首次调用无Books数据问题

我来帮你把三个Firestore实时监听封装成独立类，通过嵌套回调实现依次执行，同时覆盖你提到的所有业务场景。首先先补全你未写完的FirebaseGetBooks类，再展示完整的联动调用逻辑。

1. 补全FirebaseGetBooks监听类 #

这个类和另外两个类保持一致的结构，负责监听当前Admin下的Books集合：

public class FirebaseGetBooks {
    private static final String TAG = "FirebaseGetBooks";
    private FirebaseFirestore mDbase;
    private Activity activity;
    private String adminID;

    public FirebaseGetBooks() {}

    public FirebaseGetBooks(Activity activity) {
        this.activity = activity;
        mDbase = FirebaseFirestore.getInstance();
        // 获取当前登录Admin的ID
        FirebaseAuth mAuth = FirebaseAuth.getInstance();
        if (mAuth.getCurrentUser() != null) {
            adminID = mAuth.getUid();
        }
    }

    public interface FirestoreCallback {
        void onCallback(List<Book> books);
    }

    public void readDataRTUpdate(final FirestoreCallback firestoreCallback) {
        if (adminID == null) {
            Log.w(TAG, "Admin ID为空，无法监听Books集合");
            firestoreCallback.onCallback(new ArrayList<>());
            return;
        }

        mDbase.collection("admins").document(adminID).collection("books")
                .addSnapshotListener(activity, new EventListener<QuerySnapshot>() {
                    @Override
                    public void onEvent(@Nullable QuerySnapshot value, @Nullable FirebaseFirestoreException e) {
                        if (e != null) {
                            Log.w(TAG, "Books监听失败", e);
                            firestoreCallback.onCallback(new ArrayList<>());
                            return;
                        }

                        List<Book> books = new ArrayList<>();
                        if (value != null && !value.isEmpty()) {
                            for (QueryDocumentSnapshot document : value) {
                                Book book = document.toObject(Book.class);
                                books.add(book);
                                Log.d(TAG, "获取到书籍：" + book.toString());
                            }
                        } else {
                            Log.d(TAG, "未找到书籍或Books集合为空");
                        }
                        // 无论是否有数据，都返回列表（空列表或实际数据）
                        firestoreCallback.onCallback(books);
                    }
                });
    }
}

2. 在Activity中实现嵌套回调联动 #

在你的业务Activity里，我们通过嵌套回调依次触发三个监听，确保数据加载顺序，同时处理实时更新的场景：

public class MainActivity extends AppCompatActivity {
    private static final String TAG = "MainActivity";

    private FirebaseGetThisAdmin firebaseGetThisAdmin;
    private FirebaseGetUsers firebaseGetUsers;
    private FirebaseGetBooks firebaseGetBooks;

    // 保存实时更新的全局数据
    private Admin currentAdmin;
    private List<User> currentUsers = new ArrayList<>();
    private List<Book> currentBooks = new ArrayList<>();

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        // 初始化三个Firebase操作类
        firebaseGetThisAdmin = new FirebaseGetThisAdmin(this);
        firebaseGetUsers = new FirebaseGetUsers(this);
        firebaseGetBooks = new FirebaseGetBooks(this);

        // 启动第一个监听：先获取Admin数据
        startAdminListener();
    }

    private void startAdminListener() {
        firebaseGetThisAdmin.readDataRTUpdate(new FirebaseGetThisAdmin.FirestoreCallback() {
            @Override
            public void onCallback(Admin admin) {
                if (admin == null) {
                    Log.w(TAG, "Admin数据为空");
                    return;
                }
                currentAdmin = admin;
                Log.d(TAG, "Admin数据更新：" + admin.getUsername());

                // Admin数据就绪后，启动Users监听
                startUsersListener();
            }
        });
    }

    private void startUsersListener() {
        firebaseGetUsers.readDataRTUpdate(new FirebaseGetUsers.FirestoreCallback() {
            @Override
            public void onCallback(List<User> users) {
                currentUsers.clear();
                if (users != null) {
                    currentUsers.addAll(users);
                }
                Log.d(TAG, "Users数据更新：共" + currentUsers.size() + "个用户");

                // Users数据就绪后，启动Books监听
                startBooksListener();
            }
        });
    }

    private void startBooksListener() {
        firebaseGetBooks.readDataRTUpdate(new FirebaseGetBooks.FirestoreCallback() {
            @Override
            public void onCallback(List<Book> books) {
                currentBooks.clear();
                if (books != null) {
                    currentBooks.addAll(books);
                }
                Log.d(TAG, "Books数据更新：共" + currentBooks.size() + "本书籍");

                // 所有数据就绪，在这里处理最终业务逻辑
                handleBusinessLogic();
            }
        });
    }

    /**
     * 处理最终业务逻辑，比如更新UI、数据校验等
     */
    private void handleBusinessLogic() {
        if (currentAdmin == null) {
            Toast.makeText(this, "未找到Admin信息", Toast.LENGTH_SHORT).show();
            return;
        }

        // 适配你提到的所有场景：
        // 场景1：初始触发时，Admin存在，Users和Books会逐步更新到这里
        // 场景2：新增条目无Books时，currentBooks是空列表，可在这里做判断处理
        // 场景3：重启应用有数据时，三个数据都会正常传入
        // 场景4：新增用户/书籍时，对应监听触发，最终在这里刷新数据

        // 示例：更新UI显示数据状态
        String statusText = String.format("当前Admin：%s\n用户数量：%d\n书籍数量：%d",
                currentAdmin.getUsername(), currentUsers.size(), currentBooks.size());
        ((TextView) findViewById(R.id.tv_data_status)).setText(statusText);

        // 这里可以根据需求做列表展示、数据持久化等其他业务操作
    }
}

3. 场景适配说明 #

针对你列出的四个场景，这个实现都能完美覆盖：

• 场景1：初始触发时，Admin已存在，startAdminListener先获取到Admin数据，接着自动启动Users监听，最后启动Books监听，最终在handleBusinessLogic中拿到所有数据。
• 场景2：数据库无数据时新增条目（比如只新增User），此时Books集合为空，startBooksListener的回调会返回空列表，你可以在handleBusinessLogic中通过currentBooks.isEmpty()判断并处理这种情况。
• 场景3：重启应用后，Firestore快照监听会立即返回本地缓存或服务器的已有数据，三个监听依次触发，最终正常返回所有数据。
• 场景4：后续新增用户/书籍时，对应的集合监听会实时触发回调，比如新增User时，startUsersListener的回调会更新currentUsers，然后自动触发startBooksListener，最终在handleBusinessLogic中刷新数据，实现实时更新。

注意事项 #

• 确保Admin、User、Book实体类有默认无参构造函数，并且字段名和Firestore中的字段名一致（或者使用@PropertyName注解做映射），否则toObject()方法无法正确解析数据。
• 监听通过addSnapshotListener(activity, ...)和Activity生命周期绑定，避免内存泄漏。
• 监听回调默认在主线程触发，所以handleBusinessLogic中可以直接操作UI。

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