Реалізація відстеження активів через RFID у мобільних додатках
Відстеження активів через RFID відрізняється від інвентаризації. Інвентаризація відповідає на питання «що є на складі зараз». Відстеження активів відповідає на питання «де був актив весь цей час, хто його переміщував та коли». Потребує історії подій, прив'язки до точок читання (воротні антени, стаціонарні зчитувачі) та мобільний додаток як інструмент верифікації та вибіркового пошуку.
Архітектура на основі подій
Кожне читання тегу — подія з метаданими:
data class AssetReadEvent(
val epc: String,
val readerLocation: String, // ID антени/зчитувача
val timestamp: Long,
val rssi: Int, // сигнал: приблизна дистанція
val direction: ReadDirection?, // ENTRY / EXIT для воротних зчитувачів
val operatorId: String? // хто зробив ручне читання
)
enum class ReadDirection { ENTRY, EXIT, UNKNOWN }
Мобільний додаток генерує події з operatorId та GPS/indoor-координатами. Воротні зчитувачі (Impinj Speedway, Zebra FX9600) генерують события через LLRP або REST API. Все сходиться в одну чергу подій на бекенді.
Пошук конкретного активу
Найбільш часта операція в мобільному додатку — «знайти актив XYZ на цьому складі». RFID-зчитувач переходить у режим «proximity search»: показує RSSI конкретного тегу, допомагаючи звузити зону пошуку:
class AssetSearchSession(
private val rfidReader: RfidReader,
private val targetEpc: String
) {
private val _proximity = MutableStateFlow(ProximityLevel.UNKNOWN)
val proximity: StateFlow<ProximityLevel> = _proximity.asStateFlow()
fun start() {
rfidReader.setInventoryFilter(epcFilter = targetEpc) // читати лише цільовий тег
rfidReader.startContinuousInventory(onTag = { tag ->
if (tag.epc == targetEpc) {
_proximity.value = rssiToProximity(tag.peakRSSI)
}
})
}
private fun rssiToProximity(rssi: Int): ProximityLevel = when {
rssi > -55 -> ProximityLevel.VERY_CLOSE // < 0.5м
rssi > -65 -> ProximityLevel.CLOSE // 0.5–1.5м
rssi > -75 -> ProximityLevel.MEDIUM // 1.5–3м
else -> ProximityLevel.FAR // > 3м
}
}
Фільтр за EPC (setInventoryFilter) критичний — без нього зчитувач читає всі теги в зоні і засоряє потік даних. Специфічні API фільтрації залежать від SDK зчитувача: Zebra RFID SDK — SLFlag, TagFilter; Chainway SDK — FilterParam.
Історія переміщень
// Room entities для історії активів
@Entity(tableName = "asset_events", indices = [Index("epc"), Index("timestamp")])
data class AssetEventEntity(
@PrimaryKey(autoGenerate = true) val id: Long = 0,
val epc: String,
val eventType: String, // "scan", "checkpoint", "entry", "exit"
val locationId: String,
val locationName: String,
val operatorId: String?,
val rssi: Int?,
val timestamp: Long,
val synced: Boolean = false
)
@Dao
interface AssetEventDao {
@Query("SELECT * FROM asset_events WHERE epc = :epc ORDER BY timestamp DESC LIMIT 50")
fun getAssetHistory(epc: String): Flow<List<AssetEventEntity>>
@Query("SELECT * FROM asset_events WHERE synced = 0 ORDER BY timestamp ASC")
suspend fun getUnsynced(): List<AssetEventEntity>
}
Історія на пристрої — лише останні N подій. Повна історія — на сервері. WorkManager синхронізує несинхронізовані события при появі мережі.
Інтеграція з ERP/WMS
Відстеження активів без інтеграції з обліковою системою — половина рішення. REST API для синхронізації:
interface AssetTrackingApi {
@POST("events/batch")
suspend fun pushEvents(@Body events: List<AssetEventDto>): Response<BatchResult>
@GET("assets/{epc}")
suspend fun getAssetInfo(@Path("epc") epc: String): Response<AssetInfoDto>
@GET("assets/{epc}/location")
suspend fun getLastKnownLocation(@Path("epc") epc: String): Response<LocationDto>
}
getLastKnownLocation — для верифікації: оператор сканує тег, додаток одразу показує де система його останній раз бачила. Розбіжність між реальним та системним місцеположенням — червоний прапор для логіста.
Терміни
Мобільний додаток пошуку активів + історія подій + REST-синхронізація з WMS: 5 днів. Повне рішення включаючи настройку стаціонарних зчитувачів Impinj/Zebra, LLRP-інтеграцію та серверну шину подій: 2–4 тижні.