Создание и отображение поездок с общим бассейном

Поездки с общим пулом — это совместные поездки для нескольких потребителей, которые одновременно пользуются одним транспортным средством. То есть поездки являются одновременными, а не независимыми. Принцип работы аналогичен принципу работы трансфера из аэропорта, за исключением того, что водитель также может высаживать потребителей по маршруту.

Основное различие между поездкой с общим пулом и поездкой с одним пунктом назначения заключается в том, что при поездке с общим пулом оператор поездки может перевозить более одного пассажира одновременно.

В этом руководстве рассказывается, как создать поездку с общим бассейном. Здесь также показано, как затем интегрировать эту поездку с вашим потребительским приложением, чтобы ваши клиенты могли визуализировать ход поездки со своих телефонов. Эту интеграцию вы выполняете с помощью Consumer SDK.

Шаг 1. Создайте транспортное средство в Fleet Engine.

Транспортные средства — это объекты, которые представляют транспортные средства в вашем автопарке. Вы должны создать их в Fleet Engine, чтобы иметь возможность отслеживать их в потребительском приложении.

Вы можете создать транспортное средство, используя любой из следующих двух подходов:

gRPC

Вызовите метод CreateVehicle() с сообщением запроса CreateVehicleRequest . Для вызова CreateVehicle() у вас должны быть права суперпользователя Fleet Engine.

ОТДЫХ

Позвоните по https://fleetengine.googleapis.com/v1/providers.vehicles. create .

Предостережения

Следующие предостережения применяются при создании транспортного средства.

• Обязательно установите исходное состояние автомобиля в OFFLINE . Это гарантирует, что Fleet Engine сможет обнаружить ваш автомобиль для сопоставления поездок.

• provider_id транспортного средства должен совпадать с идентификатором проекта Google Cloud, который содержит сервисные аккаунты, используемые для вызова Fleet Engine. Хотя несколько учетных записей служб могут получить доступ к Fleet Engine для одного и того же поставщика услуг совместного использования поездок, Fleet Engine в настоящее время не поддерживает учетные записи служб из разных проектов Google Cloud, имеющих доступ к одним и тем же транспортным средствам.

• Ответ, возвращаемый функцией CreateVehicle() содержит экземпляр Vehicle . Экземпляр удаляется через семь дней, если он не был обновлен с помощью UpdateVehicle() . Вам следует вызвать GetVehicle() перед вызовом CreateVehicle() просто для того, чтобы убедиться, что транспортного средства еще не существует. Если GetVehicle() возвращает ошибку NOT_FOUND , вам следует продолжить вызов CreateVehicle() . Дополнительную информацию см. в разделе Транспортные средства и их жизненный цикл .

Пример

В следующем примере кода поставщика показано, как создать транспортное средство в 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;
}

Чтобы создать Vehicle , поддерживающее поездки с общим пулом , необходимо добавить TripType.SHARED в список поддерживаемых типов поездок в объекте Vehicle , переданном в CreateVehicleRequest .

Vehicle vehicle = Vehicle.newBuilder()
    .setVehicleState(VehicleState.OFFLINE)
    .addSupportedTripTypes(TripType.SHARED)
    .setMaximumCapacity(4)
    .setVehicleType(VehicleType.newBuilder().setCategory(VehicleType.Category.AUTO))
    .build();

Шаг 2. Включите отслеживание местоположения

Отслеживание местоположения означает отслеживание местоположения транспортного средства во время поездки, когда приложение водителя отправляет телеметрию в Fleet Engine, которая содержит текущее местоположение транспортного средства. Этот постоянно обновляемый поток информации о местоположении используется для передачи информации о ходе транспортного средства по маршруту поездки. Когда вы включаете отслеживание местоположения, приложение водителя начинает отправлять эти телеметрические данные с частотой по умолчанию — один раз в пять секунд.

Вы включаете отслеживание местоположения для Android и iOS следующим образом:

• Вызовите метод enableLocationTracking() пакета SDK драйверов для Android.

• Установите для логического свойства locationTrackingEnabled драйвера SDK для iOS значение true .

Примечание. Для аутентификации вызовов API-интерфейсов Driver SDK для Android требуется токен аутентификации, который использует роль «Водитель» и должен включать в себя vehicle_id .

Пример

В следующем примере кода показано, как включить отслеживание местоположения.

Джава

RidesharingVehicleReporter vehicleReporter = ...;

vehicleReporter.enableLocationTracking();

Котлин

val vehicleReporter = ...

vehicleReporter.enableLocationTracking()

