import org.onebusaway.gtfs.model.Trip; //导入依赖的package包/类
@Test
public void testFrequency() throws CsvEntityIOException, IOException {

  _reader.setDefaultAgencyId("1");

  Trip trip = new Trip();
  trip.setId(new AgencyAndId("1", "trip"));
  _reader.injectEntity(trip);

  StringBuilder b = new StringBuilder();
  b.append("trip_id,start_time,end_time,headway_secs,exact_times\n");
  b.append("trip,08:30:00,09:45:00,300,1\n");

  _reader.readEntities(Frequency.class, new StringReader(b.toString()));

  Frequency frequency = _dao.getFrequencyForId(1);
  assertEquals(30600, frequency.getStartTime());
  assertEquals(35100, frequency.getEndTime());
  assertEquals(1, frequency.getExactTimes());
  assertEquals(300, frequency.getHeadwaySecs());
  assertSame(trip, frequency.getTrip());
}
 

import org.onebusaway.gtfs.model.Trip; //导入依赖的package包/类
public static List<Class<?>> getEntityClasses() {
  List<Class<?>> entityClasses = new ArrayList<Class<?>>();
  entityClasses.add(FeedInfo.class);
  entityClasses.add(Agency.class);
  entityClasses.add(Block.class);
  entityClasses.add(ShapePoint.class);
  entityClasses.add(Route.class);
  entityClasses.add(Stop.class);
  entityClasses.add(Trip.class);
  entityClasses.add(StopTime.class);
  entityClasses.add(ServiceCalendar.class);
  entityClasses.add(ServiceCalendarDate.class);
  entityClasses.add(FareAttribute.class);
  entityClasses.add(FareRule.class);
  entityClasses.add(Frequency.class);
  entityClasses.add(Pathway.class);
  entityClasses.add(Transfer.class);
  return entityClasses;
}
 

import org.onebusaway.gtfs.model.Trip; //导入依赖的package包/类
public static Map<Class<?>, Comparator<?>> getEntityComparators() {
  Map<Class<?>, Comparator<?>> comparators = new HashMap<Class<?>, Comparator<?>>();
  comparators.put(Agency.class,
      getComparatorForIdentityBeanType(Agency.class));
  comparators.put(Block.class,
      getComparatorForIdentityBeanType(Block.class));
  comparators.put(Route.class, getComparatorForIdentityBeanType(Route.class));
  comparators.put(Stop.class, getComparatorForIdentityBeanType(Stop.class));
  comparators.put(Trip.class, getComparatorForIdentityBeanType(Trip.class));
  comparators.put(StopTime.class, new StopTimeComparator());
  comparators.put(ShapePoint.class, new ShapePointComparator());
  comparators.put(ServiceCalendar.class, new ServiceCalendarComparator());
  comparators.put(ServiceCalendarDate.class,
      new ServiceCalendarDateComparator());
  return comparators;
}
 

import org.onebusaway.gtfs.model.Trip; //导入依赖的package包/类
@Override
public List<Trip> getTripsForBlockId(AgencyAndId blockId) {

  if (_tripsByBlockId == null) {
    _tripsByBlockId = new HashMap<AgencyAndId, List<Trip>>();
    for (Trip trip : getAllTrips()) {
      if (trip.getBlockId() != null) {
        AgencyAndId bid = new AgencyAndId(trip.getId().getAgencyId(),
            trip.getBlockId());
        List<Trip> trips = _tripsByBlockId.get(bid);
        if (trips == null) {
          trips = new ArrayList<Trip>();
          _tripsByBlockId.put(bid, trips);
        }
        trips.add(trip);
      }
    }
  }

  return list(_tripsByBlockId.get(blockId));
}
 

import org.onebusaway.gtfs.model.Trip; //导入依赖的package包/类
@Test
public void testFrequency() throws CsvEntityIOException, IOException {

  GtfsReader reader = new GtfsReader();
  reader.setDefaultAgencyId("1");

  Trip trip = new Trip();
  trip.setId(new AgencyAndId("1", "trip"));
  reader.injectEntity(trip);

  StringBuilder b = new StringBuilder();
  b.append("trip_id,start_time,end_time,headway_secs,exact_times\n");
  b.append("trip,08:30:00,09:45:00,300,1\n");

  reader.readEntities(Frequency.class, new StringReader(b.toString()));

  Frequency frequency = reader.getEntityStore().getEntityForId(
      Frequency.class, 1);
  assertEquals(30600, frequency.getStartTime());
  assertEquals(35100, frequency.getEndTime());
  assertEquals(1, frequency.getExactTimes());
  assertEquals(300, frequency.getHeadwaySecs());
  assertSame(trip, frequency.getTrip());
}
 

