Cookies_Github_mirror/AquaDX
4
0
Fork 1
mirror of https://github.com/MewoLab/AquaDX.git synced 2026-02-10 22:47:27 +08:00
Code Issues Packages Projects Releases Wiki Activity

[O] Move const out, remove unused, fix typo

Browse Source
This commit is contained in:
Azalea
2025-01-11 18:36:24 -05:00
parent e973b28088
commit 8eeac1f3ea
1 changed files with 7 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
src/main/java/icu/samnyan/aqua/sega/maimai2/handler/GetGameRankingHandler.kt
View File

@@ -1,11 +1,9 @@
package icu.samnyan.aqua.sega.maimai2.handler package icu.samnyan.aqua.sega.maimai2.handler
import com.querydsl.jpa.impl.JPAQueryFactory import com.querydsl.jpa.impl.JPAQueryFactory
import ext.logger
import icu.samnyan.aqua.sega.general.BaseHandler import icu.samnyan.aqua.sega.general.BaseHandler
import icu.samnyan.aqua.sega.maimai2.model.Mai2Repos
import icu.samnyan.aqua.sega.maimai2.model.userdata.QMai2UserPlaylog import icu.samnyan.aqua.sega.maimai2.model.userdata.QMai2UserPlaylog
import org.slf4j.Logger
import org.slf4j.LoggerFactory
import org.springframework.scheduling.annotation.Scheduled import org.springframework.scheduling.annotation.Scheduled
import org.springframework.stereotype.Component import org.springframework.stereotype.Component
import java.time.LocalDateTime import java.time.LocalDateTime
@@ -17,7 +15,6 @@ import kotlin.concurrent.Volatile
*/ */
@Component("Maimai2GetGameRankingHandler") @Component("Maimai2GetGameRankingHandler")
class GetGameRankingHandler( class GetGameRankingHandler(
private val repos: Mai2Repos,
private val queryFactory: JPAQueryFactory private val queryFactory: JPAQueryFactory
) : BaseHandler { ) : BaseHandler {
private data class MusicRankingItem(val musicId: Int, val weight: Long) private data class MusicRankingItem(val musicId: Int, val weight: Long)
@@ -33,9 +30,6 @@ class GetGameRankingHandler(
@Scheduled(fixedDelay = 3600_000) @Scheduled(fixedDelay = 3600_000)
private fun refreshMusicRankingCache() { private fun refreshMusicRankingCache() {
val LOOK_BACK_DAYS: Long = 7
val QUREY_LIMIT: Long = 50
// Get the play count of each music in the last N days // Get the play count of each music in the last N days
val queryAfter = LocalDateTime.now().minusDays(LOOK_BACK_DAYS) val queryAfter = LocalDateTime.now().minusDays(LOOK_BACK_DAYS)
val formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss") val formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")
@@ -50,12 +44,11 @@ class GetGameRankingHandler(
.where(qPlaylog.userPlayDate.stringValue().goe(queryAfterStr)) .where(qPlaylog.userPlayDate.stringValue().goe(queryAfterStr))
.groupBy(cMusicId) .groupBy(cMusicId)
.orderBy(cUserCount.desc()) .orderBy(cUserCount.desc())
.limit(QUREY_LIMIT) .limit(QUERY_LIMIT)
.fetch() .fetch()
.map { MusicRankingItem(it.get(cMusicId)!!, it.get(cUserCount)!!) } .map { MusicRankingItem(it.get(cMusicId)!!, it.get(cUserCount)!!) }
.toList()
logger.info("Refreshed music ranking cache: ${musicRankingCache.size} items") log.info("Refreshed music ranking cache: ${musicRankingCache.size} items")
} }
override fun handle(request: Map<String, Any>): Any = mapOf( override fun handle(request: Map<String, Any>): Any = mapOf(
@@ -67,6 +60,9 @@ class GetGameRankingHandler(
) )
companion object { companion object {
val logger: Logger = LoggerFactory.getLogger(GetGameRankingHandler::class.java) val log = logger()
const val LOOK_BACK_DAYS: Long = 7
const val QUERY_LIMIT: Long = 50
} }
} }