Быстрый

vehicleReporter.locationTrackingEnabled = true

Цель-C

_vehicleReporter.locationTrackingEnabled = YES;

Шаг 3. Установите состояние автомобиля онлайн.

Вы вводите автомобиль в эксплуатацию (то есть делаете его доступным для использования), устанавливая его состояние в режиме онлайн , но вы не можете сделать это, пока не включите отслеживание местоположения.

Вы устанавливаете состояние автомобиля онлайн для Android и iOS следующим образом:

• Вызовите метод setVehicleState(VehicleState.ONLINE) пакета SDK драйверов для Android.

• Вызовите метод vehicleReporter.update(.online) Driver SDK для iOS.

Пример

В следующем примере кода показано, как установить для автомобиля состояние ONLINE .

Джава

vehicleReporter.setVehicleState(VehicleState.ONLINE);

Котлин

vehicleReporter.setVehicleState(VehicleState.ONLINE)

Быстрый

vehicleReporter.update(.online)

Цель-C

[_vehicleReporter updateVehicleState:GMTDVehicleStateOnline];

Шаг 4. Создайте поездку в Fleet Engine.

Чтобы создать поездку с общим пулом, вы создаете объект Trip так же, как и для поездки в один пункт назначения.

Поездка — это объект, представляющий путешествие, представляющий собой набор точек геокоординаты, включая исходные, путевые точки и точки высадки. Вы должны создать один объект Trip для каждого запроса на поездку, чтобы запрос можно было сопоставить с транспортным средством и затем отслеживать.

• Вы можете создать поездку, вызвав метод CreateTrip() с сообщением-запросом CreateTripRequest .

Укажите необходимые атрибуты

Следующие поля необходимы для создания поездки с общим бассейном.

parent

Строка, включающая идентификатор поставщика. Он должен совпадать с идентификатором проекта Google Cloud, который содержит сервисные аккаунты, используемые для вызова Fleet Engine.

trip_id

Строка, которую вы создаете и которая однозначно идентифицирует эту поездку.

trip

Объект Trip , который необходимо создать.

Следующие поля необходимо установить в объекте Trip , передаваемом в CreateTripRequest :

trip_type

TripType.SHARED

pickup_point

Начальная точка поездки.

dropoff_point

Конечная точка поездки. Это поле не является обязательным при создании поездки и может быть установлено позже, вызвав UpdateTrip .

Примечание. Для использования CreateTrip() требуются учетные данные для привилегированной учетной записи, указанной в разделе Fleet Engine: начальная настройка .

Пример

В следующем примере серверной интеграции показано, как создать поездку и автоматически назначить ее транспортному средству в качестве общего пула.

// 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;
}

Шаг 5. Обновите поездку, указав идентификатор транспортного средства и путевые точки.

Вам необходимо настроить поездку с использованием идентификатора транспортного средства, чтобы Fleet Engine мог отслеживать транспортное средство по его маршруту.

• Вы можете обновить поездку, указав идентификатор транспортного средства, вызвав конечную точку UpdateTrip с помощью UpdateTripRequest . Используйте поле update_mask , чтобы указать, что вы обновляете идентификатор транспортного средства.

Вы должны ввести порядок для непосещенных путевых точек в коллекции путевых точек транспортных средств поездки ( Trip.vehicle_waypoints ). Fleet Engine использует этот список для автоматического обновления путевых точек для всех поездок в общем пуле.

Например, рассмотрим две поездки с общим пулом: поездка A и поездка B. Рейс А находится в пути к месту высадки. Затем к тому же транспортному средству добавляется поездка Б. В одном UpdateTripRequest для Trip B вы устанавливаете vehicleId , а также устанавливаете Trip.vehicle_waypoints в оптимальный порядок точек маршрута: B _Pickup → A _Drop-off → B _Drop-off .

• Вызов getVehicle() возвращает список оставшихся путевых точек ( remainingWaypoints ), который содержит
  B _Пикап → A _{Возврат} → B _{Возврат} .
• Либо getTrip() , либо обратный вызов onTripRemainingWaypointsUpdated для Trip A возвращает список оставшихся путевых точек ( remainingWaypoints ), который содержит B _Pickup → A _Drop-off .
• Либо getTrip() , либо обратный вызов onTripRemainingWaypointsUpdated для Trip B возвращает список оставшихся путевых точек ( remainingWaypoints ), который содержит B _Pickup → A _Drop-off → B _Drop-off .

Пример

