Add suburb geocode to timingpoints tables too
[bus.git] / maxious-canberra-transit-feed / 04-locatebetweenpoints.reversegeocode.php
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
<?php
function getPage($url)
{
    $ch = curl_init($url);
curl_setopt( $ch, CURLOPT_RETURNTRANSFER, 1 );
curl_setopt( $ch, CURLOPT_HEADER, 0 );
$page = curl_exec($ch);
curl_close($ch);
return $page;
}
// 
// http://developers.cloudmade.com/wiki/geocoding-http-api/Documentation
$conn = pg_connect("dbname=bus user=postgres password=snmc");
if (!$conn) {
  echo "An error occured.\n";
  exit;
}
$sql = "Select * from stops where name is null or suburb is null";
     $result_stops = pg_query($conn, $sql);
     if (!$result_stops) {
        echo("Error in SQL query: " . pg_last_error() ."<br>\n");
     }
     while ($stop = pg_fetch_assoc($result_stops)) {
        if ($stop['name'] == "") {
      echo "Processing ".$stop['geohash'] . " streetname ... ";
      $url = "http://geocoding.cloudmade.com/daa03470bb8740298d4b10e3f03d63e6/geocoding/v2/find.js?around=".($stop['lat']/10000000).",".($stop['lng']/10000000)."&distance=closest&object_type=road";
      $contents = json_decode(getPage($url));
      //print_r($contents);
      $name = $contents->features[0]->properties->name;
      echo "Saving $name ! <br>" ;
      $result_save = pg_query($conn, "UPDATE stops set name = '".pg_escape_string($name)."' where geohash = '{$stop['geohash']}' ");
                              if (!$result_save) {
        echo("Error in SQL query: " . pg_last_error() ."<br>\n");
                              }
        }
        if ($stop['suburb'] == "") {
      echo "Processing ".$stop['geohash'] . " suburb ... ";
        $sql = "select * from suburbs where the_geom @> 'POINT(".($stop['lng']/10000000)." ".($stop['lat']/10000000).")'::geometry";
     $result_suburbs = pg_query($conn, $sql);
     if (!$result_suburbs) {
        echo("Error in SQL query: " . pg_last_error() ."<br>\n");
     }
     $suburbs = "";
     while ($suburb = pg_fetch_assoc($result_suburbs)) {
        $suburbs .= $suburb['name_2006'].";";
     }
      echo "Saving $suburbs ! <br>" ;
      $result_save = pg_query($conn, "UPDATE stops set suburb = '".pg_escape_string($suburbs)."' where geohash = '{$stop['geohash']}' ");
                              if (!$result_save) {
        echo("Error in SQL query: " . pg_last_error() ."<br>\n");
                              }
     }
     flush();
     }
 
?>