se/SE/se-lib/Api/WfsDataServer.php

<?php

Lib::loadClass('Api_WfsServerBase');
Lib::loadClass('Api_WfsException');
Lib::loadClass('Api_WfsGeomTypeConverter');
Lib::loadClass('Api_WfsNs');

class Api_WfsDataServer extends Api_WfsServerBase {

	public function parseXMLRequest() {
		$data = array();
		$reqContent = Request::getRequestBody();
		if (empty($reqContent)) {
			throw new Exception("Empty request");
		}
		$parserXml = xml_parser_create();
		xml_parser_set_option($parserXml, XML_OPTION_CASE_FOLDING, 0);
		xml_parser_set_option($parserXml, XML_OPTION_SKIP_WHITE, 1);
		if (0 == xml_parse_into_struct($parserXml, $reqContent, $tags)) {
			throw new Exception("Error parsing xml");
		}
		xml_parser_free($parserXml);
		if (empty($tags)) {
			throw new Exception("Empty structure from request");
		}

		$rootTagName = V::get('tag', '', $tags[0]);
		if ('Transaction' == $rootTagName) return $this->_parseTransactionXmlStruct($reqContent, $tags);

		throw new Api_WfsException("Not implemented '{$rootTagName}' #L." . __LINE__, 501);
	}

	public function getFeatureAction() {
		$args = $this->parseGetFeatureArgsFromRequest();
		if ('hits' == $args['resultType']) {
			return $this->getTotalFeatures($args, $simple = true);
		} else {
			return $this->getFeatures($args, $simple = true);
		}
	}

	public function getFeatureAdvancedAction() {
		$args = $this->parseGetFeatureArgsFromRequest();
		if ('hits' == $args['resultType']) {
			return $this->getTotalFeatures($args, $simple = false);
		} else {
			return $this->getFeatures($args, $simple = false);
		}
	}

	public function testOgcFilterAction() {
		$type = V::get('TYPENAME', '', $_REQUEST);
		$typeEx = explode(':', $type);
		$maxFeatures = V::get('MAXFEATURES', '10000', $_REQUEST, 'int');// TODO: Set Deafult Limit
		$ogcFilter = V::get('Filter', '', $_REQUEST);
		$srsname = V::get('SRSNAME', '', $_REQUEST);// eg. EPSG:4326
		if (count($typeEx) == 2) {
			Lib::loadClass('ParseOgcFilter');
			$parser = new ParseOgcFilter();
			$parser->loadOgcFilter($ogcFilter);
			$queryWhereBuilder = $parser->convertToSqlQueryWhereBuilder();
			echo $queryWhereBuilder->getQueryWhere('t');
		} else {
			throw new HttpException("Wrong param TYPENAME", 400);
		}
	}

