<?php

class DataGetter
{
    protected $data, $kothic_gran;

    function __construct($kothic_gran=null)
    {
        $this->data = array();
        $this->data["features"] = array();
        $this->data["type"] = "FeatureCollection";
        $this->kothic_gran = $kothic_gran;
    }

    function getData($options,$outProj=null)
    {
        $this->doGetData($options);
        if($outProj!==null)
            $this->reprojectData($outProj);
        return $this->data;
    }

    protected function doGetData($options)
    {
        $plyrs = isset($options["poi"]) ? explode(",", $options["poi"]):null;
        $wlyrs = isset($options["way"]) ? explode(",", $options["way"]):null;

        if(isset($options["poi"]))
            $this->getPOIData($plyrs);

        if(isset($options["way"]))
            $this->getWayData($wlyrs);
    }

    static function criteria($lyrs)
    {
        $qry="";
        if (count($lyrs) != 0)
        {
            $qry .= " AND (";
            for($i=0; $i<count($lyrs); $i++)
            {
                if($i!=0)
                    $qry.=" OR ";
                if ($lyrs[$i] == "natural")
                    $lyrs[$i] = "\"natural\"";
                $qry .= $lyrs[$i] . " <> '' ";
            }
            $qry .= ")";
        }
        return $qry;
    }

    function getPOIData($plyrs)
    {

        $pqry = $this->getPOIQuery();


        if($plyrs[0]!="all")
            $pqry .= DataGetter::criteria($plyrs);


        $presult = pg_query($pqry);

        while($prow=pg_fetch_array($presult,null,PGSQL_ASSOC))
        {
            $feature=array();
            $feature["type"] = $this->kothic_gran===null?"Feature":"Point";
            $f= json_decode($prow["geojson"],true);
            $counteddata=array();
            foreach($prow as $k=>$v)    
                if($k!='way' && $k!='geojson' && $v!='')
                    $counteddata[$k]=$v;
            $feature["properties"] = $counteddata;
            $feature["properties"]["featuretype"]=get_high_level
                ($feature["properties"]);
            if($this->kothic_gran===null)
            {
                $feature["geometry"]=array();
                $feature["geometry"]["coordinates"] = $f["coordinates"];
                $feature["geometry"]["type"] = $f["type"];
            }
            else
            {
                $feature["coordinates"]= $this->kothicAdjust($f);
            }
            $this->data["features"][] = $feature;
        }    
        pg_free_result($presult);
    }

    function getWayData($wlyrs)
    {
        $arr=array("way"=>"planet_osm_line","polygon"=>"planet_osm_polygon");

        foreach($arr as $type=>$table)
        {
            $wqry = $this->getWayQuery($table);

            if($wlyrs[0]!="all")
                $wqry .= DataGetter::criteria($wlyrs);

            $wresult = pg_query($wqry);

            $first=true;

            while($wrow=pg_fetch_array($wresult,null,PGSQL_ASSOC))
            {
                $feature=array();
                $f = json_decode($wrow['geojson'],true);
                $tags = array();
                foreach($wrow as $k=>$v)
                    if($k!='way' && $k!='geojson' && $v!='')
                    $tags[$k] = $v;
                $feature["properties"] = $tags;
                if($this->kothic_gran===null)
                {
                    $feature["type"] = "Feature"; 
                    $feature["geometry"]=array();
                    $feature["geometry"]["coordinates"] = $f["coordinates"];
                    $feature["geometry"]["type"] = $f["type"];
                    if(count($feature["geometry"]["coordinates"])>0)
                        $this->data["features"][] = $feature;
                }
                else
                {
                    $feature["coordinates"]= $this->kothicAdjust($f);
                    $feature["type"] = $f["type"];
                    if(count($feature["coordinates"])>0)
                        $this->data["features"][] = $feature;
                }
            }
            pg_free_result($wresult);
        }
    }

    function getPOIQuery()
    {
        $pqry = "SELECT *,ST_AsGeoJSON(way) AS geojson ".
        " FROM planet_osm_point WHERE true";
        return $pqry;
    }

