Marmelator/persistence-service
1
0
Fork 0
Code Issues Pull Requests 17 Actions Packages Projects Releases 1.1k Wiki Activity

viewed pages cleanup

Browse Source
This commit is contained in:
Timo Bejan 2021-09-30 10:08:49 +03:00
parent c6e22ae3a2
commit ece73f5ca7
1 changed files with 11 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/service/persistence/ViewedPagesPersistenceService.java
View File

@ -17,13 +17,18 @@ public class ViewedPagesPersistenceService {
private final ViewedPagesRepository viewedPagesRepository; private final ViewedPagesRepository viewedPagesRepository;
private final FileRepository fileRepository; private final FileRepository fileRepository;
@Transactional
public void insertPage(String fileId, String userId, int page) { public void insertPage(String fileId, String userId, int page) {
var id = new ViewedPageEntity.ViewedPageId(fileId, page, userId);
viewedPagesRepository.findById(id).ifPresentOrElse((viewedPage) -> {
viewedPage.setViewedTime(OffsetDateTime.now());
}, () -> {
var viewedPage = new ViewedPageEntity(); var viewedPage = new ViewedPageEntity();
viewedPage.setViewedTime(OffsetDateTime.now()); viewedPage.setViewedTime(OffsetDateTime.now());
viewedPage.setId(new ViewedPageEntity.ViewedPageId(null, page, userId)); viewedPage.setId(new ViewedPageEntity.ViewedPageId(null, page, userId));
viewedPage.setFile(fileRepository.getOne(fileId)); viewedPage.setFile(fileRepository.getOne(fileId));
viewedPagesRepository.save(viewedPage); viewedPagesRepository.save(viewedPage);
});
} }