import org.onebusaway.gtfs.model.Trip; //导入依赖的package包/类
@Test
public void testSyntheticGetTripAgencyIdsReferencingServiceId() {

  GtfsRelationalDaoImpl dao = new GtfsRelationalDaoImpl();

  AgencyAndId serviceId = new AgencyAndId("C", "serviceId");

  Trip tripA = new Trip();
  tripA.setId(new AgencyAndId("A", "tripId"));
  tripA.setServiceId(serviceId);
  dao.saveEntity(tripA);

  Trip tripB = new Trip();
  tripB.setId(new AgencyAndId("B", "tripId"));
  tripB.setServiceId(serviceId);
  dao.saveEntity(tripB);

  List<String> agencyIds = dao.getTripAgencyIdsReferencingServiceId(serviceId);
  assertEquals(2, agencyIds.size());
  assertTrue(agencyIds.contains("A"));
  assertTrue(agencyIds.contains("B"));
}
 

import org.onebusaway.gtfs.model.Trip; //导入依赖的package包/类
private TripDescriptor buildTripDescriptor(VesselLocationResponse vlr) {
  TripDescriptor.Builder tripDescriptor = TripDescriptor.newBuilder();

  ActivatedTrip activatedTrip = _tripResolutionService.resolve(vlr.getDepartingTerminalID().toString(),
          ts(vlr.getScheduledDeparture().getValue()),
          vlr.getArrivingTerminalID().getValue().toString());

  if (activatedTrip == null) {
    return null;
  }

  Trip trip = activatedTrip.getTrip();
  ServiceDate sd = activatedTrip.getServiceDate();

  tripDescriptor.setTripId(trip.getId().getId());
  tripDescriptor.setRouteId(trip.getRoute().getId().getId());
  tripDescriptor.setStartDate(sd.getAsString());

  return tripDescriptor.build();
}
 

import org.onebusaway.gtfs.model.Trip; //导入依赖的package包/类
@Override
public Component getListCellRendererComponent(
        JList list, Object value, int index,
        boolean isSelected, boolean cellHasFocus) {
    super.getListCellRendererComponent(list, value, index,
            isSelected, cellHasFocus);

    if (value != null) {
        Trip trip = (Trip) value;

        if (trip.getTripShortName() != null) {
            setText(trip.getTripShortName());
        } else if (trip.getTripHeadsign() != null) {
            setText(trip.getTripHeadsign());
        } else {
            setText(trip.getId().getId());
        }

    } else {
        setText("Select Trip...");
    }
    return this;
}
 

import org.onebusaway.gtfs.model.Trip; //导入依赖的package包/类
public void dumpToWriter(GtfsWriter gtfsWriter) {
    for(Agency agency : agencies){
    	gtfsWriter.handleEntity( agency );
    }
    for(Route route : routes){
    	gtfsWriter.handleEntity(route);
    }
    for(Trip trip : trips){
    	gtfsWriter.handleEntity(trip);
    }
    for(Stop stop : stops){
    	gtfsWriter.handleEntity(stop);
    }
    for(StopTime stoptime : stoptimes){
    	gtfsWriter.handleEntity(stoptime);
    }
    for(Frequency fr : frequencies){
    	gtfsWriter.handleEntity(fr);
    }
    for(ServiceCalendar sc : calendars){
    	gtfsWriter.handleEntity(sc);
    }
}
 

import org.onebusaway.gtfs.model.Trip; //导入依赖的package包/类
private boolean matchesFrom(Trip trip) {
    checkNotNull(trip);
    
    boolean match = false;
    int specificity = getFromSpecificity();
    if (specificity == 0) {
        match = true;
    }
    else if (specificity == 1) {
        if (trip.getRoute().getId().equals(fromRouteId)) {
            match = true;
        }
    }
    else if (specificity == 2) {
        if (trip.getId().equals(fromTripId)) {
            match = true;
        }
    }
    return match;
}
 

import org.onebusaway.gtfs.model.Trip; //导入依赖的package包/类
private boolean matchesTo(Trip trip) {
    checkNotNull(trip);

    boolean match = false;
    int specificity = getToSpecificity();
    if (specificity == 0) {
        match = true;
    }
    else if (specificity == 1) {
        if (trip.getRoute().getId().equals(toRouteId)) {
            match = true;
        }
    }
    else if (specificity == 2) {
        if (trip.getId().equals(toTripId)) {
            match = true;
        }
    }
    return match;
}
 

