修复定时录像删除

src/main/java/com/genersoft/iot/vmp/conf/CloudRecordTimer.java

@@ -41,12 +41,12 @@ public class CloudRecordTimer {
     /**
      * 定时查询待删除的录像文件
      */
-//    @Scheduled(fixedRate = 5000) //每五秒执行一次，方便测试
+//    @Scheduled(fixedRate = 10000) //每五秒执行一次，方便测试
     @Scheduled(cron = "0 0 0 * * ?")   //每天的0点执行
     public void execute(){
         logger.info("[录像文件定时清理] 开始清理过期录像文件");
         // 获取配置了assist的流媒体节点
-        List<MediaServerItem> mediaServerItemList =  mediaServerService.getAllWithAssistPort();
+        List<MediaServerItem> mediaServerItemList =  mediaServerService.getAllOnline();
         if (mediaServerItemList.isEmpty()) {
             return;
         }
@@ -70,8 +70,7 @@ public class CloudRecordTimer {
                     String date = new File(cloudRecordItem.getFilePath()).getParentFile().getName();
                     JSONObject jsonObject = zlmresTfulUtils.deleteRecordDirectory(mediaServerItem, cloudRecordItem.getApp(),
                             cloudRecordItem.getStream(), date, cloudRecordItem.getFileName());
-                    if (jsonObject.getInteger("code") == 0) {
-                    }else {
+                    if (jsonObject.getInteger("code") != 0) {
                         logger.warn("[录像文件定时清理] 删除磁盘文件错误： {}:{}", cloudRecordItem.getFilePath(), jsonObject);
                     }
                 }

src/main/java/com/genersoft/iot/vmp/conf/MediaConfig.java

@@ -81,8 +81,8 @@ public class MediaConfig{
     @Value("${media.record-assist-port:0}")
     private Integer recordAssistPort = 0;
 
-    @Value("${media.record-date:7}")
-    private Integer recordDay = 7;
+    @Value("${media.record-day:7}")
+    private Integer recordDay;
 
     @Value("${media.record-path}")
     private String recordPath;

src/main/java/com/genersoft/iot/vmp/storager/dao/CloudRecordServiceMapper.java

@@ -101,7 +101,7 @@ public interface CloudRecordServiceMapper {
     int changeCollectById(@Param("collect") boolean collect, @Param("recordId") Integer recordId);
 
     @Delete(" <script>" +
-            "delete from wvp_cloud_record where media_server_id=#{mediaServerId} and id in " +
+            "delete from wvp_cloud_record where id in " +
             " <foreach collection='cloudRecordItemIdList'  item='item'  open='(' separator=',' close=')' > #{item.id}</foreach>" +
             " </script>")
     int deleteList(List<CloudRecordItem> cloudRecordItemIdList);

src/main/resources/all-application.yml

@@ -155,7 +155,7 @@ media:
     # 录像路径
     record-path: ./www/record
     # 录像保存时长
-    record-date: 7
+    record-day: 7
     # 启用多端口模式, 多端口模式使用端口区分每路流，兼容性更好。 单端口使用流的ssrc区分， 点播超时建议使用多端口测试
     rtp:
         # [可选] 是否启用多端口模式, 开启后会在portRange范围内选择端口用于媒体流传输