@@ -2,6 +2,8 @@ package gogo.gogobetting.infra.batch.service
22
33import gogo.gogobetting.domain.batch.detail.persistence.BatchDetail
44import gogo.gogobetting.domain.batch.detail.persistence.BatchDetailRepository
5+ import gogo.gogobetting.domain.batch.root.event.MatchBatchEvent
6+ import gogo.gogobetting.domain.batch.root.event.StudentBettingDto
57import gogo.gogobetting.domain.batch.root.persistence.BatchRepository
68import gogo.gogobetting.domain.betting.result.persistence.BettingResultTable
79import gogo.gogobetting.domain.betting.root.persistence.BettingRepository
@@ -21,6 +23,7 @@ import org.springframework.batch.item.ItemWriter
2123import org.springframework.beans.factory.annotation.Value
2224import org.springframework.data.repository.findByIdOrNull
2325import org.springframework.stereotype.Component
26+ import java.util.*
2427import javax.sql.DataSource
2528import kotlin.math.ceil
2629
@@ -86,23 +89,23 @@ class BettingResultWriter(
8689 )
8790 )
8891
89- // val successList = accumulated.filter { it.isPredicted }
90- // .map {
91- // val studentId = bettingRepository.findByIdOrNull(it.bettingId)!!.studentId
92- // StudentBettingDto(studentId, it.earnedPoint)
93- // }
94- //
95- // val event = MatchBatchEvent(
96- // id = UUID.randomUUID().toString(),
97- // batchId = batchId,
98- // matchId = matchId,
99- // victoryTeamId = winTeamId,
100- // aTeamScore = aTeamScore,
101- // bTeamScore = bTeamScore,
102- // students = successList
103- // )
104- //
105- // log.info("published betting batch application event: {}", event.id)
106- // batchPublisher.publishBettingBatchEvent(event)
92+ val successList = accumulated.filter { it.isPredicted }
93+ .map {
94+ val studentId = bettingRepository.findByIdOrNull(it.bettingId)!! .studentId
95+ StudentBettingDto (studentId, it.earnedPoint)
96+ }
97+
98+ val event = MatchBatchEvent (
99+ id = UUID .randomUUID().toString(),
100+ batchId = batchId,
101+ matchId = matchId,
102+ victoryTeamId = winTeamId,
103+ aTeamScore = aTeamScore,
104+ bTeamScore = bTeamScore,
105+ students = successList
106+ )
107+
108+ log.info(" published betting batch application event: {}" , event.id)
109+ batchPublisher.publishBettingBatchEvent(event)
107110 }
108111}
0 commit comments