忙线逻辑调整

core/src/main/java/com/wecloud/rtc/service/impl/RtcServiceImpl.java

@@ -105,7 +105,9 @@ public class RtcServiceImpl extends UserStateListener implements RtcService {
         ImRtcRecord imRtcRecord = imRtcRecordService.getOne(new LambdaQueryWrapper<ImRtcRecord>()
         ImRtcRecord imRtcRecord = imRtcRecordService.getOne(new LambdaQueryWrapper<ImRtcRecord>()
                 .eq(ImRtcRecord::getFkAppid, currentClient.getFkAppid())
                 .eq(ImRtcRecord::getFkAppid, currentClient.getFkAppid())
                 .in(ImRtcRecord::getState, Lists.newArrayList(RtcStateEnum.CREATED.getCode(), RtcStateEnum.ING.getCode()))
                 .in(ImRtcRecord::getState, Lists.newArrayList(RtcStateEnum.CREATED.getCode(), RtcStateEnum.ING.getCode()))
-                .eq(ImRtcRecord::getToClientId, toClient.getClientId())
+                .and(o -> o.eq(ImRtcRecord::getToClientId, toClient.getClientId())
+                        .or()
+                        .eq(ImRtcRecord::getFromClientId, toClient.getClientId()))
         );
         );
         if (imRtcRecord != null) {
         if (imRtcRecord != null) {
             throw new BusinessException("对方忙线中");
             throw new BusinessException("对方忙线中");