Add geopo to timing points master
[bus.git] / betweenpoint.move.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
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
<?php
  /*
   * GeoPo Encode in PHP
   * @author : Shintaro Inagaki
   * @param $location (Array)
   * @return $geopo (String)
   */
  function geopoEncode($lat, $lng)
  {
      // 64characters (number + big and small letter + hyphen + underscore)
      $chars = "0123456789abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ-_";
      
      $geopo = "";
      $scale = 7;
      
      // Change a degree measure to a decimal number
      $lat = ($lat + 90) / 180 * pow(8, 10);
      $lng = ($lng + 180) / 360 * pow(8, 10);
      // Compute a GeoPo code from head and concatenate
      for ($i = 0; $i < $scale; $i++) {
          $geopo .= substr($chars, floor($lat / pow(8, 9 - $i) % 8) + floor($lng / pow(8, 9 - $i) % 8) * 8, 1);
      }
      return $geopo;
  }
  
  /*
   * GeoPo Decode in PHP
   * @author : Shintaro Inagaki
   * @param $geopo (String)
   * @return $location (Array)
   */
  function geopoDecode($geopo)
  {
      // 64characters (number + big and small letter + hyphen + underscore)
      $chars = "0123456789abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ-_";
      // Array for geolocation
      $location = array();
      
      for ($i = 0; $i < strlen($geopo); $i++) {
          // What number of character that equal to a GeoPo code (0-63)
          $order = strpos($chars, substr($geopo, $i, 1));
          // Lat/Lng plus geolocation value of scale 
          $location['lat'] = $location['lat'] + floor($order % 8) * pow(8, 9 - $i);
          $location['lng'] = $location['lng'] + floor($order / 8) * pow(8, 9 - $i);
      }
      
      // Change a decimal number to a degree measure, and plus revised value that shift center of area
      $location['lat'] = $location['lat'] * 180 / pow(8, 10) + 180 / pow(8, strlen($geopo)) / 2 - 90;
      $location['lng'] = $location['lng'] * 360 / pow(8, 10) + 360 / pow(8, strlen($geopo)) / 2 - 180;
      $location['scale'] = strlen($geopo);
      
      return $location;
  }
  
  $conn = pg_connect("dbname=bus user=postgres password=snmc");
  if (!$conn) {
      echo "An error occured.\n";
      exit;
  }
  if ($_REQUEST['newlatlng']) {
      $latlng = explode(";", $_REQUEST['newlatlng']);
      $lat = (float)$latlng[0];
      $lng = (float)$latlng[1];
      
      $geoPo = geopoEncode($lat, $lng);
      $nodelat = (int)($lat * 10000000);
      $nodelon = (int)($lng * 10000000);
      echo($nodelat . "," . $nodelon . "=$geoPo<br>");
      $sql = "UPDATE stops SET geohash='$geoPo', lat='$nodelat', lng='$nodelon', name=null, suburb=null WHERE geohash = '{$_REQUEST['oldgeopo']}'";
      $result = pg_query($conn, $sql);
      if (!$result) {
          echo("Error in SQL query: " . pg_last_error() . "<br>\n");
      } else if (pg_affected_rows($result) == 0) {
        echo ("Error 0 points moved, please refresh page and try again");
      } else {
      echo $_REQUEST['oldgeopo'] . " replaced with $geoPo <br>";
      $updatedroutes = 0;
      $result_outdatedroutes = pg_query($conn, "Select * FROM between_stops where points LIKE '%" . $_REQUEST['oldgeopo'] . ";%'");
      while ($outdatedroute = pg_fetch_assoc($result_outdatedroutes)) {
          $newpoints = str_replace($_REQUEST['oldgeopo'], $geoPo, $outdatedroute['points']);
          $sql = "UPDATE  between_stops set points='$newpoints' where
          fromlocation = '".pg_escape_string($outdatedroute['fromlocation']).
          "' AND tolocation = '".pg_escape_string($outdatedroute['tolocation'])."' ";
          $result = pg_query($conn, $sql);
          if (!$result) {
              echo("Error in SQL query: " . pg_last_error() . "<br>\n");
          }
          echo "updated ".$outdatedroute['fromlocation']."->".$outdatedroute['tolocation']."<br>";
          $updatedroutes++;
      }
      echo "updated $updatedroutes routes<br>";
      }
  }
  flush();
?>