q792602257/FrameTour-BE
0
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

调整下清理时机

Browse Source
This commit is contained in:
Jerry Yan
2025-05-12 18:17:44 +08:00
parent 870e79cde5
commit c366495805
1 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
src/main/java/com/ycwl/basic/task/FaceCleaner.java
View File

@ -126,7 +126,7 @@ public class FaceCleaner {
}); });
} }
@Scheduled(cron = "0 0 3 * * ?") @Scheduled(cron = "0 0 1 * * ?")
public void deleteNotBuySource(){ public void deleteNotBuySource(){
ScenicReqQuery scenicQuery = new ScenicReqQuery(); ScenicReqQuery scenicQuery = new ScenicReqQuery();
List<ScenicRespVO> scenicList = scenicMapper.list(scenicQuery); List<ScenicRespVO> scenicList = scenicMapper.list(scenicQuery);
@ -147,7 +147,7 @@ public class FaceCleaner {
}); });
} }
@Scheduled(cron = "0 15 3 * * ?") @Scheduled(cron = "0 15 1 * * ?")
public void deleteNotBuyVideos(){ public void deleteNotBuyVideos(){
ScenicReqQuery scenicQuery = new ScenicReqQuery(); ScenicReqQuery scenicQuery = new ScenicReqQuery();
List<ScenicRespVO> scenicList = scenicMapper.list(scenicQuery); List<ScenicRespVO> scenicList = scenicMapper.list(scenicQuery);
@ -168,7 +168,7 @@ public class FaceCleaner {
}); });
} }
@Scheduled(cron = "0 30 3 * * ?") @Scheduled(cron = "0 30 1 * * ?")
public void deleteExpiredSource(){ public void deleteExpiredSource(){
ScenicReqQuery scenicQuery = new ScenicReqQuery(); ScenicReqQuery scenicQuery = new ScenicReqQuery();
List<ScenicRespVO> scenicList = scenicMapper.list(scenicQuery); List<ScenicRespVO> scenicList = scenicMapper.list(scenicQuery);
@ -207,7 +207,7 @@ public class FaceCleaner {
}); });
} }
@Scheduled(cron = "0 0 1 * * ?") @Scheduled(cron = "0 0 2 * * ?")
public void clearOss(){ public void clearOss(){
cleanFaceSampleOss(); cleanFaceSampleOss();
cleanSourceOss(); cleanSourceOss();
@ -225,13 +225,13 @@ public class FaceCleaner {
return; return;
} }
} }
if(faceSampleRespVOS.parallelStream().noneMatch(faceSampleRespVO -> faceSampleRespVO.getFaceUrl().contains(fileObject.getFullPath()))){ if(faceSampleRespVOS.parallelStream().noneMatch(faceSampleRespVO -> faceSampleRespVO.getFaceUrl().contains(fileObject.getName()))){
log.info("删除人脸文件：{}", fileObject); log.info("删除人脸文件：{}", fileObject);
adapter.deleteFile(fileObject.getFullPath()); adapter.deleteFile(fileObject.getFullPath());
} }
}); });
} }
private void cleanSourceOss() { public void cleanSourceOss() {
log.info("开始清理源视频素材文件"); log.info("开始清理源视频素材文件");
List<SourceRespVO> list = sourceMapper.list(new SourceReqQuery()); List<SourceRespVO> list = sourceMapper.list(new SourceReqQuery());
scenicMapper.list(new ScenicReqQuery()).forEach(scenic -> { scenicMapper.list(new ScenicReqQuery()).forEach(scenic -> {
@ -245,7 +245,7 @@ public class FaceCleaner {
return; return;
} }
} }
if (list.parallelStream().filter(videoRespVO -> Objects.nonNull(videoRespVO.getVideoUrl())).noneMatch(videoRespVO -> videoRespVO.getVideoUrl().contains(fileObject.getFullPath()))){ if (list.parallelStream().filter(videoRespVO -> Objects.nonNull(videoRespVO.getVideoUrl())).noneMatch(videoRespVO -> videoRespVO.getVideoUrl().contains(fileObject.getName()))){
log.info("删除文件：{}", fileObject); log.info("删除文件：{}", fileObject);
adapter.deleteFile(fileObject.getFullPath()); adapter.deleteFile(fileObject.getFullPath());
} else { } else {
@ -261,7 +261,7 @@ public class FaceCleaner {
return; return;
} }
} }
if (list.parallelStream().filter(videoRespVO -> Objects.nonNull(videoRespVO.getUrl())).noneMatch(videoRespVO -> videoRespVO.getUrl().contains(fileObject.getFullPath()))){ if (list.parallelStream().filter(videoRespVO -> Objects.nonNull(videoRespVO.getUrl())).noneMatch(videoRespVO -> videoRespVO.getUrl().contains(fileObject.getName()))){
log.info("删除文件：{}", fileObject); log.info("删除文件：{}", fileObject);
adapter.deleteFile(fileObject.getFullPath()); adapter.deleteFile(fileObject.getFullPath());
} else { } else {
@ -270,7 +270,7 @@ public class FaceCleaner {
}); });
}); });
} }
private void cleanVideoOss() { public void cleanVideoOss() {
log.info("开始清理视频文件"); log.info("开始清理视频文件");
List<VideoRespVO> list = videoMapper.list(new VideoReqQuery()); List<VideoRespVO> list = videoMapper.list(new VideoReqQuery());
scenicMapper.list(new ScenicReqQuery()).forEach(scenic -> { scenicMapper.list(new ScenicReqQuery()).forEach(scenic -> {
@ -284,7 +284,7 @@ public class FaceCleaner {
return; return;
} }
} }
if (list.parallelStream().filter(videoRespVO -> Objects.nonNull(videoRespVO.getVideoUrl())).noneMatch(videoRespVO -> videoRespVO.getVideoUrl().contains(fileObject.getFullPath()))){ if (list.parallelStream().filter(videoRespVO -> Objects.nonNull(videoRespVO.getVideoUrl())).noneMatch(videoRespVO -> videoRespVO.getVideoUrl().contains(fileObject.getName()))){
log.info("删除文件：{}", fileObject); log.info("删除文件：{}", fileObject);
adapter.deleteFile(fileObject.getFullPath()); adapter.deleteFile(fileObject.getFullPath());
} else { } else {