|  |  |  | 
|---|
|  |  |  | 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"); | 
|---|