src/main/java/com/whyc/schedule/VideoScheduleService.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
src/main/resources/config/application-dev.yml | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
src/main/resources/config/logback-spring.xml | ●●●●● 补丁 | 查看 | 原始文档 | 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>