多人音视频

core/src/main/java/com/wecloud/multimeet/service/impl/MultiMeetServiceImpl.java

@@ -103,15 +103,15 @@ public class MultiMeetServiceImpl implements MultiMeetService {
                 continue;
                 continue;
             }
             }
             // 占线 通知邀请方
             // 占线 通知邀请方
-            ImMultiRtcRoomMember busyMember = imMultiRtcRoomMemberService.getOne(new QueryWrapper<ImMultiRtcRoomMember>().lambda()
+            List<ImMultiRtcRoomMember> busyMember = imMultiRtcRoomMemberService.list(new QueryWrapper<ImMultiRtcRoomMember>().lambda()
                     .eq(ImMultiRtcRoomMember::getClientId, toClientId)
                     .eq(ImMultiRtcRoomMember::getClientId, toClientId)
                     .in(ImMultiRtcRoomMember::getState, Lists.newArrayList(MultiRtcMemberStateEnum.ANSWERED.getCode(), MultiRtcMemberStateEnum.CALLING.getCode())));
                     .in(ImMultiRtcRoomMember::getState, Lists.newArrayList(MultiRtcMemberStateEnum.ANSWERED.getCode(), MultiRtcMemberStateEnum.CALLING.getCode())));
-            if (busyMember != null && Lists.newArrayList(MultiRtcMemberStateEnum.ANSWERED.getCode(), MultiRtcMemberStateEnum.CALLING.getCode()).contains(busyMember.getState())) {
+            if (CollectionUtils.isNotEmpty(busyMember)) {
                 MultiMeetBusyResponse multiMeetBusyResponse = new MultiMeetBusyResponse();
                 MultiMeetBusyResponse multiMeetBusyResponse = new MultiMeetBusyResponse();
                 multiMeetBusyResponse.setConversationId(param.getConversationId());
                 multiMeetBusyResponse.setConversationId(param.getConversationId());
                 multiMeetBusyResponse.setRoomId(param.getRoomId());
                 multiMeetBusyResponse.setRoomId(param.getRoomId());
                 multiMeetBusyResponse.setClientId(currentClient.getClientId());
                 multiMeetBusyResponse.setClientId(currentClient.getClientId());
-                multiMeetBusyResponse.setBusyClientId(busyMember.getClientId());
+                multiMeetBusyResponse.setBusyClientId(busyMember.get(0).getClientId());
                 multiMeetBusyResponse.setTimestamp(System.currentTimeMillis());
                 multiMeetBusyResponse.setTimestamp(System.currentTimeMillis());
                 wsMultiMeetWrite.busy(multiMeetBusyResponse, currentClient.getId());
                 wsMultiMeetWrite.busy(multiMeetBusyResponse, currentClient.getId());
                 continue;
                 continue;