	public function getTotalFeatures($args, $simple = true) {
		$DBG = (V::get('DBG_GEO', '', $_GET) > 0);// TODO: Profiler
		if($DBG){echo "typeName({$args['xsd:type']})\n";}
		$acl = $this->getAclFromTypeName($args['xsd:type']);
		$fldList = $this->_getFieldListFromAcl($acl);

		$baseNsUri = Api_WfsNs::getBaseWfsUri();
		$rootWfsNs = 'p5';
		$rootWfsNsUri = "{$baseNsUri}";
		$wfsNs = $args['typePrefix'];
		$wfsNsUri = "{$baseNsUri}/" . substr($args['typePrefix'], 3);
		$featureTypeUri = $this->getBaseUri() . "?SERVICE=WFS&VERSION=1.0.0&TYPENAME={$args['xsd:type']}&REQUEST=DescribeFeatureType";

		// get BBox from geom_field (only one geom fld is allowed)
		$geomFld = null;
		{
			foreach ($fldList as $fldName) {
				if ($acl->isGeomField($fldName)) {
					$geomFld = $fldName;
				}
			}
		}

		if($DBG){echo "ogcFilter(" . strlen($args['ogc:Filter']) . "): {$args['ogc:Filter']}\n";}
		$searchParams = array();
		$searchParams['limit'] = $args['limit'];
		$searchParams['limitstart'] = $args['offset'];
		if (!empty($args['sortBy'])) {
			$searchParams['sortBy'] = $args['sortBy'];
		} else {
			$searchParams['order_by'] = $acl->getPrimaryKeyField();
			$searchParams['order_dir'] = 'DESC';
		}
		if (strlen($args['ogc:Filter']) > 0) $searchParams['ogc:Filter'] = $args['ogc:Filter'];
		if (!empty($args['filterFields'])) $searchParams['cols'] = $args['filterFields'];// propertyName
		if (!empty($args['primaryKey'])) $searchParams['primaryKey'] = $args['primaryKey'];// featureID
		if (!empty($args['bbox'])) $searchParams['f_the_geom'] = "BBOX:{$args['bbox']}";
		if($DBG){echo 'getItems() searchParams:';print_r($searchParams);echo "\n";}
		$totalItems = $acl->getTotal($searchParams);
		if($DBG){echo 'totalItems:';print_r($totalItems);echo "\n";}

		$xmlWriter = new XMLWriter();
		if (!$xmlWriter) throw new HttpException("Error no XMLWriter", 404);
		$xmlWriter->openUri('php://output');
		$xmlWriter->setIndent(true);
		$xmlWriter->startDocument('1.0','UTF-8');
		$xmlWriter->startElement('wfs:FeatureCollection');
		$xmlWriter->writeAttribute('xmlns:wfs', 'http://www.opengis.net/wfs/2.0');
		$xmlWriter->writeAttribute('xmlns', 'http://www.opengis.net/wfs/2.0');
		$xmlWriter->writeAttribute('xmlns:gml', 'http://www.opengis.net/gml');
		$xmlWriter->writeAttribute('xmlns:xsi', 'http://www.w3.org/2001/XMLSchema-instance');
		// $xmlWriter->writeAttribute('xsi:schemaLocation', "{$wfsNsUri} {$featureTypeUri}");
		$xmlWriter->writeAttribute('numberMatched', $totalItems);
		$xmlWriter->writeAttribute('numberReturned', 0);
		// $xmlWriter->writeAttribute('timeStamp', "TODO: timestamp like '2011-12-09T11:30:16'");
		$xmlWriter->endElement();// wfs:FeatureCollection
		$xmlWriter->endDocument();
		exit;
	}

