|  |  | 
 |  |  | import com.genersoft.iot.vmp.media.zlm.dto.StreamProxyItem;
 | 
 |  |  | import com.genersoft.iot.vmp.media.zlm.dto.hook.*;
 | 
 |  |  | import com.genersoft.iot.vmp.service.*;
 | 
 |  |  | import com.genersoft.iot.vmp.service.bean.MessageForPushChannel;
 | 
 |  |  | import com.genersoft.iot.vmp.storager.IRedisCatchStorage;
 | 
 |  |  | import com.genersoft.iot.vmp.storager.IVideoManagerStorage;
 | 
 |  |  | import com.genersoft.iot.vmp.vmanager.bean.ErrorCode;
 | 
 |  |  | 
 |  |  |     @PostMapping(value = "/on_server_keepalive", produces = "application/json;charset=UTF-8")
 | 
 |  |  |     public HookResult onServerKeepalive(@RequestBody OnServerKeepaliveHookParam param) {
 | 
 |  |  | 
 | 
 |  |  | //        logger.info("[ZLM HOOK] 收到zlm心跳:" + param.getMediaServerId());
 | 
 |  |  | 
 | 
 |  |  |         taskExecutor.execute(() -> {
 | 
 |  |  |             List<ZlmHttpHookSubscribe.Event> subscribes = this.subscribe.getSubscribes(HookType.on_server_keepalive);
 | 
 |  |  |             JSONObject json = (JSONObject) JSON.toJSON(param);
 | 
 |  |  |             if (subscribes != null && subscribes.size() > 0) {
 | 
 |  |  |                 for (ZlmHttpHookSubscribe.Event subscribe : subscribes) {
 | 
 |  |  |                     subscribe.response(null, json);
 | 
 |  |  |                     subscribe.response(null, param);
 | 
 |  |  |                 }
 | 
 |  |  |             }
 | 
 |  |  |         });
 | 
 |  |  | 
 |  |  |             if (subscribe != null) {
 | 
 |  |  |                 MediaServerItem mediaInfo = mediaServerService.getOne(mediaServerId);
 | 
 |  |  |                 if (mediaInfo != null) {
 | 
 |  |  |                     subscribe.response(mediaInfo, json);
 | 
 |  |  |                     subscribe.response(mediaInfo, param);
 | 
 |  |  |                 }
 | 
 |  |  |             }
 | 
 |  |  |         });
 | 
 |  |  | 
 |  |  |             if (userSetting.getPushAuthority()) {
 | 
 |  |  |                 // 推流鉴权
 | 
 |  |  |                 if (param.getParams() == null) {
 | 
 |  |  |                     logger.info("推流鉴权失败: 缺少不要参数:sign=md5(user表的pushKey)");
 | 
 |  |  |                     logger.info("推流鉴权失败: 缺少必要参数:sign=md5(user表的pushKey)");
 | 
 |  |  |                     return new HookResultForOnPublish(401, "Unauthorized");
 | 
 |  |  |                 }
 | 
 |  |  |                 Map<String, String> paramMap = urlParamToMap(param.getParams());
 | 
 |  |  |                 String sign = paramMap.get("sign");
 | 
 |  |  |                 if (sign == null) {
 | 
 |  |  |                     logger.info("推流鉴权失败: 缺少不要参数:sign=md5(user表的pushKey)");
 | 
 |  |  |                     logger.info("推流鉴权失败: 缺少必要参数:sign=md5(user表的pushKey)");
 | 
 |  |  |                     return new HookResultForOnPublish(401, "Unauthorized");
 | 
 |  |  |                 }
 | 
 |  |  |                 // 推流自定义播放鉴权码
 | 
 |  |  | 
 |  |  |             ZlmHttpHookSubscribe.Event subscribe = this.subscribe.sendNotify(HookType.on_publish, json);
 | 
 |  |  |             if (subscribe != null) {
 | 
 |  |  |                 if (mediaInfo != null) {
 | 
 |  |  |                     subscribe.response(mediaInfo, json);
 | 
 |  |  |                     subscribe.response(mediaInfo, param);
 | 
 |  |  |                 } else {
 | 
 |  |  |                     new HookResultForOnPublish(1, "zlm not register");
 | 
 |  |  |                 }
 | 
 |  |  | 
 |  |  |                 return;
 | 
 |  |  |             }
 | 
 |  |  |             if (subscribe != null) {
 | 
 |  |  |                 subscribe.response(mediaInfo, json);
 | 
 |  |  |                 subscribe.response(mediaInfo, param);
 | 
 |  |  |             }
 | 
 |  |  | 
 | 
 |  |  |             List<OnStreamChangedHookParam.MediaTrack> tracks = param.getTracks();
 | 
 |  |  | 
 |  |  |                         }
 | 
 |  |  |                         GbStream gbStream = storager.getGbStream(param.getApp(), param.getStream());
 | 
 |  |  |                         if (gbStream != null) {
 | 
 |  |  |                             eventPublisher.catalogEventPublishForStream(null, gbStream, param.isRegist()?CatalogEvent.ON:CatalogEvent.OFF);
 | 
 |  |  |                             if (userSetting.isUsePushingAsStatus()) {
 | 
 |  |  |                                 eventPublisher.catalogEventPublishForStream(null, gbStream, param.isRegist()?CatalogEvent.ON:CatalogEvent.OFF);
 | 
 |  |  |                             }
 | 
 |  |  |                         }
 | 
 |  |  |                         if (type != null) {
 | 
 |  |  |                             // 发送流变化redis消息
 | 
 |  |  | 
 |  |  |     @PostMapping(value = "/on_stream_none_reader", produces = "application/json;charset=UTF-8")
 | 
 |  |  |     public JSONObject onStreamNoneReader(@RequestBody OnStreamNoneReaderHookParam param) {
 | 
 |  |  | 
 | 
 |  |  |         logger.info("[ZLM HOOK]流无人观看:{]->{}->{}/{}" + param.getMediaServerId(), param.getSchema(),
 | 
 |  |  |         logger.info("[ZLM HOOK]流无人观看:{}->{}->{}/{}",  param.getMediaServerId(), param.getSchema(),
 | 
 |  |  |                 param.getApp(), param.getStream());
 | 
 |  |  |         JSONObject ret = new JSONObject();
 | 
 |  |  |         ret.put("code", 0);
 | 
 |  |  | 
 |  |  |         if ("rtp".equals(param.getApp())) {
 | 
 |  |  |             ret.put("close", userSetting.getStreamOnDemand());
 | 
 |  |  |             // 国标流, 点播/录像回放/录像下载
 | 
 |  |  | //            StreamInfo streamInfoForPlayCatch = redisCatchStorage.queryPlayByStreamId(param.getStream());
 | 
 |  |  | 
 | 
 |  |  |             InviteInfo inviteInfo = inviteStreamService.getInviteInfoByStream(null, param.getStream());
 | 
 |  |  |             // 点播
 | 
 |  |  |             if (inviteInfo != null) {
 | 
 |  |  | 
 |  |  |                             }
 | 
 |  |  |                             redisCatchStorage.deleteSendRTPServer(parentPlatform.getServerGBId(), sendRtpItem.getChannelId(),
 | 
 |  |  |                                     sendRtpItem.getCallId(), sendRtpItem.getStreamId());
 | 
 |  |  |                             if (InviteStreamType.PUSH == sendRtpItem.getPlayType()) {
 | 
 |  |  |                                 MessageForPushChannel messageForPushChannel = MessageForPushChannel.getInstance(0,
 | 
 |  |  |                                         sendRtpItem.getApp(), sendRtpItem.getStreamId(), sendRtpItem.getChannelId(),
 | 
 |  |  |                                         sendRtpItem.getPlatformId(), parentPlatform.getName(), userSetting.getServerId(), sendRtpItem.getMediaServerId());
 | 
 |  |  |                                 messageForPushChannel.setPlatFormIndex(parentPlatform.getId());
 | 
 |  |  |                                 redisCatchStorage.sendPlatformStopPlayMsg(messageForPushChannel);
 | 
 |  |  |                             }
 | 
 |  |  |                         }
 | 
 |  |  |                     }
 | 
 |  |  |                 }
 | 
 |  |  |                 Device device = deviceService.getDevice(inviteInfo.getDeviceId());
 | 
 |  |  |                 if (device != null) {
 | 
 |  |  |                     try {
 | 
 |  |  |                         if (inviteStreamService.getInviteInfo(inviteInfo.getType(), inviteInfo.getDeviceId(), inviteInfo.getChannelId(), inviteInfo.getStream()) != null) {
 | 
 |  |  |                         InviteInfo info = inviteStreamService.getInviteInfo(inviteInfo.getType(),
 | 
 |  |  |                                 inviteInfo.getDeviceId(), inviteInfo.getChannelId(), inviteInfo.getStream());
 | 
 |  |  |                         if (info != null) {
 | 
 |  |  |                             cmder.streamByeCmd(device, inviteInfo.getChannelId(),
 | 
 |  |  |                                     inviteInfo.getStream(), null);
 | 
 |  |  |                         }
 | 
 |  |  | 
 |  |  |             // 拉流代理
 | 
 |  |  |             StreamProxyItem streamProxyItem = streamProxyService.getStreamProxyByAppAndStream(param.getApp(), param.getStream());
 | 
 |  |  |             if (streamProxyItem != null) {
 | 
 |  |  |                 if (streamProxyItem.isEnable_remove_none_reader()) {
 | 
 |  |  |                 if (streamProxyItem.isEnableRemoveNoneReader()) {
 | 
 |  |  |                     // 无人观看自动移除
 | 
 |  |  |                     ret.put("close", true);
 | 
 |  |  |                     streamProxyService.del(param.getApp(), param.getStream());
 | 
 |  |  |                     String url = streamProxyItem.getUrl() != null ? streamProxyItem.getUrl() : streamProxyItem.getSrc_url();
 | 
 |  |  |                     String url = streamProxyItem.getUrl() != null ? streamProxyItem.getUrl() : streamProxyItem.getSrcUrl();
 | 
 |  |  |                     logger.info("[{}/{}]<-[{}] 拉流代理无人观看已经移除", param.getApp(), param.getStream(), url);
 | 
 |  |  |                 } else if (streamProxyItem.isEnable_disable_none_reader()) {
 | 
 |  |  |                 } else if (streamProxyItem.isEnableDisableNoneReader()) {
 | 
 |  |  |                     // 无人观看停用
 | 
 |  |  |                     ret.put("close", true);
 | 
 |  |  |                     // 修改数据
 | 
 |  |  | 
 |  |  |                 }
 | 
 |  |  |                 return ret;
 | 
 |  |  |             }
 | 
 |  |  |             // 推流具有主动性,暂时不做处理
 | 
 |  |  |             // TODO 推流具有主动性,暂时不做处理
 | 
 |  |  | //         StreamPushItem streamPushItem = streamPushService.getPush(app, streamId);
 | 
 |  |  | //         if (streamPushItem != null) {
 | 
 |  |  | //            // TODO 发送停止
 | 
 |  |  | 
 |  |  |             resultHolder.put(key, uuid, result);
 | 
 |  |  | 
 | 
 |  |  |             if (!exist) {
 | 
 |  |  |                 playService.play(mediaInfo, deviceId, channelId, (code, message, data) -> {
 | 
 |  |  |                 playService.play(mediaInfo, deviceId, channelId, null, (code, message, data) -> {
 | 
 |  |  |                     msg.setData(new HookResult(code, message));
 | 
 |  |  |                     resultHolder.invokeResult(msg);
 | 
 |  |  |                 });
 | 
 |  |  | 
 |  |  |         } else {
 | 
 |  |  |             // 拉流代理
 | 
 |  |  |             StreamProxyItem streamProxyByAppAndStream = streamProxyService.getStreamProxyByAppAndStream(param.getApp(), param.getStream());
 | 
 |  |  |             if (streamProxyByAppAndStream != null && streamProxyByAppAndStream.isEnable_disable_none_reader()) {
 | 
 |  |  |             if (streamProxyByAppAndStream != null && streamProxyByAppAndStream.isEnableDisableNoneReader()) {
 | 
 |  |  |                 streamProxyService.start(param.getApp(), param.getStream());
 | 
 |  |  |             }
 | 
 |  |  |             DeferredResult<HookResult> result = new DeferredResult<>();
 | 
 |  |  | 
 |  |  |             List<ZlmHttpHookSubscribe.Event> subscribes = this.subscribe.getSubscribes(HookType.on_server_started);
 | 
 |  |  |             if (subscribes != null && subscribes.size() > 0) {
 | 
 |  |  |                 for (ZlmHttpHookSubscribe.Event subscribe : subscribes) {
 | 
 |  |  |                     subscribe.response(null, jsonObject);
 | 
 |  |  |                     subscribe.response(null, zlmServerConfig);
 | 
 |  |  |                 }
 | 
 |  |  |             }
 | 
 |  |  |             mediaServerService.zlmServerOnline(zlmServerConfig);
 | 
 |  |  | 
 |  |  |             List<ZlmHttpHookSubscribe.Event> subscribes = this.subscribe.getSubscribes(HookType.on_rtp_server_timeout);
 | 
 |  |  |             if (subscribes != null && subscribes.size() > 0) {
 | 
 |  |  |                 for (ZlmHttpHookSubscribe.Event subscribe : subscribes) {
 | 
 |  |  |                     subscribe.response(null, json);
 | 
 |  |  |                     subscribe.response(null, param);
 | 
 |  |  |                 }
 | 
 |  |  |             }
 | 
 |  |  |         });
 |