    function getWayQuery($table)
    {
        return "SELECT *,ST_AsGeoJSON(way) AS geojson FROM $table WHERE true";
    }

    function reprojectData($outProj)
    {
        for($f=0; $f<count($this->data["features"]); $f++)
        {
            switch($this->data["features"][$f]["geometry"]["type"])
            {
                case "Point":
                    $this->data["features"][$f]["geometry"]["coordinates"]=
                    reproject
                    ($this->data["features"][$f]["geometry"]["coordinates"][0],
                    $this->data["features"][$f]["geometry"]["coordinates"][1],
                    '900913',$outProj);
                    break;

                case "LineString":
                    for($i=0; 
                        $i<count
                        ($this->data["features"][$f]
                        ["geometry"]["coordinates"]); $i++)
                    {
                        $this->data
                        ["features"][$f]["geometry"]["coordinates"][$i]=
                        reproject
                            ($this->data
                            ["features"][$f]["geometry"]["coordinates"]
                            [$i][0],
                            $this->data["features"][$f]["geometry"]
                            ["coordinates"][$i][1],
                            '900913',$outProj);
                    }
                    break;

                case "Polygon":
                    for($i=0; $i<count($this->data["features"][$f]["geometry"]
                        ["coordinates"]); $i++)
                    {
                        for($j=0;$j<count($this->data["features"][$f]
                            ["geometry"]["coordinates"][$i]);$j++)
                        {
                            $this->data
                            ["features"][$f]["geometry"]["coordinates"]
                                [$i][$j]=reproject
                                ($this->data["features"][$f]
                                ["geometry"]["coordinates"][$i][$j][0],
                                $this->data["features"][$f]
                                ["geometry"]["coordinates"][$i][$j][1],
                                '900913',$outProj);
                        }
                    }
                    break;

                case "MultiPolygon":
                    for($i=0; $i<count($this->data["features"][$f]["geometry"]
                        ["coordinates"]); $i++)
                    {
                        for($j=0;$j<count($this->data["features"][$f]
                            ["geometry"]["coordinates"][$i]);$j++)
                        {
                            for($k=0; 
                                   $k<count($this->data["features"][$f]
                                ["geometry"]["coordinates"][$i][$j]);
                                $k++)
                            {
                                $this->data["features"][$f]
                                    ["geometry"]["coordinates"][$i][$j][$k]=
                                    reproject
                                        ($this->data["features"][$f]
                                    ["geometry"]["coordinates"][$i][$j][$k][0],
                                    $this->data["features"][$f]
                                    ["geometry"]["coordinates"][$i][$j][$k][1],
                                    '900913',$outProj);
                            }
                        }
                    }
                    break;
            }
        }
    }
}

class NameSearch extends DataGetter
{
    protected $name;

    function __construct($name)
    {
        parent::__construct();
        $this->name=$name;
    }

    function getPOIQuery()
    {
        return parent::getPOIQuery()." AND name ILIKE '%".$this->name."%'";
    }

    function getWayQuery($table)
    {
        return parent::getWayQuery($table)." AND name ILIKE '%".
            $this->name."%'";
    }
}

class BboxGetter extends DataGetter
{
    private $bbox;

    function __construct($bbox,$kothic_gran=null)
    {
        parent::__construct($kothic_gran);
        $this->bbox = $bbox;
        $this->geomtxt = $this->mkgeom();
    }

    function getData($options, $contourCache=null, $outProj=null)
    {
        parent::doGetData($options);
        
        if(isset($options["coastline"]) && $options["coastline"])
            $this->getCoastlineData();
            
        if(isset($options["contour"]) && $options["contour"])
            $this->getContourData($contourCache);

        if(isset($options["ann"]) && $options["ann"])
            $this->getAnnotationData();

        if($outProj!==null)
            $this->reprojectData($outProj);

        return $this->data;
    }

