query) && ('WFS' != V::get('service', '', $request->query))) { throw new Api_WfsException("Only WFS Service is allowed"); } $req = V::get('REQUEST', '', $request->query); if (!empty($req)) { $methodName = "{$req}Action"; if (!method_exists($this, $methodName)) { throw new Api_WfsException("Not Implemented " . htmlspecialchars($req), 501); } $this->DBG("WfsServer->{$methodName}() ...", __LINE__); $document = $this->$methodName($urlQuery); } else { $this->DBG("WfsServer->parseXMLRequest() ...", __LINE__); $document = $this->parseXMLRequest(); header('Content-type: application/xml'); echo ''; echo $document; exit;// TODO: return $document; } IF(V::get('DBG','',$_GET)){echo'
$document (' . __CLASS__ . '::' . __FUNCTION__ . ':' . __LINE__ . '): ';print_r($document);echo'
';} if ('raw' == V::get('outputFormat', '', $request->query)) { header('Content-type: text/plain; charset=utf-8'); echo $document; } else { header('Content-type: application/xml'); echo $document; } } 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 { if ('/@instance' == strtolower(substr($args['typeName'], -1 * strlen('/@instance')))) { return $this->getInstanceFeatures(substr($args['typeName'], 0, -1 * strlen('/@instance')), $args); } 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::log("typeName({$args['xsd:type']})"); $acl = $this->getAclFromTypeName($args['xsd:type']); DBG::log([ 'msg'=>"typeName({$args['xsd:type']}) - acl(".get_class($acl).")", '$acl'=>$acl ]); $fldList = $this->_getFieldListFromAcl($acl); $baseNsUri = Api_WfsNs::getBaseWfsUri(); $rootWfsNs = 'p5'; $rootWfsNsUri = "{$baseNsUri}"; $wfsNs = $args['typePrefix']; $wfsNsUri = "{$baseNsUri}/" . ('p5_' == substr($args['typePrefix'], 0, 3)) ? substr($args['typePrefix'], 3) : $args['typePrefix']; $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; } } } DBG::log("ogcFilter(" . strlen($args['ogc:filter']) . "): {$args['ogc:filter']}"); $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']}"; $queryFeatures = $acl->buildQuery($searchParams); $totalItems = $queryFeatures->getTotal(); $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) { $type = $args['typeName']; DBG::log("typeName({$args['xsd:type']})"); $acl = $this->getAclFromTypeName($args['xsd:type']); DBG::log([ 'msg'=>"typeName({$args['xsd:type']}) - acl(".get_class($acl).")", '$acl'=>$acl ]); $fldList = $this->_getFieldListFromAcl($acl); $baseNsUri = Api_WfsNs::getBaseWfsUri(); $rootWfsNs = 'p5'; $rootWfsNsUri = "{$baseNsUri}"; $wfsNs = $args['typePrefix']; $wfsNsUri = "{$baseNsUri}/" . ('p5_' === substr($args['typePrefix'], 0, 3) ? substr($args['typePrefix'], 3) : $args['typePrefix']); $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; } } } DBG::log("ogcFilter(" . strlen($args['ogc:filter']) . "): {$args['ogc:filter']}"); $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']}"; $contextFieldList = []; // convert $args['filterFields'] to field list $schemaCache = array(); try { $acl__getAllFieldNames = function ($listFields) { return array_map(function ($field) { return $field['fieldNamespace']; }, $listFields); }; $acl__getLocalFieldNames = function ($listFields) { return array_map(function ($field) { return $field['fieldNamespace']; }, array_filter($listFields, function ($field) { return $field['isLocal']; })); }; DBG::log($acl->getFields(), 'array', "\$contextFieldList ACL fields"); if (empty($args['filterFields'])) { // get all local fields // $contextFieldList = $acl__getLocalFieldNames($acl->getFields()); $contextFieldList = $acl__getAllFieldNames($acl->getFields()); } else { foreach ($args['filterFields'] as $fieldXPath) { if ('*' === $fieldXPath) { $contextFieldList = array_merge($contextFieldList, $acl__getLocalFieldNames($acl->getFields())); } else if (false === strpos($fieldXPath, '/') && false === strpos($fieldXPath, ':')) { $contextFieldList[] = $fieldXPath; } else if (false === strpos($fieldXPath, '/') && false !== strpos($fieldXPath, ':')) { $contextFieldList[] = $fieldXPath; $fieldNs = str_replace(['__x3A__', ':'], '/', $fieldXPath); $schemaCache[$fieldNs] = SchemaFactory::loadDefaultObject('SystemObject')->getItem($fieldNs, [ 'propertyName' => '*,field' ]); DBG::log($schemaCache[$fieldNs], 'array', "\$schemaCache[{$fieldNs}]"); } else if ('/*' === substr($fieldXPath, -2) && false === strpos(substr($fieldXPath, 0, -2), '/')) { $fieldName = substr($fieldXPath, 0, -2); $contextFieldList[] = $fieldName; $xsdType = $acl->getXsdFieldType($fieldName); if ('ref:' !== substr($xsdType, 0, 4)) throw new Exception("Error Processing Request - field '{$fieldXPath}' type is not ref '/*' is not allowed"); $fieldNs = str_replace(['__x3A__', ':'], '/', substr($xsdType, 4)); if (!array_key_exists($fieldNs, $schemaCache)) { $schemaCache[$fieldNs] = SchemaFactory::loadDefaultObject('SystemObject')->getItem($fieldNs, [ 'propertyName' => '*,field' ]); DBG::log($schemaCache[$fieldNs], 'array', "\$schemaCache[{$fieldNs}]"); } $fieldPrefix = "{$fieldName}"; $contextFieldList = array_merge($contextFieldList, array_map(function ($fieldName) use ($fieldPrefix) { return "{$fieldPrefix}/{$fieldName}"; }, $acl__getLocalFieldNames($schemaCache[$fieldNs]['field']))); } else { $fieldName = trim($fieldXPath, '*/'); DBG::log(['$fieldXPath'=>$fieldXPath, '$fieldName'=>$fieldName], 'array', "\$contextFieldList TODO"); } } } DBG::log($contextFieldList, 'array', "\$contextFieldList"); $searchParams['cols'] = $contextFieldList; } catch (Exception $e) { DBG::log($e); throw $e; } DBG::log([ 'msg'=>'getItems - $searchParams', '$searchParams'=>$searchParams ]); if($DBG){echo'
get_total (F.' . __FUNCTION__ . ':' . __LINE__ . '): ';print_r($jsonData->total);echo'
';} $queryFeatures = $acl->buildQuery($searchParams); $items = $queryFeatures->getItems(); DBG::log([ 'msg'=>'getItems - $items', '$items'=>$items ]); header('Content-type: application/xml; charset=utf-8'); $xmlWriter = new Core_XmlWriter(); $xmlWriter->openUri('php://output'); // $xmlWriter->openMemory();// DBG $xmlWriter->setIndent(true); if (!$xmlWriter) throw new HttpException("Error no XMLWriter", 404); $xmlWriter->startDocument('1.0','UTF-8'); //$xmlWriter->startElementNS('wfs', 'FeatureCollection', 'http://www.opengis.net/wfs'); $xmlWriter->startElement('wfs:FeatureCollection'); // $xmlWriter->writeAttributeNS('xmlns', 'wfs', 'http://www.w3.org/2000/xmlns/', 'http://www.opengis.net/wfs'); $xmlWriter->writeAttribute('xmlns:wfs', 'http://www.opengis.net/wfs'); $xmlWriter->writeAttribute('xmlns', 'http://www.opengis.net/wfs'); $xmlWriter->writeAttribute('xmlns:gml', 'http://www.opengis.net/gml'); $xmlWriter->writeAttribute('xmlns:xsi', 'http://www.w3.org/2001/XMLSchema-instance'); $xmlWriter->writeAttribute('xmlns:xlink', 'http://www.w3.org/1999/xlink'); $xmlWriter->writeAttribute("xmlns:{$wfsNs}", $wfsNsUri); // TODO: BUG $wfsNsUri if (!$simple) $xmlWriter->writeAttribute("xmlns:{$rootWfsNs}", $rootWfsNsUri); foreach ($schemaCache as $childSchema) { $xmlWriter->writeAttribute("xmlns:{$childSchema['nsPrefix']}", "{$rootWfsNsUri}/" . str_replace('__x3A__', '/', $childSchema['nsPrefix'])); } $xmlWriter->writeAttribute('xsi:schemaLocation', "{$wfsNsUri} {$featureTypeUri}"); // TODO: BUG $wfsNsUri $xmlWriter->writeAttribute('numberMatched', 'unknown'); // TODO: return total items if simple query (without prefix, small total number, maxFeatures set, etc.) // NOTE: for client: if numberMatched == 'unknown' then request with resultType = 'hits' $xmlWriter->writeAttribute('numberReturned', count($items)); $tblName = $acl->getName(); $primaryKeyField = $acl->getPrimaryKeyField(); foreach ($items as $item) { $itemKey = V::get($primaryKeyField, '', $item); if (!is_array($item)) $item = (array)$item; if (!empty($geomFld)) DBG::log(['msg'=>"item[{$itemKey}] ({$geomFld})isEmpty(".empty($item[$geomFld])."):", '$item['.$geomFld.']'=>$item[$geomFld]]); DBG::log([ 'msg'=>">>> loop({$itemKey})", '$item'=>$item ]); $xmlWriter->startElement('gml:featureMember'); $xmlWriter->startElement("{$wfsNs}:{$type}"); $xmlWriter->writeAttribute('fid', "{$type}.{$itemKey}"); if (!$simple) $xmlWriter->writeAttribute("{$rootWfsNs}:web_link", Request::getPathUri() . "index.php?_route=ViewTableAjax&namespace=" . $acl->getNamespace() . "#EDIT/{$itemKey}"); foreach ($fldList as $idZasob => $fldName) { if(V::get('DBG_LOOP','',$_GET))DBG::log([ 'msg'=>">>> loop({$itemKey}) item({$item['ID']}) fld({$fldName})", '$item'=>$item[$fldName] ]); $fldType = $acl->getXsdFieldType($fldName); if (!$acl->canReadObjectField($fldName, (object)$item)) continue; if ($geomFld != null && $fldName == $geomFld) { $xmlWriter->startElement("{$wfsNs}:{$fldName}"); if (!$simple && !$acl->canReadObjectField($fldName, (object)$item)) { $xmlWriter->writeAttribute("{$rootWfsNs}:allow_read", "false"); } if (!$simple && $acl->canWriteObjectField($fldName, (object)$item)) { $xmlWriter->writeAttribute("{$rootWfsNs}:allow_write", "true"); } $this->_typeConverter->createGmlFromWkt_xmlWriter($item[$fldName], $xmlWriter); $xmlWriter->endElement();// {$wfsNs}:{$fldName} } else if (is_array($item[$fldName])) {// TODO: by struct - REF field DBG::log([ 'msg'=>">>> loop({$itemKey}) REF item[{$itemKey}][{$fldName}]", '$item'=>$item[$fldName] ]); if (empty($item[$fldName])) { $xmlWriter->h($fldName); // } else if (1 == count($item[$fldName]) && !empty($item[$fldName][0]['xlink'])) { // $xlink = $item[$fldName][0]['xlink']; // $xlinkParts = explode(':', $xlink); // if (2 != count($xlinkParts)) throw new Exception("Error Processing Request - wrong xlink format for ".$acl->getName().".{$itemKey}/{$fldName}"); // $xlinkParts[0] = Api_WfsNs::getNsUri($xlinkParts[0]); // $xlink = implode('#', $xlinkParts); // $xmlWriter->startElement("{$wfsNs}:{$fldName}"); // if (!$simple && !$acl->canReadObjectField($fldName, (object)$item)) { // $xmlWriter->writeAttribute("{$rootWfsNs}:allow_read", "false"); // } // if (!$simple && $acl->canWriteObjectField($fldName, (object)$item)) { // $xmlWriter->writeAttribute("{$rootWfsNs}:allow_write", "true"); // } // $xmlWriter->writeAttribute('xlink:href', $xlink); // $xmlWriter->endElement();// {$wfsNs}:{$fldName} } else { // $xmlWriter->writeComment("TODO: ".$acl->getName().".{$itemKey}/{$fldName} ..."); $fieldNs = str_replace(['__x3A__', ':'], '/', $fldName); // substr($xsdType, 4)); if (!array_key_exists($fieldNs, $schemaCache)) { $xmlWriter->writeComment("Error Processing Request - field is not ref ".$acl->getName().".{$itemKey}/{$fldName}"); } else { foreach ($item[$fldName] as $refItem) { DBG::log($refItem, 'array', "\$refItem fld({$fldName})"); if (1 == count($refItem) && !empty($refItem['xlink'])) { $xmlWriter->startElement($schemaCache[$fieldNs]['typeName']); $xmlWriter->writeAttribute("xlink:href", $refItem['xlink']); $xmlWriter->endElement(); } else { $xmlWriter->startElement($schemaCache[$fieldNs]['typeName']); foreach ($schemaCache[$fieldNs]['field'] as $field) { // $xmlWriter->writeComment("REF field ({$field['fieldNamespace']}) value({$refItem[$field['fieldNamespace']]})"); if (array_key_exists($field['fieldNamespace'], $refItem)) { $xmlWriter->startElement("{$schemaCache[$fieldNs]['nsPrefix']}:{$field['fieldNamespace']}"); $xmlWriter->text($refItem[$field['fieldNamespace']]); $xmlWriter->endElement(); } } $xmlWriter->endElement(); } } } } } else if ('xsd:base64Binary' === $acl->getXsdFieldType($fldName)) { if (empty($item[$fldName]) && '0' !== $item[$fldName]) continue; $xmlWriter->startElement("{$wfsNs}:{$fldName}"); if (!$simple && !$acl->canReadObjectField($fldName, (object)$item)) { $xmlWriter->writeAttribute("{$rootWfsNs}:allow_read", "false"); } if (!$simple && $acl->canWriteObjectField($fldName, (object)$item)) { $xmlWriter->writeAttribute("{$rootWfsNs}:allow_write", "true"); } $xmlWriter->text(base64_encode($item[$fldName])); $xmlWriter->endElement();// {$wfsNs}:{$fldName} } else { $value = str_replace('&', '&', $item[$fldName]); if (empty($value) && '0' !== $value) { continue; } else { $xmlWriter->startElement("{$wfsNs}:{$fldName}"); if (!$simple && !$acl->canReadObjectField($fldName, (object)$item)) { $xmlWriter->writeAttribute("{$rootWfsNs}:allow_read", "false"); } if (!$simple && $acl->canWriteObjectField($fldName, (object)$item)) { $xmlWriter->writeAttribute("{$rootWfsNs}:allow_write", "true"); } $xmlWriter->text($value); $xmlWriter->endElement();// {$wfsNs}:{$fldName} } } } $xmlWriter->endElement();// {$wfsNs}:{$type} $xmlWriter->endElement();// gml:featureMember } $xmlWriter->endElement();// wfs:FeatureCollection $xmlWriter->endDocument(); exit; } 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() { $typeName = V::geti('TYPENAME', '', $_REQUEST); if (empty($typeName)) { $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); } if (false === strpos($typeName, ':')) throw new HttpException("Wrong param TYPENAME", 400); list($nsPrefix, $name) = explode(':', $typeName); if ('/@instance' == strtolower(substr($name, -1 * strlen('/@instance')))) { return $this->_describeInstanceAttributeTable($nsPrefix, substr($name, 0, -1 * strlen('/@instance'))); } return $this->_getDescribeFeatureType($nsPrefix, $name, $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."; $idDefaultDB = DB::getPDO()->getZasobId(); $aclList = array_filter($this->_usrAcl->getTablesAcl(), function ($acl) use ($idDefaultDB) { // // $dataSourceName = 'default_db';// TODO: getSourceName // // $tblName = $tblAcl->getName(); // // try { // // $acl = $this->getAclFromTypeName($typeName = "p5_{$dataSourceName}:{$tblName}"); // // } catch (Exception $e) { // // // echo "Error for table({$tblName}): " . $e->getMessage() . "\n"; // // } // // if (!$acl) { // // // TODO: error log msg // // return false; // // } return ($idDefaultDB == $acl->getDB()); // hide non default_db tables }); //header('Content-type: application/xml; charset="utf-8"'); header('Content-type: application/xml'); (new Api_Wfs_GetCapabilities)->getCapabilitiesXml($wfsServerUrl, $serviceTitle, $serviceDescription, $aclList); } }