Реализация телематики транспорта в мобильном IoT-приложении

Реализация телематики транспорта в мобильном IoT-приложении

Транспортная телематика — это сбор данных с движущихся объектов: координаты GPS, скорость, пробег, поведение водителя (резкие ускорения, торможения), расход топлива, температурный режим кузова для рефрижераторов. Данные идут с бортового трекера через GPRS/LTE на сервер, мобильное приложение — инструмент диспетчера или менеджера автопарка. Разработка здесь делится на три слоя: протокол трекера, серверная платформа, мобильный клиент.

Протоколы GPS-трекеров

Трекеры говорят на нескольких распространённых протоколах:

Для парсинга трекерных протоколов используют Traccar — open-source серверная платформа, которая знает 200+ протоколов. Traccar разворачивается на сервере, принимает данные от трекеров и предоставляет REST API + WebSocket для мобильных клиентов. Это самый разумный путь для старта.

Traccar API: интеграция на Android

// Retrofit интерфейс к Traccar API
interface TraccarApi {
    @GET("devices")
    suspend fun getDevices(
        @Query("all") all: Boolean = false,
        @Query("groupId") groupId: Long? = null,
    ): List<Device>

    @GET("positions")
    suspend fun getLatestPositions(
        @Query("deviceId") deviceId: Long? = null,
    ): List<Position>

    @GET("reports/trips")
    suspend fun getTrips(
        @Query("deviceId") deviceId: Long,
        @Query("from") from: String,  // ISO 8601
        @Query("to") to: String,
    ): List<Trip>
}

data class Position(
    val id: Long,
    val deviceId: Long,
    val latitude: Double,
    val longitude: Double,
    val speed: Double,     // узлы, конвертируем в км/ч * 1.852
    val course: Double,
    val altitude: Double,
    val accuracy: Double,
    val fixTime: String,
    val valid: Boolean,
    val attributes: Map<String, Any>,  // батарея, зажигание, пробег и т.д.
)

Real-time обновления через WebSocket Traccar:

class TraccarWebSocketClient(private val baseUrl: String, private val token: String) {
    private val okHttpClient = OkHttpClient.Builder()
        .readTimeout(0, TimeUnit.MILLISECONDS)  // бесконечный timeout для WS
        .build()

    fun connect(): Flow<TraccarEvent> = callbackFlow {
        val request = Request.Builder()
            .url("wss://${baseUrl}/api/socket")
            .header("Cookie", "JSESSIONID=$token")
            .build()

        val ws = okHttpClient.newWebSocket(request, object : WebSocketListener() {
            override fun onMessage(webSocket: WebSocket, text: String) {
                val event = json.decodeFromString<TraccarSocketMessage>(text)
                event.positions?.forEach { trySend(TraccarEvent.Position(it)) }
                event.devices?.forEach { trySend(TraccarEvent.DeviceUpdate(it)) }
                event.events?.forEach { trySend(TraccarEvent.Alert(it)) }
            }

            override fun onFailure(webSocket: WebSocket, t: Throwable, response: Response?) {
                close(t)
            }
        })
        awaitClose { ws.close(1000, "Closed") }
    }
}

Карта с живыми метками

Google Maps SDK на Android с кастомными маркерами-автомобилями:

class FleetMapFragment : Fragment() {
    private lateinit var map: GoogleMap
    private val vehicleMarkers = HashMap<Long, Marker>()

    private fun updateVehiclePosition(position: Position) {
        val latLng = LatLng(position.latitude, position.longitude)
        val marker = vehicleMarkers[position.deviceId]

        if (marker == null) {
            val newMarker = map.addMarker(
                MarkerOptions()
                    .position(latLng)
                    .icon(getBitmapDescriptor(R.drawable.ic_truck, position.course))
                    .title(getVehicleName(position.deviceId))
            )
            vehicleMarkers[position.deviceId] = newMarker!!
        } else {
            // Анимируем перемещение маркера
            animateMarker(marker, latLng, position.course)
        }
    }

    private fun animateMarker(marker: Marker, to: LatLng, bearing: Float) {
        val animator = ValueAnimator.ofFloat(0f, 1f).apply {
            duration = 1000
            interpolator = LinearInterpolator()
        }
        val from = marker.position
        animator.addUpdateListener { anim ->
            val fraction = anim.animatedValue as Float
            marker.position = LatLng(
                from.latitude + (to.latitude - from.latitude) * fraction,
                from.longitude + (to.longitude - from.longitude) * fraction,
            )
            marker.rotation = bearing
        }
        animator.start()
    }
}

Анимация маркера между позициями — деталь, которую часто упускают. Без неё иконка прыгает по карте.

Аналитика поведения водителя

Резкие ускорения (> 0.3g), торможения (> 0.4g), резкие повороты — события из акселерометра трекера, приходят в attributes позиции. Scoring водителя считается на бэкенде, в приложение отдаётся агрегат за день/неделю: процент времени с превышением скорости, количество жёстких событий, рейтинг из 100.

Геозоны — зоны на карте, при въезде/выезде из которых формируется событие. Добавление геозоны из мобильного приложения: рисуем полигон на карте, отправляем координаты в Traccar Geofences API.

Офлайн и кеш

Диспетчер смотрит в приложение постоянно, и если сервер недоступен 5 минут — нельзя показывать пустую карту. Кешируем последние позиции всех машин в Room. При старте показываем кеш, обновляем через WebSocket. Timestamp последнего обновления виден в заголовке.

Разработка диспетчерского приложения с картой, real-time позициями через Traccar и отчётами по поездкам: 5-8 недель. Полноценная телематическая платформа с аналитикой водителей, геозонами и интеграцией CAN-данных: 3-4 месяца. Стоимость рассчитывается индивидуально после анализа парка устройств и требований к платформе.