se/SE/se-lib/Route/WfsBiAudit.php

<?php

Lib::loadClass('RouteBase');

class Route_WfsBiAudit extends RouteBase {

	const maxResolveDepth = 3;
	private $dom, $path = [], $relations = [], $tablesUsed = [];

	public function handleAuth() {
		if (!empty($_GET['sid'])) {
			session_write_close();
			session_id($_GET['sid']); // TODO: security BUG
			error_log('wfs-data.php _GET[sid] was read' .$_GET['sid'].' ; ');
			session_start();
			session_write_close();
		}
		if (!User::logged()) throw new HttpException('Unauthorized', 401);
	}

	private static function output($output) {
		header("Content-Type: application/xml");
		header("Content-Transfer-Encoding: binary");
		header("Content-Length: " . strlen($output));
		echo $output;
	}

	private static function throwServiceException($message) {
		$xml = <<<EOT
<?xml version="1.0" encoding="UTF-8"?>
<ServiceExceptionReport xmlns="http://www.opengis.net/ogc" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.opengis.net/ogc http://schemas.opengis.net/wfs/1.0.0/OGC-exception.xsd" version="1.2.0">
  <ServiceException>{$message}</ServiceException>
</ServiceExceptionReport>
EOT;

		self::output($xml);
		die();
	}

	public function objectStructureAction($namespace) { // objectStructAction
		Lib::loadClass('SchemaFactory');
		Lib::loadClass('ACL');

		try {
			error_log('objectStructureAction for '.$namespace);
			if (empty($namespace)) throw new Exception("Missing param namespace");
			$item = SchemaFactory::loadDefaultObject('SystemObject')->getItem($namespace, [ 'propertyName' => '*,field' ]);
			$return=$this->objectStructView($item);
			return $return;

		} catch (Exception $e) {
			//error_log('danger', "Error #" . $e->getCode() . "|" . $e->getLine() . ": " . $e->getMessage());
			DBG::log($e);
		}
	}


//input param $item['namespace']='default_db/BI_audit_CEIDG_powiazania/BI_audit_CEIDG_powiazania'
public function objectStructView($item) {
		$namespace = $item['namespace'];

		$thisGetLink = [ $this, 'getLink' ];

		$getBackRefList=ACL::getBackRefList($item['namespace']);


		foreach($getBackRefList as $ind=>$backref) {
			$exploded_ns = explode('/', $backref['namespace']);
			$return['backrefs'][]=$exploded_ns[1].'__x3A__'.$exploded_ns[2].':'.$exploded_ns[3];
		}
		foreach($item['field'] as $ind=>$refs) {

			$return['refs']				  []=$refs['fieldNamespace'];
			$return['refs__rootTableName'][]=$refs['_rootTableName'];
			$return['refs__objectNamespace'][]=$refs['objectNamespace'];




		}

		$return['table']=$item['name'];
		$return['primaryKey']=$item['primaryKey'];

		//print_r($this->BaseStruct);


		return $return;

	}



	private function addChild($node, $name, $value = null) {
		$child = $this->dom->createElement($name, $value);
		$node->appendChild($child);
		return $child;
	}

	private function addAttribute($node, $name, $value) {
		$attr = $this->dom->createAttribute($name);
		$attr->value = $value;
		$node->appendChild($attr);
	}

	private function relationName($ID) {
		if (!isset($this->relations[$ID])) {
			$query = "select `RELATION` from `BI_audit_ALL_ref_RELATIONS` where `ID` & {$ID} order by `ID`";
			$result = DB::getPDO()->fetchAll($query);
			$rels = array_map('reset', $result);
			$this->relations[$ID] = implode(", ", $rels);
		}
		return $this->relations[$ID];
        }

