移除推流的国标关联移除未推流的数据

panlinlin

2021-04-03 2b1e56973edb72f990ee0d4a1b3e6d06ba3aa4d7

移除推流的国标关联移除未推流的数据

 src/main/java/com/genersoft/iot/vmp/service/impl/StreamPushServiceImpl.java

@@ -4,6 +4,7 @@
import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson.TypeReference;
import com.genersoft.iot.vmp.gb28181.bean.GbStream;
import com.genersoft.iot.vmp.media.zlm.ZLMRESTfulUtils;
import com.genersoft.iot.vmp.media.zlm.dto.MediaItem;
import com.genersoft.iot.vmp.media.zlm.dto.StreamProxyItem;
import com.genersoft.iot.vmp.media.zlm.dto.StreamPushItem;
@@ -28,6 +29,9 @@

    @Autowired
    private StreamPushMapper streamPushMapper;

    @Autowired
    private ZLMRESTfulUtils zlmresTfulUtils;

    @Override
    public List<StreamPushItem> handleJSON(String jsonData) {
@@ -84,6 +88,10 @@
    @Override
    public boolean removeFromGB(GbStream stream) {
        int del = gbStreamMapper.del(stream.getApp(), stream.getStream());
        JSONObject mediaList = zlmresTfulUtils.getMediaList(stream.getApp(), stream.getStream());
        if (mediaList == null) {
            streamPushMapper.del(stream.getApp(), stream.getStream());
        }
        return del > 0;
    }
}