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

<?php

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

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("TODO ... L." . __LINE__, 501);

		$xml = new SimpleXMLElement($reqContent);
		$namespaces = $xml->getNameSpaces(true);

		if ('Transaction' == $xml->getName()) {
			$this->_parseTransactionXml($xml);
		}
		else {
			throw new Api_WfsException("Not Implemented " . htmlspecialchars($xml->getName()), 501);
		}
	}

	public function getFeatureAction() {
		$type = V::get('TYPENAME', '', $_REQUEST);
		$typeEx = explode(':', $type);
		$maxFeatures = '10000';// TODO: Set Deafult Limit
		$maxFeatures = V::get('MAXFEATURES', $maxFeatures, $_REQUEST, 'int');
		$maxFeatures = V::get('maxFeatures', $maxFeatures, $_REQUEST, 'int');
		$ogcFilter = V::get('Filter', '', $_REQUEST);
		$sortBy = V::get('sortBy', '', $_REQUEST);
		$srsname = V::get('SRSNAME', '', $_REQUEST);// eg. EPSG:4326
		if (count($typeEx) == 2) {
			return $this->getFeatures($typeEx[0], $typeEx[1], $maxFeatures, $srsname, $ogcFilter, $sortBy);
		} else {
			throw new HttpException("Wrong param TYPENAME", 400);
		}
	}

	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 getFeatures($nsPrefix, $type, $maxFeatures, $srsname, $ogcFilter = '', $sortBy = '') {
		$DBG = (V::get('DBG_GEO', '', $_GET) > 0);// TODO: Profiler
		$typeName = "{$nsPrefix}:{$type}";
		$acl = $this->getAclFromTypeName($typeName);
		$fldList = $acl->getRealFieldList();

		$baseNsUri = $this->getBaseNamespaceUri();
		$wfsNs = 'p5_default_db_' . $type;//$nsPrefix;
		$wfsNsUri = "{$baseNsUri}/" . substr($nsPrefix, 3) . '/' . $type;

		// 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($ogcFilter) . "): {$ogcFilter}\n";}
		$searchParams = array();
		$searchParams['limit'] = $maxFeatures;
		if (!empty($sortBy)) {
			$searchParams['sortBy'] = $sortBy;
		} else {
			$searchParams['order_by'] = $acl->getPrimaryKeyField();
			$searchParams['order_dir'] = 'DESC';
		}
		if (strlen($ogcFilter) > 0) $searchParams['ogc:Filter'] = $ogcFilter;
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:' . $wfsNs, $wfsNsUri);
		$rootNode->setAttribute('xsi:schemaLocation', 'http://www.opengis.net/wfs');// TODO: add DescribeFeatureType xsd uri

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;
		}
		foreach ($items as $itemKey => $item) {

if($DBG){echo 'item['.$itemKey.'] ('.$geomFld.')isEmpty('.empty($item->{$geomFld}).'):';print_r($item->{$geomFld});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}");
					foreach ($fldList as $fldName) {
						$featureFldNode = $dom->createElementNS($wfsNsUri, "{$wfsNs}:{$fldName}");
						if ($acl->isGeomField($fldName)) {
							$geomNode = $this->_typeConverter->createGmlFromWkt($item->{$fldName}, $dom);
							if (!$geomNode) continue;
							$featureFldNode->appendChild($geomNode);
						} else {
							$featureFldNode->nodeValue = str_replace('&', '&amp;', $item->{$fldName});
							if (empty($featureFldNode->nodeValue)) {
								continue;
							}
						}
						$featureNode->appendChild($featureFldNode);
					}
		}

		return $dom->saveXml();
	}

	public function describeFeatureTypeAction() {
		$type = V::get('TYPENAME', '', $_REQUEST);
		if (empty($type)) {
			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 getDescribeFeatureType($nsPrefix, $type) {
		$typeName = "{$nsPrefix}:{$type}";
		$acl = $this->getAclFromTypeName($typeName);

		$baseNsUri = $this->getBaseNamespaceUri();
		$wfsNs = 'p5_default_db_' . $type;//$nsPrefix;
		$wfsNsUri = "{$baseNsUri}/" . substr($nsPrefix, 3) . '/' . $type;

		if (empty($type)) {
			throw new HttpException("Feature Type Name not defined", 400);
		}
		if (!$this->isAllowedFeatureType($nsPrefix, $type)) {
			throw new Api_WfsException("Could not find type: " . htmlspecialchars($type));
		}

		$typeName = $type . 'Type';
		$fldList = $acl->getRealFieldList();
		header('Content-type: application/xml');
		// <xsd:import namespace="http://www.opengis.net/gml" schemaLocation="http://webgis.regione.sardegna.it:80/geoserver/schemas/gml/2.1.2/feature.xsd"/>
		//	<xsd:element name="{type}" substitutionGroup="gml:_Feature" type="dbu:{typeName}"/>

		$dom = new DOMDocument('1.0', 'utf-8');
		$dom->formatOutput = true;
		$dom->preserveWhiteSpace = false;
		$rootNode = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xsd:schema');
		$dom->appendChild($rootNode);
		$rootNode->setAttributeNS('http://www.w3.org/2000/xmlns/', 'xmlns:gml', 'http://www.opengis.net/gml');
		$rootNode->setAttributeNS('http://www.w3.org/2000/xmlns/', 'xmlns:' . $wfsNs, $wfsNsUri);
		$rootNode->setAttribute('elementFormDefault', 'qualified');
		$rootNode->setAttribute('targetNamespace', $wfsNsUri);

		$cTypeNode = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xsd:complexType');
		$rootNode->appendChild($cTypeNode);
		$cTypeNode->setAttribute('name', $typeName);

		$cConNode = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xsd:complexContent');
		$cTypeNode->appendChild($cConNode);

		$extNode = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xsd:extension');
		$cConNode->appendChild($extNode);
		$extNode->setAttribute('base', 'gml:AbstractFeatureType');

		$seqNode = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xsd:sequence');
		$extNode->appendChild($seqNode);

		// <xsd:element maxOccurs="1" minOccurs="0" name="{$fldName}" nillable="true" type="xsd:integer"/>
		$pKeyField = $acl->getPrimaryKeyField();
		foreach ($fldList as $fldName) {
			$elNode = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xsd:element');
			$seqNode->appendChild($elNode);
			$elNode->setAttribute('name', $fldName);
			$minOccurs = 0;
			if ($pKeyField == $fldName) {
				$minOccurs = '1';
			} else {
				$minOccurs = '0';
			}
			$elNode->setAttribute('minOccurs', $minOccurs);
			if ($acl->isIntegerField($fldName)) {
				$fldType = 'xsd:integer';
			}
			else if ($acl->isDecimalField($fldName)) {
				$fldType = 'xsd:decimal';
			}
			else if ($acl->isDateField($fldName)) {
				$fldType = 'xsd:date';
			}
			else if ($acl->isDateTimeField($fldName)) {
				$fldType = 'xsd:dateTime';
			}
			else if ($acl->isGeomField($fldName)) {
				$fldType = 'gml:GeometryPropertyType';
				//$fldType = 'gml:Polygon';// nie działa musi być gml:GeometryPropertyType
			}
			else {
				$fldType = 'xsd:string';
			}
			$elNode->setAttribute('type', $fldType);
			$elNode->setAttribute('nillable', 'true');
		}

		$elNode = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xsd:element');
		$rootNode->appendChild($elNode);
		$elNode->setAttribute('name', $type);
		$elNode->setAttribute('type', $wfsNs . ':' . $typeName);

		echo $dom->saveXML();
	}

	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);
	}

}