src/Controller/ApiController.php line 390

Open in your IDE?
  1. <?php
  3. namespace App\Controller;
  5. use Bundles\Orders\Entity\OrderFx;
  6. use Symfony\Component\HttpFoundation\Request;
  7. use Symfony\Component\HttpFoundation\JsonResponse;
  8. use App\Entity\User;
  9. use App\Entity\Orders;
  10. use App\Entity\CurrencyPair;
  11. use App\Service\Matcher;
  12. use Psr\Log\LoggerInterface;
  13. use Symfony\Component\Cache\Adapter\AdapterInterface;
  14. use Psr\Cache\CacheItemPoolInterface;
  17. class ApiController extends ParentController {
  18. /** @var array */
  19. protected $errors = [];
  20. protected $data = ['status' => 'success'];
  21. protected $status = 'success';
  22. /** @var User */
  23. protected $user;
  24. protected $helper;
  25. protected $order;
  27. const EXPOSURE_UP = 1;
  28. const EXPOSURE_DOWN = 2;
  30. protected $inputOrder = [
  31. 'currency_pair',
  32. 'amount',
  33. 'exposure_direction',
  34. 'date_start',
  35. 'date_stop',
  36. 'add_periods',
  37. ];
  39. protected $inputFilters = [
  40. 'start_date_differs' => ['type' => 'int', 'limit' => 15],
  41. 'stop_date_differs' => ['type' => 'int', 'limit' => 15],
  42. ];
  44. protected $currencyPair;
  45. protected $amount;
  46. protected $exposure;
  47. protected $dateStart;
  48. protected $dateStop;
  51. public function getOrders(Request $request, LoggerInterface $dbLogger) {
  52. if (!$this->validUser($request)) {
  53. return $this->getResponse();
  54. }
  55. $dbLogger->info('getOrders', ['userId' => $this->user->getCustomer()->getId()]);
  56. /** @var OrderFx[] $orders */
  57. $orders = $this->getDoctrine()->getRepository(OrderFx::class)->findBy(['customer' => $this->user->getCustomer()->getId(), 'active' => true]);
  58. if (!empty($orders)) {
  59. $this->setData($orders);
  60. }
  62. return $this->getResponse();
  63. }
  65. public function getOrder(Request $request) {
  66. if (!$this->validUser($request)) {
  67. return $this->getResponse();
  68. }
  69. $orderPublicId = (int)$request->query->get('order_id');
  70. if (empty($orderPublicId)) {
  71. $this->setError('order id is empty');
  72. return $this->getResponse();
  73. }
  74. $filter = ['customer' => $this->user->getCustomer()->getId(), 'publicId' => $orderPublicId, 'active' => true];
  75. /** @var OrderFx $orderRecord */
  76. $orderRecord = $this->getDoctrine()->getRepository(OrderFx::class)->findOneBy($filter);
  77. if (empty($orderRecord)) {
  78. $this->setError('The order info was not found');
  79. return $this->getResponse();
  80. }
  81. $this->setData([$orderRecord]);
  83. return $this->getResponse();
  84. }
  86. public function putOrder(Request $request) {
  87. if (!$this->validUser($request)) {
  88. return $this->getResponse();
  89. }
  90. if (empty($request->query->all())) {
  91. $this->setError('No input data');
  92. return $this->getResponse();
  93. }
  94. $this->inputOrder[] = 'id'; //papildomai privalomas orderio id
  95. foreach ($this->inputOrder as $key) {
  96. $value = $request->query->get($key);
  97. if (empty($value)) {
  98. $this->setError('Required param '.$key.' is empty');
  99. }
  100. $this->data[$key] = strtoupper($value);
  101. }
  102. if (!empty($this->getErrors()) || !$this->isDataValid()) {
  103. return $this->getResponse();
  104. }
  106. $order = $this->order; //isDataValid() istato irasa, jei ji randa patikrinimo metu.
  107. $order->setCurrencyPair($this->currencyPair);
  108. $order->setAmount($this->amount);
  109. $order->setCurrency($this->exposure);
  110. $order->setDateStart($this->dateStart);
  111. $order->setDateStop($this->dateStop);
  112. $order->setEdited(date_create());
  114. $this->getDoctrine()->getManager()->persist($order);
  115. $this->getDoctrine()->getManager()->flush();
  116. $this->data = ['status' => 'success', 'id' => $order->getPublicId()];
  119. return $this->getResponse();
  120. }
  122. public function deleteOrder(Request $request) {
  123. if (!$this->validUser($request)) {
  124. return $this->getResponse();
  125. }
  126. if (empty($request->query->all())) {
  127. $this->setError('No input data');
  128. return $this->getResponse();
  129. }
  130. $this->inputOrder = ['id']; //privalomas tik orderio id
  131. foreach ($this->inputOrder as $key) {
  132. $value = $request->query->get($key);
  133. if (empty($value)) {
  134. $this->setError('Required param '.$key.' is empty');
  135. }
  136. $this->data[$key] = strtoupper($value);
  137. }
  139. if (!empty($this->data['id'])) {
  140. $filter = ['customer' => $this->user->getCustomer()->getId(), 'publicId' => (int)$this->data['id'], 'active' => true];
  141. /** @var OrderFx $orderRecord */
  142. $this->order = $this->getDoctrine()->getRepository(OrderFx::class)->findOneBy($filter);
  143. if (empty($this->order)) {
  144. $this->setError('Order by Id '.$this->data['id'].' is not find in your active order list');
  145. }
  146. }
  147. if (!empty($this->getErrors())) {
  148. return $this->getResponse();
  149. }
  151. $order = $this->order;
  152. $order->setActive(false);
  153. $order->setEdited(date_create());
  155. $this->getDoctrine()->getManager()->persist($order);
  156. $this->getDoctrine()->getManager()->flush();
  157. $this->data = ['status' => 'success', 'deleted_id' => $order->getPublicId()];
  160. return $this->getResponse();
  161. }
  163. public function postOrder(Request $request) {
  164. if (!$this->validUser($request)) {
  165. return $this->getResponse();
  166. }
  167. if (empty($request->query->all())) {
  168. $this->setError('No input data');
  169. return $this->getResponse();
  170. }
  171. foreach ($this->inputOrder as $key) {
  172. $value = $request->query->get($key);
  173. if (empty($value)) {
  174. $this->setError('Required param '.$key.' is empty');
  175. }
  176. $this->data[$key] = strtoupper($value);
  177. }
  178. if (!$this->isDataValid()) {
  179. return $this->getResponse();
  180. }
  183. $order = new OrderFx();
  185. $order->setCustomer($this->user->getCustomer());
  186. $order->setCurrencyPair($this->currencyPair);
  187. $order->setAmountBuy($this->amount);
  188. $order->setCurrency($this->exposure);
  189. $order->setCreated($this->dateStart);
  190. $order->setDateMaturity($this->dateStop);
  191. $order->setCreated(date_create());
  192. // $nextPublicId = $this->getDoctrine()->getRepository(OrderFx::class)->getNextPublicId($order->getCustomer());
  193. // $order->setPublicId($nextPublicId);
  195. // $validator = new \App\Validators\Orders();
  197. // $errors = $validator->validate($order);
  198. // if (empty($errors)) {
  199. $this->getDoctrine()->getManager()->persist($order);
  200. $this->getDoctrine()->getManager()->flush();
  201. $this->data = ['status' => 'success'];//, 'id' => $order->getPublicId()];
  202. // }
  204. return $this->getResponse();
  205. }
  207. public function getLiquidity(LoggerInterface $ordersLogger, CacheItemPoolInterface $cache, Request $request) {
  208. if (!$this->validUser($request)) {
  209. return $this->getResponse();
  210. }
  212. foreach ($this->inputOrder as $key) {
  213. $value = $request->query->get($key);
  214. if (empty($value)) {
  215. $this->setError('Required param '.$key.' is empty');
  216. }
  217. $this->data[$key] = strtoupper($value);
  218. }
  219. $this->data['filter'] = [];
  220. foreach ($this->inputFilters as $key => $params) {
  221. $value = $request->query->get($key);
  223. if (isset($value)) {
  224. if (!empty($params['type']) && $params['type'] == 'int') {
  225. $value = (int)$value;
  226. }
  227. if (!empty($params['limit']) && ($value < 0 || $value > $params['limit'])) {
  228. $this->setError('Filter param '.$key.' value is out of limits (0-'.$params['limit'].')');
  229. } else {
  230. $this->data['filter'][$key] = $value;
  231. }
  232. }
  233. }
  234. if (!$this->isDataValid()) {
  235. return $this->getResponse();
  236. }
  238. $periodsForCheck = $this->getPeriodsForCheck($request);
  240. if (!empty($periodsForCheck)) {
  241. foreach ($periodsForCheck as $period) {
  242. //dump($period);
  243. $order = new OrderFx();
  245. $order->setCustomer($this->user->getCustomer());
  246. $order->setCurrencyPair($this->currencyPair);
  247. $order->setAmount($this->amount);
  248. $order->setCurrency($this->exposure);
  249. $order->setDateStart($period['dateStart']);
  250. $order->setDateStop($period['dateStop']);
  252. try {
  253. $matcher = new Matcher(
  254. $this->container,
  255. $this->getDoctrine(),
  256. $cache,
  257. $ordersLogger,
  258. $this->config,
  259. $this->user,
  260. [$order],
  261. $this->data['filter']);
  263. $matches = $matcher->start(false);
  264. $distribution = [];
  265. $rate = 1;
  266. if (!empty($matches['orders'][0]['distribution'])) {
  267. $distribution = $matches['orders'][0]['distribution'];
  268. $rate = $matches['orders'][0]['rate'];
  269. }
  270. $coveredSumTotal = 0;
  271. $coveredSumInternal = 0;
  272. foreach ($distribution as $forwardType) {
  273. foreach ($forwardType as $item) {
  274. $coveredSumTotal += $item['amount'];
  275. if ($item['entity']->getCustomer()->getId() == $this->user->getCustomer()->getId()) {
  276. $coveredSumInternal += $item['amount'];
  277. }
  278. }
  279. }
  280. $coveredSumTotal = round(($coveredSumTotal * (float)$rate));
  281. if ($coveredSumTotal > $this->amount) {
  282. $coveredSumTotal = $this->amount;
  283. }
  284. $coverage = [
  285. 'amount' => [
  286. 'internal' => round($coveredSumInternal),
  287. 'external' => round($coveredSumTotal - $coveredSumInternal),
  288. 'total' => $coveredSumTotal,
  289. 'currency' => $order->getCurrencyPair()->getCurrencyNameByNumber($this->exposure),
  290. ],
  291. 'percentage' => [
  292. 'internal' => round($coveredSumInternal / $this->amount * 100, 1),
  293. 'external' => round(($coveredSumTotal - $coveredSumInternal) / $this->amount * 100, 1),
  294. 'total' => round($coveredSumTotal / $this->amount * 100, 1),
  295. ],
  296. ];
  297. $period = $order->getDateStart()->format('Y-m-d').' - '.$order->getDateStop()->format('Y-m-d');
  298. $this->data['coverage'][$period] = $coverage;
  299. } catch
  300. (\Exception $e) {
  301. $this->setError('internal error. '.$e->getMessage());
  302. }
  303. }
  305. }
  307. return $this->getResponse();
  308. }
  310. public function getCurrencyPairs(Request $request) {
  311. if (!$this->validUser($request)) {
  312. return $this->getResponse();
  313. }
  314. $this->helper = $this->get('helper');
  315. /** @var OrderFx[] $orders */
  316. $orders = $this->getDoctrine()->getRepository(OrderFx::class)->findBy(['active' => 1]);
  317. if (empty($orders)) {
  318. $this->setError('No any currency pair was found');
  319. return $this->getResponse();
  320. }
  321. $pairs = [];
  322. foreach ($orders as $order) {
  323. $pair = str_replace('/', '', $order->getCurrencyPair()->getName());
  324. if (!in_array($pair, $pairs)) {
  325. $pairs[] = $pair;
  326. }
  327. }
  328. sort($pairs);
  329. $this->data['currency_pairs'] = $pairs;
  331. return $this->getResponse();
  332. }
  334. protected function isDataValid() {
  336. if (!empty($this->data['id'])) {
  337. $filter = ['customer' => $this->user->getCustomer()->getId(), 'publicId' => (int)$this->data['id'], 'active' => true];
  338. /** @var OrderFx $orderRecord */
  339. $this->order = $this->getDoctrine()->getRepository(OrderFx::class)->findOneBy($filter);
  340. if (empty($this->order)) {
  341. $this->setError('Order by Id '.$this->data['id'].' is not found in your active order list');
  342. }
  343. }
  345. $currencies = str_split($this->data['currency_pair'], 3);
  346. if (count($currencies) != 2) {
  347. $this->setError('Wrong currency pair format: '.$this->data['currency_pair'].'. example: EURUSD, GBPUSD');
  348. return $this->getResponse();
  349. }
  350. $currencyPairName = $currencies[0].'/'.$currencies[1];
  351. $this->currencyPair = $this->getDoctrine()->getRepository(CurrencyPair::class)->findOneBy(['name' => $currencyPairName]);
  352. if (empty($this->currencyPair)) {
  353. $this->setError('Currency pair '.$this->data['currency_pair'].' is not supported');
  354. return $this->getResponse();
  355. }
  356. $this->exposure = self::EXPOSURE_UP;
  357. if (!in_array($this->data['exposure_direction'], ['UP', 'DOWN'])) {
  358. $this->setError('exposure_direction value allowed: "UP", "DOWN"');
  359. return $this->getResponse();
  360. }
  361. if ($this->data['exposure_direction'] == 'DOWN') {
  362. $this->exposure = self::EXPOSURE_DOWN;
  363. }
  364. $this->dateStart = date_create($this->data['date_start']);
  365. $this->dateStop = date_create($this->data['date_stop']);
  366. // if (date_create() > $this->dateStart) {
  367. // // $this->setError('Contract order start date must be in future');
  368. // }
  369. $dayOfWeekOfStartDate = $this->dateStart->format('w');
  370. if ($dayOfWeekOfStartDate != 5) {
  371. $this->setError('Order start date weekday is allowed only on fridays. Choose nearest friday date and repeat request');
  372. }
  373. // if (date_create() > $this->dateStop) {
  374. // // $this->setError('Contract order finish date must be in future');
  375. // }
  376. if ($this->dateStart >= $this->dateStop) {
  377. $this->setError('Contract order finish date must be later than start date');
  378. }
  379. $dayOfWeekOfStopDate = $this->dateStop->format('w');
  380. if ($dayOfWeekOfStopDate != 5) {
  381. $this->setError('Order stop date weekday is allowed only on fridays. Choose nearest friday date and repeat request');
  382. }
  383. $this->amount = (int)$this->data['amount'];
  384. if ($this->amount < 10000 || $this->amount > (1000000000)) {
  385. $this->setError('Amount value is out of limits (10 000 - 1 000 000 000)');
  386. }
  387. return empty($this->getErrors());
  388. }
  390. public function pageNotFound() {
  391. $this->setError('Request unknown. Check api endpoint and try again');
  392. return $this->getResponse(404);
  393. }
  395. public function apiDocs() {
  396. return $this->redirect('/api/doc/index.html');
  397. }
  399. protected function validUser(Request $request) {
  400. // look for header "Authorization: Bearer <token>"
  401. if (!$request->headers->has('Authorization')
  402. && 0 !== strpos($request->headers->get('Authorization'), 'Bearer ')) {
  403. $this->setError('Invalid authorization info');
  404. return false;
  405. }
  406. // skip beyond "Bearer "
  407. $authorizationHeader = $request->headers->get('Authorization');
  408. $apiKey = substr($authorizationHeader, 7);
  409. $ip = $request->getClientIp();
  411. /** @var User $user */
  412. $this->user = $this->getDoctrine()->getRepository(User::class)->findOneBy(['apiKey' => $apiKey]);
  413. if (empty($this->user)) {
  414. $this->setError('Invalid apiKey');
  415. return false;
  416. }
  418. if (strpos($this->user->getAllowedIps(), $ip) === false) {
  419. $this->setError('For this apiKey is not allowed IP: '.$ip);
  420. return false;
  421. }
  422. return true;
  423. }
  425. protected function setData($orders) {
  426. foreach ($orders as $order) {
  427. $order = [
  428. 'id' => $order->getPublicId(),
  429. 'currency_pair' => str_replace('/', '', $order->getCurrencyPair()->getName()),
  430. 'amount' => $order->getAmount(),
  431. 'amount_currency' => $order->getCurrencyPair()->getCurrencyNameByNumber(1),
  432. 'exposure_direction' => ($order->getCurrency() > 1 ? 'UP' : 'DOWN'),
  433. 'date_start' => $order->getDateStart()->format('Y-m-d H:i'),
  434. 'date_stop' => $order->getDateStop()->format('Y-m-d H:i'),
  435. 'covered' => $order->getReserveAmount(),
  436. ];
  437. $this->data['orders'][] = $order;
  438. }
  439. }
  441. protected function getResponse($status = 200) {
  442. if (!empty($this->getErrors())) {
  443. $this->data['status'] = 'error';
  444. $this->data['errors'] = $this->getErrors();
  445. }
  446. return new JsonResponse($this->data, $status);
  447. }
  449. protected function setError($error) {
  450. return $this->errors[] = $error;
  451. }
  453. protected function getErrors() {
  454. return $this->errors;
  455. }
  457. protected function getPeriodsForCheck($request) {
  458. $addPeriods = $request->query->get('add_periods');
  459. if (empty($addPeriods)) {
  460. return [
  461. [
  462. 'dateStart' => $this->dateStart,
  463. 'dateStop' => $this->dateStop,
  464. ],
  465. ];
  466. }
  467. $periods = [];
  468. $dateStartString = $this->dateStart->format('Y-m-d');
  469. $dateStopString = $this->dateStop->format('Y-m-d');
  470. $dateStartBeforeWeek = date_create($dateStartString.' -1 week');
  471. if ($dateStartBeforeWeek > date_create()) {
  472. $periods[] = [
  473. 'dateStart' => $dateStartBeforeWeek,
  474. 'dateStop' => date_create($dateStopString.' -1 week'),
  475. ];
  476. }
  477. $periods[] = [
  478. 'dateStart' => $this->dateStart,
  479. 'dateStop' => $this->dateStop,
  480. ];
  481. $periods[] = [
  482. 'dateStart' => $this->dateStart,
  483. 'dateStop' => date_create($dateStopString.' +1 week'),
  484. ];
  485. $periods[] = [
  486. 'dateStart' => date_create($dateStartString.' +1 week'),
  487. 'dateStop' => $this->dateStop,
  488. ];
  490. $periods[] = [
  491. 'dateStart' => date_create($dateStartString.' +1 week'),
  492. 'dateStop' => date_create($dateStopString.' +1 week'),
  493. ];
  494. if (count($periods) < 3) {
  495. $periods[] = [
  496. 'dateStart' => date_create($dateStartString.' +2 week'),
  497. 'dateStop' => date_create($dateStopString.' +2 week'),
  498. ];
  499. }
  500. return $periods;
  501. }
  502. }