package com.genersoft.iot.vmp.media.zlm; import com.alibaba.fastjson.JSONObject; import com.genersoft.iot.vmp.conf.UserSetting; import com.genersoft.iot.vmp.gb28181.bean.GbStream; import com.genersoft.iot.vmp.media.zlm.dto.*; import com.genersoft.iot.vmp.service.IStreamProxyService; import com.genersoft.iot.vmp.service.IStreamPushService; import com.genersoft.iot.vmp.service.bean.ThirdPartyGB; import com.genersoft.iot.vmp.storager.IRedisCatchStorage; import com.genersoft.iot.vmp.storager.IVideoManagerStorage; import com.genersoft.iot.vmp.storager.dao.GbStreamMapper; import com.genersoft.iot.vmp.storager.dao.PlatformGbStreamMapper; import com.genersoft.iot.vmp.storager.dao.StreamPushMapper; import com.genersoft.iot.vmp.utils.DateUtil; import org.checkerframework.checker.units.qual.C; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import org.springframework.util.StringUtils; import java.util.*; import java.util.concurrent.ConcurrentHashMap; import java.util.regex.Matcher; import java.util.regex.Pattern; /** * @author lin */ @Component public class ZLMMediaListManager { private Logger logger = LoggerFactory.getLogger("ZLMMediaListManager"); @Autowired private ZLMRESTfulUtils zlmresTfulUtils; @Autowired private IRedisCatchStorage redisCatchStorage; @Autowired private IVideoManagerStorage storager; @Autowired private GbStreamMapper gbStreamMapper; @Autowired private PlatformGbStreamMapper platformGbStreamMapper; @Autowired private IStreamPushService streamPushService; @Autowired private IStreamProxyService streamProxyService; @Autowired private StreamPushMapper streamPushMapper; @Autowired private ZLMHttpHookSubscribe subscribe; @Autowired private UserSetting userSetting; private Map channelOnlineEvents = new ConcurrentHashMap<>(); public void updateMediaList(MediaServerItem mediaServerItem) { storager.clearMediaList(); // 使用异步的当时更新媒体流列表 zlmresTfulUtils.getMediaList(mediaServerItem, (mediaList ->{ if (mediaList == null) { return; } String dataStr = mediaList.getString("data"); Integer code = mediaList.getInteger("code"); Map result = new HashMap<>(); List streamPushItems = null; // 获取所有的国标关联 // List gbStreams = gbStreamMapper.selectAllByMediaServerId(mediaServerItem.getId()); if (code == 0 ) { if (dataStr != null) { streamPushItems = streamPushService.handleJSON(dataStr, mediaServerItem); } }else { logger.warn("更新视频流失败,错误code: " + code); } if (streamPushItems != null) { storager.updateMediaList(streamPushItems); for (StreamPushItem streamPushItem : streamPushItems) { JSONObject jsonObject = new JSONObject(); jsonObject.put("app", streamPushItem.getApp()); jsonObject.put("stream", streamPushItem.getStream()); jsonObject.put("mediaServerId", mediaServerItem.getId()); subscribe.addSubscribe(ZLMHttpHookSubscribe.HookType.on_play,jsonObject, (MediaServerItem mediaServerItemInuse, JSONObject response)->{ updateMedia(mediaServerItem, response.getString("app"), response.getString("stream")); } ); } } })); } public void addMedia(MediaServerItem mediaServerItem, String app, String streamId) { //使用异步更新推流 updateMedia(mediaServerItem, app, streamId); } public StreamPushItem addPush(MediaItem mediaItem) { // 查找此直播流是否存在redis预设gbId StreamPushItem transform = streamPushService.transform(mediaItem); StreamPushItem pushInDb = streamPushService.getPush(mediaItem.getApp(), mediaItem.getStream()); transform.setUpdateTime(DateUtil.getNow()); transform.setPushTime(DateUtil.getNow()); if (pushInDb == null) { transform.setCreateTime(DateUtil.getNow()); streamPushMapper.add(transform); }else { streamPushMapper.update(transform); // if (!StringUtils.isEmpty(pushInDb.getGbId())) { // List 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; } public void updateMedia(MediaServerItem mediaServerItem, String app, String streamId) { //使用异步更新推流 zlmresTfulUtils.getMediaList(mediaServerItem, app, streamId, "rtmp", json->{ if (json == null) { return; } String dataStr = json.getString("data"); Integer code = json.getInteger("code"); Map result = new HashMap<>(); List streamPushItems = null; if (code == 0 ) { if (dataStr != null) { streamPushItems = streamPushService.handleJSON(dataStr, mediaServerItem); } }else { logger.warn("更新视频流失败,错误code: " + code); } if (streamPushItems != null && streamPushItems.size() == 1) { storager.updateMedia(streamPushItems.get(0)); } }); } public int removeMedia(String app, String streamId) { // 查找是否关联了国标, 关联了不删除, 置为离线 GbStream gbStream = gbStreamMapper.selectOne(app, streamId); int result; if (gbStream == null) { result = storager.removeMedia(app, streamId); }else { // TODO 暂不设置为离线 result =storager.mediaOffline(app, streamId); } return result; } public void addChannelOnlineEventLister(String key, ChannelOnlineEvent callback) { this.channelOnlineEvents.put(key,callback); } public void removedChannelOnlineEventLister(String key) { this.channelOnlineEvents.remove(key); } // public void clearAllSessions() { // logger.info("清空所有国标相关的session"); // JSONObject allSessionJSON = zlmresTfulUtils.getAllSession(); // ZLMServerConfig mediaInfo = redisCatchStorage.getMediaInfo(); // HashSet allLocalPorts = new HashSet(); // if (allSessionJSON.getInteger("code") == 0) { // JSONArray data = allSessionJSON.getJSONArray("data"); // if (data.size() > 0) { // for (int i = 0; i < data.size(); i++) { // JSONObject sessionJOSN = data.getJSONObject(i); // Integer local_port = sessionJOSN.getInteger("local_port"); // if (!local_port.equals(Integer.valueOf(mediaInfo.getHttpPort())) && // !local_port.equals(Integer.valueOf(mediaInfo.getHttpSSLport())) && // !local_port.equals(Integer.valueOf(mediaInfo.getRtmpPort())) && // !local_port.equals(Integer.valueOf(mediaInfo.getRtspPort())) && // !local_port.equals(Integer.valueOf(mediaInfo.getRtspSSlport())) && // !local_port.equals(Integer.valueOf(mediaInfo.getHookOnFlowReport()))){ // allLocalPorts.add(sessionJOSN.getInteger("local_port") + ""); // } // } // } // } // if (allLocalPorts.size() > 0) { // List result = new ArrayList<>(allLocalPorts); // String localPortSStr = String.join(",", result); // zlmresTfulUtils.kickSessions(localPortSStr); // } // } }