Le corse in piscina condivisa sono viaggi condivise tra più consumatori che condividono contemporaneamente il veicolo. Ciò significa che i viaggi sono simultanei, non indipendenti. Il funzionamento è simile a quello delle navette aeroportuali, con l'eccezione che l'autista può anche far scendere i consumatori lungo il percorso.
La differenza principale tra una piscina condivisa e un viaggio a destinazione singola è che, in un viaggio con piscina condivisa, l'operatore di viaggio può trasportare più di un viaggiatore contemporaneamente.
Questo tutorial illustra la procedura per creare un viaggio in piscina condivisa. Mostra anche come integrare la corsa con la tua applicazione per i consumatori in modo che i clienti possano visualizzare lo stato di avanzamento del viaggio dai loro telefoni. Questa integrazione viene eseguita utilizzando l'SDK consumer.
Passaggio 1: Crea un veicolo in Fleet Engine
I veicoli sono oggetti che rappresentano i veicoli della tua flotta. Devi crearle in Fleet Engine per poterli monitorare nell'app consumer.
Puoi creare un veicolo seguendo uno dei due approcci seguenti:
- gRPC
- Chiama il metodo
CreateVehicle()
con il messaggio di richiestaCreateVehicleRequest
. Devi disporre dei privilegi di super user Fleet Engine per chiamareCreateVehicle()
. - REST
- Chiama il numero
https://fleetengine.googleapis.com/v1/providers.vehicles.create
.
Avvertenze
Durante la creazione di un veicolo, si applicano le seguenti avvertenze.
Assicurati di impostare lo stato iniziale del veicolo su
OFFLINE
. In questo modo, Fleet Engine può rilevare il tuo veicolo per la corrispondenza della corsa.Il valore
provider_id
del veicolo deve corrispondere all'ID del progetto Google Cloud che contiene gli account di servizio utilizzati per chiamare Fleet Engine. Sebbene più account di servizio possano accedere a Fleet Engine per lo stesso provider di ridesharing, attualmente Fleet Engine non supporta gli account di servizio di diversi progetti Google Cloud che accedono agli stessi veicoli.La risposta restituita da
CreateVehicle()
contiene l'istanzaVehicle
. L'istanza viene eliminata dopo sette giorni se non è stata aggiornata utilizzandoUpdateVehicle()
. Devi chiamareGetVehicle()
prima di chiamareCreateVehicle()
per verificare che il veicolo non esista già. SeGetVehicle()
restituisce un erroreNOT_FOUND
, devi procedere con la chiamata aCreateVehicle()
. Per saperne di più, consulta Veicoli e loro ciclo di vita.
Esempio
Il seguente esempio di codice del provider mostra come creare un veicolo in Fleet Engine.
static final String PROJECT_ID = "my-rideshare-co-gcp-project";
VehicleServiceBlockingStub vehicleService = VehicleService.newBlockingStub(channel);
String parent = "providers/" + PROJECT_ID;
Vehicle vehicle = Vehicle.newBuilder()
.setVehicleState(VehicleState.OFFLINE) // Initial state
.addSupportedTripTypes(TripType.EXCLUSIVE)
.setMaximumCapacity(4)
.setVehicleType(VehicleType.newBuilder().setCategory(VehicleType.Category.AUTO))
.build();
CreateVehicleRequest createVehicleRequest = CreateVehicleRequest.newBuilder()
.setParent(parent)
.setVehicleId("8241890") // Vehicle ID assigned by solution provider.
.setVehicle(vehicle) // Initial state.
.build();
// The Vehicle is created in the OFFLINE state, and no initial position is
// provided. When the driver app calls the rideshare provider, the state can be
// set to ONLINE, and the driver app updates the vehicle location.
try {
Vehicle createdVehicle = vehicleService.createVehicle(createVehicleRequest);
} catch (StatusRuntimeException e) {
Status s = e.getStatus();
switch (s.getCode()) {
case ALREADY_EXISTS:
break;
case PERMISSION_DENIED:
break;
}
return;
}
Per creare un Vehicle
che supporti le corse shared-pool, devi aggiungere TripType.SHARED
all'elenco dei tipi di corsa supportati nell'oggetto Vehicle
passato a CreateVehicleRequest
.
Vehicle vehicle = Vehicle.newBuilder()
.setVehicleState(VehicleState.OFFLINE)
.addSupportedTripTypes(TripType.SHARED)
.setMaximumCapacity(4)
.setVehicleType(VehicleType.newBuilder().setCategory(VehicleType.Category.AUTO))
.build();
Passaggio 2: Attiva il monitoraggio della posizione
Il monitoraggio della posizione si riferisce al monitoraggio della posizione del veicolo durante il viaggio, in cui l'app del conducente invia dati di telemetria a Fleet Engine, che contiene la posizione attuale del veicolo. Questo flusso di informazioni sulla posizione costantemente aggiornato viene utilizzato per comunicare lo stato di avanzamento del veicolo lungo il percorso. Quando attivi il monitoraggio della posizione, l'app del conducente inizia a inviare questa telemetria con una frequenza predefinita di una volta ogni cinque secondi.
Per abilitare il monitoraggio della posizione per Android e iOS:
Chiama il metodo SDK Driver per Android
enableLocationTracking()
.Imposta l'SDK Driver per la proprietà booleana per iOS
locationTrackingEnabled
sutrue
.
Esempio
Il seguente esempio di codice mostra come attivare il monitoraggio della posizione.
Java
RidesharingVehicleReporter vehicleReporter = ...;
vehicleReporter.enableLocationTracking();
Kotlin
val vehicleReporter = ...
vehicleReporter.enableLocationTracking()
Swift
vehicleReporter.locationTrackingEnabled = true
Objective-C
_vehicleReporter.locationTrackingEnabled = YES;
Passaggio 3: Impostare lo stato del veicolo su online
Metti un veicolo in servizio (ovvero, per renderlo disponibile all'uso) impostandone lo stato su online, ma non potrai farlo finché non avrai attivato il monitoraggio della posizione.
Per impostare lo stato del veicolo su Online per Android e iOS:
Chiama il metodo SDK Driver per Android
setVehicleState(VehicleState.ONLINE)
.Chiama l'SDK Driver per iOS
vehicleReporter.update(.online)
.
Esempio
Il seguente esempio di codice mostra come impostare lo stato del veicolo su ONLINE
.
Java
vehicleReporter.setVehicleState(VehicleState.ONLINE);
Kotlin
vehicleReporter.setVehicleState(VehicleState.ONLINE)
Swift
vehicleReporter.update(.online)
Objective-C
[_vehicleReporter updateVehicleState:GMTDVehicleStateOnline];
Passaggio 4: Crea una corsa in Fleet Engine
Per creare un viaggio in piscina condivisa, devi creare un oggetto Trip
come faresti per un viaggio con una sola destinazione.
Una corsa è un oggetto che rappresenta un viaggio, ovvero una raccolta di punti con coordinate geografiche, tra cui origine, waypoint e punti di discesa.
Devi creare un oggetto Trip
per ogni richiesta di viaggio in modo che la richiesta possa essere associata a un veicolo e poi monitorata.
- Puoi creare un viaggio chiamando il metodo
CreateTrip()
con il messaggio di richiestaCreateTripRequest
.
Fornisci attributi obbligatori
I seguenti campi sono obbligatori per creare un viaggio in piscina condivisa.
parent
- Una stringa che include l'ID provider. Deve essere uguale all'ID del progetto Google Cloud che contiene gli account di servizio utilizzati per chiamare Fleet Engine
trip_id
- Una stringa creata da te che identifica in modo univoco questo viaggio.
trip
Trip
oggetto da creare.
Questi campi devono essere impostati nell'oggetto Trip
passato a CreateTripRequest
:
trip_type
TripType.SHARED
pickup_point
- Il punto di partenza della corsa.
dropoff_point
- Il punto di consegna della corsa. Questo campo non è obbligatorio durante la creazione del viaggio e può essere impostato in un secondo momento chiamando il numero
UpdateTrip
.
Esempio
Il seguente esempio di integrazione backend mostra come creare una corsa e assegnarla automaticamente a un veicolo come pool condiviso.
// Vehicle with VEHICLE_ID ID is already created and it is assigned Trip A.
static final String PROJECT_ID = "my-rideshare-co-gcp-project";
static final String TRIP_ID = "shared-trip-A";
static final String VEHICLE_ID = "your-vehicle-id";
static final String TRIP_A_ID = "trip-a-id";
static final String TRIP_B_ID = "trip-b-id";
TripServiceBlockingStub tripService = TripService.newBlockingStub(channel);
String parent = "providers/" + PROJECT_ID;
LatLng tripBPickup =
LatLng.newBuilder().setLatitude(-12.12314).setLongitude(88.142123).build();
LatLng tripBDropoff =
LatLng.newBuilder().setLatitude(-14.12314).setLongitude(90.142123).build();
TerminalLocation tripBPickupTerminalLocation =
TerminalLocation.newBuilder().setPoint(tripBPickup).build();
TerminalLocation tripBDropoffTerminalLocation =
TerminalLocation.newBuilder().setPoint(tripBDropoff).build();
// TripA already exists and it's assigned to a vehicle with VEHICLE_ID ID.
Trip tripB = Trip.newBuilder()
.setTripType(TripType.SHARED)
.setVehicleId(VEHICLE_ID)
.setPickupPoint(tripBPickupTerminalLocation)
.setDropoffPoint(tripBDropoffTerminalLocation)
.addAllVehicleWaypoints(
// This is where you define the arrival order for unvisited waypoints.
// If you don’t specify an order, then the Fleet Engine adds Trip B’s
// waypoints to the end of Trip A’s.
ImmutableList.of(
// Trip B’s pickup point.
TripWaypoint.newBuilder()
.setLocation(tripBPickupTerminalLocation)
.setTripId(TRIP_B_ID)
.setWaypointType(WaypointType.PICKUP_WAYPOINT_TYPE)
.build(),
// Trip A’s drop-off point.
TripWaypoint.newBuilder()
.setLocation(tripA.getDropoffPoint())
.setTripId(TRIP_A_ID)
.setWaypointType(WaypointType.DROP_OFF_WAYPOINT_TYPE)
.build(),
// Trip B’s drop-off point.
TripWaypoint.newBuilder()
.setLocation(tripBDropoffTerminalLocation)
.setTripId(TRIP_B_ID)
.setWaypointType(WaypointType.DROP_OFF_WAYPOINT_TYPE)
.build()))
.build();
// Create Trip request
CreateTripRequest createTripRequest = CreateTripRequest.newBuilder()
.setParent(parent)
.setTripId(TRIP_B_ID)
.setTrip(tripB)
.build();
try {
// createdTrip.remainingWaypoints will contain shared-pool waypoints.
// [tripB.pickup, tripA.dropoff, tripB.dropoff]
Trip createdTrip = tripService.createTrip(createTripRequest);
} catch (StatusRuntimeException e) {
Status s = e.getStatus();
switch (s.getCode()) {
case ALREADY_EXISTS:
break;
case PERMISSION_DENIED:
break;
}
return;
}
Passaggio 5: Aggiornare la corsa con l'ID veicolo e i waypoint
Devi configurare la corsa con un ID veicolo in modo che Fleet Engine possa monitorare il veicolo lungo il suo percorso.
- Puoi aggiornare la corsa con l'ID veicolo chiamando l'endpoint
UpdateTrip
con unUpdateTripRequest
. Utilizza il campoupdate_mask
per specificare che stai aggiornando l'ID veicolo.
Devi introdurre un ordine per i waypoint non visitati nella raccolta
di waypoint dei veicoli (Trip.vehicle_waypoints
). Fleet Engine utilizza questo elenco per
aggiornare automaticamente i waypoint della corsa per tutte le corse nella piscina condivisa.
Ad esempio, prendi in considerazione due corse in piscina condivisa: Corsa A e
Corsa B. La corsa A raggiunge il punto di partenza. Poi la Corsa B viene aggiunta allo
stesso veicolo. In un UpdateTripRequest
per Trip B,
imposti vehicleId
e Trip.vehicle_waypoints
sull'ordine dei waypoint ottimale: B Ritiro
→ A Abbandono →
B Abbandono.
- La chiamata a
getVehicle()
restituisce un elenco di waypoint rimanenti (remainingWaypoints
) che contiene
B Ritiro → A Abbandono → B Abbandono. getTrip()
o il callbackonTripRemainingWaypointsUpdated
per la Trip A restituiscono un elenco dei waypoint rimanenti (remainingWaypoints
) che contiene B Ritiro → A Abbandono.getTrip()
o il callbackonTripRemainingWaypointsUpdated
per Trip B restituisce un elenco di waypoint rimanenti (remainingWaypoints
) che contiene B Ritiro → A Abbandono → B Abbandono.
Esempio
Il seguente esempio di integrazione backend mostra come aggiornare una corsa con l'ID veicolo e i waypoint per due corse in pool condiviso.
static final String PROJECT_ID = "my-rideshare-co-gcp-project";
static final String TRIP_A_ID = "share-trip-A";
static final String TRIP_B_ID = "share-trip-B";
static final String VEHICLE_ID = "Vehicle";
String tripName = "providers/" + PROJECT_ID + "/trips/" + TRIP_B_ID;
// Get Trip A and Trip B objects from either the Fleet Engine or storage.
Trip tripA = …;
Trip tripB = …;
TripServiceBlockingStub tripService = TripService.newBlockingStub(channel);
// The trip settings to update.
Trip trip = Trip.newBuilder()
.setVehicleId(VEHICLE_ID)
.addAllVehicleWaypoints(
// This is where you define the arrival order for unvisited waypoints.
// If you don’t specify an order, then the Fleet Engine adds Trip B’s
// waypoints to the end of Trip A’s.
ImmutableList.of(
// Trip B’s pickup point.
TripWaypoint.newBuilder()
.setLocation(tripB.getPickupPoint())
.setTripId(TRIP_B_ID)
.setWaypointType(WaypointType.PICKUP_WAYPOINT_TYPE)
.build(),
// Trip A’s drop-off point.
TripWaypoint.newBuilder()
.setLocation(tripA.getDropoffPoint())
.setTripId(TRIP_A_ID)
.setWaypointType(WaypointType.DROP_OFF_WAYPOINT_TYPE)
.build(),
// Trip B’s drop-off point.
TripWaypoint.newBuilder()
.setLocation(tripB.getDropoffPoint())
.setTripId(TRIP_B_ID)
.setWaypointType(WaypointType.DROP_OFF_WAYPOINT_TYPE)
.build()))
.build();
// The trip update request.
UpdateTripRequest updateTripRequest = UpdateTripRequest.newBuilder()
.setName(tripName)
.setTrip(trip)
.setUpdateMask(FieldMask.newBuilder()
.addPaths("vehicle_id")
.addPaths("vehicle_waypoints"))
.build();
// Error handling. If Fleet Engine has both a trip and vehicle with the IDs,
// and if the credentials validate, and if the given vehicle_waypoints list
// is valid, then the service updates the trip.
try {
Trip updatedTrip = tripService.updateTrip(updateTripRequest);
} catch (StatusRuntimeException e) {
Status s = e.getStatus();
switch (s.getCode()) {
case NOT_FOUND: // Either the trip or vehicle does not exist.
break;
case PERMISSION_DENIED:
break;
case INVALID_REQUEST: // vehicle_waypoints is invalid.
break;
}
return;
}
Passaggio 6: Ascolta gli aggiornamenti sui percorsi nell'app per consumatori
Per Android, puoi ascoltare gli aggiornamenti dei dati di un viaggio ottenendo un oggetto
TripModel
daTripModelManager
e registrando un listenerTripModelCallback
.Per iOS, puoi ascoltare gli aggiornamenti dei dati di una corsa ottenendo un oggetto
GMTCTripModel
daGMTCTripService
e registrando un abbonatoGMTCTripModelSubscriber
.
Un listener TripModelCallback
e un iscritto GMTCTripModelSubscriber
consentono alla tua app di ricevere aggiornamenti periodici
sullo avanzamento del percorso a ogni aggiornamento in base all'intervallo di aggiornamento automatico.
Solo i valori che cambiano possono attivare il callback. In caso contrario, il callback rimane silenzioso.
I metodi TripModelCallback.onTripUpdated()
e tripModel(_:didUpdate:updatedPropertyFields:)
vengono sempre chiamati, indipendentemente da eventuali modifiche ai dati.
Esempio 1
Il seguente esempio di codice mostra come ottenere un valore TripModel
da TripModelManager
/GMTCTripService
e impostare un listener.
Java
// Start journey sharing after a trip has been created via Fleet Engine.
TripModelManager tripModelManager = consumerApi.getTripModelManager();
// Get a TripModel object.
TripModel tripModel = tripModelManager.getTripModel(tripName);
// Register a listener on the trip.
TripModelCallback tripCallback = new TripModelCallback() {
...
};
tripModel.registerTripCallback(tripCallback);
// Set the refresh interval.
TripModelOptions tripModelOptions = TripModelOptions.builder()
.setRefreshInterval(5000) // interval in milliseconds, so 5 seconds
.build();
tripModel.setTripModelOptions(tripModelOptions);
// The trip stops auto-refreshing when all listeners are unregistered.
tripModel.unregisterTripCallback(tripCallback);
Kotlin
// Start journey sharing after a trip has been created via Fleet Engine.
val tripModelManager = consumerApi.getTripModelManager()
// Get a TripModel object.
val tripModel = tripModelManager.getTripModel(tripName)
// Register a listener on the trip.
val tripCallback = TripModelCallback() {
...
}
tripModel.registerTripCallback(tripCallback)
// Set the refresh interval.
val tripModelOptions =
TripModelOptions.builder()
.setRefreshInterval(5000) // interval in milliseconds, so 5 seconds
.build()
tripModel.setTripModelOptions(tripModelOptions)
// The trip stops auto-refreshing when all listeners are unregistered.
tripModel.unregisterTripCallback(tripCallback)
Swift
let tripService = GMTCServices.shared().tripService
// Create a tripModel instance for listening for updates from the trip
// specified by the trip name.
let tripModel = tripService.tripModel(forTripName: tripName)
// Register for the trip update events.
tripModel.register(self)
// Set the refresh interval (in seconds).
tripModel.options.autoRefreshTimeInterval = 5
// Unregister for the trip update events.
tripModel.unregisterSubscriber(self)
Objective-C
GMTCTripService *tripService = [GMTCServices sharedServices].tripService;
// Create a tripModel instance for listening for updates from the trip
// specified by the trip name.
GMTCTripModel *tripModel = [tripService tripModelForTripName:tripName];
// Register for the trip update events.
[tripModel registerSubscriber:self];
// Set the refresh interval (in seconds).
tripModel.options.autoRefreshTimeInterval = 5;
// Unregister for the trip update events.
[tripModel unregisterSubscriber:self];
Esempio 2
Il seguente esempio di codice mostra come configurare un ascoltatore TripModelCallback
e un sottoscrittore GMTCTripModelSubscriber
.
Java
// Implements a callback for the trip model so your app can listen for trip
// updates from Fleet Engine.
TripModelCallback subscriber =
new TripModelCallback() {
@Override
public void onTripStatusUpdated(TripInfo tripInfo, @TripStatus int status) {
// ...
}
@Override
public void onTripActiveRouteUpdated(TripInfo tripInfo, List<LatLng> route) {
// ...
}
@Override
public void onTripVehicleLocationUpdated(
TripInfo tripInfo, @Nullable VehicleLocation vehicleLocation) {
// ...
}
@Override
public void onTripPickupLocationUpdated(
TripInfo tripInfo, @Nullable TerminalLocation pickup) {
// ...
}
@Override
public void onTripPickupTimeUpdated(TripInfo tripInfo, @Nullable Long timestampMillis) {
// ...
}
@Override
public void onTripDropoffLocationUpdated(
TripInfo tripInfo, @Nullable TerminalLocation dropoff) {
// ...
}
@Override
public void onTripDropoffTimeUpdated(TripInfo tripInfo, @Nullable Long timestampMillis) {
// ...
}
@Override
public void onTripETAToNextWaypointUpdated(
TripInfo tripInfo, @Nullable Long timestampMillis) {
// ...
}
@Override
public void onTripActiveRouteRemainingDistanceUpdated(
TripInfo tripInfo, @Nullable Integer distanceMeters) {
// ...
}
@Override
public void onTripUpdateError(TripInfo tripInfo, TripUpdateError error) {
// ...
}
@Override
public void onTripUpdated(TripInfo tripInfo) {
// ...
}
@Override
public void onTripRemainingWaypointsUpdated(
TripInfo tripInfo, List<TripWaypoint> waypointList) {
// ...
}
@Override
public void onTripIntermediateDestinationsUpdated(
TripInfo tripInfo, List<TerminalLocation> intermediateDestinations) {
// ...
}
@Override
public void onTripRemainingRouteDistanceUpdated(
TripInfo tripInfo, @Nullable Integer distanceMeters) {
// ...
}
@Override
public void onTripRemainingRouteUpdated(TripInfo tripInfo, List<LatLng> route) {
// ...
}
};
Kotlin
// Implements a callback for the trip model so your app can listen for trip
// updates from Fleet Engine.
val subscriber =
object : TripModelCallback() {
override fun onTripStatusUpdated(tripInfo: TripInfo, status: @TripStatus Int) {
// ...
}
override fun onTripActiveRouteUpdated(tripInfo: TripInfo, route: List<LatLng>) {
// ...
}
override fun onTripVehicleLocationUpdated(
tripInfo: TripInfo,
vehicleLocation: VehicleLocation?
) {
// ...
}
override fun onTripPickupLocationUpdated(tripInfo: TripInfo, pickup: TerminalLocation?) {
// ...
}
override fun onTripPickupTimeUpdated(tripInfo: TripInfo, timestampMillis: Long?) {
// ...
}
override fun onTripDropoffLocationUpdated(tripInfo: TripInfo, dropoff: TerminalLocation?) {
// ...
}
override fun onTripDropoffTimeUpdated(tripInfo: TripInfo, timestampMillis: Long?) {
// ...
}
override fun onTripETAToNextWaypointUpdated(tripInfo: TripInfo, timestampMillis: Long?) {
// ...
}
override fun onTripActiveRouteRemainingDistanceUpdated(
tripInfo: TripInfo,
distanceMeters: Int?
) {
// ...
}
override fun onTripUpdateError(tripInfo: TripInfo, error: TripUpdateError) {
// ...
}
override fun onTripUpdated(tripInfo: TripInfo) {
// ...
}
override fun onTripRemainingWaypointsUpdated(
tripInfo: TripInfo,
waypointList: List<TripWaypoint>
) {
// ...
}
override fun onTripIntermediateDestinationsUpdated(
tripInfo: TripInfo,
intermediateDestinations: List<TerminalLocation>
) {
// ...
}
override fun onTripRemainingRouteDistanceUpdated(tripInfo: TripInfo, distanceMeters: Int?) {
// ...
}
override fun onTripRemainingRouteUpdated(tripInfo: TripInfo, route: List<LatLng>) {
// ...
}
}
Swift
class TripModelSubscriber: NSObject, GMTCTripModelSubscriber {
func tripModel(_: GMTCTripModel, didUpdate trip: GMTSTrip?, updatedPropertyFields: GMTSTripPropertyFields) {
// Update the UI with the new `trip` data.
updateUI(with: trip)
...
}
func tripModel(_: GMTCTripModel, didUpdate tripStatus: GMTSTripStatus) {
// Handle trip status did change.
}
func tripModel(_: GMTCTripModel, didUpdateActiveRoute activeRoute: [GMTSLatLng]?) {
// Handle trip active route did update.
}
func tripModel(_: GMTCTripModel, didUpdate vehicleLocation: GMTSVehicleLocation?) {
// Handle vehicle location did update.
}
func tripModel(_: GMTCTripModel, didUpdatePickupLocation pickupLocation: GMTSTerminalLocation?) {
// Handle pickup location did update.
}
func tripModel(_: GMTCTripModel, didUpdateDropoffLocation dropoffLocation: GMTSTerminalLocation?) {
// Handle drop off location did update.
}
func tripModel(_: GMTCTripModel, didUpdatePickupETA pickupETA: TimeInterval) {
// Handle the pickup ETA did update.
}
func tripModel(_: GMTCTripModel, didUpdateDropoffETA dropoffETA: TimeInterval) {
// Handle the drop off ETA did update.
}
func tripModel(_: GMTCTripModel, didUpdateRemaining remainingWaypoints: [GMTSTripWaypoint]?) {
// Handle updates to the pickup, dropoff or intermediate destinations of the trip.
}
func tripModel(_: GMTCTripModel, didFailUpdateTripWithError error: Error?) {
// Handle the error.
}
func tripModel(_: GMTCTripModel, didUpdateIntermediateDestinations intermediateDestinations: [GMTSTerminalLocation]?) {
// Handle the intermediate destinations being updated.
}
...
}
Objective-C
@interface TripModelSubscriber : NSObject <GMTCTripModelSubscriber>
@end
@implementation TripModelSubscriber
- (void)tripModel:(GMTCTripModel *)tripModel
didUpdateTrip:(nullable GMTSTrip *)trip
updatedPropertyFields:(GMTSTripPropertyFields)updatedPropertyFields {
// Update the UI with the new `trip` data.
[self updateUIWithTrip:trip];
...
}
- (void)tripModel:(GMTCTripModel *)tripModel didUpdateTripStatus:(enum GMTSTripStatus)tripStatus {
// Handle trip status did change.
}
- (void)tripModel:(GMTCTripModel *)tripModel
didUpdateActiveRoute:(nullable NSArray<GMTSLatLng *> *)activeRoute {
// Handle trip route did update.
}
- (void)tripModel:(GMTCTripModel *)tripModel
didUpdateVehicleLocation:(nullable GMTSVehicleLocation *)vehicleLocation {
// Handle vehicle location did update.
}
- (void)tripModel:(GMTCTripModel *)tripModel
didUpdatePickupLocation:(nullable GMTSTerminalLocation *)pickupLocation {
// Handle pickup location did update.
}
- (void)tripModel:(GMTCTripModel *)tripModel
didUpdateDropoffLocation:(nullable GMTSTerminalLocation *)dropoffLocation {
// Handle drop off location did update.
}
- (void)tripModel:(GMTCTripModel *)tripModel didUpdatePickupETA:(NSTimeInterval)pickupETA {
// Handle the pickup ETA did update.
}
- (void)tripModel:(GMTCTripModel *)tripModel
didUpdateRemainingWaypoints:(nullable NSArray<GMTSTripWaypoint *> *)remainingWaypoints {
// Handle updates to the pickup, dropoff or intermediate destinations of the trip.
}
- (void)tripModel:(GMTCTripModel *)tripModel didUpdateDropoffETA:(NSTimeInterval)dropoffETA {
// Handle the drop off ETA did update.
}
- (void)tripModel:(GMTCTripModel *)tripModel didFailUpdateTripWithError:(nullable NSError *)error {
// Handle the error.
}
- (void)tripModel:(GMTCTripModel *)tripModel
didUpdateIntermediateDestinations:
(nullable NSArray<GMTSTerminalLocation *> *)intermediateDestinations {
// Handle the intermediate destinations being updated.
}
…
@end
Puoi accedere alle informazioni sulla corsa in qualsiasi momento come segue:
Chiama l'SDK consumer per Android
TripModel.getTripInfo()
. La chiamata di questo metodo non forza l'aggiornamento dei dati, anche se i dati continuano a essere aggiornati alla frequenza di aggiornamento.Scarica l'SDK consumer per la proprietà iOS
GMTCTripModel.currentTrip
.
Passaggio 7: Visualizzare il percorso nell'app del consumatore
Per accedere alle API degli elementi dell'interfaccia utente Rides and Deliveries:
Scarica l'oggetto
ConsumerController
dell'SDK Consumer per Android. Per ulteriori informazioni, consulta la sezione Utilizzo delle API degli elementi dell'interfaccia utente.Scarica l'oggetto
GMTCMapView
dell'SDK Consumer per iOS. Per ulteriori informazioni, consulta la sezione Utilizzo delle API degli elementi dell'interfaccia utente.
Esempio
Il seguente esempio di codice mostra come iniziare il percorso condividendo l'interfaccia utente.
Java
JourneySharingSession session = JourneySharingSession.createInstance(tripModel);
consumerController.showSession(session);
Kotlin
val session = JourneySharingSession.createInstance(tripModel)
consumerController.showSession(session)
Swift
let journeySharingSession = GMTCJourneySharingSession(tripModel: tripModel)
mapView.show(journeySharingSession)
Objective-C
GMTCJourneySharingSession *journeySharingSession =
[[GMTCJourneySharingSession alloc] initWithTripModel:tripModel];
[self.mapView showMapViewSession:journeySharingSession];
Per impostazione predefinita, l'SDK consumer visualizza solo il tratto attivo nella route, ma puoi scegliere di visualizzare il tratto rimanente, che include la destinazione.
Se vuoi visualizzare informazioni sulle tappe di altre corse, puoi accedere a tutte le tappe pertinenti a una corsa nel seguente modo:
Chiama l'SDK consumer per Android
TripModel.getTripInfo()
. Quindi chiama il numeroTripInfo.getRemainingWaypoints()
per ricevere iTripWaypoint
. Ogni oggettoTripWaypoint
contiene l'ID corsa, la posizione del waypoint e il tipo di tappa.Scarica l'SDK consumer per la proprietà iOS
GMTCTripModel.currentTrip
. Quindi recupera l'arrayGMTSTrip.remainingWaypoints
per accedere aiGMTSTripWaypoint
. Ogni oggettoGMTSTripWaypoint
contiene l'ID corsa, la posizione del waypoint e il tipo di tappa.
Passaggio 8: Gestisci lo stato della corsa in Fleet Engine
Puoi specificare lo stato di una corsa utilizzando uno dei valori di enumerazione di TripStatus
. Quando lo stato di una corsa cambia (ad esempio, da ENROUTE_TO_PICKUP
a ARRIVED_AT_PICKUP
), devi aggiornarlo tramite Fleet Engine. Lo stato del viaggio inizia sempre con il valore NEW
e termina con
un valore di COMPLETE
o CANCELED
. Per maggiori informazioni, consulta
trip_status
.
Esempio
Il seguente esempio di integrazione del backend mostra come aggiornare lo stato della corsa in Fleet Engine.
static final String PROJECT_ID = "my-rideshare-co-gcp-project";
static final String TRIP_ID = "trip-8241890";
String tripName = "providers/" + PROJECT_ID + "/trips/" + TRIP_ID;
TripServiceBlockingStub tripService = TripService.newBlockingStub(channel);
// Trip settings to be updated.
Trip trip = Trip.newBuilder()
.setTripStatus(TripStatus.ARRIVED_AT_PICKUP)
.build();
// Trip update request
UpdateTripRequest updateTripRequest = UpdateTripRequest.newBuilder()
.setName(tripName)
.setTrip(trip)
.setUpdateMask(FieldMask.newBuilder().addPaths("trip_status"))
.build();
// Error handling.
try {
Trip updatedTrip = tripService.updateTrip(updateTripRequest);
} catch (StatusRuntimeException e) {
Status s = e.getStatus();
switch (s.getCode()) {
case NOT_FOUND: // The trip doesn't exist.
break;
case FAILED_PRECONDITION: // The given trip status is invalid.
break;
case PERMISSION_DENIED:
break;
}
return;
}