import org.onebusaway.gtfs.model.Trip; //导入依赖的package包/类
/**
 * Get the transfer time that should be used when transferring from a trip to another trip.
 * Note that this function does not check whether another specific transfer exists with the
 * same specificity, what is forbidden by the specifications.    
 * @param fromTrip is the arriving trip
 * @param toTrip is the departing trip
 * @return the transfer time in seconds. May contain special (negative) values which meaning
 *   can be found in the *_TRANSFER constants.
 */
public int getTransferTime(Trip fromTrip, Trip toTrip) {
    // By default the transfer is unknown
    int transferTime = UNKNOWN_TRANSFER;
    
    // Pick the matching specific transfer with the highest specificity
    int maxFoundSpecificity = SpecificTransfer.MIN_SPECIFICITY - 1;
    for (SpecificTransfer specificTransfer : specificTransfers) {
        int specificity = specificTransfer.getSpecificity(); 
        if (specificity > maxFoundSpecificity) {
            if (specificTransfer.matches(fromTrip, toTrip)) {
                // Set the found transfer time
                transferTime = specificTransfer.transferTime;
                maxFoundSpecificity = specificity;
                
                // Break when highest specificity is found
                if (maxFoundSpecificity == SpecificTransfer.MAX_SPECIFICITY) {
                    break;
                }
            }
        }
    }
    
    // Return transfer time
    return transferTime;
}
 

import org.onebusaway.gtfs.model.Trip; //导入依赖的package包/类
/**
 * Add a transfer time to the transfer table.
 * 
 * @param fromStop is the arriving stop
 * @param toStop is the departing stop
 * @param fromRoute is the arriving route; is allowed to be null
 * @param toRoute is the departing route; is allowed to be null
 * @param fromTrip is the arriving trip; is allowed to be null
 * @param toTrip is the departing trip; is allowed to be null
 * @param transferTime is the transfer time in seconds. May contain special (negative) values
 *        which meaning can be found in the StopTransfer.*_TRANSFER constants. If no transfer is
 *        found, StopTransfer.UNKNOWN_TRANSFER is returned.
 */
public void addTransferTime(Stop fromStop, Stop toStop, Route fromRoute, Route toRoute, Trip fromTrip, Trip toTrip,
        int transferTime) {
    checkNotNull(fromStop);
    checkNotNull(toStop);
    
    // Check whether this transfer is preferred (or timed)
    if ((transferTime == StopTransfer.PREFERRED_TRANSFER) || (transferTime == StopTransfer.TIMED_TRANSFER)) {
        this.preferredTransfers = true;
    }

    // Lookup whether a transfer between the two stops already exists
    P2<AgencyAndId> stopIdPair = new P2<AgencyAndId>(fromStop.getId(), toStop.getId());
    StopTransfer stopTransfer = this.table.get(stopIdPair);
    if (stopTransfer == null) {
        // If not, create one and add to table
        stopTransfer = new StopTransfer();
        this.table.put(stopIdPair, stopTransfer);
    }
    assert (stopTransfer != null);

    // Create and add a specific transfer to the stop transfer
    SpecificTransfer specificTransfer = new SpecificTransfer(fromRoute, toRoute, fromTrip, toTrip, transferTime);
    stopTransfer.addSpecificTransfer(specificTransfer);
}
 

import org.onebusaway.gtfs.model.Trip; //导入依赖的package包/类
/****
 * {@link Trip} Methods
 ****/

@Test
public void testGetAllTrips() {
  List<Trip> trips = _dao.getAllTrips();
  assertEquals(260, trips.size());
}
 

import org.onebusaway.gtfs.model.Trip; //导入依赖的package包/类
@Test
public void testGetTripById() {
  Route route = _dao.getRouteForId(aid("ct_local"));

  Trip trip = _dao.getTripForId(aid("10101272009"));
  assertEquals(aid("10101272009"), trip.getId());
  assertNull(trip.getBlockId());
  assertEquals("0", trip.getDirectionId());
  assertEquals(route, trip.getRoute());
  assertNull(trip.getRouteShortName());
  assertEquals(aid("WD01272009"), trip.getServiceId());
  assertEquals(aid("cal_sj_sf"), trip.getShapeId());
  assertEquals("101", trip.getTripShortName());
  assertEquals("San Jose to San Francisco", trip.getTripHeadsign());
}
 

