dev add tariff and temp flag for files

src/main/java/ru/soune/nocopy/repository/FileEntityRepository.java

@@ -49,5 +49,5 @@ public interface FileEntityRepository extends JpaRepository<FileEntity, String>
     @Query("SELECT f.id FROM FileEntity f WHERE f.filePath = :filePath")
     String findFileIdByFilePath(@Param("filePath") String filePath);
 
-    long countByUserId(Long userId);
+    List<FileEntity> findFileByUserIdAndStatus(Long userId, FileStatus status);
 }

src/main/java/ru/soune/nocopy/service/file/FileEntityService.java

@@ -217,7 +217,6 @@ public class FileEntityService {
         fileEntityRepository.save(fileEntity);
     }
 
-    @Transactional
     public void deleteFromDisk(FileEntity fileEntity) throws IOException {
         Path path = Paths.get(fileEntity.getFilePath());
 
@@ -267,6 +266,14 @@ public class FileEntityService {
         fileEntityRepository.save(fileEntity);
     }
 
+    public void clearTempFiles(long userId) throws IOException {
+        List<FileEntity> fileByUserIdAndStatus = fileEntityRepository.findFileByUserIdAndStatus(userId, FileStatus.TEMP);
+
+        for (FileEntity fileEntity : fileByUserIdAndStatus) {
+            deleteFromDisk(fileEntity);
+        }
+    }
+
     public FileEntity findBySignature(String signature) {
         return fileEntityRepository.findBySignature(signature);
     }

src/main/java/ru/soune/nocopy/service/file/impl/FileUploadServiceImpl.java

@@ -319,6 +319,10 @@ public class FileUploadServiceImpl implements FileUploadService {
 
                 FileStatus status = findSimilar == 0 ? FileStatus.ACTIVE: FileStatus.TEMP;
 
+                if (status == FileStatus.TEMP) {
+                    fileEntityService.clearTempFiles(session.getUserId());
+                }
+
                 completeFileProcessingAsync(session, status);
 
             } else {