| <?php | <?php |
| /* | /* |
| * Copyright 2010,2011 Alexander Sadleir | * Copyright 2010,2011 Alexander Sadleir |
| Licensed under the Apache License, Version 2.0 (the "License"); | Licensed under the Apache License, Version 2.0 (the "License"); |
| you may not use this file except in compliance with the License. | you may not use this file except in compliance with the License. |
| You may obtain a copy of the License at | You may obtain a copy of the License at |
| http://www.apache.org/licenses/LICENSE-2.0 | http://www.apache.org/licenses/LICENSE-2.0 |
| Unless required by applicable law or agreed to in writing, software | Unless required by applicable law or agreed to in writing, software |
| distributed under the License is distributed on an "AS IS" BASIS, | distributed under the License is distributed on an "AS IS" BASIS, |
| WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| See the License for the specific language governing permissions and | See the License for the specific language governing permissions and |
| limitations under the License. | limitations under the License. |
| */ | */ |
| function getStop($stopID) { | function getStop($stopID) { |
| global $conn; | global $conn; |
| $query = "Select * from stops where stop_id = :stopID LIMIT 1"; | $query = "Select * from stops where stop_id = :stopID LIMIT 1"; |
| debug($query, "database"); | debug($query, "database"); |
| $query = $conn->prepare($query); | $query = $conn->prepare($query); |
| $query->bindParam(":stopID", $stopID); | $query->bindParam(":stopID", $stopID); |
| $query->execute(); | $query->execute(); |
| if (!$query) { | if (!$query) { |
| databaseError($conn->errorInfo()); | databaseError($conn->errorInfo()); |
| return Array(); | return Array(); |
| } | } |
| return $query->fetch(PDO :: FETCH_ASSOC); | return $query->fetch(PDO :: FETCH_ASSOC); |
| } | } |
| function getStops($firstLetter = "", $startsWith = "") { | function getStops($firstLetter = "", $startsWith = "") { |
| global $conn; | global $conn; |
| $conditions = Array(); | $conditions = Array(); |
| if ($firstLetter != "") | if ($firstLetter != "") |
| $conditions[] = "substr(stop_name,1,1) = :firstLetter"; | $conditions[] = "substr(stop_name,1,1) = :firstLetter"; |
| if ($startsWith != "") | if ($startsWith != "") |
| $conditions[] = "stop_name like :startsWith"; | $conditions[] = "stop_name like :startsWith"; |
| $query = "Select * from stops"; | $query = "Select * from stops"; |
| if (sizeof($conditions) > 0) { | if (sizeof($conditions) > 0) { |
| if (sizeof($conditions) > 1) { | if (sizeof($conditions) > 1) { |
| $query .= " Where " . implode(" AND ", $conditions) . " "; | $query .= " Where " . implode(" AND ", $conditions) . " "; |
| } else { | } else { |
| $query .= " Where " . $conditions[0] . " "; | $query .= " Where " . $conditions[0] . " "; |
| } | } |
| } | } |
| $query .= " order by stop_name;"; | $query .= " order by stop_name;"; |
| debug($query,"database"); | debug($query, "database"); |
| $query = $conn->prepare($query); | $query = $conn->prepare($query); |
| if ($firstLetter != "") | if ($firstLetter != "") |
| $query->bindParam(":firstLetter", $firstLetter); | $query->bindParam(":firstLetter", $firstLetter); |
| if ($startsWith != "") { | if ($startsWith != "") { |
| $startsWith = $startsWith . "%"; | $startsWith = $startsWith . "%"; |
| $query->bindParam(":startsWith", $startsWith); | $query->bindParam(":startsWith", $startsWith); |
| } | } |
| $query->execute(); | $query->execute(); |
| if (!$query) { | if (!$query) { |
| databaseError($conn->errorInfo()); | databaseError($conn->errorInfo()); |
| return Array(); | return Array(); |
| } | } |
| return $query->fetchAll(); | return $query->fetchAll(); |
| } | } |
| function getNearbyStops($lat, $lng, $limit = "", $distance = 1000) { | function getNearbyStops($lat, $lng, $limit = "", $distance = 1000) { |
| if ($lat == null || $lng == null) | if ($lat == null || $lng == null) |
| return Array(); | return Array(); |
| if ($limit != "") | if ($limit != "") |
| $limitSQL = " LIMIT :limit "; | $limitSQL = " LIMIT :limit "; |
| global $conn; | global $conn; |
| $query = "Select *, ST_Distance(position, ST_GeographyFromText('SRID=4326;POINT($lng $lat)'), FALSE) as distance | $query = "Select *, ST_Distance(position, ST_GeographyFromText('SRID=4326;POINT($lng $lat)'), FALSE) as distance |
| from stops WHERE ST_DWithin(position, ST_GeographyFromText('SRID=4326;POINT($lng $lat)'), :distance, FALSE) | from stops WHERE ST_DWithin(position, ST_GeographyFromText('SRID=4326;POINT($lng $lat)'), :distance, FALSE) |
| order by distance $limitSQL;"; | order by distance $limitSQL;"; |
| debug($query, "database"); | debug($query, "database"); |
| $query = $conn->prepare($query); | $query = $conn->prepare($query); |
| $query->bindParam(":distance", $distance); | $query->bindParam(":distance", $distance); |
| $query->bindParam(":limit", $limit); | $query->bindParam(":limit", $limit); |
| $query->execute(); | $query->execute(); |
| if (!$query) { | if (!$query) { |
| databaseError($conn->errorInfo()); | databaseError($conn->errorInfo()); |
| return Array(); | return Array(); |
| } | } |
| return $query->fetchAll(); | return $query->fetchAll(); |
| } | } |
| function getStopsByName($name) { | function getStopsByName($name) { |
| global $conn; | global $conn; |
| $query = "Select * from stops where stop_name LIKE :name;"; | $query = "Select * from stops where stop_name LIKE :name;"; |
| debug($query, "database"); | debug($query, "database"); |
| $query = $conn->prepare($query); | $query = $conn->prepare($query); |
| $name = "%" . $name . ";%"; | $name = "%" . $name . ";%"; |
| $query->bindParam(":name", $name); | $query->bindParam(":name", $name); |
| $query->execute(); | $query->execute(); |
| if (!$query) { | if (!$query) { |
| databaseError($conn->errorInfo()); | databaseError($conn->errorInfo()); |
| return Array(); | return Array(); |
| } | } |
| return $query->fetchAll(); | return $query->fetchAll(); |
| } | } |
| function getStopsBySuburb($suburb) { | function getStopsBySuburb($suburb) { |
| global $conn; | global $conn; |
| $query = "Select * from stops where stop_desc LIKE :suburb order by stop_name;"; | $query = "Select * from stops where stop_desc LIKE :suburb order by stop_name;"; |
| debug($query, "database"); | debug($query, "database"); |
| $query = $conn->prepare($query); | $query = $conn->prepare($query); |
| $suburb = "%<br>Suburb: %" . $suburb . "%"; | $suburb = "%<br>Suburb: %" . $suburb . "%"; |
| $query->bindParam(":suburb", $suburb); | $query->bindParam(":suburb", $suburb); |
| $query->execute(); | $query->execute(); |
| if (!$query) { | if (!$query) { |
| databaseError($conn->errorInfo()); | databaseError($conn->errorInfo()); |
| return Array(); | return Array(); |
| } | } |
| return $query->fetchAll(); | return $query->fetchAll(); |
| } | } |
| function getStopsByStopCode($stop_code, $startsWith = "") { | function getStopsByStopCode($stop_code, $startsWith = "") { |
| global $conn; | global $conn; |
| $query = "Select * from stops where (stop_code = :stop_code OR stop_code LIKE :stop_code2)"; | $query = "Select * from stops where (stop_code = :stop_code OR stop_code LIKE :stop_code2)"; |
| if ($startsWith != "") | if ($startsWith != "") |
| $query .= " AND stop_name like :startsWith"; | $query .= " AND stop_name like :startsWith"; |
| debug($query, "database"); | debug($query, "database"); |
| $query = $conn->prepare($query); | $query = $conn->prepare($query); |
| $query->bindParam(":stop_code", $stop_code); | $query->bindParam(":stop_code", $stop_code); |
| $stop_code2 = $stop_code . "%"; | $stop_code2 = $stop_code . "%"; |
| $query->bindParam(":stop_code2", $stop_code2); | $query->bindParam(":stop_code2", $stop_code2); |
| if ($startsWith != "") { | if ($startsWith != "") { |
| $startsWith = $startsWith . "%"; | $startsWith = $startsWith . "%"; |
| $query->bindParam(":startsWith", $startsWith); | $query->bindParam(":startsWith", $startsWith); |
| } | } |
| $query->execute(); | $query->execute(); |
| if (!$query) { | if (!$query) { |
| databaseError($conn->errorInfo()); | databaseError($conn->errorInfo()); |
| return Array(); | return Array(); |
| } | } |
| return $query->fetchAll(); | return $query->fetchAll(); |
| } | } |
| function getStopRoutes($stopID, $service_period) { | function getStopRoutes($stopID, $service_period) { |
| if ($service_period == "") { | if ($service_period == "") { |
| $service_period = service_period(); | $service_period = service_period(); |
| } | } |
| $service_ids = service_ids($service_period); | $service_ids = service_ids($service_period); |
| $sidA = $service_ids[0]; | $sidA = $service_ids[0]; |
| $sidB = $service_ids[1]; | $sidB = $service_ids[1]; |
| global $conn; | global $conn; |
| $query = "SELECT distinct service_id,trips.route_id,route_short_name,route_long_name | $query = "SELECT distinct service_id,trips.route_id,route_short_name,route_long_name |
| FROM stop_times join trips on trips.trip_id = | FROM stop_times join trips on trips.trip_id = |
| stop_times.trip_id join routes on trips.route_id = routes.route_id WHERE stop_id = :stopID | stop_times.trip_id join routes on trips.route_id = routes.route_id WHERE stop_id = :stopID |
| AND (service_id=:service_periodA OR service_id=:service_periodB)"; | AND (service_id=:service_periodA OR service_id=:service_periodB)"; |
| debug($query, "database"); | debug($query, "database"); |
| $query = $conn->prepare($query); | $query = $conn->prepare($query); |
| $query->bindParam(":service_periodA", $sidA); | $query->bindParam(":service_periodA", $sidA); |
| $query->bindParam(":service_periodB", $sidB); | $query->bindParam(":service_periodB", $sidB); |
| $query->bindParam(":stopID", $stopID); | $query->bindParam(":stopID", $stopID); |
| $query->execute(); | $query->execute(); |
| if (!$query) { | if (!$query) { |
| databaseError($conn->errorInfo()); | databaseError($conn->errorInfo()); |
| return Array(); | return Array(); |
| } | } |
| return $query->fetchAll(); | return $query->fetchAll(); |
| } | } |
| function getStopTrips($stopID, $service_period = "", $afterTime = "", $limit = "", $route_short_name = "") { | function getStopTrips($stopID, $service_period = "", $afterTime = "", $limit = "", $route_short_name = "") { |
| if ($service_period == "") { | if ($service_period == "") { |
| $service_period = service_period(); | $service_period = service_period(); |
| } | } |
| $service_ids = service_ids($service_period); | $service_ids = service_ids($service_period); |
| $sidA = $service_ids[0]; | $sidA = $service_ids[0]; |
| $sidB = $service_ids[1]; | $sidB = $service_ids[1]; |
| $limitSQL = ""; | $limitSQL = ""; |
| if ($limit != "") | if ($limit != "") |
| $limitSQL .= " LIMIT :limit "; | $limitSQL .= " LIMIT :limit "; |
| global $conn; | global $conn; |
| if ($afterTime != "") { | if ($afterTime != "") { |
| $query = " SELECT stop_times.trip_id,stop_times.arrival_time,stop_times.stop_id,stop_sequence,service_id,trips.route_id,trips.direction_id,route_short_name,route_long_name,end_times.arrival_time as end_time | $query = " SELECT stop_times.trip_id,stop_times.arrival_time,stop_times.stop_id,stop_sequence,service_id,trips.route_id,trips.direction_id,trips.trip_headsign,route_short_name,route_long_name,end_times.arrival_time as end_time |
| FROM stop_times | FROM stop_times |
| join trips on trips.trip_id = | join trips on trips.trip_id = |
| stop_times.trip_id | stop_times.trip_id |
| join routes on trips.route_id = routes.route_id , (SELECT trip_id,max(arrival_time) as arrival_time from stop_times | join routes on trips.route_id = routes.route_id , (SELECT trip_id,max(arrival_time) as arrival_time from stop_times |
| WHERE stop_times.arrival_time IS NOT NULL group by trip_id) as end_times | WHERE stop_times.arrival_time IS NOT NULL group by trip_id) as end_times |
| WHERE stop_times.stop_id = :stopID | WHERE stop_times.stop_id = :stopID |
| AND stop_times.trip_id = end_times.trip_id | AND stop_times.trip_id = end_times.trip_id |
| AND (service_id=:service_periodA OR service_id=:service_periodB) ".($route_short_name != "" ? " AND route_short_name = :route_short_name ":"")." | AND (service_id=:service_periodA OR service_id=:service_periodB) " . ($route_short_name != "" ? " AND route_short_name = :route_short_name " : "") . " |
| AND end_times.arrival_time > :afterTime | AND end_times.arrival_time > :afterTime |
| ORDER BY end_time $limitSQL"; | ORDER BY end_time $limitSQL"; |
| } else { | } else { |
| $query = "SELECT stop_times.trip_id,arrival_time,stop_times.stop_id,stop_sequence,service_id,trips.route_id,route_short_name,route_long_name | $query = "SELECT stop_times.trip_id,arrival_time,stop_times.stop_id,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 = | join trips on trips.trip_id = |
| stop_times.trip_id | stop_times.trip_id |
| join routes on trips.route_id = routes.route_id | join routes on trips.route_id = routes.route_id |
| WHERE stop_times.stop_id = :stopID | WHERE stop_times.stop_id = :stopID |
| AND (service_id=:service_periodA OR service_id=:service_periodB) ".($route_short_name != "" ? " AND route_short_name = :route_short_name ":"")." | AND (service_id=:service_periodA OR service_id=:service_periodB) " . ($route_short_name != "" ? " AND route_short_name = :route_short_name " : "") . " |
| ORDER BY arrival_time $limitSQL"; | ORDER BY arrival_time $limitSQL"; |
| } | } |
| debug($query, "database"); | debug($query, "database"); |
| $query = $conn->prepare($query); | $query = $conn->prepare($query); |
| $query->bindParam(":service_periodA", $sidA); | $query->bindParam(":service_periodA", $sidA); |
| $query->bindParam(":service_periodB", $sidB); | $query->bindParam(":service_periodB", $sidB); |
| $query->bindParam(":stopID", $stopID); | $query->bindParam(":stopID", $stopID); |
| if ($limit != "") | if ($limit != "") |
| $query->bindParam(":limit", $limit); | $query->bindParam(":limit", $limit); |
| if ($afterTime != "") | if ($afterTime != "") |
| $query->bindParam(":afterTime", $afterTime); | $query->bindParam(":afterTime", $afterTime); |
| if ($route_short_name != "") | if ($route_short_name != "") |
| $query->bindParam(":route_short_name", $route_short_name); | $query->bindParam(":route_short_name", $route_short_name); |
| $query->execute(); | $query->execute(); |
| if (!$query) { | if (!$query) { |
| databaseError($conn->errorInfo()); | databaseError($conn->errorInfo()); |
| return Array(); | return Array(); |
| } | } |
| return $query->fetchAll(); | return $query->fetchAll(); |
| } | } |
| function getStopTripsWithTimes($stopID, $time = "", $service_period = "", $time_range = "", $limit = "") { | function getStopTripsWithTimes($stopID, $time = "", $service_period = "", $time_range = "", $limit = "") { |
| if ($service_period == "") | if ($service_period == "") |
| $service_period = service_period(); | $service_period = service_period(); |
| if ($time_range == "") | if ($time_range == "") |
| $time_range = (24 * 60 * 60); | $time_range = (24 * 60 * 60); |
| if ($time == "") | if ($time == "") |
| $time = current_time(); | $time = current_time(); |
| if ($limit == "") | if ($limit == "") |
| $limit = 10; | $limit = 10; |
| $trips = getStopTrips($stopID, $service_period, $time); | $trips = getStopTrips($stopID, $service_period, $time); |
| $timedTrips = Array(); | $timedTrips = Array(); |
| if ($trips && sizeof($trips) > 0) { | if ($trips && sizeof($trips) > 0) { |
| foreach ($trips as $trip) { | foreach ($trips as $trip) { |
| if ($trip['arrival_time'] != "") { | if ($trip['arrival_time'] != "") { |
| if (strtotime($trip['arrival_time']) > strtotime($time) and strtotime($trip['arrival_time']) < (strtotime($time) + $time_range)) { | if (strtotime($trip['arrival_time']) > strtotime($time) and strtotime($trip['arrival_time']) < (strtotime($time) + $time_range)) { |
| $timedTrips[] = $trip; | $timedTrips[] = $trip; |
| } | } |
| } else { | } else { |
| $timedTrip = getTripAtStop($trip['trip_id'], $trip['stop_sequence']); | $timedTrip = getTripAtStop($trip['trip_id'], $trip['stop_sequence']); |
| if ($timedTrip['arrival_time'] > $time and strtotime($timedTrip['arrival_time']) < (strtotime($time) + $time_range)) { | if ($timedTrip['arrival_time'] > $time and strtotime($timedTrip['arrival_time']) < (strtotime($time) + $time_range)) { |
| $timedTrips[] = $timedTrip; | $timedTrips[] = $timedTrip; |
| } | } |
| } | } |
| if (sizeof($timedTrips) > $limit) | if (sizeof($timedTrips) > $limit) |
| break; | break; |
| } | } |
| sktimesort($timedTrips, "arrival_time", true); | sktimesort($timedTrips, "arrival_time", true); |
| } | } |
| return $timedTrips; | return $timedTrips; |
| } | } |
| ?> | ?> |
| <?php | <?php |
| /* | /* |
| * Copyright 2010,2011 Alexander Sadleir | * Copyright 2010,2011 Alexander Sadleir |
| Licensed under the Apache License, Version 2.0 (the "License"); | Licensed under the Apache License, Version 2.0 (the "License"); |
| you may not use this file except in compliance with the License. | you may not use this file except in compliance with the License. |
| You may obtain a copy of the License at | You may obtain a copy of the License at |
| http://www.apache.org/licenses/LICENSE-2.0 | http://www.apache.org/licenses/LICENSE-2.0 |
| Unless required by applicable law or agreed to in writing, software | Unless required by applicable law or agreed to in writing, software |
| distributed under the License is distributed on an "AS IS" BASIS, | distributed under the License is distributed on an "AS IS" BASIS, |
| WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| See the License for the specific language governing permissions and | See the License for the specific language governing permissions and |
| limitations under the License. | limitations under the License. |
| */ | */ |
| include ('../include/common.inc.php'); | include ('../include/common.inc.php'); |
| include_header("MyWay Deltas", "mywayDelta"); | include_header("MyWay Deltas", "mywayDelta"); |
| ?> | ?> |
| <!--[if lte IE 8]><script language="javascript" type="text/javascript" src="../js/flot/excanvas.min.js"></script><![endif]--> | <!--[if lte IE 8]><script language="javascript" type="text/javascript" src="../js/flot/excanvas.min.js"></script><![endif]--> |
| <script language="javascript" type="text/javascript" src="../js/flot/jquery.flot.js"></script> | <script language="javascript" type="text/javascript" src="../js/flot/jquery.flot.js"></script> |
| <center><div id="placeholder" style="width:900px;height:550px"></div></center> | <center><div id="placeholder" style="width:900px;height:550px"></div></center> |
| <script type="text/javascript"> | <script type="text/javascript"> |
| $(function () { | $(function () { |
| var d = new Date(); | var d = new Date(); |
| d.setUTCMinutes(0); | d.setUTCMinutes(0); |
| d.setUTCHours(0); | d.setUTCHours(0); |
| var midnight = d.getTime(); | var midnight = d.getTime(); |
| <?php | <?php |
| $query = "select * from myway_timingdeltas where abs(timing_delta) < 2*(select stddev(timing_delta) from myway_timingdeltas) order by route_name;"; | $query = "select * from myway_timingdeltas where abs(timing_delta) < 2*(select stddev(timing_delta) from myway_timingdeltas) order by route_name;"; |
| $query = $conn->prepare($query); | $query = $conn->prepare($query); |
| $query->execute(); | $query->execute(); |
| if (!$query) { | if (!$query) { |
| databaseError($conn->errorInfo()); | databaseError($conn->errorInfo()); |
| return Array(); | return Array(); |
| } | } |
| $i = 0; | $i = 0; |
| $labels = Array(); | $labels = Array(); |
| $lastRoute = ""; | $lastRoute = ""; |
| foreach ($query->fetchAll() as $delta) { | foreach ($query->fetchAll() as $delta) { |
| /*$routeIDParts = explode(" ",$delta['route_name']); | |
| $routeNumber = $routeIDParts[0]; | |
| $routeDirection = $routeIDParts[1]; | |
| if (preg_match('/31./',$routeName)) { | |
| $routeName = "312-319"." ".$routeDirection; | |
| } else { | |
| $routeName = $delta['route_name']; | |
| }*/ | |
| $routeName = $delta['route_name']; | $routeName = $delta['route_name']; |
| if (preg_match('/z/',$routeName)) { | |
| if (preg_match('/31./',$routeName)) { | |
| $routeName = "312-319"; | $routeName = "312-319"; |
| } else { | } else { |
| $routeName = preg_replace('/\D/', '', $routeName); | $routeName = preg_replace('/\D/', '', $routeName); |
| } | } |
| if ($routeName != $lastRoute) { | if ($routeName != $lastRoute) { |
| $i++; | $i++; |
| echo " var d$i = [];"; | echo " var d$i = [];"; |
| $lastRoute = $routeName; | $lastRoute = $routeName; |
| $labels[$i] = $routeName; | $labels[$i] = $routeName; |
| } | } |
| echo "d$i.push([ midnight+ (1000*" . midnight_seconds(strtotime($delta['time'])) . "), " . intval($delta['timing_delta']) . "]); \n"; | echo "d$i.push([ midnight+ (1000*" . midnight_seconds(strtotime($delta['time'])) . "), " . intval($delta['timing_delta']) . "]); \n"; |
| }; | }; |
| ?> | ?> |
| var placeholder = $("#placeholder"); | var placeholder = $("#placeholder"); |
| var plot = $.plot(placeholder, [ | var plot = $.plot(placeholder, [ |
| <?php | <?php |
| foreach ($labels as $key => $label) { | foreach ($labels as $key => $label) { |
| echo " { | echo " { |
| data: d$key, | data: d$key, |
| points: { show: true }, | points: { show: true }, |
| label: '$label' | label: '$label' |
| },"; | },"; |
| } | } |
| ?> | ?> |
| ], | ], |
| { | { |
| xaxis: { | xaxis: { |
| mode: "time", | mode: "time", |
| min: midnight + (1000*60*60*8), | min: midnight + (1000*60*60*8), |
| max: midnight + (1000*60*60*23.5) | max: midnight + (1000*60*60*23.5) |
| }, | }, |
| yaxis: { | yaxis: { |
| tickFormatter: yformatter | tickFormatter: yformatter |
| }, | }, |
| grid: { hoverable: true, clickable: true, labelMargin: 32 } | grid: { hoverable: true, clickable: true, labelMargin: 32 } |
| }); | }); |
| var o; | var o; |
| o = plot.pointOffset({ x: midnight+ (9*60*60*1000), y: -1.2}); | o = plot.pointOffset({ x: midnight+ (9*60*60*1000), y: -1.2}); |
| placeholder.append('<div style="position:absolute;left:' + (o.left + 4) + 'px;top:' + o.top + 'px;color:#666;font-size:smaller">9am</div>'); | placeholder.append('<div style="position:absolute;left:' + (o.left + 4) + 'px;top:' + o.top + 'px;color:#666;font-size:smaller">9am</div>'); |
| o = plot.pointOffset({ x: midnight+ (16*60*60*1000), y: -1.2}); | o = plot.pointOffset({ x: midnight+ (16*60*60*1000), y: -1.2}); |
| placeholder.append('<div style="position:absolute;left:' + (o.left + 4) + 'px;top:' + o.top + 'px;color:#666;font-size:smaller">4pm</div>'); | placeholder.append('<div style="position:absolute;left:' + (o.left + 4) + 'px;top:' + o.top + 'px;color:#666;font-size:smaller">4pm</div>'); |
| }); | }); |
| function yformatter(v) { | function yformatter(v) { |
| if (Math.floor(v/60) < -9) return ""; | if (Math.floor(v/60) < -9) return ""; |
| return Math.abs(Math.floor(v/60)) + " min " + (v == 0 ? "" : (v >0 ? "early":"late")) | return Math.abs(Math.floor(v/60)) + " min " + (v == 0 ? "" : (v >0 ? "early":"late")) |
| } | } |
| function showTooltip(x, y, contents) { | function showTooltip(x, y, contents) { |
| $('<div id="tooltip">' + contents + '</div>').css( { | $('<div id="tooltip">' + contents + '</div>').css( { |
| position: 'absolute', | position: 'absolute', |
| display: 'none', | display: 'none', |
| top: y + 5, | top: y + 5, |
| left: x + 5, | left: x + 5, |
| border: '1px solid #fdd', | border: '1px solid #fdd', |
| padding: '2px', | padding: '2px', |
| 'background-color': '#fee', | 'background-color': '#fee', |
| opacity: 0.80 | opacity: 0.80 |
| }).appendTo("body").fadeIn(200); | }).appendTo("body").fadeIn(200); |
| } | } |
| var previousPoint = null; | var previousPoint = null; |
| $("#placeholder").bind("plothover", function (event, pos, item) { | $("#placeholder").bind("plothover", function (event, pos, item) { |
| $("#x").text(pos.x.toFixed(2)); | $("#x").text(pos.x.toFixed(2)); |
| $("#y").text(pos.y.toFixed(2)); | $("#y").text(pos.y.toFixed(2)); |
| if (item) { | if (item) { |
| if (previousPoint != item.dataIndex) { | if (previousPoint != item.dataIndex) { |
| previousPoint = item.dataIndex; | previousPoint = item.dataIndex; |
| $("#tooltip").remove(); | $("#tooltip").remove(); |
| var x = item.datapoint[0].toFixed(2), | var x = item.datapoint[0].toFixed(2), |
| y = item.datapoint[1].toFixed(2); | y = item.datapoint[1].toFixed(2); |
| var d = new Date(); | var d = new Date(); |
| d.setTime(x); | d.setTime(x); |
| var time = d.getUTCHours() +':'+ (d.getUTCMinutes().toString().length == 1 ? '0'+ d.getMinutes(): d.getUTCMinutes()) | var time = d.getUTCHours() +':'+ (d.getUTCMinutes().toString().length == 1 ? '0'+ d.getMinutes(): d.getUTCMinutes()) |
| showTooltip(item.pageX, item.pageY, | showTooltip(item.pageX, item.pageY, |
| item.series.label + " at "+ time +" = " + Math.abs(new Number(y/60).toFixed(2))+" minutes "+(y >0 ? "early":"late")); | item.series.label + " at "+ time +" = " + Math.abs(new Number(y/60).toFixed(2))+" minutes "+(y >0 ? "early":"late")); |
| } | } |
| } | } |
| else { | else { |
| $("#tooltip").remove(); | $("#tooltip").remove(); |
| previousPoint = null; | previousPoint = null; |
| } | } |
| }); | }); |
| </script> | </script> |
| <?php | <?php |
| /* | /* |
| * Copyright 2010,2011 Alexander Sadleir | * Copyright 2010,2011 Alexander Sadleir |
| Licensed under the Apache License, Version 2.0 (the "License"); | Licensed under the Apache License, Version 2.0 (the "License"); |
| you may not use this file except in compliance with the License. | you may not use this file except in compliance with the License. |
| You may obtain a copy of the License at | You may obtain a copy of the License at |
| http://www.apache.org/licenses/LICENSE-2.0 | http://www.apache.org/licenses/LICENSE-2.0 |
| Unless required by applicable law or agreed to in writing, software | Unless required by applicable law or agreed to in writing, software |
| distributed under the License is distributed on an "AS IS" BASIS, | distributed under the License is distributed on an "AS IS" BASIS, |
| WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| See the License for the specific language governing permissions and | See the License for the specific language governing permissions and |
| limitations under the License. | limitations under the License. |
| */ | */ |
| include ('../include/common.inc.php'); | include ('../include/common.inc.php'); |
| include_header("MyWay Delta Calculate", "mywayDeltaCalc"); | include_header("MyWay Delta Calculate", "mywayDeltaCalc"); |
| flush(); | flush(); |
| ob_flush(); | ob_flush(); |
| function abssort($a, $b) { | function abssort($a, $b) { |
| if ($a['timeDiff'] == $b['timeDiff']) { | if ($a['timeDiff'] == $b['timeDiff']) { |
| return 0; | return 0; |
| } | } |
| return (abs($a['timeDiff']) < abs($b['timeDiff'])) ? -1 : 1; | return (abs($a['timeDiff']) < abs($b['timeDiff'])) ? -1 : 1; |
| } | } |
| //collect all observation not in delta | //collect all observation not in delta |
| $query = "select * from myway_observations INNER JOIN myway_stops | $query = "select * from myway_observations INNER JOIN myway_stops |
| ON myway_observations.myway_stop=myway_stops.myway_stop INNER JOIN myway_routes | ON myway_observations.myway_stop=myway_stops.myway_stop INNER JOIN myway_routes |
| ON myway_observations.myway_route=myway_routes.myway_route | ON myway_observations.myway_route=myway_routes.myway_route |
| WHERE observation_id NOT IN | WHERE observation_id NOT IN |
| ( | ( |
| SELECT observation_id | SELECT observation_id |
| FROM myway_timingdeltas | FROM myway_timingdeltas |
| )"; | )"; |
| debug($query, "database"); | debug($query, "database"); |
| $query = $conn->prepare($query); | $query = $conn->prepare($query); |
| $query->execute(); | $query->execute(); |
| if (!$query) { | if (!$query) { |
| databaseError($conn->errorInfo()); | databaseError($conn->errorInfo()); |
| return Array(); | return Array(); |
| } | } |
| $uncalcdObservations = $query->fetchAll(); | $uncalcdObservations = $query->fetchAll(); |
| //Display count | //Display count |
| echo "<h3>" . sizeof($uncalcdObservations) . " observations not yet processed</h2>"; | echo "<h3>" . sizeof($uncalcdObservations) . " observations not yet processed</h2>"; |
| //foreach observation not in delta | //foreach observation not in delta |
| foreach ($uncalcdObservations as $obsv) { | foreach ($uncalcdObservations as $obsv) { |
| //var_dump($obsv); | //var_dump($obsv); |
| echo "<h3>Observation {$obsv['observation_id']}:</h1> | echo "<h3>Observation {$obsv['observation_id']}:</h1> |
| <small>{$obsv['myway_stop']} @ {$obsv['time']} on {$obsv['myway_route']}</small><br>"; | <small>{$obsv['myway_stop']} @ {$obsv['time']} on {$obsv['myway_route']}</small><br>"; |
| // convert timestamp into time of day and date | // convert timestamp into time of day and date |
| // timezones from http://www.postgresql.org/docs/8.0/static/datetime-keywords.html | // timezones from http://www.postgresql.org/docs/8.0/static/datetime-keywords.html |
| $time = date("H:i:s", strtotime($obsv['time'])); | $time = date("H:i:s", strtotime($obsv['time'])); |
| $time_tz = date("H:i:s", strtotime($obsv['time'])) . " AESST"; | $time_tz = date("H:i:s", strtotime($obsv['time'])) . " AESST"; |
| $search_time = date("H:i:s", strtotime($obsv['time']) - (60 * 60)); // 30 minutes margin | $search_time = date("H:i:s", strtotime($obsv['time']) - (60 * 60)); // 30 minutes margin |
| $date = date("c", strtotime($obsv['time'])); | $date = date("c", strtotime($obsv['time'])); |
| $timing_period = service_period(strtotime($date)); | $timing_period = service_period(strtotime($date)); |
| if (isset($obsv["stop_id"]) && $obsv["stop_id"] != "" && $obsv["stop_id"] != "*") { | if (isset($obsv["stop_id"]) && $obsv["stop_id"] != "" && $obsv["stop_id"] != "*") { |
| $potentialStops = Array(getStop($obsv["stop_id"])); | $potentialStops = Array(getStop($obsv["stop_id"])); |
| } else { | } else { |
| echo "Potential stops are a bus station<br>"; | echo "Potential stops are a bus station<br>"; |
| $potentialStops = getStops("", trim(str_replace(Array("Arrival","Arrivals","Arrive Platform 3 Set down only.","Arrive","Set Down Only"), "", $obsv["myway_stop"]))); | $potentialStops = getStops("", trim(str_replace(Array("Arrival","Arrivals","Arrive Platform 3 Set down only.","Arrive","Set Down Only"), "", $obsv["myway_stop"]))); |
| } | } |
| //:get myway_stops records | //:get myway_stops records |
| //:search by starts with stopcode and starts with street if street is not null | //:search by starts with stopcode and starts with street if street is not null |
| //no result, skip and display error | //no result, skip and display error |
| if (sizeof($potentialStops) < 1) { | if (sizeof($potentialStops) < 1) { |
| echo "error, potential stops for stopid {$obsv["stop_id"]} unknown"; | echo "error, potential stops for stopid {$obsv["stop_id"]} unknown"; |
| continue; | continue; |
| } | } |
| //print out stops | //print out stops |
| echo "Matched stops: "; | echo "Matched stops: "; |
| foreach ($potentialStops as $potentialStop) { | foreach ($potentialStops as $potentialStop) { |
| echo $potentialStop['stop_id'] . " " . $potentialStop['stop_name'] . " "; | echo $potentialStop['stop_id'] . " " . $potentialStop['stop_name'] . " "; |
| } | } |
| echo "<br>"; | echo "<br>"; |
| //:get myway_route record | //:get myway_route record |
| //no result, skip and display error | //no result, skip and display error |
| //print out route | //print out route |
| $potentialRoutes = getRoutesByShortName($obsv["route_short_name"]); | $potentialRoutes = getRoutesByShortName($obsv["route_short_name"]); |
| if (sizeof($potentialRoutes) < 1) { | if (sizeof($potentialRoutes) < 1) { |
| echo "error, route '{$obsv["myway_route"]}' unknown"; | echo "error, route '{$obsv["myway_route"]}' unknown"; |
| continue; | continue; |
| } | } |
| $timeDeltas = Array(); | $timeDeltas = Array(); |
| foreach ($potentialRoutes as $potentialRoute) { | foreach ($potentialRoutes as $potentialRoute) { |
| echo "Matched route: {$potentialRoute['route_id']} {$potentialRoute['route_short_name']}{$potentialRoute['route_long_name']} {$timing_period}<br>"; | echo "Matched route: {$potentialRoute['route_id']} {$potentialRoute['route_short_name']}{$potentialRoute['route_long_name']} {$timing_period}<br>"; |
| foreach ($potentialStops as $potentialStop) { | foreach ($potentialStops as $potentialStop) { |
| $stopRoutes = getStopRoutes($potentialStop['stop_id'], $timing_period); | $stopRoutes = getStopRoutes($potentialStop['stop_id'], $timing_period); |
| $foundRoute = Array(); | $foundRoute = Array(); |
| foreach ($stopRoutes as $stopRoute) { | foreach ($stopRoutes as $stopRoute) { |
| //Check if this route stops at each stop | //Check if this route stops at each stop |
| if ($stopRoute['route_id'] == $potentialRoute['route_id']) { | if ($stopRoute['route_id'] == $potentialRoute['route_id']) { |
| echo "Matching route {$stopRoute['route_id']} found at stop #{$potentialStop['stop_id']}<br>"; | echo "Matching route {$stopRoute['route_id']} found at stop #{$potentialStop['stop_id']}<br>"; |
| $foundRoute = $stopRoute; | $foundRoute = $stopRoute; |
| //if does get tripstoptimes for this route | //if does get tripstoptimes for this route |
| $trips = getStopTrips($potentialStop['stop_id'], $timing_period, $search_time, 10, $potentialRoute['route_short_name']); | $trips = getStopTrips($potentialStop['stop_id'], $timing_period, $search_time, 10, $potentialRoute['route_short_name']); |
| foreach ($trips as $trip) { | foreach ($trips as $trip) { |
| //echo $trip['route_id']." ".$stopRoute['route_id'].";"; | //echo $trip['route_id']." ".$stopRoute['route_id'].";"; |
| if ($trip['route_id'] == $stopRoute['route_id']) { | if ($trip['route_id'] == $stopRoute['route_id']) { |
| $timedTrip = getTripAtStop($trip['trip_id'], $trip['stop_sequence']); | $timedTrip = getTripAtStop($trip['trip_id'], $trip['stop_sequence']); |
| $actual_time = strtotime($time); | $actual_time = strtotime($time); |
| $trip_time = strtotime($timedTrip['arrival_time']); | $trip_time = strtotime($timedTrip['arrival_time']); |
| $timeDiff = $actual_time - $trip_time; | $timeDiff = $actual_time - $trip_time; |
| //work out time delta, put into array with index of delta | //work out time delta, put into array with index of delta |
| $timeDeltas[] = Array( | $timeDeltas[] = Array( |
| "timeDiff" => $timeDiff, | "timeDiff" => $timeDiff, |
| "stop_id" => $potentialStop['stop_id'], | "stop_id" => $potentialStop['stop_id'], |
| "stop_sequence" => $trip['stop_sequence'], | "stop_sequence" => $trip['stop_sequence'], |
| "route_name" => "{$trip['route_short_name']} {$trip['route_long_name']} {$trip['direction']}", | "route_name" => "{$trip['route_short_name']} {$trip['trip_headsign']}", |
| "route_id" => $trip['route_id'] | "route_id" => $trip['route_id'] |
| ); | ); |
| echo "Found trip {$trip['trip_id']} at stop {$potentialStop['stop_id']} (#{$potentialStop['stop_name']}, sequence #{$trip['stop_sequence']})<br>"; | echo "Found trip {$trip['trip_id']} at stop {$potentialStop['stop_id']} (#{$potentialStop['stop_name']}, sequence #{$trip['stop_sequence']})<br>"; |
| echo "Arriving at {$timedTrip['arrival_time']}, difference of " . round($timeDiff / 60, 2) . " minutes<br>"; | echo "Arriving at {$timedTrip['arrival_time']}, difference of " . round($timeDiff / 60, 2) . " minutes<br>"; |
| } else { | } else { |
| echo "{$trip['route_id']} != {$stopRoute['route_id']}<br>"; | echo "{$trip['route_id']} != {$stopRoute['route_id']}<br>"; |
| } | } |
| } | } |
| if (sizeof($timeDeltas) == 0) echo "Error, no trips found.<bR>"; | if (sizeof($timeDeltas) == 0) echo "Error, no trips found.<bR>"; |
| break; // because have found route | break; // because have found route |
| } | } |
| } | } |
| if (sizeof($foundRoute) < 1) { | if (sizeof($foundRoute) < 1) { |
| //print out that stops/does not stop | //print out that stops/does not stop |
| echo "No matching routes found at {$potentialStop['stop_id']}<br>"; | echo "No matching routes found at {$potentialStop['stop_id']}<br>"; |
| //var_dump($stopRoutes); | //var_dump($stopRoutes); |
| flush(); | flush(); |
| } | } |
| } | } |
| } | } |
| // lowest delta is recorded delta | // lowest delta is recorded delta |
| usort($timeDeltas, "abssort"); | usort($timeDeltas, "abssort"); |
| $lowestDelta = $timeDeltas[0]["timeDiff"]; | $lowestDelta = $timeDeltas[0]["timeDiff"]; |
| if (sizeof($timeDeltas) != 0) { | if (sizeof($timeDeltas) != 0) { |
| if (abs($lowestDelta) > 9999) { | if (abs($lowestDelta) > 9999) { |
| echo "Difference of " . round($lowestDelta / 60, 2) . " minutes is too high. Will not record this observation<br>"; | echo "Difference of " . round($lowestDelta / 60, 2) . " minutes is too high. Will not record this observation<br>"; |
| } else { | } else { |
| echo "Lowest difference of " . round($lowestDelta / 60, 2) . " minutes will be recorded for this observation<br>"; | echo "Lowest difference of " . round($lowestDelta / 60, 2) . " minutes will be recorded for this observation<br>"; |
| $observation_id = $obsv['observation_id']; | $observation_id = $obsv['observation_id']; |
| $route_name = $timeDeltas[0]["route_name"]; | $route_name = $timeDeltas[0]["route_name"]; |
| $route_id = $timeDeltas[0]["route_id"]; | $route_id = $timeDeltas[0]["route_id"]; |
| $stop_id = $timeDeltas[0]["stop_id"]; | $stop_id = $timeDeltas[0]["stop_id"]; |
| $myway_stop = $obsv["myway_stop"]; | $myway_stop = $obsv["myway_stop"]; |
| $stop_sequence = $timeDeltas[0]["stop_sequence"]; | $stop_sequence = $timeDeltas[0]["stop_sequence"]; |
| $stmt = $conn->prepare("insert into myway_timingdeltas (observation_id, route_id, stop_id, timing_delta, time, date, timing_period, stop_sequence,myway_stop,route_name) | $stmt = $conn->prepare("insert into myway_timingdeltas (observation_id, route_id, stop_id, timing_delta, time, date, timing_period, stop_sequence,myway_stop,route_name) |
| values (:observation_id, :route_id, :stop_id, :timing_delta, :time, :date, :timing_period, :stop_sequence,:myway_stop,:route_name)"); | values (:observation_id, :route_id, :stop_id, :timing_delta, :time, :date, :timing_period, :stop_sequence,:myway_stop,:route_name)"); |
| $stmt->bindParam(':observation_id', $observation_id); | $stmt->bindParam(':observation_id', $observation_id); |
| $stmt->bindParam(':route_id', $route_id); | $stmt->bindParam(':route_id', $route_id); |
| $stmt->bindParam(':route_name', $route_name); | $stmt->bindParam(':route_name', $route_name); |
| $stmt->bindParam(':stop_id', $stop_id); | $stmt->bindParam(':stop_id', $stop_id); |
| $stmt->bindParam(':myway_stop', $myway_stop); | $stmt->bindParam(':myway_stop', $myway_stop); |
| $stmt->bindParam(':timing_delta', $lowestDelta); | $stmt->bindParam(':timing_delta', $lowestDelta); |
| $stmt->bindParam(':time', $time_tz); | $stmt->bindParam(':time', $time_tz); |
| $stmt->bindParam(':date', $date); | $stmt->bindParam(':date', $date); |
| $stmt->bindParam(':timing_period', $timing_period); | $stmt->bindParam(':timing_period', $timing_period); |
| $stmt->bindParam(':stop_sequence', $stop_sequence); | $stmt->bindParam(':stop_sequence', $stop_sequence); |
| // insert a record | // insert a record |
| $stmt->execute(); | $stmt->execute(); |
| if ($stmt->rowCount() > 0) { | if ($stmt->rowCount() > 0) { |
| echo "Recorded.<br>"; | echo "Recorded.<br>"; |
| } | } |
| var_dump($conn->errorInfo()); | var_dump($conn->errorInfo()); |
| flush(); | flush(); |
| } | } |
| } | } |
| flush(); | flush(); |
| } | } |