import org.onebusaway.gtfs.model.Trip; //导入依赖的package包/类
@Test
public void testFrequenciesForTrip() {
  Trip trip = _dao.getTripForId(new AgencyAndId("AirBART", "M-FSAT1DN"));
  List<Frequency> frequencies = _dao.getFrequenciesForTrip(trip);
  assertEquals(1, frequencies.size());

  Frequency frequency = frequencies.get(0);
  assertEquals(5 * 60 * 60, frequency.getStartTime());
  assertEquals(6 * 60 * 60, frequency.getEndTime());
  assertEquals(trip, frequency.getTrip());
  assertEquals(1200, frequency.getHeadwaySecs());
}
 

import org.onebusaway.gtfs.model.Trip; //导入依赖的package包/类
@Override
public int compare(StopTime o1, StopTime o2) {
  Trip trip1 = o1.getTrip();
  Trip trip2 = o2.getTrip();
  int c = trip1.getId().compareTo(trip2.getId());
  
  if( c == 0)
    c = o1.getStopSequence() - o2.getStopSequence();
  
  return c;
}
 

import org.onebusaway.gtfs.model.Trip; //导入依赖的package包/类
public GtfsReader() {

    _entityClasses.add(Agency.class);
    _entityClasses.add(Block.class);
    _entityClasses.add(ShapePoint.class);
    _entityClasses.add(Route.class);
    _entityClasses.add(Stop.class);
    _entityClasses.add(Trip.class);
    _entityClasses.add(StopTime.class);
    _entityClasses.add(ServiceCalendar.class);
    _entityClasses.add(ServiceCalendarDate.class);
    _entityClasses.add(FareAttribute.class);
    _entityClasses.add(FareRule.class);
    _entityClasses.add(Frequency.class);
    _entityClasses.add(Pathway.class);
    _entityClasses.add(Transfer.class);
    _entityClasses.add(FeedInfo.class);

    CsvTokenizerStrategy tokenizerStrategy = new CsvTokenizerStrategy();
    tokenizerStrategy.getCsvParser().setTrimInitialWhitespace(true);
    setTokenizerStrategy(tokenizerStrategy);
    
    setTrimValues(true);

    /**
     * Prep the Entity Schema Factories
     */
    DefaultEntitySchemaFactory schemaFactory = createEntitySchemaFactory();
    setEntitySchemaFactory(schemaFactory);

    CsvEntityContext ctx = getContext();
    ctx.put(KEY_CONTEXT, _context);

    addEntityHandler(new EntityHandlerImpl());
  }
 

import org.onebusaway.gtfs.model.Trip; //导入依赖的package包/类
public void handleEntity(Object entity) {

      if (entity instanceof Agency) {
        Agency agency = (Agency) entity;
        if (agency.getId() == null) {
          if (_defaultAgencyId == null)
            agency.setId(agency.getName());
          else
            agency.setId(_defaultAgencyId);
        }

        // If we already have this agency from a previous load, then we don't
        // add it or save it to the entity store
        if (_agencies.contains(agency))
          return;

        _agencies.add((Agency) entity);
      } else if (entity instanceof Pathway) {
        Pathway pathway = (Pathway) entity;
        registerAgencyId(Pathway.class, pathway.getId());
      } else if (entity instanceof Route) {
        Route route = (Route) entity;
        registerAgencyId(Route.class, route.getId());
      } else if (entity instanceof Trip) {
        Trip trip = (Trip) entity;
        registerAgencyId(Trip.class, trip.getId());
      } else if (entity instanceof Stop) {
        Stop stop = (Stop) entity;
        registerAgencyId(Stop.class, stop.getId());
      } else if (entity instanceof FareAttribute) {
        FareAttribute fare = (FareAttribute) entity;
        registerAgencyId(FareAttribute.class, fare.getId());
      }

      if (entity instanceof IdentityBean<?>) {
        _entityStore.saveEntity(entity);
      }

    }
 

import org.onebusaway.gtfs.model.Trip; //导入依赖的package包/类
@Override
public List<StopTime> getStopTimesForTrip(Trip trip) {

  if (_stopTimesByTrip == null) {
    _stopTimesByTrip = mapToValueList(getAllStopTimes(), "trip", Trip.class);
    for (List<StopTime> stopTimes : _stopTimesByTrip.values())
      Collections.sort(stopTimes);
  }

  return list(_stopTimesByTrip.get(trip));
}