| | |
|---|
| | | */
|
|---|
| | | @ResponseBody
|
|---|
| | | @PostMapping(value = "/on_stream_not_found", produces = "application/json;charset=UTF-8")
|
|---|
| | | public DeferredResult<HookResult> onStreamNotFound(@RequestBody OnStreamNotFoundHookParam param) {
|
|---|
| | | public HookResult onStreamNotFound(@RequestBody OnStreamNotFoundHookParam param) {
|
|---|
| | | logger.info("[ZLM HOOK] 流未找到：{}->{}->{}/{}", param.getMediaServerId(), param.getSchema(), param.getApp(), param.getStream());
|
|---|
| | |
|
|---|
| | | DeferredResult<HookResult> defaultResult = new DeferredResult<>();
|
|---|
| | |
|
|---|
| | | MediaServer mediaServer = mediaServerService.getOne(param.getMediaServerId());
|
|---|
| | | if (!userSetting.isAutoApplyPlay() || mediaServer == null) {
|
|---|
| | | defaultResult.setResult(new HookResult(ErrorCode.ERROR404.getCode(), ErrorCode.ERROR404.getMsg()));
|
|---|
| | | return defaultResult;
|
|---|
| | | return HookResult.SUCCESS();
|
|---|
| | | }
|
|---|
| | | MediaNotFoundEvent mediaNotFoundEvent = MediaNotFoundEvent.getInstance(this, param, mediaServer);
|
|---|
| | | applicationEventPublisher.publishEvent(mediaNotFoundEvent);
|
|---|
| | |
|
|---|
| | |
|
|---|
| | |
|
|---|
| | | if ("rtp".equals(param.getApp())) {
|
|---|
| | | String[] s = param.getStream().split("_");
|
|---|
| | | if ((s.length != 2 && s.length != 4)) {
|
|---|
| | | defaultResult.setResult(HookResult.SUCCESS());
|
|---|
| | | return defaultResult;
|
|---|
| | | }
|
|---|
| | | String deviceId = s[0];
|
|---|
| | | String channelId = s[1];
|
|---|
| | | Device device = redisCatchStorage.getDevice(deviceId);
|
|---|
| | | if (device == null || !device.isOnLine()) {
|
|---|
| | | defaultResult.setResult(new HookResult(ErrorCode.ERROR404.getCode(), ErrorCode.ERROR404.getMsg()));
|
|---|
| | | return defaultResult;
|
|---|
| | | }
|
|---|
| | | DeviceChannel deviceChannel = storager.queryChannel(deviceId, channelId);
|
|---|
| | | if (deviceChannel == null) {
|
|---|
| | | defaultResult.setResult(new HookResult(ErrorCode.ERROR404.getCode(), ErrorCode.ERROR404.getMsg()));
|
|---|
| | | return defaultResult;
|
|---|
| | | }
|
|---|
| | | if (s.length == 2) {
|
|---|
| | | logger.info("[ZLM HOOK] 预览流未找到, 发起自动点播：{}->{}->{}/{}", param.getMediaServerId(), param.getSchema(), param.getApp(), param.getStream());
|
|---|
| | |
|
|---|
| | | RequestMessage msg = new RequestMessage();
|
|---|
| | | String key = DeferredResultHolder.CALLBACK_CMD_PLAY + deviceId + channelId;
|
|---|
| | | boolean exist = resultHolder.exist(key, null);
|
|---|
| | | msg.setKey(key);
|
|---|
| | | String uuid = UUID.randomUUID().toString();
|
|---|
| | | msg.setId(uuid);
|
|---|
| | | DeferredResult<HookResult> result = new DeferredResult<>(userSetting.getPlayTimeout().longValue());
|
|---|
| | |
|
|---|
| | | result.onTimeout(() -> {
|
|---|
| | | logger.info("[ZLM HOOK] 预览流自动点播, 等待超时");
|
|---|
| | | msg.setData(new HookResult(ErrorCode.ERROR100.getCode(), "点播超时"));
|
|---|
| | | resultHolder.invokeAllResult(msg);
|
|---|
| | | inviteStreamService.removeInviteInfoByDeviceAndChannel(InviteSessionType.PLAY, deviceId, channelId);
|
|---|
| | | storager.stopPlay(deviceId, channelId);
|
|---|
| | | });
|
|---|
| | |
|
|---|
| | | resultHolder.put(key, uuid, result);
|
|---|
| | |
|
|---|
| | | if (!exist) {
|
|---|
| | | playService.play(mediaServer, deviceId, channelId, null, (code, message, data) -> {
|
|---|
| | | msg.setData(new HookResult(code, message));
|
|---|
| | | resultHolder.invokeResult(msg);
|
|---|
| | | });
|
|---|
| | | }
|
|---|
| | | return result;
|
|---|
| | | } else if (s.length == 4) {
|
|---|
| | | // 此时为录像回放， 录像回放格式为> 设备ID_通道ID_开始时间_结束时间
|
|---|
| | | String startTimeStr = s[2];
|
|---|
| | | String endTimeStr = s[3];
|
|---|
| | | if (startTimeStr == null || endTimeStr == null || startTimeStr.length() != 14 || endTimeStr.length() != 14) {
|
|---|
| | | defaultResult.setResult(HookResult.SUCCESS());
|
|---|
| | | return defaultResult;
|
|---|
| | | }
|
|---|
| | | String startTime = DateUtil.urlToyyyy_MM_dd_HH_mm_ss(startTimeStr);
|
|---|
| | | String endTime = DateUtil.urlToyyyy_MM_dd_HH_mm_ss(endTimeStr);
|
|---|
| | | logger.info("[ZLM HOOK] 回放流未找到, 发起自动点播：{}->{}->{}/{}-{}-{}",
|
|---|
| | | param.getMediaServerId(), param.getSchema(),
|
|---|
| | | param.getApp(), param.getStream(),
|
|---|
| | | startTime, endTime
|
|---|
| | | );
|
|---|
| | | RequestMessage msg = new RequestMessage();
|
|---|
| | | String key = DeferredResultHolder.CALLBACK_CMD_PLAYBACK + deviceId + channelId;
|
|---|
| | | boolean exist = resultHolder.exist(key, null);
|
|---|
| | | msg.setKey(key);
|
|---|
| | | String uuid = UUID.randomUUID().toString();
|
|---|
| | | msg.setId(uuid);
|
|---|
| | | DeferredResult<HookResult> result = new DeferredResult<>(userSetting.getPlayTimeout().longValue());
|
|---|
| | |
|
|---|
| | | result.onTimeout(() -> {
|
|---|
| | | logger.info("[ZLM HOOK] 回放流自动点播, 等待超时");
|
|---|
| | | // 释放rtpserver
|
|---|
| | | msg.setData(new HookResult(ErrorCode.ERROR100.getCode(), "点播超时"));
|
|---|
| | | resultHolder.invokeResult(msg);
|
|---|
| | | });
|
|---|
| | |
|
|---|
| | | resultHolder.put(key, uuid, result);
|
|---|
| | |
|
|---|
| | | if (!exist) {
|
|---|
| | | SSRCInfo ssrcInfo = mediaServerService.openRTPServer(mediaServer, param.getStream(), null,
|
|---|
| | | device.isSsrcCheck(), true, 0, false, false, device.getStreamModeForParam());
|
|---|
| | | playService.playBack(mediaServer, ssrcInfo, deviceId, channelId, startTime, endTime, (code, message, data) -> {
|
|---|
| | | msg.setData(new HookResult(code, message));
|
|---|
| | | resultHolder.invokeResult(msg);
|
|---|
| | | });
|
|---|
| | | }
|
|---|
| | | return result;
|
|---|
| | | } else {
|
|---|
| | | defaultResult.setResult(HookResult.SUCCESS());
|
|---|
| | | return defaultResult;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | } else {
|
|---|
| | | // 拉流代理
|
|---|
| | | StreamProxyItem streamProxyByAppAndStream = streamProxyService.getStreamProxyByAppAndStream(param.getApp(), param.getStream());
|
|---|
| | | if (streamProxyByAppAndStream != null && streamProxyByAppAndStream.isEnableDisableNoneReader()) {
|
|---|
| | | streamProxyService.start(param.getApp(), param.getStream());
|
|---|
| | | }
|
|---|
| | | DeferredResult<HookResult> result = new DeferredResult<>();
|
|---|
| | | result.setResult(HookResult.SUCCESS());
|
|---|
| | | return result;
|
|---|
| | | }
|
|---|
| | | return HookResult.SUCCESS();
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | /**
|
|---|