    function getContourData($contourCache=null)
    {
        if($this->kothic_gran!==null && $contourCache!==null)
        {
            if(!file_exists($contourCache))
            {
                $contourData=$this->doGetContourData();
                file_put_contents($contourCache,json_encode($contourData));
            }
            else
            {
                $txt=file_get_contents($contourCache);
                $contourData=json_decode($txt,true);
            }
        }
        else
        {
            $contourData=$this->doGetContourData();
        }
        $this->data["features"] = array_merge($this->data["features"], 
            $contourData);
    }


    function doGetContourData()
    {
        $features=array();
        $result=pg_query("SELECT ST_AsGeoJSON(ST_Intersection(".
            $this->geomtxt.",way)) ".
                    "AS geojson,height ".
                    "FROM contours WHERE way && ".$this->geomtxt);
        while($row=pg_fetch_array($result,null,PGSQL_ASSOC))
        {
            $feature=array();
            $f = json_decode($row['geojson'],true);
            $tags = array();
            $feature["properties"] = array();
            $feature["properties"]["contour"]=$row["height"];
            if($this->kothic_gran===null)
            {
                $feature["type"]="Feature";
                $feature["geometry"]=array();
                $feature["geometry"]["coordinates"] = $f["coordinates"];
                $feature["geometry"]["type"] = $f["type"];
                if(count($feature["geometry"]["coordinates"])>0)
                    $features[] = $feature;
            }
            else
            {
                $feature["coordinates"] = $this->kothicAdjust($f);
                $feature["type"] = $f["type"];
                if(count($feature["coordinates"])>0)
                    $features[] = $feature;
            }
        }
        return $features;
    }

    function getCoastlineData()
    {
        if($this->kothic_gran!==null)
        {
            $factor = $this->kothic_gran / ($this->bbox[2]-$this->bbox[0]);
        }
        $result=pg_query("SELECT ST_AsGeoJSON".
            "(ST_Intersection(".$this->geomtxt.",the_geom)) ".
                    "AS geojson ".
                    "FROM coastlines WHERE the_geom && ".$this->geomtxt);
        while($row=pg_fetch_array($result,null,PGSQL_ASSOC))
        {
            $feature=array();
            $f = json_decode($row['geojson'],true);
            $tags = array();
            $feature["properties"] = array();
            $feature["properties"]["natural"] = "land"; 
            if($this->kothic_gran===null)
            {
                $feature["type"]="Feature";
                $feature["geometry"]=array();
                $feature["geometry"]["coordinates"] = $f["coordinates"];
                $feature["geometry"]["type"] = $f["type"];
                if(count($feature["geometry"]["coordinates"])>0)
                    $this->data["features"][] = $feature;
            }
            else
            {
                $feature["coordinates"] =$this->kothicAdjust($f);
                $feature["type"] = $f["type"];
                if(count($feature["coordinates"])>0)
                    $this->data["features"][] = $feature;
            }
        }
    }
    
    function getAnnotationData()
    {
        $pqry = "SELECT *,ST_AsGeoJSON(xy) AS geojson ".
        " FROM annotations WHERE xy && ". $this->geomtxt;

        $presult = pg_query($pqry);

        while($prow=pg_fetch_array($presult,null,PGSQL_ASSOC))
        {
            $feature=array();
            $feature["type"] = "Feature";
            $f= json_decode($prow["geojson"],true);
            $counteddata=array();
            foreach($prow as $k=>$v)    
                if($k!='authorised' && $k!='geojson' && $k!='xy' && $v!='')
                    $counteddata[$k]=$v;
            $feature["properties"] = $counteddata;
            $feature["properties"]["annotation"] = "yes";
            $feature["geometry"]=array();
            $feature["geometry"]["coordinates"] = $f["coordinates"];
            $feature["geometry"]["type"] = $f["type"];
            $this->data["features"][] = $feature;
        }    
        pg_free_result($presult);
    }

