1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
|
package mx.trackermap.TrackerMap.controllers
import android.util.Log
import kotlinx.coroutines.DelicateCoroutinesApi
import kotlinx.coroutines.GlobalScope
import kotlinx.coroutines.flow.MutableStateFlow
import kotlinx.coroutines.launch
import mx.trackermap.TrackerMap.client.apis.GeofencesApi
import mx.trackermap.TrackerMap.client.apis.ReportsApi
import mx.trackermap.TrackerMap.client.models.EventInformation
import mx.trackermap.TrackerMap.client.models.Position
import mx.trackermap.TrackerMap.client.models.Stop
import mx.trackermap.TrackerMap.utils.ReportDates
@DelicateCoroutinesApi
class ReportController(
private val reportsApi: ReportsApi,
private val geofencesApi: GeofencesApi
) {
sealed class Report {
class PositionsReport(val positions: Array<Position>) : Report()
class EventsReport(val events: Array<EventInformation>) : Report()
class StopsReport(val stops: Array<Stop>) : Report()
class XlsxReport(val data: ByteArray) : Report()
object LoadingReport: Report()
}
enum class ReportType {
POSITIONS, EVENTS, STOPS
}
val reportFlow: MutableStateFlow<Report> = MutableStateFlow(Report.LoadingReport)
fun fetchReport(
deviceId: Int,
reportType: ReportType?,
reportPeriod: ReportDates.ReportPeriod?,
xlsx: Boolean = false,
eventTypes: List<EventInformation.Type> = listOf()
) {
if (reportType == null || reportPeriod == null) {
return
}
val (currentDate, previousDate) = ReportDates.getDates(reportPeriod)
Log.d("UnitReportsVM", "Current report type: $reportType")
Log.d("UnitReportsVM", "Current report period: $reportType")
Log.d("UnitReportsVM", "Current date:${currentDate}")
Log.d("UnitReportsVM", "Previous date:${previousDate}")
if (!xlsx) {
reportFlow.value = Report.LoadingReport
}
GlobalScope.launch {
when (reportType) {
ReportType.POSITIONS -> fetchPositions(deviceId, previousDate, currentDate, xlsx)
ReportType.EVENTS -> fetchEvents(deviceId, previousDate, currentDate, eventTypes, xlsx)
ReportType.STOPS -> fetchStops(deviceId, previousDate, currentDate, xlsx)
}
}
}
private suspend fun fetchPositions(
deviceId: Int,
from: String,
to: String,
xlsx: Boolean
) {
Log.d("UnitReportsVM", "Fetching positions")
if (!xlsx) {
val result = reportsApi.reportsRouteGet(from, to, deviceId)
Log.d("UnitReportsVM", "Positions report: $result")
reportFlow.value = Report.PositionsReport(result)
} else {
val result = reportsApi.reportsRouteGetXlsx(from, to, deviceId)
Log.d("UnitReportsVM", "Positions report: $result")
reportFlow.value = Report.XlsxReport(result)
}
}
private suspend fun fetchEvents(
deviceId: Int,
from: String,
to: String,
types: List<EventInformation.Type>,
xlsx: Boolean
) {
Log.d("UnitReportsVM", "Fetching events")
if (!xlsx) {
val positionsResult = reportsApi.reportsRouteGet(from, to, deviceId)
val eventsResult = reportsApi.reportsEventsGet(
from, to, EventInformation.reportTypesToStrings(types), deviceId
)
val geofencesResult = geofencesApi.geofencesGet(all = true)
val result = mutableListOf<EventInformation>()
eventsResult.forEach { event ->
result.add(EventInformation(
event = event,
position = positionsResult.find { it.id == event.positionId },
geofence = geofencesResult.find { it.id == event.geofenceId }
))
}
Log.d("UnitReportsVM", "Events report: $result")
reportFlow.value = Report.EventsReport(result.toTypedArray())
} else {
val result = reportsApi.reportsEventsGetXlsx(
from, to, EventInformation.reportTypesToStrings(types), deviceId
)
Log.d("UnitReportsVM", "Events report: $result")
reportFlow.value = Report.XlsxReport(result)
}
}
private suspend fun fetchStops(
deviceId: Int,
from: String,
to: String,
xlsx: Boolean
) {
Log.d("UnitReportsVM", "Fetching stops")
if (!xlsx) {
val result = reportsApi.reportsStopsGet(from, to, deviceId)
Log.d("UnitReportsVM", "Stops report: $result")
reportFlow.value = Report.StopsReport(result)
} else {
val result = reportsApi.reportsStopsGetXlsx(from, to, deviceId)
Log.d("UnitReportsVM", "Stops report: $result")
reportFlow.value = Report.XlsxReport(result)
}
}
}
|
