| 1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399 |
- <?php
- Lib::loadClass('Api_WfsException');
- Lib::loadClass('Api_WfsGeomTypeConverter');
- Lib::loadClass('Api_WfsNs');
- Lib::loadClass('Request');
- Lib::loadClass('Core_AclHelper');
- Lib::loadClass('Core_XmlWriter');
- class Api_WfsServerBase {
- public $_usrAcl;
- public $_typeConverter;
- public $_apiBaseUri;
- protected $_logFile;
- public function __construct($usrAcl) {
- $this->_usrAcl = $usrAcl;
- $this->_typeConverter = new Api_WfsGeomTypeConverter();
- $this->_apiBaseUri = '';
- }
- public function setBaseUri($uri) {
- $this->_apiBaseUri = $uri;
- }
- public function getBaseUri() {// TODO: RMME
- return $this->_apiBaseUri;
- }
- /**
- * @param string $typeName - 'p5_default_db:TEST_PERMS'
- */
- public function getAclFromTypeName($typeName) {
- if ('1' == V::get('root', '', $_GET) && User::isAdmin()) {// TODO: check byt CRM_CONFIG where key = 'root_access_acl__{$usrLogin}' and val = '{$namespace}'
- $namespace = Api_WfsNs::namespaceFromTypeName($typeName);
- DBG::log("getAclFromTypeName({$typeName}): ns='{$namespace}'");
- Lib::loadClass('SchemaFactory');
- $objectStorage = SchemaFactory::loadDefaultObject('SystemObject');
- $item = $objectStorage->getItem($namespace, [
- 'propertyName' => '*,field'
- ]);
- DBG::log($item, 'array', "acl item");
- if (!$item['isStructInstalled']) throw new Api_WfsException("WARNING: acl '{$namespace}' has not struct installed - reinstall acl in Storage tool");
- if (!$item['idZasob']) throw new Api_WfsException("WARNING: acl '{$namespace}' in not installed in Zasoby - add to Zasoby in Storage tool");
- switch ($item['_type']) {
- case 'AntAcl': {
- Lib::loadClass('AntAclBase');
- return AntAclBase::buildInstance($item['idZasob'], $item);
- } break;
- default: throw new Api_WfsException("WARNING: Not implemented '{$namespace}' type '{$item['_type']}'");
- }
- }
- try { // TODO: use object cache `CRM_#CACHE_ACL_OBJECT`
- $namespace = str_replace([':', '__x3A__'], '/', $typeName);
- Lib::loadClass('SchemaFactory');
- $objItem = SchemaFactory::loadDefaultObject('SystemObject')->getItem($namespace, ['propertyName'=>"*,field"]);
- DBG::log($objItem, 'array', "DBG objItem({$namespace})");
- if (!$objItem['idZasob']) throw new Exception("Missing idZasob for namespace '{$namespace}'");
- if (!in_array($objItem['_type'], [
- // 'TableAcl', // TODO: TEST - to replace TableAcl by AntAcl or use object with namespace + '/tableName'?
- 'AntAcl',
- ])) throw new Exception("Not Implemented acl type '{$objItem['_type']}'");
- if (!$objItem['isObjectActive']) {
- if (!$objItem['hasStruct']) throw new Exception("namespace has no structure '{$namespace}'");
- if (!$objItem['isStructInstalled']) throw new Exception("namespace structure not installed '{$namespace}'");
- throw new Exception("namespace is not activated '{$namespace}'");
- }
- Lib::loadClass('AntAclBase');
- $acl = AntAclBase::buildInstance($objItem['idZasob'], $objItem);
- return $acl;
- } catch (Exception $e) {
- DBG::log($e);
- }
- $typeEx = explode(':', $typeName);
- $sourceName = $typeEx[0];
- $objName = $typeEx[1];
- if (2 != count($typeEx)) throw new Api_WfsException("Could not get acl for '{$typeName}' - syntax error");
- if ('p5_' == substr($sourceName, 0, 3)) $sourceName = substr($sourceName, 3);// remove prefix 'p5_'
- $acl = $this->_usrAcl->getObjectAcl($sourceName, $objName);
- $forceTblAclInit = 0;//('1' == V::get('_force', '', $_GET));
- $acl->init($forceTblAclInit);
- return $acl;
- }
- /**
- * @param $_GET [ , POST Body - XML file ]
- * @return array $args
- * TODO: get $acl and check more restrictions
- */
- public function parseGetFeatureArgsFromRequest() {
- $rawArgs = $_GET;// $_REQUEST; ($_POST values not allowed, only xml in post body)
- $args = array();
- $args['xsd:type'] = null;// @from: TYPENAME, typeName (typename)
- $args['typePrefix'] = null;// @from: TYPENAME, typeName (typename)
- $args['typeName'] = null;// @from: TYPENAME, typeName (typename)
- $args['srsname'] = null;// @from: SRSNAME (srsname)
- $args['limit'] = 0;// @from: MAXFEATURES, maxFeatures, COUNT (maxfeatures, count)
- $args['offset'] = 0;// @from: startIndex (startindex, count)
- $args['ogc:filter'] = null;// @from: FILTER, Filter (filter)
- $args['sortBy'] = null;// @from: sortBy (sortby)
- $args['wfs:propertyName'] = null;// @from: propertyName (propertyname)
- $args['filterFields'] = array();// array of field names to show - @from: propertyName
- $args['resultType'] = null;// @from: resultType (resulttype)
- $args['bbox'] = null;// @from: BBOX (bbox)
- $args['wfs:featureID'] = null;// @from: featureID, featureId (featureid)
- $args['primaryKey'] = null;// primaryKey type - @from: featureID or $req[primaryKey]
- $lowerArgs = array(); foreach ($rawArgs as $name => $value) $lowerArgs[ strtolower($name) ] = trim($value);
- $args['xsd:type'] = V::get('typename', '', $lowerArgs);
- $exType = explode(':', $args['xsd:type']);
- if (count($exType) != 2) throw new HttpException("Wrong param TYPENAME", 400);
- $args['typePrefix'] = $exType[0];
- $args['typeName'] = $exType[1];
- $args['srsname'] = V::get('SRSNAME', '', $lowerArgs);// eg. EPSG:4326
- $args['limit'] = V::get('maxfeatures', $args['limit'], $lowerArgs, 'int');
- $args['limit'] = V::get('count', $args['limit'], $lowerArgs, 'int');
- $defaultFeaturesLimit = ('biuro.biall-net.pl' == V::get('SERVER_NAME', '', $_SERVER)) ? 50000 : 10000;
- if ($args['limit'] <= 0) $args['limit'] = $defaultFeaturesLimit;// default limit
- $args['offset'] = V::get('startindex', 0, $lowerArgs, 'int');
- $args['ogc:filter'] = urldecode(V::get('filter', '', $lowerArgs));
- if (empty($args['ogc:filter'])) {// read ogc:Filter from POST body if not defined in GET
- $reqBody = Request::getRequestBody();
- if (!empty($reqBody)) {
- $parsedRequest = $this->parseOgcFilterRequest($reqBody);
- DBG::log($parsedRequest, 'array', 'parsed ogc query request');
- if (!empty($parsedRequest['ogc:Filter'])) $args['ogc:filter'] = $parsedRequest['ogc:Filter'];
- if (!empty($parsedRequest['wfs:PropertyName'])) {
- foreach ($parsedRequest['wfs:PropertyName'] as $fieldXpath) {
- $args['filterFields'][] = $fieldXpath;
- }
- }
- }
- }
- $args['sortBy'] = V::get('sortby', '', $lowerArgs);// TODO: split to array of array(fieldName, (asc | desc))
- $args['wfs:propertyName'] = trim(V::get('propertyname', '', $lowerArgs));// TODO: fields to show - split by ','
- if (strlen($args['wfs:propertyName']) > 0) {
- $exFields = explode(',', $args['wfs:propertyName']);
- foreach ($exFields as $fieldName) {
- $fieldName = trim($fieldName);
- if (!empty($fieldName)) $args['filterFields'][] = $fieldName;
- }
- }
- $args['resultType'] = V::get('resulttype', '', $lowerArgs);
- $args['bbox'] = V::get('bbox', '', $lowerArgs);
- if (!empty($args['bbox'])) {
- // BBOX may have EPSG at then end - example: ",EPSG:4326"
- $num = "\d+.?\d*?";// "\d+(.\d+)?"
- if (!preg_match("/^({$num}),({$num}),({$num}),({$num})(\,EPSG:\d+)?$/", $args['bbox'], $matches)) throw new Exception("Illegal BBOX format");
- // QGIS send BBOX in correct order: 54.23580872176457,18.46844302390853,54.25220902538883,18.492990600812696
- // first number should not be smaller then second
- // example $matches:
- // [0] => 18.492990600812696,54.23580872176457,18.46844302390853,54.25220902538883
- // [1] => 18.492990600812696
- // [2] => 54.23580872176457
- // [3] => 18.46844302390853
- // [4] => 54.25220902538883
- // (optional) EPGS
- $bboxPoints = ($matches[1] > $matches[2])
- ? [ $matches[1], $matches[2], $matches[3], $matches[4] ]
- : [ $matches[2], $matches[3], $matches[4], $matches[1] ];
- $args['bbox'] = implode(",", $bboxPoints);
- }
- $args['wfs:featureID'] = V::get('featureid', null, $lowerArgs);// TODO: allow multiply feature id (csv)
- if ($args['wfs:featureID']) {
- $dotPos = strpos($args['wfs:featureID'], '.');
- if (!$dotPos) throw new Exception("Wrong param featureID");
- if ($args['typeName'] != substr($args['wfs:featureID'], 0, $dotPos)) throw new Exception("Wrong typeName in param featureID");
- $args['primaryKey'] = substr($args['wfs:featureID'], $dotPos + 1);
- }
- $pk = V::get('primarykey', '', $lowerArgs);
- if ($pk) {
- $args['primaryKey'] = $pk;
- }
- if(DBG::isActive() && V::get('DBG', 0, $_GET)){ echo "\$lowerArgs:";print_r($lowerArgs); }
- if(DBG::isActive() && V::get('DBG', 0, $_GET)){ echo "\$args:";print_r($args); }
- return $args;
- }
- public function _getXmlSchemaLocation() {
- $schemaLocations = array();
- //$schemaLocations[] = 'http://www.opengis.net/wfs http://webgis.regione.sardegna.it:80/geoserver/schemas/wfs/1.0.0/WFS-capabilities.xsd';// @from http://webgis.regione.sardegna.it/geoserver/ows?service=WFS&request=GetCapabilities
- return (!empty($schemaLocations))? 'xsi:schemaLocation="' . implode(' ', $schemaLocations) . '"' : '';
- }
- public function _printXmlNamespaceList() {
- $listNs = array();
- foreach (Api_WfsNs::getNsList() as $uri => $prefix) {
- $listNs[] = 'xmlns:' . $prefix . '="' . $uri . '"';
- }
- return implode("\n", $listNs);
- }
- public function _getSourceNsList() {
- $usrObjList = array();
- $tblsAcl = $this->_usrAcl->getTablesAcl();
- foreach ($tblsAcl as $tblAcl) {
- $dataSourceName = 'default_db';// TODO: getSourceName
- $tblName = $tblAcl->getName();
- $usrObjList[] = array($dataSourceName, $tblName);
- }
- $usrObjList[] = array('objects', 'File');
- $usrObjList[] = array('objects', 'TestPerms');
- $usrObjList[] = array('objects', 'Korespondencja');
- return $usrObjList;
- }
- public function _parseTransactionXmlStruct($requestXml, $requestXmlTags) {
- $DBG = V::get('DBG_XML', 0, $_GET, 'int');// TODO: Profiler
- $rootTagName = V::get('tag', '', $requestXmlTags[0]);
- if ('Transaction' != $rootTagName) throw new Api_WfsException("Parse Request XML Error - Missing Transaction as root xml tag", __LINE__, null, 'TransactionParseError', 'request');
- // TODO: special actions if action on nested objects
- // 1. convert request: wfs.transaction.convert-wfs-request.xsl
- // 2. validate converted request: wfs.transaction-converted-request.xsd
- // 3. execute request in data source
- // if($DBG){echo 'L.' . __LINE__ . ' $requestXmlTags:';print_r($requestXmlTags);echo "\n";}
- /*
- <Transaction
- xmlns="http://www.opengis.net/wfs"
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
- version="1.0.0"
- service="WFS"
- xmlns:p5_objects="https://biuro.biall-net.pl/wfs/objects"
- xmlns:gml="http://www.opengis.net/gml">
- <Insert xmlns="http://www.opengis.net/wfs">
- <TestPerms xmlns="https://biuro.biall-net.pl/wfs/objects">
- <plik xmlns="https://biuro.biall-net.pl/wfs/objects">
- <p5_objects:File>
- <p5_objects:name>blank-wfs.gif</p5_objects:name>
- <p5_objects:content>R0lGODlhAQABAIAAAP///////yH+EUNyZWF0ZWQgd2l0aCBHSU1QACH5BAEKAAEALAAAAAABAAEAAAICTAEAOw==</p5_objects:content>
- </p5_objects:File>
- </plik>
- </TestPerms>
- </Insert>
- </Transaction>
- */
- $actionXmlTags = array();// // [ 0 => [ 'action'=>Insert, 'typeName'=>str, 'tags'=>[] ]
- {// split xml for action tags (Insert, Update, Delete)
- $tagsCount = count($requestXmlTags);
- for ($i = 1, $actionTagName = null, $actionIdx = -1, $tagLvl = 0; $i < $tagsCount - 1; $i++) {// skip Transaction open/close tag
- $tag = $requestXmlTags[$i];
- if (null == $actionTagName) {
- $actionTagName = $tag['tag'];
- $tagLvl = $tag['level'];
- $actionIdx += 1;
- $actionXmlTags[$actionIdx] = array();
- $actionXmlTags[$actionIdx]['action'] = $actionTagName;
- $actionXmlTags[$actionIdx]['typeName'] = V::get('typeName', '', $tag['attributes']);
- $actionXmlTags[$actionIdx]['isDeepObject'] = null;// null - unknown, false - not seed, true - deep
- $actionXmlTags[$actionIdx]['tags'] = array();
- } else if ($tag['tag'] == $actionTagName && 'close' == $tag['type'] && $tagLvl == $tag['level']) {
- $actionTagName = null;
- } else {
- $actionXmlTags[$actionIdx]['tags'][] = $tag;
- }
- }
- }
- {// Validate Request: WFS allow multiple tags inside Insert tag
- // TODO: implement multiple tags in Insert tag if reauired. Use array_splice($actionXmlTags, $actionIdx, 0, $insertTags);
- {// throw (Not Implemented, 501) if found multiple tags in Insert tag
- foreach ($actionXmlTags as $actionIdx => $action) {
- if ('Insert' !== $action['action']) continue;
- $lvl = $action['tags'][0]['level'];
- for ($i = 1, $cnt = count($action['tags']); $i < $cnt - 1; $i++) {
- $tag = $action['tags'][$i];
- // if($DBG){echo 'L.' . __LINE__ . " actionXmlTags loop({$i}) \$tag:";print_r($tag);echo "\n";}
- if ($tag['level'] == $lvl) throw new Exception("Error Processing Request - multiple tags inside Insert tag is not implemented", 501);
- }
- }
- }
- }
- {// Insert tag - fix typeName from first tag, remove first and last tag - leave only fields
- foreach ($actionXmlTags as $actionIdx => $action) {
- if ('Insert' !== $action['action']) continue;
- array_pop($action['tags']);// remove last tag (close tag)
- $tag = array_shift($action['tags']);// remove last tag (close tag)
- $typeName = $tag['tag'];// eg. with prefix 'p5_objects:File' or without prefix but with @xmlns
- if (false === strpos($typeName, ':')) {
- $nsType = V::get('xmlns', '', $tag['attributes']);
- if (!$nsType) throw new Exception("Error Processing Request - Missing object namespace '{$tag['tag']}'");
- $prefix = Api_WfsNs::getNsPrefix($nsType);
- if (!$prefix) {
- if ($typeName == substr(rtrim($nsType, '/'), -1 * strlen($typeName))) {// typeName may be added to ns uri
- $nsBaseForType = substr(rtrim($nsType, '/'), 0, -1 * strlen($typeName) - 1);
- $prefix = Api_WfsNs::getNsPrefix($nsBaseForType);
- }
- }
- if (!$prefix) throw new Exception("Error Processing Request - Unrecognized namespace uri '{$nsType}' for object '{$tag['tag']}'");
- $typeName = "{$prefix}:{$typeName}";
- }
- $action['typeName'] = $typeName;
- $actionXmlTags[$actionIdx] = $action;
- }
- }
- {// validate
- // if($DBG){echo 'L.' . __LINE__ . ' before validate $actionXmlTags:';print_r($actionXmlTags);echo "\n";}
- foreach ($actionXmlTags as $actionIdx => $action) {
- if ('Insert' == $action['action']) {
- if (empty($action['typeName'])) throw new Exception("Error Processing Request - unknown object typeName to Insert");
- $acl = $this->getAclFromTypeName($action['typeName']);
- $actionXmlTags[$actionIdx] = $acl->validateInsertXml($action);
- } else if ('Update' == $action['action']) {
- $acl = $this->getAclFromTypeName($action['typeName']);
- $actionXmlTags[$actionIdx] = $acl->validateUpdateXml($action);
- } else if ('Delete' == $action['action']) {
- if($DBG>1){echo'<pre>$action: ';print_r($action);echo'</pre>';}
- $acl = $this->getAclFromTypeName($action['typeName']);
- $actionXmlTags[$actionIdx] = $acl->validateDeleteXml($action);
- } else {
- if($DBG>1){echo'<pre>$action: ';print_r($action);echo'</pre>';}
- throw new Exception("{$action['action']} action not implemented", 501);
- }
- // continue;// TODO: validate all by type
- }
- }
- if ('1' == V::get('DBG_DONT_CHANGE_DB', '', $_REQUEST)) {
- echo "----------------- action xml tags: ---------------" . "\n";
- print_r($actionXmlTags);
- die(".EOF\n");
- }
- {// execute
- $returnIds = array();
- $changesList = array();
- foreach ($actionXmlTags as $actionIdx => $action) {
- if ('Insert' == $action['action']) {
- if (empty($action['typeName'])) throw new Exception("Error Processing Request - unknown object typeName to Insert");
- $acl = $this->getAclFromTypeName($action['typeName']);
- $newId = $acl->insertXml($action);
- $returnIds[$actionIdx] = $newId;
- $changesList[$actionIdx] = array('Status'=>(($newId > 0)? 'SUCCESS' : 'FAILED'), 'Message'=>"created {$newId}.", 'Action' => $action['action']);
- if ($newId > 0) $changesList[$actionIdx]['fid'] = $acl->getName() . '.' . $newId;
- } else if ('Update' == $action['action']) {
- if($DBG>1){echo'<pre>$action: ';print_r($action);echo'</pre>';}
- $acl = $this->getAclFromTypeName($action['typeName']);
- $affected = $acl->updateXml($action);
- $changesList[$actionIdx] = array('Status'=>(($affected >= 0)? 'SUCCESS' : 'FAILED'), 'Message'=>"affected {$affected}.", 'Action' => $action['action']);
- } else if ('Delete' == $action['action']) {
- $acl = $this->getAclFromTypeName($action['typeName']);
- $affected = $acl->deleteXml($action);
- $changesList[$actionIdx] = array('Status'=>(($affected >= 0)? 'SUCCESS' : 'FAILED'), 'Message'=>"deleted {$affected}.", 'Action' => $action['action']);
- } else throw new Exception("TODO: {$action['action']} action not implemented", 501);
- }
- if($DBG){echo 'L.' . __LINE__ . ' $changesList:';print_r($changesList);echo "\n";}
- }
- return $this->_transactionResponse($changesList);
- }
- public function _transactionResponse($changesList) {
- // <WFS_TransactionResponse>
- // <TransactionResult>
- // <Status> : SUCCESS / FAILED / PARTIAL
- // [<Locator]
- // [<Message]
- $messageTag = '';
- $statusTag = '';
- $statusIsFailed = false;
- $statusAll = null;
- $createdFeatureId = array();
- foreach ($changesList as $featureId => $change) {
- if ('FAILED' == $change['Status']) {
- $statusIsFailed = true;
- }
- if ('SUCCESS' == $change['Status'] && !empty($change['fid'])) {
- $createdFeatureId[] = $change['fid'];
- }
- // if (!empty($change['Message'])) $messageTag .= "Feature '{$featureId}' {$change['Status']}: {$change['Message']}\n";
- }
- $statusTag = ($statusIsFailed)? 'FAILED' : 'SUCCESS';
- $statusTag = "<wfs:{$statusTag}/>";
- $messageTag = '';//"<wfs:Message>{$messageTag}</wfs:Message>";
- /* Example:
- <?xml version="1.0" encoding="UTF-8"?>
- <wfs:WFS_TransactionResponse version="1.0.0" xmlns:wfs="http://www.opengis.net/wfs"
- xmlns:ogc="http://www.opengis.net/ogc" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
- xsi:schemaLocation="http://www.opengis.net/wfs http://localhost:8080/geoserver/schemas/wfs/1.0.0/WFS-transaction.xsd">
- <wfs:InsertResult>
- <ogc:FeatureId fid="archsites.26" />
- </wfs:InsertResult>
- <wfs:TransactionResult handle="Updating Signature rock label">
- <wfs:Status>
- <wfs:SUCCESS />
- </wfs:Status>
- </wfs:TransactionResult>
- </wfs:WFS_TransactionResponse>*/
- // TODO: build xml by DOMDocument
- // TODO: xsi:schemaLocation="http://www.opengis.net/wfs http://localhost:8080/geoserver/schemas/wfs/1.0.0/WFS-transaction.xsd"
- $wfsInsertResult = '';
- if (!empty($createdFeatureId)) {
- $wfsInsertResult = "\n<wfs:InsertResult>\n";
- foreach ($createdFeatureId as $fid) {
- $wfsInsertResult .= '<ogc:FeatureId fid="' . $fid . '" xmlns:ogc="http://www.opengis.net/ogc"/>' . "\n";
- }
- $wfsInsertResult .= "\n</wfs:InsertResult>\n";
- EOF;
- }
- $tranRes = <<<EOF
- <wfs:WFS_TransactionResponse version="1.0.0"
- xmlns:wfs="http://www.opengis.net/wfs"
- xmlns:ogc="http://www.opengis.net/ogc"
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
- {$wfsInsertResult}
- <wfs:TransactionResult>
- <wfs:Status>{$statusTag}</wfs:Status>
- {$messageTag}
- </wfs:TransactionResult>
- </wfs:WFS_TransactionResponse>
- EOF;
- return $tranRes;
- }
- public function _convertTransactionXml($requestXmlString, $sourceNsList) {
- $DBG = (V::get('DBG_XSL', '', $_GET) > 0);// TODO: Profiler
- if($DBG){echo 'L.' . __LINE__ . ' sourceNsList:';print_r($sourceNsList);echo "\n";}
- $updateActionsXsd = array();
- $insertActionsXsd = array();
- $deleteActionsXsd = array();
- //<!-- TODO: create tag Update{X} where X is namespace index -->
- foreach ($sourceNsList as $nsInd => $sourceNs) {
- // <Update>
- $theGeomField = 'the_geom';// TODO: get from fields list
- $typeName = "p5_{$sourceNs[0]}:{$sourceNs[1]}";
- if($DBG){echo 'L.' . __LINE__ . ' typeName:';print_r($typeName);echo "\n";}
- $updateElementName = "UpdateNs{$nsInd}";
- $geomCoordsUpdateXpath = "//wfs:Value/*/gml:outerBoundaryIs/gml:LinearRing/gml:coordinates";
- $geomCoordsInsertXpath = "//*/gml:outerBoundaryIs/gml:LinearRing/gml:coordinates";
- $acl = $this->getAclFromTypeName($typeName);
- $geomType = $acl->getGeomFieldType($theGeomField);
- if ('polygon' == $geomType) {
- $geomCoordsUpdateXpath = ".//wfs:Value/*/gml:outerBoundaryIs/gml:LinearRing/gml:coordinates";
- $geomCoordsUpdateXpath = "((<xsl:value-of select=\"{$geomCoordsUpdateXpath}\"/>))";
- $geomCoordsInsertXpath = ".//*/gml:outerBoundaryIs/gml:LinearRing/gml:coordinates";
- $geomCoordsInsertXpath = "((<xsl:value-of select=\"{$geomCoordsInsertXpath}\"/>))";
- } else if ('linestring' == $geomType) {
- $geomCoordsUpdateXpath = ".//wfs:Value/*/gml:coordinates";
- $geomCoordsUpdateXpath = "(<xsl:value-of select=\"{$geomCoordsUpdateXpath}\"/>)";
- $geomCoordsInsertXpath = ".//*/gml:coordinates";
- $geomCoordsInsertXpath = "(<xsl:value-of select=\"{$geomCoordsInsertXpath}\"/>)";
- } else if ('point' == $geomType) {
- $geomCoordsUpdateXpath = ".//wfs:Value/*/gml:coordinates";
- $geomCoordsUpdateXpath = "(<xsl:value-of select=\"{$geomCoordsUpdateXpath}\"/>)";
- $geomCoordsInsertXpath = ".//*/gml:coordinates";
- $geomCoordsInsertXpath = "(<xsl:value-of select=\"{$geomCoordsInsertXpath}\"/>)";
- }
- $actionXsd = <<<EOF
- <xsl:when test="@typeName = '{$typeName}'">
- <xsl:element name="{$updateElementName}">
- <xsl:attribute name="typeName"><xsl:value-of select="@typeName" /></xsl:attribute>
- <xsl:attribute name="featureId"><xsl:value-of select="ogc:Filter/ogc:FeatureId/@fid" /></xsl:attribute>
- <xsl:for-each select="wfs:Property">
- <xsl:element name="{wfs:Name}">
- <xsl:choose>
- <xsl:when test="wfs:Name = '{$theGeomField}'"><xsl:value-of select="local-name(//wfs:Value/*[1])"/>{$geomCoordsUpdateXpath}</xsl:when>
- <xsl:otherwise><xsl:value-of select="wfs:Value"/></xsl:otherwise>
- </xsl:choose>
- </xsl:element>
- </xsl:for-each>
- </xsl:element>
- </xsl:when>
- EOF;
- $updateActionsXsd[] = $actionXsd;
- $typeName = "{$sourceNs[1]}";//"p5_{$sourceNs[0]}:{$sourceNs[1]}";
- $insertElementName = "InsertNs{$nsInd}";
- $actionXsd = <<<EOF
- <xsl:when test="local-name() = '{$typeName}'">
- <xsl:element name="{$insertElementName}">
- <xsl:attribute name="typeName"><xsl:value-of select="local-name()" /></xsl:attribute>
- <xsl:attribute name="typeNsUri"><xsl:value-of select="namespace-uri()" /></xsl:attribute>
- <xsl:for-each select="*">
- <xsl:element name="{local-name()}">
- <xsl:choose>
- <xsl:when test="local-name() = '{$theGeomField}'"><xsl:value-of select="local-name(*[1])"/>{$geomCoordsInsertXpath}</xsl:when>
- <xsl:otherwise><xsl:value-of select="."/></xsl:otherwise>
- </xsl:choose>
- </xsl:element>
- </xsl:for-each>
- </xsl:element>
- </xsl:when>
- EOF;
- $insertActionsXsd[] = $actionXsd;
- $deleteElementName = "DeleteNs{$nsInd}";
- $typeName = "p5_{$sourceNs[0]}:{$sourceNs[1]}";
- $actionXsd = <<<EOF
- <xsl:when test="@typeName = '{$typeName}'">
- <xsl:variable name="typeName" select="@typeName" />
- <xsl:for-each select="ogc:Filter/ogc:FeatureId">
- <xsl:element name="{$deleteElementName}">
- <xsl:attribute name="typeName"><xsl:value-of select="\$typeName" /></xsl:attribute>
- <xsl:attribute name="featureId"><xsl:value-of select="@fid" /></xsl:attribute>
- </xsl:element>
- </xsl:for-each>
- </xsl:when>
- EOF;
- $deleteActionsXsd[] = $actionXsd;
- }
- if (!empty($updateActionsXsd)) {
- $updateActionsXsd = implode("\n", $updateActionsXsd);
- $updateActionsXsd = <<<EOF
- <xsl:choose>
- {$updateActionsXsd}
- </xsl:choose>
- EOF;
- } else {
- $updateActionsXsd = '';
- }
- if (!empty($insertActionsXsd)) {
- $insertActionsXsd = implode("\n", $insertActionsXsd);
- $insertActionsXsd = <<<EOF
- <xsl:choose>
- {$insertActionsXsd}
- </xsl:choose>
- EOF;
- } else {
- $insertActionsXsd = '';
- }
- if (!empty($deleteActionsXsd)) {
- $deleteActionsXsd = implode("\n", $deleteActionsXsd);
- $deleteActionsXsd = <<<EOF
- <xsl:choose>
- {$deleteActionsXsd}
- </xsl:choose>
- EOF;
- } else {
- $deleteActionsXsd = '';
- }
- $convertTransactionXslString = '<?xml version="1.0"?>';
- $convertTransactionXslString .= <<<EOF
- <xsl:transform version="1.0"
- xmlns:xsl="http://www.w3.org/1999/XSL/Transform"
- xmlns:wfs="http://www.opengis.net/wfs"
- xmlns:ogc="http://www.opengis.net/ogc"
- xmlns:gml="http://www.opengis.net/gml">
- <xsl:template match="/">
- <xsl:for-each select="wfs:Transaction">
- <Transaction>
- <xsl:attribute name="version"><xsl:value-of select="@version" /></xsl:attribute>
- <xsl:attribute name="service"><xsl:value-of select="@service" /></xsl:attribute>
- <xsl:for-each select="wfs:Update">
- {$updateActionsXsd}
- </xsl:for-each>
- <xsl:for-each select="wfs:Insert/*">
- {$insertActionsXsd}
- </xsl:for-each>
- <xsl:for-each select="wfs:Delete">
- {$deleteActionsXsd}
- </xsl:for-each>
- <!-- TODO: Native -->
- </Transaction>
- </xsl:for-each>
- </xsl:template>
- </xsl:transform>
- EOF;
- if($DBG){echo 'L.' . __LINE__ . ' $convertTransactionXslString:' . $convertTransactionXslString . "\n";}
- $requestXml = new DOMDocument();
- $requestXml->loadXml($requestXmlString);
- $convertTransactionXsl = new DOMDocument();
- $convertTransactionXsl->loadXml($convertTransactionXslString);
- $proc = new XSLTProcessor();
- $proc->importStylesheet($convertTransactionXsl);
- return $proc->transformToXML($requestXml);
- }
- public function _validateConvertedTransactionXml($convertedTransaction, $sourceNsList) {
- $DBG = (V::get('DBG_XSD', '', $_GET) > 0);// TODO: Profiler
- if($DBG){echo 'L.' . __LINE__ . ' sourceNsList:';print_r($sourceNsList);echo "\n";}
- $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->setAttribute('elementFormDefault', 'qualified');
- $rootNode->setAttribute('version', '1.0');
- {// <xsd:element name="Transaction" type="TransactionType">
- $elNode = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xsd:element');
- $rootNode->appendChild($elNode);
- $elNode->setAttribute('name', 'Transaction');
- $elNode->setAttribute('type', 'TransactionType');
- $cTypeNode = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xsd:complexType');
- $rootNode->appendChild($cTypeNode);
- $cTypeNode->setAttribute('name', 'TransactionType');
- $seqNode = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xsd:sequence');
- $cTypeNode->appendChild($seqNode);
- $choiceNode = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xsd:choice');
- $seqNode->appendChild($choiceNode);
- $choiceNode->setAttribute('minOccurs', '0');
- $choiceNode->setAttribute('maxOccurs', 'unbounded');
- // <!-- <xsd:element ref="Update"/> -->
- foreach ($sourceNsList as $nsInd => $sourceNs) {
- $typeName = "p5_{$sourceNs[0]}:{$sourceNs[1]}";
- $updateElementName = "UpdateNs{$nsInd}";
- $updateElementType = "UpdateNs{$nsInd}ElementType";
- $updateElemNode = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xsd:element');
- $choiceNode->appendChild($updateElemNode);
- $updateElemNode->setAttribute('name', $updateElementName);
- $updateElemNode->setAttribute('type', $updateElementType);
- }
- // <!-- <xsd:element ref="Insert"/> -->
- foreach ($sourceNsList as $nsInd => $sourceNs) {
- $typeName = "p5_{$sourceNs[0]}:{$sourceNs[1]}";
- $insertElementName = "InsertNs{$nsInd}";
- $insertElementType = "InsertNs{$nsInd}ElementType";
- $insertElemNode = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xsd:element');
- $choiceNode->appendChild($insertElemNode);
- $insertElemNode->setAttribute('name', $insertElementName);
- $insertElemNode->setAttribute('type', $insertElementType);
- }
- // <!-- <xsd:element ref="Delete"/> -->
- foreach ($sourceNsList as $nsInd => $sourceNs) {
- $typeName = "p5_{$sourceNs[0]}:{$sourceNs[1]}";
- $deleteElementName = "DeleteNs{$nsInd}";
- $deleteElementType = "DeleteNs{$nsInd}ElementType";
- $deleteElemNode = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xsd:element');
- $choiceNode->appendChild($deleteElemNode);
- $deleteElemNode->setAttribute('name', $deleteElementName);
- $deleteElemNode->setAttribute('type', $deleteElementType);
- }
- // <!-- <xsd:element ref="Native"/> -->
- $attrNode = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xsd:attribute');
- $cTypeNode->appendChild($attrNode);
- $attrNode->setAttribute('name', 'version');
- $attrNode->setAttribute('type', 'xsd:string');
- $attrNode->setAttribute('use', 'required');
- $attrNode->setAttribute('fixed', '1.0.0');
- $attrNode = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xsd:attribute');
- $cTypeNode->appendChild($attrNode);
- $attrNode->setAttribute('name', 'service');
- $attrNode->setAttribute('type', 'xsd:string');
- $attrNode->setAttribute('use', 'required');
- $attrNode->setAttribute('fixed', 'WFS');
- }
- foreach ($sourceNsList as $nsInd => $sourceNs) {
- $transactionTypesList = array();
- $transactionTypesList[] = 'Update';
- $transactionTypesList[] = 'Insert';
- foreach ($transactionTypesList as $transactionType) {
- $typeName = "p5_{$sourceNs[0]}:{$sourceNs[1]}";
- if($DBG){echo 'L.' . __LINE__ . ' TODO: get acl typeName:';print_r($typeName);echo "\n";}
- $acl = $this->getAclFromTypeName($typeName);
- $updateElementName = "{$transactionType}Ns{$nsInd}";
- $updateElementType = "{$transactionType}Ns{$nsInd}ElementType";
- /*
- <xsd:complexType name="{$updateElementType}">
- <xsd:sequence>
- <xsd:element name="PARENT_ID" minOccurs="0" maxOccurs="1" type="xsd:integer" />
- </xsd:sequence>
- */
- $updateTypeNode = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xsd:complexType');
- $rootNode->appendChild($updateTypeNode);
- $updateTypeNode->setAttribute('name', $updateElementType);
- {
- $seqNode = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xsd:all');
- $updateTypeNode->appendChild($seqNode);
- {
- $pKeyField = $acl->getPrimaryKeyField();
- $fldList = $this->_getFieldListFromAcl($acl);
- // fields without geometry fields
- foreach ($fldList as $fldName) {
- if ($acl->isGeomField($fldName)) continue;
- $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);
- $fldType = null;
- 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';
- $fldType = null;// 'xsd:string';
- $patternDataTime = "(\d{4})-(\d{2})-(\d{2}) (\d{2}):(\d{2})(:(\d{2}))?";
- // <xsd:element name="..." minOccurs="0" nillable="true">
- // <xsd:simpleType>
- // <xsd:restriction base="xsd:string">
- // <xsd:pattern value="[a-zA-Z]+\(\((\-?\d+\.?\d*,\-?\d+\.?\d*)( \-?\d+\.?\d*,\-?\d+\.?\d*)+\)\)"/>
- // </xsd:restriction>
- // </xsd:simpleType>
- // </xsd:element>
- $simpleTypeNode = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xsd:simpleType');
- $restrictionNode = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xsd:restriction');
- $patternNode = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xsd:pattern');
- $restrictionNode->setAttribute('base', 'xsd:string');
- $patternNode->setAttribute('value', $patternDataTime);
- $restrictionNode->appendChild($patternNode);
- $simpleTypeNode->appendChild($restrictionNode);
- $elNode->appendChild($simpleTypeNode);
- // continue;// TODO: ? below added nillable = true, minOccurs = 0, type = $fldType
- }
- else if ($acl->isBinaryField($fldName)) {
- $fldType = 'xsd:base64Binary';
- }
- else {
- $fldType = 'xsd:string';
- }
- if ($fldType) $elNode->setAttribute('type', $fldType);
- $elNode->setAttribute('nillable', 'true');
- $elNode->setAttribute('minOccurs', '0');
- }
- // only geometry fields
- foreach ($fldList as $fldName) {
- if (!$acl->isGeomField($fldName)) continue;
- $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->isGeomField($fldName)) {
- //$fldType = 'gml:GeometryPropertyType';
- // TODO: use geom types from gml to wkt
- // TODO: pattern wg atrybutów gml:coordinates decimal="." cs="," ts=" "
- $patternWkt = '';// TODO: error if empty - unsupported geom type
- $patternNum = '\-?\d+\.?\d*';
- $patternPoint = $patternNum . ',' . $patternNum;
- $patternPoints = '(' . $patternPoint . ')( ' . $patternPoint . ')+';
- $geomType = $acl->getGeomFieldType($fldName);
- if ('polygon' == $geomType) {
- // [a-zA-Z]+\(\((\-?\d+\.?\d*,\-?\d+\.?\d*)( (\-?\d+\.?\d*,\-?\d+\.?\d*))+\)\)
- $patternWkt = '[a-zA-Z]+\(\(' . $patternPoints . '\)\)';
- } else if ('linestring' == $geomType) {
- // [a-zA-Z]+\((\-?\d+\.?\d*,\-?\d+\.?\d*)( (\-?\d+\.?\d*,\-?\d+\.?\d*))+\)
- $patternWkt = '[a-zA-Z]+\(' . $patternPoints . '\)';
- } else if ('point' == $geomType) {
- // [a-zA-Z]+\(\-?\d\.?\d*,\-?\d\.?\d*\)
- $patternWkt = '[a-zA-Z]+\(' . $patternPoint . '\)';
- }
- $simpleTypeNode = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xsd:simpleType');
- $restrictionNode = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xsd:restriction');
- $patternNode = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xsd:pattern');
- $restrictionNode->setAttribute('base', 'xsd:string');
- $patternNode->setAttribute('value', $patternWkt);
- $restrictionNode->appendChild($patternNode);
- $simpleTypeNode->appendChild($restrictionNode);
- $elNode->appendChild($simpleTypeNode);
- }
- $elNode->setAttribute('nillable', 'true');
- $elNode->setAttribute('minOccurs', '0');
- }
- }
- }
- $attrNode = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xsd:attribute');
- $updateTypeNode->appendChild($attrNode);
- $attrNode->setAttribute('name', 'typeName');
- $attrNode->setAttribute('type', 'xsd:token');
- $attrNode->setAttribute('use', 'required');
- if ($transactionType == 'Insert') {
- $attrNode = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xsd:attribute');
- $updateTypeNode->appendChild($attrNode);
- $attrNode->setAttribute('name', 'typeNsUri');
- $attrNode->setAttribute('type', 'xsd:anyURI');
- $attrNode->setAttribute('use', 'required');
- }
- if ($transactionType == 'Update') {
- $attrNode = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xsd:attribute');
- $updateTypeNode->appendChild($attrNode);
- $attrNode->setAttribute('name', 'featureId');
- $attrNode->setAttribute('use', 'required');
- $sTypeNode = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xsd:simpleType');
- $attrNode->appendChild($sTypeNode);
- $resNode = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xsd:restriction');
- $sTypeNode->appendChild($resNode);
- $resNode->setAttribute('base', 'xsd:string');
- $patternNode = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xsd:pattern');
- $resNode->appendChild($patternNode);
- $patternNode->setAttribute('value', '[a-zA-Z_][a-zA-Z0-9_]*\.[0-9]*');
- }
- }
- {// 'Delete'
- $typeName = "p5_{$sourceNs[0]}:{$sourceNs[1]}";
- $acl = $this->getAclFromTypeName($typeName);
- $deleteElementType = "DeleteNs{$nsInd}ElementType";
- $deleteTypeNode = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xsd:complexType');
- $rootNode->appendChild($deleteTypeNode);
- $deleteTypeNode->setAttribute('name', $deleteElementType);
- /* <xsd:attribute name="typeName" type="xsd:token" use="required"/> */
- $attrNode = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xsd:attribute');
- $deleteTypeNode->appendChild($attrNode);
- $attrNode->setAttribute('name', 'typeName');
- $attrNode->setAttribute('type', 'xsd:token');
- $attrNode->setAttribute('use', 'required');
- /* <xsd:attribute name="featureId" use="required"> */
- $attrNode = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xsd:attribute');
- $deleteTypeNode->appendChild($attrNode);
- $attrNode->setAttribute('name', 'featureId');
- $attrNode->setAttribute('use', 'required');
- $sTypeNode = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xsd:simpleType');
- $attrNode->appendChild($sTypeNode);
- $resNode = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xsd:restriction');
- $sTypeNode->appendChild($resNode);
- $resNode->setAttribute('base', 'xsd:string');
- $patternNode = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xsd:pattern');
- $resNode->appendChild($patternNode);
- $patternNode->setAttribute('value', '[a-zA-Z_][a-zA-Z0-9_]*\.[0-9]*');
- }
- }
- $validateConvertedTransactionXsdString = $dom->saveXml();
- if($DBG){echo 'L.' . __LINE__ . ' $validateConvertedTransactionXsdString:';print_r($validateConvertedTransactionXsdString);echo "\n";}
- $reqXml = new DOMDocument();
- $reqXml->loadXml($convertedTransaction);
- // TODO: fetch PHP Warning: DOMDocument::schemaValidateSource(): Element 'PARENT_ID': 'abc' is not a valid value of the atomic type 'xs:integer'.
- return $reqXml->schemaValidateSource($validateConvertedTransactionXsdString);
- }
- public function getInstanceFeatures($name, $args) {
- $acl = $this->getAclFromTypeName("{$args['typePrefix']}:{$name}");
- $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";
- header('Content-type: application/xml; charset=utf-8');
- $xmlWriter = new Core_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');
- $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);
- if (!$simple) $xmlWriter->writeAttribute("xmlns:{$rootWfsNs}", $rootWfsNsUri);
- $xmlWriter->writeAttribute('xsi:schemaLocation', "{$wfsNsUri} {$featureTypeUri}");
- $xmlWriter->writeComment("INSTANCE TABLE: " . Core_AclHelper::getInstanceTable($acl->getRootTableName()));
- // <gml:featureMember>
- // <p5_objects:TestPerms fid="TestPerms.64" p5:web_link="https://biuro.biall-net.pl/dev-pl/se-master/index.php?_route=ViewTableAjax&namespace=default_objects/TestPerms#EDIT/64">
- // <p5_objects:ID p5:allow_write="true">64</p5_objects:ID>
- $xmlWriter->endElement();// wfs:FeatureCollection
- $xmlWriter->endDocument();
- exit;
- }
- public function _describeInstanceAttributeTable($nsPrefix, $name) {
- $acl = $this->getAclFromTypeName("{$nsPrefix}:{$name}");
- header('Content-type: application/xml; charset=utf-8');
- $xmlWriter = new Core_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('xsd:schema');
- $xmlWriter->writeAttribute('xmlns:xsd', 'http://www.w3.org/2001/XMLSchema');
- $xmlWriter->writeAttribute('xmlns:gml', 'http://www.opengis.net/gml');
- foreach (Api_WfsNs::getNsList() as $uri => $prefix) {
- $xmlWriter->writeAttribute("xmlns:{$prefix}", $uri);
- }
- $xmlWriter->writeAttribute('elementFormDefault', 'qualified');
- $xsdInstanceType = $acl->getName() . "_instanceType";
- $xsdPrimaryKey = "xsd:string";// TODO: get from $acl
- $xmlWriter->h('xsd:element', ['name'=>"instance"], [
- [ 'xsd:complexType', [
- [ 'xsd:sequence', [
- [ 'xsd:element', ['name'=>"primaryKey", 'type'=>$xsdPrimaryKey], null ],
- [ 'xsd:element', ['name'=>"instance_name", 'type'=>$xsdInstanceType], null ],
- [ 'xsd:element', ['name'=>"instance_type", 'type'=>"xsd:string"], null ],// TODO: instance, derived, matching
- [ 'xsd:element', ['name'=>"create_author", 'type'=>"xsd:string"], null ],
- [ 'xsd:element', ['name'=>"create_date", 'type'=>"xsd:dateTime"], null ],
- [ 'xsd:element', ['name'=>"update_author", 'type'=>"xsd:string"], null ],
- [ 'xsd:element', ['name'=>"updage_date", 'type'=>"xsd:dateTime"], null ],
- [ 'xsd:element', ['name'=>"verified", 'type'=>"xsd:integer"], null ],
- ] ]
- ] ]
- ]);
- $instanceList = (method_exists($acl, 'getInstanceList'))
- ? array_map(function ($instanceName) {
- return [ 'xsd:enumeration', ['value'=>$instanceName], null ];
- }, $acl->getInstanceList())
- : [ [ 'xsd:enumeration', ['value'=>$acl->getName()], null ] ]
- ;
- $xmlWriter->h('xsd:simpleType', ['name'=>$xsdInstanceType], [
- [ 'xsd:restriction', ['base'=>"xsd:string"], $instanceList ],
- ]);
- $xmlWriter->endElement();// xsd:schema
- $xmlWriter->endDocument();
- exit;
- }
- public function _getDescribeFeatureType($nsPrefix, $type, $simple = true) {
- return $this->_getDescribeFeatureTypes(array(array($nsPrefix, $type)), $simple);
- }
- public function _parseDescribeFeatureTypeRequest($reqContent, $simple = true) {
- $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 ('DescribeFeatureType' != $rootTagName) {
- throw new Api_WfsException("Wrong xml root tag '{$rootTagName}' #" . __LINE__, 501);
- }
- $requestXmlTags = $tags;
- $DBG = (V::get('DBG_XML', '', $_GET) > 0);// TODO: Profiler
- $rootTagName = V::get('tag', '', $requestXmlTags[0]);
- if ('DescribeFeatureType' != $rootTagName) {
- throw new Exception("Parse Request xml error #" . __LINE__);
- }
- /*[1] => Array(
- [tag] => TypeName
- [type] => complete
- [level] => 2
- [value] => p5_default_db:Rozdzielcza_rurociag_wsg84)
- */
- $typeNames = array();
- $totalTypes = count($requestXmlTags) - 1;
- for ($i = 1; $i < $totalTypes; $i++) {
- if($DBG){echo "TAG[{$i}]:" . json_encode($requestXmlTags[$i]) . "\n";}
- $typeNames[] = explode(':', $requestXmlTags[$i]['value'], 2);
- }
- //echo "typeNames: " . json_encode($typeNames) . "\n";
- return $this->_getDescribeFeatureTypes($typeNames, $simple);
- }
- public function _getDescribeFeatureAllTypes($simple = true) {
- $db = DB::getDB();
- $idDefaultDB = $db->_zasob_id;
- $tblsAcl = $this->_getTableAclList();
- foreach ($tblsAcl as $tblAcl) {
- $dataSourceName = 'default_db';// TODO: getSourceName
- $tblName = $tblAcl->getName();
- $typeNames[] = array("p5_{$dataSourceName}", $tblName);
- }
- return $this->_getDescribeFeatureTypes($typeNames, $simple);
- }
- // @param $typeNames = array( array( $nsPrefix, $type ) )
- public function _getDescribeFeatureTypes($typeNames, $simple = true) {
- if (empty($typeNames)) throw new HttpException("Feature Type Names not defined", 400);
- $this->DBG("types:" . json_encode($typeNames), __LINE__, __FUNCTION__, __CLASS__);
- DBG::log($typeNames, 'array', "DescribeFeatureType \$typeNames");
- // TODO: fix namespace BUG for multiple types:
- // - fetch namespace for first type
- // - if another object has another namespace then -> import tag
- $baseNsUri = Api_WfsNs::getBaseWfsUri();
- $rootWfsNs = 'p5';
- $rootWfsNsUri = "{$baseNsUri}";
- $featureTypeUri = Api_WfsNs::getBaseWfsUri() . "?SERVICE=WFS&VERSION=1.0.0&REQUEST=DescribeFeatureType";
- header('Content-type: application/xml');
- $nsMap = Api_WfsNs::getNsList();// uri => prefix
- $xsdTargetNamespace = null;
- { // targetNamespace
- list($nsPrefix, $objectName) = reset($typeNames);
- $typeName = "{$nsPrefix}:{$objectName}";
- $acl = $this->getAclFromTypeName($typeName);
- $aclNamespaceUri = Api_WfsNs::getNsUri($acl->getSourceName());
- $xsdTargetNamespace = $aclNamespaceUri;
- if (!array_key_exists($aclNamespaceUri, $nsMap)) $nsMap[$aclNamespaceUri] = $acl->getSourceName();
- }
- $xmlWriter = new Core_XmlWriter();
- if (!$xmlWriter) throw new HttpException("Error no XMLWriter", 404);
- $xmlWriter->openMemory();// openUri('php://output');
- $xmlWriter->setIndent(true);
- $xmlWriter->startDocument('1.0','UTF-8');
- $xmlWriter->startElement('xsd:schema');
- $xmlWriter->writeAttribute('xmlns:xsd', 'http://www.w3.org/2001/XMLSchema');
- $xmlWriter->writeAttribute('xmlns:gml', 'http://www.opengis.net/gml');
- foreach (Api_WfsNs::getNsList() as $uri => $prefix) {
- $xmlWriter->writeAttribute("xmlns:{$prefix}", $uri);
- }
- $xmlWriter->writeAttribute('elementFormDefault', "qualified");
- if ($xsdTargetNamespace) $xmlWriter->writeAttribute('targetNamespace', $xsdTargetNamespace);
- $schemaLocations = [];
- //$schemaLocations[] = 'http://www.opengis.net/wfs http://webgis.regione.sardegna.it:80/geoserver/schemas/wfs/1.0.0/WFS-capabilities.xsd';// @from http://webgis.regione.sardegna.it/geoserver/ows?service=WFS&request=GetCapabilities
- if (!empty($schemaLocations)) $xmlWriter->writeAttribute('xsi:schemaLocation', implode(' ', $schemaLocations));
- $xmlWriter->writeAttribute('version', "1.0.0");
- $xmlWriter->h('xsd:import', [
- 'namespace' => "http://www.opengis.net/gml",
- 'schemaLocation' => Request::getPathUri() . "schema/gml/2.1.2/feature.xsd"
- ], null);
- foreach ($typeNames as $typeNameEx) {
- list($nsPrefix, $objectName) = $typeNameEx;
- $typeName = "{$nsPrefix}:{$objectName}";
- $xmlWriter->writeComment("typeName '{$typeName}'");
- $acl = $this->getAclFromTypeName($typeName);
- $aclNamespaceUri = Api_WfsNs::getNsUri($acl->getSourceName());
- if (!array_key_exists($aclNamespaceUri, $nsMap)) $nsMap[$aclNamespaceUri] = $acl->getSourceName();
- if ($xsdTargetNamespace != $aclNamespaceUri) {
- $xmlWriter->writeComment("TODO: typeName '{$typeName}' by import namespace '{$aclNamespaceUri}'");// TODO: <xsd:import>; continue;
- }
- DBG::log($acl->hasSimpleSchema(), 'array', "\$acl({$typeName})->hasSimpleSchema()");
- if ($acl->hasSimpleSchema()) {
- $simpleSchema = $acl->getSimpleSchema();
- $xmlWriter->writeComment("TODO: typeName '{$typeName}' hasSimpleSchema L." . __LINE__);
- $aliasRefMap = array();// fieldName => namespace uri
- foreach ($simpleSchema as $ssName => $schema) {
- if ('root' == $ssName) $ssName = $objectName;
- foreach ($schema as $fieldName => $field) {
- if (is_array($field)
- && !empty($field['@ref'])
- && false !== strpos($field['@ref'], '/')
- ) {// @ref_uri
- $aliasRefMap[ "{$ssName}_{$fieldName}" ] = $field['@ref'];
- }
- }
- }
- if (!empty($aliasRefMap)) {
- foreach ($aliasRefMap as $fieldName => $aliasNsUri) {
- list($nsUri, $prefix, $name) = Api_WfsNs::parseObjectNsUri($aliasNsUri);
- if (!array_key_exists($nsUri, $nsMap)) $nsMap[$nsUri] = $prefix;
- $xmlWriter->h('xsd:import', ['namespace' => $nsUri, 'schemaLocation' => "{$nsUri}.xsd"], null); // TODO: real file url -> DescribeFeatureType[Advanced]
- }
- }
- foreach ($simpleSchema as $ssName => $schema) {
- {// code from Code_AclSimpleSchema
- if ('root' == $ssName) $ssName = $objectName;
- // <xsd:complexType name="ZaliczkaPozycjaType">
- // <xsd:complexContent>
- // <xsd:extension base="gml:AbstractFeatureType">
- // <xsd:sequence>
- // <xsd:element minOccurs="0" maxOccurs="1" name="id" type="xsd:integer" nillable="true"/>
- // <xsd:element minOccurs="0" maxOccurs="1" name="created" type="xsd:date" nillable="true"/>
- // <xsd:element minOccurs="0" maxOccurs="1" ref="default_objects/AccessOwner" p5:name="worker"/>
- // <xsd:element minOccurs="0" maxOccurs="1" name="kwota" type="xsd:decimal" nillable="true"/>
- // <xsd:element minOccurs="0" maxOccurs="1" ref="ZaliczkaPozycja" p5:name="pozycja"/>
- // </xsd:sequence>
- // </xsd:extension>
- // </xsd:complexContent>
- // </xsd:complexType>
- $tnsPrefix = $acl->getSourceName();
- $xmlWriter->startElement('xsd:complexType');
- $xmlWriter->writeAttribute('name', "{$ssName}Type");
- $xmlWriter->startElement('xsd:sequence');
- foreach ($schema as $fieldName => $field) {
- // [@namespace] => default_db/ZALICZKA_POZYCJA/ZaliczkaPozycja
- // [id] => xsd:integer
- // [kwota] => xsd:decimal
- // [korespondencja] => [ '@ref' => Korespondencja ]
- // [projekt] => [ '@ref' => Projekt ]
- // TODO: p5:field_name
- if ('@' == substr($fieldName, 0, 1)) continue;// skip tags
- $xmlWriter->startElement('xsd:element');
- if (!is_array($field)) throw new Exception("Error Processing simpleSchema: '{$ssName}/{$fieldName}'");
- if (!empty($field['@type'])) {
- $xmlWriter->writeAttribute('name', $fieldName);
- $xmlWriter->writeAttribute('type', $field['@type']);
- $xmlWriter->writeAttribute('nillable', "true");
- } else if (!empty($field['@ref'])) {
- if (false !== strpos($field['@ref'], '/')) {// @ref_uri
- $xmlWriter->writeAttribute('ref', "{$tnsPrefix}:{$ssName}_{$fieldName}");
- $xmlWriter->writeAttributeNS($rootWfsNs, "name", $rootWfsNsUri, $fieldName);
- } else {
- $xmlWriter->writeAttribute('ref', "{$tnsPrefix}:{$field['@ref']}");
- if ($fieldName != $field['@ref']) {
- $xmlWriter->writeAttributeNS($rootWfsNs, "name", $rootWfsNsUri, $fieldName);
- }
- }
- } else {
- throw new Exception("Error Processing simpleSchema - missing @type or @ref: '{$ssName}/{$fieldName}'");
- }
- if (array_key_exists('@minOccurs', $field)) $xmlWriter->writeAttribute('minOccurs', $field['@minOccurs']);
- if (array_key_exists('@maxOccurs', $field)) $xmlWriter->writeAttribute('maxOccurs', $field['@maxOccurs']);
- $xmlWriter->endElement(); // 'xsd:element'
- }
- $xmlWriter->endElement(); // 'xsd:sequence'
- $xmlWriter->endElement(); // 'xsd:complexType'
- $xmlWriter->startElement('xsd:element');
- $xmlWriter->writeAttribute('name', $ssName);
- $xmlWriter->writeAttribute('type', "{$tnsPrefix}:{$ssName}Type");
- if (!$simple) {
- if (!empty($schema['@namespace'])) {// TODO: @namespace is required?
- list($nsUri, $prefix, $name) = Api_WfsNs::parseObjectNsUri($schema['@namespace']);
- $xmlWriter->writeAttributeNS($rootWfsNs, "namespace", $rootWfsNsUri, "{{$nsUri}}{$name}");
- }
- }
- $xmlWriter->endElement(); // 'xsd:element'
- }
- }
- if (!empty($aliasRefMap)) {
- foreach ($aliasRefMap as $fieldName => $aliasNsUri) {
- list($nsUri, $prefix, $name) = Api_WfsNs::parseObjectNsUri($aliasNsUri);
- $xmlWriter->h('xsd:element', ['name' => $fieldName, 'type' => "{$prefix}:{$name}Type"], null);
- }
- }
- } else {
- $objectXsdName = "{$objectName}Type";
- $xmlWriter->startElement('xsd:complexType');
- $xmlWriter->writeAttribute('name', $objectXsdName);
- // if (!$simple) $xmlWriter->writeAttribute("xlmns:{$rootWfsNs}", $rootWfsNsUri);
- if (!$simple) $xmlWriter->writeAttributeNS($rootWfsNs, "web_link", $rootWfsNsUri, Request::getPathUri() . "index.php?_route=ViewTableAjax&namespace=" . $acl->getNamespace());
- if (!$simple && ($lastUpdateDate = $acl->lastUpdateDate())) $xmlWriter->writeAttributeNS($rootWfsNs, "last_update_date", $rootWfsNsUri, $lastUpdateDate);
- $xmlWriter->startElement('xsd:complexContent');
- $xmlWriter->startElement('xsd:extension');
- $xmlWriter->writeAttribute('base', "gml:AbstractFeatureType");
- $xmlWriter->startElement('xsd:sequence');
- $pKeyField = $acl->getPrimaryKeyField();
- $p5Attributes = ($simple)? array() : $acl->getAttributesFromZasoby();
- $fldList = $this->_getFieldListFromAcl($acl);
- foreach ($fldList as $fldName) {
- $xmlWriter->startElement('xsd:element');
- // TODO: get minOccurs from $acl->xsd()
- $xmlWriter->writeAttribute('minOccurs', (method_exists($acl, 'getXsdMinOccurs'))
- ? $acl->getXsdMinOccurs($fldName)
- : (($pKeyField == $fldName) ? '1' : '0')
- );
- $xmlWriter->writeAttribute('maxOccurs', (method_exists($acl, 'getXsdMaxOccurs'))
- ? $acl->getXsdMaxOccurs($fldName)
- : '1'
- );
- $fldType = $acl->getXsdFieldType($fldName);
- if (!$simple && $acl->isEnumerationField($fldName)) {
- $fldType = $acl->getSourceName() . ":{$fldName}Type";
- }
- if ('ref:' == substr($fldType, 0, 4)) {
- $xmlWriter->writeAttribute("ref", substr($fldType, 4));
- $xmlWriter->writeAttributeNS($rootWfsNs, "name", $rootWfsNsUri, $fldName);
- } else if ('local_ref:' == substr($fldType, 0, 10)) {
- $xmlWriter->writeAttribute("type", "{$fldName}Type");
- $xmlWriter->writeAttributeNS($rootWfsNs, "name", $rootWfsNsUri, $fldName);
- } else if ('alias_ref:' == substr($fldType, 0, 10)) {
- $xmlWriter->writeAttribute("ref", $acl->getSourceName() . ":{$fldName}");
- $xmlWriter->writeAttributeNS($rootWfsNs, "name", $rootWfsNsUri, $fldName);
- } else {
- $xmlWriter->writeAttribute('name', $fldName);
- $xmlWriter->writeAttribute('type', $fldType);
- $xmlWriter->writeAttribute('nillable', 'true');// nillable not allowed in ref
- }
- if (!$simple) {
- if (!empty($p5Attributes[$fldName])) {
- $p5attrs = $p5Attributes[$fldName];
- if (!empty($p5attrs['id_zasob'])) $xmlWriter->writeAttributeNS($rootWfsNs, "id_zasob", $rootWfsNsUri, $p5attrs['id_zasob']);
- if (!empty($p5attrs['label'])) $xmlWriter->writeAttributeNS($rootWfsNs, "label", $rootWfsNsUri, $p5attrs['label']);
- if (!empty($p5attrs['description'])) $xmlWriter->writeAttributeNS($rootWfsNs, "description", $rootWfsNsUri, $p5attrs['description']);
- }
- if ($acl->canWriteField($fldName)) $xmlWriter->writeAttributeNS($rootWfsNs, "allow_write", $rootWfsNsUri, "true");
- if ($acl->canCreateField($fldName)) $xmlWriter->writeAttributeNS($rootWfsNs, "allow_create", $rootWfsNsUri, "true");
- if (!$acl->canReadField($fldName)) $xmlWriter->writeAttributeNS($rootWfsNs, "allow_read", $rootWfsNsUri, "false");
- }
- $xmlWriter->endElement(); // xsd:element
- }
- $xmlWriter->endElement(); // xsd:sequence
- if (!$simple) $xmlWriter->h('xsd:attribute', ['name' => "instance", 'type' => $acl->getSourceName() . ":instanceType"], null);
- $xmlWriter->endElement(); // xsd:extension
- $xmlWriter->endElement(); // xsd:complexContent
- $xmlWriter->endElement(); // xsd:complexType
- if (!$simple) {
- $xsdInstanceList = (method_exists($acl, 'getInstanceList'))
- ? array_map(function ($instanceName) {
- return [ 'xsd:enumeration', ['value'=>$instanceName], null ];
- }, $acl->getInstanceList())
- : [ [ 'xsd:enumeration', ['value'=>$acl->getName()], null ] ]
- ;
- DBG::log($xsdInstanceList, 'array', "\$xsdInstanceList");
- $xmlWriter->h('xsd:simpleType', ['name' => 'instanceType'], [
- [ 'xsd:restriction', ['base' => 'xsd:string'], $xsdInstanceList ]
- ]);
- }
- $xmlWriter->h('xsd:element', ['name' => $objectName, 'type' => $acl->getSourceName() . ':' . $objectXsdName, 'substitutionGroup'=>"gml:_Feature"], null);
- foreach ($fldList as $fldName) {
- $fldType = $acl->getXsdFieldType($fldName);
- if ('alias_ref:' == substr($fldType, 0, 10)) {
- $localRefType = substr($fldType, 10);
- $xmlWriter->h('xsd:element', ['name' => $fldName, 'type' => $localRefType], null);
- } else if ('local_ref:' == substr($fldType, 0, 10)) {
- $localRefType = substr($fldType, 10);
- $xmlWriter->writeComment("TODO:
- <xsd:complexType name=\"produkt_Type\">
- <xsd:sequence>
- <xsd:element name=\"idProd\" type=\"xsd:integer\" />
- <xsd:element name=\"nazwa\" type=\"xsd:string\" />
- <xsd:element name=\"cena\" type=\"xsd:decimal\" />
- </xsd:sequence>
- </xsd:complexType>
- ");
- }
- }
- if (!$simple) {
- foreach ($fldList as $fldName) {
- if (!$acl->isEnumerationField($fldName)) continue;
- $xsdEnumList = [];
- $enum = $acl->getEnumerations($fldName);
- foreach ($enum as $val => $label) {
- $xsdEnum = ['xsd:enumeration', ['value' => $val], null];
- if (!empty($p5Attributes[$fldName]['valuesMap'][$val])) {
- $xsdEnum[1]["xmlns:{$rootWfsNs}"] = $rootWfsNsUri;
- $xsdEnum[1]["{$rootWfsNs}:label"] = $p5Attributes[$fldName]['valuesMap'][$val];
- }
- $xsdEnumList[] = $xsdEnum;
- }
- $xmlWriter->h('xsd:simpleType', ['name' => "{$fldName}Type"], [
- [ 'xsd:restriction', ['base' => "xsd:string"], $xsdEnumList ]
- ]);
- }
- }
- }
- }
- $xmlWriter->endElement(); // 'xsd:schema'
- $xmlWriter->endDocument();
- echo $xmlWriter->outputMemory($flush = true);
- }
- public function _getTableAclList() {// Use only Tables from default_db
- $tblAclList = array();
- $idDefaultDB = DB::getPDO()->getZasobId();
- $fullTblAclList = $this->_usrAcl->getTablesAcl();
- foreach ($fullTblAclList as $tblAcl) {
- if ($idDefaultDB != $tblAcl->getDB()) {// hide non default_db tables
- continue;
- }
- // $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
- // continue;
- // }
- $tblAclList[] = $tblAcl;
- }
- return $tblAclList;
- }
- public function _getFieldListFromAcl($acl) {
- $fldList = $acl->getRealFieldListByIdZasob();
- return $fldList;
- }
- public function setLogger($logger) {
- $this->_logger = $logger;
- }
- public function DBG($reqLog, $lineNr = null, $funName = null, $className = null) {
- if (!$this->_logger) return;
- $this->_logger->DBG($reqLog, $lineNr, $funName, $className);
- }
- public function parseOgcFilterRequest($requestOgcFilter) {
- // GetFeature: @maxFeatures, @traverseXlinkDepth, @traverseXlinkExpiry
- // \-- (1..) wfs:Query: @typeName
- // \--- (0..) ---: wfs:PropertyName
- // : wfs:XlinkPropertyName
- // : ogc:Function
- // ogc:Filter
- // ogc:SortBy
- // \--- (1..) ogc:SortProperty
- // \---: ogc:PropertyName
- // : ogc:SortOrder ( DESC / ASC )
- // <ogc:SortBy>
- // <ogc:SortProperty>
- // <ogc:PropertyName>ASTA</ogc:PropertyName>
- // <ogc:SortOrder>ASC</ogc:SortOrder>
- // </ogc:SortProperty>
- // </ogc:SortBy>
- if (empty($requestOgcFilter)) return '';
- $requestXml = new DOMDocument();
- $requestXml->loadXml($requestOgcFilter);
- $rootNode = $requestXml->documentElement;
- // if ($rootNode->getAttribute('resolve'))
- DBG::log([$rootNode->getAttribute('resolve'), $rootNode->getAttribute('resolveDepth')], 'array', "TODO: use wfs:GetFeature @resolve, @resolveDepth");
- $nodesQuery = [];
- foreach ($requestXml->getElementsByTagNameNS('http://www.opengis.net/wfs', 'Query') as $element) {
- DBG::log($element->nodeName, 'array', "main loop - wfs:Query");
- $nodesQuery[] = $element;
- }
- if (empty($nodesQuery)) { // legacy - try to find 'ogc:Filter'
- $tagsFilter = [];
- foreach ($requestXml->getElementsByTagNameNS('http://www.opengis.net/ogc', 'Filter') as $element) {
- DBG::log($element->nodeName, 'array', "loop element (0 * wfs:Query)");
- $tagsFilter[] = $requestXml->saveXML($element);
- }
- DBG::log($tagsFilter, 'array', "\$tagsFilter (0 * wfs:Query)");
- return [
- 'ogc:Filter' => (!empty($tagsFilter))
- ? reset($tagsFilter) // TODO: only one ogc:Filter allowed
- : ''
- ];
- }
- if (1 === count($nodesQuery)) {
- $tagsFilter = [];
- foreach ($requestXml->getElementsByTagNameNS('http://www.opengis.net/ogc', 'Filter') as $element) {
- // DBG::log($element->nodeName, 'array', "loop ogc:Filter (1 * wfs:Query)");
- $tagsFilter[] = $requestXml->saveXML($element);
- }
- DBG::log($tagsFilter, 'array', "\$tagsFilter (1 * wfs:Query)");
- $tagsWfsPropertyName = [];
- foreach ($requestXml->getElementsByTagNameNS('http://www.opengis.net/wfs', 'PropertyName') as $element) {
- // DBG::log($element->nodeValue, 'array', "loop wfs:PropertyName (1 * wfs:Query)");
- if ($element->getAttribute('resolve')) DBG::log([$element->getAttribute('resolve'), $element->getAttribute('resolveDepth'), $element->getAttribute('resolvePath')], 'array', "TODO: use wfs:PropertyName @resolve, @resolveDepth, @resolvePath");
- $value = $element->nodeValue;
- if (in_array($element->getAttribute('resolve'), ['all', 'local', 'remote'])) {
- $depth = $element->getAttribute('resolveDepth');
- if ('*' !== substr($value, -1)) { // TODO: propertyName is not regex
- if ('*' === $depth) $value .= "/**"; // TODO: resolveDepth="*" - resolve all
- else if ((int)$depth > 0) $value .= str_repeat("/*", $depth);
- }
- }
- $tagsWfsPropertyName[] = $value;
- }
- DBG::log($tagsWfsPropertyName, 'array', "\$tagsWfsPropertyName (1 * wfs:Query)");
- return array_filter([
- 'ogc:Filter' => (!empty($tagsFilter))
- ? reset($tagsFilter)
- : '',
- 'wfs:PropertyName' => (!empty($tagsWfsPropertyName))
- ? $tagsWfsPropertyName
- : '',
- ], function ($value) { return !empty($value); });
- }
- throw new Exception("Not imeplemented multiple ogc:Query"); // multiple ogc:Query require ogc:Query/@typeName
- }
- }
|