| | |
|---|
| | | @PostMapping(value = "/on_server_keepalive", produces = "application/json;charset=UTF-8")
|
|---|
| | | public HookResult onServerKeepalive(@RequestBody OnServerKeepaliveHookParam param) {
|
|---|
| | |
|
|---|
| | | logger.info("[ZLM HOOK] 收到zlm心跳：" + param.getMediaServerId());
|
|---|
| | | // logger.info("[ZLM HOOK] 收到zlm心跳：" + param.getMediaServerId());
|
|---|
| | |
|
|---|
| | | taskExecutor.execute(() -> {
|
|---|
| | | List<ZlmHttpHookSubscribe.Event> subscribes = this.subscribe.getSubscribes(HookType.on_server_keepalive);
|
|---|
| | |
|---|
| | | List<SendRtpItem> sendRtpItems = redisCatchStorage.querySendRTPServerByStream(param.getStream());
|
|---|
| | | if (sendRtpItems.size() > 0) {
|
|---|
| | | for (SendRtpItem sendRtpItem : sendRtpItems) {
|
|---|
| | | if (sendRtpItem.getApp().equals(param.getApp())) {
|
|---|
| | | if (sendRtpItem != null && sendRtpItem.getApp().equals(param.getApp())) {
|
|---|
| | | String platformId = sendRtpItem.getPlatformId();
|
|---|
| | | ParentPlatform platform = storager.queryParentPlatByServerGBId(platformId);
|
|---|
| | | Device device = deviceService.getDevice(platformId);
|
|---|
