|
@@ -279,12 +279,13 @@ export class RoomAssistant {
|
|
|
if (user.oid) {
|
|
|
console.log("hasDuplicateUser-存在oid", user.oid);
|
|
|
const hasDuplicateUser = await this.getOpenidInRoom(roomId, user.oid);
|
|
|
- console.log("hasDuplicateUser-1", hasDuplicateUser);
|
|
|
if (hasDuplicateUser && hasDuplicateUser.length > 0) {
|
|
|
- this.room.logger.info("hasDuplicateUser-2", hasDuplicateUser);
|
|
|
+ console.log("hasDuplicateUser-共有用户", hasDuplicateUser.length);
|
|
|
const removeAll = [];
|
|
|
Array.from(hasDuplicateUser).forEach((duplicateUser) => {
|
|
|
- removeAll.push(removeRoomUser(roomId, duplicateUser.userId));
|
|
|
+ const deleteUserKey = `user:duplicateUser.userId`;
|
|
|
+ console.log("deleteUserKey", deleteUserKey);
|
|
|
+ removeAll.push(removeRoomUser(roomId, deleteUserKey));
|
|
|
});
|
|
|
const res = await Promise.all(removeAll);
|
|
|
console.log("去重完成", res);
|