В следующем примере серверной интеграции показано, как обновить поездку с помощью идентификатора транспортного средства и путевых точек для двух поездок с общим пулом.

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;
}

Шаг 6. Прослушивайте обновления поездок в потребительском приложении.

• В Android вы можете прослушивать обновления данных о поездке, получив объект TripModel из TripModelManager и зарегистрировав прослушиватель TripModelCallback .

• Для iOS вы можете прослушивать обновления данных о поездке, получив объект GMTCTripModel из GMTCTripService и зарегистрировав подписчика GMTCTripModelSubscriber .

Прослушиватель TripModelCallback и подписчик GMTCTripModelSubscriber позволяют вашему приложению периодически получать обновления о ходе поездки при каждом обновлении на основе интервала автоматического обновления. Только изменяющиеся значения могут вызвать обратный вызов. В противном случае обратный вызов остается молчаливым.

Методы TripModelCallback.onTripUpdated() и tripModel(_:didUpdate:updatedPropertyFields:) вызываются всегда, независимо от каких-либо изменений данных.

Пример 1

В следующем примере кода показано, как получить TripModel из TripModelManager / GMTCTripService и установить для него прослушиватель.

Джава

// 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);

Котлин

// 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)

Быстрый

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)

Цель-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];

Пример 2

В следующем примере кода показано, как настроить прослушиватель TripModelCallback и подписчика GMTCTripModelSubscriber .

Джава

// 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) {
      // ...
    }
  };

Котлин

// 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>) {
      // ...
    }
  }

Быстрый

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.
  }

  ...
}

Цель-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

Вы можете получить информацию о поездке в любое время следующим образом:

• Вызовите метод TripModel.getTripInfo() в Consumer SDK для Android. Вызов этого метода не приводит к принудительному обновлению данных, хотя данные по-прежнему продолжают обновляться с той же частотой.

• Получите свойство Consumer SDK для iOS GMTCTripModel.currentTrip .

Шаг 7. Отобразите путешествие в потребительском приложении.

Вы можете получить доступ к API-интерфейсам элементов пользовательского интерфейса «Поездки и доставки» следующим образом:

• Получите Consumer SDK для объекта Android ConsumerController . Дополнительные сведения см. в разделе Использование API-интерфейсов элементов пользовательского интерфейса .

• Получите объект Consumer SDK для iOS GMTCMapView . Дополнительные сведения см. в разделе Использование API-интерфейсов элементов пользовательского интерфейса .

Пример

В следующем примере кода показано, как запустить пользовательский интерфейс совместного использования путешествия.

Джава

JourneySharingSession session = JourneySharingSession.createInstance(tripModel);
consumerController.showSession(session);

Котлин

val session = JourneySharingSession.createInstance(tripModel)
consumerController.showSession(session)

Быстрый

let journeySharingSession = GMTCJourneySharingSession(tripModel: tripModel)
mapView.show(journeySharingSession)

Цель-C

GMTCJourneySharingSession *journeySharingSession =
    [[GMTCJourneySharingSession alloc] initWithTripModel:tripModel];
[self.mapView showMapViewSession:journeySharingSession];

По умолчанию Consumer SDK отображает только активный участок маршрута, но у вас есть возможность отобразить оставшийся участок, который включает пункт назначения.

Если вы хотите отобразить информацию о путевых точках из других поездок, вы можете получить доступ ко всем путевым точкам, относящимся к поездке, следующим образом:

• Вызовите метод TripModel.getTripInfo() в Consumer SDK для Android. Затем вызовите TripInfo.getRemainingWaypoints() чтобы получить TripWaypoint s. Каждый объект TripWaypoint содержит идентификатор поездки, местоположение и тип маршрутной точки.

• Получите свойство Consumer SDK для iOS GMTCTripModel.currentTrip . Затем получите массив GMTSTrip.remainingWaypoints для доступа к GMTSTripWaypoint s. Каждый объект GMTSTripWaypoint содержит идентификатор поездки, местоположение и тип маршрутной точки.

Шаг 8. Управляйте состоянием поездки в Fleet Engine.

Вы указываете состояние поездки, используя одно из значений перечисления TripStatus . При изменении состояния поездки (например, с ENROUTE_TO_PICKUP на ARRIVED_AT_PICKUP ) вы должны обновить состояние поездки через Fleet Engine. Состояние отключения всегда начинается со значения NEW и заканчивается значением COMPLETE или CANCELED . Для получения дополнительной информации см. trip_status .

Пример

В следующем примере интеграции с серверной частью показано, как обновить состояние поездки в 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;
}