se/SE/superedit-SYNC_GIS_GEOPORTAL_IMPORT_G2_GO_WFS.php

<?php
//
// synchronizacja do serwera postgres GIS
//

include_once('se-lib/DB_Dump.php');
include_once('se-lib/UsersHelper.php');
set_time_limit(360);



function get_data($url) {
	$ch = curl_init();
	$timeout = 5;
	
	$User_Agent = 'Mozilla/5.0 (X11; Linux i686) AppleWebKit/537.31 (KHTML, like Gecko) Chrome/26.0.1410.43 Safari/537.31';

	$request_headers = array();
	$request_headers[] = 'User-Agent: '. $User_Agent;
	$request_headers[] = 'Accept: text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8';
	curl_setopt($ch, CURLOPT_HTTPHEADER, $request_headers);
	
	curl_setopt($ch, CURLOPT_URL, $url);
	curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
	curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, $timeout);
	$data = curl_exec($ch);
	$error=curl_error ( $ch);
	
	echo $error;
	curl_close($ch);
	
	return $data;
}


function SYNC_GIS_GEOPORTAL_IMPORT_G2_GO_WFS() {
	global $db,$gdb;

	$mysql_zas_id=36;
	$gis_zas_id=13102;
	$sql_cr="";
	
	$db = DB::getDB();
	$gdb= DB::getDB($gis_zas_id);
	
	$tbl_dest="WFS_DzKat_G2_GO_WFS";
	
	
		DEBUG_S(-3,'db',$db);
		DEBUG_S(-3,'gis',$gdb);
		
	
	//			 http://sdi.geoportal.gov.pl/wfs_dzkat/wfservice.aspx?service=wfs&request=getfeature&bbox=50.855,20.695,50.911,20.805&version=1.1.0&typename=Dzialki&srsname=EPSG:4326
	//2014-06-05 http://sdi.geoportal.gov.pl/wfs_dzkat/wfservice.aspx?request=getfeature&version=1.1.0&service=wfs&typename=Dzialki&srsName=EPSG:4326&bbox=21.1,52.6,21.2,52.7

	
	
$url="http://sdi.geoportal.gov.pl/wfs_dzkat/wfservice.aspx?request=getFeature&version=1.1.0&service=WFS&typename=gmgml:";
$url="http://mapy.geoportal.gov.pl/wss/service/pub/guest/G2_GO_WFS/MapServer/WFSServer?service=wfs&request=getFeature&service=service=WFS";

$layers[]='G2_GO_WFS:Dzialki';
$srsName='EPSG:4326';
//$bbox_y0=51.00; //dol
//$bbox_x0=21.00; //lewo
//$bbox_y1=52.14; //gora
//$bbox_x1=22.83;//prawo
//$step_y=0.01;
//$step_x=0.01;


//dla gdanska
$bbox_x0=54.21; //dol
$bbox_y0=18.41; //lewo
$bbox_x1=54.28;//gora
$bbox_y1=18.55; //prawo
$step_y=0.01;
$step_x=0.01;


/*
$srsName='EPSG:2180';
$bbox_y0=378316; //dol
$bbox_x0=423036; //lewo
$bbox_y1=379316; //gora
$bbox_x1=424036;//prawo
$step_y=50;
$step_x=50;
*/

//lg=174213,770680,,876438,108559
//<gml:lowerCorner>49.0023866380461 14.1229300045899</gml:lowerCorner>
//<gml:upperCorner>54.8357888684533 24.1457361773594</gml:upperCorner>
//EPSG:2180 378316,423036
//54.13000,18.3156,54.3226,18.5427



foreach($layers as $layer) {


	for($y=$bbox_y0;$y<=$bbox_y1;$y=$y+$step_y) {
		
		for($x=$bbox_x0;$x<=$bbox_x1;$x=$x+$step_x) {		
		
			$url_get=$url."&typename=".$layer.'&srsName='.$srsName.'&bbox='.$y.','.$x.','.($y+$step_y).','.($x+$step_x);
			echo "<br>".$url_get;
			//break 2 ;


echo "<br> bede jechac ".$url_get;
			
			
			
			$xml_=get_data($url_get);
			//$xmlarray = array(); // this will hold the flattened data 
			
			
			
			
			$element = simplexml_load_string($xml_);
			$element->registerXPathNamespace('G2_GO_WFS', 'http://mapy.geoportal.gov.pl:80/wss/service/pub/guest/G2_GO_WFS/MapServer/WFSServer');
			$element->registerXPathNamespace('gml', 'http://www.opengis.net/gml');
			$element->registerXPathNamespace('wfs', 'http://www.opengis.net/wfs');

			//$element->registerXPathNamespace('p', 'http://example.org');
			
//			$positions = $element->xpath('/wfs:FeatureCollection[1]/gml:featureMember/gmgml:Dzialki');
			$positions = $element->xpath('/wfs:FeatureCollection[1]/gml:featureMember');
			DEBUG_S(-3,'Element positions',$positions,__FILE__,__FUNCTION__,__LINE__);
			//$count[]=$positions->count();
			$i=0;
			foreach ($positions as $pos) {
			

		     // $pos_id = $element->xpath('/wfs:FeatureCollection/gml:featureMember/G2_GO_WFS:Dzialki[@gml:id="F324__22282165"]/G2_GO_WFS:OBJECTID');
		     /* $pos_id = $element->xpath('/wfs:FeatureCollection/gml:featureMember/G2_GO_WFS:Dzialki[@gml:id="F324__22458175"]/G2_GO_WFS:IDENTYFIKATOR');
		      foreach($pos_id as $pos_id_) {
			      echo "<br>136: ";
			      print_r($pos_id_->__toString());
		      }
				*/	      

			  $pos_ = $pos->xpath('./G2_GO_WFS:Dzialki/@gml:id');
	//		  DEBUG_S(-3,'pos_',$pos,__FILE__,__FUNCTION__,__LINE__);
			  foreach ($pos_ as $ind_=>$pos__) {
			  
			  	$seq[]=1;
			  	$exp[$i]['ID']=$pos__->__toString();

			    ///	$result[] = $pos__->__toString();
			  	$i++;
			  	
			  }
			
			 
			}
			DEBUG_S(-3,'Element exp',$exp,__FILE__,__FUNCTION__,__LINE__);

			$cols=array('IDENTYFIKATOR'=>'G2_GO_WFS:IDENTYFIKATOR','POWIERZCHNIA'=>'G2_GO_WFS:POWIERZCHNIA','posList'=>'G2_GO_WFS:SHAPE/gml:MultiSurface/gml:surfaceMember/gml:Polygon/gml:exterior/gml:LinearRing/gml:posList'); //todo jak zrobic atrubuty ? 'EPSG'=>'gmgml:GEOMETRIA_DEG/gml:Polygon@'
			
			foreach($cols as $column=>$xpath) {
			  foreach($seq as $ind=>$val) {
			 //  echo "<br>Xpath test ".'/wfs:FeatureCollection/gml:featureMember/G2_GO_WFS:Dzialki[@gml:id="'.$exp[$ind]['ID'].'"]/'.$xpath;
				$pos1_=$element->xpath('/wfs:FeatureCollection/gml:featureMember/G2_GO_WFS:Dzialki[@gml:id="'.$exp[$ind]['ID'].'"]/'.$xpath);
					//echo "<br> exp[".$ind. "][".$column."]=";
					  foreach($pos1_ as $pos1__) {
				  	     $exp[$ind][$column]=$pos1__->__toString();
				  	  //  echo "DET: .. a string to ".$pos1__->__toString();
				  	  }
			  }
			}
			
			//var_dump($result);
			
			DEBUG_S(-3,'x',array($url_get,$xml_,$xml,$element,$result,$ind,$count,$exp),__FILE__,__FUNCTION__,__LINE__);
			
			
			
			foreach($exp as $exp_) {
			
				$WKT_a=explode(" ", $exp_['posList']);
				$y_=false;
				$WKT='';
				$WKT_=array();
				$i=0;
				foreach($WKT_a as $ref) {
				    if(!$y_) $y_=$ref;
				       else { 
				       	$WKT_[]=$ref." ".$y_;
				       	$y_=false;
				       }
				$i++;
				}
				
				$WKT=implode(",", $WKT_);
				//print_r($WKT);
				
				//$sql='delete from  "'.$tbl_dest.'" where "REM_SYSTEM"=\''.$url.'\' and "REM_ID"=\''.$exp_['ID'].'\'';
				//$gdb->query($sql);
				//nie kasujemy istniejaych obiektow - TODO 
				$sql='select "REM_ID" from "'.$tbl_dest.'" where "REM_SYSTEM"=\''.$url.'\' and "REM_ID"=\''.$exp_['ID'].'\' ';
				$res=$gdb->query($sql);
				if($gdb->count($res)<1) {
				
					$sql='insert  into "'.$tbl_dest.'" ( "REM_SYSTEM","REM_ID","IDENTYFIKATOR","POWIERZCHNIA","posList","A_RECORD_CREATE_DATE" ) values 
					(\''.$url.'\',\''.$exp_['ID'].'\',\''.$exp_['IDENTYFIKATOR'].'\' , \''.$exp_['POWIERZCHNIA'].'\',ST_GeomFromEWKT(\'SRID=4326;POLYGON(('.$WKT.'))\') ,now() ) 
					';
					DEBUG_S(-3,"SQL",$sql,__FILE__,__FUNCTION__,__LINE__);	
					$gdb->query($sql);
				} else echo " | Obj ".$exp_['ID']." already exists in DB";
			}
			
			unset($exp);
			unset($seq);
		//	die();

			//	die('test');

		}
		
	}
	
flush();
//break 2;
}



			


echo "<br> pojechalem";


echo "</pre>";

	

}