|  |  | 
 |  |  |         if (callId != null) { | 
 |  |  |             // 权限校验 | 
 |  |  |             StreamAuthorityInfo streamAuthorityInfo = redisCatchStorage.getStreamAuthorityInfo(app, stream); | 
 |  |  |             if (streamAuthorityInfo.getCallId().equals(callId)) { | 
 |  |  |             if (streamAuthorityInfo != null | 
 |  |  |                     && streamAuthorityInfo.getCallId() != null | 
 |  |  |                     && streamAuthorityInfo.getCallId().equals(callId)) { | 
 |  |  |                 authority = true; | 
 |  |  |             }else { | 
 |  |  |                 throw new ControllerException(ErrorCode.ERROR400); | 
 |  |  | 
 |  |  |             try { | 
 |  |  |                 Thread.sleep(1000); | 
 |  |  |             } catch (InterruptedException e) { | 
 |  |  |                 e.printStackTrace(); | 
 |  |  |                 logger.error("[线程休眠失败], {}", e.getMessage()); | 
 |  |  |             } | 
 |  |  |             if (useSourceIpAsStreamIp != null && useSourceIpAsStreamIp) { | 
 |  |  |                 String host = request.getHeader("Host"); |