whycxzp
2025-01-20 ddd18928908468ba12c2abb42c267b0d4e49a0d9
摄像头视频流相关接口
3个文件已修改
40 ■■■■ 已修改文件
src/main/java/com/whyc/schedule/VideoScheduleService.java 13 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/resources/config/application-dev.yml 23 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/resources/config/logback-spring.xml 4 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/whyc/schedule/VideoScheduleService.java
@@ -7,6 +7,7 @@
import com.whyc.service.VideoService;
import com.whyc.util.DateUtil;
import com.whyc.util.FileUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
@@ -21,6 +22,7 @@
@EnableScheduling
@Component
@Slf4j
public class VideoScheduleService {
    @Autowired
@@ -41,7 +43,6 @@
            List<String> videoStreamIds = YamlProperties.videoStreamIds;
            Response4Http streamIdsOnlineRes = service.getVideoStreamIds();
            List<String> streamIdsOnline = (List<String>) streamIdsOnlineRes.getData2()==null?new ArrayList<>():(List<String>) streamIdsOnlineRes.getData2();
            if(streamIdsOnlineRes.getCode() == 1 && ((boolean) streamIdsOnlineRes.getData())){
                videoStreamIds.forEach(streamId->{
                    if(!streamIdsOnline.contains(streamId)){ //流不存在
@@ -50,9 +51,9 @@
                        Response4Http response2 = service.startRecord(streamId);
                        if(!(response2.getCode() ==1 && ((boolean) response2.getData()))){
                            System.out.println("流id为:"+streamId+"的信息:"+response2.getMsg());
                            log.info("流id为:"+streamId+"的信息:"+response2.getMsg());
                        }else{
                            System.out.println("流id为:"+streamId+"的信息:"+response2.getData());
                            log.error("流id为:"+streamId+"的信息:"+response2.getData());
                        }
                    }else{ //流存在
                        //检查是否在录制状态
@@ -60,9 +61,9 @@
                        if(!(boolean)recordingRes.getData()){ //不在录制,则进行录制
                            Response4Http response2 = service.startRecord(streamId);
                            if(!(response2.getCode() ==1 && ((boolean) response2.getData()))){
                                System.out.println("流id为:"+streamId+"的信息:"+response2.getMsg());
                                log.error("流id为:"+streamId+"的信息:"+response2.getMsg());
                            }else{
                                System.out.println("流id为:"+streamId+"的信息:"+response2.getData());
                                log.info("流id为:"+streamId+"的信息:"+response2.getData());
                            }
                        }
                    }
@@ -74,7 +75,7 @@
    /**
     * 录像保持3天
     */
    @Scheduled(cron= "0 0 3 * * ?")
    @Scheduled(cron= "0 0 2 * * ?")
    public void recordRecycle(){
        System.out.println("-----------执行录像循环----------:"+ DateUtil.YYYY_MM_DD_HH_MM_SS.format(new Date()));
        //文件夹路径 /battery_system/video_system/Debug/www/record/rtp/{streamId}/{day}}
src/main/resources/config/application-dev.yml
@@ -96,25 +96,4 @@
#视频流的id
video:
  streamIds:
     "34020000001110000001_34020000001320000001,
      34020000001110000001_34020000001320000002,
      34020000001110000001_34020000001320000003,
      34020000001110000002_34020000001320000001,
      34020000001110000002_34020000001320000002,
      34020000001110000002_34020000001320000003,
      34020000001320000001_34020000001320000001,
      34020000001320000001_34020000001320000002,
      34020000001320000002_34020000001320000001,
      34020000001320000002_34020000001320000002,
      34020000001320000003_34020000001320000001,
      34020000001320000003_34020000001320000002,
      34020000001320000004_34020000001320000001,
      34020000001320000004_34020000001320000002,
      34020000001320000005_34020000001320000001,
      34020000001320000005_34020000001320000002,
      34020000001320000006_34020000001320000001,
      34020000001320000006_34020000001320000002,
      34020000001320000007_34020000001320000001,
      34020000001320000007_34020000001320000002,
      34020000001320000008_34020000001320000001,
      34020000001320000008_34020000001320000002"
     "34020000001320000001_34020000001320000002"
src/main/resources/config/logback-spring.xml
@@ -8,12 +8,12 @@
    <!-- 定义文件输出 -->
    <appender name="FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
        <file>web_logs\fg.log</file>
        <file>web_logs/fg.log</file>
        <encoder>
            <pattern>%d{yyyy-MM-dd HH:mm:ss} [%thread] %-5level %logger{36} - %msg%n</pattern>
        </encoder>
        <rollingPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedRollingPolicy">
            <fileNamePattern>web_logs\fg-%d{yyyy-MM-dd}.%i.log</fileNamePattern>
            <fileNamePattern>web_logs/fg-%d{yyyy-MM-dd}.%i.log</fileNamePattern>
            <maxFileSize>50MB</maxFileSize>
            <maxHistory>30</maxHistory>
        </rollingPolicy>