刷新管理员列表

accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/room/RoomService.java

@@ -2230,13 +2230,25 @@ public class RoomService extends BaseService {
                  if (!refreshCache || CollectionUtils.isEmpty(roomMemberRets)){
                      continue;
                  }
+
                  roomUid = room.getUid();
-                 this.roomManageUser(roomUid).delete();
+                 RSet<Long> manageUser = this.roomManageUser(roomUid);
+                 Set<Long> existUids = manageUser.readAll();
+                 manageUser.delete();
                  for (RoomMemberRet roomMemberRet : roomMemberRets) {
                      Long accid = roomMemberRet.getAccid();
                      this.roomManageUser(roomUid).add(accid);
                      this.userManageRoom(accid).add(roomUid);
                  }
+                 if (CollectionUtils.isEmpty(existUids)) {
+                     continue;
+                 }
+                 List<Long> nowAdminUid = roomMemberRets.stream().map(RoomMemberRet::getAccid).collect(Collectors.toList());
+                 for (Long existUid : existUids) {
+                     if (nowAdminUid.contains(existUid)) {
+                         this.userManageRoom(existUid).remove(roomUid);
+                     }
+                 }
              }
          } catch (Exception e) {
              log.info("MyApiService.reloadAdminMember, refreshCache:{}, roomUid:{},e:{}", refreshCache, roomUid, e.getMessage(), e);