	public function getFeatures($args, $simple = true) {
		$DBG = (V::get('DBG_GEO', '', $_GET) > 0);// TODO: Profiler
		$DBG_DS = V::get('DBG_DS', 0, $_GET, 'int');
		$type = $args['typeName'];
		if($DBG){echo "typeName({$args['xsd:type']})\n";}
		$acl = $this->getAclFromTypeName($args['xsd:type']);
		$fldList = $this->_getFieldListFromAcl($acl);

		$baseNsUri = Api_WfsNs::getBaseWfsUri();
		$rootWfsNs = 'p5';
		$rootWfsNsUri = "{$baseNsUri}";
		$wfsNs = $args['typePrefix'];
		$wfsNsUri = "{$baseNsUri}/" . substr($args['typePrefix'], 3);
		$featureTypeUri = $this->getBaseUri() . "?SERVICE=WFS&VERSION=1.0.0&TYPENAME={$args['xsd:type']}&REQUEST=DescribeFeatureType";

		// get BBox from geom_field (only one geom fld is allowed)
		$geomFld = null;
		{
			foreach ($fldList as $fldName) {
				if ($acl->isGeomField($fldName)) {
					$geomFld = $fldName;
				}
			}
		}

		if($DBG){echo "ogcFilter(" . strlen($args['ogc:Filter']) . "): {$args['ogc:Filter']}\n";}
		$searchParams = array();
		$searchParams['limit'] = $args['limit'];
		$searchParams['limitstart'] = $args['offset'];
		if (!empty($args['sortBy'])) {
			$searchParams['sortBy'] = $args['sortBy'];
		} else {
			$searchParams['order_by'] = $acl->getPrimaryKeyField();
			$searchParams['order_dir'] = 'DESC';
		}
		if (strlen($args['ogc:Filter']) > 0) $searchParams['ogc:Filter'] = $args['ogc:Filter'];
		if (!empty($args['filterFields'])) $searchParams['cols'] = $args['filterFields'];// PropertyName
		if (!empty($args['primaryKey'])) $searchParams['primaryKey'] = $args['primaryKey'];// featureID
		if (!empty($args['bbox'])) $searchParams['f_the_geom'] = "BBOX:{$args['bbox']}";
		if($DBG){echo 'getItems:';print_r($searchParams);echo "\n";}
		$items = $acl->getItems($searchParams);

		$dom = new DOMDocument('1.0', 'utf-8');
		$dom->formatOutput = true;
		$dom->preserveWhiteSpace = false;
		$rootNode = $dom->createElementNS('http://www.opengis.net/wfs', 'wfs:FeatureCollection');
		$dom->appendChild($rootNode);
		$rootNode->setAttributeNS('http://www.w3.org/2000/xmlns/', 'xmlns', 'http://www.opengis.net/wfs');
		$rootNode->setAttributeNS('http://www.w3.org/2000/xmlns/', 'xmlns:wfs', 'http://www.opengis.net/wfs');
		$rootNode->setAttributeNS('http://www.w3.org/2000/xmlns/', 'xmlns:gml', 'http://www.opengis.net/gml');
		$rootNode->setAttributeNS('http://www.w3.org/2000/xmlns/', 'xmlns:xsi', 'http://www.w3.org/2001/XMLSchema-instance');
		$rootNode->setAttributeNS('http://www.w3.org/2000/xmlns/', 'xmlns:xlink', 'http://www.w3.org/1999/xlink');
		$rootNode->setAttributeNS('http://www.w3.org/2000/xmlns/', 'xmlns:' . $wfsNs, $wfsNsUri);
		if (!$simple) $rootNode->setAttributeNS('http://www.w3.org/2000/xmlns/', "xmlns:{$rootWfsNs}", $rootWfsNsUri);
		//$rootNode->setAttribute('xsi:schemaLocation', 'http://www.opengis.net/wfs');
		$rootNode->setAttribute('xsi:schemaLocation', "{$wfsNsUri} {$featureTypeUri}");

		if($DBG){echo '(geomFld: '.$geomFld.'):';print_r($acl->getFieldType($geomFld));echo "\n";}
		if (empty($items)) {
			$pKeyField = $acl->getPrimaryKeyField();
			$fakeItem = new stdClass();
			$fakeItem->{$pKeyField} = 0;
			$items[0] = $fakeItem;
		}
		$sourceName = $acl->getSourceName();
		$tblName = $acl->getName();
		foreach ($items as $itemKey => $item) {
			if (!is_array($item)) $item = (array)$item;

			if($DBG && !empty($geomFld)){echo 'item['.$itemKey.'] ('.$geomFld.')isEmpty('.empty($item[$geomFld]).'):';print_r($item[$geomFld]);echo "\n";}
			if($DBG_DS){echo ">>> loop({$itemKey}) item: ";print_r($item);echo "\n";}

			$featureMemberNode = $dom->createElementNS('http://www.opengis.net/gml', 'gml:featureMember');
			$rootNode->appendChild($featureMemberNode);
				$featureNode = $dom->createElementNS($wfsNsUri, "{$wfsNs}:{$type}");
				$featureMemberNode->appendChild($featureNode);
				$featureNode->setAttribute('fid', "{$type}.{$itemKey}");
				if (!$simple) $featureNode->setAttributeNS($rootWfsNsUri, "{$rootWfsNs}:web_link", Request::getPathUri() . "index.php?_route=ViewTableAjax&typeName=p5_{$sourceName}:{$tblName}#EDIT/{$itemKey}");
					foreach ($fldList as $fldName) {
						$fldType = $acl->getXsdFieldType($fldName);
						$featureFldNode = $dom->createElementNS($wfsNsUri, "{$wfsNs}:{$fldName}");
						if($DBG_DS){echo">>> acl->canReadObjectField('{$fldName}', \$item) ...\n";}
						if ($acl->canReadObjectField($fldName, (object)$item)) {
							if ($geomFld != null && $geomFld == $fldName) {
								$geomNode = $this->_typeConverter->createGmlFromWkt($item[$fldName], $dom);
								if (!$geomNode) continue;
								$featureFldNode->appendChild($geomNode);
							} else if (is_array($item[$fldName])) {// TODO: by struct - REF field
								if($DBG_DS){echo">>> TODO({$fldName}) REF item[{$itemKey}][{$fldName}]: ";print_r($item[$fldName]);echo "\n";}
								if (1 == count($item[$fldName])) {
									$xlink = $item[$fldName][0]['xlink'];
									$xlinkParts = explode(':', $xlink);
									if (2 != count($xlinkParts)) throw new Exception("Error Processing Reques - wrong xlink format for ".$acl->getName().".{$itemKey}/{$fldName}");
									$xlinkParts[0] = Api_WfsNs::getNsUri($xlinkParts[0]);
									$xlink = implode('#', $xlinkParts);
									$featureFldNode->setAttribute('xlink:href', $xlink);
								} else {
									throw new Exception("Error Processing Request - too many refs for ".$acl->getName().".{$itemKey}/{$fldName}");
								}
								// foreach ($item[$fldName] as $ref) {
								// 	$refNode = $dom->createElementNS($wfsNsUri, "{$wfsNs}:{$fldName}");
								// 	$featureFldNode->appendChild($refNode);
								// }
							} else {
								$featureFldNode->nodeValue = str_replace('&', '&amp;', $item[$fldName]);
								if (empty($featureFldNode->nodeValue) && '0' !== $featureFldNode->nodeValue) {
									continue;
								}
							}
						}
						if (!$simple) {
							if (!$acl->canReadObjectField($fldName, (object)$item)) {
								$featureFldNode->setAttributeNS($rootWfsNsUri, "{$rootWfsNs}:allow_read", "false");
							}
							if ($acl->canWriteObjectField($fldName, (object)$item)) {
								$featureFldNode->setAttributeNS($rootWfsNsUri, "{$rootWfsNs}:allow_write", "true");
							}
						}
						$featureNode->appendChild($featureFldNode);
					}
		}

		return $dom->saveXml();
	}

