Api.php 6.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194
  1. <?php
  2. class Api {
  3. private $_apiUser;
  4. private $_apiBaseUri;
  5. private $_request;
  6. public function setUser($user) {
  7. $this->_apiUser = $user;
  8. }
  9. public function setBaseUri($uri) {
  10. $this->_apiBaseUri = $uri;
  11. }
  12. public function execute($url) {
  13. $request = $this->parseUrl($url);
  14. $apiRouterName = $request->apiRouterName;
  15. 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>';}
  16. $apiRouterName = ucfirst(strtolower($apiRouterName));
  17. $apiRouterClassName = "Api_{$apiRouterName}";
  18. if (!Lib::tryLoadClass($apiRouterClassName)) {
  19. throw new HttpException("Route not exists", 404);
  20. }
  21. $apiRouter = new $apiRouterClassName();
  22. $apiRouter->setUser($this->_apiUser);
  23. $apiRouter->setBaseUri($this->_apiBaseUri);
  24. $responseDocument = $apiRouter->execute($request);
  25. if (empty($responseDocument)) {
  26. throw new HttpException("No result", 404);
  27. }
  28. $this->response($responseDocument);
  29. }
  30. private function parseUrl($url) {
  31. $request = new stdClass();
  32. $request->url = trim($url, '/ ');
  33. $urlParts = explode('?', $request->url);
  34. $request->path = $urlParts[0];
  35. $request->query = (count($urlParts) > 1)? $urlParts[1] : '';
  36. $request->args = $_REQUEST;
  37. $request->segments = array();
  38. $urlPathParts = explode('/', $request->path);
  39. foreach ($urlPathParts as $part) {
  40. if (!empty($part)) $request->segments[] = $part;
  41. }
  42. IF(V::get('DBG','',$_GET)>1){echo'<pre style="max-height:200px;overflow:auto;border:1px solid red;text-align:left;">url (' . __CLASS__ . '::' . __FUNCTION__ . ':' . __LINE__ . '): ';print_r($request);echo'</pre>';}
  43. $request->format = array_shift($request->segments);
  44. if (empty($request->segments)) return null;
  45. IF(V::get('DBG','',$_GET)>1){echo'<pre style="max-height:200px;overflow:auto;border:1px solid red;text-align:left;">responseFormat (' . __CLASS__ . '::' . __FUNCTION__ . ':' . __LINE__ . '): ';print_r($request->format);echo'</pre>';}
  46. if (!$this->checkResponseFormat($request->format)) {
  47. throw new HttpException("Response format not allowed", 400);
  48. }
  49. IF(V::get('DBG','',$_GET)>1){echo'<pre style="max-height:200px;overflow:auto;border:1px solid red;text-align:left;">u (' . __CLASS__ . '::' . __FUNCTION__ . ':' . __LINE__ . '): ';print_r($request);echo'</pre>';}
  50. $request->apiRouterName = array_shift($request->segments);
  51. IF(V::get('DBG','',$_GET)>1){echo'<pre style="max-height:200px;overflow:auto;border:1px solid red;text-align:left;">u (' . __CLASS__ . '::' . __FUNCTION__ . ':' . __LINE__ . '): ';print_r($request);echo'</pre>';}
  52. if (!empty($request->query)) {
  53. $queryArgs = array();
  54. parse_str($request->query, $queryArgs);
  55. $request->query = $queryArgs;
  56. }
  57. $this->_request = $request;
  58. return $this->_request;
  59. }
  60. private function checkResponseFormat($format) {
  61. $allowedTypes = array();
  62. $allowedTypes[] = 'xml';
  63. $allowedTypes[] = 'json';
  64. $allowedTypes[] = 'csv';
  65. $allowedTypes[] = 'csv_file';
  66. $allowedTypes[] = 'raw';
  67. //$allowedTypes[] = 'xml-ns';// xml with namespace
  68. return in_array($format, $allowedTypes);
  69. }
  70. private function response($document) {
  71. if ('xml' == $this->_request->format) {
  72. $this->responseXml($document);
  73. }
  74. else if ('json' == $this->_request->format) {
  75. $this->responseJson($document);
  76. }
  77. else if ('csv' == $this->_request->format) {
  78. $this->responseCsv($document);
  79. }
  80. else if ('csv_file' == $this->_request->format) {
  81. $this->responseCsvFile($document);
  82. }
  83. else if ('raw' == $this->_request->format) {
  84. echo $document;
  85. }
  86. }
  87. private function responseXml($document) {
  88. 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>';}
  89. $xml = new DOMDocument('1.0', 'utf-8');
  90. $xml->formatOutput = true;
  91. $data = $xml->createElement('data');
  92. $xml->appendChild($data);
  93. $this->_xmlAddChildRec($document, $data, $xml);
  94. header('Content-type: application/xml; charset="utf-8"');
  95. echo $xml->saveXML();
  96. }
  97. private function _xmlAddChildRec($node, $parentNode, $dom) {
  98. if (!$node) return;
  99. if (is_object($node)) {
  100. foreach ($node as $childNodeName => $childNode) {
  101. $n = $dom->createElement($childNodeName);
  102. $parentNode->appendChild($n);
  103. $this->_xmlAddChildRec($childNode, $n, $dom);
  104. }
  105. }
  106. else if (is_array($node)) {
  107. foreach ($node as $childNodeIndeks => $childNode) {
  108. $this->_xmlAddChildRec($childNode, $parentNode, $dom);
  109. }
  110. }
  111. else if (false !== strpos($node, '&')) {
  112. $n = $dom->createCDATASection($node);
  113. $parentNode->appendChild($n);
  114. }
  115. else {
  116. $n = $dom->createTextNode($node);
  117. $parentNode->appendChild($n);
  118. }
  119. }
  120. private function responseJson($document) {
  121. 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>';}
  122. header('Content-type: application/json; charset="utf-8"');
  123. echo json_encode($document);
  124. }
  125. private function responseCsv($document) {
  126. header('Content-Type: text/csv; charset=utf-8');
  127. if (empty($document)) return;
  128. $csvSeparator = ';';
  129. $this->_printCsvDocument($document, $csvSeparator);
  130. }
  131. private function responseCsvFile($document) {
  132. $csvFileName = 'output';//$this->_request
  133. if ('table' === $this->_request->apiRouterName) {
  134. $pathEx = explode('/', $this->_request->path);
  135. if (count($pathEx) > 3) {
  136. $csvFileName = $pathEx[3];
  137. }
  138. }
  139. header('Content-Type: text/csv; charset=utf-8');
  140. header("Content-Disposition: attachment; filename={$csvFileName}.csv");
  141. if (empty($document)) return;
  142. $csvSeparator = ';';
  143. $this->_printCsvDocument($document, $csvSeparator);
  144. }
  145. private function _printCsvDocument($document, $csvSeparator = ';') {
  146. if (empty($document)) return;
  147. $fldList = array();
  148. $labelsLine = array();
  149. foreach ($document->items[0]->item as $fldName => $value) {
  150. $fldList[] = $fldName;
  151. $labelsLine[] = '"' . addslashes($fldName) . '"';
  152. }
  153. echo implode($csvSeparator, $labelsLine) . "\n";
  154. foreach ($document->items as $itemsList) {
  155. foreach ($itemsList as $item) {
  156. $itemLine = array();
  157. foreach ($fldList as $fldName) {
  158. $itemLine[] = '"' . addslashes($item->{$fldName}) . '"';
  159. }
  160. echo implode($csvSeparator, $itemLine) . "\n";
  161. }
  162. }
  163. }
  164. }