增加：航线 关闭：流媒体拉流

liusuyi

2024-11-01 dc4d96ff05b50617c685d90d625c6e2617c81dde

 ard-work/src/main/java/com/ard/vtdu/service/impl/MediaServiceImpl.java

@@ -2,8 +2,10 @@

import com.ard.common.constant.HttpStatus;
import com.ard.common.core.page.TableDataInfo;
import com.ard.tianyu.model.receiver.BoxReceiver;
import com.ard.tianyu.model.receiver.PullStreamUrlReceiver;
import com.ard.tianyu.config.TyConfiguration;
import com.ard.tianyu.model.cache.TyTcpServerCache;
import com.ard.tianyu.model.receiver.BoxInfoReceiver;
import com.ard.tianyu.model.receiver.BoxStreamUrlReceiver;
import com.ard.tianyu.service.ITyService;
import com.ard.vtdu.client.MediaClient;
import com.ard.vtdu.domain.*;
@@ -42,6 +44,8 @@
    private MediaClient mediaClient;
    @Resource
    private ITyService tyService;
    @Resource
    private TyConfiguration tyConfiguration;
    @Value("${mediamtx.host}")
    private String mediamtxHost;

@@ -566,18 +570,21 @@
    }

    //同步无人机推流到流媒体
    @Scheduled(cron = "0/20 * * * * ?")
   // @Scheduled(cron = "0/20 * * * * ?")
    public void syncVtdu() {
        if (!TyTcpServerCache.getTcpServerCache(tyConfiguration.getTcpserver() + ":" + tyConfiguration.getTcpport())) {
            return;
        }
        log.info("定时同步MediaMTX任务开始");
        List<String> nameList = getNameList();
        List<BoxReceiver> boxList = tyService.getBoxList();
        List<BoxInfoReceiver> boxList = tyService.getBoxList();
        if (boxList == null || boxList.isEmpty()) {
            return;
        }
        List<ArdVtdu> ardVtduList = boxList.stream()
                .filter(boxReceiver -> boxReceiver.getOnLine() != 0)  // 过滤掉不在线的
                .map(boxReceiver -> {
                    PullStreamUrlReceiver boxLiveUrl = tyService.getBoxLiveUrl(boxReceiver.getBoxSn());
                    BoxStreamUrlReceiver boxLiveUrl = tyService.getBoxLiveUrl(boxReceiver.getBoxSn());
                    return ArdVtdu.builder().name(boxReceiver.getBoxSn()).rtspSource(boxLiveUrl.getRtmp()).build();
                })
                .collect(Collectors.toList());