	public function describeFeatureTypeAction() {
		$type = V::get('TYPENAME', '', $_REQUEST);
		if (empty($type)) {
			$reqContent = Request::getRequestBody();
			if (!empty($reqContent)) {
				return $this->_parseDescribeFeatureTypeRequest($reqContent);
			} else {
				return $this->_getDescribeFeatureAllTypes();
			}
			//throw new HttpException("Wrong param TYPENAME", 400);
		}
		$typeEx = explode(':', $type);
		if (count($typeEx) != 2) throw new HttpException("Wrong param TYPENAME", 400);
		return $this->_getDescribeFeatureType($typeEx[0], $typeEx[1]);
	}

	public function describeFeatureTypeAdvancedAction() {
		$type = V::get('TYPENAME', '', $_REQUEST);
		if (empty($type)) {
			$reqContent = Request::getRequestBody();
			if (!empty($reqContent)) {
				return $this->_parseDescribeFeatureTypeRequest($reqContent, $simple = false);
			} else {
				return $this->_getDescribeFeatureAllTypes($simple = false);
			}
			//throw new HttpException("Wrong param TYPENAME", 400);
		}
		$typeEx = explode(':', $type);
		if (count($typeEx) != 2) throw new HttpException("Wrong param TYPENAME", 400);
		return $this->_getDescribeFeatureType($typeEx[0], $typeEx[1], $simple = false);
	}

	public function getCapabilitiesAction() {
		$wfsServerUrl = $this->getBaseUri();
		$serviceTitle = "Web Feature Service";
		$serviceDescription = "This is the reference implementation of WFS 1.0.0 and WFS 1.1.0, supports all WFS operations including Transaction.";

		//header('Content-type: application/xml; charset="utf-8"');
		header('Content-type: application/xml');
		$this->_getCapabilities($wfsServerUrl, $serviceTitle, $serviceDescription);
	}

}