修复数据写入

648540858
1 parent ee9f55b3
Showing 3 changed files with 0 additions and 82 deletions
src/main/java/top/panll/assist/config/StartConfig.java
src/main/java/top/panll/assist/dto/CloudRecordItem.java
src/main/java/top/panll/assist/mapper/CloudRecordServiceMapper.java
@@ -159,7 +159,6 @@ public class StartConfig implements CommandLineRunner {
                                     cloudRecordItem.setStartTime(startTimeStamp);
                                     cloudRecordItem.setEndTime(endTimeStamp);
                                     cloudRecordItem.setCollect(collect);
-                                    cloudRecordItem.setReserve(reserve);
                                     cloudRecordItem.setMediaServerId(mediaServerId);
                                     cloudRecordItem.setFileName(DateUtils.getTimeStr(startTimeStamp) + "-" + dateVideoFileIndexList.get(dataPath).size() + ".mp4");
                                     cloudRecordItem.setFolder(streamFile.getAbsolutePath());
@@ -60,10 +60,6 @@ public class CloudRecordItem {
      */
     private Boolean collect;
-    /**
-     * 保留，收藏的文件不移除
-     */
-    private Boolean reserve;
     /**
      * 文件大小
@@ -178,12 +174,4 @@ public class CloudRecordItem {
     public void setCollect(Boolean collect) {
         this.collect = collect;
     }
-
-    public Boolean getReserve() {
-        return reserve;
-    }
-
-    public void setReserve(Boolean reserve) {
-        this.reserve = reserve;
-    }
 }
@@ -21,7 +21,6 @@ public interface CloudRecordServiceMapper {
             " file_path," +
             " file_size," +
             " collect," +
-            " reserve," +
             " time_len ) " +
             "VALUES (" +
             " #{app}," +
@@ -35,78 +34,10 @@ public interface CloudRecordServiceMapper {
             " #{filePath}," +
             " #{fileSize}," +
             " #{collect}," +
-            " #{reserve}," +
             " #{timeLen})" +
             " </script>")
     int add(CloudRecordItem cloudRecordItem);
-
-    @Update(" <script>" +
-            "update wvp_cloud_record set collect = #{collect} where file_path in " +
-            " <foreach collection='cloudRecordItemList'  item='item'  open='(' separator=',' close=')' > #{item.filePath}</foreach>" +
-            " </script>")
-    void updateCollectList(@Param("collect") boolean collect, List<CloudRecordItem> cloudRecordItemList);
-
-    @Delete(" <script>" +
-            "delete from wvp_cloud_record where media_server_id=#{mediaServerId} file_path in " +
-            " <foreach collection='filePathList'  item='item'  open='(' separator=',' close=')' > #{item}</foreach>" +
-            " </script>")
-    void deleteByFileList(List<String> filePathList, @Param("mediaServerId") String mediaServerId);
-
-
-    @Select(" <script>" +
-            "select file_path" +
-            " from wvp_cloud_record " +
-            " where collect = false and reserve = false " +
-            " <if test= 'endTimeStamp != null '> and start_time &lt;= #{endTimeStamp}</if>" +
-            " <if test= 'callId != null '> and call_id = #{callId}</if>" +
-            " <if test= 'mediaServerId != null  ' > and media_server_id  = #{mediaServerId} </if>" +
-            " </script>")
-    List<String> queryRecordFilePathListForDelete(@Param("endTimeStamp")Long endTimeStamp, String mediaServerId);
-
-    @Update(" <script>" +
-            "update wvp_cloud_record set reserve = #{reserve} where file_path in " +
-            " <foreach collection='cloudRecordItems'  item='item'  open='(' separator=',' close=')' > #{item.filePath}</foreach>" +
-            " </script>")
-    void updateReserveList(@Param("reserve") boolean reserve,List<CloudRecordItem> cloudRecordItems);
-
-    @Update(" <script>" +
-            "update wvp_cloud_record set collect = #{collect} where id = #{recordId} " +
-            " </script>")
-    void changeCollectById(@Param("collect") boolean collect, @Param("recordId") Integer recordId);
-
-    @Update(" <script>" +
-            "update wvp_cloud_record set reserve = #{reserve} where id = #{recordId} " +
-            " </script>")
-    void changeReserveById(@Param("reserve") boolean reserve, Integer recordId);
-
-
-    @Insert("<script> " +
-            "insert into wvp_cloud_record " +
-            "(" +
-            " app," +
-            " stream," +
-            " call_id," +
-            " start_time," +
-            " end_time," +
-            " media_server_id," +
-            " file_name," +
-            " folder," +
-            " file_path," +
-            " file_size," +
-            " collect," +
-            " reserve," +
-            " time_len " +
-            ") " +
-            "values " +
-            "<foreach collection='cloudRecordItems' index='index' item='item' separator=','> " +
-            "(#{item.app}, #{item.stream}, #{item.callId}, #{item.startTime}, " +
-            "#{item.endTime}, #{item.mediaServerId}, #{item.fileName},#{item.folder}," +
-            "#{item.filePath}, #{item.fileSize}, #{item.collect}, #{item.reserve}, #{item.timeLen}) " +
-            "</foreach> " +
-            "</script>")
-    int batchAdd(@Param("cloudRecordItems") List<CloudRecordItem> cloudRecordItems);
-
     @Select(" <script>" +
             "select *" +
             " from wvp_cloud_record " +