feat: 서울 버스 막차 시간 구하기

DoTheBestMayB · DoTheBestMayB · commit 728298f734b3 · 2022-11-24T19:57:18.000+09:00
diff --git a/data/src/main/java/com/stop/data/remote/network/WsBusApiService.kt b/data/src/main/java/com/stop/data/remote/network/WsBusApiService.kt
@@ -1,6 +1,7 @@
 package com.stop.data.remote.network
 
 import com.stop.data.remote.model.NetworkResult
+import com.stop.domain.model.route.seoul.bus.GetBusLastTimeResponse
 import com.stop.domain.model.route.seoul.bus.GetBusLineResponse
 import com.stop.domain.model.route.seoul.bus.GetBusStationArsIdResponse
 import retrofit2.http.GET
@@ -17,10 +18,19 @@ internal interface WsBusApiService {
     @GET(GET_BUS_LINE_URL)
     suspend fun getBusLine(
         @Query("arsId") stationId: String,
+        @Query("resultType") resultType: String = "json",
     ): NetworkResult<GetBusLineResponse>
 
+    @GET(GET_BUS_LAST_TIME_URL)
+    suspend fun getBusLastTime(
+        @Query("arsId") stationId: String,
+        @Query("busRouteId") lineId: String,
+        @Query("resultType") resultType: String = "json",
+    ): NetworkResult<GetBusLastTimeResponse>
+
     companion object {
         private const val GET_BUS_ARS_URL = "stationinfo/getStationByName"
         private const val GET_BUS_LINE_URL = "stationinfo/getRouteByStation"
+        private const val GET_BUS_LAST_TIME_URL = "stationinfo/getBustimeByStation"
     }
 }
diff --git a/data/src/main/java/com/stop/data/remote/source/route/RouteRemoteDataSource.kt b/data/src/main/java/com/stop/data/remote/source/route/RouteRemoteDataSource.kt
@@ -2,6 +2,7 @@ package com.stop.data.remote.source.route
 
 import com.stop.domain.model.geoLocation.AddressType
 import com.stop.domain.model.route.gyeonggi.GetGyeonggiBusStationIdResponse
+import com.stop.domain.model.route.seoul.bus.GetBusLastTimeResponse
 import com.stop.domain.model.route.seoul.bus.GetBusLineResponse
 import com.stop.domain.model.route.seoul.bus.GetBusStationArsIdResponse
 import com.stop.domain.model.route.tmap.RouteRequest
@@ -21,5 +22,7 @@ internal interface RouteRemoteDataSource {
 
     suspend fun getSeoulBusLine(stationId: String): GetBusLineResponse
 
+    suspend fun getSeoulBusLastTime(stationId: String, lineId: String): GetBusLastTimeResponse
+
     suspend fun getGyeonggiBusStationId(stationName: String): GetGyeonggiBusStationIdResponse
 }
diff --git a/data/src/main/java/com/stop/data/remote/source/route/RouteRemoteDataSourceImpl.kt b/data/src/main/java/com/stop/data/remote/source/route/RouteRemoteDataSourceImpl.kt
@@ -7,6 +7,7 @@ import com.stop.data.remote.network.TmapApiService
 import com.stop.data.remote.network.WsBusApiService
 import com.stop.domain.model.geoLocation.AddressType
 import com.stop.domain.model.route.gyeonggi.GetGyeonggiBusStationIdResponse
+import com.stop.domain.model.route.seoul.bus.GetBusLastTimeResponse
 import com.stop.domain.model.route.seoul.bus.GetBusLineResponse
 import com.stop.domain.model.route.seoul.bus.GetBusStationArsIdResponse
 import com.stop.domain.model.route.seoul.subway.SubwayStationResponse
@@ -89,6 +90,17 @@ internal class RouteRemoteDataSourceImpl @Inject constructor(
         }
     }
 
