iktdev/MediaProcessing
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Update

Browse Source
This commit is contained in:
Brage 2023-07-27 01:22:04 +02:00
parent 64f2bfba76
commit 4ede2aaf6a
2 changed files with 16 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
Reader/build.gradle.kts
View File

@ -27,7 +27,7 @@ dependencies {
implementation("no.iktdev.streamit.library:streamit-library-kafka:0.0.2-alpha75") implementation("no.iktdev.streamit.library:streamit-library-kafka:0.0.2-alpha75")
implementation("no.iktdev:exfl:0.0.12-SNAPSHOT") implementation("no.iktdev:exfl:0.0.12-SNAPSHOT")
implementation("no.iktdev.streamit.library:streamit-library-db:0.0.6-alpha13") implementation("no.iktdev.streamit.library:streamit-library-db:0.0.6-alpha14")
implementation("org.jetbrains.exposed:exposed-core:$exposedVersion") implementation("org.jetbrains.exposed:exposed-core:$exposedVersion")
implementation("org.jetbrains.exposed:exposed-dao:$exposedVersion") implementation("org.jetbrains.exposed:exposed-dao:$exposedVersion")

17
Reader/src/main/kotlin/no/iktdev/streamit/content/reader/collector/VideoConsumer.kt
View File

@ -14,8 +14,12 @@ import no.iktdev.streamit.library.kafka.KafkaEvents
import no.iktdev.streamit.library.kafka.listener.collector.CollectorMessageListener import no.iktdev.streamit.library.kafka.listener.collector.CollectorMessageListener
import no.iktdev.streamit.library.kafka.listener.collector.ICollectedMessagesEvent import no.iktdev.streamit.library.kafka.listener.collector.ICollectedMessagesEvent
import no.iktdev.streamit.library.kafka.listener.deserializer.IMessageDataDeserialization import no.iktdev.streamit.library.kafka.listener.deserializer.IMessageDataDeserialization
import org.jetbrains.exposed.sql.SqlExpressionBuilder.eq
import org.jetbrains.exposed.sql.andWhere
import org.jetbrains.exposed.sql.insert import org.jetbrains.exposed.sql.insert
import org.jetbrains.exposed.sql.select
import org.jetbrains.exposed.sql.transactions.transaction import org.jetbrains.exposed.sql.transactions.transaction
import org.jetbrains.exposed.sql.update
import org.springframework.stereotype.Service import org.springframework.stereotype.Service
import java.io.File import java.io.File
import kotlin.math.log import kotlin.math.log
@ -105,21 +109,30 @@ class VideoConsumer: DefaultKafkaReader("collectorConsumerEncodedVideo"), IColle
iid = iid, iid = iid,
genres = genres genres = genres
) )
val catalogType = if (serieData == null) "movie" else "serie"
catalog.insert { catalog.insert {
it[title] = fileData.title it[title] = fileData.title
it[cover] = coverFile?.name it[cover] = coverFile?.name
it[type] = if (serieData == null) "movie" else "serie" it[type] = catalogType
it[catalog.collection] = fileData.title it[catalog.collection] = fileData.title
it[catalog.iid] = iid it[catalog.iid] = iid
it[catalog.genres] = genres it[catalog.genres] = genres
} }
if (coverFile != null) {
val qres = catalog.select { catalog.title eq fileData.title }.andWhere { catalog.type eq catalogType}.firstOrNull() ?: null
if (qres != null && qres[catalog.cover].isNullOrBlank()) {
catalog.update({ catalog.id eq qres[catalog.id] }) {
it[catalog.cover] = coverFile.name
}
}
}
val cqId = cq.getId() ?: throw RuntimeException("No Catalog id found!") val cqId = cq.getId() ?: throw RuntimeException("No Catalog id found!")
metadata?.let { metadata?.let {
val summary = it.summary val summary = it.summary
if (summary != null) { if (summary != null) {
SummaryQuery(cid = cqId, language = "eng", description = summary) val success = SummaryQuery(cid = cqId, language = "eng", description = summary).insertAndGetStatus()
} }
} }
} }