From 9e397ba9f6a967e147d7c994a0ab82c8fc58e9be Mon Sep 17 00:00:00 2001
From: 648540858 <648540858@qq.com>
Date: 星期二, 19 七月 2022 17:46:16 +0800
Subject: [PATCH] 移除共享所有直播流功能

---
 src/main/java/com/genersoft/iot/vmp/media/zlm/ZLMMediaListManager.java |   28 +---------------------------
 1 files changed, 1 insertions(+), 27 deletions(-)

diff --git a/src/main/java/com/genersoft/iot/vmp/media/zlm/ZLMMediaListManager.java b/src/main/java/com/genersoft/iot/vmp/media/zlm/ZLMMediaListManager.java
index 693dda1..3d9b7cb 100644
--- a/src/main/java/com/genersoft/iot/vmp/media/zlm/ZLMMediaListManager.java
+++ b/src/main/java/com/genersoft/iot/vmp/media/zlm/ZLMMediaListManager.java
@@ -116,6 +116,7 @@
         // 鏌ユ壘姝ょ洿鎾祦鏄惁瀛樺湪redis棰勮gbId
         StreamPushItem transform = streamPushService.transform(mediaItem);
         StreamPushItem pushInDb = streamPushService.getPush(mediaItem.getApp(), mediaItem.getStream());
+        transform.setPushIng(true);
         transform.setUpdateTime(DateUtil.getNow());
         transform.setPushTime(DateUtil.getNow());
         if (pushInDb == null) {
@@ -123,34 +124,7 @@
             streamPushMapper.add(transform);
         }else {
             streamPushMapper.update(transform);
-
-
-//            if (!StringUtils.isEmpty(pushInDb.getGbId())) {
-//                List<GbStream> gbStreamList = gbStreamMapper.selectByGBId(transform.getGbId());
-//                if (gbStreamList != null && gbStreamList.size() == 1) {
-//                    transform.setGbStreamId(gbStreamList.get(0).getGbStreamId());
-//                    transform.setPlatformId(gbStreamList.get(0).getPlatformId());
-//                    transform.setCatalogId(gbStreamList.get(0).getCatalogId());
-//                    transform.setGbId(gbStreamList.get(0).getGbId());
-//                    gbStreamMapper.update(transform);
-//                    streamPushMapper.del(gbStreamList.get(0).getApp(), gbStreamList.get(0).getStream());
-//                }else {
-//                    transform.setCreateTime(DateUtil.getNow());
-//                    transform.setUpdateTime(DateUtil.getNow());
-//                    gbStreamMapper.add(transform);
-//                }
-                // 閫氱煡閫氶亾涓婄嚎
-//            if (transform != null) {
-//                if (channelOnlineEvents.get(transform.getGbId()) != null)  {
-//                    channelOnlineEvents.get(transform.getGbId()).run(transform.getApp(), transform.getStream(), transform.getServerId());
-//                    channelOnlineEvents.remove(transform.getGbId());
-//                }
-//            }
-//            }
         }
-
-
-
         return transform;
     }
 

--
Gitblit v1.8.0