custom/plugins/UandiEfbErpSynchronization/src/Service/Api/SoapService.php line 83

Open in your IDE?
  1. <?php declare(strict_types=1);
  2. namespace Uandi\UandiEfbErpSynchronization\Service\Api;
  4. use Exception;
  5. use Monolog\Logger;
  6. use Shopware\Core\System\SystemConfig\SystemConfigService;
  7. use SoapFault;
  8. use Uandi\UandiEfbErpSynchronization\Service\Api\SoapClient as SoapClient;
  9. use Uandi\UandiEfbErpSynchronization\Service\ApiConnectionServiceInterface;
  11. class SoapService implements ApiConnectionServiceInterface
  12. {
  13.     private SystemConfigService $systemConfigService;
  14.     private Logger $logger;
  16.     public function __construct(SystemConfigService $systemConfigService, Logger $logger) {
  17.         $this->systemConfigService = $systemConfigService;
  18.         $this->logger = $logger;
  19.     }
  21.     /**
  22.      * Execute soap request
  23.      *
  24.      * @param array $request
  25.      * @param string|null $requestName
  26.      * @param string|null $salesChannelId
  27.      * @return array
  28.      */
  29.     public function execute(array $request = [], ?string $requestName = null, ?string $salesChannelId = null): array
  30.     {
  31.         try {
  32.             //encode the request array
  33.             $jsonRequest = json_encode($request);
  35.             // create ERP request
  36.             $client = $this->createConnection($salesChannelId);
  37.             $jsonResponse = $client->$requestName(["request_p" => $jsonRequest]);
  39.             $returnValue = $jsonResponse->return_value;
  40.             $responseArray = $this->jsonDecode($returnValue);
  42.             // handle/log the error response
  43.             if (isset($responseArray['error'])) {
  44.                 $this->logger->critical(
  45.                     sprintf(
  46.                         '%s: Request name: %s, Error code: %s, Error text: %s',
  47.                         __METHOD__,
  48.                         $requestName,
  49.                         $responseArray['error']['error_code'],
  50.                         $responseArray['error']['error_text']
  51.                     )
  52.                 );
  54.                 return ['request' => $request];
  55.             }
  57.             $responseArray['request'] = $request;
  59.             return $responseArray;
  61.         } catch (Exception $e) {
  62.             $this->logger->critical(
  63.                 sprintf(
  64.                     '%s, %s: %s, trace: %s',
  65.                     $request['customer_number'] ?? '',
  66.                     __METHOD__,
  67.                     $e->getMessage(),
  68.                     $e->getTraceAsString()
  69.                 )
  71.             );
  72.             return ['request' => $request];
  73.         }
  74.     }
  76.     /**
  77.      * Create connection to the ERP
  78.      *
  79.      * @param string|null $salesChannelId
  80.      * @return SoapClient
  81.      * @throws SoapFault
  82.      */
  83.     private function createConnection(?string $salesChannelId = null): SoapClient
  84.     {
  85.         $wsdl = $this->systemConfigService->get('UandiEfbErpSynchronization.config.soapApiEndpoint', $salesChannelId);
  86.         $user = $this->systemConfigService->get('UandiEfbErpSynchronization.config.soapApiUsername', $salesChannelId);
  87.         $password = $this->systemConfigService->get('UandiEfbErpSynchronization.config.soapApiPassword', $salesChannelId);
  89.         return new SoapClient(
  90.             $wsdl,
  91.             array('user' => $user, 'password' => $password)
  92.         );
  93.     }
  95.     /**
  96.      * Decodes json
  97.      *
  98.      * @param $json
  99.      *
  100.      * @return array
  101.      */
  102.     public function jsonDecode($json): array
  103.     {
  104.         $data = json_decode($json, true);
  106.         if (JSON_ERROR_NONE !== json_last_error()) {
  107.             $errorMessage['message'] = 'JSON is invalid';
  108.             $errorMessage['json_last_error_msg'] = json_last_error_msg();
  109.             $errorMessage['json'] = $json;
  110.             $this->logger->critical(sprintf('%s: error %s', __METHOD__, json_encode($errorMessage, JSON_PRETTY_PRINT)));
  111.         }
  113.         return $data === null ? [] : $data;
  114.     }
  115. }