1111import run .ikaros .api .core .subject .*;
1212import run .ikaros .api .infra .properties .IkarosProperties ;
1313import run .ikaros .api .infra .utils .FileUtils ;
14- import run .ikaros .api .store .entity .FileEntity ;
1514import run .ikaros .api .store .enums .FileType ;
1615import run .ikaros .api .store .enums .SubjectSyncPlatform ;
1716import run .ikaros .api .wrap .PagingWrap ;
2423import java .time .format .DateTimeFormatter ;
2524import java .util .List ;
2625import java .util .Optional ;
27- import java .util .function .Consumer ;
2826import lombok .extern .slf4j .Slf4j ;
2927
3028@ Slf4j
@@ -150,9 +148,9 @@ private void handleSubject(Signal<Subject> subjectSignal, String mediaDirAbsolut
150148 }
151149 EpisodeResource episodeResource = episode .getResources ().get (0 );
152150 Long fileId = episodeResource .getFileId ();
153- fileOperate .findById (fileId ).subscribe (fileEntity ->
151+ fileOperate .findById (fileId ).subscribe (file ->
154152 linkEpisodeFileAndGenerateNfo (bgmTvIdOp , subjectDirAbsolutePath ,
155- workDirAbsolutePath , episode , fileEntity ));
153+ workDirAbsolutePath , episode , file ));
156154
157155 }
158156 }
@@ -161,14 +159,14 @@ private void linkEpisodeFileAndGenerateNfo(Optional<String> bgmTvIdOp,
161159 String subjectDirAbsolutePath ,
162160 String workDirAbsolutePath ,
163161 Episode episode ,
164- FileEntity fileEntity ) {
165- if (fileEntity == null ) {
162+ run . ikaros . api . core . file . File file ) {
163+ if (file == null ) {
166164 log .warn ("skip operate, file entity is null for episode: [{}]." ,
167165 episode .getName ());
168166 return ;
169167 }
170- String originalFileName = fileEntity .getOriginalName ();
171- String epUrl = fileEntity .getUrl ();
168+ String originalFileName = file .getOriginalName ();
169+ String epUrl = file .getUrl ();
172170
173171 String epFileAbsolutePath =
174172 workDirAbsolutePath + (epUrl .startsWith ("/" ) ? epUrl : "/" + epUrl );
@@ -206,7 +204,8 @@ private void linkEpisodeFileAndGenerateNfo(Optional<String> bgmTvIdOp,
206204 }
207205
208206 // link ass file if exists
209- String originalFileNameWithNoPostfix = originalFileName .substring (0 , originalFileName .indexOf ("." ));
207+ String originalFileNameWithNoPostfix =
208+ originalFileName .substring (0 , originalFileName .indexOf ("." ));
210209 log .debug ("originalFileNameWithNoPostfix: {}" , originalFileNameWithNoPostfix );
211210 fileOperate .findAllByOriginalNameLikeAndType (originalFileNameWithNoPostfix ,
212211 FileType .DOCUMENT )
0 commit comments