    function mkgeom()
    {
        $bbox=$this->bbox;
        $g="GeomFromText('POLYGON(($bbox[0] $bbox[1],$bbox[2] $bbox[1], ".
            "$bbox[2] $bbox[3],$bbox[0] $bbox[3],$bbox[0] $bbox[1]))',900913)";
        return $g; 
    }


    function kothicAdjust($f)
    {
        $factor = $this->kothic_gran / ($this->bbox[2]-$this->bbox[0]);
        $coords=array();
        switch($f["type"])
        {
            case "Point":
                $x =  (int)    
                    (($f["coordinates"][0] - $this->bbox[0]) * $factor);
                $y =     (int)
                    (($f["coordinates"][1] - $this->bbox[1]) * $factor);
            $coords = array($x,$y);
            break;

            case "LineString":
                for($i=0; $i<count($f["coordinates"]); $i++)
                {
                    $x =  (int)    
                    round(($f["coordinates"][$i][0]-$this->bbox[0]) * $factor);
                    $y =     (int)
                    round(($f["coordinates"][$i][1]-$this->bbox[1]) * $factor);
                    // coords of (0,0) seem to  screw up rendering
                    $x=($x==0)?1:$x;
                    $y=($y==0)?1:$y;
                    $x=($x==$this->kothic_gran)?$this->kothic_gran-1:$x;
                    $y=($y==$this->kothic_gran)?$this->kothic_gran-1:$y;
                    if($x>=0 && $y>=0 && $x<=$this->kothic_gran && 
                        $y<=$this->kothic_gran)
                    {
                           $coords[] = array($x,$y);
                    }
                }
                break;

            case "MultiLineString":
            case "Polygon":
                for($i=0; $i<count($f["coordinates"]); $i++)
                {
                    $coords[$i]=array();
                    for($j=0; $j<count($f["coordinates"][$i]); $j++)
                    {
                        $x =  (int)    
                        round(($f["coordinates"][$i][$j][0]-
                        $this->bbox[0]) * $factor);
                        $y =     (int)
                        round(($f["coordinates"][$i][$j][1]-
                        $this->bbox[1]) * $factor);
                        // coords of (0,0) seem to screw up rendering
                        if($f["type"]=="MultiLineString")
                        {
                            $x=($x==0)?1:$x;
                            $y=($y==0)?1:$y;
                            $x=($x==$this->kothic_gran)?$this->kothic_gran-1:$x;
                            $y=($y==$this->kothic_gran)?$this->kothic_gran-1:$y;
                        }
                        $coords[$i][] = array($x,$y);

                    }
                }
                break;

            case "MultiPolygon":
                for($i=0; $i<count($f["coordinates"]); $i++)
                {
                    $coords[$i]=array();
                    for($j=0; $j<count($f["coordinates"][$i]); $j++)
                    {
                        $coords[$i][$j]=array();
                        for($k=0; $k<count($f["coordinates"][$i][$j]); $k++)
                        {
                            $x =  (int)    
                            round(($f["coordinates"][$i][$j][$k][0]-
                            $this->bbox[0]) * 
                            $factor);

                            $y =     (int)
                            round(($f["coordinates"][$i][$j][$k][1]-
                            $this->bbox[1]) * 
                            $factor);

                            $x=($x==0)?1:$x;
                            $y=($y==0)?1:$y;
                            $x=($x==$this->kothic_gran)?$this->kothic_gran-1:$x;
                            $y=($y==$this->kothic_gran)?$this->kothic_gran-1:$y;
                            $coords[$i][$j][] = array($x,$y);
                        }
                    }
                }
                break;
        }
        return $coords;
    }

    function getPOIQuery()
    {
        return parent::getPOIQuery() . " AND way && ".$this->geomtxt;
    }

    function getWayQuery($table)
    {
        return "SELECT *,ST_AsGeoJSON(ST_Intersection(".$this->geomtxt.
            ",way)) AS geojson ".
            "FROM $table WHERE way && ".$this->geomtxt." AND ST_IsValid(way)";
    }
}

?>