    private function findRelations_base($node, $ID, $resolveDepth, $relation = null, $BaseStruct=null,$table=null) {
	    if (in_array($ID, $this->path)) return;
		$this->path[] = $ID;
				error_log('#208 findRelations_base  passing');

		foreach($BaseStruct['refs__objectNamespace'] as $ind=>$refs){
				$getRefTable=ACL::getRefTable('default_db/'.$table.'/'.$table,$refs);

				$query = "select `REMOTE_PRIMARY_KEY`  from `".$getRefTable."` where `PRIMARY_KEY` = {$ID}";
						error_log('#114 findRelations_base  passing query '.$query);

				if (!($row = DB::getPDO()->fetchFirst($query))) {

				} else {
						/*{
							$this->objectStructureAction('default_db/BI_audit_CEIDG_pelnomocnicy/BI_audit_CEIDG_pelnomocnicy');
							 self::throwServiceException("Błąd danych #102 findRelations_base");
						}*/

				if (!in_array($BaseStruct['_rootTableName'][$ind], $this->tablesUsed)) $this->tablesUsed[] = $BaseStruct['_rootTableName'][$ind];
				}

				if ($resolveDepth) {
					$feature = $this->addChild($node, $BaseStruct['refs'][$ind]);
					$this->addAttribute($feature, 'fid', $BaseStruct['_rootTableName'][$ind].$row['REMOTE_PRIMARY_KEY']);
					$this->addChild($feature, "default_db__x3A__".$BaseStruct['_rootTableName'][$ind].":ID", $row['REMOTE_PRIMARY_KEY']);
					if ($relation) $this->addChild($feature, "relation_from", $this->relationName($relation));
					//$query = "select `ID2` from `BI_audit_ALL_ref` where `ID1` = {$ID}";
					//$where = $relation ? "and ({$relation} & `RELATION_ID`) != {$relation}" : "";
					$RefBaseStruct=$this->objectStructureAction($BaseStruct['objectNamespace'][$ind]);

					$query = "select `".$RefBaseStruct['primaryKey']."` from `".$RefBaseStruct['table']."` where `".$RefBaseStruct['primaryKey']."` = ".$row['REMOTE_PRIMARY_KEY'] ;
					$result = DB::getPDO()->fetchAll($query);
					foreach ($result as $row) $this->findRelations($feature, $row['REMOTE_PRIMARY_KEY'], $resolveDepth - 1, null,$BaseStruct['table'],$RefBaseStruct['table']);
				} else {
					$xlink = $this->addChild($node, $BaseStruct['refs'][$ind]);
					$this->addAttribute($xlink, 'xlink:href', "https://biuro.biall-net.pl/wfs/default_db/{$RefBaseStruct['table']}?BI_audit_ALL_ref_RELATIONS={$relation}#{$RefBaseStruct['table']}.{$row['REMOTE_PRIMARY_KEY']}");
				}
		array_pop($this->path);
		}


	}

	private function findRelations($node, $ID, $resolveDepth, $relation = null,$BaseTableFrom,$BaseTableTo) {
		if (in_array($ID, $this->path)) return;
		$this->path[] = $ID;
		if(isset($BaseTableFrom)) {
			$query = "select `REMOTE_TABLE`, `REMOTE_ID` from `BI_audit_ALL` where `ID` = {$ID} and `REMOTE_TABLE`='".$BaseTableTo."'"; //todo nie wiem czy nie na odwrot $BaseTableTo
		} else {
			$query = "select `REMOTE_TABLE`, `REMOTE_ID` from `BI_audit_ALL` where `ID` = {$ID}";
		}

		if (!($row = DB::getPDO()->fetchFirst($query)))
		{
				//$this->objectStructureAction('default_db/BI_audit_CEIDG_pelnomocnicy/BI_audit_CEIDG_pelnomocnicy');
				// self::throwServiceException("Błąd danych findRelations #130");
				 $this->BaseStruct=$this->objectStructureAction("default_db/".$BaseTableTo."/".$BaseTableTo );
				 $query = "select `".$this->BaseStruct['primaryKey']."` from `".$BaseTableTo."` where ".$this->BaseStruct['primaryKey']." = {$ID}";
				if (!($ID = DB::getPDO()->fetchValue($query))) {
					self::throwServiceException("Błąd danych z BaseStruct/findRelations #162 ");
				}

				if (!in_array($BaseTableTo, $this->tablesUsed)) $this->tablesUsed[] = $BaseTableTo;
				if ($resolveDepth) {
						$feature = $this->addChild($node, "default_db__x3A__{$row['REMOTE_TABLE']}:{$row['REMOTE_TABLE']}");
						$this->addAttribute($feature, 'fid', "{$row['REMOTE_TABLE']}.{$row['REMOTE_ID']}");
						$this->addChild($feature, "default_db__x3A__{$row['REMOTE_TABLE']}:ID", $row['REMOTE_ID']);
						if ($relation) $this->addChild($feature, "relation_from", $this->relationName($relation));
						//$query = "select `ID2` from `BI_audit_ALL_ref` where `ID1` = {$ID}";
						//$where = $relation ? "and ({$relation} & `RELATION_ID`) != {$relation}" : "";
						//$query = "select `ID2`, `RELATION_ID` from `BI_audit_ALL_ref` where `ID1` = {$ID} {$where}";
						//$result = DB::getPDO()->fetchAll($query);
						//foreach ($result as $row)
						// $this->findRelations($feature, $row['ID2'], $resolveDepth - 1, $row['RELATION_ID'],);
						findRelations_base($node, $ID, $resolveDepth, $relation = null, $this->BaseStruct,$BaseTableTo) ;

					} else {
						$xlink = $this->addChild($node, "default_db__x3A__{$BaseTableTo}:{$BaseTableTo}");
						$this->addAttribute($xlink, 'xlink:href', "https://biuro.biall-net.pl/wfs/default_db/".$BaseTableTo."?BI_audit_ALL_ref_RELATIONS={$BaseTableTo}#{$BaseTableTo}.{$row[$this->BaseStruct['primaryKey']]}");
					}
					array_pop($this->path);

		} else {
					if (!in_array($row['REMOTE_TABLE'], $this->tablesUsed)) $this->tablesUsed[] = $row['REMOTE_TABLE'];
					if ($resolveDepth) {
						$feature = $this->addChild($node, "default_db__x3A__{$row['REMOTE_TABLE']}:{$row['REMOTE_TABLE']}");
						$this->addAttribute($feature, 'fid', "{$row['REMOTE_TABLE']}.{$row['REMOTE_ID']}");
						$this->addChild($feature, "default_db__x3A__{$row['REMOTE_TABLE']}:ID", $row['REMOTE_ID']);
						if ($relation) $this->addChild($feature, "relation_from", $this->relationName($relation));
						//$query = "select `ID2` from `BI_audit_ALL_ref` where `ID1` = {$ID}";
						$where = $relation ? "and ({$relation} & `RELATION_ID`) != {$relation}" : "";
						$query = "select `ID2`, `RELATION_ID` from `BI_audit_ALL_ref` where `ID1` = {$ID} {$where}";
						$result = DB::getPDO()->fetchAll($query);
						foreach ($result as $row) $this->findRelations($feature, $row['ID2'], $resolveDepth - 1, $row['RELATION_ID']);
					} else {
						$xlink = $this->addChild($node, "default_db__x3A__{$row['REMOTE_TABLE']}:{$row['REMOTE_TABLE']}");
						$this->addAttribute($xlink, 'xlink:href', "https://biuro.biall-net.pl/wfs/default_db/{$row['REMOTE_TABLE']}?BI_audit_ALL_ref_RELATIONS={$relation}#{$row['REMOTE_TABLE']}.{$row['REMOTE_ID']}");
					}
					array_pop($this->path);
		}
	}

