Merged in APITOCART-18507-shipments-workflow (pull request #51)

APITOCART-18507-shipments-workflow [MASTER]

Approved-by: Oleg Syvak

Author: Taras Kubiv

src/app/Console/Commands/MakeRequest.php

@@ -0,0 +1,201 @@
+<?php
+
+namespace App\Console\Commands;
+
+use Api2Cart\Client\Model\ModelInterface;
+use App\Models\User;
+use App\Services\Api2Cart;
+use Carbon\Carbon;
+use GuzzleHttp\Promise\Promise;
+use GuzzleHttp\Promise\Utils as GuzzleHttpPromiseUtils;
+use Illuminate\Console\Command;
+use Illuminate\Support\Collection;
+use Illuminate\Support\Facades\Auth;
+
+class MakeRequest extends Command
+{
+  private $_api2Cart;
+
+  /**
+   * The name and signature of the console command.
+   *
+   * @var string
+   */
+  protected $signature = 'sendRequestToA2C
+                         {method : Method name}
+                         {parameters : base64encoded parameters}
+                         {resultEntity : Result entity in response}
+                         {resultEntityCount : Count of entity in response}
+                         {--subEntities=no : Get sub entities}
+                         {--subEntityId=id : SubEntity ID}';
+
+  /**
+   * The console command description.
+   *
+   * @var string
+   */
+  protected $description = 'Send request to Api2Cart';
+
+  /**
+   * Create a new command instance.
+   *
+   * @return void
+   */
+  public function __construct(Api2Cart $api2Cart)
+  {
+    $this->_api2Cart = $api2Cart;
+    parent::__construct();
+  }
+
+  /**
+   * Execute the console command.
+   *
+   * @return void
+   * @throws \Throwable
+   */
+  public function handle()
+  {
+    $userId = $_SERVER['USER_ID'];
+
+    $user = User::find($userId);
+
+    if ($user) {
+      $logs = collect([]);
+      $entities = collect([]);
+      Auth::login($user);
+      $this->_api2Cart->setApiKey($user->api2cart_key);
+      $resultEntity = $this->argument('resultEntity');
+      $resultEntityCount = $this->argument('resultEntityCount');
+      $method = $this->argument('method');
+
+      $parameters = json_decode(base64_decode($this->argument('parameters')), true);
+      $cartId = $parameters['cart_id'] ?? '';
+      unset($parameters['cart_id']);
+      $subEntities = strtolower($this->option('subEntities'));
+
+      $result = $this->_api2Cart->{$method}(...$parameters);
+
+      $entities = $this->_getEntities($result, $resultEntityCount, $resultEntity, $entities, $cartId);
+
+      if (isset($result['pagination']['next']) && strlen($result['pagination']['next'])) {
+        while (isset($result['pagination']['next']) && strlen($result['pagination']['next'])) {
+          $result = $this->_api2Cart->{$method . 'Page'}(null, $result['pagination']['next']);
+          $entities = $this->_getEntities($result, $resultEntityCount, $resultEntity, $entities, $cartId);
+        }
+      }
+
+      if ($entities->count()) {
+        $entities = $entities->keyBy('id');
+      }
+
+      if ($subEntities !== 'no') {
+        $subEntityId = strtolower($this->option('subEntityId'));
+        $entitiesIds = $entities->pluck($subEntityId)->all();
+
+        $maxConcurrent = 5;
+
+        /**
+         * @var Promise[] $promises
+         */
+        $promises = [];
+        $subEntitiesResults = [];
+
+        foreach ($entitiesIds as $entityId) {
+          if (count($promises) >= $maxConcurrent) {
+            GuzzleHttpPromiseUtils::unwrap($promises);
+
+            foreach ($promises as $entityId => $promise) {
+              if ($promise->getState() === Promise::FULFILLED) {
+
+                /**
+                 * @var ModelInterface $result
+                 */
+                $result = $promise->wait()[0] ?? [];
+
+                if ($result instanceof ModelInterface && $result->getReturnCode() === 10) {
+                  list($promise, $callback) = $this->_api2Cart->{$subEntities}($entityId);
+                  $subEntitiesResults[$entityId]['callback'] = $callback;
+                  $promises[$entityId] = $promise;
+                  break 2;
+                } else {
+                  $subEntitiesResults[$entityId]['result'] = $result;
+                }
+              }
+            }
+
+            $promises = [];
+            usleep(1000000);
+          }
+
+          list($promise, $callback) = $this->_api2Cart->{$subEntities}($entityId);
+          $subEntitiesResults[$entityId]['callback'] = $callback;
+          $promises[$entityId] = $promise;
+        }
+
+        GuzzleHttpPromiseUtils::unwrap($promises);
+
+        foreach ($promises as $entityId => $promise) {
+          $subEntitiesResults[$entityId]['result'] = $promise->wait()[0] ?? [];
+        }
+
+        $entities = $entities->transform(function ($item) use ($subEntitiesResults, $subEntityId) {
+          if (isset($subEntitiesResults[$item[$subEntityId]]['result'])
+            && $subEntitiesResults[$item[$subEntityId]]['result'] instanceof ModelInterface
+          ) {
+            $item['sub_entities'] = $subEntitiesResults[$item[$subEntityId]]['callback']($subEntitiesResults[$item[$subEntityId]]['result']);
+          }
+
+          return $item;
+        });
+      }
+
+      foreach ($this->_api2Cart->getLog()->all() as $item) {
+        $logs->push($item);
+      }
+
+      if (isset($entities->first()->create_at)) {
+        $entities = $entities->sortBy('create_at.value');
+      } else {
+        $entities = $entities->sortBy('id');
+      }
+
+      $data = collect([
+        'result' => $entities,
+        'logs' => $this->_api2Cart->getLog()->all()
+      ]);
+
+      $this->getOutput()->write($data->toJson());
+    } else {
+      $this->error('User not found');
+    }
+  }
+
+  /**
+   * @param array      $result            Result
+   * @param string     $resultEntityCount Result entity count field name
+   * @param string     $resultEntity      Result entity field name
+   * @param Collection $entities          Entities
+   * @param string     $cartId            Cart ID
+   *
+   * @return Collection
+   */
+  protected function _getEntities(
+    array $result, $resultEntityCount, $resultEntity, Collection $entities, string $cartId
+  ): Collection
+  {
+    $resEntities = (!empty($result['result'][$resultEntityCount]))
+      ? collect($result['result'][$resultEntity])
+      : collect([]);
+
+    if ($resEntities->count()) {
+      foreach ($resEntities as $item) {
+        $newItem = $item;
+        $newItem['create_at']['value'] = Carbon::parse($item['create_at']['value'])->setTimezone('UTC')->format("Y-m-d\TH:i:sO");
+        $newItem['cart_id'] = $cartId;
+        $entities->push($newItem);
+      }
+    }
+
+    return $entities;
+  }
+}

src/app/Console/Kernel.php

@@ -13,7 +13,7 @@ class Kernel extends ConsoleKernel
      * @var array
      */
     protected $commands = [
-        //
+      \App\Console\Commands\MakeRequest::class,
     ];
 
     /**

src/app/Http/Controllers/BusinessCases/OrdersShipmentsController.php

@@ -0,0 +1,67 @@
+<?php
+/*-----------------------------------------------------------------------------+
+ | MagneticOne                                                                  |
+ | Copyright (c) 2023 MagneticOne.com <[email protected]>                 |
+ | All rights reserved                                                          |
+ +------------------------------------------------------------------------------+
+ | PLEASE READ  THE FULL TEXT OF SOFTWARE LICENSE AGREEMENT IN THE "license.txt"|
+ | FILE PROVIDED WITH THIS DISTRIBUTION. THE AGREEMENT TEXT IS ALSO AVAILABLE   |
+ | AT THE FOLLOWING URL: http://www.magneticone.com/store/license.php           |
+ |                                                                              |
+ | THIS  AGREEMENT  EXPRESSES  THE  TERMS  AND CONDITIONS ON WHICH YOU MAY USE  |
+ | THIS SOFTWARE   PROGRAM   AND  ASSOCIATED  DOCUMENTATION   THAT  MAGNETICONE |
+ | (hereinafter  referred to as "THE AUTHOR") IS FURNISHING  OR MAKING          |
+ | AVAILABLE TO YOU WITH  THIS  AGREEMENT  (COLLECTIVELY,  THE  "SOFTWARE").    |
+ | PLEASE   REVIEW   THE  TERMS  AND   CONDITIONS  OF  THIS  LICENSE AGREEMENT  |
+ | CAREFULLY   BEFORE   INSTALLING   OR  USING  THE  SOFTWARE.  BY INSTALLING,  |
+ | COPYING   OR   OTHERWISE   USING   THE   SOFTWARE,  YOU  AND  YOUR  COMPANY  |
+ | (COLLECTIVELY,  "YOU")  ARE  ACCEPTING  AND AGREEING  TO  THE TERMS OF THIS  |
+ | LICENSE   AGREEMENT.   IF  YOU    ARE  NOT  WILLING   TO  BE  BOUND BY THIS  |
+ | AGREEMENT, DO  NOT INSTALL OR USE THE SOFTWARE.  VARIOUS   COPYRIGHTS   AND  |
+ | OTHER   INTELLECTUAL   PROPERTY   RIGHTS    PROTECT   THE   SOFTWARE.  THIS  |
+ | AGREEMENT IS A LICENSE AGREEMENT THAT GIVES  YOU  LIMITED  RIGHTS   TO  USE  |
+ | THE  SOFTWARE   AND  NOT  AN  AGREEMENT  FOR SALE OR FOR  TRANSFER OF TITLE. |
+ | THE AUTHOR RETAINS ALL RIGHTS NOT EXPRESSLY GRANTED BY THIS AGREEMENT.       |
+ |                                                                              |
+ | The Developer of the Code is MagneticOne,                                    |
+ | Copyright (C) 2006 - 2023 All Rights Reserved.                               |
+ +-----------------------------------------------------------------------------*/
+
+namespace App\Http\Controllers\BusinessCases;
+
+use App\Http\Controllers\Controller;
+use App\Jobs\MakeRequestToA2C;
+use App\Services\Api2Cart;
+use ShipmentsController;
+
+/**
+ * Date: 22.06.23 10:26
+ * @category
+ * @package
+ * @author   Taras Kubiv <[email protected]>
+ * @license  Not public license
+ * @link     https://www.api2cart.com
+ */
+
+class OrdersShipmentsController extends Controller
+{
+  private $_api2cart;
+
+ /**
+  * OrdersShipmentsController constructor.
+  *
+  * @param Api2Cart $api2Cart Api2Cart service
+  */
+  public function __construct(Api2Cart $api2Cart)
+  {
+    $this->_api2cart = $api2Cart;
+  }
+
+/**
+ * @return \Illuminate\Contracts\Foundation\Application|\Illuminate\Contracts\View\Factory|\Illuminate\View\View
+ */
+  public function index()
+  {
+    return view('business_cases.orders_shipments_controller.index');
+  }
+}