侦听集合中的多个文档并更新RecycerView

Question

我不知道如何监听Firestore db中的更改和更新RecycerView中的项。

其中包括聊天模型、RecycerView活动和适配器。

public class Chat {
    private String sender;
    private String receiver;
    private String message;
    private boolean isseen;
    public Date sent_timestamp;

    public Chat(String sender, String receiver, String message, boolean isseen, Date sent_timestamp) {
        this.sender = sender;
        this.receiver = receiver;
        this.message = message;
        this.isseen = isseen;
        this.sent_timestamp = sent_timestamp;

private void seenMessage(final String userid) {
        Query query = mFirebaseFirestore.collection("Chats");
        query.addSnapshotListener(this, new EventListener<QuerySnapshot>() {
            @Override
            public void onEvent(@Nullable QuerySnapshot queryDocumentSnapshots, @Nullable FirebaseFirestoreException e) {
                for (DocumentChange doc : queryDocumentSnapshots.getDocumentChanges()) {
                    if (doc.getType() == DocumentChange.Type.ADDED) {
                        QueryDocumentSnapshot docEvent = doc.getDocument();
                        Chat chat = doc.getDocument().toObject(Chat.class);
                        if (chat.getReceiver().equals(fuser.getUid()) && chat.getSender().equals(userid)) {
                            HashMap<String, Object> hashMap = new HashMap<>();
                            hashMap.put("isseen", true);
                            doc.getDocument().getReference().update(hashMap);
                        }
                    }
                }
            }
        });

private void readMessages(final String myid, final String userid, final String imageurl) {
        mchat = new ArrayList<>();
        messageAdapter = new MessageAdapter(MessageActivity.this, mchat, imageurl);
        recyclerView.setAdapter(messageAdapter);
        Query query = mFirebaseFirestore.collection("Chats").orderBy("sent_timestamp", Query.Direction.ASCENDING);
        query.addSnapshotListener(this, new EventListener<QuerySnapshot>() {
            @Override
            public void onEvent(@Nullable QuerySnapshot queryDocumentSnapshots, @Nullable FirebaseFirestoreException e) {
                for (DocumentChange doc : queryDocumentSnapshots.getDocumentChanges()) {
                    if (doc.getType() == DocumentChange.Type.ADDED) {
                        QueryDocumentSnapshot docEvent = doc.getDocument();
                        Chat chat = doc.getDocument().toObject(Chat.class);
                        if (chat.getReceiver().equals(myid) && chat.getSender().equals(userid) ||
                                chat.getReceiver().equals(userid) && chat.getSender().equals(myid)) {
                            mchat.add(chat);
                        }
                    }
                    messageAdapter.notifyDataSetChanged();
                }
            }
        });
    }


@Override
public void onBindViewHolder(@NonNull MessageAdapter.ViewHolder holder, int position) {

        Chat chat = mChat.get(position);
        if (position == mChat.size() - 1) {
            if (chat.isIsseen()) {
                holder.txt_seen.setText("Seen");
            } else {
                holder.txt_seen.setText("Delivered");
            }
        } else {
            holder.txt_seen.setVisibility(View.GONE);
        }

一旦值“isseen”更改为“true”，它就应该显示在发件人的电话上。

Answer 1

尝试下面的查询

Query query = mFirebaseFirestore.collection("Chats").whereEqualTo("isseen", true);

它将给出isseen=true的所有消息列表，以及任何“isseen”实时变为true的时间。