修复定时删除过期录像文件时，收藏文件被删除的问题

648540858

2023-11-21 c98ef23b98573d622f6637bb181bfebc8172b118

修复定时删除过期录像文件时，收藏文件被删除的问题

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

@@ -41,8 +41,8 @@
    /**
     * 定时查询待删除的录像文件
     */
//    @Scheduled(fixedRate = 5000) //每五秒执行一次，方便测试
    @Scheduled(cron = "0 0 0 * * ?")   //每天的0点执行
    @Scheduled(fixedRate = 5000) //每五秒执行一次，方便测试
//    @Scheduled(cron = "0 0 0 * * ?")   //每天的0点执行
    public void execute(){
        logger.info("[录像文件定时清理] 开始清理过期录像文件");
        // 获取配置了assist的流媒体节点
@@ -56,7 +56,7 @@
            Calendar lastCalendar = Calendar.getInstance();
            if (mediaServerItem.getRecordDay() > 0) {
                lastCalendar.setTime(new Date());
                // 获取保存的最后截至日期，因为每个节点都有一个日期，也就是支持每个节点设置不同的保存日期，
                // 获取保存的最后截至日[期，因为每个节点都有一个日期，也就是支持每个节点设置不同的保存日期，
                lastCalendar.add(Calendar.DAY_OF_MONTH, -mediaServerItem.getRecordDay());
                Long lastDate = lastCalendar.getTimeInMillis();


 src/main/java/com/genersoft/iot/vmp/service/impl/StreamProxyServiceImpl.java

@@ -133,6 +133,9 @@
            JSONArray dataArray = jsonObject.getJSONArray("data");
            JSONObject mediaServerConfig = dataArray.getJSONObject(0);
            String ffmpegCmd = mediaServerConfig.getString(param.getFfmpegCmdKey());
            if (ffmpegCmd == null) {
                throw new ControllerException(ErrorCode.ERROR100.getCode(), "ffmpeg拉流代理无法获取ffmpeg cmd");
            }
            String schema = getSchemaFromFFmpegCmd(ffmpegCmd);
            if (schema == null) {
                throw new ControllerException(ErrorCode.ERROR100.getCode(), "ffmpeg拉流代理无法从ffmpeg cmd中获取到输出格式");

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

@@ -91,7 +91,7 @@
    @Select(" <script>" +
            "select *" +
            " from wvp_cloud_record " +
            " where end_time &lt;= #{endTimeStamp} and media_server_id  = #{mediaServerId} " +
            " where collect = false and end_time &lt;= #{endTimeStamp} and media_server_id  = #{mediaServerId} " +
            " </script>")
    List<CloudRecordItem> queryRecordListForDelete(@Param("endTimeStamp")Long endTimeStamp, String mediaServerId);