update

app/service/users/person_room.js

@@ -23,13 +23,13 @@ class Person_roomService extends CrudService {
     // const notRead = await this.pc.find({ room_id: data.map(i => i._id), is_read: false, receiver_id: p_id });
     console.log(data.map(i => ObjectId(i.id || i._id)));
     const aggQuery = [
-      { $match: { room_id: data.map(i => ObjectId(i.id || i._id)), is_read: false, receiver_id: ObjectId(p_id) } },
-      // {
-      //   $group: {
-      //     _id: '$room_id',
-      //     sum: { $sum: 1 },
-      //   },
-      // },
+      { $match: { is_read: false, receiver_id: ObjectId(p_id) } },
+      {
+        $group: {
+          _id: '$room_id',
+          sum: { $sum: 1 },
+        },
+      },
     ];
     console.log(aggQuery);
     const r = await this.pc.aggregate(aggQuery);