Api.php 4.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158
  1. <?php
  2. Lib::loadClass('Type_ApiRequest');
  3. class Api {
  4. private $_apiUser;
  5. private $_apiBaseUri;
  6. private $_request;
  7. public function setUser($user) {
  8. $this->_apiUser = $user;
  9. }
  10. public function setBaseUri($uri) {
  11. $this->_apiBaseUri = $uri;
  12. }
  13. public function execute($url) {
  14. header('Access-Control-Allow-Credentials: true');
  15. header('Access-Control-Allow-Origin: https://dev.procesy5.pl');
  16. // header('Access-Control-Allow-Origin: *');
  17. // header('Access-Control-Max-Age: 86400'); // cache for 1 day
  18. $request = Type_ApiRequest::build($url);
  19. $this->_request = $request;
  20. $apiRouterName = $request->apiRouterName;
  21. IF(V::get('DBG','',$_GET)){echo'<pre style="max-height:200px;overflow:auto;border:1px solid red;text-align:left;">apiRouterName (' . __CLASS__ . '::' . __FUNCTION__ . ':' . __LINE__ . '): ';print_r($apiRouterName);echo'</pre>';}
  22. switch (strtolower($apiRouterName)) {
  23. case 'wfsdata': $apiRouterName = 'WfsData'; break;
  24. case 'wfsqgis': $apiRouterName = 'WfsQgis'; break;
  25. default: $apiRouterName = ucfirst(strtolower($apiRouterName)); break;
  26. }
  27. $apiRouterClassName = "Api_{$apiRouterName}"; // Api_WfsData, Api_WfsQgis, Api_Wps
  28. if (!Lib::tryLoadClass($apiRouterClassName)) {
  29. throw new HttpException("Route not exists", 404);
  30. }
  31. $apiRouter = new $apiRouterClassName();
  32. $apiRouter->setUser($this->_apiUser);
  33. $apiRouter->setBaseUri($this->_apiBaseUri);
  34. $responseDocument = $apiRouter->execute($request);
  35. if (empty($responseDocument)) {
  36. throw new HttpException("No result", 404);
  37. }
  38. $this->response($responseDocument);
  39. }
  40. private function response($document) {
  41. if ('xml' == $this->_request->format) {
  42. $this->responseXml($document);
  43. }
  44. else if ('json' == $this->_request->format) {
  45. $this->responseJson($document);
  46. }
  47. else if ('csv' == $this->_request->format) {
  48. $this->responseCsv($document);
  49. }
  50. else if ('csv_file' == $this->_request->format) {
  51. $this->responseCsvFile($document);
  52. }
  53. else if ('raw' == $this->_request->format) {
  54. echo $document;
  55. }
  56. }
  57. private function responseXml($document) {
  58. IF(V::get('DBG','',$_GET)){echo'<pre style="max-height:200px;overflow:auto;border:1px solid red;text-align:left;">document (' . __CLASS__ . '::' . __FUNCTION__ . ':' . __LINE__ . '): ';print_r($document);echo'</pre>';}
  59. $xml = new DOMDocument('1.0', 'utf-8');
  60. $xml->formatOutput = true;
  61. $data = $xml->createElement('data');
  62. $xml->appendChild($data);
  63. $this->_xmlAddChildRec($document, $data, $xml);
  64. header('Content-type: application/xml; charset="utf-8"');
  65. echo $xml->saveXML();
  66. }
  67. private function _xmlAddChildRec($node, $parentNode, $dom) {
  68. if (!$node) return;
  69. if (is_object($node)) {
  70. foreach ($node as $childNodeName => $childNode) {
  71. $n = $dom->createElement($childNodeName);
  72. $parentNode->appendChild($n);
  73. $this->_xmlAddChildRec($childNode, $n, $dom);
  74. }
  75. }
  76. else if (is_array($node)) {
  77. foreach ($node as $childNodeIndeks => $childNode) {
  78. $this->_xmlAddChildRec($childNode, $parentNode, $dom);
  79. }
  80. }
  81. else if (false !== strpos($node, '&')) {
  82. $n = $dom->createCDATASection($node);
  83. $parentNode->appendChild($n);
  84. }
  85. else {
  86. $n = $dom->createTextNode($node);
  87. $parentNode->appendChild($n);
  88. }
  89. }
  90. private function responseJson($document) {
  91. IF(V::get('DBG','',$_GET)){echo'<pre style="max-height:200px;overflow:auto;border:1px solid red;text-align:left;">document (' . __CLASS__ . '::' . __FUNCTION__ . ':' . __LINE__ . '): ';print_r($document);echo'</pre>';}
  92. header('Content-type: application/json; charset="utf-8"');
  93. echo json_encode($document);
  94. }
  95. private function responseCsv($document) {
  96. header('Content-Type: text/csv; charset=utf-8');
  97. if (empty($document)) return;
  98. $csvSeparator = ';';
  99. $this->_printCsvDocument($document, $csvSeparator);
  100. }
  101. private function responseCsvFile($document) {
  102. $csvFileName = 'output';//$this->_request
  103. if ('table' === $this->_request->apiRouterName) {
  104. $pathEx = explode('/', $this->_request->path);
  105. if (count($pathEx) > 3) {
  106. $csvFileName = $pathEx[3];
  107. }
  108. }
  109. header('Content-Type: text/csv; charset=utf-8');
  110. header("Content-Disposition: attachment; filename={$csvFileName}.csv");
  111. if (empty($document)) return;
  112. $csvSeparator = ';';
  113. $this->_printCsvDocument($document, $csvSeparator);
  114. }
  115. private function _printCsvDocument($document, $csvSeparator = ';') {
  116. if (empty($document)) return;
  117. $fldList = array();
  118. $labelsLine = array();
  119. foreach ($document->items[0]->item as $fldName => $value) {
  120. $fldList[] = $fldName;
  121. $labelsLine[] = '"' . addslashes($fldName) . '"';
  122. }
  123. echo implode($csvSeparator, $labelsLine) . "\n";
  124. foreach ($document->items as $itemsList) {
  125. foreach ($itemsList as $item) {
  126. $itemLine = array();
  127. foreach ($fldList as $fldName) {
  128. $itemLine[] = '"' . addslashes($item->{$fldName}) . '"';
  129. }
  130. echo implode($csvSeparator, $itemLine) . "\n";
  131. }
  132. }
  133. }
  134. }