Backup_Repos/komga
1
0
Fork 0
mirror of https://github.com/gotson/komga.git synced 2026-05-09 05:10:19 +02:00
Code Issues Projects Releases Wiki Activity

refactor(komga): use extension function

Browse source
This commit is contained in:
Gauthier Roebroeck 2023-10-13 16:06:30 +08:00
parent cafe669d15
commit 9abb26196c
1 changed files with 16 additions and 13 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

29
komga/src/main/kotlin/org/gotson/komga/infrastructure/jooq/main/ReadProgressDao.kt
View file

@ -58,22 +58,25 @@ class ReadProgressDao(
@Transactional
override fun save(readProgress: ReadProgress) {
saveQuery(readProgress).execute()
readProgress.toQuery().execute()
aggregateSeriesProgress(listOf(readProgress.bookId), readProgress.userId)
}
@Transactional
override fun save(readProgresses: Collection<ReadProgress>) {
val queries = readProgresses.map { saveQuery(it) }
queries.chunked(batchSize).forEach { chunk -> dsl.batch(chunk).execute() }
readProgresses
.map { it.toQuery() }
.chunked(batchSize)
.forEach { chunk -> dsl.batch(chunk).execute() }
readProgresses.groupBy { it.userId }
readProgresses
.groupBy { it.userId }
.forEach { (userId, readProgresses) ->
aggregateSeriesProgress(readProgresses.map { it.bookId }, userId)
}
}
private fun saveQuery(readProgress: ReadProgress): Query =
private fun ReadProgress.toQuery(): Query =
dsl.insertInto(
r,
r.BOOK_ID,
@ -83,16 +86,16 @@ class ReadProgressDao(
r.READ_DATE,
)
.values(
readProgress.bookId,
readProgress.userId,
readProgress.page,
readProgress.completed,
readProgress.readDate.toUTC(),
bookId,
userId,
page,
completed,
readDate.toUTC(),
)
.onDuplicateKeyUpdate()
.set(r.PAGE, readProgress.page)
.set(r.COMPLETED, readProgress.completed)
.set(r.READ_DATE, readProgress.readDate.toUTC())
.set(r.PAGE, page)
.set(r.COMPLETED, completed)
.set(r.READ_DATE, readDate.toUTC())
.set(r.LAST_MODIFIED_DATE, LocalDateTime.now(ZoneId.of("Z")))
@Transactional