feat: 서울 버스 노선번호 구하기

DoTheBestMayB · DoTheBestMayB · commit 6f18180cf103 · 2022-11-24T17:29:17.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.GetBusLineResponse
 import com.stop.domain.model.route.seoul.bus.GetBusStationArsIdResponse
 import retrofit2.http.GET
 import retrofit2.http.Query
@@ -13,7 +14,13 @@ internal interface WsBusApiService {
         @Query("resultType") resultType: String = "json",
     ): NetworkResult<GetBusStationArsIdResponse>
 
+    @GET(GET_BUS_LINE_URL)
+    suspend fun getBusLine(
+        @Query("arsId") stationId: String,
+    ): NetworkResult<GetBusLineResponse>
+
     companion object {
         private const val GET_BUS_ARS_URL = "stationinfo/getStationByName"
+        private const val GET_BUS_LINE_URL = "stationinfo/getRouteByStation"
     }
 }
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.GetBusLineResponse
 import com.stop.domain.model.route.seoul.bus.GetBusStationArsIdResponse
 import com.stop.domain.model.route.tmap.RouteRequest
 import com.stop.domain.model.route.tmap.custom.Coordinate
@@ -18,5 +19,7 @@ internal interface RouteRemoteDataSource {
 
     suspend fun getSeoulBusStationArsId(stationName: String): GetBusStationArsIdResponse
 
+    suspend fun getSeoulBusLine(stationId: String): GetBusLineResponse
+
     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.GetBusLineResponse
 import com.stop.domain.model.route.seoul.bus.GetBusStationArsIdResponse
 import com.stop.domain.model.route.seoul.subway.SubwayStationResponse
 import com.stop.domain.model.route.tmap.RouteRequest
@@ -77,6 +78,17 @@ internal class RouteRemoteDataSourceImpl @Inject constructor(
         }
     }
 