	public function defaultAction() {
		$TYPENAME = V::get('TYPENAME', '', $_GET);
		$primaryKey = V::get('primaryKey', 0, $_GET, 'int');
		$resolveDepth = V::get('resolveDepth', 1, $_GET, 'int');
		$TYPENAME_exploded = explode(":", $TYPENAME);
		if (!(count($TYPENAME_exploded) == 2 && $primaryKey && $resolveDepth >= 1 && $resolveDepth <= self::maxResolveDepth)) self::throwServiceException("WFS request error");
		$table = $TYPENAME_exploded[1];

		try {
			$this->dom = new DOMDocument('1.0', 'UTF-8');
			$this->dom->preserveWhiteSpace = false;
			$this->dom->formatOutput = true;

			$attrs = [
				'xmlns:wfs' => 'http://www.opengis.net/wfs',
				'xmlns' => 'http://www.opengis.net/wfs',
				'xmlns:gml' => 'http://www.opengis.net/gml',
				'xmlns:xsi' => 'http://www.w3.org/2001/XMLSchema-instance',
				'xmlns:xlink' => 'http://www.w3.org/1999/xlink',
			];

			$wfs = $this->addChild($this->dom, 'wfs:FeatureCollection');
			foreach ($attrs as $name => $value) $this->addAttribute($wfs, $name, $value);
			$gml = $this->addChild($wfs, 'gml:featureMember');

			$query = "select `ID` from `BI_audit_ALL` where `REMOTE_TABLE` = " . DB::getPDO()->quote($table) . " and `REMOTE_ID` = {$primaryKey}";
			if (!($ID = DB::getPDO()->fetchValue($query))) {

				error_log('#233 default base passing');
				$this->BaseStruct=$this->objectStructureAction("default_db/".$table."/".$table );


				$query = "select `".$this->BaseStruct['primaryKey']."` from `".$table."` where ".$this->BaseStruct['primaryKey']." = {$primaryKey}";
				if (!($ID = DB::getPDO()->fetchValue($query))) {
					self::throwServiceException("Błąd danych z BaseStruct ");
				}
					$this->findRelations_base($gml, $ID, $resolveDepth,$table,$this->BaseStruct,$table);

						foreach ($this->tablesUsed as $table) $this->addAttribute($wfs, "xmlns:default_db__x3A__{$table}", "https://biuro.biall-net.pl/wfs/default_db/{$table}");
						$attrs = [
							'numberMatched' => 'unknown',
							'numberReturned' => '1',
						];
						foreach ($attrs as $name => $value) $this->addAttribute($wfs, $name, $value);

						$xml = $this->dom->saveXML();
						self::output($xml);

				} else {
					error_log('#254 default  passing');

					$this->findRelations($gml, $ID, $resolveDepth);

					foreach ($this->tablesUsed as $table) $this->addAttribute($wfs, "xmlns:default_db__x3A__{$table}", "https://biuro.biall-net.pl/wfs/default_db/{$table}");
					$attrs = [
						'numberMatched' => 'unknown',
						'numberReturned' => '1',
					];
					foreach ($attrs as $name => $value) $this->addAttribute($wfs, $name, $value);

					$xml = $this->dom->saveXML();
					self::output($xml);

				}

			} catch (Exception $e) {
					//$this->objectStructureAction('default_db/BI_audit_CEIDG_pelnomocnicy/BI_audit_CEIDG_pelnomocnicy');

					self::throwServiceException($e->getMessage());
		    }
	}

}