| <?php | <?php |
| function getTrip($tripID) | function getTrip($tripID) |
| { | { |
| global $conn; | global $conn; |
| $query = "Select * from trips | $query = "Select * from trips |
| join routes on trips.route_id = routes.route_id | join routes on trips.route_id = routes.route_id |
| where trip_id = '$tripID' | where trip_id = '$tripID' |
| LIMIT 1"; | LIMIT 1"; |
| debug($query, "database"); | debug($query, "database"); |
| $result = pg_query($conn, $query); | $result = pg_query($conn, $query); |
| if (!$result) { | if (!$result) { |
| databaseError(pg_result_error($result)); | databaseError(pg_result_error($result)); |
| return Array(); | return Array(); |
| } | } |
| return pg_fetch_assoc($result); | return pg_fetch_assoc($result); |
| } | } |
| function getTripShape() | function getTripShape() |
| { | { |
| /* def handle_json_GET_tripstopTimes(self, params): | /* def handle_json_GET_tripstopTimes(self, params): |
| schedule = self.server.schedule | schedule = self.server.schedule |
| try: | try: |
| trip = schedule.GetTrip(params.get('trip')) | trip = schedule.GetTrip(params.get('trip')) |
| except KeyError: | except KeyError: |
| # if a non-existent trip is searched for, the return nothing | # if a non-existent trip is searched for, the return nothing |
| return | return |
| time_stops = trip.GetTimeInterpolatedStops() | time_stops = trip.GetTimeInterpolatedStops() |
| stops = [] | stops = [] |
| times = [] | times = [] |
| for arr,ts,is_timingpoint in time_stops: | for arr,ts,is_timingpoint in time_stops: |
| stops.append(StopToTuple(ts.stop)) | stops.append(StopToTuple(ts.stop)) |
| times.append(arr) | times.append(arr) |
| return [stops, times] | return [stops, times] |
| def handle_json_GET_tripshape(self, params): | def handle_json_GET_tripshape(self, params): |
| schedule = self.server.schedule | schedule = self.server.schedule |
| try: | try: |
| trip = schedule.GetTrip(params.get('trip')) | trip = schedule.GetTrip(params.get('trip')) |
| except KeyError: | except KeyError: |
| # if a non-existent trip is searched for, the return nothing | # if a non-existent trip is searched for, the return nothing |
| return | return |
| points = [] | points = [] |
| if trip.shape_id: | if trip.shape_id: |
| shape = schedule.GetShape(trip.shape_id) | shape = schedule.GetShape(trip.shape_id) |
| for (lat, lon, dist) in shape.points: | for (lat, lon, dist) in shape.points: |
| points.append((lat, lon)) | points.append((lat, lon)) |
| else: | else: |
| time_stops = trip.GetTimeStops() | time_stops = trip.GetTimeStops() |
| for arr,dep,stop in time_stops: | for arr,dep,stop in time_stops: |
| points.append((stop.stop_lat, stop.stop_lon)) | points.append((stop.stop_lat, stop.stop_lon)) |
| return points*/ | return points*/ |
| } | } |
| function getTimeInterpolatedTrip($tripID) | function getTimeInterpolatedTrip($tripID) |
| { | { |
| global $conn; | global $conn; |
| $query = "SELECT stop_times.trip_id,arrival_time,stop_times.stop_id,stop_lat,stop_lon,stop_name,stop_code, | $query = "SELECT stop_times.trip_id,arrival_time,stop_times.stop_id,stop_lat,stop_lon,stop_name,stop_code, |
| stop_sequence,service_id,trips.route_id,route_short_name,route_long_name | stop_sequence,service_id,trips.route_id,route_short_name,route_long_name |
| FROM stop_times | FROM stop_times |
| join trips on trips.trip_id = stop_times.trip_id | join trips on trips.trip_id = stop_times.trip_id |
| join routes on trips.route_id = routes.route_id | join routes on trips.route_id = routes.route_id |
| join stops on stops.stop_id = stop_times.stop_id | join stops on stops.stop_id = stop_times.stop_id |
| WHERE trips.trip_id = '$tripID' ORDER BY stop_sequence"; | WHERE trips.trip_id = '$tripID' ORDER BY stop_sequence"; |
| debug($query, "database"); | debug($query, "database"); |
| $result = pg_query($conn, $query); | $result = pg_query($conn, $query); |
| if (!$result) { | if (!$result) { |
| databaseError(pg_result_error($result)); | databaseError(pg_result_error($result)); |
| return Array(); | return Array(); |
| } | } |
| $stopTimes = pg_fetch_all($result); | $stopTimes = pg_fetch_all($result); |
| $cur_timepoint = Array(); | $cur_timepoint = Array(); |
| $next_timepoint = Array(); | $next_timepoint = Array(); |
| $distance_between_timepoints = 0.0; | $distance_between_timepoints = 0.0; |
| $distance_traveled_between_timepoints = 0.0; | $distance_traveled_between_timepoints = 0.0; |
| $rv = Array(); | $rv = Array(); |
| foreach ($stopTimes as $i => $stopTime) { | foreach ($stopTimes as $i => $stopTime) { |
| if ($stopTime['arrival_time'] != "") { | if ($stopTime['arrival_time'] != "") { |
| // is timepoint | // is timepoint |
| $cur_timepoint = $stopTime; | $cur_timepoint = $stopTime; |
| $distance_between_timepoints = 0.0; | $distance_between_timepoints = 0.0; |
| $distance_traveled_between_timepoints = 0.0; | $distance_traveled_between_timepoints = 0.0; |
| if ($i + 1 < sizeof($stopTimes)) { | if ($i + 1 < sizeof($stopTimes)) { |
| $k = $i + 1; | $k = $i + 1; |
| $distance_between_timepoints += distance($stopTimes[$k - 1]["stop_lat"], $stopTimes[$k - 1]["stop_lon"], $stopTimes[$k]["stop_lat"], $stopTimes[$k]["stop_lon"]); | $distance_between_timepoints += distance($stopTimes[$k - 1]["stop_lat"], $stopTimes[$k - 1]["stop_lon"], $stopTimes[$k]["stop_lat"], $stopTimes[$k]["stop_lon"]); |
| while ($stopTimes[$k]["arrival_time"] == "" && $k + 1 < sizeof($stopTimes)) { | while ($stopTimes[$k]["arrival_time"] == "" && $k + 1 < sizeof($stopTimes)) { |
| $k += 1; | $k += 1; |
| //echo "k".$k; | //echo "k".$k; |
| $distance_between_timepoints += distance($stopTimes[$k - 1]["stop_lat"], $stopTimes[$k - 1]["stop_lon"], $stopTimes[$k]["stop_lat"], $stopTimes[$k]["stop_lon"]); | $distance_between_timepoints += distance($stopTimes[$k - 1]["stop_lat"], $stopTimes[$k - 1]["stop_lon"], $stopTimes[$k]["stop_lat"], $stopTimes[$k]["stop_lon"]); |
| } | } |
| $next_timepoint = $stopTimes[$k]; | $next_timepoint = $stopTimes[$k]; |
| $rv[] = $stopTime; | $rv[] = $stopTime; |
| } | } |
| } | } |
| else { | else { |
| // is untimed point | // is untimed point |
| //echo "i".$i; | //echo "i".$i; |
| $distance_traveled_between_timepoints += distance($stopTimes[$i - 1]["stop_lat"], $stopTimes[$i - 1]["stop_lon"], $stopTimes[$i]["stop_lat"], $stopTimes[$i]["stop_lon"]); | $distance_traveled_between_timepoints += distance($stopTimes[$i - 1]["stop_lat"], $stopTimes[$i - 1]["stop_lon"], $stopTimes[$i]["stop_lat"], $stopTimes[$i]["stop_lon"]); |
| //echo "$distance_traveled_between_timepoints / $distance_between_timepoints<br>"; | //echo "$distance_traveled_between_timepoints / $distance_between_timepoints<br>"; |
| $distance_percent = $distance_traveled_between_timepoints / $distance_between_timepoints; | $distance_percent = $distance_traveled_between_timepoints / $distance_between_timepoints; |
| if ($next_timepoint["arrival_time"] != "") { | if ($next_timepoint["arrival_time"] != "") { |
| $total_time = strtotime($next_timepoint["arrival_time"]) - strtotime($cur_timepoint["arrival_time"]); | $total_time = strtotime($next_timepoint["arrival_time"]) - strtotime($cur_timepoint["arrival_time"]); |
| //echo strtotime($next_timepoint["arrival_time"])." - ".strtotime($cur_timepoint["arrival_time"])."<br>"; | //echo strtotime($next_timepoint["arrival_time"])." - ".strtotime($cur_timepoint["arrival_time"])."<br>"; |
| $time_estimate = ($distance_percent * $total_time) + strtotime($cur_timepoint["arrival_time"]); | $time_estimate = ($distance_percent * $total_time) + strtotime($cur_timepoint["arrival_time"]); |
| $stopTime["arrival_time"] = date("H:i:s", $time_estimate); | $stopTime["arrival_time"] = date("H:i:s", $time_estimate); |
| } else { | } else { |
| $stopTime["arrival_time"] = $cur_timepoint["arrival_time"]; | $stopTime["arrival_time"] = $cur_timepoint["arrival_time"]; |
| } | } |
| $rv[] = $stopTime; | $rv[] = $stopTime; |
| //var_dump($rv); | //var_dump($rv); |
| } | } |
| } | } |
| return $rv; | return $rv; |
| } | } |
| function getTimeInterpolatedTripAtStop($tripID, $stop_sequence) | function getTimeInterpolatedTripAtStop($tripID, $stop_sequence, $stop_id = "") |
| { | { |
| foreach (getTimeInterpolatedTrip($tripID) as $tripStop) { | foreach (getTimeInterpolatedTrip($tripID) as $tripStop) { |
| if ($tripStop['stop_sequence'] == $stop_sequence) return $tripStop; | if ($tripStop['stop_sequence'] == $stop_sequence) return $tripStop; |
| if ($tripStop['stop_id'] == $stop_id) return $tripStop; | |
| } | } |
| return Array(); | return Array(); |
| } | } |
| function getTripStartTime($tripID) | function getTripStartTime($tripID) |
| { | { |
| global $conn; | global $conn; |
| $query = "Select * from stop_times | $query = "Select * from stop_times |
| where trip_id = '$tripID' | where trip_id = '$tripID' |
| AND arrival_time IS NOT NULL | AND arrival_time IS NOT NULL |
| AND stop_sequence = '1'"; | AND stop_sequence = '1'"; |
| debug($query, "database"); | debug($query, "database"); |
| $result = pg_query($conn, $query); | $result = pg_query($conn, $query); |
| if (!$result) { | if (!$result) { |
| databaseError(pg_result_error($result)); | databaseError(pg_result_error($result)); |
| return Array(); | return Array(); |
| } | } |
| $r = pg_fetch_assoc($result); | $r = pg_fetch_assoc($result); |
| return $r['arrival_time']; | return $r['arrival_time']; |
| } | } |
| function viaPointNames($tripid, $stop_sequence = "") | function viaPointNames($tripid, $stop_sequence = "") |
| { | { |
| global $conn; | global $conn; |
| $query = "SELECT stop_name | $query = "SELECT stop_name |
| FROM stop_times join stops on stops.stop_id = stop_times.stop_id | FROM stop_times join stops on stops.stop_id = stop_times.stop_id |
| WHERE stop_times.trip_id = '$tripid' | WHERE stop_times.trip_id = '$tripid' |
| ".($stop_sequence != "" ? "AND stop_sequence > '$stop_sequence'" : ""). | ".($stop_sequence != "" ? "AND stop_sequence > '$stop_sequence'" : ""). |
| "AND substr(stop_code,1,2) != 'Wj' ORDER BY stop_sequence"; | "AND substr(stop_code,1,2) != 'Wj' ORDER BY stop_sequence"; |
| debug($query, "database"); | debug($query, "database"); |
| $result = pg_query($conn, $query); | $result = pg_query($conn, $query); |
| if (!$result) { | if (!$result) { |
| databaseError(pg_result_error($result)); | databaseError(pg_result_error($result)); |
| return Array(); | return Array(); |
| } | } |
| $pointNames = pg_fetch_all($result); | $pointNames = pg_fetch_all($result); |
| return r_implode(", ", $pointNames); | return r_implode(", ", $pointNames); |
| } | } |
| ?> | ?> |