Update users updater
This commit is contained in:
parent
35af5b2040
commit
1c52a62d91
@ -6,7 +6,6 @@ import com.nisemoe.nise.database.UserService
|
|||||||
import com.nisemoe.nise.integrations.DiscordEmbed
|
import com.nisemoe.nise.integrations.DiscordEmbed
|
||||||
import com.nisemoe.nise.integrations.DiscordService
|
import com.nisemoe.nise.integrations.DiscordService
|
||||||
import com.nisemoe.nise.osu.OsuApi
|
import com.nisemoe.nise.osu.OsuApi
|
||||||
import org.jooq.Condition
|
|
||||||
import org.jooq.DSLContext
|
import org.jooq.DSLContext
|
||||||
import org.slf4j.LoggerFactory
|
import org.slf4j.LoggerFactory
|
||||||
import org.springframework.beans.factory.annotation.Value
|
import org.springframework.beans.factory.annotation.Value
|
||||||
@ -63,7 +62,6 @@ class ImportUsers(
|
|||||||
val userIds = dslContext
|
val userIds = dslContext
|
||||||
.select(USERS.USER_ID)
|
.select(USERS.USER_ID)
|
||||||
.from(USERS)
|
.from(USERS)
|
||||||
.leftJoin(SCORES).on(USERS.USER_ID.eq(SCORES.USER_ID))
|
|
||||||
.orderBy(USERS.SYS_LAST_UPDATE.asc())
|
.orderBy(USERS.SYS_LAST_UPDATE.asc())
|
||||||
.limit(pageSize)
|
.limit(pageSize)
|
||||||
.offset(offset)
|
.offset(offset)
|
||||||
@ -79,10 +77,7 @@ class ImportUsers(
|
|||||||
}
|
}
|
||||||
|
|
||||||
private fun updateUserIds(userIds: List<Long>) {
|
private fun updateUserIds(userIds: List<Long>) {
|
||||||
val threeMonthsAgo = LocalDateTime.now().minusMonths(3)
|
|
||||||
|
|
||||||
val bannedUsersCondition = SCORES.IS_BANNED.eq(true)
|
val bannedUsersCondition = SCORES.IS_BANNED.eq(true)
|
||||||
.and(SCORES.DATE.greaterOrEqual(threeMonthsAgo))
|
|
||||||
|
|
||||||
val usersResult = this.osuApi.getUsersBatch(userIds)
|
val usersResult = this.osuApi.getUsersBatch(userIds)
|
||||||
|
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user