+    override suspend fun getSeoulBusLine(stationId: String): GetBusLineResponse {
+        with(wsBusApiService.getBusLine(stationId)) {
+            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
@@ -3,6 +3,7 @@ package com.stop.data.repository
 import com.stop.data.remote.source.route.RouteRemoteDataSource
 import com.stop.domain.model.geoLocation.AddressType
 import com.stop.domain.model.route.gyeonggi.GetGyeonggiBusStationIdResponse
+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
 import com.stop.domain.model.route.tmap.custom.Coordinate
@@ -31,6 +32,10 @@ internal class RouteRepositoryImpl @Inject constructor(
         return remoteDataSource.getSeoulBusStationArsId(stationName)
     }
 
+    override suspend fun getSeoulBusLine(stationId: String): GetBusLineResponse {
+        return remoteDataSource.getSeoulBusLine(stationId)
+    }
+
     override suspend fun getGyeonggiBusStationId(stationName: String): GetGyeonggiBusStationIdResponse {
         return remoteDataSource.getGyeonggiBusStationId(stationName)
     }
diff --git a/domain/src/main/java/com/stop/domain/model/route/Area.kt b/domain/src/main/java/com/stop/domain/model/route/Area.kt
@@ -0,0 +1,13 @@
+package com.stop.domain.model.route
+
+enum class Area(val cityName: String) {
+    SEOUL("서울특별시"), GYEONGGI("경기도"), UN_SUPPORT_AREA("Unknown");
+
+    companion object {
+        fun getAreaByName(name: String): Area {
+            return values().firstOrNull {
+                it.cityName == name
+            } ?: UN_SUPPORT_AREA
+        }
+    }
+}
diff --git a/domain/src/main/java/com/stop/domain/model/route/TransportIdRequest.kt b/domain/src/main/java/com/stop/domain/model/route/TransportIdRequest.kt
@@ -4,18 +4,40 @@ import com.stop.domain.model.route.tmap.custom.Coordinate
 
 data class TransportIdRequest(
     val transportMoveType: TransportMoveType,
-    val id: String,
+    val stationId: String,
     val stationName: String,
     val coordinate: Coordinate,
     val stationType: Int,
+    val area: Area,
+    val lineId: String,
+    val lineName: String,
+    val term: Int, // 배차 간격, 서울 버스는 노선을 구하는 과정에서 얻을 수 있기 때문에 넣음
 ) {
-    fun changeId(newId: String): TransportIdRequest {
+    fun changeStationId(newStationId: String): TransportIdRequest {
         return TransportIdRequest(
             transportMoveType = transportMoveType,
-            id = newId,
+            stationId = newStationId,
             stationName = stationName,
             coordinate = coordinate,
             stationType = stationType,
+            area = area,
+            lineId = lineId,
+            lineName = lineName,
+            term = term,
+        )
+    }
+
+    fun changeLineId(newLineId: String, newTerm: Int?): TransportIdRequest {
+        return TransportIdRequest(
+            transportMoveType = transportMoveType,
+            stationId = stationId,
+            stationName = stationName,
+            coordinate = coordinate,
+            stationType = stationType,
+            area = area,
+            lineId = newLineId,
+            lineName = lineName,
+            term = newTerm ?: term,
         )
     }
 }
diff --git a/domain/src/main/java/com/stop/domain/model/route/seoul/bus/BusLineInfo.kt b/domain/src/main/java/com/stop/domain/model/route/seoul/bus/BusLineInfo.kt
@@ -0,0 +1,14 @@
+package com.stop.domain.model.route.seoul.bus
+
+import com.squareup.moshi.Json
+import com.squareup.moshi.JsonClass
+
+@JsonClass(generateAdapter = true)
+data class BusLineInfo(
+    @Json(name = "busRouteNm")
+    val busLineName: String,
+    @Json(name = "busRouteId")
+    val lineId: String,
+    @Json(name = "term")
+    val term: Int,
+)
diff --git a/domain/src/main/java/com/stop/domain/model/route/seoul/bus/GetBusLineResponse.kt b/domain/src/main/java/com/stop/domain/model/route/seoul/bus/GetBusLineResponse.kt
@@ -0,0 +1,8 @@
+package com.stop.domain.model.route.seoul.bus
+
+import com.squareup.moshi.JsonClass
+
+@JsonClass(generateAdapter = true)
+data class GetBusLineResponse(
+    val lineIdMsgBody: LineIdMsgBody,
+)
diff --git a/domain/src/main/java/com/stop/domain/model/route/seoul/bus/LineIdMsgBody.kt b/domain/src/main/java/com/stop/domain/model/route/seoul/bus/LineIdMsgBody.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 LineIdMsgBody(
+    @Json(name = "itemList")
+    val busLines: List<BusLineInfo>
+)
diff --git a/domain/src/main/java/com/stop/domain/repository/RouteRepository.kt b/domain/src/main/java/com/stop/domain/repository/RouteRepository.kt
@@ -2,6 +2,7 @@ package com.stop.domain.repository
 
 import com.stop.domain.model.geoLocation.AddressType
 import com.stop.domain.model.route.gyeonggi.GetGyeonggiBusStationIdResponse
+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
 import com.stop.domain.model.route.tmap.custom.Coordinate
@@ -14,6 +15,9 @@ interface RouteRepository {
     suspend fun reverseGeocoding(coordinate: Coordinate, addressType: AddressType): ReverseGeocodingResponse
 
     suspend fun getSubwayStationCd(stationId: String, stationName: String): String
+
     suspend fun getSeoulBusStationArsId(stationName: String): GetBusStationArsIdResponse
+    suspend fun getSeoulBusLine(stationId: String): GetBusLineResponse
+
     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
@@ -1,6 +1,7 @@
 package com.stop.domain.usecase.route
 
 import com.stop.domain.model.geoLocation.AddressType
+import com.stop.domain.model.route.Area
 import com.stop.domain.model.route.TransportIdRequest
 import com.stop.domain.model.route.TransportLastTimeInfo
 import com.stop.domain.model.route.TransportMoveType
@@ -15,13 +16,13 @@ internal class GetLastTransportTimeUseCaseImpl @Inject constructor(
     private val routeRepository: RouteRepository
 ) : GetLastTransportTimeUseCase {
 
-    class NoAppropriateDataException(override val message: String): Exception()
+    class NoAppropriateDataException(override val message: String) : Exception()
 
     private val allowedSubwayLineForUse = (SUBWAY_LINE_ONE..SUBWAY_LINE_EIGHT).toList()
 
     override suspend fun getLastTransportTime(itinerary: Itinerary): TransportLastTimeInfo? {
         // 승차지, 도착지, 고유 번호를 알아내는데 필요한 정보로만 구성된 데이터 클래스로 변환하기
-        val transportIdRequests =
+        var transportIdRequests =
             itinerary.routes.fold(listOf<TransportIdRequest>()) { transportIdRequests, route ->
                 when (route) {
                     is WalkRoute -> transportIdRequests
@@ -32,26 +33,49 @@ internal class GetLastTransportTimeUseCaseImpl @Inject constructor(
 
                         transportIdRequests + TransportIdRequest(
                             transportMoveType = transportMoveType,
-                            id = startStation.stationId,
+                            stationId = startStation.stationId,
                             stationName = startStation.stationName,
                             coordinate = startStation.coordinate,
                             stationType = route.routeType,
+                            area = getArea(startStation.coordinate),
+                            lineName = route.routeInfo,
+                            lineId = UNKNOWN_ID
                         )
                     }
                     else -> transportIdRequests
                 }
             }
 
-        // 공공데이터 포털에서 사용하는 버스, 지하철의 고유번호로 변환하는 작업
-        val transportLastTimeRequests = transportIdRequests.map { transportIdRequest ->
+        // 공공데이터 포털에서 사용하는 버스 정류소, 지하철 역의 고유번호로 변환하는 작업
+        transportIdRequests = transportIdRequests.map { transportIdRequest ->
             try {
-                transportIdRequest.changeId(getId(transportIdRequest))
+                transportIdRequest.changeStationId(getStationId(transportIdRequest))
             } catch (exception: NoAppropriateDataException) {
                 exception.printStackTrace()
                 return null
             }
         }
 
+        // 공공데이터 포털에서 사용하는 버스 노선, 지하철 역의 노선번호로 변환하는 작업
+        transportIdRequests = transportIdRequests.map { transportIdRequest ->
+            try {
+                when (transportIdRequest.transportMoveType) {
+                    TransportMoveType.BUS -> {
+                        when (transportIdRequest.area) {
+                            Area.SEOUL -> getSeoulBusLineId(transportIdRequest)
+                            Area.GYEONGGI -> TODO()
+                            Area.UN_SUPPORT_AREA -> throw NoAppropriateDataException(UN_SUPPORT_AREA)
+                        }
+                    }
+                    TransportMoveType.SUBWAY -> TODO()
+                }
+            } catch (exception: NoAppropriateDataException) {
+                exception.printStackTrace()
+                return null
+            }
+        }
+
+
         // 고유 번호로 승차지의 막차 시간 모두 알아내기
 //        val dataWithLastTime: List<Unit>
 
@@ -75,6 +99,11 @@ internal class GetLastTransportTimeUseCaseImpl @Inject constructor(
             }
         }
 
+    private suspend fun getArea(coordinate: Coordinate): Area {
+        val areaName =
+            routeRepository.reverseGeocoding(coordinate, AddressType.LOT_ADDRESS).addressInfo.cityDo
+
+        return Area.getAreaByName(areaName)
     }
 
     /**
@@ -87,11 +116,8 @@ internal class GetLastTransportTimeUseCaseImpl @Inject constructor(
     private suspend fun getBusIdUsedAtPublicApi(
         transportIdRequest: TransportIdRequest
     ): String {
-        val reverseGeocodingResponse =
-            routeRepository.reverseGeocoding(transportIdRequest.coordinate, AddressType.LOT_ADDRESS)
-
-        val arsId = when (reverseGeocodingResponse.addressInfo.cityDo) {
-            GYEONGGI_DO -> {
+        val arsId = when (transportIdRequest.area) {
+            Area.GYEONGGI -> {
                 if (transportIdRequest.stationName.contains("마을")) {
                     throw NoAppropriateDataException(GYEONGGI_REGION_BUS_NOT_SUPPORT)
                 }
@@ -100,18 +126,18 @@ internal class GetLastTransportTimeUseCaseImpl @Inject constructor(
 
                 findClosestGyeonggiBusStation(transportIdRequest, busStations)
             }
-            SEOUL -> {
+            Area.SEOUL -> {
                 val busStations =
                     routeRepository.getSeoulBusStationArsId(transportIdRequest.stationName)
                         .arsIdMsgBody
                         .busStations
 
                 findClosestSeoulBusStation(transportIdRequest, busStations)
             }
-            else -> throw NoAppropriateDataException(NO_SUPPORTING_CITY)
+            Area.UN_SUPPORT_AREA -> throw NoAppropriateDataException(UN_SUPPORT_AREA)
         }
 
-        if (arsId == UNKNOWN_ARS_ID) {
+        if (arsId == UNKNOWN_ID) {
             throw NoAppropriateDataException(NO_BUS_ARS_ID)
         }
         return arsId
@@ -180,7 +206,7 @@ internal class GetLastTransportTimeUseCaseImpl @Inject constructor(
             }
         }
 
-        return closestStation?.stationId?.toString() ?: UNKNOWN_ARS_ID
+        return closestStation?.stationId?.toString() ?: UNKNOWN_ID
     }
 
     private fun correctLongitudeValue(longitude: String): Int {
@@ -194,10 +220,11 @@ internal class GetLastTransportTimeUseCaseImpl @Inject constructor(
     companion object {
         private const val NOT_REGISTERED_STATION = "API를 지원하지 않는 전철역입니다."
         private const val NO_BUS_ARS_ID = "버스 정류소 고유 아이디가 없습니다."
-        private const val NO_SUPPORTING_CITY = "지원하지 않는 도시입니다."
+        private const val NO_BUS_LINE_ID = "버스 노선 고유 아이디가 없습니다."
+        private const val UN_SUPPORT_AREA = "지원하지 않는 지역입니다."
         private const val GYEONGGI_REGION_BUS_NOT_SUPPORT = "경기도 마을 버스 정보는 API에서 제공하지 않습니다."
 
-        private const val UNKNOWN_ARS_ID = "0"
+        private const val UNKNOWN_ID = "0"
         private const val KOREA_LONGITUDE = 127
         private const val KOREA_LATITUDE = 37
         private const val CORRECTION_VALUE = 10_000
