优化包结构、增加载荷飞控权限

liusuyi

2025-03-04 16fd4235f692777cfd9cceff5090e5450e2173b3

 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.BoxInfoReceiver;
import com.ard.tianyu.model.receiver.BoxStreamUrlReceiver;
import com.ard.tianyu.config.TyConfiguration;
import com.ard.tianyu.domain.cache.TyTcpServerCache;
import com.ard.tianyu.domain.receiver.BoxInfoReceiver;
import com.ard.tianyu.domain.receiver.BoxStreamUrlReceiver;
import com.ard.tianyu.service.ITyService;
import com.ard.vtdu.client.MediaClient;
import com.ard.vtdu.domain.*;
@@ -13,7 +15,6 @@
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service;

import javax.annotation.PostConstruct;
@@ -42,6 +43,8 @@
    private MediaClient mediaClient;
    @Resource
    private ITyService tyService;
    @Resource
    private TyConfiguration tyConfiguration;
    @Value("${mediamtx.host}")
    private String mediamtxHost;

@@ -565,9 +568,12 @@
        return mediaClient.getPathConfigs(pageNum - 1, pageSize);
    }

    //同步无人机推流到流媒体
    @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<BoxInfoReceiver> boxList = tyService.getBoxList();