+    override suspend fun getSeoulBusLastTime(stationId: String, lineId: String): GetBusLastTimeResponse {
+        with(wsBusApiService.getBusLastTime(stationId, lineId)) {
+            return when(this) {
+                is NetworkResult.Success -> this.data
+                is NetworkResult.Failure -> throw IllegalArgumentException(this.message)
+                is NetworkResult.NetworkError -> throw this.exception
+                is NetworkResult.Unexpected -> throw this.exception
+            }
+        }
+    }
+
     override suspend fun getGyeonggiBusStationId(stationName: String): GetGyeonggiBusStationIdResponse {
         with(apisDataService.getBusStationId(stationName)) {
             return when (this) {
diff --git a/data/src/main/java/com/stop/data/repository/RouteRepositoryImpl.kt b/data/src/main/java/com/stop/data/repository/RouteRepositoryImpl.kt
@@ -14,13 +14,16 @@ import javax.inject.Inject
 
 internal class RouteRepositoryImpl @Inject constructor(
     private val remoteDataSource: RouteRemoteDataSource
-): RouteRepository {
+) : RouteRepository {
 
     override suspend fun getRoute(routeRequest: RouteRequest): RouteResponse {
         return remoteDataSource.getRoute(routeRequest)
     }
 
-    override suspend fun reverseGeocoding(coordinate: Coordinate, addressType: AddressType): ReverseGeocodingResponse {
+    override suspend fun reverseGeocoding(
+        coordinate: Coordinate,
+        addressType: AddressType
+    ): ReverseGeocodingResponse {
         return remoteDataSource.reverseGeocoding(coordinate, addressType)
     }
 
@@ -36,6 +39,14 @@ internal class RouteRepositoryImpl @Inject constructor(
         return remoteDataSource.getSeoulBusLine(stationId)
     }
 
+    override suspend fun getSeoulBusLastTime(stationId: String, lineId: String): String {
+        return remoteDataSource.getSeoulBusLastTime(stationId, lineId)
+            .lastTimeMsgBody
+            .lastTimes
+            .first()
+            .lastTime
+    }
+
     override suspend fun getGyeonggiBusStationId(stationName: String): GetGyeonggiBusStationIdResponse {
         return remoteDataSource.getGyeonggiBusStationId(stationName)
     }
diff --git a/domain/src/main/java/com/stop/domain/model/route/seoul/bus/GetBusLastTimeResponse.kt b/domain/src/main/java/com/stop/domain/model/route/seoul/bus/GetBusLastTimeResponse.kt
@@ -0,0 +1,10 @@
+package com.stop.domain.model.route.seoul.bus
+
+import com.squareup.moshi.Json
+import com.squareup.moshi.JsonClass
+
+@JsonClass(generateAdapter = true)
+data class GetBusLastTimeResponse(
+    @Json(name = "msgBody")
+    val lastTimeMsgBody: LastTimeMsgBody,
+)
diff --git a/domain/src/main/java/com/stop/domain/model/route/seoul/bus/LastTimeInfo.kt b/domain/src/main/java/com/stop/domain/model/route/seoul/bus/LastTimeInfo.kt
@@ -0,0 +1,10 @@
+package com.stop.domain.model.route.seoul.bus
+
+import com.squareup.moshi.Json
+import com.squareup.moshi.JsonClass
+
+@JsonClass(generateAdapter = true)
+data class LastTimeInfo(
+    @Json(name = "lastBusTm")
+    val lastTime: String
+)
diff --git a/domain/src/main/java/com/stop/domain/model/route/seoul/bus/LastTimeMsgBody.kt b/domain/src/main/java/com/stop/domain/model/route/seoul/bus/LastTimeMsgBody.kt
@@ -0,0 +1,10 @@
+package com.stop.domain.model.route.seoul.bus
+
+import com.squareup.moshi.Json
+import com.squareup.moshi.JsonClass
+
+@JsonClass(generateAdapter = true)
+data class LastTimeMsgBody(
+    @Json(name = "itemList")
+    val lastTimes: List<LastTimeInfo>
+)
diff --git a/domain/src/main/java/com/stop/domain/repository/RouteRepository.kt b/domain/src/main/java/com/stop/domain/repository/RouteRepository.kt
@@ -18,6 +18,7 @@ interface RouteRepository {
 
     suspend fun getSeoulBusStationArsId(stationName: String): GetBusStationArsIdResponse
     suspend fun getSeoulBusLine(stationId: String): GetBusLineResponse
+    suspend fun getSeoulBusLastTime(stationId: String, lineId: String): String
 
     suspend fun getGyeonggiBusStationId(stationName: String): GetGyeonggiBusStationIdResponse
 }
diff --git a/domain/src/main/java/com/stop/domain/usecase/route/GetLastTransportTimeUseCaseImpl.kt b/domain/src/main/java/com/stop/domain/usecase/route/GetLastTransportTimeUseCaseImpl.kt
@@ -39,7 +39,8 @@ internal class GetLastTransportTimeUseCaseImpl @Inject constructor(
                             stationType = route.routeType,
                             area = getArea(startStation.coordinate),
                             lineName = route.routeInfo,
-                            lineId = UNKNOWN_ID
+                            lineId = UNKNOWN_ID,
+                            term = NOT_YET_CALCULATED,
                         )
                     }
                     else -> transportIdRequests
@@ -77,27 +78,66 @@ internal class GetLastTransportTimeUseCaseImpl @Inject constructor(
 
 
         // 고유 번호로 승차지의 막차 시간 모두 알아내기
-//        val dataWithLastTime: List<Unit>
+        val dataWithLastTime: List<String> = transportIdRequests.map { transportIdRequest ->
+            when (transportIdRequest.transportMoveType) {
+                TransportMoveType.BUS -> getBusLastTransportTime(transportIdRequest)
+                TransportMoveType.SUBWAY -> getSubwayLastTransportTime(transportIdRequest)
+            }
+        }
 
         // 막차 시간 중 가장 빠른 시간과 dataWithLastTime을 가지는 데이터 클래스 반환하기
 //        return ReturnData(fastestTime, dataWithLastTime)
         return null
     }
 
-    private suspend fun getId(
-        transportIdRequest: TransportIdRequest,
-    ): String {
+    private fun getSubwayLastTransportTime(transportIdRequest: TransportIdRequest): String {
+        TODO()
+    }
+
+    private suspend fun getBusLastTransportTime(transportIdRequest: TransportIdRequest): String {
+        when (transportIdRequest.area) {
+            Area.GYEONGGI -> {
+                TODO()
+            }
+            Area.SEOUL -> {
+                return routeRepository.getSeoulBusLastTime(
+                    transportIdRequest.stationId,
+                    transportIdRequest.lineId
+                )
+            }
+            Area.UN_SUPPORT_AREA -> {
+                TODO()
+            }
+        }
+    }
+
+
+    private suspend fun getSeoulBusLineId(transportIdRequest: TransportIdRequest): TransportIdRequest {
+        val busName = transportIdRequest.lineName.split(":")[1]
+        val line =
+            routeRepository.getSeoulBusLine(transportIdRequest.stationId).lineIdMsgBody.busLines.firstOrNull {
+                it.busLineName == busName
+            } ?: throw NoAppropriateDataException(NO_BUS_LINE_ID)
+
+        return transportIdRequest.changeLineId(line.lineId, line.term)
+    }
+
+    private suspend fun getStationId(transportIdRequest: TransportIdRequest): String {
         return when (transportIdRequest.transportMoveType) {
             TransportMoveType.SUBWAY -> {
                 if (allowedSubwayLineForUse.contains(transportIdRequest.stationType).not()) {
                     throw NoAppropriateDataException(NOT_REGISTERED_STATION)
                 }
-                routeRepository.getSubwayStationCd(transportIdRequest.id, transportIdRequest.stationName)
+                routeRepository.getSubwayStationCd(
+                    transportIdRequest.stationId,
+                    transportIdRequest.stationName
+                )
             }
             TransportMoveType.BUS -> {
                 getBusIdUsedAtPublicApi(transportIdRequest)
             }
         }
+    }
 
     private suspend fun getArea(coordinate: Coordinate): Area {
         val areaName =
@@ -173,7 +213,7 @@ internal class GetLastTransportTimeUseCaseImpl @Inject constructor(
             }
         }
 
-        return closestStation?.arsId ?: UNKNOWN_ARS_ID
+        return closestStation?.arsId ?: UNKNOWN_ID
     }
 
     private fun findClosestGyeonggiBusStation(
@@ -225,6 +265,7 @@ internal class GetLastTransportTimeUseCaseImpl @Inject constructor(
         private const val GYEONGGI_REGION_BUS_NOT_SUPPORT = "경기도 마을 버스 정보는 API에서 제공하지 않습니다."
 
         private const val UNKNOWN_ID = "0"
+        private const val NOT_YET_CALCULATED = 0
         private const val KOREA_LONGITUDE = 127
         private const val KOREA_LATITUDE = 37
         private const val CORRECTION_VALUE = 10_000

Original file line number	Diff line number	Diff line change
`@@ -18,6 +18,7 @@ interface RouteRepository {`
`18`	`18`
`19`	`19`	`suspend fun getSeoulBusStationArsId(stationName: String): GetBusStationArsIdResponse`
`20`	`20`	`suspend fun getSeoulBusLine(stationId: String): GetBusLineResponse`
	`21`	`+ suspend fun getSeoulBusLastTime(stationId: String, lineId: String): String`
`21`	`22`
`22`	`23`	`suspend fun getGyeonggiBusStationId(stationName: String): GetGyeonggiBusStationIdResponse`
`23`	`24`	`}`